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

Eliminated KickStartDone and using ChannelRegistered

Browse source
This commit is contained in:
Endre Sándor Varga 2013-02-05 13:26:27 +01:00
parent 3505a7e76b
commit 78a9e81a6b
10 changed files with 37 additions and 35 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-actor/src/main/scala/akka/io/SelectionHandler.scala
View file

@ -44,10 +44,9 @@ abstract class SelectionHandlerSettings(config: Config) {
private[io] object SelectionHandler {
case class WorkerForCommand(apiCommand: HasFailureMessage, commander: ActorRef, childProps: Props)
// FIXME: all actors should listen to this
case object WorkerForCommandDone
case class RegisterChannel(channel: SelectableChannel, initialOps: Int)
case object ChannelRegistered
case class Retry(command: WorkerForCommand, retriesLeft: Int) { require(retriesLeft >= 0) }
case object ChannelConnectable
@ -79,7 +78,7 @@ private[io] class SelectionHandler(manager: ActorRef, settings: SelectionHandler
case cmd: WorkerForCommand ⇒
// FIXME: factor out to common
withCapacityProtection(cmd, SelectorAssociationRetries) { spawnChild(cmd.childProps) ! WorkerForCommandDone }
withCapacityProtection(cmd, SelectorAssociationRetries) { spawnChild(cmd.childProps) }
case RegisterChannel(channel, initialOps) ⇒
execute(registerChannel(channel, sender, initialOps))
@ -88,7 +87,7 @@ private[io] class SelectionHandler(manager: ActorRef, settings: SelectionHandler
commander ! cmd.failureMessage
case Retry(cmd, retriesLeft) ⇒
withCapacityProtection(cmd, retriesLeft) { spawnChild(cmd.childProps) ! WorkerForCommandDone }
withCapacityProtection(cmd, retriesLeft) { spawnChild(cmd.childProps) }
case Terminated(child) ⇒
execute(unregister(child))
@ -144,6 +143,7 @@ private[io] class SelectionHandler(manager: ActorRef, settings: SelectionHandler
new Task {
def tryRun() {
updateKeyMap(channelActor, channel.register(selector, initialOps, channelActor))
channelActor ! ChannelRegistered
}
}