Home
last modified time | relevance | path

Searched refs:Pin (Results 1 - 25 of 90) sorted by relevance

1234

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dasync_write.rs17 use std::pin::Pin;
41 self: Pin<&mut Self>, in poll_write()
51 self: Pin<&mut Self>, in poll_write_vectored()
76 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>>; in poll_flush()
94 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>>; in poll_flush()
102 mut self: Pin<&mut Self>, in poll_flush()
106 Pin::new(&mut **self).poll_write(cx, buf) in poll_flush()
112 mut self: Pin<&mut Self>, in poll_flush()
116 Pin::new(&mut **self).poll_write_vectored(cx, bufs) in poll_flush()
127 fn poll_flush(mut self: Pin< in poll_flush()
[all...]
H A Dasync_read.rs15 use std::pin::Pin;
42 self: Pin<&mut Self>, in poll_read()
51 mut self: Pin<&mut Self>, in poll_read()
55 Pin::new(&mut **self).poll_read(cx, buf) in poll_read()
62 mut self: Pin<&mut Self>, in poll_read()
66 Pin::new(&mut **self).poll_read(cx, buf) in poll_read()
71 impl<T> AsyncRead for Pin<T>
77 self: Pin<&mut Self>, in poll_read()
211 mut self: Pin<&mut Self>, in poll_read()
H A Dasync_buf_read.rs16 use std::pin::Pin;
37 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>>; in poll_fill_buf()
47 fn consume(self: Pin<&mut Self>, amt: usize); in poll_fill_buf()
52 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
53 Pin::new(&mut **self.get_mut()).poll_fill_buf(cx) in poll_fill_buf()
56 fn consume(mut self: Pin<&mut Self>, amt: usize) { in poll_fill_buf()
57 Pin::new(&mut **self).consume(amt) in poll_fill_buf()
63 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<&[u8]>> { in poll_fill_buf()
64 Pin::new(&mut **self.get_mut()).poll_fill_buf(cx) in poll_fill_buf()
67 fn consume(mut self: Pin< in poll_fill_buf()
[all...]
H A Dasync_seek.rs17 use std::pin::Pin;
39 self: Pin<&mut Self>, in poll_seek()
45 impl<T> AsyncSeek for Pin<T>
50 self: Pin<&mut Self>, in poll_seek()
60 mut self: Pin<&mut Self>, in poll_seek()
64 Pin::new(&mut **self).poll_seek(cx, pos) in poll_seek()
70 mut self: Pin<&mut Self>, in poll_seek()
74 Pin::new(&mut **self).poll_seek(cx, pos) in poll_seek()
H A Dwrite_task.rs17 use std::pin::Pin;
58 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
61 match Pin::new(&mut writer).poll_write(cx, self.buf) {
98 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
101 match Pin::new(&mut writer).poll_write_vectored(cx, self.bufs) {
140 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
143 match Pin::new(&mut writer).poll_write(cx, &self.buf[self.w_len..]) {
177 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
179 Pin::new(&mut me.writer).poll_flush(cx)
202 fn poll(self: Pin<
[all...]
H A Dread_task.rs16 use std::pin::Pin;
61 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
65 match Pin::new(&mut reader).poll_read(cx, &mut buf) {
115 let poll = Pin::new(&mut reader).poll_read(cx, &mut read_buf); in poll_read_to_end()
139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
211 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
246 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
255 let _ = match Pin::new(&mut reader).poll_read(cx, &mut this.buf) {
301 let available = poll_ready!(Pin::new(&mut reader).poll_fill_buf(cx))?; in poll_read_until()
316 Pin in poll_read_until()
[all...]
H A Dstdin.rs16 use std::pin::Pin;
47 mut self: Pin<&mut Self>, in poll_read()
74 let (res, mut buf_inner, std) = match Pin::new(join_handle).poll(cx)? { in poll_read()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dmix.rs14 use core::pin::Pin;
37 mut self: Pin<&mut Self>, in poll_read()
42 MixStream::Http(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
43 MixStream::Https(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
45 MixStream::Udp(s) => Pin::new(s).poll_recv(cx, buf), in poll_read()
53 mut self: Pin<&mut Self>, in poll_write()
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()
61 MixStream::Udp(s) => Pin::new(s).poll_send(ctx, buf), in poll_write()
65 fn poll_flush(mut self: Pin<
[all...]
H A Dtimeout.rs15 use std::pin::Pin;
24 pub(crate) timeout: Option<Pin<Box<Sleep>>>,
28 impl<T> TimeoutFuture<Pin<Box<T>>> {
43 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
51 match Pin::new(&mut this.future).poll(cx) {
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A Dasync_buf_writer.rs16 use std::pin::Pin;
173 fn flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in flush()
180 Pin::new_unchecked(&mut this.inner).poll_write(cx, &this.buf[this.written..])
207 mut self: Pin<&mut Self>, in poll_write()
217 unsafe { Pin::new_unchecked(&mut this.inner).poll_write(cx, buf) } in poll_write()
225 mut self: Pin<&mut Self>, in poll_write_vectored()
240 unsafe { Pin::new_unchecked(&mut this.inner).poll_write_vectored(cx, bufs) } in poll_write_vectored()
261 return unsafe { Pin::new_unchecked(&mut this.inner).poll_write(cx, &bufs[0]) }; in poll_write_vectored()
282 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
285 unsafe { Pin
[all...]
H A Dasync_buf_reader.rs16 use std::pin::Pin;
182 mut self: Pin<&mut Self>, in poll_read()
189 return unsafe { Pin::new_unchecked(&mut this.inner).poll_read(cx, buf) }; in poll_read()
201 fn poll_fill_buf(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<&[u8]>> { in poll_fill_buf()
206 poll_ready!(Pin::new_unchecked(&mut this.inner).poll_read(cx, &mut read_buf))?;
214 fn consume(self: Pin<&mut Self>, amt: usize) { in consume()
222 self: Pin<&mut Self>, in poll_seek()
231 poll_ready!(Pin::new_unchecked(&mut this.inner) in poll_seek()
238 poll_ready!(Pin::new_unchecked(&mut this.inner) in poll_seek()
245 let res = unsafe { poll_ready!(Pin in poll_seek()
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dstream.rs16 use std::pin::Pin;
52 mut self: Pin<&mut Self>, in poll_read()
56 Pin::new(&mut self.stream).poll_read(cx, buf) in poll_read()
66 mut self: Pin<&mut Self>, in poll_write()
70 Pin::new(&mut self.stream).poll_write(cx, buf) in poll_write()
73 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
74 Pin::new(&mut self.stream).poll_flush(cx) in poll_flush()
77 fn poll_shutdown(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
78 Pin::new(&mut self.stream).poll_shutdown(cx) in poll_flush()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/
H A Doperator.rs15 use std::pin::Pin;
28 self: Pin<&mut Self>, in poll_download()
38 self: Pin<&mut Self>, in poll_progress()
81 mut self: Pin<&mut Self>, in poll_download()
85 Pin::new(&mut **self).poll_download(cx, data) in poll_download()
89 mut self: Pin<&mut Self>, in poll_progress()
94 Pin::new(&mut **self).poll_progress(cx, downloaded, total) in poll_progress()
109 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
111 Pin::new(&mut fut.operator).poll_download(cx, fut.data)
127 fn poll(self: Pin<
[all...]
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/
H A Doperator.rs15 use std::pin::Pin;
29 /// # use std::pin::Pin;
40 /// self: Pin<&mut Self>,
54 self: Pin<&mut Self>, in poll_progress()
80 mut self: Pin<&mut Self>, in poll_progress()
85 Pin::new(&mut **self).poll_progress(cx, uploaded, total) in poll_progress()
102 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
104 Pin::new(&mut fut.operator).poll_progress(cx, fut.uploaded, fut.total)
113 self: Pin<&mut Self>, in poll_progress()
H A Dmod.rs18 use std::pin::Pin;
59 /// # use std::pin::Pin;
71 /// self: Pin<&mut Self>,
132 self: Pin<&mut Self>, in poll_read()
144 match Pin::new(&mut this.operator).poll_progress( in poll_read()
160 Pin::new(&mut this.reader).poll_read(cx, buf) in poll_read()
171 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
206 use crate::async_impl::uploader::{Context, Pin, Poll};
233 ylong_runtime::futures::poll_fn(|cx| Pin::new(&mut uploader).poll_read(cx, &mut buf))
248 ylong_runtime::futures::poll_fn(|cx| Pin
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/
H A Dtry_join3.rs15 use std::pin::Pin;
45 let mut fut1 = unsafe { Pin::new_unchecked(&mut fut1) };
48 let mut fut2 = unsafe { Pin::new_unchecked(&mut fut2) };
51 let mut fut3 = unsafe { Pin::new_unchecked(&mut fut3) };
81 pub(crate) fn take_output(self: Pin<&mut Self>) -> F::Output {
96 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
100 FutureDone::Pending(fut) => match Pin::new_unchecked(fut).poll(cx) { in poll()
118 use std::pin::Pin;
169 let mut fut = unsafe { Pin::new_unchecked(&mut fut) }; in ut_future_done_test()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/
H A Dc_ssl_stream.rs14 use core::pin::Pin;
29 fn with_context<F, R>(self: Pin<&mut Self>, ctx: &mut Context<'_>, f: F) -> R in with_context()
45 fn get_pin_mut(self: Pin<&mut Self>) -> Pin<&mut S> { in get_pin_mut()
47 unsafe { Pin::new_unchecked(&mut self.get_unchecked_mut().0.get_mut().stream) } in get_pin_mut()
78 fn poll_connect(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), ssl::SslError>> { in poll_connect()
83 pub(crate) async fn connect(mut self: Pin<&mut Self>) -> Result<(), ssl::SslError> { in poll_connect()
94 self: Pin<&mut Self>, in poll_read()
126 fn poll_write(self: Pin<&mut Self>, ctx: &mut Context, buf: &[u8]) -> Poll<io::Result<usize>> { in poll_write()
130 fn poll_flush(self: Pin<
[all...]
H A Dwrapper.rs15 use core::pin::Pin;
34 unsafe fn inner(&mut self) -> (Pin<&mut S>, &mut Context<'_>) { in inner()
36 let stream = Pin::new_unchecked(&mut self.stream);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dyield_now.rs16 use std::pin::Pin;
45 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
67 fn poll(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/
H A Dpty.rs17 use std::pin::Pin;
180 self: Pin<&mut Self>, in poll_read()
190 self: Pin<&mut Self>, in poll_write()
197 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
201 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
230 self: Pin<&mut Self>, in poll_read()
267 self: Pin<&mut Self>, in poll_write()
274 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
278 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
289 self: Pin< in poll_read()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dmod.rs176 use core::pin::Pin;
228 self: Pin<&mut Self>, in poll_data()
300 self: Pin<&mut Self>, in poll_trailer()
372 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
374 Pin::new(&mut *fut.body).poll_trailer(cx)
398 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
400 Pin::new(&mut *fut.body).poll_data(cx, fut.buf)
409 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
417 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
430 ) -> Pin<Bo in reuse()
[all...]
H A Dempty.rs15 use core::pin::Pin;
95 self: Pin<&mut Self>, in poll_data()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/
H A Dsplit.rs18 use std::pin::Pin;
72 self: Pin<&mut Self>, in poll_read()
83 self: Pin<&mut Self>, in poll_write()
92 self: Pin<&mut Self>, in poll_write_vectored()
104 fn poll_flush(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), io::Error>> { in poll_flush()
109 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
116 fn stream(&mut self) -> Pin<&mut T> { in stream()
119 unsafe { Pin::new_unchecked(&mut *self.inner) } in stream()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/
H A Dstream.rs20 use std::pin::Pin;
339 self: Pin<&mut Self>, in poll_read()
348 fn poll_write(self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8]) -> Poll<Result<usize>> { in poll_write()
353 self: Pin<&mut Self>, in poll_write()
364 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>> { in poll_flush()
368 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>> { in poll_flush()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dtimer_test.rs17 use std::pin::Pin;
94 sleep: Option<Pin<Box<Sleep>>>,
101 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
107 if Pin::new(&mut sleep).poll(cx).is_pending() {

Completed in 10 milliseconds

1234