From 4533a2b76a95b577e3ddd091a0ec8b58f63fc147 Mon Sep 17 00:00:00 2001 From: Anton Evangelatov Date: Thu, 7 Mar 2019 17:09:55 +0100 Subject: [PATCH] swarm/network: propagate span with ctx --- swarm/network/stream/peer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/swarm/network/stream/peer.go b/swarm/network/stream/peer.go index 1d3868a66b..0f14727432 100644 --- a/swarm/network/stream/peer.go +++ b/swarm/network/stream/peer.go @@ -160,7 +160,7 @@ func (p *Peer) Deliver(ctx context.Context, chunk storage.Chunk, priority uint8, // SendPriority sends message to the peer using the outgoing priority queue func (p *Peer) SendPriority(ctx context.Context, msg interface{}, priority uint8) error { defer metrics.GetOrRegisterResettingTimer(fmt.Sprintf("peer.sendpriority_t.%d", priority), nil).UpdateSince(time.Now()) - tracing.StartSaveSpan(ctx) + ctx = tracing.StartSaveSpan(ctx) metrics.GetOrRegisterCounter(fmt.Sprintf("peer.sendpriority.%d", priority), nil).Inc(1) wmsg := WrappedPriorityMsg{ Context: ctx,