mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-18 18:02:24 +00:00
swarm/network/stream: better request subscription error message
This commit is contained in:
parent
746d1d6a54
commit
83e5a535ad
1 changed files with 3 additions and 2 deletions
|
|
@ -302,9 +302,10 @@ func (r *Registry) Run(p *network.BzzPeer) error {
|
||||||
// a := val.(network.OverlayPeer)
|
// a := val.(network.OverlayPeer)
|
||||||
log.Debug(fmt.Sprintf("Requesting subscription by: registry %s from peer %s for bin: %d", r.addr.ID(), p.ID(), bin))
|
log.Debug(fmt.Sprintf("Requesting subscription by: registry %s from peer %s for bin: %d", r.addr.ID(), p.ID(), bin))
|
||||||
|
|
||||||
err = r.RequestSubscription(p.ID(), NewStream("SYNC", []byte{uint8(bin)}, true), &Range{}, Top)
|
stream := NewStream("SYNC", []byte{uint8(bin)}, true)
|
||||||
|
err = r.RequestSubscription(p.ID(), stream, &Range{}, Top)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error(fmt.Sprintf("Error in RequestSubsciption! %v", err))
|
log.Error("request subscription", "err", err, "peer", p.ID(), "stream", stream)
|
||||||
return false
|
return false
|
||||||
}
|
}
|
||||||
return true
|
return true
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue