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

Fixed deadlock in RemoteClient shutdown after reconnection timeout

Browse source
This commit is contained in:
Jonas Bonér 2010-08-23 14:33:49 +02:00
parent 55766c21e5
commit 5154235fae
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-core/src/main/scala/remote/RemoteClient.scala
View file

@ -10,7 +10,7 @@ import se.scalablesolutions.akka.dispatch.{DefaultCompletableFuture, Completable
import se.scalablesolutions.akka.util.{ListenerManagement, UUID, Logging, Duration}
import se.scalablesolutions.akka.config.Config._
import se.scalablesolutions.akka.AkkaException
import Actor._
import org.jboss.netty.channel._
import group.DefaultChannelGroup
import org.jboss.netty.channel.socket.nio.NioClientSocketChannelFactory
@ -399,7 +399,7 @@ class RemoteClientHandler(
}
}
}, RemoteClient.RECONNECT_DELAY.toMillis, TimeUnit.MILLISECONDS)
} else client.shutdown
} else spawn { client.shutdown }
}
override def channelConnected(ctx: ChannelHandlerContext, event: ChannelStateEvent) = {