Lines Matching refs:c
8 fn sort_chunks_by_tsn(c: &mut [ChunkPayloadData]) { in sort_chunks_by_tsn()
9 c.sort_by(|a, b| { in sort_chunks_by_tsn()
18 fn sort_chunks_by_ssn(c: &mut [ChunkSet]) { in sort_chunks_by_ssn()
19 c.sort_by(|a, b| { in sort_chunks_by_ssn()
48 for c in &self.chunks { in push()
49 if c.tsn == chunk.tsn { in push()
87 for (i, c) in self.chunks.iter().enumerate() { in is_complete()
95 if c.tsn != last_tsn + 1 { in is_complete()
101 last_tsn = c.tsn; in is_complete()
190 for (i, c) in self.unordered_chunks.iter().enumerate() { in find_complete_unordered_chunk_set()
192 if c.beginning_fragment { in find_complete_unordered_chunk_set()
195 last_tsn = c.tsn; in find_complete_unordered_chunk_set()
197 if c.ending_fragment { in find_complete_unordered_chunk_set()
209 if c.tsn != last_tsn + 1 { in find_complete_unordered_chunk_set()
214 last_tsn = c.tsn; in find_complete_unordered_chunk_set()
217 if c.ending_fragment { in find_complete_unordered_chunk_set()
281 for c in &cset.chunks { in read()
282 let to_copy = c.user_data.len(); in read()
286 buf[n_written..n_written + n].copy_from_slice(&c.user_data[..n]); in read()
309 n + s.chunks.iter().fold(0, |acc, c| acc + c.user_data.len()) in forward_tsn_for_ordered()
329 for (i, c) in self.unordered_chunks.iter().enumerate() { in forward_tsn_for_unordered()
330 if sna32gt(c.tsn, new_cumulative_tsn) { in forward_tsn_for_unordered()