Commit 87de8da0 authored by Ralph Pichler's avatar Ralph Pichler Committed by GitHub

fix pushsync logs (#990)

parent 9c8de01d
...@@ -301,7 +301,7 @@ func (ps *PushSync) PushChunkToClosest(ctx context.Context, ch swarm.Chunk) (*Re ...@@ -301,7 +301,7 @@ func (ps *PushSync) PushChunkToClosest(ctx context.Context, ch swarm.Chunk) (*Re
streamer, err := ps.streamer.NewStream(ctx, peer, nil, protocolName, protocolVersion, streamName) streamer, err := ps.streamer.NewStream(ctx, peer, nil, protocolName, protocolVersion, streamName)
if err != nil { if err != nil {
lastErr = fmt.Errorf("new stream for peer %s: %w", peer.String(), err) lastErr = fmt.Errorf("new stream for peer %s: %w", peer.String(), err)
ps.logger.Debugf("pushsync-push: %w", lastErr) ps.logger.Debugf("pushsync-push: %v", lastErr)
continue continue
} }
deferFuncs = append(deferFuncs, func() { go streamer.FullClose() }) deferFuncs = append(deferFuncs, func() { go streamer.FullClose() })
...@@ -310,7 +310,7 @@ func (ps *PushSync) PushChunkToClosest(ctx context.Context, ch swarm.Chunk) (*Re ...@@ -310,7 +310,7 @@ func (ps *PushSync) PushChunkToClosest(ctx context.Context, ch swarm.Chunk) (*Re
if err := ps.sendChunkDelivery(ctx, w, ch); err != nil { if err := ps.sendChunkDelivery(ctx, w, ch); err != nil {
_ = streamer.Reset() _ = streamer.Reset()
lastErr = fmt.Errorf("chunk deliver to peer %s: %w", peer.String(), err) lastErr = fmt.Errorf("chunk deliver to peer %s: %w", peer.String(), err)
ps.logger.Debugf("pushsync-push: %w", lastErr) ps.logger.Debugf("pushsync-push: %v", lastErr)
if errors.Is(err, context.DeadlineExceeded) { if errors.Is(err, context.DeadlineExceeded) {
ps.blocklistPeer(peer) ps.blocklistPeer(peer)
} }
...@@ -331,7 +331,7 @@ func (ps *PushSync) PushChunkToClosest(ctx context.Context, ch swarm.Chunk) (*Re ...@@ -331,7 +331,7 @@ func (ps *PushSync) PushChunkToClosest(ctx context.Context, ch swarm.Chunk) (*Re
if err != nil { if err != nil {
_ = streamer.Reset() _ = streamer.Reset()
lastErr = fmt.Errorf("receive receipt from peer %s: %w", peer.String(), err) lastErr = fmt.Errorf("receive receipt from peer %s: %w", peer.String(), err)
ps.logger.Debugf("pushsync-push: %w", lastErr) ps.logger.Debugf("pushsync-push: %v", lastErr)
if errors.Is(err, context.DeadlineExceeded) { if errors.Is(err, context.DeadlineExceeded) {
ps.blocklistPeer(peer) ps.blocklistPeer(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