| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_write.rs | 40 fn poll_write( in poll_write() functions
59 self.poll_write(cx, buf) in poll_write_vectored()
99 /// A default poll_write implementation for an object that could be deref to an in poll_flush()
101 fn poll_write( in poll_flush() functions
106 Pin::new(&mut **self).poll_write(cx, buf) in poll_flush()
151 fn poll_write( in poll_write() functions
156 Pin::as_mut(self.get_mut()).poll_write(cx, buf) in poll_write()
|
| H A D | stdio.rs | 111 fn poll_write( in poll_write() functions
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
| H A D | pty.rs | 189 fn poll_write( in poll_write() functions
194 self.0.poll_write(cx, buf) in poll_write()
266 fn poll_write( in poll_write() functions
271 self.0 .0.poll_write(cx, buf) in poll_write()
325 fn poll_write( in poll_write() functions
330 self.0 .0.poll_write(cx, buf) in poll_write()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | input.rs | 139 .poll_write(cx, &self.buf.buf[self.buf.start..self.buf.end]) in poll_writer_frame()
168 .poll_write(cx, &self.buf.buf[index..size])
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| H A D | async_buf_writer.rs | 180 Pin::new_unchecked(&mut this.inner).poll_write(cx, &this.buf[this.written..])
206 fn poll_write( in poll_write() functions
217 unsafe { Pin::new_unchecked(&mut this.inner).poll_write(cx, buf) } in poll_write()
261 return unsafe { Pin::new_unchecked(&mut this.inner).poll_write(cx, &bufs[0]) }; in poll_write_vectored()
|
| H A D | async_buf_reader.rs | 252 fn poll_write( in poll_write() functions
258 unsafe { Pin::new_unchecked(&mut this.inner).poll_write(cx, buf) } in poll_write()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| H A D | stream.rs | 64 // poll_write separately.
65 fn poll_write( in poll_write() functions
70 Pin::new(&mut self.stream).poll_write(cx, buf) in poll_write()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | mix.rs | 51 // poll_write separately.
52 fn poll_write( in poll_write() functions
58 MixStream::Http(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
59 MixStream::Https(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| H A D | split.rs | 40 fn poll_write( in poll_write() functions
45 self.0.source.poll_write(cx, buf) in poll_write()
86 fn poll_write( in poll_write() functions
91 self.0.source.poll_write(cx, buf) in poll_write()
|
| H A D | stream.rs | 609 fn poll_write( in poll_write() functions
614 self.source.poll_write(cx, buf) in poll_write()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/ |
| H A D | split.rs | 82 fn poll_write( in poll_write() functions
88 inner.stream().poll_write(cx, buf) in poll_write()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| H A D | stream.rs | 348 fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8]) -> Poll<Result<usize>> { in poll_write() functions
349 self.source.poll_write(cx, buf) in poll_write()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | c_ssl_stream.rs | 126 fn poll_write(self: Pin<&mut Self>, ctx: &mut Context, buf: &[u8]) -> Poll<io::Result<usize>> { in poll_write() functions
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h3/ |
| H A D | io_manager.rs | 142 match Pin::new(&mut self.io).poll_write( in poll_io_send()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/ |
| H A D | child.rs | 140 fn poll_write( in poll_write() functions
145 self.inner.poll_write(cx, buf) in poll_write()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | async_source.rs | 199 pub(crate) fn poll_write<'a>(
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | child.rs | 342 fn poll_write( in poll_write() functions
347 Pin::new(&mut self.inner).poll_write(ctx, buffer) in poll_write()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| H A D | async_file.rs | 590 fn poll_write( in poll_write() functions
|