| /bionic/libc/private/ |
| ScopedPthreadMutexLocker.h | 26 explicit ScopedPthreadMutexLocker(pthread_mutex_t* mu) : mu_(mu) {
27 pthread_mutex_lock(mu_);
31 pthread_mutex_unlock(mu_);
35 pthread_mutex_t* mu_; member in class:ScopedPthreadMutexLocker
|
| /external/tensorflow/tensorflow/core/platform/default/ |
| mutex.h | 41 mutex() { nsync::nsync_mu_init(&mu_); }
46 void lock() EXCLUSIVE_LOCK_FUNCTION() { nsync::nsync_mu_lock(&mu_); }
48 return nsync::nsync_mu_trylock(&mu_) != 0;
50 void unlock() UNLOCK_FUNCTION() { nsync::nsync_mu_unlock(&mu_); }
52 void lock_shared() SHARED_LOCK_FUNCTION() { nsync::nsync_mu_rlock(&mu_); }
54 return nsync::nsync_mu_rtrylock(&mu_) != 0;
56 void unlock_shared() UNLOCK_FUNCTION() { nsync::nsync_mu_runlock(&mu_); }
60 nsync::nsync_mu mu_; member in class:tensorflow::mutex
68 explicit mutex_lock(mutex_type& mu) EXCLUSIVE_LOCK_FUNCTION(mu) : mu_(&mu) {
69 mu_->lock()
81 explicit mutex_lock(mutex_lock&& ml) noexcept : mu_(ml.mu_) { function in class:tensorflow::mutex_lock
94 mutex_type* mu_; member in class:tensorflow::mutex_lock
119 explicit tf_shared_lock(tf_shared_lock&& ml) noexcept : mu_(ml.mu_) { function in class:tensorflow::tf_shared_lock
132 mutex_type* mu_; member in class:tensorflow::tf_shared_lock
[all...] |
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| recent_request_ids.h | 61 mutex mu_; member in class:tensorflow::RecentRequestIds
65 int next_index_ GUARDED_BY(mu_) = 0; member in class:tensorflow::RecentRequestIds
66 std::vector<int64> circular_buffer_ GUARDED_BY(mu_);
67 gtl::FlatSet<int64> set_ GUARDED_BY(mu_);
|
| call_options.h | 68 mutex mu_; member in class:tensorflow::CallOptions
69 CancelFunction cancel_func_ GUARDED_BY(mu_);
72 int64 timeout_in_ms_ GUARDED_BY(mu_);
|
| call_options.cc | 25 mutex_lock l(mu_);
27 // NOTE: We must call the cancel_func_ with mu_ held. This ensure
35 mutex_lock l(mu_);
40 mutex_lock l(mu_);
45 mutex_lock l(mu_);
50 mutex_lock l(mu_);
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| now_seconds_env.h | 32 mutex_lock lock(mu_);
38 mutex_lock lock(mu_);
43 mutex mu_; member in class:tensorflow::NowSecondsEnv
|
| gcs_throttle.h | 113 mutex_lock l(mu_);
126 void UpdateState() EXCLUSIVE_LOCKS_REQUIRED(mu_);
132 mutex mu_; member in class:tensorflow::GcsThrottle
139 uint64 last_updated_secs_ GUARDED_BY(mu_) = 0; member in class:tensorflow::GcsThrottle
148 int64 available_tokens_ GUARDED_BY(mu_) = 0; member in class:tensorflow::GcsThrottle
151 GcsThrottleConfig config_ GUARDED_BY(mu_);
|
| google_auth_provider.h | 47 Status GetTokenFromFiles() EXCLUSIVE_LOCKS_REQUIRED(mu_);
50 Status GetTokenFromGce() EXCLUSIVE_LOCKS_REQUIRED(mu_);
53 Status GetTokenForTesting() EXCLUSIVE_LOCKS_REQUIRED(mu_);
58 mutex mu_; member in class:tensorflow::GoogleAuthProvider
59 string current_token_ GUARDED_BY(mu_);
60 uint64 expiration_timestamp_sec_ GUARDED_BY(mu_) = 0; member in class:tensorflow::GoogleAuthProvider
|
| file_block_cache.h | 91 void RemoveFile(const string& filename) LOCKS_EXCLUDED(mu_);
94 void Flush() LOCKS_EXCLUDED(mu_);
102 size_t CacheSize() const LOCKS_EXCLUDED(mu_);
144 /// the block-cache-wide mu_ instance variable. The state variable should only
148 /// In order to prevent deadlocks, never grab the block-cache-wide mu_ lock
150 /// mu_.
174 void Prune() LOCKS_EXCLUDED(mu_);
177 EXCLUSIVE_LOCKS_REQUIRED(mu_);
180 std::shared_ptr<Block> Lookup(const Key& key) LOCKS_EXCLUDED(mu_);
183 LOCKS_EXCLUDED(mu_);
206 mutable mutex mu_; member in class:tensorflow::FileBlockCache
223 size_t cache_size_ GUARDED_BY(mu_) = 0; member in class:tensorflow::FileBlockCache
[all...] |
| gcs_dns_cache.h | 45 mutex_lock l(mu_);
62 mutex mu_; member in class:tensorflow::GcsDnsCache
65 std::default_random_engine random_ GUARDED_BY(mu_);
66 bool started_ GUARDED_BY(mu_) = false; member in class:tensorflow::GcsDnsCache
67 bool cancelled_ GUARDED_BY(mu_) = false; member in class:tensorflow::GcsDnsCache
68 std::unique_ptr<Thread> worker_ GUARDED_BY(mu_); // After mutable vars.
72 std::vector<std::vector<string>> addresses_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/core/util/ |
| reffed_status_callback.h | 36 mutex_lock lock(mu_);
42 mutex_lock lock(mu_);
48 mutex_lock lock(mu_);
56 mutex mu_; member in class:tensorflow::ReffedStatusCallback
57 Status status_ GUARDED_BY(mu_);
|
| /external/protobuf/src/google/protobuf/stubs/ |
| mutex.h | 84 explicit MutexLock(Mutex *mu) : mu_(mu) { this->mu_->Lock(); }
85 ~MutexLock() { this->mu_->Unlock(); }
87 Mutex *const mu_; member in class:google::protobuf::internal::MutexLock
99 mu_(mu) { if (this->mu_ != NULL) { this->mu_->Lock(); } }
100 ~MutexLockMaybe() { if (this->mu_ != NULL) { this->mu_->Unlock(); } }
102 Mutex *const mu_; member in class:google::protobuf::internal::MutexLockMaybe
[all...] |
| /prebuilts/tools/darwin-x86_64/protoc/include/google/protobuf/stubs/ |
| mutex.h | 84 explicit MutexLock(Mutex *mu) : mu_(mu) { this->mu_->Lock(); }
85 ~MutexLock() { this->mu_->Unlock(); }
87 Mutex *const mu_; member in class:google::protobuf::internal::MutexLock
99 mu_(mu) { if (this->mu_ != NULL) { this->mu_->Lock(); } }
100 ~MutexLockMaybe() { if (this->mu_ != NULL) { this->mu_->Unlock(); } }
102 Mutex *const mu_; member in class:google::protobuf::internal::MutexLockMaybe
[all...] |
| /external/tensorflow/tensorflow/core/common_runtime/ |
| costmodel_manager.h | 38 mutex_lock l(mu_);
49 mutex mu_; member in class:tensorflow::CostModelManager
50 CostModelMap cost_models_ GUARDED_BY(mu_);
|
| /external/valgrind/drd/tests/ |
| tsan_thread_wrappers_pthread.h | 113 CHECK(0 == pthread_spin_init(&mu_, 0));
114 ANNOTATE_RWLOCK_CREATE((void*)&mu_);
117 ANNOTATE_RWLOCK_DESTROY((void*)&mu_);
118 CHECK(0 == pthread_spin_destroy(&mu_));
121 CHECK(0 == pthread_spin_lock(&mu_));
122 ANNOTATE_RWLOCK_ACQUIRED((void*)&mu_, 1);
125 ANNOTATE_RWLOCK_RELEASED((void*)&mu_, 1);
126 CHECK(0 == pthread_spin_unlock(&mu_));
129 pthread_spinlock_t mu_; member in class:SpinLock
137 SpinLock() : mu_(OS_SPINLOCK_INIT)
152 OSSpinLock mu_; member in class:SpinLock
256 pthread_mutex_t mu_; member in class:Mutex
271 Mutex *mu_; member in class:MutexLock
309 pthread_rwlock_t mu_; member in class:RWLock
322 RWLock *mu_; member in class:ReaderLockScoped
335 RWLock *mu_; member in class:WriterLockScoped
413 Mutex mu_; member in class:ProducerConsumerQueue
586 Mutex mu_; member in class:BlockingCounter
[all...] |
| /external/tensorflow/tensorflow/core/framework/ |
| cancellation.cc | 33 mutex_lock l(mu_);
40 // We call these callbacks without holding mu_, so that concurrent
49 mutex_lock l(mu_);
57 mutex_lock l(mu_);
63 mutex_lock l(mu_);
73 mu_.lock();
75 mu_.unlock();
78 mu_.unlock();
87 mu_.unlock();
|
| resource_op_kernel.h | 67 void Compute(OpKernelContext* context) override LOCKS_EXCLUDED(mu_) {
68 mutex_lock l(mu_);
77 [this](T** ret) EXCLUSIVE_LOCKS_REQUIRED(mu_) {
102 context->set_output_ref(0, &mu_, handle_.AccessTensor(context));
108 mutex mu_; member in class:tensorflow::ResourceOpKernel
109 ContainerInfo cinfo_ GUARDED_BY(mu_);
110 T* resource_ GUARDED_BY(mu_) = nullptr; member in class:tensorflow::ResourceOpKernel
115 virtual Status CreateResource(T** resource) EXCLUSIVE_LOCKS_REQUIRED(mu_) = 0; member in class:tensorflow::ResourceOpKernel
124 PersistentTensor handle_ GUARDED_BY(mu_);
|
| tracking_allocator.h | 96 bool UnRef() EXCLUSIVE_LOCKS_REQUIRED(mu_);
99 mutex mu_; member in class:tensorflow::TrackingAllocator
103 int ref_ GUARDED_BY(mu_);
107 size_t allocated_ GUARDED_BY(mu_);
111 size_t high_watermark_ GUARDED_BY(mu_);
116 size_t total_bytes_ GUARDED_BY(mu_);
118 gtl::InlinedVector<AllocRecord, 4> allocations_ GUARDED_BY(mu_);
128 std::unordered_map<const void*, Chunk> in_use_ GUARDED_BY(mu_);
129 int64 next_allocation_id_ GUARDED_BY(mu_);
|
| cancellation.h | 75 // mutex mu_;
81 // mutex_lock(mu_);
89 // // holding `mu_`, before `callback` is invoked.
99 // mutex_lock(mu_);
129 mutex mu_; member in class:tensorflow::CancellationManager
131 CancellationToken next_cancellation_token_ GUARDED_BY(mu_);
132 gtl::FlatMap<CancellationToken, CancelCallback> callbacks_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/core/kernels/ |
| record_yielder.h | 109 mutex mu_; member in class:tensorflow::RecordYielder
112 bool stop_ GUARDED_BY(mu_) = false; member in class:tensorflow::RecordYielder
113 Status status_ GUARDED_BY(mu_);
116 std::mt19937_64 rnd_ GUARDED_BY(mu_);
119 std::vector<string> buf_ GUARDED_BY(mu_);
132 bool BufEmpty() const SHARED_LOCKS_REQUIRED(mu_) {
137 bool BufNotFull() const SHARED_LOCKS_REQUIRED(mu_) {
142 bool BufEnough() const SHARED_LOCKS_REQUIRED(mu_) {
|
| /external/tensorflow/tensorflow/core/common_runtime/gpu/ |
| gpu_allocator_retry_test.cc | 40 mutex_lock l(mu_);
52 mutex_lock l(mu_);
60 mutex mu_; member in namespace:tensorflow::__anon39482
61 size_t memory_capacity_ GUARDED_BY(mu_);
80 mutex_lock l(mu_);
94 mutex_lock l(mu_);
103 void IncrementTurn() EXCLUSIVE_LOCKS_REQUIRED(mu_) {
112 mutex mu_; member in class:tensorflow::AlternatingBarrier
115 int next_turn_ GUARDED_BY(mu_);
116 std::vector<bool> done_ GUARDED_BY(mu_);
176 mutex mu_; member in class:tensorflow::GPUAllocatorRetryTest
177 bool has_failed_ GUARDED_BY(mu_) = false; member in class:tensorflow::GPUAllocatorRetryTest
178 int count_ GUARDED_BY(mu_) = 0; member in class:tensorflow::GPUAllocatorRetryTest
[all...] |
| process_state.h | 120 mutex mu_; member in class:tensorflow::ProcessState
122 std::vector<Allocator*> cpu_allocators_ GUARDED_BY(mu_);
123 std::vector<VisitableAllocator*> gpu_allocators_ GUARDED_BY(mu_);
124 std::vector<std::vector<AllocVisitor>> gpu_visitors_ GUARDED_BY(mu_);
125 std::vector<Allocator*> cuda_host_allocators_ GUARDED_BY(mu_);
132 std::vector<Allocator*> cpu_al_ GUARDED_BY(mu_);
133 std::vector<Allocator*> gpu_al_ GUARDED_BY(mu_);
134 std::vector<Allocator*> cuda_al_ GUARDED_BY(mu_);
142 : mm_(mm), a_(a), md_(md), mu_(mu) {}
147 mutex_lock l(*mu_); variable
152 mutex_lock l(*mu_); variable
165 mutex* mu_; member in class:tensorflow::internal::RecordingAllocator
[all...] |
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| fake_clock_env.h | 59 mutex mu_; member in class:tensorflow::serving::test_util::FakeClockEnv
61 uint64 current_time_ GUARDED_BY(mu_) = 0; member in class:tensorflow::serving::test_util::FakeClockEnv
67 std::vector<SleepingThread> sleeping_threads_ GUARDED_BY(mu_);
|
| /external/tensorflow/tensorflow/stream_executor/host/ |
| host_stream.cc | 33 mutex_lock lock(mu_);
39 mutex_lock lock(mu_);
48 mutex_lock lock(mu_);
|
| /external/tensorflow/tensorflow/core/lib/core/ |
| blocking_counter.h | 42 mutex_lock l(mu_);
51 mutex_lock l(mu_);
61 mutex_lock l(mu_);
72 mutex mu_; member in class:tensorflow::BlockingCounter
|
