Inline functions frequently called from Materialize

src/trace/implementations/spine_fueled.rs

@@ -210,20 +210,25 @@ where
 
         Some((CursorList::new(cursors, &storage), storage))
     }
+    #[inline]
     fn set_logical_compaction(&mut self, frontier: AntichainRef<B::Time>) {
         self.logical_frontier.clear();
         self.logical_frontier.extend(frontier.iter().cloned());
     }
+    #[inline]
     fn get_logical_compaction(&mut self) -> AntichainRef<B::Time> { self.logical_frontier.borrow() }
+    #[inline]
     fn set_physical_compaction(&mut self, frontier: AntichainRef<B::Time>) {
         // 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);
         self.physical_frontier.clear();
         self.physical_frontier.extend(frontier.iter().cloned());
         self.consider_merges();
     }
+    #[inline]
     fn get_physical_compaction(&mut self) -> AntichainRef<B::Time> { self.physical_frontier.borrow() }
 
+    #[inline]
     fn map_batches<F: FnMut(&Self::Batch)>(&self, mut f: F) {
         for batch in self.merging.iter().rev() {
             match batch {

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<Self::Time>)
     where
         Self::Time: Timestamp,

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<Tr::Time>, upper: AntichainRef<Tr::Time>) {
         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<Tr::Time>, upper: AntichainRef<Tr::Time>) {
         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();
     }
-}
+}