Searched refs:oneshot (Results 1 – 25 of 36) sorted by relevance
12
/system/nfc/src/rust/hal/ |
D | hidl_hal.rs | 25 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()
|
D | hal.rs | 24 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/ |
D | lib.rs | 31 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/ |
D | aconfigd.rc | 5 oneshot 15 oneshot 25 oneshot
|
/system/tools/aidl/tests/lazy_test/ |
D | aidl_lazy_test_server.rc | 6 oneshot 13 oneshot
|
D | aidl_lazy_cb_test_server.rc | 5 oneshot
|
/system/apex/apexd/ |
D | apexd.rc | 6 oneshot 16 oneshot 26 oneshot
|
/system/nfc/src/rust/nci/ |
D | nci.rs | 33 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/ |
D | snapuserd.rc | 3 oneshot 13 oneshot
|
/system/logging/logd/ |
D | logd.rc | 15 oneshot 23 oneshot
|
/system/core/usbd/ |
D | usbd.rc | 3 oneshot
|
/system/core/init/test_service/ |
D | test_service.rc | 7 oneshot
|
/system/core/init/ |
D | action.h | 62 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/ |
D | hidl_lazy_cb_test_server.rc | 5 oneshot
|
D | hidl_lazy_test_server.rc | 8 oneshot
|
/system/extras/boottime_tools/bootio/ |
D | bootio.rc | 7 oneshot
|
/system/core/trusty/keymint/ |
D | android.hardware.security.keymint-service.rust.trusty.rc | 7 oneshot
|
/system/sepolicy/public/ |
D | bootanim.te | 1 # bootanimation oneshot service
|
/system/sepolicy/private/ |
D | art_boot.te | 1 # ART boot oneshot service
|
/system/extras/profcollectd/ |
D | profcollectd.rc | 4 oneshot
|
/system/security/ondevice-signing/ |
D | odsign.rc | 11 # Note that odsign is not oneshot, but stopped manually when it exits. This
|
/system/dmesgd/ |
D | dmesgd.rc | 21 oneshot
|
/system/gsid/ |
D | gsid.rc | 3 oneshot
|
/system/core/trusty/utils/spiproxyd/ |
D | proxy.rc | 20 oneshot
|
/system/core/trusty/utils/rpmb_dev/ |
D | rpmb_dev.rc | 26 oneshot
|
12