status-im
/
torrent
mirror of
2
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

dht.Server.query: Return nil Transaction if there's an error

This commit is contained in:
Matt Joiner 2016-05-17 16:07:49 +10:00
parent 2ca76cfea8
commit 95bb8a5eb3
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
dht/server.go
View File

@ -446,7 +446,7 @@ func (s *Server) query(node Addr, q string, a map[string]interface{}, onResponse
if err != nil {
return
}
t = &Transaction{
_t := &Transaction{
remoteAddr: node,
t: tid,
response: make(chan Msg, 1),
@ -455,15 +455,16 @@ func (s *Server) query(node Addr, q string, a map[string]interface{}, onResponse
s: s,
onResponse: onResponse,
}
err = t.sendQuery()
err = _t.sendQuery()
if err != nil {
return
}
s.getNode(node, "").lastSentQuery = time.Now()
t.mu.Lock()
t.startTimer()
t.mu.Unlock()
s.addTransaction(t)
_t.mu.Lock()
_t.startTimer()
_t.mu.Unlock()
s.addTransaction(_t)
t = _t
return
}