comments

sled-agent/src/instance_manager.rs

@@ -286,6 +286,7 @@ impl InstanceManager {
         rx.await?
     }
 
+    /// Returns the last-set size of the reservoir
     pub fn reservoir_size(&self) -> ByteCount {
         self.inner.vmm_reservoir_manager.reservoir_size()
     }

sled-agent/src/vmm_reservoir.rs

@@ -239,15 +239,14 @@ impl VmmReservoirManager {
         let log = log.new(o!("component" => "VmmReservoirManager"));
         // We use a rendevous channel to only allow one request at a time.
         // Resizing a reservoir may block the thread for up to two minutes, so
-        // we want to ensure, it is complete before allowing another call.
+        // we want to ensure it is complete before allowing another call.
         let (tx, rx) = flume::bounded(0);
         let reservoir_size = Arc::new(AtomicU64::new(0));
         let manager = VmmReservoirManager {
             reservoir_size: reservoir_size.clone(),
             rx,
             log,
         };
-
         let _manager_handle = thread::spawn(move || {
             manager.run(hardware_manager, reservoir_mode)
         });