Home
last modified time | relevance | path

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

/foundation/communication/ipc/interfaces/innerkits/rust/src/parcel/
H A Dwrapper.rs17 use std::pin::Pin;
44 fn ReadFileDescriptor(self: Pin<&mut MessageParcel>) -> i32; in ReadFileDescriptor()
45 fn WriteFileDescriptor(self: Pin<&mut MessageParcel>, fd: i32) -> bool; in WriteFileDescriptor()
48 unsafe fn AsParcelMut(msgParcel: Pin<&mut MessageParcel>) -> *mut Parcel; in AsParcelMut()
50 fn WriteInterfaceToken(msgParcel: Pin<&mut MessageParcel>, name: &str) -> bool; in WriteInterfaceToken()
51 fn ReadInterfaceToken(msgParcel: Pin<&mut MessageParcel>) -> String; in ReadInterfaceToken()
53 fn WriteBuffer(msgParcel: Pin<&mut MessageParcel>, buffer: &[u8]) -> bool; in WriteBuffer()
55 fn ReadBuffer(msgParcel: Pin<&mut MessageParcel>, len: usize, buffer: &mut Vec<u8>) in ReadBuffer()
59 msgParcel: Pin<&mut MessageParcel>, in WriteRemoteObject()
63 fn ReadRemoteObject(msgParcel: Pin<
[all...]
H A Dmsg.rs19 use std::pin::Pin;
169 fn read_process(parcel: Pin<&mut MessageParcel>) -> IpcResult<String> { in read_interface_token()
349 parcel: Pin<&mut MessageParcel>, in read_remote()
607 fn as_msg_parcel_mut(&mut self) -> Pin<&mut MessageParcel> { in as_msg_parcel_mut()
610 ParcelMem::Borrow(p) => unsafe { Pin::new_unchecked(&mut **p) }, in as_msg_parcel_mut()
629 pub(crate) fn as_parcel_mut(&mut self) -> Pin<&mut Parcel> {
633 Pin::new_unchecked(&mut *parcel)
636 let parcel = AsParcelMut(Pin::new_unchecked(&mut **p));
637 Pin::new_unchecked(&mut *parcel)
646 f: fn(parcel: Pin<
[all...]
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/
H A Doperator.rs18 use std::pin::Pin;
31 /// # use std::pin::Pin;
42 /// self: Pin<&mut Self>,
50 /// self: Pin<&mut Self>,
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 in poll_progress()
[all...]
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/
H A Doperator.rs18 use std::pin::Pin;
30 /// # use std::pin::Pin;
42 /// self: Pin<&mut Self>,
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)
115 self: Pin<&mut Self>, in poll_progress()
H A Dmod.rs25 use std::pin::Pin;
62 /// # use std::pin::Pin;
75 /// self: Pin<&mut Self>,
132 self: Pin<&mut Self>, in poll_read()
144 match Pin::new(&mut this.operator).poll_progress( in poll_read()
158 match Pin::new(&mut this.reader).poll_read(cx, buf) { in poll_read()
H A Dmultipart.rs17 use std::pin::Pin;
193 mut self: Pin<&mut Self>, in poll_read()
208 return match Pin::new(status).poll_read(cx, buf) { in poll_read()
443 Stream(Pin<Box<dyn AsyncRead + Send + Sync>>),
451 fn stream(reader: Pin<Box<dyn AsyncRead + Send + Sync>>) -> Self { in stream()
458 self: Pin<&mut Self>, in poll_read()
/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()
129 fn PublishWrapper(self: Pin<&mut SystemAbilityWrapper>, ability: Box<AbilityStub>) -> bool; in PublishWrapper()
132 data: Pin<&mut MessageParcel>, in DeserializeOnDemandReasonExtraData()
137 data: Pin< in SerializeOnDemandReasonExtraData()
[all...]
H A Dability.rs16 use std::pin::Pin;
79 let system_ability = unsafe { Pin::new_unchecked(&mut *self.inner) };
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()
/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()
/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()
/foundation/communication/netmanager_base/interfaces/innerkits/netconnclient/include/
H A Dnetwork_security_config.h38 struct Pin { struct
45 std::vector<Pin> pins_;
/foundation/communication/ipc/interfaces/innerkits/rust/src/ipc_async/
H A Dmod.rs19 use std::pin::Pin;
27 /// without littering it with Pin and Send bounds.
28 pub type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;
/foundation/communication/ipc/interfaces/innerkits/rust/src/
H A Dskeleton.rs56 fn FlushCommands(object: Pin<&mut IRemoteObjectWrapper>) -> i32; in FlushCommands()
/foundation/communication/netmanager_base/frameworks/native/netconnclient/src/
H A Dnetwork_security_config.cpp446 Pin pin; in ParseJsonPinSet()
/foundation/communication/netmanager_base/test/netsysbpfstats/unittest/bpf_core_test/
H A DBpfTaskTaskTest.cpp853 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()
/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_core_test/
H A DNetSysTaskTaskTest.cpp853 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()
/foundation/communication/netmanager_ext/test/vpnmanager/unittest/vpn_core_test/
H A DVpnTaskTaskTest.cpp853 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()
/foundation/communication/netstack/test/unittest/http_test/
H A DHttpClientTaskTest.cpp853 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()
/foundation/communication/netstack/test/unittest/tcp_core_test/
H A DTcpSocketTaskTaskTest.cpp853 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()
/foundation/communication/netmanager_ext/test/networksharemanager/unittest/netshare_core_test/
H A DNetShareTaskTaskTest.cpp853 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()
/foundation/communication/netstack/test/unittest/http_client_test/
H A DHttpClientTaskTest.cpp852 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()
/foundation/communication/netstack/test/unittest/http_client/
H A DHttpClientTaskTest.cpp853 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()
/foundation/communication/netstack/test/unittest/websocket_core_test/
H A DWebSocketTaskTaskTest.cpp853 OHOS::NetManagerStandard::Pin pin; in HWTEST_F()

Completed in 21 milliseconds