coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-21 18:37:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

don't close immediately

Browse Source
This commit is contained in:
Cassandra Heart 2025-03-05 03:07:19 -06:00
parent 83073423c0
commit f8a9616f76
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 0 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
node/rpc/hypergraph_sync_rpc_server.go
View File

@ -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)