Home
last modified time | relevance | path

Searched refs:req (Results 1 - 20 of 20) sorted by relevance

/commonlibrary/rust/ylong_http/ylong_http_client/examples/
H A Dsync_https_outside.rs22 let handle = std::thread::spawn(|| req); in main()
31 fn req() -> Result<(), HttpClientError> { in req() functions
H A Dasync_https_outside.rs26 let handle = rt.spawn(req()); in main()
37 async fn req() -> Result<(), HttpClientError> {
/commonlibrary/ets_utils/js_concurrent_module/taskpool/
H A Dworker.cpp84 void Worker::ReleaseWorkerHandles(const uv_async_t* req) in ReleaseWorkerHandles() argument
86 auto worker = static_cast<Worker*>(req->data); in ReleaseWorkerHandles()
146 void Worker::HandleDebuggerTask(const uv_async_t* req) in HandleDebuggerTask() argument
148 Worker* worker = reinterpret_cast<Worker*>(req->data); in HandleDebuggerTask()
344 void Worker::TriggerGCCheck(const uv_async_t* req) in TriggerGCCheck() argument
346 if (req == nullptr || req->data == nullptr) { in TriggerGCCheck()
347 HILOG_ERROR("taskpool:: req handle is invalid"); in TriggerGCCheck()
350 auto worker = reinterpret_cast<Worker*>(req->data); in TriggerGCCheck()
381 void Worker::PerformTask(const uv_async_t* req) in PerformTask() argument
[all...]
H A Dworker.h114 static void HandleDebuggerTask(const uv_async_t* req);
188 static void PerformTask(const uv_async_t* req);
190 static void ReleaseWorkerHandles(const uv_async_t* req);
191 static void TriggerGCCheck(const uv_async_t* req);
H A Dtaskpool.h37 static void ExecuteCallback(const uv_async_t* req);
39 static void HandleTaskResult(const uv_async_t* req);
H A Dtask_manager.h106 MsgQueue* GetMessageQueue(const uv_async_t* req);
170 static void NotifyExpand(const uv_async_t* req);
171 static void TriggerLoadBalance(const uv_timer_t* req = nullptr);
H A Dtaskpool.cpp106 void TaskPool::ExecuteCallback(const uv_async_t* req) in ExecuteCallback() argument
108 auto* msgQueue = TaskManager::GetInstance().GetMessageQueue(req); in ExecuteCallback()
406 void TaskPool::HandleTaskResult(const uv_async_t* req) in HandleTaskResult() argument
410 auto task = static_cast<Task*>(req->data); in HandleTaskResult()
H A Dtask.h112 static void StartExecutionCallback(const uv_async_t* req);
H A Dtask_manager.cpp507 void TaskManager::TriggerLoadBalance(const uv_timer_t* req) in TriggerLoadBalance() argument
554 void TaskManager::NotifyExpand(const uv_async_t* req) in NotifyExpand() argument
998 MsgQueue* TaskManager::GetMessageQueue(const uv_async_t* req) in GetMessageQueue() argument
1001 auto info = static_cast<CallbackInfo*>(req->data); in GetMessageQueue()
H A Dtask.cpp641 void Task::StartExecutionCallback(const uv_async_t* req) in StartExecutionCallback() argument
644 auto listenerCallBackInfo = static_cast<ListenerCallBackInfo*>(req->data); in StartExecutionCallback()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dstream_manager.rs745 let req = match this.poll_recv_request(cx) {
746 Poll::Ready(Ok(req)) => req,
756 req.request.header,
757 req.request.data,
758 req.frame_tx.clone(),
760 let _ = req.frame_tx.try_send(RespMessage::OutputExit(e));
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dclient.rs525 let mut req = Request::new(body); in ut_request_client_err() variables
526 let request_uri = req.uri_mut(); in ut_request_client_err()
528 let response = client.request(req); in ut_request_client_err()
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.h111 * @param req The value of the object passed in by the js layer.
113 static void HostOnMessage(const uv_async_t* req);
118 * @param req The value of the object passed in by the js layer.
120 static void HostOnError(const uv_async_t* req);
125 * @param req The value of the object passed in by the js layer.
127 static void WorkerOnMessage(const uv_async_t* req);
365 static void HostOnGlobalCall(const uv_async_t* req);
547 static void HandleDebuggerTask(const uv_async_t* req);
H A Dworker.cpp1394 void Worker::HostOnMessage(const uv_async_t* req) in HostOnMessage() argument
1397 Worker* worker = static_cast<Worker*>(req->data); in HostOnMessage()
1466 void Worker::HostOnGlobalCall(const uv_async_t* req) in HostOnGlobalCall() argument
1469 Worker* worker = static_cast<Worker*>(req->data); in HostOnGlobalCall()
1683 void Worker::HostOnError(const uv_async_t* req) in HostOnError() argument
1685 Worker* worker = static_cast<Worker*>(req->data); in HostOnError()
1922 void Worker::WorkerOnMessage(const uv_async_t* req) in WorkerOnMessage() argument
1925 Worker* worker = static_cast<Worker*>(req->data); in WorkerOnMessage()
2371 void Worker::HandleDebuggerTask(const uv_async_t* req) in HandleDebuggerTask() argument
2373 Worker* worker = DereferenceHelp::DereferenceOf(&Worker::debuggerOnPostTaskSignal_, req); in HandleDebuggerTask()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_http2.rs44 req: hyper::Request<hyper::Body>,
46 let (parts, mut body) = req.into_parts();
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dmod.rs419 let mut req = Vec::new(); variables
422 &mut req,
427 write!(&mut req, "Proxy-Authorization: Basic {value}\r\n")?;
430 write!(&mut req, "\r\n")?;
432 conn.write_all(&req).await?;
/commonlibrary/ets_utils/js_concurrent_module/taskpool/test/
H A Dtest.h53 static void foo(const uv_async_t* req);
H A Dtest.cpp225 void NativeEngineTest::foo(const uv_async_t* req) in foo() argument
752 uv_async_t* req = new uv_async_t; in ReleaseWorkerHandles() local
753 req->data = worker; in ReleaseWorkerHandles()
754 Worker::ReleaseWorkerHandles(req); in ReleaseWorkerHandles()
768 uv_async_t* req = new uv_async_t; in DebuggerOnPostTask() local
773 req->data = worker; in DebuggerOnPostTask()
775 Worker::HandleDebuggerTask(req); in DebuggerOnPostTask()
818 uv_async_t* req = new uv_async_t; in PerformTask() local
819 req->data = worker; in PerformTask()
823 Worker::PerformTask(req); in PerformTask()
[all...]
H A Dtest_taskpool.cpp2040 uv_async_t* req = new uv_async_t; in HWTEST_F() local
2041 req->data = cbInfo; in HWTEST_F()
2043 TaskPool::ExecuteCallback(req); in HWTEST_F()
2056 TaskPool::ExecuteCallback(req); in HWTEST_F()
2071 uv_async_t* req = new uv_async_t; in HWTEST_F() local
2072 req->data = cbInfo; in HWTEST_F()
2090 TaskPool::ExecuteCallback(req); in HWTEST_F()
2105 uv_async_t* req = new uv_async_t; in HWTEST_F() local
2106 req->data = cbInfo; in HWTEST_F()
2134 TaskPool::ExecuteCallback(req); in HWTEST_F()
3411 uv_async_t* req = new uv_async_t; HWTEST_F() local
3424 uv_async_t* req = new uv_async_t; HWTEST_F() local
[all...]
/commonlibrary/ets_utils/js_concurrent_module/worker/test/
H A Dtest_worker.cpp90 static void WorkerOnMessage(const uv_async_t *req) in WorkerOnMessage() argument
92 Worker *worker = static_cast<Worker*>(req->data); in WorkerOnMessage()
122 static void HostOnMessage(const uv_async_t *req) in HostOnMessage() argument
124 Worker *worker = static_cast<Worker*>(req->data); in HostOnMessage()
268 uv_async_t* req = new uv_async_t; in TestHostOnMessageInner() local
269 req->data = nullptr; in TestHostOnMessageInner()
270 Worker::HostOnMessage(req); in TestHostOnMessageInner()
271 delete req; in TestHostOnMessageInner()
304 uv_async_t* req = new uv_async_t; in HostOnGlobalCall() local
305 req in HostOnGlobalCall()
647 uv_async_t* req = new uv_async_t; TestWorkerOnMessageInner() local
1107 uv_async_t* req = new uv_async_t; HWTEST_F() local
1138 uv_async_t* req = new uv_async_t; HWTEST_F() local
1544 uv_async_t* req = new uv_async_t; HWTEST_F() local
1858 uv_async_t* req = new uv_async_t; HWTEST_F() local
1906 uv_async_t* req = new uv_async_t; HWTEST_F() local
[all...]

Completed in 38 milliseconds