| /thrift-3.4.0/lib/cpp/src/thrift/concurrency/ |
| D | Mutex.h | 60 Guard(const Mutex& value, int64_t timeout = 0) : mutex_(&value) {
65 mutex_ = nullptr;
69 mutex_ = nullptr;
74 if (mutex_) { in ~Guard()
75 mutex_->unlock(); in ~Guard()
79 operator bool() const { return (mutex_ != nullptr); }
82 const Mutex* mutex_;
|
| D | Monitor.cpp | 44 …Impl() : ownedMutex_(new Mutex()), conditionVariable_(), mutex_(nullptr) { init(ownedMutex_.get())… in Impl()
46 Impl(Mutex* mutex) : ownedMutex_(), conditionVariable_(), mutex_(nullptr) { init(mutex); } in Impl()
48 Impl(Monitor* monitor) : ownedMutex_(), conditionVariable_(), mutex_(nullptr) { in Impl()
52 Mutex& mutex() { return *mutex_; } in mutex()
53 void lock() { mutex_->lock(); } in lock()
54 void unlock() { mutex_->unlock(); } in unlock()
83 assert(mutex_); in waitForTimeRelative()
84 auto* mutexImpl = static_cast<std::timed_mutex*>(mutex_->getUnderlyingImpl()); in waitForTimeRelative()
99 assert(mutex_); in waitForTime()
100 auto* mutexImpl = static_cast<std::timed_mutex*>(mutex_->getUnderlyingImpl()); in waitForTime()
[all …]
|
| D | ThreadManager.cpp | 63 monitor_(&mutex_), in Impl()
64 maxMonitor_(&mutex_), in Impl()
65 workerMonitor_(&mutex_) {} in Impl()
75 Guard g(mutex_); in threadFactory()
80 Guard g(mutex_); in threadFactory()
94 Guard g(mutex_); in workerCount()
99 Guard g(mutex_); in pendingTaskCount()
104 Guard g(mutex_); in totalTaskCount()
109 Guard g(mutex_); in pendingTaskCountMax()
114 Guard g(mutex_); in expiredTaskCount()
[all …]
|
| /thrift-3.4.0/lib/d/src/thrift/util/ |
| D | awaitable.d | 84 mutex_ = new Mutex; in this()
85 condition_ = new Condition(mutex_); in this()
89 synchronized (mutex_) { in wait()
95 synchronized (mutex_) { in wait()
103 mutex_.lock(); in addCallback()
104 scope (failure) mutex_.unlock(); in addCallback()
109 mutex_.unlock(); in addCallback()
114 mutex_.unlock(); in addCallback()
118 synchronized (mutex_) { in removeCallback()
132 synchronized (mutex_) { in trigger()
[all …]
|
| /thrift-3.4.0/lib/cpp/test/processor/ |
| D | Handlers.h | 33 : triggerMonitor(&mutex_), generation_(0), wait_(false), log_(log) {} in ParentHandler()
36 concurrency::Guard g(mutex_); in incrementGeneration()
42 concurrency::Guard g(mutex_); in getGeneration()
48 concurrency::Guard g(mutex_); in addString()
54 concurrency::Guard g(mutex_); in getStrings()
60 concurrency::Guard g(mutex_); in getDataWait()
69 concurrency::Guard g(mutex_); in onewayWait()
76 concurrency::Guard g(mutex_); in exceptionWait()
87 concurrency::Guard g(mutex_); in unexpectedExceptionWait()
105 concurrency::Guard g(mutex_); in prepareTriggeredCall()
[all …]
|
| /thrift-3.4.0/lib/cpp/test/ |
| D | TNonblockingServerTest.cpp | 83 Mutex mutex_; member
87 listenHandler.reset(new ListenEventHandler(&mutex_)); in Runner()
98 Guard g(mutex_); in readyBarrier()
|
| D | TServerIntegrationTest.cpp | 109 Guard g(mutex_); in incrementGeneration()
114 Guard g(mutex_); in getGeneration()
119 Guard g(mutex_); in addString()
124 Guard g(mutex_); in getStrings()
140 Mutex mutex_; member in ParentHandler
|
| D | TNonblockingSSLServerTest.cpp | 155 Mutex mutex_; member
158 listenHandler.reset(new ListenEventHandler(&mutex_)); in Runner()
170 Guard g(mutex_); in readyBarrier()
|
| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | TFileTransport.cpp | 82 notFull_(&mutex_), in TFileTransport()
83 notEmpty_(&mutex_), in TFileTransport()
85 flushed_(&mutex_), in TFileTransport()
232 Guard g(mutex_); in enqueueEvent()
268 Guard g(mutex_); in swapEventBuffers()
468 Guard g(mutex_); in writerThread()
510 Guard g(mutex_); in writerThread()
527 Guard g(mutex_); in flush()
|
| D | TSSLSocket.h | 328 static concurrency::Mutex mutex_; variable
|
| D | TSSLSocket.cpp | 874 Mutex TSSLSocketFactory::mutex_; member in apache::thrift::transport::TSSLSocketFactory
878 Guard guard(mutex_); in TSSLSocketFactory()
890 Guard guard(mutex_); in ~TSSLSocketFactory()
|
| D | TFileTransport.h | 356 Mutex mutex_; variable
|
| /thrift-3.4.0/contrib/fb303/ |
| D | TClientInfo.h | 62 Mutex mutex_; variable
87 Guard g(mutex_); in expand()
|
| /thrift-3.4.0/lib/d/test/ |
| D | transport_test.d | 713 mutex_ = new Mutex; in this()
714 cancelCondition_ = new Condition(mutex_); in this()
720 synchronized (mutex_) { in ~this()
730 synchronized (mutex_) { in add()
754 synchronized (mutex_) { in timerThread()
800 Mutex mutex_; member
|
