frugalos · koba-e964 · Dec 18, 2019 · Dec 6, 2019
diff --git a/frugalos_segment/src/queue_executor/repair_queue_executor.rs b/frugalos_segment/src/queue_executor/repair_queue_executor.rs
@@ -88,6 +88,13 @@ impl RepairQueueExecutor {
             self.enqueued_repair.increment();
         }
     }
+    /// Deletes an element from this queue.
+    /// This is typically called for deleted objects.
+    pub(crate) fn delete(&mut self, version: ObjectVersion) {
+        if self.queue.remove(&version) {
+            self.dequeued_repair.increment();
+        }
+    }
     fn pop(&mut self) -> Option<ObjectVersion> {
         // Pick the minimum element, if queue is not empty.
         let result = self.queue.iter().next().copied();

diff --git a/frugalos_segment/src/synchronizer.rs b/frugalos_segment/src/synchronizer.rs
@@ -118,8 +118,9 @@ impl Synchronizer {
                 Event::Putted { .. } => {
                     self.general_queue.push(event);
                 }
-                Event::Deleted { .. } => {
+                Event::Deleted { version, .. } => {
                     self.general_queue.push(event);
+                    self.repair_queue.delete(version);
                 }
                 // Because pushing FullSync into the task queue causes difficulty in implementation,
                 // we decided not to push this task to the task priority queue and handle it manually.