Lines Matching refs:queueId_
30 FFRT_LOGI("destruct concurrent queueId=%u leave", queueId_); in ~ConcurrentQueue()
36 FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot push task, [queueId=%u] is exiting", queueId_); in Push()
49 …FFRT_COND_DO_ERR(IsOnLoop(), return FAILED, "cannot push task, [queueId=%u] loop empty", queueId_); in Push()
53 … FFRT_LOGD("task [gid=%llu] concurrency[%u] + 1 [queueId=%u]", task->gid, oldValue, queueId_); in Push()
77 return dequeFunc_(queueId_, now, whenMap_, nullptr); in Pull()
84 FFRT_LOGD("[queueId=%u] stuck in %llu us wait", queueId_, diff); in Pull()
86 FFRT_LOGD("[queueId=%u] wakeup from wait", queueId_); in Pull()
92 uint32_t queueId = queueId_; in Pull()
97 … FFRT_COND_DO_ERR(isExit_, return nullptr, "cannot pull task, [queueId=%u] is exiting", queueId_); in Pull()
100 return dequeFunc_(queueId_, now, whenMap_, nullptr); in Pull()
119 FFRT_LOGI("clear [queueId=%u] succ", queueId_); in Stop()
125 FFRT_LOGE("queueId %s should bind to loop invalid", queueId_); in SetLoop()