server: immediately return to caller when processing sendToPeer
This commit alters the logic of processing sendToPeer requests within the server to immediately return to the caller after locating the target peer.
This commit is contained in:
1 file changed
+2
-2
@@ -640,11 +640,11 @@ out:
|
|||||||
}
|
}
|
||||||
s.peersMtx.RUnlock()
|
s.peersMtx.RUnlock()
|
||||||
|
|
||||||
|
sMsg.errChan <- nil
|
||||||
|
|
||||||
for _, msg := range sMsg.msgs {
|
for _, msg := range sMsg.msgs {
|
||||||
targetPeer.queueMsg(msg, nil)
|
targetPeer.queueMsg(msg, nil)
|
||||||
}
|
}
|
||||||
|
|
||||||
sMsg.errChan <- nil
|
|
||||||
}()
|
}()
|
||||||
case query := <-s.queries:
|
case query := <-s.queries:
|
||||||
switch msg := query.(type) {
|
switch msg := query.(type) {
|
||||||
|
|||||||
Reference in new issue
Block a user