Lines Matching refs:consume
144 fn purge_consumed_location(&mut self, consume: &SampleSequenceLocation, force_consume: bool) { in purge_consumed_location()
148 match consume.compare(self.filled.head) { in purge_consumed_location()
238 let mut consume = SampleSequenceLocation::new(); in build_sample() localVariable
262 consume.head = self.active.head; in build_sample()
263 consume.tail = i.wrapping_add(1); in build_sample()
268 consume.head = self.active.head; in build_sample()
269 consume.tail = i; in build_sample()
275 if consume.empty() { in build_sample()
279 if !purging_buffers && self.buffer[consume.tail as usize].is_none() { in build_sample()
290 for i in consume.tail..self.active.tail { in build_sample()
299 let head_payload = self.buffer[consume.head as usize] in build_sample()
306 let is_padding = consume.range(&self.buffer).all(|p| { in build_sample()
313 self.dropped_packets += consume.count(); in build_sample()
315 self.padding_packets += consume.count(); in build_sample()
317 self.purge_consumed_location(&consume, true); in build_sample()
320 self.active.head = consume.tail; in build_sample()
321 return Err(BuildError::InvalidParition(consume)); in build_sample()
325 self.active.head = consume.tail; in build_sample()
329 let mut i = consume.head; in build_sample()
330 while i != consume.tail { in build_sample()
362 self.purge_consumed_location(&consume, true); in build_sample()
365 Ok(consume) in build_sample()