Searched refs:threadStatus (Results 1 – 11 of 11) sorted by relevance
72 std::thread thread([this, threadStatus] { this->StartWorker(threadStatus); }); in Init()136 threadStatus->isThreadWaiting_ = true; in WaitForTask()146 threadStatus->isThreadWaiting_ = false; in WaitForTask()155 … "cpuAffinityType:%{public}d", taskType_, threadStatus->threadId_, threadStatus->cpuAffinityType); in StartWorker()157 if (!WaitForTask(threadStatus)) { in StartWorker()167 ++(threadStatus->taskNum_); in StartWorker()177 ++(threadStatus->taskNum_); in StartWorker()187 ++(threadStatus->taskNum_); in StartWorker()192 taskType_, threadStatus->threadId_); in StartWorker()276 if (!threadStatus->isThreadWaiting_) { in IsAllThreadWaiting()[all …]
43 if (fcm->threadStatus[dir] > THREAD_RUNNING) { in IsFcThreadNeedStop()93 fcm->threadStatus[dir] = THREAD_STARTING; in RunWiFiFlowControl()95 fcm->threadStatus[dir] = THREAD_WAITING; in RunWiFiFlowControl()104 fcm->threadStatus[dir] = THREAD_RUNNING; in RunWiFiFlowControl()112 fcm->threadStatus[dir] = THREAD_STOPPED; in RunWiFiFlowControl()151 if (fcm->threadStatus[dir] == THREAD_INIT_FAIL || fcm->threadStatus[dir] == THREAD_DESTROYED) { in DestroyTask()155 fcm->threadStatus[dir] = THREAD_STOPPING; in DestroyTask()168 fcm->threadStatus[dir] = THREAD_DESTROYED; in DestroyTask()187 fcm->threadStatus[FLOW_TX] = THREAD_INIT_FAIL; in CreateFlowControlTask()196 fcm->threadStatus[FLOW_TX] = THREAD_INIT_SUCCESS; in CreateFlowControlTask()[all …]
99 if (threadStatus == STOP) { in LinuxReadAllKmsg()129 if (threadStatus == NONEXIST || threadStatus == STOP) { in Start()136 threadStatus = START; in Start()141 if (threadStatus == NONEXIST || threadStatus == STOP) { in Stop()145 threadStatus = STOP; in Stop()
55 threadStatus = ThreadStatus::THREAD_STATUS_INIT; in InitThreadInfo()60 threadStatus = ThreadStatus::THREAD_STATUS_INVALID; in ~DfxThread()117 if (threadStatus == ThreadStatus::THREAD_STATUS_ATTACHED) { in Detach()119 threadStatus = ThreadStatus::THREAD_STATUS_INIT; in Detach()125 if (threadStatus == ThreadStatus::THREAD_STATUS_ATTACHED) { in Attach()133 threadStatus = ThreadStatus::THREAD_STATUS_ATTACHED; in Attach()
69 ThreadStatus threadStatus = ThreadStatus::THREAD_STATUS_INVALID; variable
53 cntlr->threadStatus |= CAN_THREAD_RUNNING; in CanIrqThreadWorker()54 while ((cntlr->threadStatus & CAN_THREAD_RUNNING) != 0) { in CanIrqThreadWorker()60 if ((cntlr->threadStatus & CAN_THREAD_RUNNING) == 0) { in CanIrqThreadWorker()68 cntlr->threadStatus &= ~CAN_THREAD_PENDING; in CanIrqThreadWorker()71 cntlr->threadStatus |= CAN_THREAD_STOPPED; in CanIrqThreadWorker()100 cntlr->threadStatus = 0; in CanCntlrCreateThread()159 cntlr->threadStatus &= ~CAN_THREAD_RUNNING; in CanCntlrDestroyThread()162 while ((cntlr->threadStatus & CAN_THREAD_STOPPED) == 0) { in CanCntlrDestroyThread()
211 …if ((cntlr->threadStatus & CAN_THREAD_RUNNING) == 0 || (cntlr->threadStatus & CAN_THREAD_PENDING) … in CanCntlrOnNewMsgIrqSafe()216 cntlr->threadStatus |= CAN_THREAD_PENDING; in CanCntlrOnNewMsgIrqSafe()
44 threadStatus = NONEXIST; in LogKmsg()49 ThreadStatus threadStatus; variable
93 void StartWorker(std::shared_ptr<ThumbnailGenerateThreadStatus> threadStatus);94 bool WaitForTask(std::shared_ptr<ThumbnailGenerateThreadStatus> threadStatus);
215 … FcThreadStatus threadStatus[FLOW_DIR_COUNT]; /**< Array of flow control thread statuses */ member
65 uint8_t threadStatus; member