Searched refs:active_clients_bit_mask_ (Results 1 – 5 of 5) sorted by relevance
96 active_clients_bit_mask_ = in InitializeBuffer()102 active_clients_bit_mask_->store(BufferHubDefs::kFirstClientBitMask, in InitializeBuffer()253 active_clients_bit_mask_->load(std::memory_order_acquire); in CreateConsumerStateMask()272 while (!active_clients_bit_mask_->compare_exchange_weak( in CreateConsumerStateMask()304 active_clients_bit_mask_->fetch_and(~consumer_state_mask, in RemoveConsumerClientMask()599 active_clients_bit_mask_->load(std::memory_order_acquire); in RemoveConsumer()602 while (!active_clients_bit_mask_->compare_exchange_weak( in RemoveConsumer()669 active_clients_bit_mask_->load(std::memory_order_acquire)) == 0U; in IsBufferReleasedByAllActiveClientsExceptForOrphans()
83 active_clients_bit_mask_->load(std::memory_order_acquire)) == 0; in is_released()138 std::atomic<uint32_t>* active_clients_bit_mask_ = nullptr; variable
178 active_clients_bit_mask_->load(std::memory_order_acquire)) && in LocalGain()202 active_clients_bit_mask_->load(std::memory_order_acquire)) && in LocalGain()227 active_clients_bit_mask_->load(std::memory_order_acquire); in LocalGain()
133 active_clients_bit_mask_ = &metadata_header_->activeClientsBitMask; in ImportBuffer()138 id(), active_clients_bit_mask_->load(std::memory_order_acquire)); in ImportBuffer()
84 std::atomic<uint32_t>* active_clients_bit_mask_ = nullptr; variable