diff --git a/src/trace/implementations/spine_fueled.rs b/src/trace/implementations/spine_fueled.rs index ba737293b..f3b61ec94 100644 --- a/src/trace/implementations/spine_fueled.rs +++ b/src/trace/implementations/spine_fueled.rs @@ -210,11 +210,14 @@ where Some((CursorList::new(cursors, &storage), storage)) } + #[inline] fn set_logical_compaction(&mut self, frontier: AntichainRef) { self.logical_frontier.clear(); self.logical_frontier.extend(frontier.iter().cloned()); } + #[inline] fn get_logical_compaction(&mut self) -> AntichainRef { self.logical_frontier.borrow() } + #[inline] fn set_physical_compaction(&mut self, frontier: AntichainRef) { // We should never request to rewind the frontier. debug_assert!(PartialOrder::less_equal(&self.physical_frontier.borrow(), &frontier), "FAIL\tthrough frontier !<= new frontier {:?} {:?}\n", self.physical_frontier, frontier); @@ -222,8 +225,10 @@ where self.physical_frontier.extend(frontier.iter().cloned()); self.consider_merges(); } + #[inline] fn get_physical_compaction(&mut self) -> AntichainRef { self.physical_frontier.borrow() } + #[inline] fn map_batches(&self, mut f: F) { for batch in self.merging.iter().rev() { match batch { diff --git a/src/trace/mod.rs b/src/trace/mod.rs index fc340e432..6e411475e 100644 --- a/src/trace/mod.rs +++ b/src/trace/mod.rs @@ -160,6 +160,7 @@ pub trait TraceReader { /// Reads the upper frontier of committed times. /// /// + #[inline] fn read_upper(&mut self, target: &mut Antichain) where Self::Time: Timestamp, diff --git a/src/trace/wrappers/rc.rs b/src/trace/wrappers/rc.rs index b31f8779e..508521b8d 100644 --- a/src/trace/wrappers/rc.rs +++ b/src/trace/wrappers/rc.rs @@ -61,12 +61,14 @@ where } } /// Replaces elements of `lower` with those of `upper`. + #[inline] pub fn adjust_logical_compaction(&mut self, lower: AntichainRef, upper: AntichainRef) { self.logical_compaction.update_iter(upper.iter().cloned().map(|t| (t,1))); self.logical_compaction.update_iter(lower.iter().cloned().map(|t| (t,-1))); self.trace.set_logical_compaction(self.logical_compaction.frontier()); } /// Replaces elements of `lower` with those of `upper`. + #[inline] pub fn adjust_physical_compaction(&mut self, lower: AntichainRef, upper: AntichainRef) { self.physical_compaction.update_iter(upper.iter().cloned().map(|t| (t,1))); self.physical_compaction.update_iter(lower.iter().cloned().map(|t| (t,-1))); @@ -177,4 +179,4 @@ where self.logical_compaction = Antichain::new(); self.physical_compaction = Antichain::new(); } -} \ No newline at end of file +}