Searched refs:iteration_num_ (Results 1 – 4 of 4) sorted by relevance
116 …_LOG(INFO) << "Notify cluster starts to proceed to next iteration. Iteration is " << iteration_num_ in MoveToNextIteration()118 if (IsMoveToNextIterRequestReentrant(iteration_num_)) { in MoveToNextIteration()132 if (!BroadcastEndLastIterRequest(iteration_num_)) { in MoveToNextIteration()146 MS_LOG(INFO) << "Iteration " << iteration_num_ << " start running."; in SetIterationRunning()159 MS_LOG(INFO) << "Iteration " << iteration_num_ << " completes."; in SetIterationCompleted()310 iteration_num_ = 1; in NewInstance()311 LocalMetaStore::GetInstance().set_curr_iter_num(iteration_num_); in NewInstance()358 iteration_num_ = sync_iter_rsp.iteration(); in SyncIteration()374 sync_iter_rsp.set_iteration(iteration_num_); in HandleSyncIterationRequest()398 notify_leader_to_next_iter_req.set_iter_num(iteration_num_); in NotifyLeaderMoveToNextIteration()[all …]
133 iteration_num_(1), in Iteration()146 LocalMetaStore::GetInstance().set_curr_iter_num(iteration_num_); in Iteration()215 size_t iteration_num_; variable
103 iteration_num_(0), in FLWorker()137 std::atomic<uint64_t> iteration_num_; variable
170 void FLWorker::set_fl_iteration_num(uint64_t iteration_num) { iteration_num_ = iteration_num; } in set_fl_iteration_num()172 uint64_t FLWorker::fl_iteration_num() const { return iteration_num_.load(); } in fl_iteration_num()