Skip to content

M
mybee
Commit 76d2016e authored by acud's avatar acud Committed by GitHub
Browse files
Options

retrieval: log less (#1523)

parent 685cf5d9
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 3 deletions
pkg/retrieval/retrieval.go
View file @ 76d2016e
...@@ -229,13 +229,11 @@ func (s *Service) retrieveChunk(ctx context.Context, addr swarm.Address, sp *ski ...@@ -229,13 +229,11 @@ func (s *Service) retrieveChunk(ctx context.Context, addr swarm.Address, sp *ski
} }
}() }()
returnedTarget, returnedPrice, returnedIndex, err := headerutils.ParsePricingResponseHeaders(returnedHeaders) _, returnedPrice, returnedIndex, err := headerutils.ParsePricingResponseHeaders(returnedHeaders)
if err != nil { if err != nil {
return nil, peer, fmt.Errorf("retrieval headers: read returned: %w", err) return nil, peer, fmt.Errorf("retrieval headers: read returned: %w", err)
} }
s.logger.Debugf("retrieval headers: returned target %v with price as %v, from peer %s", returnedTarget, returnedPrice, peer)
s.logger.Debugf("retrieval headers: original target %v with price as %v, from peer %s", addr, chunkPrice, peer)
// check if returned price matches presumed price, if not, update price // check if returned price matches presumed price, if not, update price
if returnedPrice != chunkPrice { if returnedPrice != chunkPrice {
err = s.pricer.NotifyPeerPrice(peer, returnedPrice, returnedIndex) // save priceHeaders["price"] corresponding row for peer err = s.pricer.NotifyPeerPrice(peer, returnedPrice, returnedIndex) // save priceHeaders["price"] corresponding row for peer
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment