Return the state with new round after phase1b

r0qs · Jun 24, 2016 · dd6ba08 · dd6ba08
1 parent a7ff6c4
commit dd6ba08
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/main/scala/cfabcast/agents/Acceptor.scala b/src/main/scala/cfabcast/agents/Acceptor.scala
@@ -65,11  65,13 @@ trait Acceptor extends ActorLogging {
     if (oldState.rnd < msg.rnd && (msg.rnd.coordinator contains actorSender)) {
       val newState = oldState.copy(rnd = msg.rnd)
       actorSender ! Msg1B(id, msg.instance, newState.rnd, newState.vrnd, newState.vval)
       //FIXME: return newstate was not specified in protocol, but round needs to be updated
       return newState
     } else {
       log.warning("INSTANCE: {} - {} PHASE1B message round: {} < state rnd: {}", msg.instance, id, msg.rnd, oldState.rnd)
       actorSender ! UpdateRound(msg.instance, oldState.rnd)
     }
-    oldState
     return oldState
   }
 
   def acceptorBehavior(config: ClusterConfiguration, instances: Map[Instance, Future[AcceptorMeta]])(implicit ec: ExecutionContext): Receive = {