Skip to content

Commit b98d2e9

Browse files
holisticodenonsense
authored andcommitted
swarm/network/stream: Debug log instead of Warn for retrieval failure (#18246)
1 parent 92639b6 commit b98d2e9

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

swarm/network/stream/delivery.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,7 @@ const (
3939
var (
4040
processReceivedChunksCount = metrics.NewRegisteredCounter("network.stream.received_chunks.count", nil)
4141
handleRetrieveRequestMsgCount = metrics.NewRegisteredCounter("network.stream.handle_retrieve_request_msg.count", nil)
42+
retrieveChunkFail = metrics.NewRegisteredCounter("network.stream.retrieve_chunks_fail.count", nil)
4243

4344
requestFromPeersCount = metrics.NewRegisteredCounter("network.stream.request_from_peers.count", nil)
4445
requestFromPeersEachCount = metrics.NewRegisteredCounter("network.stream.request_from_peers_each.count", nil)
@@ -169,7 +170,8 @@ func (d *Delivery) handleRetrieveRequestMsg(ctx context.Context, sp *Peer, req *
169170
go func() {
170171
chunk, err := d.chunkStore.Get(ctx, req.Addr)
171172
if err != nil {
172-
log.Warn("ChunkStore.Get can not retrieve chunk", "peer", sp.ID().String(), "addr", req.Addr, "hopcount", req.HopCount, "err", err)
173+
retrieveChunkFail.Inc(1)
174+
log.Debug("ChunkStore.Get can not retrieve chunk", "peer", sp.ID().String(), "addr", req.Addr, "hopcount", req.HopCount, "err", err)
173175
return
174176
}
175177
if req.SkipCheck {

0 commit comments

Comments
 (0)