| /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);
77 std::mutex mutex; variable
79 const NetworkController* mNetCtrl GUARDED_BY(mutex);
80 std::map<std::string, ClatdTracker> mClatdTrackers GUARDED_BY(mutex);
81 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
88 ret->list_mutex = new std::mutex; in reactor_new()
151 object->mutex = new std::mutex; in reactor_register()
162 delete object->mutex; in reactor_register()
188 std::lock_guard<std::mutex> lock(*object->mutex); in reactor_change_registration()
211 std::unique_lock<std::mutex> lock(*reactor->list_mutex); in reactor_unregister()
223 obj->mutex->lock(); in reactor_unregister()
224 obj->mutex->unlock(); in reactor_unregister()
225 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()
103 std::unique_lock<std::mutex> lock(tracker_lock); in allocation_tracker_notify_alloc()
137 std::unique_lock<std::mutex> lock(tracker_lock); in allocation_tracker_notify_free()
179 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/bt/stack/a2dp/ |
| D | a2dp_vendor_ldac_decoder.cc | 96 pthread_mutex_t mutex; member
128 pthread_mutex_init(&(a2dp_ldac_decoder_cb.mutex), NULL); in A2DP_VendorLoadDecoderLdac()
166 pthread_mutex_destroy(&(a2dp_ldac_decoder_cb.mutex)); in A2DP_VendorUnloadDecoderLdac()
183 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_init()
192 pthread_mutex_unlock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_init()
197 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_cleanup()
201 pthread_mutex_unlock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_cleanup()
205 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_decode_packet()
232 pthread_mutex_unlock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_decode_packet()
237 pthread_mutex_lock(&(a2dp_ldac_decoder_cb.mutex)); in a2dp_vendor_ldac_decoder_start()
[all …]
|
| /system/core/adb/fdevent/ |
| 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/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()
|
| /system/bt/gd/common/ |
| D | blocking_queue.h | 31 std::unique_lock<std::mutex> lock(mutex_); in push()
39 std::unique_lock<std::mutex> lock(mutex_); in take()
50 std::unique_lock<std::mutex> lock(mutex_); in wait_to_take()
60 std::unique_lock<std::mutex> lock(mutex_); in empty()
65 std::unique_lock<std::mutex> lock(mutex_); in clear()
72 mutable std::mutex mutex_;
|
| /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/bt/gd/hal/ |
| D | hci_hal_host_rootcanal.cc | 97 std::lock_guard<std::mutex> lock(api_mutex_); in registerIncomingPacketCallback()
100 std::lock_guard<std::mutex> incoming_packet_callback_lock(incoming_packet_callback_mutex_); in registerIncomingPacketCallback()
108 std::lock_guard<std::mutex> lock(api_mutex_); in unregisterIncomingPacketCallback()
111 std::lock_guard<std::mutex> incoming_packet_callback_lock(incoming_packet_callback_mutex_); in unregisterIncomingPacketCallback()
118 std::lock_guard<std::mutex> lock(api_mutex_); in sendHciCommand()
127 std::lock_guard<std::mutex> lock(api_mutex_); in sendAclData()
136 std::lock_guard<std::mutex> lock(api_mutex_); in sendScoData()
150 std::lock_guard<std::mutex> lock(api_mutex_); in Start()
163 std::lock_guard<std::mutex> lock(api_mutex_); in Stop()
175 std::lock_guard<std::mutex> incoming_packet_callback_lock(incoming_packet_callback_mutex_); in Stop()
[all …]
|
| /system/core/adb/client/pairing/tests/ |
| D | pairing_connection_test.cpp | 190 std::mutex server_mutex; in TEST_F()
192 std::unique_lock<std::mutex> server_lock(server_mutex); in TEST_F()
209 std::lock_guard<std::mutex> lock(server_mutex); in TEST_F()
216 std::mutex client_mutex; in TEST_F()
218 std::unique_lock<std::mutex> client_lock(client_mutex); in TEST_F()
235 std::lock_guard<std::mutex> lock(client_mutex); in TEST_F()
257 std::mutex server_mutex; in TEST_F()
259 std::unique_lock<std::mutex> server_lock(server_mutex); in TEST_F()
269 std::lock_guard<std::mutex> lock(server_mutex); in TEST_F()
277 std::mutex client_mutex; in TEST_F()
[all …]
|
| /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/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/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/main/shim/ |
| D | stack.cc | 51 std::lock_guard<std::mutex> lock(mutex_); in StartIdleMode()
63 std::lock_guard<std::mutex> lock(mutex_); in StartEverything()
110 std::lock_guard<std::mutex> lock(mutex_); in Stop()
130 std::lock_guard<std::mutex> lock(mutex_); in IsRunning()
135 std::lock_guard<std::mutex> lock(mutex_); in GetStackManager()
141 std::lock_guard<std::mutex> lock(mutex_); in GetBtm()
147 std::lock_guard<std::mutex> lock(mutex_); in GetHandler()
|
| /system/bt/vendor_libs/test_vendor_lib/model/setup/ |
| D | async_manager.cc | 99 std::unique_lock<std::mutex> guard(internal_mutex_); in WatchFdForNonBlockingReads()
117 std::unique_lock<std::mutex> guard(internal_mutex_); in StopWatchingFileDescriptor()
141 std::unique_lock<std::mutex> guard(internal_mutex_); in stopThread()
191 std::unique_lock<std::mutex> guard(internal_mutex_); in setUpFileDescriptorSet()
218 std::unique_lock<std::mutex> guard(internal_mutex_); in runAppropriateCallbacks()
259 std::mutex internal_mutex_;
289 std::unique_lock<std::mutex> guard(internal_mutex_); in CancelAsyncTask()
300 std::unique_lock<std::mutex> guard(internal_mutex_); in CancelAsyncTasksFromUser()
320 std::unique_lock<std::mutex> guard(internal_mutex_); in stopThread()
387 std::unique_lock<std::mutex> guard(internal_mutex_); in scheduleTask()
[all …]
|
| /system/core/adb/ |
| D | adb_utils.h | 68 std::mutex mutex; variable
75 std::unique_lock<std::mutex> lock(mutex); in Push()
86 std::unique_lock<std::mutex> lock(mutex); in PopAll()
|