@@ -2,24 +2,20 @@ package io.iohk.ethereum.network
2
2
3
3
import java .net .{InetSocketAddress , URI }
4
4
5
- import akka .actor .SupervisorStrategy .Stop
5
+ import akka .actor .SupervisorStrategy .Escalate
6
6
import io .iohk .ethereum .network .PeerManagerActor .PeerConfiguration
7
7
import akka .actor ._
8
- import akka .agent .Agent
9
- import akka .util .ByteString
10
8
import io .iohk .ethereum .network .p2p ._
11
9
import io .iohk .ethereum .network .p2p .messages .WireProtocol ._
12
10
import io .iohk .ethereum .network .p2p .messages .Versions
13
11
import io .iohk .ethereum .network .rlpx .{AuthHandshaker , RLPxConnectionHandler }
14
12
import io .iohk .ethereum .network .PeerActor .Status ._
15
13
import io .iohk .ethereum .network .PeerEventBusActor .PeerEvent .{MessageFromPeer , PeerHandshakeSuccessful }
16
14
import io .iohk .ethereum .network .PeerEventBusActor .Publish
17
- import io .iohk .ethereum .utils .NodeStatus
18
15
import io .iohk .ethereum .network .handshaker .Handshaker
19
16
import io .iohk .ethereum .network .handshaker .Handshaker .HandshakeComplete .{HandshakeFailure , HandshakeSuccess }
20
17
import io .iohk .ethereum .network .handshaker .Handshaker .{HandshakeResult , NextMessage }
21
18
import io .iohk .ethereum .network .rlpx .RLPxConnectionHandler .RLPxConfiguration
22
- import org .spongycastle .crypto .AsymmetricCipherKeyPair
23
19
import org .spongycastle .util .encoders .Hex
24
20
25
21
@@ -46,7 +42,7 @@ class PeerActor[R <: HandshakeResult](
46
42
47
43
override val supervisorStrategy : OneForOneStrategy =
48
44
OneForOneStrategy () {
49
- case _ => Stop
45
+ case _ => Escalate
50
46
}
51
47
52
48
def scheduler : Scheduler = externalSchedulerOpt getOrElse system.scheduler
0 commit comments