| /system/netd/server/ |
| D | ClatdController.h | 42 explicit ClatdController(NetworkController* controller) EXCLUDES(mutex) in ClatdController()
44 virtual ~ClatdController() EXCLUDES(mutex){}; in ~ClatdController()
47 void init(void) EXCLUDES(mutex);
50 std::string* v6Addr) EXCLUDES(mutex);
51 int stopClatd(const std::string& interface) EXCLUDES(mutex);
53 void dump(netdutils::DumpWriter& dw) EXCLUDES(mutex);
79 std::mutex mutex; variable
81 const NetworkController* mNetCtrl GUARDED_BY(mutex);
82 std::map<std::string, ClatdTracker> mClatdTrackers GUARDED_BY(mutex);
83 ClatdTracker* getClatdTracker(const std::string& interface) REQUIRES(mutex);
[all …]
|
| /system/chre/util/tests/ |
| D | conditional_lock_guard_test.cc | 44 MockMutex mutex; in TEST() local
45 ASSERT_EQ(mutex.getLockCount(), 0); in TEST()
48 ConditionalLockGuard<MockMutex> lock(mutex, true); in TEST()
49 EXPECT_EQ(mutex.getLockCount(), 1); in TEST()
52 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
56 MockMutex mutex; in TEST() local
57 ASSERT_EQ(mutex.getLockCount(), 0); in TEST()
60 ConditionalLockGuard<MockMutex> lock(mutex, false); in TEST()
61 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
64 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
|
| D | lock_guard_test.cc | 44 MockMutex mutex; in TEST() local
45 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
48 LockGuard<MockMutex> lock(mutex); in TEST()
49 EXPECT_EQ(mutex.getLockCount(), 1); in TEST()
52 EXPECT_EQ(mutex.getLockCount(), 0); in TEST()
|
| /system/bt/osi/src/ |
| D | fixed_queue.cc | 35 std::mutex* mutex; member
49 ret->mutex = new std::mutex; in fixed_queue_new()
81 delete queue->mutex; in fixed_queue_free()
99 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_is_empty()
106 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_length()
123 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_enqueue()
137 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_dequeue()
154 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_try_enqueue()
169 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_try_dequeue()
182 std::lock_guard<std::mutex> lock(*queue->mutex); in fixed_queue_try_peek_first()
[all …]
|
| D | reactor.cc | 45 std::mutex* list_mutex;
56 std::mutex* mutex; // protects the lifetime of this object and all variables. member
89 ret->list_mutex = new std::mutex; in reactor_new()
153 object->mutex = new std::mutex; in reactor_register()
164 delete object->mutex; in reactor_register()
190 std::lock_guard<std::mutex> lock(*object->mutex); in reactor_change_registration()
213 std::unique_lock<std::mutex> lock(*reactor->list_mutex); in reactor_unregister()
225 obj->mutex->lock(); in reactor_unregister()
226 obj->mutex->unlock(); in reactor_unregister()
227 delete obj->mutex; in reactor_unregister()
[all …]
|
| D | allocation_tracker.cc | 43 static std::mutex tracker_lock;
53 std::unique_lock<std::mutex> lock(tracker_lock); in allocation_tracker_init()
66 std::unique_lock<std::mutex> lock(tracker_lock); in allocation_tracker_uninit()
74 std::unique_lock<std::mutex> lock(tracker_lock); in allocation_tracker_reset()
81 std::unique_lock<std::mutex> lock(tracker_lock); in allocation_tracker_expect_no_allocations()
104 std::unique_lock<std::mutex> lock(tracker_lock); in allocation_tracker_notify_alloc()
138 std::unique_lock<std::mutex> lock(tracker_lock); in allocation_tracker_notify_free()
180 std::unique_lock<std::mutex> lock(tracker_lock); in osi_allocator_debug_dump()
|
| /system/bt/service/common/bluetooth/util/ |
| D | atomic_string.cc | 24 std::mutex* mutex = const_cast<std::mutex*>(&lock_); in Get() local
25 std::lock_guard<std::mutex> lock(*mutex); in Get()
30 std::lock_guard<std::mutex> lock(lock_); in Set()
|
| /system/core/adb/ |
| D | fdevent_test.h | 36 std::mutex mutex; in WaitForFdeventLoop() local
38 std::unique_lock<std::mutex> lock(mutex); in WaitForFdeventLoop()
40 mutex.lock(); in WaitForFdeventLoop()
41 mutex.unlock(); in WaitForFdeventLoop()
|
| /system/extras/perfprofd/ |
| D | perfprofd_threaded_handler.h | 53 std::unique_lock<std::mutex> guard(mutex_); in Sleep()
58 std::unique_lock<std::mutex> guard(mutex_); in ShouldStopProfiling()
63 std::unique_lock<std::mutex> guard(mutex_); in ResetStopProfiling()
67 std::unique_lock<std::mutex> guard(mutex_); in StopProfiling()
87 std::mutex mutex_;
104 std::lock_guard<std::mutex> guard(lock_); in StartProfiling()
120 std::lock_guard<std::mutex> unset_guard(service->lock_); in StartProfiling()
130 std::lock_guard<std::mutex> guard(lock_); in StopProfiling()
175 std::lock_guard<std::mutex> guard(lock_); in RunOnConfig()
188 std::mutex lock_;
|
| /system/bt/service/ |
| D | a2dp_sink.cc | 44 std::lock_guard<std::mutex> lock(delegate_mutex_); in SetDelegate()
49 std::lock_guard<std::mutex> lock(mutex_); in Enable()
54 std::lock_guard<std::mutex> lock(mutex_); in Disable()
59 std::lock_guard<std::mutex> lock(mutex_); in Connect()
78 std::lock_guard<std::mutex> lock(mutex_); in Disconnect()
97 std::lock_guard<std::mutex> lock(mutex_); in SetAudioFocusState()
104 std::lock_guard<std::mutex> lock(mutex_); in SetAudioTrackGain()
114 std::lock_guard<std::mutex> lock(delegate_mutex_); in ConnectionStateCallback()
124 std::lock_guard<std::mutex> lock(delegate_mutex_); in AudioStateCallback()
135 std::lock_guard<std::mutex> lock(delegate_mutex_); in AudioConfigCallback()
|
| D | avrcp_control.cc | 48 std::lock_guard<std::mutex> lock(delegate_mutex_); in SetDelegate()
53 std::lock_guard<std::mutex> lock(mutex_); in Enable()
58 std::lock_guard<std::mutex> lock(mutex_); in Disable()
73 std::lock_guard<std::mutex> lock(mutex_); in SendPassThroughCommand()
96 std::lock_guard<std::mutex> lock(mutex_); in SetAbsVolumeResponse()
120 std::lock_guard<std::mutex> lock(mutex_); in RegisterForAbsVolumeCallbackResponse()
139 std::lock_guard<std::mutex> lock(delegate_mutex_); in ConnectionStateCallback()
147 std::lock_guard<std::mutex> lock(delegate_mutex_); in CtrlSetabsvolCmdCallback()
155 std::lock_guard<std::mutex> lock(delegate_mutex_); in CtrlRegisternotificationAbsVolCallback()
211 std::lock_guard<std::mutex> lock(delegate_mutex_); in CtrlTrackChangedCallback()
|
| D | adapter.cc | 41 using std::mutex;
220 lock_guard<mutex> lock(observers_lock_); in AddObserver()
225 lock_guard<mutex> lock(observers_lock_); in RemoveObserver()
390 lock_guard<mutex> lock(local_le_features_lock_); in IsMultiAdvertisementSupported()
395 lock_guard<mutex> lock(connected_devices_lock_); in IsDeviceConnected()
400 lock_guard<mutex> lock(local_le_features_lock_); in GetTotalNumberOfTrackableAdvertisements()
405 lock_guard<mutex> lock(local_le_features_lock_); in IsOffloadedFilteringSupported()
410 lock_guard<mutex> lock(local_le_features_lock_); in IsOffloadedScanBatchingSupported()
533 lock_guard<mutex> lock(observers_lock_); in AdapterPropertiesCallback()
560 lock_guard<mutex> lock(local_le_features_lock_); in AdapterPropertiesCallback()
[all …]
|
| D | low_energy_client.cc | 27 using std::mutex;
78 lock_guard<mutex> lock(connection_fields_lock_); in Disconnect()
105 lock_guard<mutex> lock(connection_fields_lock_); in SetMtu()
125 lock_guard<mutex> lock(delegate_mutex_); in SetDelegate()
143 lock_guard<mutex> lock(connection_fields_lock_); in ConnectCallback()
162 lock_guard<mutex> lock(connection_fields_lock_); in DisconnectCallback()
180 lock_guard<mutex> lock(connection_fields_lock_); in MtuChangedCallback()
210 lock_guard<mutex> lock(pending_calls_lock_); in RegisterInstance()
234 lock_guard<mutex> lock(pending_calls_lock_); in RegisterClientCallback()
|
| /system/chre/platform/linux/include/chre/target_platform/ |
| D | condition_variable_impl.h | 32 inline void ConditionVariable::wait(Mutex& mutex) { in wait() argument
33 mConditionVariable.wait(mutex); in wait()
36 inline bool ConditionVariable::wait_for(Mutex& mutex, Nanoseconds timeout) { in wait_for() argument
38 mutex, std::chrono::nanoseconds(timeout.toRawNanoseconds())); in wait_for()
|
| /system/libhidl/base/ |
| D | SynchronizedQueue.h | 48 std::unique_lock<std::mutex> lock() { in lock()
49 return std::unique_lock<std::mutex>(mMutex); in lock()
61 std::mutex mMutex;
73 std::unique_lock<std::mutex> lock(mMutex); in wait_pop()
89 std::unique_lock<std::mutex> lock(mMutex); in push()
104 std::unique_lock<std::mutex> lock(mMutex); in size()
|
| /system/core/libutils/include/utils/ |
| D | Condition.h | 69 status_t wait(Mutex& mutex);
71 status_t waitRelative(Mutex& mutex, nsecs_t reltime);
117 inline status_t Condition::wait(Mutex& mutex) { in wait() argument
118 return -pthread_cond_wait(&mCond, &mutex.mMutex); in wait()
120 inline status_t Condition::waitRelative(Mutex& mutex, nsecs_t reltime) { in waitRelative() argument
150 return -pthread_cond_timedwait(&mCond, &mutex.mMutex, &ts); in waitRelative()
|
| /system/bt/common/ |
| D | leaky_bonded_queue.h | 86 std::mutex lock_;
104 std::lock_guard<std::mutex> lock(lock_); in Enqueue()
114 std::lock_guard<std::mutex> lock(lock_); in EnqueueWithPop()
128 std::lock_guard<std::mutex> lock(lock_); in Dequeue()
136 std::lock_guard<std::mutex> lock(lock_); in Clear()
145 std::lock_guard<std::mutex> lock(lock_); in Length()
156 std::lock_guard<std::mutex> lock(lock_); in Empty()
|
| /system/chre/platform/slpi/include/chre/target_platform/ |
| D | condition_variable_impl.h | 39 inline void ConditionVariable::wait(Mutex& mutex) { in wait() argument
40 qurt_cond_wait(&mConditionVariable, &mutex.mMutex); in wait()
45 inline bool ConditionVariable::wait_for(Mutex& mutex, Nanoseconds timeout) { in wait_for() argument
71 wait(mutex); in wait_for()
|
| /system/libhidl/transport/include/hidl/ |
| D | ConcurrentMap.h | 34 std::unique_lock<std::mutex> _lock(mMutex); in set()
40 std::unique_lock<std::mutex> _lock(mMutex); in get()
49 std::unique_lock<std::mutex> _lock(mMutex); in erase()
54 std::unique_lock<std::mutex> _lock(mMutex); in eraseIfEqual()
67 std::unique_lock<std::mutex> lock() { return std::unique_lock<std::mutex>(mMutex); } in lock()
89 mutable std::mutex mMutex;
|
| /system/core/adb/daemon/ |
| D | mdns.cpp | 33 static std::mutex& mdns_lock = *new std::mutex();
65 std::lock_guard<std::mutex> lock(mdns_lock); in setup_mdns_thread()
84 std::lock_guard<std::mutex> lock(mdns_lock); in teardown_mdns()
|
| /system/bt/service/ipc/binder/ |
| D | bluetooth_a2dp_sink_binder_server.cc | 51 std::lock_guard<std::mutex> lock(*maps_lock()); in Enable()
70 std::lock_guard<std::mutex> lock(*maps_lock()); in Disable()
85 std::lock_guard<std::mutex> lock(*maps_lock()); in Connect()
105 std::lock_guard<std::mutex> lock(*maps_lock()); in Disconnect()
125 std::lock_guard<std::mutex> lock(*maps_lock()); in SetAudioFocusState()
140 std::lock_guard<std::mutex> lock(*maps_lock()); in SetAudioTrackGain()
155 std::lock_guard<std::mutex> lock(*maps_lock()); in OnConnectionState()
167 std::lock_guard<std::mutex> lock(*maps_lock()); in OnAudioState()
180 std::lock_guard<std::mutex> lock(*maps_lock()); in OnAudioConfig()
|
| /system/bt/vendor_libs/test_vendor_lib/model/setup/ |
| D | async_manager.cc | 101 std::unique_lock<std::mutex> guard(internal_mutex_); in WatchFdForNonBlockingReads()
119 std::unique_lock<std::mutex> guard(internal_mutex_); in StopWatchingFileDescriptor()
141 std::unique_lock<std::mutex> guard(internal_mutex_); in stopThread()
194 std::unique_lock<std::mutex> guard(internal_mutex_); in setUpFileDescriptorSet()
221 std::unique_lock<std::mutex> guard(internal_mutex_); in runAppropriateCallbacks()
262 std::mutex internal_mutex_;
285 std::unique_lock<std::mutex> guard(internal_mutex_); in CancelAsyncTask()
300 std::unique_lock<std::mutex> guard(internal_mutex_); in stopThread()
358 std::unique_lock<std::mutex> guard(internal_mutex_); in scheduleTask()
389 std::unique_lock<std::mutex> guard(internal_mutex_); in tryStartThread()
[all …]
|
| /system/core/base/ |
| D | quick_exit.cpp | 27 static auto& quick_exit_mutex = *new std::mutex();
31 std::lock_guard<std::mutex> lock(quick_exit_mutex); in quick_exit()
39 std::lock_guard<std::mutex> lock(quick_exit_mutex); in at_quick_exit()
|
| /system/libhidl/transport/token/1.0/utils/ |
| D | HybridInterface.cpp | 30 std::mutex gTokenManagerLock;
35 std::lock_guard<std::mutex> lock(gTokenManagerLock); in serviceDied()
79 std::lock_guard<std::mutex> lock(gTokenManagerLock); in retrieveHalInterface()
94 std::lock_guard<std::mutex> lock(gTokenManagerLock); in createHalToken()
108 std::lock_guard<std::mutex> lock(gTokenManagerLock); in deleteHalToken()
|
| /system/bt/vendor_libs/linux/interface/ |
| D | async_fd_watcher.cc | 43 std::unique_lock<std::mutex> guard(internal_mutex_); in WatchFdForNonBlockingReads()
56 std::unique_lock<std::mutex> guard(timeout_mutex_); in ConfigureTimeout()
96 std::unique_lock<std::mutex> guard(internal_mutex_); in stopThread()
101 std::unique_lock<std::mutex> guard(timeout_mutex_); in stopThread()
156 std::unique_lock<std::mutex> guard(timeout_mutex_); in ThreadRoutine()
175 std::unique_lock<std::mutex> guard(internal_mutex_); in ThreadRoutine()
|