diff options
Diffstat (limited to 'services/bufferhub/BufferNode.cpp')
-rw-r--r-- | services/bufferhub/BufferNode.cpp | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/services/bufferhub/BufferNode.cpp b/services/bufferhub/BufferNode.cpp index 4bad829210..cc87e15917 100644 --- a/services/bufferhub/BufferNode.cpp +++ b/services/bufferhub/BufferNode.cpp @@ -14,10 +14,10 @@ void BufferNode::InitializeMetadata() { // Using placement new here to reuse shared memory instead of new allocation // Initialize the atomic variables to zero. BufferHubDefs::MetadataHeader* metadata_header = metadata_.metadata_header(); - buffer_state_ = new (&metadata_header->buffer_state) std::atomic<uint64_t>(0); - fence_state_ = new (&metadata_header->fence_state) std::atomic<uint64_t>(0); + buffer_state_ = new (&metadata_header->buffer_state) std::atomic<uint32_t>(0); + fence_state_ = new (&metadata_header->fence_state) std::atomic<uint32_t>(0); active_clients_bit_mask_ = - new (&metadata_header->active_clients_bit_mask) std::atomic<uint64_t>(0); + new (&metadata_header->active_clients_bit_mask) std::atomic<uint32_t>(0); } // Allocates a new BufferNode. @@ -74,22 +74,22 @@ BufferNode::~BufferNode() { } } -uint64_t BufferNode::GetActiveClientsBitMask() const { +uint32_t BufferNode::GetActiveClientsBitMask() const { return active_clients_bit_mask_->load(std::memory_order_acquire); } -uint64_t BufferNode::AddNewActiveClientsBitToMask() { - uint64_t current_active_clients_bit_mask = GetActiveClientsBitMask(); - uint64_t client_state_mask = 0ULL; - uint64_t updated_active_clients_bit_mask = 0ULL; +uint32_t BufferNode::AddNewActiveClientsBitToMask() { + uint32_t current_active_clients_bit_mask = GetActiveClientsBitMask(); + uint32_t client_state_mask = 0U; + uint32_t updated_active_clients_bit_mask = 0U; do { client_state_mask = BufferHubDefs::FindNextAvailableClientStateMask(current_active_clients_bit_mask); - if (client_state_mask == 0ULL) { + if (client_state_mask == 0U) { ALOGE("%s: reached the maximum number of channels per buffer node: %d.", __FUNCTION__, BufferHubDefs::kMaxNumberOfClients); errno = E2BIG; - return 0ULL; + return 0U; } updated_active_clients_bit_mask = current_active_clients_bit_mask | client_state_mask; } while (!(active_clients_bit_mask_->compare_exchange_weak(current_active_clients_bit_mask, @@ -99,7 +99,7 @@ uint64_t BufferNode::AddNewActiveClientsBitToMask() { return client_state_mask; } -void BufferNode::RemoveClientsBitFromMask(const uint64_t& value) { +void BufferNode::RemoveClientsBitFromMask(const uint32_t& value) { active_clients_bit_mask_->fetch_and(~value); } |