Home
last modified time | relevance | path

Searched defs:task (Results 1 – 25 of 42) sorted by relevance

12

/commonlibrary/c_utils/base/test/unittest/common/
Dutils_thread_pool_test.cpp130 auto task = std::bind(TestFuncAddOneTime, i); variable
136 auto task = std::bind(TestFuncSubOneTime, i); variable
160 auto task = std::bind(TestFuncAddOneTime, i); variable
166 auto task = std::bind(TestFuncSubOneTime, i); variable
208 auto task = std::bind(TestFuncAddWait, i); variable
214 auto task = std::bind(TestFuncSubWait, i); variable
246 auto task = std::bind(TestFuncAddWait, i); variable
252 auto task = std::bind(TestFuncSubWait, i); variable
300 auto task = std::bind(TestFuncGetName, poolName); variable
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
Dtest_taskpool.cpp51 napi_value task = nullptr; in GeneratorTask() local
91 Task* task = Task::GenerateTask(env, thisValue, func, taskName, args, argc); in CreateTaskObject() local
117 Task* task = nullptr; in CreateNullTaskObject() local
172 Task* task = taskManager.GetTask(taskId); variable
300 Task* task = new Task(); variable
311 Task* task = new Task(); variable
322 Task* task = new Task(); variable
395 Task* task = new Task(); variable
416 auto task = new Task(); variable
431 auto task = new Task(); variable
[all …]
Dtest.cpp185 Task* task = reinterpret_cast<Task*>(handle->data); in UpdateGroupInfoByResult() local
332 Task* task = new Task(); in CancelTask() local
363 Task* task = new Task(); in NotifyWorkerIdle() local
380 Task* task = new Task(); in EnqueueTaskId() local
400 Task* task = new Task(); in GetTaskByPriority() local
424 Task* task = new Task(); in RestoreWorker() local
473 Task* task = new Task(); in NotifyDependencyTaskInfo() local
497 Task* task = new Task(); in StoreTaskDependency() local
535 Task* task = new Task(); in RemoveTaskDependency() local
562 Task* task = new Task(); in ReleaseTaskData() local
[all …]
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
Dtaskpool.cpp171 auto task = TaskManager::GetInstance().GetTask(taskId); in TerminateTask() local
209 Task* task = nullptr; in Execute() local
231 …Task* task = Task::GenerateFunctionTask(env, args[0], args + 1, argc - 1, TaskType::FUNCTION_TASK); in Execute() local
244 auto task = TaskManager::GetInstance().GetTask(taskMessage->taskId); in DelayTask() local
297 Task* task = nullptr; in ExecuteDelayed() local
370 Task* task = nullptr; in ExecuteGroup() local
389 void TaskPool::HandleTaskResult(Task* task) in HandleTaskResult()
406 void TaskPool::HandleTaskResultInner(Task* task) in HandleTaskResultInner()
444 void TaskPool::TriggerTask(Task* task, bool isCancel) in TriggerTask()
482 void TaskPool::UpdateGroupInfoByResult(napi_env env, Task* task, napi_value res, bool success) in UpdateGroupInfoByResult()
[all …]
Dworker.cpp153 auto task = std::move(worker->debuggerQueue_.front()); in HandleDebuggerTask() local
159 void Worker::DebuggerOnPostTask(std::function<void()>&& task) in DebuggerOnPostTask()
272 workerEngine->SetDebuggerPostTaskFunc([this](std::function<void()>&& task) { in PrepareForWorkerInstance()
285 Task* task = static_cast<Task*>(data); in PrepareForWorkerInstance() local
300 Task* task = static_cast<Task*>(data); in PrepareForWorkerInstance() local
433 Task* task = TaskManager::GetInstance().GetTask(taskInfo.first); in PerformTask() local
500 void Worker::NotifyTaskResult(napi_env env, Task* task, napi_value result) in NotifyTaskResult()
523 void Worker::NotifyHandleTaskResult(Task* task) in NotifyHandleTaskResult()
559 Task* task = static_cast<Task*>(data); in TaskResultCallback() local
611 bool Worker::InitTaskPoolFunc(napi_env env, napi_value func, Task* task) in InitTaskPoolFunc()
[all …]
Dtask.cpp81 Task* task = GenerateTask(env, thisVar, func, name, args, argc); in TaskConstructor() local
103 Task* task; in LongTaskConstructor() local
111 Task* task = static_cast<Task*>(data); in TaskDestructor() local
144 Task* task = static_cast<Task*>(arg); in CleanupHookFunc() local
169 Task* task = TaskManager::GetInstance().GetTask(message->taskId); in Cancel() local
198 Task* task = new Task(env, TaskType::TASK, nameStr); in GenerateTask() local
244 Task* task = new Task(env, type, nameStr); in GenerateFunctionTask() local
255 napi_value Task::GetTaskInfoPromise(napi_env env, napi_value task, TaskType taskType, Priority prio… in GetTaskInfoPromise()
308 Task* task = nullptr; in SetTransferList() local
368 Task* task = nullptr; in SetCloneList() local
[all …]
Dasync_runner.cpp113 Task* task = nullptr; in Execute() local
212 void AsyncRunner::ExecuteTaskImmediately(AsyncRunner* asyncRunner, Task* task) in ExecuteTaskImmediately()
222 bool AsyncRunner::AddTasksToAsyncRunner(AsyncRunner* asyncRunner, Task* task) in AddTasksToAsyncRunner()
258 bool AsyncRunner::RemoveWaitingTask(Task* task, bool isReject) in RemoveWaitingTask()
282 void AsyncRunner::TriggerRejectErrorTimer(Task* task, int32_t errCode, bool isWaiting) in TriggerRejectErrorTimer()
298 Task* task = nullptr; in TriggerWaitingTask() local
Dsequence_runner.cpp130 Task* task = nullptr; in Execute() local
173 bool SequenceRunner::RemoveWaitingTask(Task* task) in RemoveWaitingTask()
200 void SequenceRunner::AddTask(Task* task) in AddTask()
213 Task* task = seqRunnerTasks_.front(); in TriggerTask() local
Dtask_group.cpp106 Task* task = nullptr; in AddTask() local
122 …Task* task = Task::GenerateFunctionTask(env, args[0], args + 1, argc - 1, TaskType::GROUP_FUNCTION… in AddTask() local
195 Task* task = nullptr; in NotifyGroupTask() local
Dsequence_runner_manager.cpp98 void SequenceRunnerManager::AddTaskToSeqRunner(uint64_t seqRunnerId, Task* task) in AddTaskToSeqRunner()
130 void SequenceRunnerManager::RemoveWaitingTask(Task* task) in RemoveWaitingTask()
Dtask_group_manager.cpp61 Task* task = TaskManager::GetInstance().GetTask(taskId); in ReleaseTaskGroupData() local
126 auto task = TaskManager::GetInstance().GetTask(taskId); in CancelGroupTask() local
Dthread.cpp43 auto task = [this]() { in Start() local
Dasync_runner_manager.cpp106 void AsyncRunnerManager::CancelAsyncRunnerTask(napi_env env, Task* task) in CancelAsyncRunnerTask()
138 void AsyncRunnerManager::RemoveWaitingTask(Task* task) in RemoveWaitingTask()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
Dylong_tokio_async_file.rs37 let task = || async { localVariable
61 let task = || async { localVariable
88 let task = || async { localVariable
Dylong_tokio_file.rs63 let task = || async { localVariable
89 let task = || async { localVariable
117 let task = || async { localVariable
148 let task = || async { localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dblock_on.rs78 async fn task() -> i32 { in sdv_block_on_nest_spawn_spawn_blocking() function
108 async fn task() -> i32 { in sdv_block_on_nest_spawn_and_spawn() function
149 async fn task() -> i32 { in sdv_block_on_nest_spawn_nest_spawn() function
183 async fn task() -> i32 { in sdv_block_on_nest_spawn_nest_spawn2() function
203 async fn task() -> i32 { in sdv_block_on_nest_batch_spawn() function
228 async fn task() -> usize { in sdv_block_on_nest_await_spawn() function
262 async fn task() -> usize { in sdv_block_on_nest_await_spawn_bug_test() function
Dtask_cancel.rs35 let task = ylong_runtime::spawn(async move { in sdv_task_cancel_simple() localVariable
57 let task = ylong_runtime::spawn(async move { 1 }); in sdv_task_cancel_failed() localVariable
/commonlibrary/ets_utils/js_concurrent_module/utils/condition/
Dcondition_variable.cpp76 ConditionTask *task = new ConditionTask(this, env, deferred, timeout); in AddTask() local
86 ConditionTask *task = tasks_.front(); in FinishTask() local
101 void ConditionVariable::FindAndFinishTask(ConditionTask *task, ConditionTaskFinishReason reason) in FindAndFinishTask()
Dcondition_task.cpp64 ConditionTask *task {static_cast<ConditionTask *>(arg)}; in EnvCleanup() local
101 ConditionTask *task {static_cast<ConditionTask *>(timer->data)}; in InitTimer() local
/commonlibrary/rust/ylong_http/ylong_http/tests/
Dsdv_http_body.rs84 let mut task = ChunkBody::from_async_reader(content.as_slice()); in sdv_async_chunk_body_from_async_reader() localVariable
111 let mut task = ChunkBody::from_bytes(content.as_slice()); in sdv_async_chunk_body_from_bytes() localVariable
140 let mut task = ChunkBody::from_bytes(content.as_slice()).set_trailer(headers); in sdv_chunk_body_encode_trailer_0() localVariable
/commonlibrary/c_utils/base/src/
Dthread_pool.cpp100 Task task; in ScheduleTask() local
120 Task task = ScheduleTask(); in WorkInThread() local
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
Dlib.rs43 pub mod task; module
Dspawn.rs53 let task = BlockingTask(Some(task)); localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
Dqueue.rs232 let task = self.buffer[(pos & MASK) as usize].get(); in pop_front() localVariable
322 let task = unsafe { ptr::read(task_ptr).assume_init() }; in push_overflowed() localVariable
391 let task = unsafe { ptr::read(task_ptr).assume_init() }; in steal_into() localVariable
404 let task = unsafe { ptr::read(task_ptr).assume_init() }; in steal_into() localVariable
438 let task = self.pop_front().unwrap(); in drop() localVariable
461 let task = unsafe { ptr::read(task_ptr.get()).assume_init() }; in push_batch() localVariable
520 let task = list in pop_front() localVariable
615 let task = self.pop_front(); in pop_front_and_release() localVariable
622 let task = self.steal_into(other); in steal_into_and_release() localVariable
/commonlibrary/rust/ylong_http/ylong_http/src/h1/request/
Dencoder.rs484 let mut task = WriteData::new(version, &mut self.src_idx, buf); in encode() localVariable
545 let mut task = WriteData::new(name, &mut self.name_idx, buf); in encode_name() localVariable
560 let mut task = WriteData::new(colon, &mut self.colon_idx, buf); in encode_colon() localVariable
575 let mut task = WriteData::new(value, &mut self.value_idx, buf); in encode_value() localVariable
624 let mut task = WriteData::new(sp, &mut self.src_idx, buf); in encode() localVariable
640 let mut task = WriteData::new(crlf, &mut self.src_idx, buf); in encode() localVariable

12