diff --git a/swarm/network/stream/delivery.go b/swarm/network/stream/delivery.go index 01ae7f9435..eef690ff9f 100644 --- a/swarm/network/stream/delivery.go +++ b/swarm/network/stream/delivery.go @@ -185,6 +185,7 @@ func (d *Delivery) handleRetrieveRequestMsg(ctx context.Context, sp *Peer, req * if err != nil { log.Warn("ERROR in handleRetrieveRequestMsg", "err", err) } + osp.LogFields(olog.Bool("delivered", true)) return } osp.LogFields(olog.Bool("skipCheck", false)) diff --git a/swarm/network/stream/peer.go b/swarm/network/stream/peer.go index 152814bd4f..bbfc5a2b47 100644 --- a/swarm/network/stream/peer.go +++ b/swarm/network/stream/peer.go @@ -154,7 +154,7 @@ func (p *Peer) Deliver(ctx context.Context, chunk storage.Chunk, priority uint8, } ctx = context.WithValue(ctx, "stream_send_tag", nil) - return p.SendPriority(ctx, msg, priority) + return p.Send(ctx, msg) } // SendPriority sends message to the peer using the outgoing priority queue