fixup! feat: don't block on sending on a full channel in primary

MystenLabs · Aug 8, 2022 · ff03272 · ff03272
1 parent 147e92d
commit ff03272
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/primary/src/header_waiter.rs b/primary/src/header_waiter.rs
@@ -314,10 +314,8 @@ impl HeaderWaiter {
                     match message {
                         ReconfigureNotification::NewEpoch(new_committee) => {
                             // Update the committee and cleanup internal state.
-                            self.primary_network
-                            .cleanup(self.committee.network_diff(&committee));
-                            self.worker_network
-                                .cleanup(self.committee.network_diff(&committee));
+                            self.primary_network.cleanup(self.committee.network_diff(&new_committee));
+                            self.worker_network.cleanup(self.committee.network_diff(&new_committee));
 
                             self.committee = new_committee;