Peernet-Archive/core
1
0
Fork 0
mirror of https://github.com/PeernetOfficial/core.git synced 2026-07-17 02:47:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

Fix race condition in cmdResponse.

Browse Source
This commit is contained in:
Kleissner
2021-05-06 14:54:28 +02:00
parent e929d6ba2f
commit eb0afce3f9
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Commands.go
View File

@@ -148,7 +148,7 @@ func (peer *PeerInfo) cmdResponse(msg *MessageResponse) {
}
for _, hash2Peer := range msg.Hash2Peers {
info.ResultChan <- &dht.NodeMessage{SenderID: peer.NodeID, Closest: records2Nodes(hash2Peer.Closest, msg.connection.Network), Storing: records2Nodes(hash2Peer.Storing, msg.connection.Network)}
info.QueueResult(&dht.NodeMessage{SenderID: peer.NodeID, Closest: records2Nodes(hash2Peer.Closest, msg.connection.Network), Storing: records2Nodes(hash2Peer.Storing, msg.connection.Network)})
if hash2Peer.IsLast {
info.Done()
@@ -156,7 +156,7 @@ func (peer *PeerInfo) cmdResponse(msg *MessageResponse) {
}
for _, file := range msg.FilesEmbed {
info.ResultChan <- &dht.NodeMessage{SenderID: peer.NodeID, Data: file.Data}
info.QueueResult(&dht.NodeMessage{SenderID: peer.NodeID, Data: file.Data})
info.Done()
info.Terminate() // file was found, terminate the request.