| /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()
380 void Worker::TriggerGCCheck(const uv_async_t* req) in TriggerGCCheck()
416 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 | task.cpp | 162 void Task::Cancel(const uv_async_t* req) in Cancel()
692 void Task::StartExecutionCallback(const uv_async_t* req) in StartExecutionCallback()
1775 void Task::DiscardTask(const uv_async_t* req) in DiscardTask()
|
| D | task_manager.cpp | 538 void TaskManager::TriggerLoadBalance([[maybe_unused]] const uv_timer_t* req) in TriggerLoadBalance()
547 void TaskManager::DispatchAndTryExpand([[maybe_unused]] const uv_async_t* req) in DispatchAndTryExpand()
567 void TaskManager::TryExpand([[maybe_unused]] const uv_timer_t* req) in TryExpand()
|
| /commonlibrary/ets_utils/js_concurrent_module/taskpool/test/ |
| D | test.cpp | 228 void NativeEngineTest::foo(const uv_async_t* req) in foo()
748 uv_async_t* req = new uv_async_t; in ReleaseWorkerHandles() local
764 uv_async_t* req = new uv_async_t; in DebuggerOnPostTask() local
813 uv_async_t* req = new uv_async_t; in PerformTask() local
922 uv_async_t* req = new uv_async_t; in WorkerPostTask() local
1014 uv_async_t* req = new uv_async_t; in PerformTask() local
|
| D | test_taskpool.cpp | 2090 uv_async_t* req = new uv_async_t; variable
2122 uv_async_t* req = new uv_async_t; variable
3503 uv_async_t* req = new uv_async_t; variable
3516 uv_async_t* req = new uv_async_t; variable
5817 uv_async_t* req = new uv_async_t; variable
5901 uv_async_t* req = new uv_async_t; variable
6115 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 | 1613 void Worker::HostOnMessage(const uv_async_t* req) in HostOnMessage()
1698 void Worker::HostOnGlobalCall(const uv_async_t* req) in HostOnGlobalCall()
1919 void Worker::HostOnError(const uv_async_t* req) in HostOnError()
2200 void Worker::WorkerOnMessage(const uv_async_t* req) in WorkerOnMessage()
2647 void Worker::HandleDebuggerTask(const uv_async_t* req) in HandleDebuggerTask()
2762 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()
372 uv_async_t* req = new uv_async_t; in TestHostOnMessageInner() local
408 uv_async_t* req = new uv_async_t; in HostOnGlobalCall() local
751 uv_async_t* req = new uv_async_t; in TestWorkerOnMessageInner() local
1371 uv_async_t* req = new uv_async_t; variable
1402 uv_async_t* req = new uv_async_t; variable
1815 uv_async_t* req = new uv_async_t; variable
2147 uv_async_t* req = new uv_async_t; variable
2195 uv_async_t* req = new uv_async_t; variable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 487 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
|