aboutsummaryrefslogtreecommitdiffstats
path: root/swarm/network/stream/messages.go
diff options
context:
space:
mode:
authorlash <nolash@users.noreply.github.com>2019-02-20 21:50:37 +0800
committerViktor TrĂ³n <viktor.tron@gmail.com>2019-02-20 21:50:37 +0800
commitd36e974ba303d12d79d769d0811dd5babcf6688f (patch)
tree22073c5ae7d6e0b243ed7f4bed4ed9aae054a116 /swarm/network/stream/messages.go
parent460d206f309fc0884c666bd191a1b6a4b63462fc (diff)
downloadgo-tangerine-d36e974ba303d12d79d769d0811dd5babcf6688f.tar
go-tangerine-d36e974ba303d12d79d769d0811dd5babcf6688f.tar.gz
go-tangerine-d36e974ba303d12d79d769d0811dd5babcf6688f.tar.bz2
go-tangerine-d36e974ba303d12d79d769d0811dd5babcf6688f.tar.lz
go-tangerine-d36e974ba303d12d79d769d0811dd5babcf6688f.tar.xz
go-tangerine-d36e974ba303d12d79d769d0811dd5babcf6688f.tar.zst
go-tangerine-d36e974ba303d12d79d769d0811dd5babcf6688f.zip
swarm/network: Keep span across roundtrip (#19140)
* swarm/newtork: WIP Span request span until delivery and put * swarm/storage: Introduce new trace across single fetcher lifespan * swarm/network: Put span ids for sendpriority in context value * swarm: Add global span store in tracing * swarm/tracing: Add context key constants * swarm/tracing: Add comments * swarm/storage: Remove redundant fix for filestore * swarm/tracing: Elaborate constants comments * swarm/network, swarm/storage, swarm:tracing: Minor cleanup
Diffstat (limited to 'swarm/network/stream/messages.go')
-rw-r--r--swarm/network/stream/messages.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/swarm/network/stream/messages.go b/swarm/network/stream/messages.go
index de4e8a3bb..b293724cc 100644
--- a/swarm/network/stream/messages.go
+++ b/swarm/network/stream/messages.go
@@ -300,7 +300,7 @@ func (p *Peer) handleOfferedHashesMsg(ctx context.Context, req *OfferedHashesMsg
return
}
log.Trace("sending want batch", "peer", p.ID(), "stream", msg.Stream, "from", msg.From, "to", msg.To)
- err := p.SendPriority(ctx, msg, c.priority, "")
+ err := p.SendPriority(ctx, msg, c.priority)
if err != nil {
log.Warn("SendPriority error", "err", err)
}