Home
last modified time | relevance | path

Searched refs:mutex_ (Results 1 – 25 of 900) sorted by relevance

12345678910>>...36

/external/webrtc/modules/audio_coding/neteq/
Dneteq_impl.h216 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
223 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
235 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
247 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
253 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
261 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
267 bool play_dtmf) RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
273 bool play_dtmf) RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
275 bool DoCodecPlc() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
278 int DoExpand(bool play_dtmf) RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
[all …]
/external/icing/icing/
Dicing-search-engine.h107 InitializeResultProto Initialize() ICING_LOCKS_EXCLUDED(mutex_);
173 ICING_LOCKS_EXCLUDED(mutex_);
183 false) ICING_LOCKS_EXCLUDED(mutex_);
240 ICING_LOCKS_EXCLUDED(mutex_);
249 GetSchemaResultProto GetSchema() ICING_LOCKS_EXCLUDED(mutex_);
264 ICING_LOCKS_EXCLUDED(mutex_);
276 ICING_LOCKS_EXCLUDED(mutex_);
286 ICING_LOCKS_EXCLUDED(mutex_);
303 PutResultProto Put(DocumentProto&& document) ICING_LOCKS_EXCLUDED(mutex_);
311 ICING_LOCKS_EXCLUDED(mutex_);
[all …]
/external/pigweed/pw_stream/public/pw_stream/
Dmpsc_stream.h118 bool connected() const PW_LOCKS_EXCLUDED(mutex_);
121 size_t last_write() const PW_LOCKS_EXCLUDED(mutex_);
124 const duration& timeout() const PW_LOCKS_EXCLUDED(mutex_);
151 void SetTimeout(const duration& timeout) PW_LOCKS_EXCLUDED(mutex_);
164 void SetLimit(size_t limit) PW_LOCKS_EXCLUDED(mutex_);
169 void Close() PW_LOCKS_EXCLUDED(mutex_);
189 void CloseLocked() PW_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
191 mutable sync::Mutex mutex_; variable
192 MpscReader* reader_ PW_GUARDED_BY(mutex_) = nullptr;
193 size_t limit_ PW_GUARDED_BY(mutex_) = kUnlimited;
[all …]
/external/icing/icing/index/lite/
Dlite-index.h85 libtextclassifier3::Status Reset() ICING_LOCKS_EXCLUDED(mutex_);
89 void Warm() ICING_LOCKS_EXCLUDED(mutex_);
96 libtextclassifier3::Status PersistToDisk() ICING_LOCKS_EXCLUDED(mutex_);
100 ICING_LOCKS_EXCLUDED(mutex_);
122 ICING_LOCKS_EXCLUDED(mutex_) { in FindTermPrefixes()
123 absl_ports::shared_lock l(&mutex_); in FindTermPrefixes()
134 NamespaceId namespace_id) ICING_LOCKS_EXCLUDED(mutex_);
145 ICING_LOCKS_EXCLUDED(mutex_);
154 ICING_LOCKS_EXCLUDED(mutex_);
174 ICING_LOCKS_EXCLUDED(mutex_);
[all …]
/external/pigweed/pw_rpc/public/pw_rpc/internal/
Dfake_channel_output.h57 Status last_status() const PW_LOCKS_EXCLUDED(mutex_) { in last_status()
58 std::lock_guard lock(mutex_); in last_status()
72 const PW_LOCKS_EXCLUDED(mutex_) { in PW_LOCKS_EXCLUDED() argument
73 std::lock_guard lock(mutex_); in PW_LOCKS_EXCLUDED()
84 uint32_t method_id) const PW_LOCKS_EXCLUDED(mutex_) { in payloads()
85 std::lock_guard lock(mutex_); in payloads()
92 const PW_LOCKS_EXCLUDED(mutex_) { in PW_LOCKS_EXCLUDED() argument
93 std::lock_guard lock(mutex_); in PW_LOCKS_EXCLUDED()
106 uint32_t method_id) const PW_LOCKS_EXCLUDED(mutex_) { in total_payloads()
107 std::lock_guard lock(mutex_); in total_payloads()
[all …]
/external/webrtc/modules/desktop_capture/win/
Ddxgi_duplicator_controller.h165 bool Initialize() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
169 bool DoInitialize() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
173 void Deinitialize() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
177 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
180 void Setup(Context* context) RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
185 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
189 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
195 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
198 int64_t GetNumFramesCaptured() const RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
201 DesktopSize desktop_size() const RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
[all …]
/external/webrtc/modules/video_coding/
Dframe_buffer2.h122 int64_t FindNextFrame(Timestamp now) RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
124 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
126 void StartWaitForNextFrameOnQueue() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
127 void CancelCallback() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
132 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
136 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
143 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
145 void ClearFramesAndHistory() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
158 FrameMap frames_ RTC_GUARDED_BY(mutex_);
159 DecodedFramesHistory decoded_frames_history_ RTC_GUARDED_BY(mutex_);
[all …]
Djitter_buffer.h150 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
156 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
160 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
166 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
171 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
172 VCMFrameBuffer* NextFrame() const RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
177 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
181 bool HandleTooLargeNackList() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
183 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
188 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
[all …]
/external/webrtc/media/base/
Dvideo_adapter.h54 int* out_height) RTC_LOCKS_EXCLUDED(mutex_);
66 RTC_LOCKS_EXCLUDED(mutex_);
79 const absl::optional<int>& max_fps) RTC_LOCKS_EXCLUDED(mutex_);
90 const absl::optional<int>& max_fps) RTC_LOCKS_EXCLUDED(mutex_);
103 RTC_LOCKS_EXCLUDED(mutex_);
115 bool DropFrame(int64_t in_timestamp_ns) RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
117 int frames_in_ RTC_GUARDED_BY(mutex_); // Number of input frames.
118 int frames_out_ RTC_GUARDED_BY(mutex_); // Number of output frames.
119 int frames_scaled_ RTC_GUARDED_BY(mutex_); // Number of frames scaled.
121 RTC_GUARDED_BY(mutex_); // Number of changes in scale factor.
[all …]
Dfake_network_interface.h50 RTC_LOCKS_EXCLUDED(mutex_) { in SetConferenceMode()
51 webrtc::MutexLock lock(&mutex_); in SetConferenceMode()
56 int NumRtpBytes() RTC_LOCKS_EXCLUDED(mutex_) { in NumRtpBytes()
57 webrtc::MutexLock lock(&mutex_); in NumRtpBytes()
65 int NumRtpBytes(uint32_t ssrc) RTC_LOCKS_EXCLUDED(mutex_) { in NumRtpBytes()
66 webrtc::MutexLock lock(&mutex_); in NumRtpBytes()
72 int NumRtpPackets() RTC_LOCKS_EXCLUDED(mutex_) { in NumRtpPackets()
73 webrtc::MutexLock lock(&mutex_); in NumRtpPackets()
77 int NumRtpPackets(uint32_t ssrc) RTC_LOCKS_EXCLUDED(mutex_) { in NumRtpPackets()
78 webrtc::MutexLock lock(&mutex_); in NumRtpPackets()
[all …]
/external/webrtc/call/
Drtp_video_sender.h101 RTC_LOCKS_EXCLUDED(mutex_) override;
102 void Stop() RTC_LOCKS_EXCLUDED(mutex_) override;
103 bool IsActive() RTC_LOCKS_EXCLUDED(mutex_) override;
106 RTC_LOCKS_EXCLUDED(mutex_) override;
108 RTC_LOCKS_EXCLUDED(mutex_) override;
110 RTC_LOCKS_EXCLUDED(mutex_) override;
113 RTC_LOCKS_EXCLUDED(mutex_) override;
121 RTC_LOCKS_EXCLUDED(mutex_) override;
124 void SetFecAllowed(bool fec_allowed) RTC_LOCKS_EXCLUDED(mutex_) override;
131 RTC_LOCKS_EXCLUDED(mutex_) override;
[all …]
/external/sdv/vsomeip/third_party/boost/asio/include/boost/asio/detail/
Dconditionally_enabled_mutex.hpp44 : mutex_(m), in scoped_lock()
51 : mutex_(m) in scoped_lock()
55 mutex_.mutex_.lock(); in scoped_lock()
66 mutex_.mutex_.unlock(); in ~scoped_lock()
72 if (mutex_.enabled_ && !locked_) in lock()
74 mutex_.mutex_.lock(); in lock()
84 mutex_.unlock(); in unlock()
98 return mutex_.mutex_; in mutex()
103 conditionally_enabled_mutex& mutex_; member in boost::asio::detail::conditionally_enabled_mutex::scoped_lock
128 mutex_.lock(); in lock()
[all …]
/external/pigweed/pw_bluetooth_proxy/public/pw_bluetooth_proxy/internal/
Dl2cap_status_tracker.h38 PW_LOCKS_EXCLUDED(mutex_);
41 PW_LOCKS_EXCLUDED(mutex_);
48 PW_LOCKS_EXCLUDED(mutex_);
51 PW_LOCKS_EXCLUDED(mutex_);
54 PW_LOCKS_EXCLUDED(mutex_);
61 void DeliverPendingEvents() PW_LOCKS_EXCLUDED(mutex_);
65 PW_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
68 PW_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
71 PW_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
73 IntrusiveForwardList<L2capStatusDelegate> delegates_ PW_GUARDED_BY(mutex_);
[all …]
/external/grpc-grpc/src/core/lib/promise/
Dpromise_mutex.h38 if (mutex_ != nullptr) { in ~Lock()
39 GPR_ASSERT(mutex_->locked_); in ~Lock()
40 mutex_->locked_ = false; in ~Lock()
41 mutex_->waiter_.Wake(); in ~Lock()
46 : mutex_(std::exchange(other.mutex_, nullptr)) {} in Lock()
48 std::swap(mutex_, other.mutex_);
56 GPR_DEBUG_ASSERT(mutex_ != nullptr);
57 return &mutex_->value_;
60 GPR_DEBUG_ASSERT(mutex_ != nullptr);
61 return mutex_->value_;
[all …]
/external/webrtc/modules/audio_device/win/
Daudio_device_core_win.h61 virtual InitStatus Init() RTC_LOCKS_EXCLUDED(mutex_);
62 virtual int32_t Terminate() RTC_LOCKS_EXCLUDED(mutex_);
66 virtual int16_t PlayoutDevices() RTC_LOCKS_EXCLUDED(mutex_);
67 virtual int16_t RecordingDevices() RTC_LOCKS_EXCLUDED(mutex_);
71 RTC_LOCKS_EXCLUDED(mutex_);
75 RTC_LOCKS_EXCLUDED(mutex_);
78 virtual int32_t SetPlayoutDevice(uint16_t index) RTC_LOCKS_EXCLUDED(mutex_);
80 virtual int32_t SetRecordingDevice(uint16_t index) RTC_LOCKS_EXCLUDED(mutex_);
82 AudioDeviceModule::WindowsDeviceType device) RTC_LOCKS_EXCLUDED(mutex_);
86 virtual int32_t InitPlayout() RTC_LOCKS_EXCLUDED(mutex_);
[all …]
/external/webrtc/modules/video_coding/timing/
Dtiming.h121 TimeDelta RequiredDecodeTime() const RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
123 RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
124 TimeDelta TargetDelayInternal() const RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
125 bool UseLowLatencyRendering() const RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
128 mutable Mutex mutex_;
131 RTC_PT_GUARDED_BY(mutex_);
132 std::unique_ptr<CodecTimer> codec_timer_ RTC_GUARDED_BY(mutex_)
133 RTC_PT_GUARDED_BY(mutex_);
134 TimeDelta render_delay_ RTC_GUARDED_BY(mutex_);
140 TimeDelta min_playout_delay_ RTC_GUARDED_BY(mutex_);
[all …]
/external/leveldb/db/
Ddb_impl.h114 EXCLUSIVE_LOCKS_REQUIRED(mutex_);
119 void RemoveObsoleteFiles() EXCLUSIVE_LOCKS_REQUIRED(mutex_);
124 void CompactMemTable() EXCLUSIVE_LOCKS_REQUIRED(mutex_);
128 EXCLUSIVE_LOCKS_REQUIRED(mutex_);
131 EXCLUSIVE_LOCKS_REQUIRED(mutex_);
134 EXCLUSIVE_LOCKS_REQUIRED(mutex_);
136 EXCLUSIVE_LOCKS_REQUIRED(mutex_);
140 void MaybeScheduleCompaction() EXCLUSIVE_LOCKS_REQUIRED(mutex_);
143 void BackgroundCompaction() EXCLUSIVE_LOCKS_REQUIRED(mutex_);
145 EXCLUSIVE_LOCKS_REQUIRED(mutex_);
[all …]
/external/federated-compute/fcp/client/http/curl/
Dcurl_http_request_handle.h49 ABSL_LOCKS_EXCLUDED(mutex_);
52 ABSL_LOCKS_EXCLUDED(mutex_);
54 void MarkAsCompleted() ABSL_LOCKS_EXCLUDED(mutex_);
58 TotalSentReceivedBytes() const override ABSL_LOCKS_EXCLUDED(mutex_);
59 void Cancel() override ABSL_LOCKS_EXCLUDED(mutex_);
64 ABSL_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
68 ABSL_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
83 curl_off_t ulnow) ABSL_LOCKS_EXCLUDED(mutex_);
85 mutable absl::Mutex mutex_; variable
86 const std::unique_ptr<HttpRequest> request_ ABSL_GUARDED_BY(mutex_);
[all …]
/external/pigweed/pw_rpc/fuzz/public/pw_rpc/fuzz/
Dengine.h123 std::lock_guard lock(mutex_); in id()
128 std::lock_guard lock(mutex_); in pending()
142 std::lock_guard lock(mutex_);
161 std::lock_guard lock(mutex_);
175 void Await() PW_LOCKS_EXCLUDED(mutex_);
178 void Notify() PW_LOCKS_EXCLUDED(mutex_);
185 void Reset(Variant call = Variant()) PW_LOCKS_EXCLUDED(mutex_);
188 void Log() PW_LOCKS_EXCLUDED(mutex_);
195 sync::TimedMutex mutex_; variable
200 size_t id_ PW_GUARDED_BY(mutex_);
[all …]
/external/gflags/src/
Dmutex.h189 MutexType mutex_;
219 Mutex::Mutex() : mutex_(0) { } in Mutex()
220 Mutex::Mutex(Mutex::LinkerInitialized) : mutex_(0) { } in Mutex()
221 Mutex::~Mutex() { assert(mutex_ == 0); } in ~Mutex()
222 void Mutex::Lock() { assert(--mutex_ == -1); } in Lock()
223 void Mutex::Unlock() { assert(mutex_++ == -1); } in Unlock()
225 bool Mutex::TryLock() { if (mutex_) return false; Lock(); return true; } in TryLock()
227 void Mutex::ReaderLock() { assert(++mutex_ > 0); } in ReaderLock()
228 void Mutex::ReaderUnlock() { assert(mutex_-- > 0); } in ReaderUnlock()
233 InitializeCriticalSection(&mutex_); in Mutex()
[all …]
/external/webrtc/test/
Dfake_encoder.h42 void SetMaxBitrate(int max_kbps) RTC_LOCKS_EXCLUDED(mutex_);
43 void SetQp(int qp) RTC_LOCKS_EXCLUDED(mutex_);
49 RTC_LOCKS_EXCLUDED(mutex_) override;
52 RTC_LOCKS_EXCLUDED(mutex_) override;
54 RTC_LOCKS_EXCLUDED(mutex_) override;
57 RTC_LOCKS_EXCLUDED(mutex_) override;
60 int GetConfiguredInputFramerate() const RTC_LOCKS_EXCLUDED(mutex_);
61 int GetNumInitializations() const RTC_LOCKS_EXCLUDED(mutex_);
62 const VideoCodec& config() const RTC_LOCKS_EXCLUDED(mutex_);
86 int framerate) RTC_LOCKS_EXCLUDED(mutex_);
[all …]
/external/webrtc/rtc_base/
Dvirtual_socket_server.h130 void PostSignalReadEvent() RTC_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
134 webrtc::Mutex mutex_; variable
136 bool alive_ RTC_GUARDED_BY(mutex_) = true;
139 bool pending_read_signal_event_ RTC_GUARDED_BY(mutex_) = false;
148 PostedConnects posted_connects_ RTC_GUARDED_BY(mutex_);
151 std::list<std::unique_ptr<Packet>> recv_buffer_ RTC_GUARDED_BY(mutex_);
155 RTC_GUARDED_BY(mutex_);
238 void set_bandwidth(uint32_t bandwidth) RTC_LOCKS_EXCLUDED(mutex_);
242 void set_network_capacity(uint32_t capacity) RTC_LOCKS_EXCLUDED(mutex_);
245 uint32_t send_buffer_capacity() const RTC_LOCKS_EXCLUDED(mutex_);
[all …]
/external/icing/icing/result/
Dresult-state-manager.h81 ICING_LOCKS_EXCLUDED(mutex_);
97 int64_t current_time_ms) ICING_LOCKS_EXCLUDED(mutex_);
101 ICING_LOCKS_EXCLUDED(mutex_);
104 void InvalidateAllResultStates() ICING_LOCKS_EXCLUDED(mutex_);
109 absl_ports::shared_mutex mutex_;
125 ICING_GUARDED_BY(mutex_);
129 ICING_GUARDED_BY(mutex_);
134 std::unordered_set<uint64_t> invalidated_token_set_ ICING_GUARDED_BY(mutex_);
137 std::mt19937_64 random_generator_ ICING_GUARDED_BY(mutex_);
145 int64_t current_time_ms) ICING_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
[all …]
/external/pigweed/pw_stream/
Dmpsc_stream.cc40 std::lock_guard rlock(reader.mutex_); in CreateMpscStream()
42 std::lock_guard wlock(writer.mutex_); in CreateMpscStream()
60 other.mutex_.lock(); in operator =()
65 other.mutex_.unlock(); in operator =()
68 mutex_.lock(); in operator =()
73 mutex_.unlock(); in operator =()
78 std::lock_guard lock(reader->mutex_); in operator =()
98 std::lock_guard lock(mutex_); in connected()
103 std::lock_guard lock(mutex_); in last_write()
108 std::lock_guard lock(mutex_); in SetTimeout()
[all …]
/external/rust/android-crates-io/crates/grpcio-sys/grpc/third_party/re2/util/
Dmutex.h58 MutexType mutex_;
69 Mutex::Mutex() : mutex_(SRWLOCK_INIT) { } in Mutex()
71 void Mutex::Lock() { AcquireSRWLockExclusive(&mutex_); } in Lock()
72 void Mutex::Unlock() { ReleaseSRWLockExclusive(&mutex_); } in Unlock()
73 void Mutex::ReaderLock() { AcquireSRWLockShared(&mutex_); } in ReaderLock()
74 void Mutex::ReaderUnlock() { ReleaseSRWLockShared(&mutex_); } in ReaderUnlock()
83 Mutex::Mutex() { SAFE_PTHREAD(pthread_rwlock_init(&mutex_, NULL)); } in Mutex()
84 Mutex::~Mutex() { SAFE_PTHREAD(pthread_rwlock_destroy(&mutex_)); } in ~Mutex()
85 void Mutex::Lock() { SAFE_PTHREAD(pthread_rwlock_wrlock(&mutex_)); } in Lock()
86 void Mutex::Unlock() { SAFE_PTHREAD(pthread_rwlock_unlock(&mutex_)); } in Unlock()
[all …]

12345678910>>...36