mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-20 10:52:25 +00:00
swarm/network: add log for SkipCheck
This commit is contained in:
parent
2cfd8f0d8e
commit
6e7af784dc
1 changed files with 3 additions and 0 deletions
|
|
@ -179,12 +179,15 @@ func (d *Delivery) handleRetrieveRequestMsg(ctx context.Context, sp *Peer, req *
|
||||||
}
|
}
|
||||||
if req.SkipCheck {
|
if req.SkipCheck {
|
||||||
syncing := false
|
syncing := false
|
||||||
|
osp.LogFields(olog.Bool("skipCheck", true))
|
||||||
|
|
||||||
err = sp.Deliver(ctx, chunk, s.priority, syncing)
|
err = sp.Deliver(ctx, chunk, s.priority, syncing)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Warn("ERROR in handleRetrieveRequestMsg", "err", err)
|
log.Warn("ERROR in handleRetrieveRequestMsg", "err", err)
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
osp.LogFields(olog.Bool("skipCheck", false))
|
||||||
select {
|
select {
|
||||||
case streamer.deliveryC <- chunk.Address()[:]:
|
case streamer.deliveryC <- chunk.Address()[:]:
|
||||||
case <-streamer.quit:
|
case <-streamer.quit:
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue