diff --git a/accord-maelstrom/src/main/java/accord/maelstrom/Cluster.java b/accord-maelstrom/src/main/java/accord/maelstrom/Cluster.java index 8fb34489fd..2d7e1e5c72 100644 --- a/accord-maelstrom/src/main/java/accord/maelstrom/Cluster.java +++ b/accord-maelstrom/src/main/java/accord/maelstrom/Cluster.java @@ -39,7 +39,11 @@ import java.util.function.LongSupplier; import java.util.function.Supplier; +import accord.api.Agent; +import accord.api.DataStore; +import accord.api.LocalListeners; import accord.api.MessageSink; +import accord.api.ProgressLog; import accord.api.Scheduler; import accord.api.LocalConfig; import accord.coordinate.CoordinationAdapter; @@ -50,9 +54,12 @@ import accord.impl.DefaultRemoteListeners; import accord.impl.SizeOfIntersectionSorter; import accord.local.AgentExecutor; +import accord.local.CommandStore; +import accord.local.CommandStores; import accord.local.DurableBefore; import accord.local.Node; import accord.local.Node.Id; +import accord.local.NodeCommandStoreService; import accord.local.ShardDistributor; import accord.local.TimeService; import accord.messages.Callback; @@ -65,6 +72,7 @@ import accord.utils.RandomSource; import accord.utils.async.AsyncChains; import accord.utils.async.AsyncResult; +import accord.utils.async.AsyncResults; import static accord.local.TimeService.elapsedWrapperFromNonMonotonicSource; import static java.util.stream.Collectors.toList; @@ -352,7 +360,7 @@ public static void run(Id[] nodes, QueueSupplier queueSupplier, Consumer AsyncResult startup = AsyncChains.reduce(lookup.values().stream().map(Node::unsafeStart).collect(toList()), (a, b) -> null).beginAsResult(); while (sinks.processPending()); - if (!startup.isDone()) throw new AssertionError(); + while (!startup.isDone()); List nodesList = new ArrayList<>(Arrays.asList(nodes)); sinks.recurring(() -> diff --git a/accord-maelstrom/src/main/java/accord/maelstrom/Datum.java b/accord-maelstrom/src/main/java/accord/maelstrom/Datum.java index 90f93e087a..110a88755c 100644 --- a/accord-maelstrom/src/main/java/accord/maelstrom/Datum.java +++ b/accord-maelstrom/src/main/java/accord/maelstrom/Datum.java @@ -158,7 +158,7 @@ public boolean equals(Object that) public boolean equals(Datum that) { - return this.kind.equals(that.kind) && this.value.equals(that.value); + return this.kind.equals(that.kind) && Objects.equals(this.value, that.value); } @Override