diff options
| author | lash <nolash@users.noreply.github.com> | 2019-02-08 23:57:48 +0800 |
|---|---|---|
| committer | Rafael Matias <rafael@skyle.net> | 2019-02-19 20:09:09 +0800 |
| commit | 068725c5b09a49b32850a9c10707a86f07fde962 (patch) | |
| tree | 50e8fa47aa84e442e6116a1e4f4aa460dd3d7c79 /swarm/network/stream/stream.go | |
| parent | 710775f43574ca7bdd039abb7474f34a4e4fe9fd (diff) | |
| download | go-tangerine-068725c5b09a49b32850a9c10707a86f07fde962.tar go-tangerine-068725c5b09a49b32850a9c10707a86f07fde962.tar.gz go-tangerine-068725c5b09a49b32850a9c10707a86f07fde962.tar.bz2 go-tangerine-068725c5b09a49b32850a9c10707a86f07fde962.tar.lz go-tangerine-068725c5b09a49b32850a9c10707a86f07fde962.tar.xz go-tangerine-068725c5b09a49b32850a9c10707a86f07fde962.tar.zst go-tangerine-068725c5b09a49b32850a9c10707a86f07fde962.zip | |
swarm/network, swarm/storage: Preserve opentracing contexts (#19022)
(cherry picked from commit 0c10d376066cb7e57d3bfc03f950c7750cd90640)
Diffstat (limited to 'swarm/network/stream/stream.go')
| -rw-r--r-- | swarm/network/stream/stream.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/swarm/network/stream/stream.go b/swarm/network/stream/stream.go index e06048053..ee4f57c1a 100644 --- a/swarm/network/stream/stream.go +++ b/swarm/network/stream/stream.go @@ -359,7 +359,7 @@ func (r *Registry) Subscribe(peerId enode.ID, s Stream, h *Range, priority uint8 } log.Debug("Subscribe ", "peer", peerId, "stream", s, "history", h) - return peer.SendPriority(context.TODO(), msg, priority) + return peer.SendPriority(context.TODO(), msg, priority, "") } func (r *Registry) Unsubscribe(peerId enode.ID, s Stream) error { @@ -730,7 +730,8 @@ func (c *client) batchDone(p *Peer, req *OfferedHashesMsg, hashes []byte) error if err != nil { return err } - if err := p.SendPriority(context.TODO(), tp, c.priority); err != nil { + + if err := p.SendPriority(context.TODO(), tp, c.priority, ""); err != nil { return err } if c.to > 0 && tp.Takeover.End >= c.to { |