Searched refs:localSubscribeMapLock_ (Results 1 – 2 of 2) sorted by relevance
37 std::unique_lock<std::shared_mutex> lockGuard(localSubscribeMapLock_); in ClearLocalSubscribeQuery()62 std::unique_lock<std::shared_mutex> lockGuard(localSubscribeMapLock_); in ReserveLocalSubscribeQuery()71 std::unique_lock<std::shared_mutex> lockGuard(localSubscribeMapLock_); in ActiveLocalSubscribeQuery()87 std::unique_lock<std::shared_mutex> lockGuard(localSubscribeMapLock_); in DeleteLocalSubscribeQuery()103 std::unique_lock<std::shared_mutex> lockGuard(localSubscribeMapLock_); in PutLocalUnFinishedSubQueries()118 std::shared_lock<std::shared_mutex> lock(localSubscribeMapLock_); in GetAllUnFinishSubQueries()145 std::unique_lock<std::shared_mutex> lockGuard(localSubscribeMapLock_); in RemoveLocalSubscribeQuery()162 std::shared_lock<std::shared_mutex> lock(localSubscribeMapLock_); in GetLocalSubscribeQueries()206 std::shared_lock<std::shared_mutex> lock(localSubscribeMapLock_); in LocalSubscribeLimitCheck()
109 mutable std::shared_mutex localSubscribeMapLock_; variable