fix rollcall count

Signed-off-by: Derek Anderson <[email protected]>
blessnetwork · Feb 8, 2024 · 4dfd769 · 4dfd769
1 parent 6b6db44
commit 4dfd769
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/node/head_execute.go b/node/head_execute.go
@@ -70,7 +70,7 @@ func (n *Node) headProcessExecute(ctx context.Context, from peer.ID, payload []b
 func (n *Node) headExecute(ctx context.Context, requestID string, req execute.Request, subgroup string) (codes.Code, execute.ResultMap, execute.Cluster, error) {
 
 	nodeCount := -1
-	if req.Config.NodeCount > 1 {
+	if req.Config.NodeCount >= 1 {
 		nodeCount = req.Config.NodeCount
 	}
 

diff --git a/node/roll_call.go b/node/roll_call.go
@@ -148,7 +148,7 @@ rollCallResponseLoop:
 		case <-tctx.Done():
 
 			// -1 means we'll take any peers reporting
-			if (len(reportingPeers) > 1 && nodeCount == -1) {
+			if (len(reportingPeers) >= 1 && nodeCount == -1) {
 				log.Info().Msg("enough peers reported for roll call")
 				break rollCallResponseLoop
 			}