Home
last modified time | relevance | path

Searched refs:Mutex (Results 1 – 25 of 142) sorted by relevance

123456

/packages/modules/Bluetooth/system/gd/rust/linux/client/src/
Dcallbacks.rs48 use std::sync::{Arc, Mutex};
61 context: Arc<Mutex<ClientContext>>,
64 dbus_crossroads: Arc<Mutex<Crossroads>>,
70 context: Arc<Mutex<ClientContext>>, in new()
72 dbus_crossroads: Arc<Mutex<Crossroads>>, in new()
108 Arc::new(Mutex::new(DisconnectWatcher::new())), in export_for_rpc()
110 cr.lock().unwrap().insert(self.get_object_id(), &[iface], Arc::new(Mutex::new(self))); in export_for_rpc()
117 context: Arc<Mutex<ClientContext>>,
120 dbus_crossroads: Arc<Mutex<Crossroads>>,
126 context: Arc<Mutex<ClientContext>>, in new()
[all …]
Deditor.rs15 use std::sync::{Arc, Mutex};
39 client_context: Arc<Mutex<ClientContext>>,
143 rl: Arc<Mutex<Editor<BtHelper>>>,
144 result: Arc<Mutex<Option<rustyline::Result<String>>>>,
171 rl: Arc<Mutex<Editor<BtHelper>>>,
180 client_context: Arc<Mutex<ClientContext>>, in new()
190 Ok(AsyncEditor { rl: Arc::new(Mutex::new(rl)) }) in new()
198 AsyncReadline { rl: self.rl.clone(), result: Arc::new(Mutex::new(None)) } in readline()
/packages/apps/TV/jni/
Dmutex.h24 class Mutex {
26 Mutex() { in Mutex() function
35 ~Mutex() { in ~Mutex()
43 Autolock(Mutex &mutex) : lock(&mutex) { in Autolock()
50 Mutex *lock;
57 Mutex(const Mutex&);
58 Mutex& operator=(const Mutex&);
/packages/apps/Nfc/nci/jni/
DMutex.cpp41 Mutex::Mutex() { in Mutex() function in Mutex
58 Mutex::~Mutex() { in ~Mutex()
74 void Mutex::lock() { in lock()
90 void Mutex::unlock() { in unlock()
106 bool Mutex::tryLock() { in tryLock()
123 pthread_mutex_t* Mutex::nativeHandle() { return &mMutex; } in nativeHandle()
DMutex.h24 class Mutex {
35 Mutex();
46 ~Mutex();
94 inline Autolock(Mutex& mutex) : mLock(mutex) { mLock.lock(); } in Autolock()
95 inline Autolock(Mutex* mutex) : mLock(*mutex) { mLock.lock(); } in Autolock()
99 Mutex& mLock;
106 typedef Mutex::Autolock AutoMutex;
/packages/modules/Bluetooth/system/gd/rust/linux/service/src/
Dmain.rs8 use std::sync::{Arc, Condvar, Mutex};
108 let logging = Arc::new(Mutex::new(Box::new(BluetoothLogging::new( in main()
128 enabled: Mutex::new(false), in main()
130 thread_attached: Mutex::new(false), in main()
134 let intf = Arc::new(Mutex::new(get_btinterface().unwrap())); in main()
136 Arc::new(Mutex::new(Box::new(BluetoothGatt::new(intf.clone(), tx.clone())))); in main()
138 Arc::new(Mutex::new(Box::new(BatteryProviderManager::new(tx.clone())))); in main()
139 let battery_service = Arc::new(Mutex::new(Box::new(BatteryService::new( in main()
145 let battery_manager = Arc::new(Mutex::new(Box::new(BatteryManager::new( in main()
149 let bluetooth_media = Arc::new(Mutex::new(Box::new(BluetoothMedia::new( in main()
[all …]
Dinterface_manager.rs5 use std::sync::{Arc, Mutex};
58 disconnect_watcher: Arc<Mutex<DisconnectWatcher>>, in dispatch()
59 bluetooth: Arc<Mutex<Box<Bluetooth>>>, in dispatch()
60 bluetooth_admin: Arc<Mutex<Box<BluetoothAdmin>>>, in dispatch()
61 bluetooth_gatt: Arc<Mutex<Box<BluetoothGatt>>>, in dispatch()
62 battery_service: Arc<Mutex<Box<BatteryService>>>, in dispatch()
63 battery_manager: Arc<Mutex<Box<BatteryManager>>>, in dispatch()
64 battery_provider_manager: Arc<Mutex<Box<BatteryProviderManager>>>, in dispatch()
65 bluetooth_media: Arc<Mutex<Box<BluetoothMedia>>>, in dispatch()
66 bluetooth_qa: Arc<Mutex<Box<BluetoothQA>>>, in dispatch()
[all …]
/packages/services/Car/cpp/watchdog/server/src/
DPressureMonitor.cpp62 Mutex::Autolock lock(mMutex); in init()
92 Mutex::Autolock lock(mMutex); in terminate()
101 Mutex::Autolock lock(mMutex); in terminate()
174 Mutex::Autolock lock(mMutex); in start()
193 Mutex::Autolock lock(mMutex); in start()
203 Mutex::Autolock lock(mMutex); in start()
212 Mutex::Autolock lock(mMutex); in registerPressureChangeCallback()
222 Mutex::Autolock lock(mMutex); in unregisterPressureChangeCallback()
247 Mutex::Autolock lock(mMutex); in handleMessage()
256 Mutex::Autolock lock(mMutex); in monitorPressure()
[all …]
DWatchdogProcessService.cpp305 Mutex::Autolock lock(mMutex); in unregisterClient()
326 Mutex::Autolock lock(mMutex); in registerCarWatchdogService()
340 Mutex::Autolock lock(mMutex); in unregisterCarWatchdogService()
355 Mutex::Autolock lock(mMutex); in registerMonitor()
373 Mutex::Autolock lock(mMutex); in registerMonitor()
395 Mutex::Autolock lock(mMutex); in unregisterMonitor()
417 Mutex::Autolock lock(mMutex); in tellClientAlive()
431 Mutex::Autolock lock(mMutex); in tellCarWatchdogServiceAlive()
449 Mutex::Autolock lock(mMutex); in tellDumpFinished()
460 Mutex::Autolock lock(mMutex); in setEnabled()
[all …]
DUidCpuStatsCollector.h60 Mutex::Autolock lock(mMutex); in init()
70 Mutex::Autolock lock(mMutex); in latestStats()
75 Mutex::Autolock lock(mMutex); in deltaStats()
80 Mutex::Autolock lock(mMutex); in enabled()
91 mutable Mutex mMutex;
DProcDiskStatsCollector.h107 Mutex::Autolock lock(mMutex); in init()
117 Mutex::Autolock lock(mMutex); in latestPerPartitionDiskStats()
122 Mutex::Autolock lock(mMutex); in deltaSystemWideDiskStats()
127 Mutex::Autolock lock(mMutex); in enabled()
138 mutable Mutex mMutex;
DWatchdogPerfService.cpp198 Mutex::Autolock lock(mMutex); in registerDataProcessor()
208 Mutex::Autolock lock(mMutex); in start()
259 Mutex::Autolock lock(mMutex); in start()
287 Mutex::Autolock lock(mMutex); in start()
296 Mutex::Autolock lock(mMutex); in terminate()
325 Mutex::Autolock lock(mMutex); in setSystemState()
334 Mutex::Autolock lock(mMutex); in onCarWatchdogServiceRegistered()
346 Mutex::Autolock lock(mMutex); in onBootFinished()
368 Mutex::Autolock lock(mMutex); in onUserStateChange()
461 Mutex::Autolock lock(mMutex); in onSuspendExit()
[all …]
/packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/
Dmedia_service.rs15 use std::sync::{Arc, Mutex};
35 pub btif_a2dp: Arc<Mutex<A2dp>>,
36 btif_a2dp_sink: Arc<Mutex<A2dpSink>>,
37 pub btif_avrcp: Arc<Mutex<Avrcp>>,
42 pub fn create(rt: Arc<Runtime>, btif_intf: Arc<Mutex<BluetoothInterface>>) -> grpcio::Service { in create()
51 btif_a2dp: Arc::new(Mutex::new(btif_a2dp)), in create()
52 btif_a2dp_sink: Arc::new(Mutex::new(btif_a2dp_sink)), in create()
53 btif_avrcp: Arc::new(Mutex::new(btif_avrcp)), in create()
Dhfp_service.rs15 use std::sync::{Arc, Mutex};
20 _hfp: Arc<Mutex<Hfp>>, in get_hfp_dispatcher()
21 tx: Arc<Mutex<Option<mpsc::Sender<HfpCallbacks>>>>, in get_hfp_dispatcher()
48 pub btif_hfp: Arc<Mutex<Hfp>>,
50 event_tx: Arc<Mutex<Option<mpsc::Sender<HfpCallbacks>>>>,
55 pub fn create(rt: Arc<Runtime>, btif_intf: Arc<Mutex<BluetoothInterface>>) -> grpcio::Service { in create()
56 let btif_hfp = Arc::new(Mutex::new(Hfp::new(&btif_intf.lock().unwrap()))); in create()
57 let event_tx = Arc::new(Mutex::new(None)); in create()
/packages/services/Car/cpp/powerpolicy/server/src/
DCarPowerPolicyServer.cpp64 using ::android::Mutex;
192 Mutex::Autolock lock(mMutex); in terminate()
197 Mutex::Autolock lock(mMutex); in dump()
206 Mutex::Autolock lock(mMutex); in notifyCarServiceReady()
216 Mutex::Autolock lock(mMutex); in notifyPowerPolicyChange()
227 Mutex::Autolock lock(mMutex); in notifyPowerPolicyDefinition()
238 Mutex::Autolock lock(mMutex); in terminate()
243 Mutex::Autolock lock(mMutex); in dump()
272 Mutex::Autolock lock(mMutex); in setPowerPolicyGroup()
324 Mutex::Autolock lock(mMutex); in runWithService()
[all …]
DPowerComponentHandler.cpp39 Mutex::Autolock lock(mMutex); in init()
50 Mutex::Autolock lock(mMutex); in applyPowerPolicy()
110 Mutex::Autolock lock(mMutex); in getCustomPowerComponentState()
117 Mutex::Autolock lock(mMutex); in getPowerComponentState()
123 Mutex::Autolock lock(mMutex); in getAccumulatedPolicy()
128 Mutex::Autolock lock(mMutex); in dump()
DSilentModeHandler.cpp39 using ::android::Mutex;
108 Mutex::Autolock lock(mMutex); in init()
133 Mutex::Autolock lock(mMutex); in isSilentMode()
185 Mutex::Autolock lock(mMutex); in dump()
248 Mutex::Autolock lock(mMutex); in handleSilentModeHwStateChange()
287 Mutex::Autolock lock(mMutex); in switchToForcedMode()
308 Mutex::Autolock lock(mMutex); in switchToNonForcedMode()
/packages/services/Car/cpp/watchdog/server/tests/
DLooperStub.cpp47 Mutex::Autolock lock(mMutex); in pollAll()
69 Mutex::Autolock lock(mMutex); in pollAll()
80 Mutex::Autolock lock(mMutex); in sendMessageAtTime()
97 Mutex::Autolock lock(mMutex); in removeMessages()
103 Mutex::Autolock lock(mMutex); in removeMessages()
118 Mutex::Autolock lock(mMutex); in pollCache()
124 Mutex::Autolock lock(mMutex); in pollCache()
/packages/services/Car/cpp/watchdog/testclient/src/
DWatchdogClient.cpp33 using ::android::Mutex;
55 Mutex::Autolock lock(mMutex); in checkIfAlive()
80 Mutex::Autolock lock(mMutex); in initialize()
101 Mutex::Autolock lock(mMutex); in finalize()
114 Mutex::Autolock lock(mMutex); in respondToWatchdog()
133 Mutex::Autolock lock(mMutex); in becomeInactive()
160 Mutex::Autolock lock(mMutex); in registerClient()
175 Mutex::Autolock lock(mMutex); in unregisterClient()
/packages/modules/Bluetooth/system/gd/rust/common/src/
Dinit_flags.rs6 use std::sync::Mutex;
243 static ref FLAGS: Mutex<InitFlags> = Mutex::new(InitFlags::default());
245 pub static ref AID_BLUETOOTH: Mutex<u32> = Mutex::new(1002);
247 pub static ref MISC: Mutex<String> = Mutex::new("/data/misc/".to_string());
270 pub(super) static ref ASYNC_LOCK: Mutex<bool> = Mutex::new(false);
/packages/modules/Connectivity/remoteauth/service/jni/src/
Dremoteauth_jni_android_platform.rs29 Arc, Mutex,
55 static ref HANDLE_MAPPING: Mutex<HashMap<i64, Arc<Mutex<JavaPlatform>>>> =
56 Mutex::new(HashMap::new());
64 fn insert_platform_handle(handle: i64, item: Arc<Mutex<JavaPlatform>>) { in insert_platform_handle()
103 map_futures: Mutex<HashMap<i64, Box<dyn ResponseCallback + Send>>>,
111 ) -> Result<Arc<Mutex<impl Platform>>, JNIError> { in create()
113 let platform = Arc::new(Mutex::new(JavaPlatform::new( in create()
138 map_futures: Mutex::new(HashMap::new()), in new()
/packages/modules/Bluetooth/system/gd/rust/linux/stack/src/
Dsuspend.rs11 use std::sync::{Arc, Mutex};
130 bt: Arc<Mutex<Box<Bluetooth>>>,
131 intf: Arc<Mutex<BluetoothInterface>>,
132 gatt: Arc<Mutex<Box<BluetoothGatt>>>,
133 media: Arc<Mutex<Box<BluetoothMedia>>>,
145 suspend_state: Arc<Mutex<SuspendState>>,
150 bt: Arc<Mutex<Box<Bluetooth>>>, in new()
151 intf: Arc<Mutex<BluetoothInterface>>, in new()
152 gatt: Arc<Mutex<Box<BluetoothGatt>>>, in new()
153 media: Arc<Mutex<Box<BluetoothMedia>>>, in new()
[all …]
Dasync_helper.rs2 use std::sync::{Arc, Mutex};
18 senders: Arc<Mutex<HashMap<u32, oneshot::Sender<R>>>>,
21 pub(crate) type CallbackSender<R> = Arc<Mutex<Box<(dyn Fn(u32, R) + Send)>>>;
28 senders: Arc::new(Mutex::new(HashMap::new())), in new()
77 return Arc::new(Mutex::new(Box::new(move |call_id, ret| { in get_callback_sender()
/packages/modules/Bluetooth/system/gd/rust/topshim/src/
Dtopstack.rs8 use std::sync::{Arc, Mutex};
29 static ref CB_DISPATCHER: Arc<Mutex<DispatchContainer>> =
30 Arc::new(Mutex::new(DispatchContainer { instances: HashMap::new() }));
106 pub fn get_dispatchers() -> Arc<Mutex<DispatchContainer>> { in get_dispatchers()
/packages/modules/Bluetooth/system/gd/rust/linux/mgmt/src/
Dpowerd_suspend_manager.rs9 use std::sync::{Arc, Mutex};
53 dbus_crossroads: Arc<Mutex<Crossroads>>,
55 context: Arc<Mutex<SuspendManagerContext>>,
62 dbus_crossroads: Arc<Mutex<Crossroads>>, in new()
63 context: Arc<Mutex<SuspendManagerContext>>, in new()
177 Arc::new(Mutex::new(DisconnectWatcher::new())), in export_for_rpc()
179 cr.lock().unwrap().insert(self.get_object_id(), &[iface], Arc::new(Mutex::new(self))); in export_for_rpc()
185 dbus_crossroads: Arc<Mutex<Crossroads>>,
194 context: Arc<Mutex<SuspendManagerContext>>,
205 pub fn new(conn: Arc<SyncConnection>, dbus_crossroads: Arc<Mutex<Crossroads>>) -> Self { in new()
[all …]

123456