Searched refs:impl_ (Results 1 – 8 of 8) sorted by relevance
| /thrift-3.4.0/lib/cpp/src/thrift/concurrency/ |
| D | Mutex.cpp | 38 Mutex::Mutex() : impl_(new Mutex::impl()) { in Mutex()
42 return impl_.get(); in getUnderlyingImpl()
46 impl_->lock(); in lock()
50 return impl_->try_lock(); in trylock()
54 return impl_->try_lock_for(std::chrono::milliseconds(ms)); in timedlock()
58 impl_->unlock(); in unlock()
|
| D | Monitor.cpp | 137 Monitor::Monitor() : impl_(new Monitor::Impl()) { in Monitor()
139 Monitor::Monitor(Mutex* mutex) : impl_(new Monitor::Impl(mutex)) { in Monitor()
141 Monitor::Monitor(Monitor* monitor) : impl_(new Monitor::Impl(monitor)) { in Monitor()
145 delete impl_; in ~Monitor()
149 return const_cast<Monitor::Impl*>(impl_)->mutex(); in mutex()
153 const_cast<Monitor::Impl*>(impl_)->lock(); in lock()
157 const_cast<Monitor::Impl*>(impl_)->unlock(); in unlock()
161 const_cast<Monitor::Impl*>(impl_)->wait(timeout); in wait()
165 return const_cast<Monitor::Impl*>(impl_)->waitForTime(abstime); in waitForTime()
169 return const_cast<Monitor::Impl*>(impl_)->waitForTimeRelative(timeout); in waitForTimeRelative()
[all …]
|
| D | Mutex.h | 54 std::shared_ptr<impl> impl_; variable
|
| D | Monitor.h | 112 Impl* impl_; variable
|
| /thrift-3.4.0/lib/cpp/src/thrift/transport/ |
| D | TPipeServer.cpp | 157 if (impl_) in getNativeWaitHandle()
158 return impl_->getNativeWaitHandle(); in getNativeWaitHandle()
195 impl_.reset(new TAnonPipeServer); in TPipeServer()
200 impl_.reset(new TAnonPipeServer); in TPipeServer()
207 return (impl_->getPipeHandle() != INVALID_HANDLE_VALUE); in isOpen()
216 impl_.reset(new TNamedPipeServer(pipename_, bufsize_, maxconns_, securityDescriptor_)); in listen()
220 return impl_->acceptImpl(); in acceptImpl()
344 if (impl_) in interrupt()
345 impl_->interrupt(); in interrupt()
349 impl_.reset(); in close()
[all …]
|
| D | TPipe.cpp | 226 : impl_(new TWaitableNamedPipeImpl(Pipe)), TimeoutSeconds_(3), in TPipe()
234 impl_.reset(new TWaitableNamedPipeImpl(pipeHandle)); in TPipe()
248 : impl_(new TAnonPipeImpl(PipeRd, PipeWrt)), TimeoutSeconds_(3), isAnonymous_(true), in TPipe()
263 return impl_.get() != nullptr; in isOpen()
299 impl_.reset(new TNamedPipeImpl(hPipe)); in open()
303 impl_.reset(); in close()
310 return impl_->read(buf, len); in read()
330 impl_->write(buf, len); in write()
361 if (impl_) in getPipeHandle()
362 return impl_->getPipeHandle(); in getPipeHandle()
[all …]
|
| D | TPipeServer.h | 97 std::shared_ptr<TPipeServerImpl> impl_;
|
| D | TPipe.h | 98 std::shared_ptr<TPipeImpl> impl_;
|
