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

Fixing ticket #603

Browse source
This commit is contained in:
Viktor Klang 2011-01-05 11:43:49 +01:00
parent fff4109cb5
commit f0e9732b7f
1 changed files with 3 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

5
akka-remote/src/main/scala/akka/remote/netty/NettyRemoteSupport.scala
View file

@ -171,7 +171,7 @@ abstract class RemoteClient private[akka] (
isOneWay: Boolean,
actorRef: ActorRef,
typedActorInfo: Option[Tuple2[String, String]],
actorType: AkkaActorType): Option[CompletableFuture[T]] = {
actorType: AkkaActorType): Option[CompletableFuture[T]] = synchronized { //TODO: find better strategy to prevent race
send(createRemoteMessageProtocolBuilder(
Some(actorRef),
Left(actorRef.uuid),
@ -811,7 +811,7 @@ class RemoteServerHandler(
val typedSessionActors = new ChannelLocal[ConcurrentHashMap[String, AnyRef]]()
//Writes the specified message to the specified channel and propagates write errors to listeners
private def write(channel: Channel, message: AnyRef): Unit =
private def write(channel: Channel, message: AnyRef): Unit = {
channel.write(message).addListener(
new ChannelFutureListener {
def operationComplete(future: ChannelFuture): Unit = {
@ -826,6 +826,7 @@ class RemoteServerHandler(
}
}
})
}
/**
* ChannelOpen overridden to store open channels for a clean postStop of a node.