Lines Matching refs:head
88 let mut i = location.head; in too_old()
102 while i != location.head { in too_old()
123 (self.buffer[location.head as usize]) in fetch_timestamp()
148 match consume.compare(self.filled.head) { in purge_consumed_location()
150 self.release_packet(self.filled.head); in purge_consumed_location()
151 self.filled.head = self.filled.head.wrapping_add(1); in purge_consumed_location()
154 self.release_packet(self.filled.head); in purge_consumed_location()
155 self.filled.head = self.filled.head.wrapping_add(1); in purge_consumed_location()
174 if self.active.has_data() && (self.active.head == self.filled.head) { in purge_buffers()
188 self.active.head = self.active.head.wrapping_add(1); in purge_buffers()
191 self.release_packet(self.filled.head); in purge_buffers()
192 self.filled.head = self.filled.head.wrapping_add(1); in purge_buffers()
205 self.filled.head = sequence_number; in push()
209 self.filled.head = sequence_number; in push()
240 let mut i = self.active.head; in build_sample()
262 consume.head = self.active.head; in build_sample()
268 consume.head = self.active.head; in build_sample()
299 let head_payload = self.buffer[consume.head as usize] in build_sample()
320 self.active.head = consume.tail; in build_sample()
325 self.active.head = consume.tail; in build_sample()
329 let mut i = consume.head; in build_sample()
377 &mut self.prepared_samples[self.prepared.head as usize], in pop()
380 self.prepared.head = self.prepared.head.wrapping_add(1); in pop()