| /foundation/resourceschedule/ffrt/src/queue/ |
| H A D | queue_api.cpp | 39 FFRT_COND_DO_ERR(unlikely(queue == nullptr), return nullptr, "input invalid, queue == nullptr"); in ffrt_queue_submit_base()
40 FFRT_COND_DO_ERR(unlikely(f == nullptr), return nullptr, "input invalid, function header == nullptr"); in ffrt_queue_submit_base()
57 FFRT_COND_DO_ERR((attr == nullptr), return -1, "input invalid, attr == nullptr"); in ffrt_queue_attr_init()
68 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr"); in ffrt_queue_attr_destroy()
77 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr"); in ffrt_queue_attr_set_qos()
85 FFRT_COND_DO_ERR((attr == nullptr), return ffrt_qos_default, "input invalid, attr == nullptr"); in ffrt_queue_attr_get_qos()
93 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr"); in ffrt_queue_attr_set_timeout()
100 FFRT_COND_DO_ERR((attr == nullptr), return 0, "input invalid, attr == nullptr"); in ffrt_queue_attr_get_timeout()
108 FFRT_COND_DO_ERR((attr == nullptr), return, "input invalid, attr == nullptr"); in ffrt_queue_attr_set_callback()
120 FFRT_COND_DO_ERR((att in ffrt_queue_attr_get_callback()
[all...] |
| H A D | queue_handler.cpp | 51 FFRT_COND_DO_ERR((queue_ == nullptr), return, "[queueId=%u] constructed failed", GetQueueId()); in QueueHandler()
66 FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot destruct, [queueId=%u] constructed failed", GetQueueId()); in ~QueueHandler()
92 FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId()); in SetLoop()
96 FFRT_COND_DO_ERR((queue_->GetQueueType() != ffrt_queue_concurrent), in SetLoop()
103 FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId()); in ClearLoop()
104 FFRT_COND_DO_ERR((queue_->GetQueueType() != ffrt_queue_concurrent), in ClearLoop()
111 FFRT_COND_DO_ERR((queue_ == nullptr), return nullptr, "[queueId=%u] constructed failed", GetQueueId()); in PickUpTask()
117 FFRT_COND_DO_ERR((queue_ == nullptr), return, "cannot submit, [queueId=%u] constructed failed", GetQueueId()); in Submit()
118 FFRT_COND_DO_ERR((task == nullptr), return, "input invalid, serial task is nullptr"); in Submit()
161 FFRT_COND_DO_ERR((queue in Cancel()
[all...] |
| H A D | base_queue.cpp | 50 FFRT_COND_DO_ERR(isExit_, return, "cannot remove task, [queueId=%u] is exiting", 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()
130 FFRT_COND_DO_ERR((iter == CREATE_FUNC_MAP.end()), return nullptr, "invalid queue type");
in CreateQueue()
|
| H A D | eventhandler_interactive_queue.cpp | 28 FFRT_COND_DO_ERR((prio > Priority::IDLE), return FAILED, "Priority invalid.");
in Push()
42 FFRT_COND_DO_ERR((!taskStatus), return FAILED, "post task fail");
in Push()
|
| H A D | serial_queue.cpp | 29 FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot push task, [queueId=%u] is exiting", queueId_); in Push()
63 FFRT_COND_DO_ERR(isExit_, return nullptr, "cannot pull task, [queueId=%u] is exiting", queueId_); in Pull()
|
| H A D | concurrent_queue.cpp | 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()
96 FFRT_COND_DO_ERR(isExit_, return nullptr, "cannot pull task, [queueId=%u] is exiting", queueId_);
in Pull()
|
| H A D | queue_handler.h | 65 FFRT_COND_DO_ERR((queue_ == nullptr), return 0, "queue construct failed"); in GetQueueId()
71 FFRT_COND_DO_ERR((queue_ == nullptr), return false, "[queueId=%u] constructed failed", GetQueueId()); in HasTask()
|
| H A D | queue_monitor.cpp | 109 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return, in ResetQueueInfo()
118 FFRT_COND_DO_ERR((queuesStructInfo_.size() <= queueId), return, in ResetQueueStruct()
126 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return, in UpdateQueueInfo()
139 FFRT_COND_DO_ERR((queuesRunningInfo_.size() <= queueId), return INVALID_TASK_ID, in QueryQueueStatus()
146 FFRT_COND_DO_ERR(exit_.load(), abortSendTimer_.store(true); in SendDelayedWorker()
|
| H A D | eventhandler_adapter_queue.cpp | 121 FFRT_COND_DO_ERR(isExit_, return FAILED, "cannot push task, [queueId=%u] is exiting", queueId_);
in Push()
162 FFRT_COND_DO_ERR(isExit_, return nullptr, "cannot pull task, [queueId=%u] is exiting", queueId_);
in Pull()
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| H A D | loop_api.cpp | 27 FFRT_COND_DO_ERR((queue == nullptr), return nullptr, "input invalid, queue is nullptr"); in ffrt_loop_create()
29 FFRT_COND_DO_ERR((!handler->IsValidForLoop()), return nullptr, "queue invalid for loop"); in ffrt_loop_create()
32 FFRT_COND_DO_ERR((innerLoop == nullptr), return nullptr, "failed to construct loop"); in ffrt_loop_create()
44 FFRT_COND_DO_ERR((loop == nullptr), return -1, "input invalid, loop is nullptr"); in ffrt_loop_destroy()
53 FFRT_COND_DO_ERR((loop == nullptr), return -1, "input invalid, loop is nullptr"); in ffrt_loop_run()
63 FFRT_COND_DO_ERR((loop == nullptr), return, "input invalid, loop is nullptr"); in ffrt_loop_stop()
71 FFRT_COND_DO_ERR((loop == nullptr), return -1, "input invalid, loop is nullptr"); in ffrt_loop_epoll_ctl()
79 FFRT_COND_DO_ERR((loop == nullptr), return -1, "input invalid, loop is nullptr"); in ffrt_loop_timer_start()
87 FFRT_COND_DO_ERR((loop == nullptr), return -1, "input invalid, loop is nullptr"); in ffrt_loop_timer_stop()
|
| /foundation/resourceschedule/ffrt/src/sched/ |
| H A D | scheduler.cpp | 40 FFRT_COND_DO_ERR((node == nullptr), return false, "Node is NULL"); in InsertNode()
43 FFRT_COND_DO_ERR((level == qos_inherit), return false, "Level incorrect"); in InsertNode()
68 FFRT_COND_DO_ERR((node == nullptr), return false, "Node is NULL"); in RemoveNode()
71 FFRT_COND_DO_ERR((level == qos_inherit), return false, "Level incorrect"); in RemoveNode()
86 FFRT_COND_DO_ERR((task == nullptr), return false, "task is nullptr"); in WakeupTask()
|
| /foundation/resourceschedule/ffrt/src/core/ |
| H A D | task_io.cpp | 74 FFRT_COND_DO_ERR((exec == nullptr), return, "input invalid, exec == nullptr"); in ffrt_submit_coroutine()
|
| H A D | task.cpp | 468 FFRT_COND_DO_ERR((curTask->type != ffrt_normal_task), return 1, "update qos task type invalid"); in ffrt_this_task_update_qos()
|
| /foundation/resourceschedule/ffrt/src/dfx/log/ |
| H A D | ffrt_log_api.h | 146 #define FFRT_COND_DO_ERR(cond, expr, format, ...) \ macro
|
| /foundation/resourceschedule/ffrt/src/sync/ |
| H A D | delayed_worker.cpp | 161 FFRT_COND_DO_ERR(toExit, return -1, "HandleWork exit, map size:%d", map.size()); in HandleWork()
|
| H A D | poller.cpp | 161 FFRT_COND_DO_ERR((eventsVec == nullptr), return -1, "eventsVec cannot be null");
169 FFRT_COND_DO_ERR((maxevents < EPOLL_EVENT_SIZE), return -1, "maxEvents:%d cannot be less than 1024", maxevents);
|
| /foundation/resourceschedule/ffrt/src/util/ |
| H A D | worker_monitor.cpp | 282 FFRT_COND_DO_ERR(!transactionFile.is_open(), return, "open transaction_proc failed"); in RecordIpcInfo()
|
| /foundation/resourceschedule/ffrt/src/dm/ |
| H A D | sdependence_manager.cpp | 361 FFRT_COND_DO_ERR((handle == nullptr), return ffrt_error_inval, "input ffrt task handle is invalid."); in onSkip()
|