Home
last modified time | relevance | path

Searched refs:prio (Results 1 - 16 of 16) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/
H A Dsend_task_scheduler.cpp40 for (const auto &prio : priorityOrder_) { in Initialize()
41 extraCapacityInByteByPrio_[prio] = 0; in Initialize()
42 taskCountByPrio_[prio] = 0; in Initialize()
43 taskDelayCountByPrio_[prio] = 0; in Initialize()
44 taskGroupByPrio_[prio] = TaskListByTarget(); in Initialize()
200 for (auto &prio : priorityOrder_) { in DelayTaskByTarget()
201 size_t count = taskGroupByPrio_[prio][inTarget].size(); in DelayTaskByTarget()
202 taskDelayCountByPrio_[prio] += static_cast<uint32_t>(count); in DelayTaskByTarget()
220 for (auto &prio : priorityOrder_) { in NoDelayTaskByTarget()
221 size_t count = taskGroupByPrio_[prio][inTarge in NoDelayTaskByTarget()
[all...]
H A Dcommunicator_aggregator.cpp326 errCode = scheduler_.AddSendTaskIntoSchedule(task, inConfig.prio); in ScheduleSendTask()
328 errCode = RetryUntilTimeout(task, inConfig.timeout, inConfig.prio); in ScheduleSendTask()
/foundation/resourceschedule/ffrt/src/queue/
H A Deventhandler_interactive_queue.cpp27 Priority prio = EventHandlerAdapter::Instance()->ConvertPriority(task->GetPriority()); in Push() local
28 FFRT_COND_DO_ERR((prio > Priority::IDLE), return FAILED, "Priority invalid."); in Push()
40 task->label, delayUs / msPerSecond, static_cast<Priority>(prio), static_cast<uintptr_t>(task->gid)); in Push()
/foundation/ability/ability_runtime/frameworks/native/runtime/
H A Dohos_js_environment_impl.cpp44 AppExecFwk::EventQueue::Priority prio = AppExecFwk::EventQueue::Priority::IMMEDIATE; in PostTaskToHandler() local
47 prio = AppExecFwk::EventQueue::Priority::IMMEDIATE; in PostTaskToHandler()
50 prio = AppExecFwk::EventQueue::Priority::LOW; in PostTaskToHandler()
53 prio = AppExecFwk::EventQueue::Priority::IDLE; in PostTaskToHandler()
56 prio = AppExecFwk::EventQueue::Priority::HIGH; in PostTaskToHandler()
64 g_eventHandler->PostTask(task, "uv_io_cb", 0, prio); in PostTaskToHandler()
/foundation/resourceschedule/ffrt/tools/ffrt_trace_process/
H A Dffrt_trace_recover.py51 def make_costart_fake_log(mark, pid, label, gid, tid, tname, prio):
58 tname, tid, pid, cpu_id, timestamp, tname, tid, prio, label, pid, gid, prio)
63 def make_coyield_fake_log(mark, pid, label, gid, tid, tname, prio):
70 label, pid, gid, pid, cpu_id, timestamp, label, pid, gid, prio, tname, tid, prio)
104 fake_log = fake_log[:fake_log.index("pid=")] + "pid=%d0%d " % (pid, gid) + fake_log[fake_log.index("prio="):]
242 prio = 120
253 prio = int(mark[mark.index("prev_prio="):].split(' ')[0].split('=')[-1])
255 prio
[all...]
/foundation/resourceschedule/qos_manager/test/unittest/phone/
H A Dconcurrent_task_controller_test.cpp290 int prio = PRIO_NORMAL; in HWTEST_F() local
292 foregroundapprecord.AddKeyThread(tid, prio); in HWTEST_F()
294 foregroundapprecord.AddKeyThread(tid, prio); in HWTEST_F()
296 foregroundapprecord.AddKeyThread(tid, prio); in HWTEST_F()
298 foregroundapprecord.AddKeyThread(tid, prio); in HWTEST_F()
304 foregroundapprecord.AddKeyThread(tid, prio); in HWTEST_F()
305 prio = RPIO_IN; in HWTEST_F()
307 prio = PRIO_RT; in HWTEST_F()
309 foregroundapprecord.AddKeyThread(tid, prio); in HWTEST_F()
/foundation/resourceschedule/ffrt/src/tm/
H A Dqueue_task.h82 inline void SetPriority(const ffrt_queue_priority_t prio) in SetPriority() argument
84 prio_ = prio; in SetPriority()
/foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/
H A Djs_ability_thread.cpp129 uint8_t prio = 0; in AppTaskHandler() local
130 osStatus_t ret = osMessageQueueGet(messageQueueId, &innerMsg, &prio, osWaitForever); in AppTaskHandler()
H A Dnative_ability_thread.cpp165 uint8_t prio = 0; in NativeAppTaskHandler() local
166 osStatus_t ret = osMessageQueueGet(messageQueueId, &innerMsg, &prio, osWaitForever); in NativeAppTaskHandler()
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_queue.cpp642 for (int prio = 0; prio < 5; prio++) {
643 ffrt_task_attr_set_queue_priority(&task_attr, static_cast<ffrt_queue_priority_t>(prio));
646 create_function_wrapper(priorityFuncs[prio], ffrt_function_kind_queue), &task_attr);
/foundation/resourceschedule/qos_manager/services/include/
H A Dconcurrent_task_controller.h130 void AddKeyThread(int tid, int prio = PRIO_NORMAL);
/foundation/resourceschedule/ffrt/src/core/
H A Dtask.cpp228 int prio = static_cast<int>(priority); in ffrt_task_attr_set_queue_priority() local
229 if (prio < static_cast<int>(ffrt_queue_priority_immediate) || in ffrt_task_attr_set_queue_priority()
230 prio > static_cast<int>(ffrt_queue_priority_idle) + 1) { in ffrt_task_attr_set_queue_priority()
/foundation/resourceschedule/ffrt/interfaces/kits/cpp/
H A Dtask.h137 inline task_attr& priority(ffrt_queue_priority_t prio) in priority() argument
139 ffrt_task_attr_set_queue_priority(this, prio); in priority()
/foundation/communication/netstack/test/fuzztest/http_fuzzer/
H A Dhttp_fuzzer.cpp338 uint32_t prio = GetData<uint32_t>(); in HttpClientTaskSetHttpProtocolFuzzTest() local
339 request.SetPriority(prio); in HttpClientTaskSetHttpProtocolFuzzTest()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/include/
H A Dcommunicator_aggregator.h43 Priority prio = Priority::NORMAL; member
/foundation/resourceschedule/qos_manager/services/src/
H A Dconcurrent_task_controller.cpp991 void ForegroundAppRecord::AddKeyThread(int tid, int prio) in AddKeyThread() argument
993 int rtgPrio = (prio >= PRIO_NORMAL) ? PRIO_NORMAL : PRIO_RT; in AddKeyThread()
1005 if (prio == RPIO_IN) { in AddKeyThread()

Completed in 12 milliseconds