aboutsummaryrefslogtreecommitdiffstats
path: root/les/peer.go
diff options
context:
space:
mode:
authorPéter Szilágyi <peterke@gmail.com>2017-01-09 22:58:23 +0800
committerGitHub <noreply@github.com>2017-01-09 22:58:23 +0800
commit681b51aac46fa11c235e9ac1af1228e0105a0720 (patch)
treeecbd5467a5f7356b2386189a67b8629663068cec /les/peer.go
parent4268cb8efecceaf506e1b0b71e06714a838a49a8 (diff)
parent66979aa468b6329aabf49542bd3db14e59010c20 (diff)
downloadgo-tangerine-681b51aac46fa11c235e9ac1af1228e0105a0720.tar
go-tangerine-681b51aac46fa11c235e9ac1af1228e0105a0720.tar.gz
go-tangerine-681b51aac46fa11c235e9ac1af1228e0105a0720.tar.bz2
go-tangerine-681b51aac46fa11c235e9ac1af1228e0105a0720.tar.lz
go-tangerine-681b51aac46fa11c235e9ac1af1228e0105a0720.tar.xz
go-tangerine-681b51aac46fa11c235e9ac1af1228e0105a0720.tar.zst
go-tangerine-681b51aac46fa11c235e9ac1af1228e0105a0720.zip
Merge pull request #3519 from zsfelfoldi/light-topic5
les: fixed selectPeer deadlock, improved request distribution
Diffstat (limited to 'les/peer.go')
-rw-r--r--les/peer.go4
1 files changed, 3 insertions, 1 deletions
diff --git a/les/peer.go b/les/peer.go
index 8d4a83f59..d5008ded1 100644
--- a/les/peer.go
+++ b/les/peer.go
@@ -241,7 +241,9 @@ func (p *peer) RequestHeaderProofs(reqID, cost uint64, reqs []*ChtReq) error {
func (p *peer) SendTxs(cost uint64, txs types.Transactions) error {
glog.V(logger.Debug).Infof("%v relaying %v txs", p, len(txs))
- p.fcServer.SendRequest(0, cost)
+ reqID := getNextReqID()
+ p.fcServer.MustAssignRequest(reqID)
+ p.fcServer.SendRequest(reqID, cost)
return p2p.Send(p.rw, SendTxMsg, txs)
}