Searched refs:goaway (Results 1 – 3 of 3) sorted by relevance
729 if let Payload::Goaway(goaway) = frame.payload() { in encode_goaway_payload()730 let payload_size = goaway.encoded_len(); in encode_goaway_payload()735 self.iterate_goaway_payload(goaway, buf, bytes_to_write)?; in encode_goaway_payload()752 goaway: &Goaway, in iterate_goaway_payload()761 *buf_item = (goaway.get_last_stream_id() in iterate_goaway_payload()768 (goaway.get_error_code() >> (24 - (8 * error_code_byte_index))) as u8; in iterate_goaway_payload()772 if debug_data_index < goaway.get_debug_data().len() { in iterate_goaway_payload()773 *buf_item = goaway.get_debug_data()[debug_data_index]; in iterate_goaway_payload()
492 let goaway = Frame::new( in decode_goaway_payload() localVariable497 Ok(FrameKind::Complete(goaway)) in decode_goaway_payload()1499 Payload::Goaway(goaway) => { in ut_decode_goaway_payload()1500 assert_eq!(goaway.get_last_stream_id(), 1); in ut_decode_goaway_payload()1501 assert_eq!(goaway.get_error_code(), 2); in ut_decode_goaway_payload()1502 assert_eq!(goaway.get_debug_data(), b"debug"); in ut_decode_goaway_payload()
403 let go_away = if let Payload::Goaway(goaway) = frame.payload() { in recv_go_away_frame()404 goaway in recv_go_away_frame()