Home
last modified time | relevance | path

Searched refs:Pin (Results 1 – 25 of 140) sorted by relevance

123456

/ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/parcel/
H A Dwrapper.rs17 use std::pin::Pin;
59 msgParcel: Pin<&mut MessageParcel>, in WriteRemoteObject()
68 fn ReadString16(parcel: Pin<&mut Parcel>) -> String; in ReadString16()
87 fn ReadInt8(self: Pin<&mut Parcel>, v: &mut i8) -> bool; in ReadInt8()
97 fn ReadPointer(self: Pin<&mut Parcel>) -> usize; in ReadPointer()
110 fn GetReadPosition(self: Pin<&mut Parcel>) -> usize; in GetReadPosition()
111 fn GetWritePosition(self: Pin<&mut Parcel>) -> usize; in GetWritePosition()
113 fn SkipBytes(self: Pin<&mut Parcel>, size: usize); in SkipBytes()
119 fn SetFlags(self: Pin<&mut MessageOption>, flag: i32); in SetFlags()
158 fn write_process(&self, parcel: Pin<&mut Parcel>) -> bool; in write_process()
[all …]
H A Dmsg.rs19 use std::pin::Pin;
349 parcel: Pin<&mut MessageParcel>, in read_remote()
607 fn as_msg_parcel_mut(&mut self) -> Pin<&mut MessageParcel> { in as_msg_parcel_mut()
629 pub(crate) fn as_parcel_mut(&mut self) -> Pin<&mut Parcel> { in as_parcel_mut()
633 Pin::new_unchecked(&mut *parcel) in as_parcel_mut()
637 Pin::new_unchecked(&mut *parcel) in as_parcel_mut()
646 f: fn(parcel: Pin<&mut MessageParcel>, value: T) -> bool, in write_process()
658 let w = unsafe { Pin::new_unchecked(&mut *p) }; in write_process()
672 f: fn(parcel: Pin<&mut MessageParcel>) -> IpcResult<T>, in read_process()
681 let w = unsafe { Pin::new_unchecked(&mut *p) }; in read_process()
[all …]
/ohos5.0/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()
102 mut self: Pin<&mut Self>,
112 mut self: Pin<&mut Self>,
128 Pin::new(&mut **self).poll_flush(cx)
134 Pin::new(&mut **self).poll_shutdown(cx)
147 impl<T> AsyncWrite for Pin<T> implementation
152 self: Pin<&mut Self>, in poll_write()
160 self: Pin<&mut Self>, in poll_write_vectored()
[all …]
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 consume()
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 consume()
57 Pin::new(&mut **self).consume(amt) in consume()
64 Pin::new(&mut **self.get_mut()).poll_fill_buf(cx) in poll_fill_buf()
67 fn consume(mut self: Pin<&mut Self>, amt: usize) { in consume()
68 Pin::new(&mut **self).consume(amt) in consume()
73 impl<T> AsyncBufRead for Pin<T> implementation
[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> implementation
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 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> implementation
77 self: Pin<&mut Self>, in poll_read()
211 mut self: Pin<&mut Self>, in poll_read()
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) { in poll()
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) { in poll()
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..]) { in poll()
177 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
179 Pin::new(&mut me.writer).poll_flush(cx) in poll()
202 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/
H A Dmix.rs14 use core::pin::Pin;
34 mut self: Pin<&mut Self>, in poll_read()
39 MixStream::Http(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
40 MixStream::Https(s) => Pin::new(s).poll_read(cx, buf), in poll_read()
51 mut self: Pin<&mut Self>, in poll_write()
56 MixStream::Http(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
57 MixStream::Https(s) => Pin::new(s).poll_write(ctx, buf), in poll_write()
63 MixStream::Http(s) => Pin::new(s).poll_flush(ctx), in poll_flush()
64 MixStream::Https(s) => Pin::new(s).poll_flush(ctx), in poll_flush()
70 MixStream::Http(s) => Pin::new(s).poll_shutdown(ctx), in poll_shutdown()
[all …]
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 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<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_flush()
134 fn poll_shutdown(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_shutdown()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/
H A Dasync_buf_writer.rs16 use std::pin::Pin;
207 mut self: Pin<&mut Self>, in poll_write()
225 mut self: Pin<&mut Self>, in poll_write_vectored()
285 unsafe { Pin::new_unchecked(&mut this.inner).poll_flush(cx) } in poll_flush()
291 unsafe { Pin::new_unchecked(&mut this.inner).poll_shutdown(cx) } in poll_shutdown()
297 mut self: Pin<&mut Self>, in poll_seek()
303 unsafe { Pin::new_unchecked(&mut this.inner).poll_seek(cx, pos) } in poll_seek()
309 self: Pin<&mut Self>, in poll_read()
321 unsafe { Pin::new_unchecked(&mut this.inner).poll_fill_buf(cx) } in poll_fill_buf()
324 fn consume(self: Pin<&mut Self>, amt: usize) { in consume()
[all …]
H A Dasync_buf_reader.rs16 use std::pin::Pin;
182 mut self: Pin<&mut Self>, in poll_read()
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()
253 self: Pin<&mut Self>, in poll_write()
258 unsafe { Pin::new_unchecked(&mut this.inner).poll_write(cx, buf) } in poll_write()
262 self: Pin<&mut Self>, in poll_write_vectored()
276 unsafe { Pin::new_unchecked(&mut this.inner).poll_flush(cx) } in poll_flush()
[all …]
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/
H A Doperator.rs18 use std::pin::Pin;
64 self: Pin<&mut Self>, in poll_download()
73 self: Pin<&mut Self>, in poll_progress()
110 mut self: Pin<&mut Self>, in poll_download()
114 Pin::new(&mut **self).poll_download(cx, data) in poll_download()
118 mut self: Pin<&mut Self>, in poll_progress()
123 Pin::new(&mut **self).poll_progress(cx, downloaded, total) in poll_progress()
139 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
141 Pin::new(&mut fut.operator).poll_download(cx, fut.data) in poll()
169 self: Pin<&mut Self>, in poll_download()
[all …]
/ohos5.0/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) in poll()
138 self: Pin<&mut Self>, in poll_download()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dstream.rs16 use std::pin::Pin;
43 mut self: Pin<&mut Self>, in poll_read()
47 Pin::new(&mut self.stream).poll_read(cx, buf) in poll_read()
57 mut self: Pin<&mut Self>, in poll_write()
61 Pin::new(&mut self.stream).poll_write(cx, buf) in poll_write()
64 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
65 Pin::new(&mut self.stream).poll_flush(cx) in poll_flush()
68 fn poll_shutdown(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
69 Pin::new(&mut self.stream).poll_shutdown(cx) in poll_shutdown()
/ohos5.0/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_shutdown()
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()
289 self: Pin<&mut Self>, in poll_read()
326 self: Pin<&mut Self>, in poll_write()
[all …]
/ohos5.0/foundation/systemabilitymgr/samgr/interfaces/innerkits/rust/src/
H A Dwrapper.rs14 use std::pin::Pin;
43 data: Pin<&mut MessageParcel>, in on_remote_request()
44 reply: Pin<&mut MessageParcel>, in on_remote_request()
94 fn UnSubscribe(self: Pin<&mut UnSubscribeSystemAbilityHandler>); in UnSubscribe()
107 action: Pin<&mut CxxString>, in SendStrategy()
127 fn UnSubscribe(self: Pin<&mut UnSubscribeSystemProcessHandler>); in UnSubscribe()
129 fn GetOnDemandReasonExtraData(extra_data_id: i64, parcel: Pin<&mut MessageParcel>) -> i32; in GetOnDemandReasonExtraData()
147 data: Pin<&mut MessageParcel>, in on_remote_request()
148 reply: Pin<&mut MessageParcel>, in on_remote_request()
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/
H A Doperator.rs18 use std::pin::Pin;
56 self: Pin<&mut Self>, in poll_progress()
82 mut self: Pin<&mut Self>, in poll_progress()
87 Pin::new(&mut **self).poll_progress(cx, uploaded, total) in poll_progress()
104 fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> { in poll()
106 Pin::new(&mut fut.operator).poll_progress(cx, fut.uploaded, fut.total) in poll()
115 self: Pin<&mut Self>, in poll_progress()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/
H A Doperator.rs15 use std::pin::Pin;
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) in poll()
113 self: Pin<&mut Self>, in poll_progress()
H A Dmod.rs18 use std::pin::Pin;
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)) in upload()
248 ylong_runtime::futures::poll_fn(|cx| Pin::new(&mut multi_uploader).poll_read(cx, &mut buf)) in upload()
273 self: Pin<&mut Self>, in upload_op_cov()
306 self: Pin<&mut Self>, in upload_and_show_progress()
[all …]
/ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/remote/
H A Dwrapper.rs19 use std::pin::Pin;
38 data: Pin<&mut MessageParcel>, in on_remote_request()
39 reply: Pin<&mut MessageParcel>, in on_remote_request()
75 data: Pin<&mut MessageParcel>, in SendRequest()
76 reply: Pin<&mut MessageParcel>, in SendRequest()
77 option: Pin<&mut MessageOption>, in SendRequest()
118 data: Pin<&mut MessageParcel>, in on_remote_request()
119 reply: Pin<&mut MessageParcel>, in on_remote_request()
/ohos5.0/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/rust/src/
H A Dwrapper.rs18 use std::pin::Pin;
65 data: Pin<&mut MessageParcel>, in on_remote_request()
66 reply: Pin<&mut MessageParcel>, in on_remote_request()
116 self: Pin<&mut SystemAbilityWrapper>, in AddSystemAbilityListener()
121 self: Pin<&mut SystemAbilityWrapper>, in RemoveSystemAbilityListener()
125 fn StopAbilityWrapper(self: Pin<&mut SystemAbilityWrapper>, system_ability: i32); in StopAbilityWrapper()
127 fn CancelIdleWrapper(self: Pin<&mut SystemAbilityWrapper>) -> bool; in CancelIdleWrapper()
132 data: Pin<&mut MessageParcel>, in DeserializeOnDemandReasonExtraData()
137 data: Pin<&mut MessageParcel>, in SerializeOnDemandReasonExtraData()
212 data: Pin<&mut MessageParcel>, in on_remote_request()
[all …]
/ohos5.0/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()
/ohos5.0/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) }; in try_join3()
48 let mut fut2 = unsafe { Pin::new_unchecked(&mut fut2) }; in try_join3()
51 let mut fut3 = unsafe { Pin::new_unchecked(&mut fut3) }; in try_join3()
81 pub(crate) fn take_output(self: Pin<&mut Self>) -> F::Output { in take_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()
H A Dchild.rs18 use std::pin::Pin;
343 mut self: Pin<&mut Self>, in poll_write()
347 Pin::new(&mut self.inner).poll_write(ctx, buffer) in poll_write()
351 mut self: Pin<&mut Self>, in poll_write_vectored()
355 Pin::new(&mut self.inner).poll_write_vectored(ctx, bufs) in poll_write_vectored()
363 Pin::new(&mut self.inner).poll_flush(ctx) in poll_flush()
367 Pin::new(&mut self.inner).poll_shutdown(ctx) in poll_shutdown()
373 mut self: Pin<&mut Self>, in poll_read()
377 Pin::new(&mut self.inner).poll_read(ctx, buf) in poll_read()
383 mut self: Pin<&mut Self>, in poll_read()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/
H A Dsplit.rs16 use std::pin::Pin;
31 self: Pin<&mut Self>, in poll_read()
41 self: Pin<&mut Self>, in poll_write()
49 self: Pin<&mut Self>, in poll_write_vectored()
60 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
64 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
77 self: Pin<&mut Self>, in poll_read()
87 self: Pin<&mut Self>, in poll_write()
95 self: Pin<&mut Self>, in poll_write_vectored()
106 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
[all …]

123456