Abort instead of Close

hyperledger-labs · Nov 2, 2020 · a94e6b0 · a94e6b0
1 parent a44ed7f
commit a94e6b0
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/scala/scorex/core/network/PeerConnectionHandler.scala b/src/main/scala/scorex/core/network/PeerConnectionHandler.scala
@@ -124,7 +124,7 @@ class PeerConnectionHandler(val settings: NetworkSettings,
       reportStrangeInput
 
   private def fatalCommands: Receive = {
-    case _: ConnectionClosed =>
+    case _: ConnectionClosed  =>
       log.info(s"Connection closed to $connectionId")
       context stop self
   }
@@ -144,7 +144,7 @@ class PeerConnectionHandler(val settings: NetworkSettings,
     case CloseConnection =>
       log.info(s"Enforced to abort communication with: " + connectionId + ", switching to closing mode")
       pushAllWithNoAck()
-      connection ! Close
+      connection ! Abort
 
     case ReceivableMessages.Ack(_) => // ignore ACKs in stable mode
 
@@ -178,7 +178,7 @@ class PeerConnectionHandler(val settings: NetworkSettings,
     case CloseConnection =>
       log.info(s"Enforced to abort communication with: " + connectionId + s", switching to closing mode")
       pushAllWithNoAck()
-      connection ! Close
+      connection ! Abort
   }
 
   def remoteInterface: Receive = {