| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_multi_threaded.rs | 56 let (send, recv) = mpsc::sync_channel(TASK_NUM);
68 let _ = recv.recv().unwrap();
104 let (send, recv) = mpsc::sync_channel(TASK_NUM); in chained_spawn()
113 recv.recv().unwrap(); in chained_spawn()
147 let (send, recv) = mpsc::sync_channel(TASK_NUM); in chained_spawn()
154 recv.recv().unwrap(); in chained_spawn()
|
| H A D | sync_benchmarks.rs | 101 let (send, recv) = mpsc::sync_channel(TASK_NUM); in std_multi_threaded_ping()
112 recv.recv().unwrap(); in std_multi_threaded_ping()
119 let (send, recv) = mpsc::sync_channel(TASK_NUM); in std_multi_threaded_ping_pong()
129 recv1.recv().unwrap(); in std_multi_threaded_ping_pong()
134 recv2.recv().unwrap(); in std_multi_threaded_ping_pong()
141 recv.recv().unwrap(); in std_multi_threaded_ping_pong()
|
| H A D | ylong_tokio_signal.rs | 41 stream.recv().await;
66 stream.recv().await;
90 stream.recv().await;
115 stream.recv().await;
|
| H A D | ylong_tokio_bounded_mpsc.rs | 34 let res = receiver.recv().await.unwrap();
68 let res = receiver.recv().await.unwrap();
|
| H A D | ylong_tokio_unbounded_mpsc.rs | 34 let res = receiver.recv().await.unwrap();
68 let res = receiver.recv().await.unwrap();
|
| H A D | ylong_tokio_udp.rs | 74 /// Benchmark test for ylong udp function send() and recv().
80 /// 3. Receiver use recv() to receives message.
109 let len = connected_receiver.recv(&mut recv_buf[..]).await.unwrap(); in ylong_udp_send_recv()
121 /// Benchmark test for tokio udp function send() and recv().
127 /// 3. Receiver use recv() to receives message.
150 let len = receiver.recv(&mut recv_buf[..]).await.unwrap(); in tokio_udp_send_recv()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | signal.rs | 41 /// SDV cases for signal `recv()`.
54 stream.recv().await; in sdv_signal_recv_test()
60 /// SDV cases for signal `recv()` in multi thread.
75 stream.recv().await; in sdv_signal_recv_multi_thread_test()
119 stream.recv().await; in sdv_signal_poll_recv_multi_thread_test()
139 signal.recv().await; in sdv_signal_alarm()
154 signal.recv().await; in sdv_signal_child()
169 signal.recv().await; in sdv_signal_hangup()
184 signal.recv().await; in sdv_signal_interrupt()
199 signal.recv() in sdv_signal_io()
[all...] |
| H A D | mpsc_test.rs | 31 assert_eq!(rx.recv().await, Ok(1)); in sdv_unbounded_send_recv_test()
32 assert_eq!(rx.recv().await, Ok(2)); in sdv_unbounded_send_recv_test()
33 assert_eq!(rx.recv().await, Err(RecvError)); in sdv_unbounded_send_recv_test()
51 assert_eq!(rx.recv().await, Ok(1)); in sdv_unbounded_send_recv_drop_test()
52 assert_eq!(rx.recv().await, Ok(2)); in sdv_unbounded_send_recv_drop_test()
106 assert_eq!(rx.recv().await, Ok(1)); in sdv_bounded_send_recv_test()
107 assert_eq!(rx.recv().await, Ok(2)); in sdv_bounded_send_recv_test()
108 assert_eq!(rx.recv().await, Err(RecvError)); in sdv_bounded_send_recv_test()
128 assert_eq!(rx.recv().await, Ok(1)); in sdv_bounded_send_recv_drop_test()
129 assert_eq!(rx.recv() in sdv_bounded_send_recv_drop_test()
[all...] |
| H A D | timer_test.rs | 29 let recv = RECV_SIZE;
30 left -= recv;
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | mod.rs | 53 /// signal.recv().await;
90 /// signal.recv().await;
112 /// signal.recv().await;
134 /// signal.recv().await;
156 /// signal.recv().await;
178 /// signal.recv().await;
200 /// signal.recv().await;
222 /// signal.recv().await;
244 /// signal.recv().await;
266 /// signal.recv()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| H A D | sdv_async_http2.rs | 123 .recv()
158 .recv() in sdv_async_h2_client_send_request()
160 .expect("recv server start msg failed !"); in sdv_async_h2_client_send_request()
165 let mut handle = rx.recv().expect("recv Handle failed !"); in sdv_async_h2_client_send_request()
212 .recv() in sdv_async_h2_client_send_request()
238 .recv() in sdv_async_h2_client_send_request_concurrently()
240 .expect("recv server start msg failed !"); in sdv_async_h2_client_send_request_concurrently()
245 let mut handle = rx.recv().expect("recv Handl in sdv_async_h2_client_send_request_concurrently()
[all...] |
| H A D | sdv_async_http_client_error.rs | 156 .recv() in sdv_err_req_timeout()
221 .recv() in sdv_err_redirect_wrong_location()
292 .recv() in sdv_err_response_with_wrong_body_length()
|
| H A D | sdv_async_custom_dns_resolver.rs | 84 .recv() in sdv_client_custom_dns_resolver()
|
| H A D | sdv_async_http_proxy.rs | 132 .recv() in sdv_async_client_send_request()
|
| H A D | sdv_async_http_body_io.rs | 101 .recv() in sdv_body_chunk_and_trailer()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | streams.rs | 55 // send PP | | recv PP
61 // ,------| reserved | | recv H | reserved |------.
65 // | | recv ES | | send ES | |
66 // | send H | ,-------| open |-------. | recv H |
72 // | | (remote) | | recv R | (local) | |
75 // | | send ES / | recv ES / | |
77 // | | recv R +--------+ recv R | |
79 // | recv R | closed | recv
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | datagram.rs | 137 /// Trys to recv message.
170 .try_io(Interest::READABLE, || (*self.source).recv(buf)) in try_recv()
365 /// socket.recv(buf.as_mut_slice()).await.expect("recv failed");
369 pub async fn recv(&self, buf: &mut [u8]) -> Result<usize> {
371 .async_process(Interest::READABLE, || self.source.recv(buf))
489 /// 2. Client Sends message and server recv it.
504 server.recv(buf.as_mut_slice()).await.expect("recv failed"); in ut_uds_datagram_read_write_test()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_signal.rs | 46 stream.recv().await; in run_multi_thread_signal()
65 stream.recv().await; in run_multi_thread_signal()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 367 let recv = crate::runtime::spawn(async move { in launch()
369 let mut recv = RecvData::new(decoder, recv_settings_sync, read, resp_tx); in launch() variables
370 let _ = Pin::new(&mut recv).await; in launch()
372 handles.push(recv); in launch()
557 pub(crate) async fn recv(&mut self) -> Result<Frame, HttpClientError> {
561 match receiver.recv().await {
570 match receiver.recv().await {
818 match self.resp_receiver.recv().await {
827 match self.resp_receiver.recv().await {
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/ |
| H A D | mod.rs | 53 /// signal.recv().await;
66 /// signal.recv().await;
86 /// signal.recv().await;
99 /// signal.recv().await;
104 pub async fn recv(&mut self) {
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | datagram.rs | 180 /// socket.recv(buf.as_mut_slice()).expect("recv failed");
184 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv() functions
185 self.inner.recv(buf) in recv()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/common/ |
| H A D | mod.rs | 73 .recv()
94 .recv()
104 .recv()
141 .recv()
406 .recv()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | udp_socket_test.rs | 18 /// SDV test cases for `send()` and `recv()`.
68 match connected_receiver.recv(&mut recv_buf[..]) { in sdv_send_recv()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | mod.rs | 576 .recv() in ut_ssl_tunnel_error()
616 .recv() in ut_ssl_tunnel_error()
653 .recv() in ut_ssl_tunnel_error()
697 .recv() in ut_ssl_tunnel_connect()
750 .recv() in ut_ssl_tunnel_resp_beyond_size()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/udp/ |
| H A D | udp_socket.rs | 24 /// UdpSocket supports bind\connect\send\recv\send_to\recv_from\broadcast.
60 /// let len = connected_receiver.recv(&mut buf)?;
238 /// and limiting packets that are read via recv from the address specified
569 /// let n = connected_sock.recv(&mut recv_buf[..])?;
574 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv() functions
576 inner.recv(buf) in recv()
|