Skip to content

Commit 229271e

Browse files
committed
fix(headers): reduce diff
1 parent 0c4e215 commit 229271e

File tree

1 file changed

+0
-2
lines changed

1 file changed

+0
-2
lines changed

pkg/p2p/libp2p/libp2p.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -359,7 +359,6 @@ func New(ctx context.Context, signer beecrypto.Signer, networkID uint64, overlay
359359
return nil, fmt.Errorf("protocol version match %s: %w", id, err)
360360
}
361361

362-
// Handshake protocol NEVER exchanges headers - capabilities are unknown at this point
363362
s.host.SetStreamHandlerMatch(id, matcher, s.handleIncoming)
364363

365364
connMetricNotify := newConnMetricNotify(s.metrics)
@@ -411,7 +410,6 @@ func (s *Service) handleIncoming(stream network.Stream) {
411410
}
412411

413412
peerID := stream.Conn().RemotePeer()
414-
// Handshake stream NEVER has headers - capabilities are unknown at this point
415413
handshakeStream := newStream(stream, s.metrics)
416414
i, err := s.handshakeService.Handle(s.ctx, handshakeStream, stream.Conn().RemoteMultiaddr(), peerID)
417415
if err != nil {

0 commit comments

Comments
 (0)