Remove schedulers, just hard-wire where needed

salesforce · Oct 24, 2023 · 74785ff · 74785ff
1 parent 3ab46bd
commit 74785ff
Show file tree

Hide file tree

Showing 29 changed files with 1,061 additions and 892 deletions.
diff --git a/choam/src/main/java/com/salesforce/apollo/choam/CHOAM.java b/choam/src/main/java/com/salesforce/apollo/choam/CHOAM.java
@@ -781,7 +781,7 @@ public void start() {
             return;
         }
         log.info("CHOAM startup, majority: {} on: {}", params.majority(), params.member().getId());
-        combine.start(params.producer().gossipDuration(), params.scheduler());
+        combine.start(params.producer().gossipDuration());
         transitions.fsm().enterStartState();
         transitions.start();
     }

diff --git a/choam/src/main/java/com/salesforce/apollo/choam/GenesisAssembly.java b/choam/src/main/java/com/salesforce/apollo/choam/GenesisAssembly.java
@@ -167,7 +167,7 @@ public void gather() {
         proposals.put(params().member().getId(), proposed);
 
         ds.setValue(join.toByteString());
-        coordinator.start(params().producer().gossipDuration(), params().scheduler());
+        coordinator.start(params().producer().gossipDuration());
         controller.start();
     }