Searched refs:kLeaderServerRank (Results 1 – 5 of 5) sorted by relevance
123 if (server_node_->rank_id() == kLeaderServerRank) { in MoveToNextIteration()148 if (server_node_->rank_id() == kLeaderServerRank) { in SetIterationRunning()161 if (server_node_->rank_id() == kLeaderServerRank) { in SetIterationCompleted()187 if (server_rank != kLeaderServerRank) { in ReInitForScaling()349 …if (!communicator_->SendPbRequest(sync_iter_req, kLeaderServerRank, ps::core::TcpUserCommand::kSyn… in SyncIteration()400 if (!communicator_->SendPbRequest(notify_leader_to_next_iter_req, kLeaderServerRank, in NotifyLeaderMoveToNextIteration()648 if (server_node_->rank_id() != kLeaderServerRank || metrics_ == nullptr) { in SummarizeIteration()
187 constexpr uint32_t kLeaderServerRank = 0; variable
409 if (server_node_->rank_id() == kLeaderServerRank) { in InitMetrics()436 DistributedCountService::GetInstance().Initialize(server_node_, kLeaderServerRank); in StartCommunicator()
47 constexpr uint32_t kLeaderServerRank = 0; variable
64 …if (!fl::worker::FLWorker::GetInstance().SendToServer(fl::kLeaderServerRank, fbb_->GetBufferPointe… in Launch()