| /foundation/resourceschedule/ffrt/src/queue/ |
| H A D | concurrent_queue.cpp | 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()
93 FFRT_LOGD("concurrency[%d] - 1 [queueId=%u] switch into inactive", oldValue, queueId_);
in Pull()
96 FFRT_COND_DO_ERR(isExit_, return nullptr, "cannot pull task, [queueId=%u] is exiting", queueId_);
in Pull()
99 return dequeFunc_(queueId_, no in Pull()
[all...] |
| H A D | serial_queue.cpp | 23 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()
51 FFRT_LOGD("[queueId=%u] stuck in %llu us wait", queueId_, diff); in Pull()
53 FFRT_LOGD("[queueId=%u] wakeup from wait", queueId_); in Pull()
59 FFRT_LOGD("[queueId=%u] switch into inactive", queueId_); in Pull()
63 FFRT_COND_DO_ERR(isExit_, return nullptr, "cannot pull task, [queueId=%u] is exiting", queueId_); in Pull()
66 return dequeFunc_(queueId_, now, whenMap_, nullptr); in Pull()
|
| H A D | base_queue.cpp | 44 FFRT_LOGI("clear [queueId=%u] succ", queueId_);
in Stop()
50 FFRT_COND_DO_ERR(isExit_, return, "cannot remove task, [queueId=%u] is exiting", queueId_);
in Remove()
54 FFRT_LOGD("cancel [queueId=%u] all tasks succ", queueId_);
in Remove()
60 FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot remove task, [queueId=%u] is exiting", queueId_);
in Remove()
81 FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot remove task, [queueId=%u] is exiting", queueId_);
in Remove()
107 queueId_, mutex_.GetOwnerId(), mutex_.GetDuration());
in PrintMutexOwner()
110 queueId_, mutex_.GetOwnerId(), mutex_.GetDuration());
in PrintMutexOwner()
|
| H A D | base_queue.h | 42 explicit BaseQueue() : queueId_(queueId++) {}
in BaseQueue()
67 return queueId_;
in GetQueueId()
93 const uint32_t queueId_;
member in ffrt::BaseQueue
|
| H A D | eventhandler_adapter_queue.cpp | 115 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 D | eventhandler_interactive_queue.cpp | 22 FFRT_LOGI("destruct eventhandler interactive queueId=%u leave", queueId_);
in ~EventHandlerInteractiveQueue()
|
| /foundation/graphic/graphic_3d/lume/metaobject/test/src/api/ |
| H A D | TimerTest.cpp | 43 queueId_ = interface_cast<IObjectInstance>(queue_)->GetInstanceId();
44 GetTaskQueueRegistry().RegisterTaskQueue(queue_, queueId_.ToUid());
48 GetTaskQueueRegistry().UnregisterTaskQueue(queueId_.ToUid());
53 InstanceId queueId_; member in TimerTest
68 TimeSpan::Milliseconds(100), [&count] { ++count; }, Timer::RECURRING, queueId_.ToUid()); in HWTEST_F()
90 TimeSpan::Milliseconds(20), [] {}, Timer::RECURRING, queueId_.ToUid()); in HWTEST_F()
109 TimeSpan::Milliseconds(100), [&count] { ++count; }, Timer::RECURRING, queueId_.ToUid())); in HWTEST_F()
135 TimeSpan::Milliseconds(100), [&count] { ++count; }, Timer::RECURRING, queueId_.ToUid())); in HWTEST_F()
148 TimeSpan::Milliseconds(100), [&count] { ++count; }, Timer::RECURRING, queueId_.ToUid())); in HWTEST_F()
169 TimeSpan::Milliseconds(100), [&count] { ++count; }, Timer::SINGLE_SHOT, queueId_ in HWTEST_F()
[all...] |
| /foundation/graphic/graphic_surface/surface/src/ |
| H A D | producer_surface.cpp | 66 BLOGD("~ProducerSurface dtor, name: %{public}s, uniqueId: %{public}" PRIu64 ".", name_.c_str(), queueId_); in ~ProducerSurface()
86 queueId_ = initInfo_.uniqueId; in Init()
88 BLOGD("Init name: %{public}s, uniqueId: %{public}" PRIu64 ".", name_.c_str(), queueId_); in Init()
125 BLOGD("RequestBuffer ret: %{public}d, uniqueId: %{public}" PRIu64 ".", ret, queueId_); in RequestBuffer()
138 BLOGD("SetMetadataValve ret: %{public}d, uniqueId: %{public}" PRIu64 ".", ret, queueId_); in RequestBuffer()
151 BLOGD("SetColorSpaceType ret: %{public}d, uniqueId: %{public}" PRIu64 ".", ret, queueId_); in SetMetadataValve()
161 BLOGD("SetHDRStaticMetadata ret: %{public}d, uniqueId: %{public}" PRIu64 ".", ret, queueId_); in SetMetadataValve()
171 BLOGD("SetHDRStaticMetadata ret: %{public}d, uniqueId: %{public}" PRIu64 ".", ret, queueId_); in SetMetadataValve()
179 BLOGD("SetHDRMetadataType ret: %{public}d, uniqueId: %{public}" PRIu64 ".", ret, queueId_); in SetMetadataValve()
195 if (fdRec[fdTmp] != queueId_) { in OutputRequestBufferLog()
[all...] |
| /foundation/graphic/graphic_surface/surface/include/ |
| H A D | producer_surface.h | 246 uint64_t queueId_ = 0; member in OHOS::ProducerSurface
|