coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-03-05 00:07:33 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

switch to using unbuffered channel for queued requests

Browse Source
This commit is contained in:
Cassandra Heart 2025-02-15 03:33:14 -06:00
parent 24282dd690
commit 1100fcadd6
No known key found for this signature in database
GPG Key ID: 6352152859385958
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
node/rpc/hypergraph_sync_rpc_server.go
View File

@ -321,8 +321,10 @@ func syncTreeBidirectionallyServer(
return err
}
pendingQueries := make(chan []int32, 10000)
pendingQueries <- rootPath
pendingQueries := make(chan []int32)
go func(path []int32) {
pendingQueries <- path
}(rootPath)
incoming := make(chan *protobufs.HypergraphComparison, 10000)
go func() {
@ -458,7 +460,9 @@ func syncTreeBidirectionallyServer(
append([]int32(nil), remoteInfo.Path...),
remoteChild.Index,
)
pendingQueries <- newPath
go func(path []int32) {
pendingQueries <- path
}(newPath)
}
}
}
@ -604,8 +608,10 @@ func SyncTreeBidirectionally(
return err
}
pendingQueries := make(chan []int32, 10000)
pendingQueries <- []int32{}
pendingQueries := make(chan []int32)
go func(path []int32) {
pendingQueries <- path
}([]int32{})
incoming := make(chan *protobufs.HypergraphComparison, 10000)
go func() {
@ -730,7 +736,9 @@ func SyncTreeBidirectionally(
append([]int32(nil), remoteInfo.Path...),
remoteChild.Index,
)
pendingQueries <- newPath
go func(path []int32) {
pendingQueries <- path
}(newPath)
}
}
}