fixed epoch

Author: GusevTimofey

src/main/scala/mvp2/actors/Planner.scala

@@ -31,7 +31,6 @@ class Planner(settings: Settings) extends CommonActor {
   val networker: ActorSelection = context.system.actorSelection("/user/starter/blockchainer/networker")
   var scheduleForWriting: List[ByteString] = List()
   var hasWritten: Boolean = false
-  var needToCheckTimeToPublish: Boolean = true
 
   override def specialBehavior: Receive = {
     case SyncingDone =>
@@ -60,7 +59,6 @@ class Planner(settings: Settings) extends CommonActor {
   def syncedNode: Receive = {
     case keyBlock: KeyBlock =>
       nextPeriod = Period(keyBlock, settings)
-      needToCheckTimeToPublish = true
       lastBlock = keyBlock
       epoch = epoch.dropNextPublisherPublicKey
       if (lastBlock.scheduler.nonEmpty) hasWritten = true
@@ -88,10 +86,9 @@ class Planner(settings: Settings) extends CommonActor {
       logger.info(s"Current public keys: ${allPublicKeys.map(EncodingUtils.encode2Base16).mkString(",")}")
       scheduleForWriting = epoch.schedule
       checkMyTurn(scheduleForWriting)
-    case Tick if nextPeriod.timeToPublish && needToCheckTimeToPublish =>
+    case Tick if nextPeriod.timeToPublish =>
       logger.info(s"nextPeriod.timeToPublish. Height of last block is: ${lastBlock.height}")
       checkMyTurn(scheduleForWriting)
-      needToCheckTimeToPublish = false
       logger.info(s"Current epoch is: $epoch. Height of last block is: ${lastBlock.height}")
       logger.info(s"Current public keys: ${allPublicKeys.map(EncodingUtils.encode2Base16).mkString(",")}")
       checkScheduleUpdateTime()
@@ -104,7 +101,6 @@ class Planner(settings: Settings) extends CommonActor {
       if (!hasWritten) epoch = Epoch(epoch.schedule)
       checkMyTurn(scheduleForWriting)
       context.parent ! nextPeriod
-      needToCheckTimeToPublish = true
       checkScheduleUpdateTime()
     case Tick =>
       logger.info("123")