Searched refs:consumer_state_mask (Results 1 – 4 of 4) sorted by relevance
254 uint32_t consumer_state_mask = in CreateConsumerStateMask() local257 if (consumer_state_mask == 0U) { in CreateConsumerStateMask()263 current_active_clients_bit_mask | consumer_state_mask; in CreateConsumerStateMask()281 consumer_state_mask = BufferHubDefs::findNextAvailableClientStateMask( in CreateConsumerStateMask()283 if (consumer_state_mask == 0U) { in CreateConsumerStateMask()289 current_active_clients_bit_mask | consumer_state_mask; in CreateConsumerStateMask()292 return {consumer_state_mask}; in CreateConsumerStateMask()295 void ProducerChannel::RemoveConsumerClientMask(uint32_t consumer_state_mask) { in RemoveConsumerClientMask() argument299 buffer_state_->fetch_and(~consumer_state_mask, std::memory_order_release); in RemoveConsumerClientMask()300 fence_state_->fetch_and(~consumer_state_mask, std::memory_order_release); in RemoveConsumerClientMask()[all …]
99 uint64_t consumer_state_mask = status.get(); in RegisterNewBuffer() local102 consumer_state_mask); in RegisterNewBuffer()122 uint64_t consumer_state_mask = in OnConsumerQueueImportBuffers() local123 pending_buffer_slots_.front().consumer_state_mask; in OnConsumerQueueImportBuffers()134 producer_channel->CreateConsumer(message, consumer_state_mask); in OnConsumerQueueImportBuffers()
57 uint32_t consumer_state_mask);65 void OnConsumerOrphaned(const uint32_t& consumer_state_mask);113 void RemoveConsumerClientMask(uint32_t consumer_state_mask);
51 consumer_state_mask = mask; in PendingBuffer()57 uint64_t consumer_state_mask; member