2 * Copyright (C) 2016 The Android Open Source Project
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
19 #include <audio_utils/fifo_index.h>
20 #include <audio_utils/futex.h>
22 // These are not implemented within <audio_utils/fifo_index.h>
23 // so that we don't expose futex.
25 uint32_t audio_utils_fifo_index::loadAcquire()
27 return atomic_load_explicit(&mIndex, std::memory_order_acquire);
30 void audio_utils_fifo_index::storeRelease(uint32_t value)
32 atomic_store_explicit(&mIndex, value, std::memory_order_release);
35 int audio_utils_fifo_index::wait(int op, uint32_t expected, const struct timespec *timeout)
37 return sys_futex(&mIndex, op, expected, timeout, NULL, 0);
40 int audio_utils_fifo_index::wake(int op, int waiters)
42 return sys_futex(&mIndex, op, waiters, NULL, NULL, 0);
45 uint32_t audio_utils_fifo_index::loadConsume()
47 return atomic_load_explicit(&mIndex, std::memory_order_consume);
52 RefIndexDeferredStoreReleaseDeferredWake::RefIndexDeferredStoreReleaseDeferredWake(
53 audio_utils_fifo_index& index)
54 : mIndex(index), mValue(0), mWriteback(false), mWaiters(0), mWakeOp(FUTEX_WAIT_PRIVATE)
58 RefIndexDeferredStoreReleaseDeferredWake::~RefIndexDeferredStoreReleaseDeferredWake()
64 void RefIndexDeferredStoreReleaseDeferredWake::set(uint32_t value) {
69 void RefIndexDeferredStoreReleaseDeferredWake::writeback()
72 // TODO When part of a collection, should use relaxed for all but the last writeback
73 mIndex.storeRelease(mValue);
78 void RefIndexDeferredStoreReleaseDeferredWake::writethrough(uint32_t value) {
83 void RefIndexDeferredStoreReleaseDeferredWake::wakeDeferred(int op, int waiters)
88 // default is FUTEX_WAKE_PRIVATE
89 if (op == FUTEX_WAKE) {
92 if (waiters < INT_MAX - mWaiters) {
99 void RefIndexDeferredStoreReleaseDeferredWake::wakeNowIfNeeded()
102 mIndex.wake(mWakeOp, mWaiters);
104 mWakeOp = FUTEX_WAKE_PRIVATE;
108 void RefIndexDeferredStoreReleaseDeferredWake::wakeNow(int op, int waiters)
110 wakeDeferred(op, waiters);
116 RefIndexCachedLoadAcquireDeferredWait::RefIndexCachedLoadAcquireDeferredWait(
117 audio_utils_fifo_index& index)
118 : mIndex(index), mValue(0), mLoaded(false)
122 RefIndexCachedLoadAcquireDeferredWait::~RefIndexCachedLoadAcquireDeferredWait()
126 uint32_t RefIndexCachedLoadAcquireDeferredWait::get()
132 void RefIndexCachedLoadAcquireDeferredWait::prefetch()
135 // TODO When part of a collection, should use relaxed for all but the last load
136 mValue = mIndex.loadAcquire();
141 void RefIndexCachedLoadAcquireDeferredWait::invalidate()
147 uint32_t RefIndexCachedLoadAcquireDeferredWait::readthrough()
154 int RefIndexCachedLoadAcquireDeferredWait::wait(int op, const struct timespec *timeout)
159 int err = mIndex.wait(op, mValue /*expected*/, timeout);