Home
last modified time | relevance | path

Searched refs:oneshot (Results 1 – 25 of 36) sorted by relevance

12

/system/nfc/src/rust/hal/
Dhidl_hal.rs25 use tokio::sync::oneshot;
30 let (hal_open_evt_tx, hal_open_evt_rx) = oneshot::channel::<ffi::NfcStatus>(); in init()
31 let (hal_close_evt_tx, hal_close_evt_rx) = oneshot::channel::<ffi::NfcStatus>(); in init()
113 hal_open_evt_tx: Option<oneshot::Sender<ffi::NfcStatus>>,
114 hal_close_evt_tx: Option<oneshot::Sender<ffi::NfcStatus>>,
159 hal_close_evt_rx: oneshot::Receiver<ffi::NfcStatus>, in dispatch_outgoing()
Dhal.rs24 use tokio::sync::{oneshot, Mutex};
78 handlers: Arc<Mutex<HashMap<HalEvent, oneshot::Sender<HalEventStatus>>>>,
83 pub async fn register(&mut self, event: HalEvent, sender: oneshot::Sender<HalEventStatus>) { in register()
92 pub async fn unregister(&mut self, event: HalEvent) -> Option<oneshot::Sender<HalEventStatus>> { in unregister()
/system/security/keystore2/rkpd_client/src/
Dlib.rs31 use tokio::sync::oneshot;
84 inner: Mutex<Option<oneshot::Sender<T>>>,
88 fn new(sender: oneshot::Sender<T>) -> Self { in new()
109 registration_tx: oneshot::Sender<Result<binder::Strong<dyn IRegistration>>>, in new_native_binder()
149 let (tx, rx) = oneshot::channel(); in get_rkpd_registration()
168 key_tx: oneshot::Sender<Result<RemotelyProvisionedKey>>, in new_native_binder()
207 let (tx, rx) = oneshot::channel(); in get_rkpd_attestation_key_from_registration_async()
243 completer: oneshot::Sender<Result<()>>, in new_native_binder()
273 let (tx, rx) = oneshot::channel(); in store_rkpd_attestation_key_with_registration_async()
410 let (tx, rx) = oneshot::channel(); in get_mock_registration()
[all …]
/system/server_configurable_flags/aconfigd/
Daconfigd.rc5 oneshot
15 oneshot
25 oneshot
/system/tools/aidl/tests/lazy_test/
Daidl_lazy_test_server.rc6 oneshot
13 oneshot
Daidl_lazy_cb_test_server.rc5 oneshot
/system/apex/apexd/
Dapexd.rc6 oneshot
16 oneshot
26 oneshot
/system/nfc/src/rust/nci/
Dnci.rs33 use tokio::sync::{oneshot, RwLock};
76 response: oneshot::Sender<Response>,
82 notification: Option<oneshot::Sender<Notification>>,
95 pub notification: oneshot::Receiver<Notification>,
101 let (tx, rx) = oneshot::channel::<Response>(); in send()
113 let (tx, rx) = oneshot::channel::<Response>(); in send_and_notify()
114 let (ntx, nrx) = oneshot::channel::<Notification>(); in send_and_notify()
297 handlers: Arc<Mutex<HashMap<Opcode, oneshot::Sender<Notification>>>>,
302 pub async fn register(&mut self, code: Opcode, sender: oneshot::Sender<Notification>) { in register()
311 pub async fn unregister(&mut self, code: Opcode) -> Option<oneshot::Sender<Notification>> { in unregister()
/system/core/fs_mgr/libsnapshot/snapuserd/
Dsnapuserd.rc3 oneshot
13 oneshot
/system/logging/logd/
Dlogd.rc15 oneshot
23 oneshot
/system/core/usbd/
Dusbd.rc3 oneshot
/system/core/init/test_service/
Dtest_service.rc7 oneshot
/system/core/init/
Daction.h62 Action(bool oneshot, Subcontext* subcontext, const std::string& filename, int line,
78 bool oneshot() const { return oneshot_; } in oneshot() function
/system/tools/hidl/test/lazy_test/
Dhidl_lazy_cb_test_server.rc5 oneshot
Dhidl_lazy_test_server.rc8 oneshot
/system/extras/boottime_tools/bootio/
Dbootio.rc7 oneshot
/system/core/trusty/keymint/
Dandroid.hardware.security.keymint-service.rust.trusty.rc7 oneshot
/system/sepolicy/public/
Dbootanim.te1 # bootanimation oneshot service
/system/sepolicy/private/
Dart_boot.te1 # ART boot oneshot service
/system/extras/profcollectd/
Dprofcollectd.rc4 oneshot
/system/security/ondevice-signing/
Dodsign.rc11 # Note that odsign is not oneshot, but stopped manually when it exits. This
/system/dmesgd/
Ddmesgd.rc21 oneshot
/system/gsid/
Dgsid.rc3 oneshot
/system/core/trusty/utils/spiproxyd/
Dproxy.rc20 oneshot
/system/core/trusty/utils/rpmb_dev/
Drpmb_dev.rc26 oneshot

12