Home
last modified time | relevance | path

Searched refs:mLock (Results 1 – 25 of 42) sorted by relevance

12

/system/netd/resolv/
DDnsTlsSocket.h57 bool initialize() EXCLUDES(mLock);
65 bool query(uint16_t id, const netdutils::Slice query) override EXCLUDES(mLock);
69 std::mutex mLock;
72 void loop() EXCLUDES(mLock);
73 std::unique_ptr<std::thread> mLoopThread GUARDED_BY(mLock);
78 netdutils::Status tcpConnect() REQUIRES(mLock);
82 bssl::UniquePtr<SSL> sslConnect(int fd) REQUIRES(mLock);
85 void sslDisconnect() REQUIRES(mLock);
88 bool sslWrite(const netdutils::Slice buffer) REQUIRES(mLock);
94 int sslRead(const netdutils::Slice buffer, bool wait) REQUIRES(mLock);
[all …]
DDnsTlsTransport.h53 std::future<Result> query(const netdutils::Slice query) EXCLUDES(mLock);
62 void onClosed() override EXCLUDES(mLock);
65 std::mutex mLock;
74 void doConnect() REQUIRES(mLock);
77 void doReconnect() EXCLUDES(mLock);
78 std::unique_ptr<std::thread> mReconnectThread GUARDED_BY(mLock);
81 bool mClosing GUARDED_BY(mLock) = false;
84 std::unique_ptr<IDnsTlsSocket> mSocket GUARDED_BY(mLock);
87 bool sendQuery(const DnsTlsQueryMap::Query q) REQUIRES(mLock);
DLockedQueue.h34 std::lock_guard guard(mLock); in push()
40 std::lock_guard guard(mLock); in swap()
45 std::mutex mLock;
46 std::deque<T> mQueue GUARDED_BY(mLock);
DDnsTlsSessionCache.h44 bssl::UniquePtr<SSL_SESSION> getSession() EXCLUDES(mLock);
50 std::mutex mLock; variable
51 void recordSession(SSL_SESSION* _Nullable session) EXCLUDES(mLock);
54 std::deque<bssl::UniquePtr<SSL_SESSION>> mSessions GUARDED_BY(mLock);
DDnsTlsQueryMap.cpp29 std::lock_guard guard(mLock); in recordQuery()
58 std::lock_guard guard(mLock); in markTried()
66 std::lock_guard guard(mLock); in cleanup()
105 std::lock_guard guard(mLock); in getAll()
114 std::lock_guard guard(mLock); in empty()
119 std::lock_guard guard(mLock); in clear()
133 std::lock_guard guard(mLock); in onResponse()
DDnsTlsQueryMap.h78 std::mutex mLock;
94 std::map<uint16_t, QueryPromise> mQueries GUARDED_BY(mLock);
97 int32_t getFreeId() REQUIRES(mLock);
DDnsTlsTransport.cpp34 std::lock_guard guard(mLock); in query()
87 std::lock_guard guard(mLock); in onClosed()
107 std::lock_guard guard(mLock); in doReconnect()
124 std::lock_guard guard(mLock); in ~DnsTlsTransport()
DDnsTlsSessionCache.cpp57 std::lock_guard guard(mLock); in recordSession()
66 std::lock_guard guard(mLock); in getSession()
Ddns_tls_test.cpp222 ~FakeSocketDelay() { std::lock_guard guard(mLock); } in ~FakeSocketDelay()
228 std::lock_guard guard(mLock); in query()
245 std::lock_guard guard(mLock); in sendResponses()
256 std::mutex mLock; member in android::net::FakeSocketDelay
258 std::set<uint16_t> mIds GUARDED_BY(mLock);
259 std::vector<bytevec> mResponses GUARDED_BY(mLock);
467 std::lock_guard guard(mLock); in ~FakeSocketLimited()
485 std::lock_guard guard(mLock); in query()
506 std::lock_guard guard(mLock); in sendClose()
517 std::mutex mLock; member in android::net::FakeSocketLimited
[all …]
/system/core/libutils/
DMutex_test.cpp21 static android::Mutex mLock; variable
22 static int i GUARDED_BY(mLock);
24 void modifyLockedVariable() REQUIRES(mLock) { in modifyLockedVariable()
29 android::Mutex::Autolock _l(mLock); in TEST()
35 if (mLock.tryLock() != 0) { in TEST()
38 mLock.unlock(); in TEST()
43 if (mLock.timedLock(1) != 0) { in TEST()
46 mLock.unlock(); in TEST()
DThreads.cpp644 mLock("Thread::mLock"), in Thread()
668 Mutex::Autolock _l(mLock); in run()
754 Mutex::Autolock _l(self->mLock); in _threadLoop()
780 Mutex::Autolock _l(mLock); in requestExit()
786 Mutex::Autolock _l(mLock); in requestExitAndWait()
799 mThreadExitedCondition.wait(mLock); in requestExitAndWait()
810 Mutex::Autolock _l(mLock); in join()
821 mThreadExitedCondition.wait(mLock); in join()
828 Mutex::Autolock _l(mLock); in isRunning()
836 Mutex::Autolock _l(mLock); in getTid()
[all …]
DLooper.cpp71 AutoMutex _l(mLock); in Looper()
243 mLock.lock(); in pollInner()
317 mLock.unlock(); in pollInner()
326 mLock.lock(); in pollInner()
337 mLock.unlock(); in pollInner()
449 AutoMutex _l(mLock); in addFd()
521 AutoMutex _l(mLock); in removeFd()
593 AutoMutex _l(mLock); in sendMessageAtTime()
624 AutoMutex _l(mLock); in removeMessages()
641 AutoMutex _l(mLock); in removeMessages()
/system/netd/server/
DTcpSocketMonitor.h90 const struct tcp_info *tcpinfo, uint32_t tcpinfoLen) REQUIRES(mLock);
93 std::mutex mLock; variable
100 milliseconds mNextSleepDurationMs GUARDED_BY(mLock);
102 time_point mLastPoll GUARDED_BY(mLock);
104 bool mIsSuspended GUARDED_BY(mLock);
106 bool mIsRunning GUARDED_BY(mLock);
110 std::unordered_map<uint64_t, SocketEntry> mSocketEntries GUARDED_BY(mLock);
114 std::unordered_map<uint32_t, TcpStats> mNetworkStats GUARDED_BY(mLock);
DTcpSocketMonitor.cpp104 std::lock_guard guard(mLock); in dump()
157 std::lock_guard guard(mLock); in setPollingInterval()
167 std::lock_guard guard(mLock); in resumePolling()
180 std::lock_guard guard(mLock); in suspendPolling()
192 std::lock_guard guard(mLock); in poll()
259 std::lock_guard guard(mLock); in waitForNextPoll()
264 std::unique_lock<std::mutex> ul(mLock); in waitForNextPoll()
273 std::lock_guard guard(mLock); in isRunning()
320 std::lock_guard guard(mLock); in TcpSocketMonitor()
336 std::lock_guard guard(mLock); in ~TcpSocketMonitor()
/system/core/libutils/include/utils/
DRWLock.h62 inline explicit AutoRLock(RWLock& rwlock) : mLock(rwlock) { mLock.readLock(); } in AutoRLock()
63 inline ~AutoRLock() { mLock.unlock(); } in ~AutoRLock()
65 RWLock& mLock;
70 inline explicit AutoWLock(RWLock& rwlock) : mLock(rwlock) { mLock.writeLock(); } in AutoWLock()
71 inline ~AutoWLock() { mLock.unlock(); } in ~AutoWLock()
73 RWLock& mLock;
DMutex.h132 inline explicit Autolock(Mutex& mutex) ACQUIRE(mutex) : mLock(mutex) { mLock.lock(); } in Autolock()
133 inline explicit Autolock(Mutex* mutex) ACQUIRE(mutex) : mLock(*mutex) { mLock.lock(); } in Autolock()
134 inline ~Autolock() RELEASE() { mLock.unlock(); } in RELEASE()
137 Mutex& mLock;
/system/tools/hidl/test/hidl_test/
DFooCallback.cpp22 : mLock{}, mCond{} { in FooCallback()
36 Mutex::Autolock lock(mLock); in heyItsYou()
52 Mutex::Autolock lock(mLock); in heyItsYouIsntIt()
68 Mutex::Autolock lock(mLock); in heyItsTheMeaningOfLife()
82 Mutex::Autolock lock(mLock); in reportResults()
91 ::android::status_t rc = mCond.waitRelative(mLock, leftToWaitNs); in reportResults()
115 Mutex::Autolock lock(mLock); in youBlockedMeFor()
/system/libhwbinder/
DBpHwBinder.cpp128 AutoMutex _l(mLock); in linkToDeath()
154 AutoMutex _l(mLock); in unlinkToDeath()
193 mLock.lock(); in sendObituary()
203 mLock.unlock(); in sendObituary()
239 AutoMutex _l(mLock); in attachObject()
246 AutoMutex _l(mLock); in findObject()
252 AutoMutex _l(mLock); in detachObject()
267 mLock.lock(); in ~BpHwBinder()
273 mLock.unlock(); in ~BpHwBinder()
DProcessState.cpp107 AutoMutex _l(mLock); in setContextObject()
113 mLock.lock(); in getContextObject()
116 mLock.unlock(); in getContextObject()
149 AutoMutex _l(mLock); in startThreadPool()
166 AutoMutex _l(mLock); in becomeContextManager()
269 AutoMutex _l(mLock); in getStrongProxyForHandle()
299 AutoMutex _l(mLock); in getWeakProxyForHandle()
328 AutoMutex _l(mLock); in expungeHandle()
378 AutoMutex _l(mLock); in setThreadPoolConfiguration()
DBinder.cpp68 Mutex mLock; member in android::hardware::BHwBinder::Extras
150 AutoMutex _l(e->mLock); in attachObject()
159 AutoMutex _l(e->mLock); in findObject()
168 AutoMutex _l(e->mLock); in detachObject()
DBufferedTextOutput.cpp165 AutoMutex _l(mLock); in print()
228 AutoMutex _l(mLock); in moveIndent()
236 AutoMutex _l(mLock); in pushBundle()
243 AutoMutex _l(mLock); in popBundle()
/system/core/libpixelflinger/codeflinger/
DCodeCache.cpp158 pthread_mutex_init(&mLock, 0); in CodeCache()
163 pthread_mutex_destroy(&mLock); in ~CodeCache()
168 pthread_mutex_lock(&mLock); in lookup()
176 pthread_mutex_unlock(&mLock); in lookup()
183 pthread_mutex_lock(&mLock); in cache()
211 pthread_mutex_unlock(&mLock); in cache()
/system/media/audio_utils/include/audio_utils/
DSimpleLog.h138 std::lock_guard<std::mutex> guard(mLock); in logs()
164 std::lock_guard<std::mutex> guard(mLock);
203 mutable std::mutex mLock;
DErrorLog.h71 std::lock_guard<std::mutex> guard(mLock); in log()
100 std::lock_guard<std::mutex> guard(mLock);
185 mutable std::mutex mLock; // monitor mutex
/system/libhidl/libhidlcache/
DMemoryDealer.cpp79 mutable Mutex mLock; member in android::hardware::SimpleBestFitAllocator
137 Lock lock(mLock); in allocate()
143 Lock lock(mLock); in deallocate()
248 Lock lock(mLock); in dump()
259 Lock lock(mLock); in dump()

12