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

fix broken rename of nanoTimeOfLastSend

Browse source
This commit is contained in:
Patrik Nordwall 2013-01-04 13:07:56 +01:00
parent 27acfcf5e1
commit f876d921ff
1 changed files with 10 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-remote-tests/src/main/scala/akka/remote/testconductor/Player.scala
View file

@ -52,12 +52,16 @@ trait Player { this: TestConductorExt ⇒
val a = system.actorOf(Props(new Actor {
var waiting: ActorRef = _
def receive = {
case fsm: ActorRef ⇒ waiting = sender; fsm ! SubscribeTransitionCallBack(self)
case fsm: ActorRef ⇒
waiting = sender; fsm ! SubscribeTransitionCallBack(self)
case Transition(_, Connecting, AwaitDone) ⇒ // step 1, not there yet
case Transition(_, AwaitDone, Connected) ⇒ waiting ! Done; context stop self
case t: Transition[_] ⇒ waiting ! Status.Failure(new RuntimeException("unexpected transition: " + t)); context stop self
case CurrentState(_, Connected) ⇒ waiting ! Done; context stop self
case _: CurrentState[_] ⇒
case Transition(_, AwaitDone, Connected) ⇒
waiting ! Done; context stop self
case t: Transition[_] ⇒
waiting ! Status.Failure(new RuntimeException("unexpected transition: " + t)); context stop self
case CurrentState(_, Connected) ⇒
waiting ! Done; context stop self
case _: CurrentState[_] ⇒
}
}))
@ -218,7 +222,7 @@ private[akka] class ClientFSM(name: RoleName, controllerAddr: InetSocketAddress)
else if (t.rateMBit == 0.0f) Blackhole
// Conversion needed as the TokenBucket measures in octets: 125000 Octets/s = 1Mbit/s
// FIXME: Initial capacity should be carefully chosen
else TokenBucket(capacity = 1000, tokensPerSecond = t.rateMBit * 125000.0, lastSend = 0, availableTokens = 0)
else TokenBucket(capacity = 1000, tokensPerSecond = t.rateMBit * 125000.0, nanoTimeOfLastSend = 0, availableTokens = 0)
val cmdFuture = TestConductor().transport.managementCommand(SetThrottle(t.target, t.direction, mode))