| /commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
| D | sync_https_outside.rs | 31 fn req() -> Result<(), HttpClientError> { in req() function
|
| D | async_https_outside.rs | 37 async fn req() -> Result<(), HttpClientError> { in req() function
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/ |
| D | worker.cpp | 83 void Worker::ReleaseWorkerHandles(const uv_async_t* req) in ReleaseWorkerHandles()
145 void Worker::HandleDebuggerTask(const uv_async_t* req) in HandleDebuggerTask()
377 void Worker::TriggerGCCheck(const uv_async_t* req) in TriggerGCCheck()
413 void Worker::PerformTask(const uv_async_t* req) in PerformTask()
|
| D | task_group.cpp | 155 void TaskGroup::StartRejectResult(const uv_async_t* req) in StartRejectResult()
|
| D | taskpool.cpp | 107 void TaskPool::ExecuteCallback(const uv_async_t* req) in ExecuteCallback()
424 void TaskPool::HandleTaskResult(const uv_async_t* req) in HandleTaskResult()
|
| D | task_manager.cpp | 516 void TaskManager::TriggerLoadBalance([[maybe_unused]] const uv_timer_t* req) in TriggerLoadBalance()
525 void TaskManager::DispatchAndTryExpand([[maybe_unused]] const uv_async_t* req) in DispatchAndTryExpand()
545 void TaskManager::TryExpand([[maybe_unused]] const uv_timer_t* req) in TryExpand()
1069 MsgQueue* TaskManager::GetMessageQueue(const uv_async_t* req) in GetMessageQueue()
|
| D | task.cpp | 157 void Task::Cancel(const uv_async_t* req) in Cancel()
707 void Task::StartExecutionCallback(const uv_async_t* req) in StartExecutionCallback()
1794 void Task::DiscardTask(const uv_async_t* req) in DiscardTask()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test.cpp | 228 void NativeEngineTest::foo(const uv_async_t* req) in foo()
750 uv_async_t* req = new uv_async_t; in ReleaseWorkerHandles() local
766 uv_async_t* req = new uv_async_t; in DebuggerOnPostTask() local
815 uv_async_t* req = new uv_async_t; in PerformTask() local
931 uv_async_t* req = new uv_async_t; in WorkerPostTask() local
|
| D | test_taskpool.cpp | 2021 uv_async_t* req = new uv_async_t; variable
2052 uv_async_t* req = new uv_async_t; variable
2086 uv_async_t* req = new uv_async_t; variable
3469 uv_async_t* req = new uv_async_t; variable
3482 uv_async_t* req = new uv_async_t; variable
5784 uv_async_t* req = new uv_async_t; variable
5868 uv_async_t* req = new uv_async_t; variable
6082 uv_async_t* req = new uv_async_t; variable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | connector.rs | 152 let mut req = Vec::new(); in tunnel() localVariable
|
| D | client.rs | 525 let mut req = Request::new(body); in ut_request_client_err() localVariable
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/ |
| D | worker.cpp | 1538 void Worker::HostOnMessage(const uv_async_t* req) in HostOnMessage()
1621 void Worker::HostOnGlobalCall(const uv_async_t* req) in HostOnGlobalCall()
1842 void Worker::HostOnError(const uv_async_t* req) in HostOnError()
2117 void Worker::WorkerOnMessage(const uv_async_t* req) in WorkerOnMessage()
2564 void Worker::HandleDebuggerTask(const uv_async_t* req) in HandleDebuggerTask()
2675 void Worker::HostOnAllErrors(const uv_async_t* req) in HostOnAllErrors()
|
| /commonlibrary/ets_utils/js_concurrent_module/worker/test/ |
| D | test_worker.cpp | 188 static void WorkerOnMessage(const uv_async_t *req) in WorkerOnMessage()
220 static void HostOnMessage(const uv_async_t *req) in HostOnMessage()
368 uv_async_t* req = new uv_async_t; in TestHostOnMessageInner() local
404 uv_async_t* req = new uv_async_t; in HostOnGlobalCall() local
747 uv_async_t* req = new uv_async_t; in TestWorkerOnMessageInner() local
1353 uv_async_t* req = new uv_async_t; variable
1384 uv_async_t* req = new uv_async_t; variable
1788 uv_async_t* req = new uv_async_t; variable
2108 uv_async_t* req = new uv_async_t; variable
2156 uv_async_t* req = new uv_async_t; variable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 483 let mut req = Vec::new(); in tunnel() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| D | stream_manager.rs | 745 let req = match this.poll_recv_request(cx) { in poll() localVariable
|