Lines Matching refs:epoch
52 use crate::epoch::{AtomicEpoch, Epoch};
103 fn seal(self, epoch: Epoch) -> SealedBag { in seal()
104 SealedBag { epoch, bag: self } in seal()
218 epoch: Epoch, field
230 global_epoch.wrapping_sub(self.epoch) >= 2 in is_expired()
243 pub(crate) epoch: CachePadded<AtomicEpoch>, field
256 epoch: CachePadded::new(AtomicEpoch::new(Epoch::starting())), in new()
266 let epoch = self.epoch.load(Ordering::Relaxed); in push_bag() localVariable
267 self.queue.push(bag.seal(epoch), guard); in push_bag()
308 let global_epoch = self.epoch.load(Ordering::Relaxed); in try_advance()
323 let local_epoch = local.epoch.load(Ordering::Relaxed); in try_advance()
343 self.epoch.store(new_epoch, Ordering::Release); in try_advance()
354 epoch: AtomicEpoch, field
399 epoch: AtomicEpoch::new(Epoch::starting()), in register()
465 let global_epoch = self.global().epoch.load(Ordering::Relaxed); in pin()
486 let res = self.epoch.compare_exchange( in pin()
498 self.epoch.store(new_epoch, Ordering::Relaxed); in pin()
523 self.epoch.store(Epoch::starting(), Ordering::Release); in unpin()
538 let epoch = self.epoch.load(Ordering::Relaxed); in repin() localVariable
539 let global_epoch = self.global().epoch.load(Ordering::Relaxed).pinned(); in repin()
542 if epoch != global_epoch { in repin()
545 self.epoch.store(global_epoch, Ordering::Release); in repin()