From f8a9616f76e8dcff3d71329d2ed9388b0ce1955b Mon Sep 17 00:00:00 2001 From: Cassandra Heart Date: Wed, 5 Mar 2025 03:07:19 -0600 Subject: [PATCH] don't close immediately --- node/rpc/hypergraph_sync_rpc_server.go | 4 ---- 1 file changed, 4 deletions(-) diff --git a/node/rpc/hypergraph_sync_rpc_server.go b/node/rpc/hypergraph_sync_rpc_server.go index 7c6aeac..5c3be4a 100644 --- a/node/rpc/hypergraph_sync_rpc_server.go +++ b/node/rpc/hypergraph_sync_rpc_server.go @@ -767,7 +767,6 @@ func syncTreeBidirectionallyServer( msg, err := stream.Recv() if err == io.EOF { logger.Info("received disconnect") - close(backpressure) close(incomingQueriesIn) close(incomingResponsesIn) close(incomingLeavesIn) @@ -775,7 +774,6 @@ func syncTreeBidirectionallyServer( } if err != nil { logger.Info("received error", zap.Error(err)) - close(backpressure) close(incomingQueriesIn) close(incomingResponsesIn) close(incomingLeavesIn) @@ -976,14 +974,12 @@ func SyncTreeBidirectionally( for { msg, err := stream.Recv() if err == io.EOF { - close(backpressure) close(incomingQueriesIn) close(incomingResponsesIn) close(incomingLeavesIn) return } if err != nil { - close(backpressure) close(incomingQueriesIn) close(incomingResponsesIn) close(incomingLeavesIn)