commit
4ce9ffdf5a
@ -77,10 +77,6 @@ func (s *BaseDrpcServer) serve(ctx context.Context, lis net.Listener) {
|
|||||||
}
|
}
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
if herr, ok := err.(secureservice.HandshakeError); ok {
|
|
||||||
l.Warn("listener handshake error", zap.Error(herr), zap.String("remoteAddr", herr.RemoteAddr()))
|
|
||||||
continue
|
|
||||||
}
|
|
||||||
l.Error("listener accept error", zap.Error(err))
|
l.Error("listener accept error", zap.Error(err))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
@ -98,6 +94,7 @@ func (s *BaseDrpcServer) serveConn(conn net.Conn) {
|
|||||||
ctx, conn, err = s.handshake(conn)
|
ctx, conn, err = s.handshake(conn)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
l.Info("handshake error", zap.Error(err))
|
l.Info("handshake error", zap.Error(err))
|
||||||
|
return
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user