| /ohos5.0/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..]) in flush()
217 unsafe { Pin::new_unchecked(&mut this.inner).poll_write(cx, buf) } in poll_write()
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()
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()
303 unsafe { Pin::new_unchecked(&mut this.inner).poll_seek(cx, pos) } in poll_seek()
314 unsafe { Pin::new_unchecked(&mut this.inner).poll_read(cx, buf) } in poll_read()
321 unsafe { Pin::new_unchecked(&mut this.inner).poll_fill_buf(cx) } in poll_fill_buf()
326 unsafe { Pin::new_unchecked(&mut this.inner).consume(amt) } in consume()
|
| H A D | async_buf_reader.rs | 189 return unsafe { Pin::new_unchecked(&mut this.inner).poll_read(cx, buf) }; in poll_read()
206 poll_ready!(Pin::new_unchecked(&mut this.inner).poll_read(cx, &mut read_buf))?; in poll_fill_buf()
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::new_unchecked(&mut this.inner).poll_seek(cx, pos))? }; in poll_seek()
258 unsafe { Pin::new_unchecked(&mut this.inner).poll_write(cx, buf) } in poll_write()
267 unsafe { Pin::new_unchecked(&mut this.inner).poll_write_vectored(cx, bufs) } in poll_write_vectored()
276 unsafe { Pin::new_unchecked(&mut this.inner).poll_flush(cx) } in poll_flush()
281 unsafe { Pin::new_unchecked(&mut this.inner).poll_shutdown(cx) } in poll_shutdown()
|
| /ohos5.0/foundation/systemabilitymgr/safwk/interfaces/innerkits/safwk/rust/src/ |
| H A D | ability.rs | 79 let system_ability = unsafe { Pin::new_unchecked(&mut *self.inner) }; in publish()
84 let system_ability = unsafe { Pin::new_unchecked(&mut *self.inner) }; in cancel_idle()
89 let system_ability = unsafe { Pin::new_unchecked(&mut *self.inner) }; in add_system_ability_listen()
94 let system_ability = unsafe { Pin::new_unchecked(&mut *self.inner) }; in remove_system_ability_listen()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/ |
| H A D | try_join3.rs | 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()
100 FutureDone::Pending(fut) => match Pin::new_unchecked(fut).poll(cx) { in poll()
169 let mut fut = unsafe { Pin::new_unchecked(&mut fut) }; in ut_future_done_test()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| H A D | interest.rs | 27 pub const READABLE: Interest = Interest(unsafe { NonZeroU8::new_unchecked(READABLE) });
29 pub const WRITABLE: Interest = Interest(unsafe { NonZeroU8::new_unchecked(WRITABLE) });
33 Interest(unsafe { NonZeroU8::new_unchecked(self.0.get() | other.0.get()) }) in add()
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/parcel/ |
| H A D | msg.rs | 360 .map(|remote| unsafe { RemoteObj::new_unchecked(remote) }) in read_remote()
610 ParcelMem::Borrow(p) => unsafe { Pin::new_unchecked(&mut **p) }, in as_msg_parcel_mut()
633 Pin::new_unchecked(&mut *parcel) in as_parcel_mut()
636 let parcel = AsParcelMut(Pin::new_unchecked(&mut **p)); in as_parcel_mut()
637 Pin::new_unchecked(&mut *parcel) in as_parcel_mut()
658 let w = unsafe { Pin::new_unchecked(&mut *p) }; in write_process()
681 let w = unsafe { Pin::new_unchecked(&mut *p) }; in read_process()
|
| H A D | wrapper.rs | 527 value.write_process(Pin::new_unchecked(&mut *parcel)) in serialize()
539 Process::read_process(Pin::new_unchecked(&mut *parcel)) in deserialize()
551 WriteString(Pin::new_unchecked(&mut *parcel), value) in serialize()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | timeout.rs | 75 let value = unsafe { Pin::new_unchecked(&mut timeout.value) }; in poll()
80 let sleep = unsafe { Pin::new_unchecked(&mut timeout.sleep) }; in poll()
|
| H A D | wheel.rs | 131 NonNull::new_unchecked(node_ptr) in node()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/ |
| H A D | schedule_io.rs | 106 NonNull::new_unchecked(node_ptr) in node()
170 let mut fut = unsafe { Pin::new_unchecked(&mut fut) }; in readiness()
366 .push_front(NonNull::new_unchecked(waiter.get())); in poll_init()
456 .remove(NonNull::new_unchecked(self.waiter.get())); in drop()
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | database.rs | 90 let ret = unsafe { Pin::new_unchecked(&mut *self.inner).ExecuteSql(sql) }; in execute()
115 let ret = unsafe { Pin::new_unchecked(&mut *self.inner).QueryInteger(sql, &mut v) }; in query_integer()
490 unsafe { Pin::new_unchecked(&mut *self.inner).GetTaskQosInfo(&sql, &mut info) }; in get_task_qos_info()
524 let _ = unsafe { Pin::new_unchecked(&mut *self.inner).GetAppTaskQosInfos(sql, &mut v) }; in get_app_task_qos_infos_inner()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | block_on.rs | 103 let mut future = unsafe { Pin::new_unchecked(&mut task) }; in block_on()
|
| H A D | current_thread.rs | 283 let mut future = unsafe { Pin::new_unchecked(&mut future) }; in block_on()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| H A D | wrapper.rs | 36 let stream = Pin::new_unchecked(&mut self.stream); in inner()
|
| H A D | c_ssl_stream.rs | 47 unsafe { Pin::new_unchecked(&mut self.get_unchecked_mut().0.get_mut().stream) } in get_pin_mut()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| H A D | linked_list.rs | 86 let head_ptr = unsafe { NonNull::new_unchecked(Box::into_raw(head)) }; in new()
203 NonNull::new_unchecked(node_ptr) in address_of_node()
|
| /ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/remote/ |
| H A D | obj.rs | 59 pub unsafe fn new_unchecked(wrap: UniquePtr<IRemoteObjectWrapper>) -> Self { in new_unchecked() method
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/ |
| H A D | split.rs | 119 unsafe { Pin::new_unchecked(&mut *self.inner) } in stream()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | raw.rs | 109 NonNull::new_unchecked(node_ptr) in node()
254 let future = unsafe { Pin::new_unchecked(future) }; in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
| H A D | select.rs | 224 let fut = unsafe { Pin::new_unchecked(fut) };
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/ |
| H A D | selector.rs | 616 unsafe { Pin::new_unchecked(Arc::from_raw(sock_ptr)) } in from_overlapped()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| H A D | simple.rs | 465 let result = unsafe { Pin::new_unchecked(stream).poll_read(cx, buf) }; in poll_read_curr()
|