More debug output
This commit is contained in:
		| @@ -121,6 +121,7 @@ impl<B> Recv<B> where B: Buf { | |||||||
|                                  stream: &mut store::Ptr<B>) |                                  stream: &mut store::Ptr<B>) | ||||||
|         -> Result<(), ConnectionError> |         -> Result<(), ConnectionError> | ||||||
|     { |     { | ||||||
|  |         trace!("opening stream; init_window={}", self.init_window_sz); | ||||||
|         let is_initial = stream.state.recv_open(self.init_window_sz, frame.is_end_stream())?; |         let is_initial = stream.state.recv_open(self.init_window_sz, frame.is_end_stream())?; | ||||||
|  |  | ||||||
|         if is_initial { |         if is_initial { | ||||||
|   | |||||||
| @@ -79,7 +79,7 @@ impl<B> Send<B> where B: Buf { | |||||||
|                         stream: &mut store::Ptr<B>) |                         stream: &mut store::Ptr<B>) | ||||||
|         -> Result<(), ConnectionError> |         -> Result<(), ConnectionError> | ||||||
|     { |     { | ||||||
|         trace!("send_headers; frame={:?}", frame); |         trace!("send_headers; frame={:?}; init_window={:?}", frame, self.init_window_sz); | ||||||
|         // Update the state |         // Update the state | ||||||
|         stream.state.send_open(self.init_window_sz, frame.is_end_stream())?; |         stream.state.send_open(self.init_window_sz, frame.is_end_stream())?; | ||||||
|  |  | ||||||
|   | |||||||
		Reference in New Issue
	
	Block a user