Searched defs:frame (Results 1 – 14 of 14) sorted by relevance
382 let frame = self.try_retrieve_current_frame()?; in encode_headers_frame() localVariable468 let frame = self.try_retrieve_current_frame()?; in encode_headers_payload() localVariable487 let frame = self.try_retrieve_current_frame()?; in encode_continuation_frames() localVariable533 let frame = self.try_retrieve_current_frame()?; in encode_data_header() localVariable605 let frame = self.try_retrieve_current_frame()?; in encode_data_payload() localVariable629 let frame = self.try_retrieve_current_frame()?; in encode_padding() localVariable659 let frame = self.try_retrieve_current_frame()?; in encode_goaway_frame() localVariable716 let frame = self.try_retrieve_current_frame()?; in encode_goaway_payload() localVariable769 let frame = self.try_retrieve_current_frame()?; in encode_window_update_frame() localVariable833 let frame = self.try_retrieve_current_frame()?; in encode_window_update_payload() localVariable[all …]
56 mod frame; module
397 let frame = match self.header.frame_type { in decode_frame_payload() localVariable586 let frame = Frame::new( in decode_settings_payload() localVariable606 let frame = Frame::new( in decode_data_payload() localVariable628 let frame = Frame::new( in decode_data_payload() localVariable651 let frame = if self.continuations.promised_stream_id != 0 { in decode_continuation_payload() localVariable712 let frame = Frame::new( in decode_headers_payload() localVariable778 let frame = Frame::new( in push_promise_framing() localVariable
19 mod frame; module
512 let frame = Frame::new( in decode_data_payload() localVariable522 let frame = Frame::new( in decode_data_payload() localVariable552 let frame = match self.curr_frame_type() { in get_qpack_decoded_header() localVariable626 let frame = in decode_variable_payload() localVariable631 let frame = Frame::new( in decode_variable_payload() localVariable638 let frame = Frame::new( in decode_variable_payload() localVariable703 let frame = Frame::new(SETTINGS_FRAME_TYPE, Payload::Settings(settings)); in decode_settings_payload() localVariable
505 let frame = self in encode_cancel_push() localVariable
123 let frame = Frame::new(id, FrameFlags::new(0), Payload::WindowUpdate(window_update)); in check_window_update() localVariable325 let frame = rw.check_window_update(1); in ut_rw_check_window_update() localVariable328 let frame = rw.check_window_update(1); in ut_rw_check_window_update() localVariable
98 let frame = fc.check_conn_recv_window_update(); in ut_fc_check_conn_recv_window_update() localVariable
77 let frame = match sender.poll_recv_frame(cx) { in poll() localVariable93 let frame = if let SettingState::Ack = state { in poll() localVariable
561 let frame = Frame::new(id, FrameFlags::empty(), Payload::RstStream(rest_payload)); in manage_stream_error() localVariable607 let frame = Frame::new( in manage_conn_error() localVariable647 let frame = Frame::new( in poll_deal_with_go_away() localVariable
62 let frame = conn.recv_resp().await?; in request() localVariable
73 let frame = conn.receiver.recv().await?; in request() localVariable
534 let frame = match kind { in recv_request_stream() localVariable
696 let frame = Frame::new( in poll_blocked_message() localVariable