Searched refs:events_mutex_ (Results 1 – 9 of 9) sorted by relevance
246 ABSL_LOCKS_EXCLUDED(events_mutex_);252 ABSL_EXCLUSIVE_LOCKS_REQUIRED(events_mutex_);257 void DeleteEvent(EventId id) ABSL_LOCKS_EXCLUDED(events_mutex_);262 ABSL_LOCKS_EXCLUDED(events_mutex_);265 ABSL_LOCKS_EXCLUDED(events_mutex_);298 absl::Mutex events_mutex_; member in tpu_driver::__anonbd0c70900111::GrpcTpuStream300 ABSL_GUARDED_BY(events_mutex_);476 absl::MutexLock lock(&events_mutex_); in ~GrpcTpuStream()511 absl::MutexLock lock(&events_mutex_); in InitializeRequest()553 absl::MutexLock lock(&events_mutex_); in DeleteEvent()[all …]
123 std::lock_guard<std::mutex> its_lock(events_mutex_); in get_events()128 std::lock_guard<std::mutex> its_lock(events_mutex_); in add_event()161 std::lock_guard<std::mutex> its_lock(events_mutex_); in remove_event()282 std::lock_guard<std::mutex> its_lock(events_mutex_); in update_remote_subscription()403 std::lock_guard<std::mutex> its_lock(events_mutex_); in is_selective()428 std::lock_guard<std::mutex> its_lock(events_mutex_); in send_initial_events()
102 std::lock_guard<std::mutex> its_lock(events_mutex_); in offer_service()126 std::lock_guard<std::mutex> its_lock(events_mutex_); in stop_offer_service()470 std::lock_guard<std::mutex> its_lock(events_mutex_); in register_event()479 std::lock_guard<std::mutex> its_lock(events_mutex_); in unregister_event()534 std::lock_guard<std::mutex> its_lock(events_mutex_); in find_events()660 std::lock_guard<std::mutex> its_guard(events_mutex_); in unsubscribe_all()1087 std::lock_guard<std::mutex> its_lock(events_mutex_); in find_event()1407 std::lock_guard<std::mutex> its_lock(events_mutex_); in get_subscriptions()
2237 std::lock_guard<std::mutex> its_lock(events_mutex_); in on_stop_offer_service()
2189 std::lock_guard<std::mutex> its_lock(events_mutex_); in is_field()
175 std::lock_guard<std::mutex> g(events_mutex_); in free()270 std::lock_guard<std::mutex> g(events_mutex_); in process_events()288 std::lock_guard<std::mutex> g(events_mutex_); in process_events()349 alignas(64) std::mutex events_mutex_; member
161 std::lock_guard<std::mutex> its_lock(events_mutex_); in on_message()267 std::unique_lock<std::mutex> its_events_lock(events_mutex_); in run()338 std::mutex events_mutex_; member in subscribe_notify_test_one_event_two_eventgroups_client
131 mutable std::mutex events_mutex_; member in vsomeip_v3::eventgroupinfo
259 mutable std::mutex events_mutex_; member in vsomeip_v3::routing_manager_base