forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/network: chunk delivery span

Browse source
This commit is contained in:
Anton Evangelatov 2019-03-11 15:36:30 +01:00
parent db28927cce
commit 32933036a7
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
swarm/network/stream/delivery.go
View file

@ -217,6 +217,10 @@ type ChunkDeliveryMsgSyncing ChunkDeliveryMsg
// chunk delivery msg is response to retrieverequest msg // chunk delivery msg is response to retrieverequest msg
func (d *Delivery) handleChunkDeliveryMsg(ctx context.Context, sp *Peer, req *ChunkDeliveryMsg) error { 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) processReceivedChunksCount.Inc(1)
@ -225,6 +229,8 @@ func (d *Delivery) handleChunkDeliveryMsg(ctx context.Context, sp *Peer, req *Ch
span := tracing.ShiftSpanByKey(spanId) span := tracing.ShiftSpanByKey(spanId)
go func() { go func() {
defer osp.Finish()
if span != nil { if span != nil {
span.LogFields(olog.String("finish", "from handleChunkDeliveryMsg")) span.LogFields(olog.String("finish", "from handleChunkDeliveryMsg"))
defer span.Finish() defer span.Finish()