Home
last modified time | relevance | path

Searched refs:myLock (Results 1 – 15 of 15) sorted by relevance

/third_party/grpc/src/csharp/Grpc.Core/Internal/
DAsyncCallBase.cs46 protected readonly object myLock = new object(); field in Grpc.Core.Internal.AsyncCallBase
77 lock (myLock) in Cancel()
94 lock (myLock) in CancelWithStatus()
107 lock (myLock) in InitializeInternal()
121 lock (myLock) in SendMessageInternalAsync()
145 lock (myLock) in ReadMessageInternalAsync()
253 lock (myLock) in HandleSendFinished()
306 lock (myLock) in HandleSendStatusFromServerFinished()
340 lock (myLock) in HandleReadFinished()
DAsyncCall.cs88 lock (myLock) in UnaryCall()
132 lock (myLock) in UnaryCall()
150 lock (myLock) in UnaryCallAsync()
192 lock (myLock) in ClientStreamingCallAsync()
228 lock (myLock) in StartServerStreamingCall()
268 lock (myLock) in StartDuplexStreamingCall()
318 lock (myLock) in SendCloseFromClientAsync()
372 lock (myLock) in GetStatus()
385 lock (myLock) in GetTrailers()
550 lock (myLock) in HandleUnaryResponse()
[all …]
DDefaultObjectPool.cs32 readonly object myLock = new object(); field in Grpc.Core.Internal.DefaultObjectPool
99 lock(myLock) in LeaseInternal()
150 lock (myLock) in Return()
179 lock (myLock) in Dispose()
DAsyncCallServer.cs67 lock (myLock) in ServerSideCallAsync()
101 lock (myLock) in SendInitialMetadataAsync()
137 lock (myLock) in SendStatusFromServerAsync()
213 lock (myLock) in HandleFinishedServerside()
DGrpcThreadPool.cs40 readonly object myLock = new object(); field in Grpc.Core.Internal.GrpcThreadPool
77 lock (myLock) in Start()
92 lock (myLock) in StopAsync()
/third_party/grpc/src/csharp/Grpc.Core/
DServer.cs46 readonly object myLock = new object(); field in Grpc.Core.Server
133 lock (myLock)
150 lock (myLock) in Start()
220 lock (myLock) in ShutdownInternalAsync()
265 lock (myLock) in AddServiceDefinitionInternal()
281 lock (myLock) in AddPortInternal()
321 lock (myLock) in CheckPortsBoundSuccessfully()
DChannel.cs37 readonly object myLock = new object(); field in Grpc.Core.Channel
154 lock (myLock) in TryWaitForStateChangedAsync()
216 lock (myLock) in ShutdownAsyncCore()
231 lock (myLock) in ShutdownAsyncCore()
298 lock (myLock) in GetConnectivityState()
/third_party/grpc/src/csharp/Grpc.IntegrationTesting/
DHistogram.cs40 readonly object myLock = new object(); field in Grpc.IntegrationTesting.Histogram
66 lock (myLock) in AddObservation()
77 lock (myLock) in GetSnapshot()
90 lock (myLock) in GetSnapshot()
DXdsInteropClient.cs308 private readonly object myLock = new object(); field in Grpc.IntegrationTesting.StatsWatcher
327 lock (myLock) in OnRpcComplete()
363 Monitor.Pulse(myLock); in OnRpcComplete()
370 lock (myLock) in Reset()
383 lock (myLock) in WaitForRpcStatsResponse()
397 if (!Monitor.Wait(myLock, timeoutMillis) || rpcsCompleted >= rpcsWanted) in WaitForRpcStatsResponse()
DTimeStats.cs40 readonly object myLock = new object(); field in Grpc.IntegrationTesting.TimeStats
54 lock (myLock) in GetSnapshot()
/third_party/boost/libs/thread/test/
Dtest_4648.cpp27 boost::upgrade_lock<boost::shared_mutex> myLock(pBoostThreadLocksTest->myMutex); in firstFunction() local
28 pBoostThreadLocksTest->secondFunction(pBoostThreadLocksTest, myLock); in firstFunction()
/third_party/mindspore/mindspore/ccsrc/minddata/dataset/util/
Dbtree_iterator.tpp294 RWLock *myLock = nullptr;
296 myLock = &this->rw_lock_;
298 myLock->LockShared();
300 IndexRc rc = Locate(myLock, false, root_, key, &leaf, &slot);
313 RWLock *myLock = nullptr;
315 myLock = &this->rw_lock_;
317 myLock->LockShared();
319 IndexRc rc = Locate(myLock, false, root_, key, &leaf, &slot);
Dbtree_impl.tpp375 RWLock *myLock = nullptr;
378 myLock = &top->rw_lock_;
383 myLock->LockExclusive();
385 myLock->LockShared();
388 myLock->LockShared();
401 if (myLock != nullptr) {
402 myLock->Unlock();
409 return Locate(myLock, forUpdate, FindBranch(inner, slot), key, ln, s);
505 RWLock *myLock = nullptr;
507 myLock = &this->rw_lock_;
[all …]
/third_party/grpc/examples/csharp/RouteGuide/RouteGuideServer/
DRouteGuideImpl.cs34 readonly object myLock = new object(); field in Routeguide.RouteGuideImpl
124 lock (myLock) in AddNoteForLocation()
/third_party/boost/libs/thread/doc/
Dexternal_locking.qbk220 strict_lock<BankAccount> myLock(myAccount); // ok
250 strict_lock<BankAccount> myLock(myAccount); // ok
251 strict_lock<BankAccount>* pAlias = &myLock; // error!
253 strict_lock<BankAccount>& rAlias = myLock; // ok