Home
last modified time | relevance | path

Searched refs:send (Results 1 - 25 of 37) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_multi_threaded.rs33 sender.send(()).unwrap(); in runtime_spawn_many()
42 sender.send(()).unwrap(); in runtime_yield_many()
56 let (send, recv) = mpsc::sync_channel(TASK_NUM);
61 $fn(&runtime, send.clone());
96 sender.send(()).unwrap(); in chained_spawn()
104 let (send, recv) = mpsc::sync_channel(TASK_NUM); in chained_spawn()
108 let sender = send.clone(); in chained_spawn()
140 sender.send(()).unwrap(); in chained_spawn()
147 let (send, recv) = mpsc::sync_channel(TASK_NUM); in chained_spawn()
150 let sender = send in chained_spawn()
[all...]
H A Dsync_benchmarks.rs101 let (send, recv) = mpsc::sync_channel(TASK_NUM); in std_multi_threaded_ping()
104 let sender = send.clone(); in std_multi_threaded_ping()
107 sender.send(()).unwrap(); in std_multi_threaded_ping()
119 let (send, recv) = mpsc::sync_channel(TASK_NUM); in std_multi_threaded_ping_pong()
122 let done_send = send.clone(); in std_multi_threaded_ping_pong()
130 send2.send(()).unwrap(); in std_multi_threaded_ping_pong()
133 send1.send(()).unwrap(); in std_multi_threaded_ping_pong()
136 done_send.send(()).unwrap(); in std_multi_threaded_ping_pong()
H A Dylong_tokio_bounded_mpsc.rs44 producer.send(1).await.unwrap();
78 producer.send(1).await.unwrap();
H A Dylong_tokio_unbounded_mpsc.rs44 producer.send(1).unwrap();
78 producer.send(1).unwrap();
H A Dylong_tokio_udp.rs74 /// Benchmark test for ylong udp function send() and recv().
79 /// 2. Sender use send() to send message.
106 connected_sender.send(b"Hello").await.unwrap(); in ylong_udp_send_recv()
121 /// Benchmark test for tokio udp function send() and recv().
126 /// 2. Sender use send() to send message.
147 sender.send(b"Hello").await.unwrap(); in tokio_udp_send_recv()
166 /// 2. Sender use send_to() to send message.
209 /// 2. Sender use send_to() to send messag
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dmpsc_test.rs35 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_test()
36 assert!(tx.send(2).is_ok()); in sdv_unbounded_send_recv_test()
54 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_drop_test()
55 assert!(tx.send(2).is_ok()); in sdv_unbounded_send_recv_drop_test()
70 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_try_recv_test()
86 assert!(tx.send(1).is_ok()); in sdv_unbounded_send_recv_timeout_test()
112 assert!(tx.send(1).await.is_ok()); in sdv_bounded_send_recv_test()
113 assert!(tx.send(2).await.is_ok()); in sdv_bounded_send_recv_test()
133 assert!(tx.send(1).await.is_ok()); in sdv_bounded_send_recv_drop_test()
134 assert!(tx.send( in sdv_bounded_send_recv_drop_test()
[all...]
H A Dselect.rs62 /// 1. Creates two oneshot::channel and send message.
73 tx1.send("first").unwrap(); in sdv_new_select_channel()
77 tx2.send("second").unwrap(); in sdv_new_select_channel()
H A Dtcp_test.rs206 .expect("client send failed"); in sdv_tcp_global_runtime()
419 tx.send(addr).unwrap(); in sdv_tcp_drop_out_context()
470 let _ = tx.send(addr); in sdv_tcp_cancel()
515 tx.send(addr).unwrap(); in sdv_tcp_cancel()
563 tx.send(addr).unwrap(); in sdv_tcp_unexpected_eof()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dstreams.rs55 // send PP | | recv PP
60 // | | | send H / | |
65 // | | recv ES | | send ES | |
66 // | send H | ,-------| open |-------. | recv H |
71 // | | closed | | send R / | closed | |
75 // | | send ES / | recv ES / | |
76 // | | send R / v send R / | |
78 // | send R / `----------->| |<-----------' send
[all...]
H A Dmanager.rs280 .send(frame) in poll_send_frame()
367 .send(new_settings) in recv_settings_frame()
382 // TODO The client does not have the logic to send ping frames. Therefore, the in recv_ping_frame()
387 .send(Ping::ack(ping.clone())) in recv_ping_frame()
556 .send(frame) in manage_stream_error()
613 .send(frame) in manage_conn_error()
660 .send(frame) in send_peer_goaway()
670 .send(frame) in send_peer_goaway()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Doneshot.rs14 //! One-shot channel is used to send a single message from a single sender to a
18 //! The `Sender` handle is used by the producer to send a message.
22 //! The `send` method is not async. It can be called from non-async context.
31 //! if let Err(_) = tx.send(6) {
64 /// The `Sender` can send a single value to the `Receiver`.
73 /// if let Err(_) = tx.send(6) {
104 /// if let Err(_) = tx.send(6) {
142 /// back if it fails to send.
144 /// The sender will consume itself when calling this method. It can send a
154 /// if let Err(_) = tx.send(
165 pub fn send(self, value: T) -> Result<(), T> { send() functions
[all...]
H A Dwatch.rs49 /// let _ = tx.send(2);
80 /// let _ = tx.send(2);
105 /// let _ = tx.send(2);
108 pub fn send(&self, value: T) -> Result<(), SendError<T>> { in send() functions
136 /// let _ = tx.send(2);
196 /// let _ = tx.send(2);
231 /// let _ = tx.send(2);
270 /// let _ = tx.send(2);
293 /// let _ = tx.send(2);
353 /// assert!(tx.send(
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_http2.rs119 .send(())
130 .send(())
161 tx.send(handle) in sdv_async_h2_client_send_request()
162 .expect("send Handle out the server coroutine failed !"); in sdv_async_h2_client_send_request()
207 .send(()) in sdv_async_h2_client_send_request()
209 .expect("send client shutdown"); in sdv_async_h2_client_send_request()
241 tx.send(handle) in sdv_async_h2_client_send_request_concurrently()
242 .expect("send Handle out the server coroutine failed !"); in sdv_async_h2_client_send_request_concurrently()
295 .send(()) in sdv_async_h2_client_send_request_concurrently()
297 .expect("send clien in sdv_async_h2_client_send_request_concurrently()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Ddatagram.rs206 /// Trys to send message.
238 .try_io(Interest::WRITABLE, || (*self.source).send(buf)) in try_send()
321 /// socket.send(b"hello world").await.expect("send_to failed");
325 pub async fn send(&self, buf: &[u8]) -> Result<usize> {
327 .async_process(Interest::WRITABLE, || self.source.send(buf))
500 client.send(b"hello world").await.expect("send failed"); in ut_uds_datagram_read_write_test()
522 /// 2. Server send message with `writable()` and `try_send()`.
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dmod.rs41 /// assert!(tx.send(1).is_ok());
72 /// assert!(tx.send(1).is_ok());
95 /// assert!(tx.send(1).is_ok());
119 /// assert!(tx.send(1).is_ok());
122 pub fn send(&self, value: T) -> Result<(), SendError<T>> { in send() functions
123 self.channel.send(value) in send()
127 /// send values anymore. It returns true if the [`UnboundedReceiver`] is
167 /// tx.send(1).unwrap();
182 /// tx.send(1).unwrap();
208 /// tx.send(
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs322 if input_tx.send(settings).is_ok() {
355 let send = crate::runtime::spawn(async move { in launch()
359 let mut send = in launch() variables
361 let _ = Pin::new(&mut send).await; in launch()
364 handles.push(send); in launch()
435 .send(ReqMessage {
484 let ft = async move { sender.send(message).await };
530 // ignore the send error occurs here in order to finish all
532 let _ = input_tx.send(frame);
775 // stream and send t
[all...]
H A Dtest_utils.rs88 tx2.send(handle).expect("send TcpHandle out coroutine failed !");
120 tx.send(()).expect("server send order failed !");
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/quic/
H A Dmod.rs132 let (write, _send_info) = self.send(&mut out).expect("initial send failed");
164 let (write, _send_info) = match self.send(&mut out) {
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
H A Ddatagram.rs217 /// socket.send(b"hello world").expect("send_to failed");
221 pub fn send(&self, buf: &[u8]) -> io::Result<usize> { in send() functions
222 self.inner.send(buf) in send()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Dmod.rs43 /// assert!(tx.send(1).await.is_ok());
78 /// assert!(tx.send(1).await.is_ok());
111 /// assert!(tx.send(1).await.is_ok());
128 /// Attempts to send a value to the associated [`BoundedReceiver`].
177 /// assert!(tx.send(1).await.is_ok());
183 pub async fn send(&self, value: T) -> Result<(), SendError<T>> {
184 self.channel.send(value).await
187 /// Attempts to send a value to the associated receiver in a limited amount
232 /// send values anymore. It returns true after the [`BoundedReceiver`] is
479 /// The `Sender` will fail to call [`send`] o
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/common/
H A Dmod.rs66 tx.send(handle)
67 .expect("Failed to send the handle to the test thread.");
74 .expect("Handle send channel (Server-Half) be closed unexpectedly");
97 tx.send(handle)
98 .expect("Failed to send the handle to the test thread.");
105 .expect("Handle send channel (Server-Half) be closed unexpectedly");
137 .send(())
148 .send(())
401 .send(())
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/
H A Dmod.rs82 rx2.send(handle).expect("send TcpHandle out coroutine failed !");
141 rx.send(()).expect("server send order failed !");
238 rx.send(()).expect("server send order failed !");
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Duds_test.rs150 let n = sender2.send(b"Hello"); in sdv_uds_send_recv()
154 let n = sender.send(b"Hello").expect("sender send failed"); in sdv_uds_send_recv()
H A Dudp_socket_test.rs18 /// SDV test cases for `send()` and `recv()`.
57 match connected_sender.send(b"Hello") { in sdv_send_recv()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dregistry.rs136 let _ = event.inner.send(());

Completed in 13 milliseconds

12