Searched refs:cset (Results 1 – 2 of 2) sorted by relevance
151 self.unordered.push(cset); in push()174 let ok = cset.push(chunk); in push()175 self.ordered.push(cset); in push()248 let cset = &self.ordered[0]; in is_readable() localVariable249 if cset.is_complete() && sna16lte(cset.ssn, self.next_ssn) { in is_readable()262 let cset = &self.ordered[0]; in read() localVariable263 if !cset.is_complete() { in read()266 if sna16gt(cset.ssn, self.next_ssn) { in read()269 if cset.ssn == self.next_ssn { in read()281 for c in &cset.chunks { in read()[all …]
928 let cset = ChunkSet::new(0, PayloadProtocolIdentifier::default()); in test_chunk_set_empty_chunk_set() localVariable929 assert!(!cset.is_complete(), "empty chunkSet cannot be complete"); in test_chunk_set_empty_chunk_set()935 let mut cset = ChunkSet::new(0, PayloadProtocolIdentifier::default()); in test_chunk_set_push_dup_chunks_to_chunk_set() localVariable936 cset.push(ChunkPayloadData { in test_chunk_set_push_dup_chunks_to_chunk_set()941 let complete = cset.push(ChunkPayloadData { in test_chunk_set_push_dup_chunks_to_chunk_set()947 assert_eq!(cset.chunks.len(), 1, "chunk with dup TSN should be ignored"); in test_chunk_set_push_dup_chunks_to_chunk_set()953 let cset = ChunkSet { in test_chunk_set_incomplete_chunk_set_no_beginning() localVariable959 !cset.is_complete(), in test_chunk_set_incomplete_chunk_set_no_beginning()967 let cset = ChunkSet { in test_chunk_set_incomplete_chunk_set_no_contiguous_tsn() localVariable988 !cset.is_complete(), in test_chunk_set_incomplete_chunk_set_no_contiguous_tsn()