Searched refs:ChunkForwardTsn (Results 1 – 7 of 7) sorted by relevance
25 pub(crate) struct ChunkForwardTsn { struct38 impl fmt::Display for ChunkForwardTsn { implementation50 impl Chunk for ChunkForwardTsn { implementation85 Ok(ChunkForwardTsn { in unmarshal()
200 let actual = ChunkForwardTsn::unmarshal(&binary)?; in test_chunk_forward_tsn_success()225 let result = ChunkForwardTsn::unmarshal(&binary); in test_chunk_forward_tsn_unmarshal_failure()711 if let Some(c) = pkt.chunks[0].as_any().downcast_ref::<ChunkForwardTsn>() { in test_forward_tsn_chunk()
171 let fwdtsn = ChunkForwardTsn { in test_handle_forward_tsn_forward_3unreceived_chunks()221 let fwdtsn = ChunkForwardTsn { in test_handle_forward_tsn_forward_1for1_missing()271 let fwdtsn = ChunkForwardTsn { in test_handle_forward_tsn_forward_1for2_missing()305 let fwdtsn = ChunkForwardTsn { in test_handle_forward_tsn_dup_forward_tsn_chunk_should_generate_sack()
7 use crate::chunk::chunk_forward_tsn::ChunkForwardTsn;127 CT_FORWARD_TSN => Box::new(ChunkForwardTsn::unmarshal(&raw.slice(offset..))?), in unmarshal()
1563 fn create_forward_tsn(&self) -> ChunkForwardTsn { in create_forward_tsn() argument1584 let mut fwd_tsn = ChunkForwardTsn { in create_forward_tsn()1639 async fn handle_forward_tsn(&mut self, c: &ChunkForwardTsn) -> Result<Vec<Packet>> { in handle_forward_tsn()2125 } else if let Some(c) = chunk_any.downcast_ref::<ChunkForwardTsn>() { in handle_chunk()
11 use crate::chunk::chunk_forward_tsn::{ChunkForwardTsn, ChunkForwardTsnStream};
2553 chunks: vec![Box::new(ChunkForwardTsn { in test_association_handle_packet_before_init()