| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/ |
| D | http1.rs | 47 conn.shutdown(); in request()
52 conn.shutdown(); in request()
68 conn.shutdown(); in request()
78 conn.shutdown(); in request()
94 conn.shutdown(); in request()
102 conn.shutdown(); in request()
111 conn.shutdown(); in request()
121 conn.shutdown(); in request()
141 fn shutdown(&self) { in shutdown() method
142 Self::shutdown(self) in shutdown()
|
| D | mod.rs | 31 fn shutdown(&self); in shutdown() method
|
| D | http2.rs | 281 fn shutdown(&self) { in shutdown() method
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | blocking_pool.rs | 38 self.shutdown(BLOCKING_THREAD_QUIT_WAIT_TIME); in drop()
58 shutdown: false, in new()
75 pub fn shutdown(&mut self, timeout: Duration) -> bool { in shutdown() method
78 if shared.shutdown { in shutdown()
157 shutdown: bool, field
211 if shared.shutdown { in spawn()
269 while !shared.shutdown { in run()
298 if !shared.shutdown && timeout_result.timed_out() { in run()
310 if shared.shutdown { in run()
330 let shutdown = shared.shutdown; in run() localVariable
[all …]
|
| D | worker.rs | 149 task.shutdown(); in pre_shutdown()
161 task.shutdown(); in pre_shutdown()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | http_body.rs | 76 io.shutdown(); in new()
163 io.shutdown() in drop()
219 io.shutdown(); in data()
235 io.shutdown(); in data()
289 io.shutdown(); in data()
314 io.shutdown(); in data()
325 io.shutdown(); in data()
345 io.shutdown(); in data()
418 io.shutdown(); in data()
442 io.shutdown(); in data()
|
| /commonlibrary/c_utils/docs/en/ |
| D | c_utils_timer.md | 16 | virtual uint32_t | **Setup**()<br>Set up "Timer". Do not set up repeatly before shutdown. |
31 1. Timer should be set up(via Setup()) before use, and shutdown(via Shutdown()) before its deconstr…
33 1. Timer should be set up first and then shutdown. Avoid delegating them to different threads since…
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | mod.rs | 79 pub(crate) fn shutdown(self) { in shutdown() method
80 self.0.shutdown(); in shutdown()
|
| D | raw.rs | 109 pub(super) fn shutdown(self) { in shutdown() method
309 task_handle.shutdown(); in release()
|
| D | task_handle.rs | 246 pub(crate) unsafe fn shutdown(self) { in shutdown() function
|
| D | join_set.rs | 263 pub async fn shutdown(&mut self) { in shutdown() method
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/conn/ |
| D | mod.rs | 28 fn shutdown(&self); in shutdown() method
|
| D | http1.rs | 136 fn shutdown(&self) { in shutdown() method
137 Self::shutdown(self) in shutdown()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/tcp/ |
| D | stream.rs | 156 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown() method
157 self.inner.shutdown(how) in shutdown()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | http_body.rs | 139 io.shutdown(); in data()
160 io.shutdown(); in data()
172 io.shutdown(); in data()
248 io.shutdown(); in data()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | stream.rs | 508 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown() method
509 self.source.shutdown(how) in shutdown()
549 self.source.shutdown(std::net::Shutdown::Write)?; in poll_shutdown()
|
| D | split.rs | 65 self.0.shutdown(Shutdown::Write).into() in poll_shutdown()
111 self.0.shutdown(Shutdown::Write).into() in poll_shutdown()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| D | stream.rs | 121 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown() method
122 self.inner.shutdown(how) in shutdown()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| D | schedule_io.rs | 179 pub(crate) fn shutdown(&self) { in shutdown() method
247 fn wake0(&self, ready: Ready, shutdown: bool) { in wake0()
250 waiters.is_shutdown |= shutdown; in wake0()
474 schedule_io.shutdown(); in ut_schedule_io_shutdown()
|
| D | driver.rs | 406 io.shutdown(); in drop()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | dispatcher.rs | 88 pub(crate) shutdown: AtomicBool, field
97 shutdown: AtomicBool::new(false), in new()
117 self.inner.shutdown.load(Ordering::Relaxed) in is_shutdown()
134 pub(crate) fn shutdown(&self) { in shutdown() method
135 self.inner.shutdown.store(true, Ordering::Release); in shutdown()
316 pub(crate) fn shutdown(&self) { in shutdown() method
814 self.controller.shutdown(); in poll_match_result()
1132 self.controller.shutdown(); in dispatch_read_frames()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | async_write.rs | 290 fn shutdown(&mut self) -> ShutdownTask<'_, Self> in shutdown() method
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | c_ssl_stream.rs | 127 match self.as_mut().with_context(ctx, |s| s.shutdown()) { in poll_shutdown()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| D | stream.rs | 155 pub(crate) fn shutdown(&mut self) -> Result<ShutdownResult, SslError> { in shutdown() method
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | join_set.rs | 277 set.shutdown().await; in sdv_join_set_shutdown()
|