Lines Matching refs:queue_
50 queue_ = CreateQueue(type, attr);
51 FFRT_COND_DO_ERR((queue_ == nullptr), return, "[queueId=%u] constructed failed", GetQueueId());
66 FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot destruct, [queueId=%u] constructed failed", GetQueueId());
69 queue_->Stop();
70 while (QueueMonitor::GetInstance().QueryQueueStatus(GetQueueId()) || queue_->GetActiveStatus()) {
92 FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId());
93 if (queue_->GetQueueType() == ffrt_queue_eventhandler_interactive) {
96 FFRT_COND_DO_ERR((queue_->GetQueueType() != ffrt_queue_concurrent),
98 return reinterpret_cast<ConcurrentQueue*>(queue_.get())->SetLoop(loop);
103 FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId());
104 FFRT_COND_DO_ERR((queue_->GetQueueType() != ffrt_queue_concurrent),
106 return reinterpret_cast<ConcurrentQueue*>(queue_.get())->ClearLoop();
111 FFRT_COND_DO_ERR((queue_ == nullptr), return nullptr, "[queueId=%u] constructed failed", GetQueueId());
112 return queue_->Pull();
117 FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot submit, [queueId=%u] constructed failed", GetQueueId());
129 if (queue_->GetQueueType() == ffrt_queue_eventhandler_adapter) {
133 int ret = queue_->Push(task);
153 queue_->Push(task);
161 FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot cancel, [queueId=%u] constructed failed", GetQueueId());
162 queue_->Remove();
167 FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot cancelAndWait, [queueId=%u] constructed failed",
169 queue_->Remove();
170 while (QueueMonitor::GetInstance().QueryQueueStatus(GetQueueId()) != 0 || queue_->GetActiveStatus()) {
177 FFRT_COND_DO_ERR((queue_ == nullptr), return INACTIVE,
179 int ret = queue_->Remove(name);
189 FFRT_COND_DO_ERR((queue_ == nullptr), return INACTIVE,
193 int ret = queue_->Remove(task);
218 if (queue_->GetQueueType() == ffrt_queue_eventhandler_adapter) {
225 if (queue_->GetQueueType() == ffrt_queue_eventhandler_adapter) {
228 reinterpret_cast<EventHandlerAdapterQueue*>(queue_.get())->PushHistoryTask(task, triggerTime, completeTime);
239 if (!queue_->IsOnLoop()) {
249 QueueTask* task = queue_->Pull();
258 if (queue_->GetQueueType() == ffrt_queue_eventhandler_adapter) {
259 reinterpret_cast<EventHandlerAdapterQueue*>(queue_.get())->SetCurrentRunningTask(task);
350 if (queue_ != nullptr) {
351 ss << ", remaining tasks count=" << queue_->GetMapSize();
358 FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId());
359 FFRT_COND_DO_ERR((queue_->GetQueueType() != ffrt_queue_eventhandler_adapter),
362 return reinterpret_cast<EventHandlerAdapterQueue*>(queue_.get())->IsIdle();
367 FFRT_COND_DO_ERR((queue_ == nullptr), return, "[queueId=%u] constructed failed", GetQueueId());
369 bool typeInvalid = (queue_->GetQueueType() != ffrt_queue_eventhandler_interactive) &&
370 (queue_->GetQueueType() != ffrt_queue_eventhandler_adapter);
373 reinterpret_cast<EventHandlerInteractiveQueue*>(queue_.get())->SetEventHandler(eventHandler);
378 FFRT_COND_DO_ERR((queue_ == nullptr), return nullptr, "[queueId=%u] constructed failed", GetQueueId());
380 bool typeInvalid = (queue_->GetQueueType() != ffrt_queue_eventhandler_interactive) &&
381 (queue_->GetQueueType() != ffrt_queue_eventhandler_adapter);
384 return reinterpret_cast<EventHandlerInteractiveQueue*>(queue_.get())->GetEventHandler();
389 FFRT_COND_DO_ERR((queue_ == nullptr), return -1, "[queueId=%u] constructed failed", GetQueueId());
390 FFRT_COND_DO_ERR((queue_->GetQueueType() != ffrt_queue_eventhandler_adapter),
392 return reinterpret_cast<EventHandlerAdapterQueue*>(queue_.get())->Dump(tag, buf, len, historyInfo);
397 FFRT_COND_DO_ERR((queue_ == nullptr), return -1, "[queueId=%u] constructed failed", GetQueueId());
398 FFRT_COND_DO_ERR((queue_->GetQueueType() != ffrt_queue_eventhandler_adapter),
400 return reinterpret_cast<EventHandlerAdapterQueue*>(queue_.get())->DumpSize(priority);