|
|
|
@ -39,6 +39,7 @@ const ( |
|
|
|
|
var ( |
|
|
|
|
processReceivedChunksCount = metrics.NewRegisteredCounter("network.stream.received_chunks.count", nil) |
|
|
|
|
handleRetrieveRequestMsgCount = metrics.NewRegisteredCounter("network.stream.handle_retrieve_request_msg.count", nil) |
|
|
|
|
retrieveChunkFail = metrics.NewRegisteredCounter("network.stream.retrieve_chunks_fail.count", nil) |
|
|
|
|
|
|
|
|
|
requestFromPeersCount = metrics.NewRegisteredCounter("network.stream.request_from_peers.count", nil) |
|
|
|
|
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 * |
|
|
|
|
go func() { |
|
|
|
|
chunk, err := d.chunkStore.Get(ctx, req.Addr) |
|
|
|
|
if err != nil { |
|
|
|
|
log.Warn("ChunkStore.Get can not retrieve chunk", "peer", sp.ID().String(), "addr", req.Addr, "hopcount", req.HopCount, "err", err) |
|
|
|
|
retrieveChunkFail.Inc(1) |
|
|
|
|
log.Debug("ChunkStore.Get can not retrieve chunk", "peer", sp.ID().String(), "addr", req.Addr, "hopcount", req.HopCount, "err", err) |
|
|
|
|
return |
|
|
|
|
} |
|
|
|
|
if req.SkipCheck { |
|
|
|
|