Lines Matching refs:p
27 pub(crate) fn can_push(&self, p: &ChunkPayloadData, cumulative_tsn: u32) -> bool { in can_push()
28 !(self.chunk_map.contains_key(&p.tsn) || sna32lte(p.tsn, cumulative_tsn)) in can_push()
31 pub(crate) fn push_no_check(&mut self, p: ChunkPayloadData) { in push_no_check()
32 let tsn = p.tsn; in push_no_check()
33 self.n_bytes += p.user_data.len(); in push_no_check()
34 self.chunk_map.insert(tsn, p); in push_no_check()
63 pub(crate) fn push(&mut self, p: ChunkPayloadData, cumulative_tsn: u32) -> bool { in push()
64 let ok = self.chunk_map.contains_key(&p.tsn); in push()
65 if ok || sna32lte(p.tsn, cumulative_tsn) { in push()
67 self.dup_tsn.push(p.tsn); in push()
71 self.push_no_check(p); in push()