Home
last modified time | relevance | path

Searched defs:recv (Results 1 – 13 of 13) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/
Dmod.rs104 pub async fn recv(&mut self) { in recv() method
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dtimer_test.rs29 let recv = RECV_SIZE; in download() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
Dmod.rs319 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() method
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
Dmod.rs439 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() method
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
Ddatagram.rs369 pub async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv() method
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
Ddatagram.rs184 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv() method
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
Ddispatcher.rs522 let recv = crate::runtime::spawn(async move { in launch() localVariable
524 let mut recv = RecvData::new(decoder, recv_settings_sync, read, resp_tx); in launch() localVariable
728 pub(crate) async fn recv(&mut self) -> Result<Frame, HttpClientError> { in recv() method
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/
Dudp_socket.rs456 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv() method
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/
Dudp_socket.rs574 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv() method
/commonlibrary/ets_utils/js_concurrent_module/worker/
Dworker.cpp834 void CallWorkCallback(napi_env env, napi_value recv, size_t argc, const napi_value* argv, const cha… in CallWorkCallback()
2253 bool Worker::HandleEventListeners(napi_env env, napi_value recv, size_t argc, const napi_value* arg… in HandleEventListeners()
2588 void Worker::ParentPortHandleEventListeners(napi_env env, napi_value recv, size_t argc, in ParentPortHandleEventListeners()
/commonlibrary/ets_utils/js_concurrent_module/test/
Dtest_concurrent.cpp775 napi_value recv = nullptr; variable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/
Dudp.rs1077 pub async fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv() method
/commonlibrary/ets_utils/js_concurrent_module/worker/test/
Dtest_worker.cpp989 napi_value recv = NapiHelper::CreateObject(env); in ParentPortHandleEventListeners() local