p2p/discv5: fixed talkResponse send condition

This commit is contained in:
Zsolt Felfoldi 2019-12-08 20:19:18 +01:00
parent 91b69d08da
commit 936328ff68

View file

@ -1372,7 +1372,7 @@ func (q *talkQuery) start(net *Network) bool {
if q.remote == net.tab.self { if q.remote == net.tab.self {
return false return false
} }
if q.remote.state.canQuery { if q.remote.state == known {
net.talkResponseSubLock.Lock() net.talkResponseSubLock.Lock()
hash := net.conn.send(q.remote, talkRequestPacket, talkRequest{TalkID: []byte(q.talkID), Payload: q.payload}) hash := net.conn.send(q.remote, talkRequestPacket, talkRequest{TalkID: []byte(q.talkID), Payload: q.payload})
q.key = string(q.remote.sha[:]) + string(hash[:]) q.key = string(q.remote.sha[:]) + string(hash[:])