Searched refs:WORKER (Results 1 – 22 of 22) sorted by relevance
87 } else if (register_message.role() == NodeRole::WORKER) { in NextRankId()93 bool res = item.second.is_alive == false && item.second.node_role_ == NodeRole::WORKER; in NextRankId()117 node_info.node_role_ = NodeRole::WORKER; in NextRankId()279 if (item.second.node_role_ == NodeRole::WORKER && item.second.is_alive == false) { in IsWorkerOrServer0()
56 InitNodeInfo(NodeRole::WORKER); in Initialize()
132 case NodeRole::WORKER: in NodeRoleToString()142 } else if (node_role == NodeRole::WORKER && (rank_id > IntToUint(total_worker_num) - 1)) { in ValidateRankId()
649 if (info.node_role_ == NodeRole::WORKER) { in ProcessScaleIn()1006 if (node_infos[val].node_role_ == NodeRole::WORKER) { in CheckIfNodeIdLegal()
1121 if (it.second.is_alive == true && it.second.node_role_ == NodeRole::WORKER) { in IsWorkerOrServer0()
39 WORKER = 1 enumerator
38 enum class Role { SERVER = 0, WORKER = 1, SCHEDULER = 2 }; enumerator
55 #define WLOG(SEVERITY, WORKER) \ argument56 (shrpx::Log(SEVERITY, __FILE__, __LINE__) << "[WORKER:" << WORKER << "] ")
37 Thread 1 (WORKER)
74 V(WORKER) \
46 WORKER = 1; enumerator
47 delete providers.WORKER;
199 pContext->pArContext[i] = ArchRast::CreateThreadContext(ArchRast::AR_THREAD::WORKER); in SwrCreateContext()
31280 1F477;CONSTRUCTION WORKER;So;0;ON;;;;;N;;;;;
32072 1F477;CONSTRUCTION WORKER;So;0;ON;;;;;N;;;;;
37111 cp;1F477;EBase;lb=EB;na=CONSTRUCTION WORKER
30191 1F477;CONSTRUCTION WORKER;So;0;ON;;;;;N;;;;;
35812 cp;1F477;EBase;lb=EB;na=CONSTRUCTION WORKER