Home
last modified time | relevance | path

Searched refs:priority (Results 1 - 21 of 21) sorted by relevance

/commonlibrary/utils_lite/include/
H A Dohos_init.h68 #define LAYER_INITCALL(func, layer, clayer, priority) \
69 static __attribute__((constructor(CTOR_VALUE_##layer + LAYER_INIT_LEVEL_##priority))) \
70 void BOOT_##layer##priority##func() {func();}
72 #define LAYER_INITCALL(func, layer, clayer, priority) \
74 __attribute__((section(".zinitcall." clayer #priority ".init"))) = func
76 // Default priority is 2, priority range is [0, 4]
81 * @brief Identifies the entry for initializing and starting a core phase by the priority 2.
84 * This macro is used to identify the entry called at the priority 2 of the core phase of
93 * priority
[all...]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dsequence_runner.cpp56 uint32_t priority = Priority::DEFAULT; in SeqRunnerConstructor() local
58 if (argc == 2) { // 2: The number of parameters is 2, if the first is seqRunner name, the second must be priority in SeqRunnerConstructor()
61 priority = NapiHelper::GetUint32Value(env, args[1]); in SeqRunnerConstructor()
62 if (priority >= Priority::NUMBER) { in SeqRunnerConstructor()
63 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "priority value unvalied."); in SeqRunnerConstructor()
75 priority = NapiHelper::GetUint32Value(env, args[0]); in SeqRunnerConstructor()
76 if (priority >= Priority::NUMBER) { in SeqRunnerConstructor()
77 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "priority value unvalied."); in SeqRunnerConstructor()
88 seqRunner = SequenceRunnerManager::GetInstance().CreateOrGetGlobalRunner(env, thisVar, argc, name, priority); in SeqRunnerConstructor()
95 seqRunner->priority_ = static_cast<Priority>(priority); in SeqRunnerConstructor()
158 ExecuteTaskImmediately(uint64_t taskId, Priority priority) ExecuteTaskImmediately() argument
[all...]
H A Dtaskpool.h30 Priority priority {Priority::DEFAULT};
61 static void ExecuteTask(napi_env env, Task* task, Priority priority = Priority::DEFAULT);
62 static napi_value ExecuteGroup(napi_env env, napi_value taskGroup, Priority priority);
67 static bool CheckDelayedParams(napi_env env, napi_callback_info cbinfo, uint32_t &priority, int32_t &delayTime,
69 static bool CheckPeriodicallyParams(napi_env env, napi_callback_info cbinfo, int32_t &period, uint32_t &priority,
H A Dtaskpool.cpp57 // define priority in InitTaskPool()
224 uint32_t priority = Priority::DEFAULT; // DEFAULT priority is MEDIUM in Execute() local
230 priority = NapiHelper::GetUint32Value(env, args[1]); in Execute()
231 if (priority >= Priority::NUMBER) { in Execute()
232 ErrorHelper::ThrowError(env, ErrorHelper::TYPE_ERROR, "priority value is error"); in Execute()
237 return ExecuteGroup(env, args[0], static_cast<Priority>(priority)); in Execute()
249 static_cast<Priority>(priority)); in Execute()
253 ExecuteTask(env, task, static_cast<Priority>(priority)); in Execute()
287 TaskInfo* taskInfo = task->GetTaskInfo(task->env_, napiTask, taskMessage->priority); in DelayTask()
318 uint32_t priority = Priority::DEFAULT; // DEFAULT priority is MEDIUM ExecuteDelayed() local
363 ExecuteGroup(napi_env env, napi_value napiTaskGroup, Priority priority) ExecuteGroup() argument
559 ExecuteTask(napi_env env, Task* task, Priority priority) ExecuteTask() argument
667 uint32_t priority = Priority::DEFAULT; ExecutePeriodically() local
710 CheckDelayedParams(napi_env env, napi_callback_info cbinfo, uint32_t &priority, int32_t &delayTime, Task* &task) CheckDelayedParams() argument
760 CheckPeriodicallyParams(napi_env env, napi_callback_info cbinfo, int32_t &period, uint32_t &priority, Task* &periodicTask) CheckPeriodicallyParams() argument
[all...]
H A Dtask.h50 Priority priority {Priority::DEFAULT};
107 napi_value transferList, napi_value cloneList, Priority priority,
119 Priority priority = Priority::DEFAULT);
120 TaskInfo* GetTaskInfo(napi_env env, napi_value task, Priority priority);
154 bool VerifyAndPostResult(Priority priority);
155 bool CheckStartExecution(Priority priority);
H A Dtask_manager.h64 void EnqueueTaskId(uint64_t taskId, Priority priority = Priority::DEFAULT);
65 void EraseWaitingTaskId(uint64_t taskId, Priority priority);
117 void EnqueuePendingTaskInfo(uint64_t taskId, Priority priority);
124 bool PostTask(std::function<void()> task, const char* taskName, Priority priority = Priority::DEFAULT);
175 std::pair<uint64_t, Priority> GetTaskByPriority(const std::unique_ptr<ExecuteQueue>& taskQueue, Priority priority);
176 void IncreaseNumIfNoIdle(Priority priority);
177 void DecreaseNumIfNoIdle(Priority priority);
191 // <<pendingTaskId1, priority>, <pendingTaskId2, priority>, ...>
221 // for task priority
[all...]
H A Dtask_manager.cpp150 napi_value priority = NapiHelper::CreateUint32(env, static_cast<uint32_t>(worker->priority_)); in GetThreadInfos() local
166 napi_set_named_property(env, threadInfo, "priority", priority); in GetThreadInfos()
635 EraseWaitingTaskId(task->taskId_, task->currentTaskInfo_->priority); in CancelTask()
718 void TaskManager::IncreaseNumIfNoIdle(Priority priority) in IncreaseNumIfNoIdle() argument
720 if (priority != Priority::IDLE) { in IncreaseNumIfNoIdle()
725 void TaskManager::DecreaseNumIfNoIdle(Priority priority) in DecreaseNumIfNoIdle() argument
727 if (priority != Priority::IDLE) { in DecreaseNumIfNoIdle()
738 void TaskManager::EnqueueTaskId(uint64_t taskId, Priority priority) in EnqueueTaskId() argument
742 IncreaseNumIfNoIdle(priority); in EnqueueTaskId()
757 EraseWaitingTaskId(uint64_t taskId, Priority priority) EraseWaitingTaskId() argument
809 GetTaskByPriority(const std::unique_ptr<ExecuteQueue>& taskQueue, Priority priority) GetTaskByPriority() argument
1151 EnqueuePendingTaskInfo(uint64_t taskId, Priority priority) EnqueuePendingTaskInfo() argument
1446 PostTask(std::function<void()> task, const char* taskName, Priority priority) PostTask() argument
1705 CreateOrGetGlobalRunner(napi_env env, napi_value thisVar, size_t argc, const std::string &name, uint32_t priority) CreateOrGetGlobalRunner() argument
[all...]
H A Dtask_group.cpp161 Priority priority = currentGroupInfo_->priority; in NotifyGroupTask() local
163 task->GetTaskInfo(env, napiTask, priority); in NotifyGroupTask()
170 TaskManager::GetInstance().EnqueueTaskId(task->taskId_, priority); in NotifyGroupTask()
H A Dsequence_runner.h39 static void ExecuteTaskImmediately(uint64_t taskId, Priority priority);
H A Dtask_group.h28 Priority priority {Priority::DEFAULT};
H A Dtask.cpp212 napi_value Task::GetTaskInfoPromise(napi_env env, napi_value task, TaskType taskType, Priority priority) in GetTaskInfoPromise() argument
214 TaskInfo* taskInfo = GetTaskInfo(env, task, priority); in GetTaskInfoPromise()
222 TaskInfo* Task::GetTaskInfo(napi_env env, napi_value napiTask, Priority priority) in GetTaskInfo() argument
240 TaskInfo* pendingInfo = GenerateTaskInfo(env, func, args, transferList, cloneList, priority, in GetTaskInfo()
988 napi_value transferList, napi_value cloneList, Priority priority, in GenerateTaskInfo()
1016 taskInfo->priority = priority; in GenerateTaskInfo()
1051 TaskManager::GetInstance().EnqueueTaskId(taskId_, currentTaskInfo_->priority); in NotifyPendingTask()
1371 bool Task::VerifyAndPostResult(Priority priority) in VerifyAndPostResult() argument
1384 TaskManager::GetInstance().PostTask(onResultTask, "TaskPoolOnResultTask", priority); in VerifyAndPostResult()
987 GenerateTaskInfo(napi_env env, napi_value func, napi_value args, napi_value transferList, napi_value cloneList, Priority priority, bool defaultTransfer, bool defaultCloneSendable) GenerateTaskInfo() argument
1428 CheckStartExecution(Priority priority) CheckStartExecution() argument
[all...]
/commonlibrary/c_utils/base/src/
H A Dthread_ex.cpp29 int priority; member
41 int prio = t->priority; in Proxy()
46 // set thread priority in Proxy()
70 t->priority = para.priority; in CreatePThread()
106 ThreadStatus Thread::Start(const std::string& name, int32_t priority, size_t stack) in Start() argument
123 para.priority = priority; in Start()
/commonlibrary/ets_utils/platform/ohos/
H A Dqos_helper.cpp37 int SetWorkerPriority([[maybe_unused]] Priority priority) in SetWorkerPriority() argument
39 return SetThreadQos(WORKERPRIORITY_QOSLEVEL_MAP.at(priority)); in SetWorkerPriority()
42 int SetWorkerPriority(Priority priority)
/commonlibrary/c_utils/base/test/fuzztest/thread_fuzzer/
H A Dthread_fuzzer.cpp44 TestThread(const int data, const bool readyToWork, int priority, ThreadRunFunc runFunc) in TestThread() argument
45 : data_(data), priority_(priority), name_(DEFAULT_THREAD_NAME), readyToWork_(readyToWork), runFunc_(runFunc) in TestThread()
86 bool priority = dataProvider->ConsumeIntegralInRange(0, MAX_PRIORITY); in ThreadTestFunc() local
87 auto t = std::make_unique<TestThread>(0, readyToWork, priority, TestRun); in ThreadTestFunc()
/commonlibrary/ets_utils/platform/default/
H A Dqos_helper.cpp21 int SetWorkerPriority([[maybe_unused]] Priority priority) in SetWorkerPriority() argument
/commonlibrary/ets_utils/platform/
H A Dqos_helper.h22 int SetWorkerPriority(Priority priority);
/commonlibrary/c_utils/base/include/
H A Dthread_ex.h70 * @param priority Indicates the thread priority.
77 ThreadStatus Start(const std::string& name, int32_t priority = THREAD_PROI_NORMAL, size_t stack = 0);
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest_taskpool.cpp907 groupInfo->priority = Priority::DEFAULT; in HWTEST_F()
940 groupInfo->priority = Priority::DEFAULT; in HWTEST_F()
953 groupInfo->priority = Priority::DEFAULT; in HWTEST_F()
1634 napi_value priority = nullptr; in HWTEST_F() local
1635 napi_create_uint32(env, 2, &priority); // 2: LOW priority in HWTEST_F()
1636 napi_value argv[] = { task, priority }; in HWTEST_F()
1650 napi_value priority = nullptr; in HWTEST_F() local
1651 napi_create_uint32(env, 10, &priority); // 10: invalid priority in HWTEST_F()
2315 napi_value priority = nullptr; HWTEST_F() local
2503 napi_value priority = nullptr; HWTEST_F() local
2546 napi_value priority = nullptr; HWTEST_F() local
4318 napi_value priority = nullptr; HWTEST_F() local
4341 napi_value priority = nullptr; HWTEST_F() local
[all...]
H A Dtest.cpp810 Priority priority = Priority::DEFAULT; in PerformTask() local
811 auto& mediumTaskQueue = taskManager.taskQueues_[priority]; in PerformTask()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/
H A Ddecoder.rs467 let priority = Frame::new( in decode_priority_payload()
472 Ok(FrameKind::Complete(priority)) in decode_priority_payload()
686 let priority = self.header.is_headers_priority(); in decode_headers_payload()
701 if priority { in decode_headers_payload()
1185 /// Test a complete Request HEADERS Frames with padding and priority.
1346 /// Test a complete Request HEADERS Frames with padding and priority, the
1450 Payload::Priority(priority) => { in ut_decode_priority_payload()
1451 assert!(priority.get_exclusive()); in ut_decode_priority_payload()
1452 assert_eq!(priority.get_stream_dependency(), 1); in ut_decode_priority_payload()
1453 assert_eq!(priority in ut_decode_priority_payload()
[all...]
H A Dencoder.rs1071 if let Payload::Priority(priority) = frame.payload() { in encode_priority_payload()
1077 self.iterate_priority_payload(priority, buf, frame_header_size, bytes_to_write)?; in encode_priority_payload()
1094 priority: &Priority, in iterate_priority_payload()
1106 *buf_item = (priority.get_exclusive() as u8) << 7 in iterate_priority_payload()
1107 | ((priority.get_stream_dependency() >> 24) & 0x7F) as u8; in iterate_priority_payload()
1111 *buf_item = (priority.get_stream_dependency() in iterate_priority_payload()
1117 *buf_item = priority.get_weight(); in iterate_priority_payload()

Completed in 24 milliseconds