Home
last modified time | relevance | path

Searched refs:stream (Results 1 - 25 of 59) sorted by relevance

123

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtcp_test.rs35 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect() variables
36 while stream.is_err() { in sdv_tcp_ipv6_connect()
37 stream = TcpStream::connect(addr).await; in sdv_tcp_ipv6_connect()
39 let mut stream = stream.unwrap(); in sdv_tcp_ipv6_connect() variables
41 let _ = stream.read(&mut buf).await; in sdv_tcp_ipv6_connect()
45 let (mut stream, _) = listener.accept().await.unwrap(); in sdv_tcp_ipv6_connect()
46 stream.write(b"hello").await.unwrap(); in sdv_tcp_ipv6_connect()
86 let mut stream = TcpStream::connect(addr).await; in sdv_tcp_stream_try() variables
87 while stream in sdv_tcp_stream_try()
121 let mut stream = TcpStream::connect(addr).await; sdv_tcp_stream_basic() variables
168 let mut stream = TcpStream::connect(addr).await; sdv_tcp_stream_peek() variables
296 let mut stream = TcpStream::connect(addr).await; sdv_tcp_split_borrow_half() variables
300 let mut stream = stream.unwrap(); sdv_tcp_split_borrow_half() variables
366 let mut stream = TcpStream::connect(addr).await; sdv_tcp_split_owned_half() variables
[all...]
H A Duds_cargo_test.rs64 let mut stream = UnixStream::connect(PATH).await; in sdv_uds_listener_read_write_test() variables
65 while stream.is_err() { in sdv_uds_listener_read_write_test()
66 stream = UnixStream::connect(PATH).await; in sdv_uds_listener_read_write_test()
68 let mut stream = stream.unwrap(); in sdv_uds_listener_read_write_test() variables
70 stream.read_exact(&mut read_buf).await.unwrap(); in sdv_uds_listener_read_write_test()
75 stream.write_all(server_msg.as_bytes()).await.unwrap(); in sdv_uds_listener_read_write_test()
78 let (mut stream, _) = listener.accept().await.unwrap(); in sdv_uds_listener_read_write_test()
79 stream.write_all(client_msg.as_bytes()).await.unwrap(); in sdv_uds_listener_read_write_test()
81 stream in sdv_uds_listener_read_write_test()
[all...]
H A Dsignal.rs51 let mut stream = signal(SignalKind::alarm()).unwrap(); in sdv_signal_recv_test() variables
54 stream.recv().await; in sdv_signal_recv_test()
73 let mut stream = signal(SignalKind::child()).unwrap(); in sdv_signal_recv_multi_thread_test() variables
75 stream.recv().await; in sdv_signal_recv_multi_thread_test()
95 let mut stream = signal(SignalKind::hangup()).unwrap(); in sdv_signal_poll_recv_test() variables
98 poll_fn(|cx| stream.poll_recv(cx)).await; in sdv_signal_poll_recv_test()
117 let mut stream = signal(SignalKind::io()).unwrap(); in sdv_signal_poll_recv_multi_thread_test() variables
119 stream.recv().await; in sdv_signal_poll_recv_multi_thread_test()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dstreams.rs230 for (_id, stream) in self.stream_map.iter_mut() {
231 stream.send_window.increase_size(excess)?;
240 for (_id, stream) in self.stream_map.iter_mut() {
241 stream.send_window.reduce_size(excess);
254 for (_id, stream) in self.stream_map.iter_mut() {
256 stream.recv_window.increase_notification(extra);
257 stream.recv_window.increase_actual(extra);
261 for (_id, stream) in self.stream_map.iter_mut() {
262 stream.recv_window.reduce_notification(current - size);
274 if let Some(stream)
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dsplit.rs139 let mut stream = TcpStream::connect(addr).await; in poll_flush() variables
140 while stream.is_err() { in poll_flush()
141 stream = TcpStream::connect(addr).await; in poll_flush()
143 let mut stream = stream.unwrap(); in poll_flush() variables
144 let (mut read_half, mut write_half) = stream.split(); in poll_flush()
156 let (mut stream, _) = listener.accept().await.unwrap(); in poll_flush()
158 let n = stream.read(&mut buf).await.expect("server read err"); in poll_flush()
164 stream.write(b"hello read half.").await.unwrap(); in poll_flush()
185 let mut stream in poll_flush() variables
232 let mut stream = TcpStream::connect(addr).await; poll_flush() variables
236 let mut stream = stream.unwrap(); poll_flush() variables
282 let mut stream = TcpStream::connect(addr).await; poll_flush() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_io/tests/
H A Dtcp_test.rs33 let (mut stream, _) = loop { in sdv_tcp_server()
34 let stream = server.accept(); in sdv_tcp_server()
35 match stream { in sdv_tcp_server()
36 Ok(stream) => break stream, in sdv_tcp_server()
41 let mut ret = stream.write(b"hello"); in sdv_tcp_server()
49 ret = stream.write(b"hello"); in sdv_tcp_server()
55 let mut read_stream = stream.try_clone().unwrap(); in sdv_tcp_server()
76 Ok(stream) => break stream, in sdv_tcp_server()
[all...]
H A Duds_test.rs41 let mut stream = loop { in sdv_uds_stream_test() variables
42 if let Ok(stream) = UnixStream::connect(PATH) { in sdv_uds_stream_test()
43 break stream; in sdv_uds_stream_test()
50 match stream.read_vectored(&mut [slice]) { in sdv_uds_stream_test()
61 let n = stream.write_vectored(&[slice]).unwrap(); in sdv_uds_stream_test()
65 stream.shutdown(Shutdown::Both).unwrap(); in sdv_uds_stream_test()
83 let (mut stream, _) = server.accept()?; in server()
86 poll.register(&mut stream, token, Interest::READABLE | Interest::WRITABLE)?; in server()
87 connections.insert(token, stream); in server()
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/
H A Dgraph.cpp25 std::ostream &operator<<(std::ostream &stream, typename G::VColor c) in operator <<() argument
29 stream << "W"; in operator <<()
32 stream << "B"; in operator <<()
35 stream << "G"; in operator <<()
38 stream << "?"; in operator <<()
41 return stream; in operator <<()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/
H A Dstreams.rs122 // cannot recv cause of stream blocks
124 // stream resumes and should decode again
188 if let Some(stream) = self.bidirectional_stream.get_mut(&id) {
189 match stream.state {
192 stream.state = H3StreamState::HeadersReceived;
205 stream.state = H3StreamState::BodyReceived;
210 stream.state = H3StreamState::TrailerReceived;
219 // stream has been shutdown, drop frame
223 if stream.curr_message.is_some() {
224 stream
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/h3/
H A Ddecoder.rs29 use crate::h3::stream::StreamMessage::Request;
30 use crate::h3::stream::{FrameKind, Frames, StreamMessage};
31 use crate::h3::{frame, is_bidirectional, stream, Frame, H3ErrorCode};
33 /// HTTP3 stream bytes sequence decoder.
34 /// The http3 stream decoder deserializes stream data into readable structured
35 /// data, including stream type, Frame, etc.
98 /// stream blocks allowed by qpack, and max_table_capacity is the
115 /// the stream.
123 /// Cleans the stream informatio
147 let mut stream = if let Some(stream) = self.streams.remove(&id) { decode() variables
[all...]
H A Dencoder.rs70 /// HTTP3 frame encoder, which serializes a Frame into a byte stream in the
117 let stream = self in set_frame()
122 match stream.state { in set_frame()
126 stream.current_frame = Some(frame); in set_frame()
128 if let Some(ref frame) = stream.current_frame { in set_frame()
133 stream.state = FrameEncoderState::EncodingHeadersFrame; in set_frame()
136 frame::DATA_FRAME_TYPE => stream.state = FrameEncoderState::EncodingDataFrame, in set_frame()
138 stream.state = FrameEncoderState::EncodingCancelPushFrame in set_frame()
141 stream.state = FrameEncoderState::EncodingSettingsFrame in set_frame()
143 frame::GOAWAY_FRAME_TYPE => stream in set_frame()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/
H A Dylong_runtime_tcp_client_perf.rs25 let mut stream = match TcpStream::connect(addr).await { in main() variables
26 Ok(stream) => stream, in main()
32 match stream.write(&recv_buf).await { in main()
41 match stream.read(&mut recv_buf).await { in main()
H A Dylong_runtime_tcp_server_perf.rs33 let (mut stream, _) = match server.accept().await { in main()
34 Ok((stream, addr)) => (stream, addr), in main()
40 match stream.read(&mut recv_buf).await { in main()
50 match stream.write(&recv_buf).await { in main()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/
H A Dssl_base.rs67 pub(crate) fn connect<S>(self, stream: S) -> Result<SslStream<S>, HandshakeError<S>>
74 let mut stream = SslStream::new_base(self, stream, None)?; variables
75 let ret = unsafe { SSL_connect(stream.ssl.as_ptr()) };
77 Ok(stream)
79 let error = stream.get_error(ret);
83 _stream: stream,
88 _stream: stream,
H A Dmod.rs19 mod stream; modules
28 pub(crate) use stream::verify_server_cert;
29 pub(crate) use stream::{MidHandshakeSslStream, ShutdownResult, SslStream};
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/
H A Dsplit.rs43 stream: Mutex<T>,
51 pub(crate) fn split<T>(stream: T) -> (Reader<T>, Writer<T>)
55 let is_write_vectored = stream.is_write_vectored();
57 stream: Mutex::new(stream),
77 guard.stream().poll_read(cx, buf) in poll_read()
88 inner.stream().poll_write(cx, buf) in poll_write()
97 inner.stream().poll_write_vectored(cx, bufs) in poll_write_vectored()
106 inner.stream().poll_flush(cx)
111 inner.stream() in poll_shutdown()
116 fn stream(&mut self) -> Pin<&mut T> { stream() functions
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Dstream.rs35 pub(crate) fn new(stream: ylong_io::UnixStream) -> Result<Self> {
37 source: AsyncSource::new(stream, None)?,
50 /// let mut stream = UnixStream::connect("/tmp/sock").await?;
55 let stream = UnixStream::new(ylong_io::UnixStream::connect(path)?)?;
57 stream
60 // Wait until the stream is writable
66 if let Some(e) = stream.source.take_error()? {
70 Ok(stream)
85 /// let stream = UnixStream::from_std(std_stream)?;
90 let stream in from_std()
[all...]
H A Dlistener.rs67 let (stream, addr) = self
72 let stream = UnixStream::new(stream)?;
73 Ok((stream, addr))
/commonlibrary/rust/ylong_runtime/ylong_io/examples/
H A Dylong_io_tcp_client.rs27 let mut stream = match TcpStream::connect(addr) { in main() variables
36 match stream.read(&mut buffer) { in main()
45 println!("client socket: {stream:?}"); in main()
47 match stream.write(b"Hello World") { in main()
52 if stream.read(&mut buffer).is_ok() { in main()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_signal.rs39 let mut stream = tokio_signal($kind).unwrap(); variables
41 stream.recv().await;
63 let mut stream = tokio_signal($kind).unwrap(); variables
66 stream.recv().await;
88 let mut stream = ylong_signal($kind).unwrap(); variables
90 stream.recv().await;
112 let mut stream = ylong_signal($kind).unwrap(); variables
115 stream.recv().await;
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/quic/
H A Dmod.rs64 stream: &mut S,
80 let local = stream.conn_detail().local();
81 let peer = stream.conn_detail().peer();
106 if let Err(e) = conn.connect_inner(stream, &mut new_ssl, tls_config).await {
123 stream: &mut S,
134 stream
139 self.conn_recv(stream, &mut buf).await?;
145 let Some(key) = tls_config.pinning_host_match(stream.conn_detail().addr()) else {
177 stream
186 async fn conn_recv<S>(&mut self, stream
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/
H A Dmod.rs84 let (mut stream, _client) = server.accept().await.expect("failed to build a tcp stream");
90 let size = stream.read(&mut buf).await.expect("tcp stream read error !");
117 let size2 = stream.read(&mut buf).await.expect("tcp stream read error2 !");
133 stream.write_all(resp_str.as_bytes()).await.expect("server write response failed");
139 stream.shutdown($shutdown).expect("server shutdown failed");
185 let (mut stream, _client) = server.accept().expect("failed to build a tcp stream");
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dmod.rs16 mod stream; modules
23 pub use stream::ConnInfo;
39 /// Futures generated by this connector when attempting to create a stream.
103 .and_then(|stream| match stream.set_nodelay(true) {
104 Ok(()) => Ok(stream),
152 use crate::async_impl::connector::stream::HttpStream;
175 let stream = eyeballs_connect(resolver, addr.as_str(), timeout).await?; in connect()
176 let local = stream in connect()
179 let peer = stream in connect()
308 let mut stream = connect() variables
383 let mut stream = config global() variables
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_signal.rs44 let mut stream = signal(SignalKind::child()).unwrap(); in run_multi_thread_signal() variables
46 stream.recv().await; in run_multi_thread_signal()
63 let mut stream = signal(SignalKind::ctrl_c()).unwrap(); in run_multi_thread_signal() variables
65 stream.recv().await; in run_multi_thread_signal()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/
H A Dmod.rs22 mod stream; modules
23 pub use stream::TcpStream;

Completed in 11 milliseconds

123