| /third_party/grpc/src/cpp/thread_manager/ |
| D | thread_manager.cc | 66 grpc_core::MutexLock lock(&mu_); in ~ThreadManager()
76 grpc_core::MutexLock lock(&mu_); in Wait()
83 grpc_core::MutexLock lock(&mu_); in Shutdown()
88 grpc_core::MutexLock lock(&mu_); in IsShutdown()
93 grpc_core::MutexLock list_lock(&list_mu_); in GetMaxActiveThreadsSoFar()
99 grpc_core::MutexLock list_lock(&list_mu_); in MarkAsCompleted()
104 grpc_core::MutexLock lock(&mu_); in MarkAsCompleted()
120 grpc_core::MutexLock lock(&list_mu_); in CleanupCompletedThreads()
136 grpc_core::MutexLock lock(&mu_); in Initialize()
188 grpc_core::MutexLock failure_lock(&mu_); in MainWorkLoop()
|
| /third_party/grpc/src/core/lib/gprpp/ |
| D | sync.h | 46 using MutexLock = absl::MutexLock; variable
85 class ABSL_SCOPED_LOCKABLE MutexLock {
87 explicit MutexLock(Mutex* mu) ABSL_EXCLUSIVE_LOCK_FUNCTION(mu) : mu_(mu) {
90 ~MutexLock() ABSL_UNLOCK_FUNCTION() { mu_->Unlock(); }
92 MutexLock(const MutexLock&) = delete;
93 MutexLock& operator=(const MutexLock&) = delete;
181 MutexLockForGprMu(const MutexLock&) = delete;
182 MutexLockForGprMu& operator=(const MutexLock&) = delete;
|
| /third_party/re2/util/ |
| D | mutex.h | 90 class MutexLock {
92 explicit MutexLock(Mutex *mu) : mu_(mu) { mu_->Lock(); } in MutexLock() function
93 ~MutexLock() { mu_->Unlock(); } in ~MutexLock()
97 MutexLock(const MutexLock&) = delete;
98 MutexLock& operator=(const MutexLock&) = delete;
125 #define MutexLock(x) static_assert(false, "MutexLock declaration missing variable name") macro
|
| /third_party/skia/third_party/externals/swiftshader/src/Common/ |
| D | MutexLock.hpp | 27 class MutexLock class
30 MutexLock() in MutexLock() function in sw::MutexLock
35 ~MutexLock() in ~MutexLock()
172 using MutexLock = BackoffLock; typedef
180 explicit LockGuard(sw::MutexLock &mutex) : mutex(&mutex) in LockGuard()
185 explicit LockGuard(sw::MutexLock *mutex) : mutex(mutex) in LockGuard()
196 sw::MutexLock *mutex;
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | sync.h | 69 class MutexLock {
71 explicit MutexLock(Mutex* mu) : mu_(mu->get()) { in MutexLock() function
74 explicit MutexLock(gpr_mu* mu) : mu_(mu) { in MutexLock() function
77 ~MutexLock() { g_core_codegen_interface->gpr_mu_unlock(mu_); } in ~MutexLock()
79 MutexLock(const MutexLock&) = delete;
80 MutexLock& operator=(const MutexLock&) = delete;
|
| D | server_callback.h | 280 grpc::internal::MutexLock l(&stream_mu_); in StartSendInitialMetadata()
298 grpc::internal::MutexLock l(&stream_mu_); in StartRead()
327 grpc::internal::MutexLock l(&stream_mu_); in StartWrite()
356 grpc::internal::MutexLock l(&stream_mu_); in StartWriteAndFinish()
391 grpc::internal::MutexLock l(&stream_mu_); in Finish()
439 grpc::internal::MutexLock l(&stream_mu_); in InternalBindStream()
494 grpc::internal::MutexLock l(&reader_mu_); in StartSendInitialMetadata()
507 grpc::internal::MutexLock l(&reader_mu_); in StartRead()
520 grpc::internal::MutexLock l(&reader_mu_); in Finish()
543 grpc::internal::MutexLock l(&reader_mu_); in InternalBindReader()
[all …]
|
| /third_party/protobuf/src/google/protobuf/stubs/ |
| D | mutex.h | 116 class PROTOBUF_EXPORT MutexLock {
118 explicit MutexLock(Mutex *mu) : mu_(mu) { this->mu_->Lock(); } in MutexLock() function
119 ~MutexLock() { this->mu_->Unlock(); } in ~MutexLock()
122 GOOGLE_DISALLOW_EVIL_CONSTRUCTORS(MutexLock);
126 typedef MutexLock ReaderMutexLock;
127 typedef MutexLock WriterMutexLock;
173 using internal::MutexLock;
|
| /third_party/benchmark/src/ |
| D | mutex.h | 87 class SCOPED_CAPABILITY MutexLock {
91 MutexLock(Mutex& m) ACQUIRE(m) : ml_(m.native_handle()) {} in MutexLock() function
92 ~MutexLock() RELEASE() {} in RELEASE()
107 MutexLock ml(lock_); in wait()
115 MutexLock ml(lock_); in removeThread()
132 bool createBarrier(MutexLock& ml) REQUIRES(lock_) { in createBarrier()
|
| /third_party/json/benchmarks/thirdparty/benchmark/src/ |
| D | mutex.h | 87 class SCOPED_CAPABILITY MutexLock {
91 MutexLock(Mutex& m) ACQUIRE(m) : ml_(m.native_handle()) {} in MutexLock() function
92 ~MutexLock() RELEASE() {} in RELEASE()
107 MutexLock ml(lock_); in wait()
115 MutexLock ml(lock_); in removeThread()
132 bool createBarrier(MutexLock& ml) REQUIRES(lock_) { in createBarrier()
|
| /third_party/grpc/src/cpp/server/health/ |
| D | default_health_check_service.cc | 47 grpc_core::MutexLock lock(&mu_); in SetServingStatus()
57 grpc_core::MutexLock lock(&mu_); in SetServingStatus()
68 grpc_core::MutexLock lock(&mu_); in Shutdown()
82 grpc_core::MutexLock lock(&mu_); in GetServingStatus()
94 grpc_core::MutexLock lock(&mu_); in RegisterCallHandler()
104 grpc_core::MutexLock lock(&mu_); in UnregisterCallHandler()
172 grpc_core::MutexLock lock(&cq_shutdown_mu_); in ~HealthCheckServiceImpl()
275 grpc_core::MutexLock lock(&service->cq_shutdown_mu_); in CreateAndStart()
320 grpc_core::MutexLock lock(&service_->cq_shutdown_mu_); in OnCallReceived()
356 grpc_core::MutexLock lock(&service->cq_shutdown_mu_); in CreateAndStart()
[all …]
|
| /third_party/abseil-cpp/absl/flags/internal/ |
| D | flag.cc | 270 absl::MutexLock l(DataGuard()); in IsSpecifiedOnCommandLine()
275 absl::MutexLock l(DataGuard()); in DefaultValue()
285 absl::MutexLock l(guard); in CurrentValue()
306 absl::MutexLock l(DataGuard()); in SetCallback()
335 absl::MutexLock lock(&callback_->guard); in InvokeCallback()
340 absl::MutexLock l(DataGuard()); in SaveState()
365 absl::MutexLock l(DataGuard()); in RestoreState()
436 absl::MutexLock l(guard); in Read()
456 absl::MutexLock l(DataGuard()); in Write()
482 absl::MutexLock l(DataGuard()); in ParseFrom()
[all …]
|
| D | program_name.cc | 37 absl::MutexLock l(&program_name_guard); in ProgramInvocationName()
43 absl::MutexLock l(&program_name_guard); in ShortProgramInvocationName()
50 absl::MutexLock l(&program_name_guard); in SetProgramInvocationName()
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/ |
| D | mutex.h | 518 class ABSL_SCOPED_LOCKABLE MutexLock {
525 explicit MutexLock(Mutex *mu) ABSL_EXCLUSIVE_LOCK_FUNCTION(mu) : mu_(mu) { in MutexLock() function
532 explicit MutexLock(Mutex *mu, const Condition &cond) in MutexLock() function
538 MutexLock(const MutexLock &) = delete; // NOLINT(runtime/mutex)
539 MutexLock(MutexLock&&) = delete; // NOLINT(runtime/mutex)
540 MutexLock& operator=(const MutexLock&) = delete;
541 MutexLock& operator=(MutexLock&&) = delete;
543 ~MutexLock() ABSL_UNLOCK_FUNCTION() { this->mu_->Unlock(); } in ABSL_UNLOCK_FUNCTION()
|
| D | barrier_test.cc | 40 absl::MutexLock lock(&mutex); in TEST()
60 absl::MutexLock lock(&mutex); in TEST()
73 absl::MutexLock lock(&mutex); in TEST()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | init.cc | 132 grpc_core::MutexLock lock(g_init_mu); in grpc_init()
205 grpc_core::MutexLock lock(g_init_mu); in grpc_shutdown_internal()
216 grpc_core::MutexLock lock(g_init_mu); in grpc_shutdown()
245 grpc_core::MutexLock lock(g_init_mu); in grpc_shutdown_blocking()
255 grpc_core::MutexLock lock(g_init_mu); in grpc_is_initialized()
262 grpc_core::MutexLock lock(g_init_mu); in grpc_maybe_wait_for_async_shutdown()
|
| /third_party/abseil-cpp/absl/synchronization/ |
| D | mutex.h | 538 class ABSL_SCOPED_LOCKABLE MutexLock {
540 explicit MutexLock(Mutex *mu) ABSL_EXCLUSIVE_LOCK_FUNCTION(mu) : mu_(mu) { in MutexLock() function
544 MutexLock(const MutexLock &) = delete; // NOLINT(runtime/mutex)
545 MutexLock(MutexLock&&) = delete; // NOLINT(runtime/mutex)
546 MutexLock& operator=(const MutexLock&) = delete;
547 MutexLock& operator=(MutexLock&&) = delete;
549 ~MutexLock() ABSL_UNLOCK_FUNCTION() { this->mu_->Unlock(); } in ABSL_UNLOCK_FUNCTION()
|
| /third_party/grpc/src/cpp/server/ |
| D | external_connection_acceptor_impl.cc | 55 grpc_core::MutexLock lock(&mu_); in GetAcceptor()
64 grpc_core::MutexLock lock(&mu_); in HandleNewConnection()
79 grpc_core::MutexLock lock(&mu_); in Shutdown()
84 grpc_core::MutexLock lock(&mu_); in Start()
|
| D | dynamic_thread_pool.cc | 43 grpc_core::MutexLock lock(&pool_->mu_); in ThreadFunc()
85 grpc_core::MutexLock lock(&mu_); in DynamicThreadPool()
98 grpc_core::MutexLock lock(&mu_); in ~DynamicThreadPool()
108 grpc_core::MutexLock lock(&mu_); in Add()
|
| /third_party/grpc/src/core/ext/xds/ |
| D | xds_certificate_provider.cc | 269 MutexLock lock(&mu_); in ProvidesRootCerts()
278 MutexLock lock(&mu_); in UpdateRootCertNameAndDistributor()
294 MutexLock lock(&mu_); in ProvidesIdentityCerts()
303 MutexLock lock(&mu_); in UpdateIdentityCertNameAndDistributor()
319 MutexLock lock(&mu_); in GetRequireClientCertificate()
327 MutexLock lock(&mu_); in UpdateRequireClientCertificate()
335 MutexLock lock(&san_matchers_mu_); in GetSanMatchers()
343 MutexLock lock(&san_matchers_mu_); in UpdateSubjectAlternativeNameMatchers()
354 MutexLock lock(&mu_); in WatchStatusCallback()
|
| /third_party/skia/third_party/externals/abseil-cpp/absl/flags/internal/ |
| D | flag.cc | 278 absl::MutexLock l(DataGuard()); in IsSpecifiedOnCommandLine()
283 absl::MutexLock l(DataGuard()); in DefaultValue()
306 absl::MutexLock l(guard); in CurrentValue()
315 absl::MutexLock l(DataGuard()); in SetCallback()
344 absl::MutexLock lock(&callback_->guard); in InvokeCallback()
349 absl::MutexLock l(DataGuard()); in SaveState()
380 absl::MutexLock l(DataGuard()); in RestoreState()
461 absl::MutexLock l(guard); in Read()
500 absl::MutexLock l(DataGuard()); in Write()
526 absl::MutexLock l(DataGuard()); in ParseFrom()
[all …]
|
| D | program_name.cc | 37 absl::MutexLock l(&program_name_guard); in ProgramInvocationName()
43 absl::MutexLock l(&program_name_guard); in ShortProgramInvocationName()
50 absl::MutexLock l(&program_name_guard); in SetProgramInvocationName()
|
| /third_party/grpc/src/core/lib/security/security_connector/tls/ |
| D | tls_security_connector.h | 73 grpc_core::MutexLock lock(&mu_); in ClientHandshakerFactoryForTesting()
78 grpc_core::MutexLock lock(&mu_); in RootCertsForTesting()
83 grpc_core::MutexLock lock(&mu_); in KeyCertPairListForTesting()
167 grpc_core::MutexLock lock(&mu_); in ServerHandshakerFactoryForTesting()
172 grpc_core::MutexLock lock(&mu_); in RootCertsForTesting()
178 grpc_core::MutexLock lock(&mu_); in KeyCertPairListForTesting()
|
| /third_party/googletest/googlemock/src/ |
| D | gmock-spec-builders.cc | 213 MutexLock l(&mutex_); in CheckActionCountIfNotDone()
320 MutexLock l(&g_gmock_mutex); in RegisterOwner()
334 MutexLock l(&g_gmock_mutex); in SetOwnerAndName()
347 MutexLock l(&g_gmock_mutex); in MockObject()
364 MutexLock l(&g_gmock_mutex); in Name()
678 internal::MutexLock l(&internal::g_gmock_mutex); in SetReactionOnUninterestingCalls()
709 internal::MutexLock l(&internal::g_gmock_mutex); in UnregisterCallReaction()
718 internal::MutexLock l(&internal::g_gmock_mutex); in GetReactionOnUninterestingCalls()
728 internal::MutexLock l(&internal::g_gmock_mutex); in AllowLeak()
737 internal::MutexLock l(&internal::g_gmock_mutex); in VerifyAndClearExpectations()
[all …]
|
| /third_party/grpc/src/core/lib/channel/ |
| D | channelz.cc | 202 MutexLock lock(&child_mu_); in PopulateChildRefs()
230 MutexLock lock(&child_mu_); in AddChildChannel()
235 MutexLock lock(&child_mu_); in RemoveChildChannel()
240 MutexLock lock(&child_mu_); in AddChildSubchannel()
245 MutexLock lock(&child_mu_); in RemoveChildSubchannel()
259 MutexLock lock(&child_mu_); in AddChildSocket()
264 MutexLock lock(&child_mu_); in RemoveChildSocket()
269 MutexLock lock(&child_mu_); in AddChildListenSocket()
274 MutexLock lock(&child_mu_); in RemoveChildListenSocket()
286 MutexLock lock(&child_mu_); in RenderServerSockets()
[all …]
|
| /third_party/grpc/src/core/lib/security/credentials/tls/ |
| D | grpc_tls_certificate_distributor.cc | 31 grpc_core::MutexLock lock(&mu_); in SetKeyMaterials()
88 grpc_core::MutexLock lock(&mu_); in HasRootCerts()
96 grpc_core::MutexLock lock(&mu_); in HasKeyCertPairs()
106 grpc_core::MutexLock lock(&mu_); in SetErrorForCert()
156 grpc_core::MutexLock lock(&mu_); in SetError()
188 grpc_core::MutexLock lock(&mu_); in WatchTlsCertificates()
242 grpc_core::MutexLock lock(&callback_mu_); in WatchTlsCertificates()
272 grpc_core::MutexLock lock(&mu_); in CancelTlsCertificatesWatch()
307 grpc_core::MutexLock lock(&callback_mu_); in CancelTlsCertificatesWatch()
|