diff --git a/pkg/pushsync/pushsync.go b/pkg/pushsync/pushsync.go index 18332aeba57..7fd0c434752 100644 --- a/pkg/pushsync/pushsync.go +++ b/pkg/pushsync/pushsync.go @@ -429,7 +429,7 @@ func (ps *PushSync) pushPeer(ctx context.Context, peer swarm.Address, ch swarm.C streamer, err := ps.streamer.NewStream(ctx, peer, nil, protocolName, protocolVersion, streamName) if err != nil { - return nil, true, fmt.Errorf("new stream for peer %s: %w", peer, err) + return nil, false, fmt.Errorf("new stream for peer %s: %w", peer, err) } defer streamer.Close() @@ -440,7 +440,7 @@ func (ps *PushSync) pushPeer(ctx context.Context, peer swarm.Address, ch swarm.C Stamp: stamp, }); err != nil { _ = streamer.Reset() - return nil, true, fmt.Errorf("chunk %s deliver to peer %s: %w", ch.Address(), peer, err) + return nil, false, fmt.Errorf("chunk %s deliver to peer %s: %w", ch.Address(), peer, err) } ps.metrics.TotalSent.Inc()