From 32933036a73e593fe2f6c6947891499f2142f050 Mon Sep 17 00:00:00 2001 From: Anton Evangelatov Date: Mon, 11 Mar 2019 15:36:30 +0100 Subject: [PATCH] swarm/network: chunk delivery span --- swarm/network/stream/delivery.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/swarm/network/stream/delivery.go b/swarm/network/stream/delivery.go index eef690ff9f..f503204ffd 100644 --- a/swarm/network/stream/delivery.go +++ b/swarm/network/stream/delivery.go @@ -217,6 +217,10 @@ type ChunkDeliveryMsgSyncing ChunkDeliveryMsg // chunk delivery msg is response to retrieverequest msg func (d *Delivery) handleChunkDeliveryMsg(ctx context.Context, sp *Peer, req *ChunkDeliveryMsg) error { + var osp opentracing.Span + ctx, osp = spancontext.StartSpan( + ctx, + "handle.chunk.delivery") processReceivedChunksCount.Inc(1) @@ -225,6 +229,8 @@ func (d *Delivery) handleChunkDeliveryMsg(ctx context.Context, sp *Peer, req *Ch span := tracing.ShiftSpanByKey(spanId) go func() { + defer osp.Finish() + if span != nil { span.LogFields(olog.String("finish", "from handleChunkDeliveryMsg")) defer span.Finish()