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

WIP separate prio artery channel (#21278)

Browse source 
* First incorrect stab - separate prio channel

* Send prio messages over the control stream
This commit is contained in:
Johan Andrén 2016-08-26 14:44:33 +02:00 • committed by Patrik Nordwall
parent 51bb330d2f
commit af5eb4c6bf
5 changed files with 64 additions and 41 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-remote/src/main/scala/akka/remote/RemoteActorRefProvider.scala
View file

@ -458,9 +458,10 @@ private[akka] trait RemoteRef extends ActorRefScope {
/**
* INTERNAL API
*/
private[remote] sealed abstract class LargeMessageDestinationFlag
private[remote] case object RegularDestination extends LargeMessageDestinationFlag
private[remote] case object LargeDestination extends LargeMessageDestinationFlag
private[remote] sealed abstract class MessageDestinationFlag
private[remote] case object RegularDestination extends MessageDestinationFlag
private[remote] case object LargeDestination extends MessageDestinationFlag
private[remote] case object PriorityDestination extends MessageDestinationFlag
/**
* INTERNAL API
@ -486,8 +487,8 @@ private[akka] class RemoteActorRef private[akka] (
}
@volatile private[remote] var cachedAssociation: artery.Association = null
// used by artery to direct messages to a separate stream for large messages
@volatile private[remote] var cachedLargeMessageDestinationFlag: LargeMessageDestinationFlag = null
// used by artery to direct messages to separate specialized streams
@volatile private[remote] var cachedMessageDestinationFlag: MessageDestinationFlag = null
def getChild(name: Iterator[String]): InternalActorRef = {
val s = name.toStream