From 984f107eff4e5c384bd03f4c4e412b347b1b954c Mon Sep 17 00:00:00 2001 From: Metacertain Date: Mon, 7 Jun 2021 12:07:09 +0200 Subject: [PATCH] fix: delay concluding attempt --- pkg/pushsync/pushsync.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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()