diff --git a/protocol/connections/engine.go b/protocol/connections/engine.go index 72c7d97..2e58c62 100644 --- a/protocol/connections/engine.go +++ b/protocol/connections/engine.go @@ -122,7 +122,7 @@ func (e *engine) eventHandler() { case event.BlockPeer: e.blocked.Store(ev.Data[event.RemotePeer], true) connection, err := e.service.GetConnection(ev.Data[event.RemotePeer]) - if err != nil { + if connection != nil && err == nil { connection.Close() } case event.ProtocolEngineStartListen: