Commit 303ac3af authored by Janoš Guljaš's avatar Janoš Guljaš Committed by GitHub

Revert "Disconnect on headers error (#333)" (#335)

This reverts commit abfa4187.
parent abfa4187
......@@ -285,8 +285,6 @@ func (s *Service) AddProtocol(p p2p.ProtocolSpec) (err error) {
// exchange headers
if err := handleHeaders(ss.Headler, stream); err != nil {
s.logger.Debugf("handle protocol %s/%s: stream %s: peer %s: handle headers: %v", p.Name, p.Version, ss.Name, overlay, err)
s.logger.Errorf("handle protocol %s/%s: peer %s", p.Name, p.Version, overlay)
_ = s.disconnect(peerID)
return
}
......@@ -442,8 +440,6 @@ func (s *Service) NewStream(ctx context.Context, overlay swarm.Address, headers
// exchange headers
if err := sendHeaders(ctx, headers, stream); err != nil {
s.logger.Debugf("send headers: returned error %s: %v", peerID, err)
_ = s.disconnect(peerID)
return nil, fmt.Errorf("send headers: %w", err)
}
......
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