Remove indices vec in recover()

mit-pdos · Nov 8, 2017 · 1a62618 · 1a62618
1 parent 6fbae6f
commit 1a62618
Showing 1 changed file with 6 additions and 12 deletions.
diff --git a/src/flow/mod.rs b/src/flow/mod.rs
@@ -509,21 +509,15 @@ impl ControllerInner {
     /// StartRecovery packet to each base node domain.
     pub fn recover(&mut self, _: ()) {
         info!(self.log, "Recovering from log");
-        let indices = self.inputs(())
-            .iter()
-            .map(|(_name, index)| {
-                let node = &self.ingredients[*index];
-                node.domain()
-            })
-            .collect::<Vec<_>>();
-
-        for index in indices.clone() {
-            let domain = self.domains.get_mut(&index).unwrap();
+        for (_name, index) in self.inputs(()).iter() {
+            let node = &self.ingredients[*index];
+            let domain = self.domains.get_mut(&node.domain()).unwrap();
             domain.send(box payload::Packet::StartRecovery).unwrap();
         }
 
-        for index in indices {
-            let domain = self.domains.get_mut(&index).unwrap();
+        for (_name, index) in self.inputs(()).iter() {
+            let node = &self.ingredients[*index];
+            let domain = self.domains.get_mut(&node.domain()).unwrap();
             domain.wait_for_ack().unwrap();
         }
     }