| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | blocking_pool.rs | 39 self.shutdown(BLOCKING_THREAD_QUIT_WAIT_TIME); in drop()
59 shutdown: false, in new()
76 pub fn shutdown(&mut self, timeout: Duration) -> bool { in shutdown() functions
79 if shared.shutdown { in shutdown()
117 /// Used for thread shutdown synchronization
157 shutdown: bool,
210 // if the shutdown flag is on, cancel the task in spawn()
212 !shared.shutdown, in spawn()
213 "The blocking runtime has already been shutdown, cannot spawn tasks" in spawn()
295 if !shared.shutdown in wait_temporary()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | stdio_cargo_test.rs | 39 let res = stdout.shutdown().await; in sdv_stdio_write()
51 let res = stderr.shutdown().await; in sdv_stdio_write()
71 let res = buf_writer.shutdown().await; in sdv_stdio_buf_writer_write()
80 let res = buf_writer.shutdown().await; in sdv_stdio_buf_writer_write()
|
| H A D | pty_process.rs | 91 pty.shutdown().await.unwrap(); in sdv_pty_process_read_and_write_test()
117 write_pty.shutdown().await.unwrap(); in sdv_pty_split_test()
149 write_pty.shutdown().await.unwrap(); in sdv_pty_into_split_test()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | http_body.rs | 83 io.shutdown();
172 // If response body is not totally read, shutdown io. in drop()
174 io.shutdown() in drop()
244 io.shutdown(); in poll_read_io()
262 io.shutdown(); in poll_read_io()
336 io.shutdown(); in read_remaining()
372 io.shutdown(); in poll_read_io()
381 io.shutdown(); in poll_read_io()
406 io.shutdown(); in poll_read_io()
473 io.shutdown(); in data()
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| H A D | http1.rs | 67 conn.shutdown();
72 conn.shutdown();
82 conn.shutdown();
156 conn.shutdown();
161 conn.shutdown();
178 // The shutdown function only sets the current connection to the closed state in decode_response()
185 conn.shutdown() in decode_response()
196 conn.shutdown() in decode_response()
204 conn.shutdown() in decode_response()
212 conn.shutdown(); in decode_response()
291 fn shutdown(&self) { shutdown() functions
[all...] |
| H A D | mod.rs | 31 fn shutdown(&self); in shutdown() functions
|
| H A D | http2.rs | 341 fn shutdown(&self) { in shutdown() functions
464 let shutdown = Arc::new(AtomicBool::new(false)); in ut_http2_body_poll_read()
465 let mut conn: Http2Conn<()> = Http2Conn::new(20, shutdown, req_tx); in ut_http2_body_poll_read()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | test_utils.rs | 70 $(Shutdown: $shutdown: expr,)?
117 stream.shutdown($shutdown).expect("server shutdown failed");
|
| H A D | dispatcher.rs | 116 // `shutdown` indicates that the connection need to be shut down.
117 pub(crate) shutdown: AtomicBool,
128 shutdown: AtomicBool::new(false),
148 self.inner.shutdown.load(Ordering::Relaxed) in is_shutdown()
168 pub(crate) fn shutdown(&self) {
169 self.inner.shutdown.store(true, Ordering::Release);
397 // todo: goaway and shutdown in is_goaway()
446 pub(crate) fn new(streams: Streams, shutdown: Arc<AtomicBool>) -> Self {
448 io_shutdown: shutdown,
457 pub(crate) fn shutdown(
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/conn/ |
| H A D | mod.rs | 25 fn shutdown(&self); in shutdown() functions
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | http_body.rs | 140 io.shutdown(); in data()
158 io.shutdown(); in data()
170 io.shutdown(); in data()
239 io.shutdown(); in data()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| H A D | stream.rs | 195 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown() functions
196 self.inner.shutdown(how) in shutdown()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| H A D | datagram.rs | 253 /// socket.shutdown(Shutdown::Both).expect("shutdown() failed");
257 pub fn shutdown(&self, how: std::net::Shutdown) -> io::Result<()> { in shutdown() functions
258 self.inner.shutdown(how) in shutdown()
332 receiver2.shutdown(Shutdown::Both).unwrap(); in ut_uds_datagram_pair()
333 sender.shutdown(Shutdown::Both).unwrap() in ut_uds_datagram_pair()
|
| H A D | stream.rs | 153 /// socket.shutdown(Shutdown::Both).expect("shutdown() failed");
157 pub fn shutdown(&self, how: std::net::Shutdown) -> io::Result<()> { in shutdown() functions
158 self.inner.shutdown(how) in shutdown()
284 receiver2.shutdown(Shutdown::Both).unwrap(); in ut_uds_stream_pair()
285 sender.shutdown(Shutdown::Both).unwrap() in ut_uds_stream_pair()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| H A D | stream.rs | 120 /// .shutdown(Shutdown::Both)
121 /// .expect("shutdown call failed");
123 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown() functions
124 self.inner.shutdown(how) in shutdown()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | stream.rs | 332 pub fn shutdown(&self, how: Shutdown) -> Result<()> { in shutdown() functions
333 self.source.shutdown(how) in shutdown()
369 self.source.shutdown(std::net::Shutdown::Write)?; in poll_flush()
|
| H A D | datagram.rs | 425 /// socket.shutdown(Shutdown::Both).expect("shutdown() failed");
429 pub fn shutdown(&self, how: std::net::Shutdown) -> Result<()> { in shutdown() functions
430 self.source.shutdown(how) in shutdown()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | mod.rs | 81 pub(crate) fn shutdown(self) {
82 self.0.shutdown();
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | stream.rs | 562 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in fmt() functions
563 self.source.shutdown(how) in fmt()
634 self.source.shutdown(std::net::Shutdown::Write)?; in poll_flush()
|
| H A D | split.rs | 65 self.0.shutdown(Shutdown::Write).into() in poll_flush()
111 self.0.shutdown(Shutdown::Write).into() in poll_flush()
245 write_half.shutdown().await.unwrap(); in poll_flush()
295 write_half.shutdown().await.unwrap(); in poll_flush()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/tests/tcp_server/ |
| H A D | mod.rs | 63 $(Shutdown: $shutdown: expr,)?
139 stream.shutdown($shutdown).expect("server shutdown failed");
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 65 stream.shutdown(Shutdown::Both).unwrap(); in sdv_uds_stream_test()
149 sender2.shutdown(Shutdown::Write).unwrap(); in sdv_uds_send_recv()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_write.rs | 82 /// This method is designed for asynchronous shutdown of the I/O connection. in poll_flush()
87 /// been occurred during the shutdown procedure. It typically means the in poll_flush()
288 /// io.shutdown().await?; in poll_flush()
290 fn shutdown(&mut self) -> ShutdownTask<'_, Self> in poll_flush() functions
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | mod.rs | 267 fn shutdown(&self) { in shutdown() functions
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | c_ssl_stream.rs | 136 match self.as_mut().with_context(ctx, |s| s.shutdown()) { in poll_shutdown()
|