Fix build

This commit is contained in:
Carl Lerche
2017-08-09 14:17:55 -07:00
parent dfec401fdf
commit a8c8cdb8e9
3 changed files with 5 additions and 3 deletions

View File

@@ -63,12 +63,14 @@ impl FlowControl {
// TODO: Handle invalid increment // TODO: Handle invalid increment
if sz <= self.underflow { if sz <= self.underflow {
self.underflow -= sz; self.underflow -= sz;
return; return Ok(());
} }
let added = sz - self.underflow; let added = sz - self.underflow;
self.next_window_update += added; self.next_window_update += added;
self.underflow = 0; self.underflow = 0;
Ok(())
} }
/* /*

View File

@@ -48,7 +48,7 @@ impl<B> Prioritize<B>
self.flow_control.expand_window(frame.size_increment())?; self.flow_control.expand_window(frame.size_increment())?;
// Imediately apply the update // Imediately apply the update
self.flow.apply_window_update(); self.flow_control.apply_window_update();
Ok(()) Ok(())
} }

View File

@@ -184,7 +184,7 @@ impl<B> Send<B> where B: Buf {
pub fn recv_connection_window_update(&mut self, frame: frame::WindowUpdate) pub fn recv_connection_window_update(&mut self, frame: frame::WindowUpdate)
-> Result<(), ConnectionError> -> Result<(), ConnectionError>
{ {
self.priority.recv_window_update(frame)?; self.prioritize.recv_window_update(frame)?;
// TODO: If there is available connection capacity, release pending // TODO: If there is available connection capacity, release pending
// streams. // streams.