diff options
author | Péter Szilágyi <peterke@gmail.com> | 2017-01-09 22:58:23 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2017-01-09 22:58:23 +0800 |
commit | 681b51aac46fa11c235e9ac1af1228e0105a0720 (patch) | |
tree | ecbd5467a5f7356b2386189a67b8629663068cec /les/peer.go | |
parent | 4268cb8efecceaf506e1b0b71e06714a838a49a8 (diff) | |
parent | 66979aa468b6329aabf49542bd3db14e59010c20 (diff) | |
download | go-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.go | 4 |
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) } |