Home
last modified time | relevance | path

Searched refs:queueId_ (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/resourceschedule/ffrt/src/queue/
H A Dconcurrent_queue.cpp30 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()
100 return dequeFunc_(queueId_, now, whenMap_, nullptr); in Pull()
119 FFRT_LOGI("clear [queueId=%u] succ", queueId_); in Stop()
[all …]
H A Dserial_queue.cpp23 FFRT_LOGI("destruct serial queueId=%u leave", queueId_); in ~SerialQueue()
29 FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot push task, [queueId=%u] is exiting", queueId_); in Push()
37 FFRT_LOGD("head insert task=%u in [queueId=%u]", task->gid, queueId_); in Push()
52 FFRT_LOGW("[queueId=%u] overload warning, size=%llu", queueId_, whenMap_.size()); in Push()
66 FFRT_LOGD("[queueId=%u] stuck in %llu us wait", queueId_, diff); in Pull()
68 FFRT_LOGD("[queueId=%u] wakeup from wait", queueId_); in Pull()
74 FFRT_LOGD("[queueId=%u] switch into inactive", queueId_); in Pull()
78 … FFRT_COND_DO_ERR(isExit_, return nullptr, "cannot pull task, [queueId=%u] is exiting", queueId_); in Pull()
81 return dequeFunc_(queueId_, now, whenMap_, nullptr); in Pull()
H A Deventhandler_adapter_queue.cpp115 FFRT_LOGI("destruct eventhandler adapter queueId=%u leave", queueId_); in ~EventHandlerAdapterQueue()
121 FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot push task, [queueId=%u] is exiting", queueId_); in Push()
150 FFRT_LOGD("[queueId=%u] stuck in %llu us wait", queueId_, diff); in Pull()
152 FFRT_LOGD("[queueId=%u] wakeup from wait", queueId_); in Pull()
158 FFRT_LOGD("[queueId=%u] switch into inactive", queueId_); in Pull()
162 … FFRT_COND_DO_ERR(isExit_, return nullptr, "cannot pull task, [queueId=%u] is exiting", queueId_); in Pull()
165 return dequeFunc_(queueId_, now, whenMap_, &pulledTaskCount_); in Pull()
H A Dbase_queue.cpp55 FFRT_LOGI("clear [queueId=%u] succ", queueId_); in Stop()
72 FFRT_COND_DO_ERR(isExit_, return, "cannot remove task, [queueId=%u] is exiting", queueId_); in Remove()
75 FFRT_LOGD("cancel [queueId=%u] all tasks succ", queueId_); in Remove()
86 … FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot remove task, [queueId=%u] is exiting", queueId_); in Remove()
112 … FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot remove task, [queueId=%u] is exiting", queueId_); in Remove()
H A Dbase_queue.h41 explicit BaseQueue() : queueId_(queueId++) {} in BaseQueue()
72 return queueId_; in GetQueueId()
90 const uint32_t queueId_; variable
H A Deventhandler_interactive_queue.cpp22 FFRT_LOGI("destruct eventhandler interactive queueId=%u leave", queueId_); in ~EventHandlerInteractiveQueue()
/ohos5.0/foundation/graphic/graphic_surface/surface/src/
H A Dproducer_surface.cpp85 queueId_ = initInfo_.uniqueId; in Init()
133 BLOGD("SetMetadataValue fail, uniqueId: %{public}" PRIu64 ".", queueId_); in RequestBuffer()
626 key.c_str(), val.c_str(), queueId_); in SetUserData()
726 funcName.c_str(), queueId_); in RegisterUserDataChangeListener()
775 BLOGD("CleanCacheLocked, uniqueId: %{public}" PRIu64 ".", queueId_); in CleanCacheLocked()
785 BLOGD("CleanCache, uniqueId: %{public}" PRIu64 ".", queueId_); in CleanCache()
798 BLOGD("GoBackground, uniqueId: %{public}" PRIu64 ".", queueId_); in GoBackground()
811 return queueId_; in GetUniqueId()
829 BLOGE("GetTransform failed, uniqueId: %{public}" PRIu64 ".", queueId_); in GetTransform()
854 BLOGD("Connect, uniqueId: %{public}" PRIu64 ".", queueId_); in Connect()
[all …]
/ohos5.0/base/telephony/core_service/utils/common/src/
H A Dtel_event_queue.cpp69 SubmitInner(queueId_.load()); in Submit()
140 if (queueId_ >= INT32_MAX) { in GetNextQueueId()
141 queueId_ = 1; in GetNextQueueId()
143 return queueId_++; in GetNextQueueId()
149 if (queueId != queueId_.load()) { in SubmitToFFRT()
233 if (IsEmpty() || queueId != queueId_.load()) { in PopEvent()
/ohos5.0/base/telephony/core_service/utils/common/include/
H A Dtel_event_queue.h62 std::atomic_int queueId_ { 0 };
/ohos5.0/foundation/graphic/graphic_surface/surface/include/
H A Dproducer_surface.h188 uint64_t queueId_ = 0; variable