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

Fixing stall issue in remote pipeline

Browse source
This commit is contained in:
Viktor Klang 2011-03-18 10:41:49 +01:00
parent 12b91edea5
commit 76f058edac
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -860,7 +860,7 @@ class RemoteServerHandler(
val actorInfo = request.getActorInfo val actorInfo = request.getActorInfo
val actorRef = val actorRef =
try { createActor(actorInfo, channel).start } catch { try { createActor(actorInfo, channel) } catch {
case e: SecurityException => case e: SecurityException =>
EventHandler notify EventHandler.Error(e, this) EventHandler notify EventHandler.Error(e, this)
write(channel, createErrorReplyMessage(e, request, AkkaActorType.ScalaActor)) write(channel, createErrorReplyMessage(e, request, AkkaActorType.ScalaActor))
@ -1031,7 +1031,7 @@ class RemoteServerHandler(
val actorRef = factory() val actorRef = factory()
actorRef.uuid = parseUuid(uuid) //FIXME is this sensible? actorRef.uuid = parseUuid(uuid) //FIXME is this sensible?
sessionActors.get(channel).put(id, actorRef) sessionActors.get(channel).put(id, actorRef)
actorRef actorRef.start //Start it where's it's created
} }
case sessionActor => sessionActor case sessionActor => sessionActor
} }
@ -1055,7 +1055,7 @@ class RemoteServerHandler(
actorRef.id = id actorRef.id = id
actorRef.timeout = timeout actorRef.timeout = timeout
server.actorsByUuid.put(actorRef.uuid.toString, actorRef) // register by uuid server.actorsByUuid.put(actorRef.uuid.toString, actorRef) // register by uuid
actorRef actorRef.start //Start it where it's created
} catch { } catch {
case e: Throwable => case e: Throwable =>
EventHandler notify EventHandler.Error(e, this) EventHandler notify EventHandler.Error(e, this)