raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=act cleanup state parameters in TcpOutgoingConnection

Browse source 
Backport of c480208f56
This commit is contained in:
Johannes Rudolph 2013-11-23 10:25:16 +01:00
parent c35988de2c
commit aac7e7ad4a
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

7
akka-actor/src/main/scala/akka/io/TcpOutgoingConnection.scala
View file

@ -55,13 +55,12 @@ private[io] class TcpOutgoingConnection(_tcp: TcpExt,
completeConnect(registration, commander, options)
else {
registration.enableInterest(SelectionKey.OP_CONNECT)
context.become(connecting(registration, commander, options, tcp.Settings.FinishConnectRetries))
context.become(connecting(registration, tcp.Settings.FinishConnectRetries))
}
}
}
def connecting(registration: ChannelRegistration, commander: ActorRef,
options: immutable.Traversable[SocketOption], remainingFinishConnectRetries: Int): Receive = {
def connecting(registration: ChannelRegistration, remainingFinishConnectRetries: Int): Receive = {
{
case ChannelConnectable ⇒
reportConnectFailure {
@ -74,7 +73,7 @@ private[io] class TcpOutgoingConnection(_tcp: TcpExt,
context.system.scheduler.scheduleOnce(1.millisecond) {
channelRegistry.register(channel, SelectionKey.OP_CONNECT)
}(context.dispatcher)
context.become(connecting(registration, commander, options, remainingFinishConnectRetries - 1))
context.become(connecting(registration, remainingFinishConnectRetries - 1))
} else {
log.debug("Could not establish connection because finishConnect " +
"never returned true (consider increasing akka.io.tcp.finish-connect-retries)")