aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorChris Robinson <[email protected]>2019-07-31 09:20:53 -0700
committerChris Robinson <[email protected]>2019-07-31 09:20:53 -0700
commita0aa5bc80a5c38f4ba92e38f924f4141344da819 (patch)
tree88e7622b2067ab67bb1b14c94648a855315c6053
parent4cd7eee01cd7ab2cb14ca71551954f5bd76bfd12 (diff)
Add iterators to ALbufferlistitem
And change some types to ALuint
-rw-r--r--al/buffer.cpp7
-rw-r--r--al/buffer.h6
-rw-r--r--al/source.cpp187
-rw-r--r--al/source.h53
-rw-r--r--alc/mixvoice.cpp62
5 files changed, 170 insertions, 145 deletions
diff --git a/al/buffer.cpp b/al/buffer.cpp
index d6d743d0..4e843e03 100644
--- a/al/buffer.cpp
+++ b/al/buffer.cpp
@@ -459,14 +459,14 @@ void LoadData(ALCcontext *context, ALbuffer *ALBuf, ALuint freq, ALsizei size, U
if(UNLIKELY(size/SrcByteAlign > std::numeric_limits<ALsizei>::max()/align))
SETERR_RETURN(context, AL_OUT_OF_MEMORY,,
"Buffer size overflow, %d blocks x %d samples per block", size/SrcByteAlign, align);
- const ALsizei frames{size / SrcByteAlign * align};
+ const auto frames = static_cast<ALuint>(size / SrcByteAlign * align);
/* Convert the sample frames to the number of bytes needed for internal
* storage.
*/
ALsizei NumChannels{ChannelsFromFmt(DstChannels)};
ALsizei FrameSize{NumChannels * BytesFromFmt(DstType)};
- if(UNLIKELY(frames > std::numeric_limits<ALsizei>::max()/FrameSize))
+ if(UNLIKELY(frames > std::numeric_limits<size_t>::max()/FrameSize))
SETERR_RETURN(context, AL_OUT_OF_MEMORY,,
"Buffer size overflow, %d frames x %d bytes per frame", frames, FrameSize);
size_t newsize{static_cast<size_t>(frames) * FrameSize};
@@ -1129,7 +1129,8 @@ START_API_FUNC
if(UNLIKELY(ReadRef(&albuf->ref) != 0))
context->setError(AL_INVALID_OPERATION, "Modifying in-use buffer %u's loop points",
buffer);
- else if(UNLIKELY(values[0] >= values[1] || values[0] < 0 || values[1] > albuf->SampleLen))
+ else if(UNLIKELY(values[0] < 0 || values[0] >= values[1] ||
+ static_cast<ALuint>(values[1]) > albuf->SampleLen))
context->setError(AL_INVALID_VALUE, "Invalid loop point range %d -> %d on buffer %u",
values[0], values[1], buffer);
else
diff --git a/al/buffer.h b/al/buffer.h
index 1d5873e5..e5149bb1 100644
--- a/al/buffer.h
+++ b/al/buffer.h
@@ -92,7 +92,7 @@ struct ALbuffer {
ALsizei Frequency{0};
ALbitfieldSOFT Access{0u};
- ALsizei SampleLen{0};
+ ALuint SampleLen{0u};
FmtChannels mFmtChannels{};
FmtType mFmtType{};
@@ -101,8 +101,8 @@ struct ALbuffer {
ALsizei OriginalSize{0};
ALsizei OriginalAlign{0};
- ALsizei LoopStart{0};
- ALsizei LoopEnd{0};
+ ALuint LoopStart{0u};
+ ALuint LoopEnd{0u};
std::atomic<ALsizei> UnpackAlign{0};
std::atomic<ALsizei> PackAlign{0};
diff --git a/al/source.cpp b/al/source.cpp
index ab509804..6708c970 100644
--- a/al/source.cpp
+++ b/al/source.cpp
@@ -205,8 +205,8 @@ int64_t GetSourceSampleOffset(ALsource *Source, ALCcontext *context, std::chrono
const ALbufferlistitem *BufferList{Source->queue};
while(BufferList && BufferList != Current)
{
- readPos += int64_t{BufferList->max_samples} << 32;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ readPos += int64_t{BufferList->mMaxSamples} << 32;
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
readPos = minu64(readPos, 0x7fffffffffffffff_u64);
}
@@ -252,17 +252,17 @@ ALdouble GetSourceSecOffset(ALsource *Source, ALCcontext *context, std::chrono::
const ALbuffer *BufferFmt{nullptr};
while(BufferList && BufferList != Current)
{
- for(ALsizei i{0};!BufferFmt && i < BufferList->num_buffers;++i)
- BufferFmt = BufferList->buffers[i];
- readPos += int64_t{BufferList->max_samples} << FRACTIONBITS;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ for(ALuint i{0};!BufferFmt && i < BufferList->mNumBuffers;++i)
+ BufferFmt = (*BufferList)[i];
+ readPos += int64_t{BufferList->mMaxSamples} << FRACTIONBITS;
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
while(BufferList && !BufferFmt)
{
- for(ALsizei i{0};!BufferFmt && i < BufferList->num_buffers;++i)
- BufferFmt = BufferList->buffers[i];
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ for(ALuint i{0};!BufferFmt && i < BufferList->mNumBuffers;++i)
+ BufferFmt = (*BufferList)[i];
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
assert(BufferFmt != nullptr);
@@ -314,14 +314,14 @@ ALdouble GetSourceOffset(ALsource *Source, ALenum name, ALCcontext *context)
while(BufferList)
{
- for(ALsizei i{0};!BufferFmt && i < BufferList->num_buffers;++i)
- BufferFmt = BufferList->buffers[i];
+ for(ALuint i{0};!BufferFmt && i < BufferList->mNumBuffers;++i)
+ BufferFmt = (*BufferList)[i];
readFin |= (BufferList == Current);
- totalBufferLen += BufferList->max_samples;
- if(!readFin) readPos += BufferList->max_samples;
+ totalBufferLen += BufferList->mMaxSamples;
+ if(!readFin) readPos += BufferList->mMaxSamples;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
assert(BufferFmt != nullptr);
@@ -393,10 +393,10 @@ ALboolean GetSampleOffset(ALsource *Source, ALuint *offset, ALsizei *frac)
BufferList = Source->queue;
while(BufferList)
{
- for(ALsizei i{0};i < BufferList->num_buffers && !BufferFmt;i++)
- BufferFmt = BufferList->buffers[i];
+ for(ALuint i{0};!BufferFmt && i < BufferList->mNumBuffers;i++)
+ BufferFmt = (*BufferList)[i];
if(BufferFmt) break;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
if(!BufferFmt)
{
@@ -463,7 +463,7 @@ ALboolean ApplyOffset(ALsource *Source, ALvoice *voice)
ALbufferlistitem *BufferList{Source->queue};
while(BufferList && totalBufferLen <= offset)
{
- if(static_cast<ALuint>(BufferList->max_samples) > offset-totalBufferLen)
+ if(static_cast<ALuint>(BufferList->mMaxSamples) > offset-totalBufferLen)
{
/* Offset is in this buffer */
voice->mPosition.store(offset - totalBufferLen, std::memory_order_relaxed);
@@ -471,9 +471,9 @@ ALboolean ApplyOffset(ALsource *Source, ALvoice *voice)
voice->mCurrentBuffer.store(BufferList, std::memory_order_release);
return AL_TRUE;
}
- totalBufferLen += BufferList->max_samples;
+ totalBufferLen += BufferList->mMaxSamples;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
/* Offset is out of range of the queue */
@@ -1305,10 +1305,10 @@ ALboolean SetSourceiv(ALsource *Source, ALCcontext *Context, SourceProp prop, co
/* Add the selected buffer to a one-item queue */
auto newlist = static_cast<ALbufferlistitem*>(al_calloc(alignof(void*),
ALbufferlistitem::Sizeof(1u)));
- newlist->next.store(nullptr, std::memory_order_relaxed);
- newlist->max_samples = buffer->SampleLen;
- newlist->num_buffers = 1;
- newlist->buffers[0] = buffer;
+ newlist->mNext.store(nullptr, std::memory_order_relaxed);
+ newlist->mMaxSamples = buffer->SampleLen;
+ newlist->mNumBuffers = 1;
+ newlist->mBuffers[0] = buffer;
IncrementRef(&buffer->ref);
/* Source is now Static */
@@ -1327,13 +1327,11 @@ ALboolean SetSourceiv(ALsource *Source, ALCcontext *Context, SourceProp prop, co
while(oldlist != nullptr)
{
ALbufferlistitem *temp{oldlist};
- oldlist = temp->next.load(std::memory_order_relaxed);
+ oldlist = temp->mNext.load(std::memory_order_relaxed);
- for(ALsizei i{0};i < temp->num_buffers;i++)
- {
- if(temp->buffers[i])
- DecrementRef(&temp->buffers[i]->ref);
- }
+ std::for_each(temp->begin(), temp->end(),
+ [](ALbuffer *buffer) -> void
+ { if(buffer) DecrementRef(&buffer->ref); });
al_free(temp);
}
return AL_TRUE;
@@ -1846,8 +1844,8 @@ ALboolean GetSourceiv(ALsource *Source, ALCcontext *Context, SourceProp prop, AL
case AL_BUFFER:
BufferList = (Source->SourceType == AL_STATIC) ? Source->queue : nullptr;
- *values = (BufferList && BufferList->num_buffers >= 1 && BufferList->buffers[0]) ?
- BufferList->buffers[0]->id : 0;
+ *values = (BufferList && BufferList->mNumBuffers >= 1 && BufferList->front()) ?
+ BufferList->front()->id : 0;
return AL_TRUE;
case AL_SOURCE_STATE:
@@ -1861,8 +1859,8 @@ ALboolean GetSourceiv(ALsource *Source, ALCcontext *Context, SourceProp prop, AL
{
ALsizei count = 0;
do {
- count += BufferList->num_buffers;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ count += BufferList->mNumBuffers;
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
} while(BufferList != nullptr);
*values = count;
}
@@ -1889,8 +1887,8 @@ ALboolean GetSourceiv(ALsource *Source, ALCcontext *Context, SourceProp prop, AL
while(BufferList && BufferList != Current)
{
- played += BufferList->num_buffers;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ played += BufferList->mNumBuffers;
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
*values = played;
}
@@ -2840,8 +2838,8 @@ START_API_FUNC
* length buffer.
*/
ALbufferlistitem *BufferList{source->queue};
- while(BufferList && BufferList->max_samples == 0)
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ while(BufferList && BufferList->mMaxSamples == 0)
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
/* If there's nothing to play, go right to stopped. */
if(UNLIKELY(!BufferList))
@@ -2918,10 +2916,9 @@ START_API_FUNC
voice->mPositionFrac.load(std::memory_order_relaxed) != 0 ||
voice->mCurrentBuffer.load(std::memory_order_relaxed) != BufferList;
- auto buffers_end = BufferList->buffers + BufferList->num_buffers;
- auto buffer = std::find_if(BufferList->buffers, buffers_end,
+ auto buffer = std::find_if(BufferList->cbegin(), BufferList->cend(),
std::bind(std::not_equal_to<const ALbuffer*>{}, _1, nullptr));
- if(buffer != buffers_end)
+ if(buffer != BufferList->cend())
{
voice->mFrequency = (*buffer)->Frequency;
voice->mFmtChannels = (*buffer)->mFmtChannels;
@@ -3215,13 +3212,10 @@ START_API_FUNC
ALbufferlistitem *BufferList{source->queue};
while(BufferList)
{
- for(ALsizei i{0};i < BufferList->num_buffers;i++)
- {
- if((BufferFmt=BufferList->buffers[i]) != nullptr)
- break;
- }
+ for(ALuint i{0};!BufferFmt && i < BufferList->mNumBuffers;i++)
+ BufferFmt = (*BufferList)[i];
if(BufferFmt) break;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
std::unique_lock<std::mutex> buflock{device->BufferLock};
@@ -3246,13 +3240,13 @@ START_API_FUNC
{
auto item = static_cast<ALbufferlistitem*>(al_calloc(alignof(void*),
ALbufferlistitem::Sizeof(1u)));
- BufferList->next.store(item, std::memory_order_relaxed);
+ BufferList->mNext.store(item, std::memory_order_relaxed);
BufferList = item;
}
- BufferList->next.store(nullptr, std::memory_order_relaxed);
- BufferList->max_samples = buffer ? buffer->SampleLen : 0;
- BufferList->num_buffers = 1;
- BufferList->buffers[0] = buffer;
+ BufferList->mNext.store(nullptr, std::memory_order_relaxed);
+ BufferList->mMaxSamples = buffer ? buffer->SampleLen : 0;
+ BufferList->mNumBuffers = 1;
+ BufferList->mBuffers[0] = buffer;
if(!buffer) continue;
IncrementRef(&buffer->ref);
@@ -3277,12 +3271,10 @@ START_API_FUNC
* each buffer we had. */
while(BufferListStart)
{
- ALbufferlistitem *next = BufferListStart->next.load(std::memory_order_relaxed);
- for(i = 0;i < BufferListStart->num_buffers;i++)
- {
- if((buffer=BufferListStart->buffers[i]) != nullptr)
- DecrementRef(&buffer->ref);
- }
+ ALbufferlistitem *next = BufferListStart->mNext.load(std::memory_order_relaxed);
+ std::for_each(BufferListStart->begin(), BufferListStart->end(),
+ [](ALbuffer *buffer) -> void
+ { if(buffer) DecrementRef(&buffer->ref); });
al_free(BufferListStart);
BufferListStart = next;
}
@@ -3300,9 +3292,9 @@ START_API_FUNC
else
{
ALbufferlistitem *next;
- while((next=BufferList->next.load(std::memory_order_relaxed)) != nullptr)
+ while((next=BufferList->mNext.load(std::memory_order_relaxed)) != nullptr)
BufferList = next;
- BufferList->next.store(BufferListStart, std::memory_order_release);
+ BufferList->mNext.store(BufferListStart, std::memory_order_release);
}
}
END_API_FUNC
@@ -3332,22 +3324,19 @@ START_API_FUNC
ALbufferlistitem *BufferList{source->queue};
while(BufferList)
{
- for(ALsizei i{0};i < BufferList->num_buffers;i++)
- {
- if((BufferFmt=BufferList->buffers[i]) != nullptr)
- break;
- }
+ for(ALuint i{0};!BufferFmt && i < BufferList->mNumBuffers;i++)
+ BufferFmt = (*BufferList)[i];
if(BufferFmt) break;
- BufferList = BufferList->next.load(std::memory_order_relaxed);
+ BufferList = BufferList->mNext.load(std::memory_order_relaxed);
}
std::unique_lock<std::mutex> buflock{device->BufferLock};
auto BufferListStart = static_cast<ALbufferlistitem*>(al_calloc(alignof(void*),
ALbufferlistitem::Sizeof(nb)));
BufferList = BufferListStart;
- BufferList->next.store(nullptr, std::memory_order_relaxed);
- BufferList->max_samples = 0;
- BufferList->num_buffers = 0;
+ BufferList->mNext.store(nullptr, std::memory_order_relaxed);
+ BufferList->mMaxSamples = 0;
+ BufferList->mNumBuffers = 0;
for(ALsizei i{0};i < nb;i++)
{
@@ -3358,12 +3347,12 @@ START_API_FUNC
goto buffer_error;
}
- BufferList->buffers[BufferList->num_buffers++] = buffer;
+ BufferList->mBuffers[BufferList->mNumBuffers++] = buffer;
if(!buffer) continue;
IncrementRef(&buffer->ref);
- BufferList->max_samples = maxi(BufferList->max_samples, buffer->SampleLen);
+ BufferList->mMaxSamples = maxu(BufferList->mMaxSamples, buffer->SampleLen);
if(buffer->MappedAccess != 0 && !(buffer->MappedAccess&AL_MAP_PERSISTENT_BIT_SOFT))
{
@@ -3385,12 +3374,10 @@ START_API_FUNC
* each buffer we had. */
while(BufferListStart)
{
- ALbufferlistitem *next{BufferListStart->next.load(std::memory_order_relaxed)};
- for(i = 0;i < BufferListStart->num_buffers;i++)
- {
- if((buffer=BufferListStart->buffers[i]) != nullptr)
- DecrementRef(&buffer->ref);
- }
+ ALbufferlistitem *next{BufferListStart->mNext.load(std::memory_order_relaxed)};
+ std::for_each(BufferListStart->begin(), BufferListStart->end(),
+ [](ALbuffer *buffer) -> void
+ { if(buffer) DecrementRef(&buffer->ref); });
al_free(BufferListStart);
BufferListStart = next;
}
@@ -3408,9 +3395,9 @@ START_API_FUNC
else
{
ALbufferlistitem *next;
- while((next=BufferList->next.load(std::memory_order_relaxed)) != nullptr)
+ while((next=BufferList->mNext.load(std::memory_order_relaxed)) != nullptr)
BufferList = next;
- BufferList->next.store(BufferListStart, std::memory_order_release);
+ BufferList->mNext.store(BufferListStart, std::memory_order_release);
}
}
END_API_FUNC
@@ -3447,27 +3434,27 @@ START_API_FUNC
if(UNLIKELY(BufferList == Current))
SETERR_RETURN(context, AL_INVALID_VALUE,, "Unqueueing pending buffers");
- ALsizei i{BufferList->num_buffers};
- while(i < nb)
+ ALuint i{BufferList->mNumBuffers};
+ while(i < static_cast<ALuint>(nb))
{
/* If the next bufferlist to check is NULL or is the current one, it's
* trying to unqueue pending buffers.
*/
- ALbufferlistitem *next{BufferList->next.load(std::memory_order_relaxed)};
+ ALbufferlistitem *next{BufferList->mNext.load(std::memory_order_relaxed)};
if(UNLIKELY(!next) || UNLIKELY(next == Current))
SETERR_RETURN(context, AL_INVALID_VALUE,, "Unqueueing pending buffers");
BufferList = next;
- i += BufferList->num_buffers;
+ i += BufferList->mNumBuffers;
}
while(nb > 0)
{
ALbufferlistitem *head{source->queue};
- ALbufferlistitem *next{head->next.load(std::memory_order_relaxed)};
- for(i = 0;i < head->num_buffers && nb > 0;i++,nb--)
+ ALbufferlistitem *next{head->mNext.load(std::memory_order_relaxed)};
+ for(i = 0;i < head->mNumBuffers && nb > 0;i++,nb--)
{
- ALbuffer *buffer{head->buffers[i]};
+ ALbuffer *buffer{(*head)[i]};
if(!buffer)
*(buffers++) = 0;
else
@@ -3476,21 +3463,21 @@ START_API_FUNC
DecrementRef(&buffer->ref);
}
}
- if(i < head->num_buffers)
+ if(i < head->mNumBuffers)
{
/* This head has some buffers left over, so move them to the front
* and update the sample and buffer count.
*/
- ALsizei max_length{0};
- ALsizei j{0};
- while(i < head->num_buffers)
+ ALuint max_length{0};
+ ALuint j{0};
+ while(i < head->mNumBuffers)
{
- ALbuffer *buffer{head->buffers[i++]};
- if(buffer) max_length = maxi(max_length, buffer->SampleLen);
- head->buffers[j++] = buffer;
+ ALbuffer *buffer{(*head)[i++]};
+ if(buffer) max_length = maxu(max_length, buffer->SampleLen);
+ head->mBuffers[j++] = buffer;
}
- head->max_samples = max_length;
- head->num_buffers = j;
+ head->mMaxSamples = max_length;
+ head->mNumBuffers = j;
break;
}
@@ -3584,12 +3571,10 @@ ALsource::~ALsource()
ALbufferlistitem *BufferList{queue};
while(BufferList != nullptr)
{
- ALbufferlistitem *next{BufferList->next.load(std::memory_order_relaxed)};
- for(ALsizei i{0};i < BufferList->num_buffers;i++)
- {
- if(BufferList->buffers[i])
- DecrementRef(&BufferList->buffers[i]->ref);
- }
+ ALbufferlistitem *next{BufferList->mNext.load(std::memory_order_relaxed)};
+ std::for_each(BufferList->begin(), BufferList->end(),
+ [](ALbuffer *buffer) -> void
+ { if(buffer) DecrementRef(&buffer->ref); });
al_free(BufferList);
BufferList = next;
}
diff --git a/al/source.h b/al/source.h
index c9892398..1aafafab 100644
--- a/al/source.h
+++ b/al/source.h
@@ -4,6 +4,7 @@
#include <array>
#include <atomic>
#include <cstddef>
+#include <iterator>
#include "AL/al.h"
#include "AL/alc.h"
@@ -21,16 +22,58 @@ struct ALeffectslot;
struct ALbufferlistitem {
- std::atomic<ALbufferlistitem*> next;
- ALsizei max_samples;
- ALsizei num_buffers;
- ALbuffer *buffers[];
+ using element_type = ALbuffer*;
+ using value_type = ALbuffer*;
+ using index_type = size_t;
+ using difference_type = ptrdiff_t;
+
+ using pointer = ALbuffer**;
+ using const_pointer = ALbuffer*const*;
+ using reference = ALbuffer*&;
+ using const_reference = ALbuffer*const&;
+
+ using iterator = pointer;
+ using const_iterator = const_pointer;
+ using reverse_iterator = std::reverse_iterator<iterator>;
+ using const_reverse_iterator = std::reverse_iterator<const_iterator>;
+
+
+ std::atomic<ALbufferlistitem*> mNext;
+ ALuint mMaxSamples;
+ ALuint mNumBuffers;
+ element_type mBuffers[];
static constexpr size_t Sizeof(size_t num_buffers) noexcept
{
- return maxz(offsetof(ALbufferlistitem, buffers) + sizeof(ALbuffer*)*num_buffers,
+ return maxz(offsetof(ALbufferlistitem, mBuffers) + sizeof(element_type)*num_buffers,
sizeof(ALbufferlistitem));
}
+
+ reference front() { return mBuffers[0]; }
+ const_reference front() const { return mBuffers[0]; }
+ reference back() { return mBuffers[mNumBuffers-1]; }
+ const_reference back() const { return mBuffers[mNumBuffers-1]; }
+ reference operator[](index_type idx) { return mBuffers[idx]; }
+ const_reference operator[](index_type idx) const { return mBuffers[idx]; }
+ pointer data() noexcept { return mBuffers; }
+ const_pointer data() const noexcept { return mBuffers; }
+
+ index_type size() const noexcept { return mNumBuffers; }
+ bool empty() const noexcept { return mNumBuffers == 0; }
+
+ iterator begin() noexcept { return mBuffers; }
+ iterator end() noexcept { return mBuffers+mNumBuffers; }
+ const_iterator begin() const noexcept { return mBuffers; }
+ const_iterator end() const noexcept { return mBuffers+mNumBuffers; }
+ const_iterator cbegin() const noexcept { return mBuffers; }
+ const_iterator cend() const noexcept { return mBuffers+mNumBuffers; }
+
+ reverse_iterator rbegin() noexcept { return reverse_iterator{end()}; }
+ reverse_iterator rend() noexcept { return reverse_iterator{begin()}; }
+ const_reverse_iterator rbegin() const noexcept { return const_reverse_iterator{end()}; }
+ const_reverse_iterator rend() const noexcept { return const_reverse_iterator{begin()}; }
+ const_reverse_iterator crbegin() const noexcept { return const_reverse_iterator{cend()}; }
+ const_reverse_iterator crend() const noexcept { return const_reverse_iterator{cbegin()}; }
};
diff --git a/alc/mixvoice.cpp b/alc/mixvoice.cpp
index 881759c0..e2b2bf51 100644
--- a/alc/mixvoice.cpp
+++ b/alc/mixvoice.cpp
@@ -382,15 +382,15 @@ void LoadSamples(ALfloat *RESTRICT dst, const al::byte *src, ALint srcstep, FmtT
}
ALfloat *LoadBufferStatic(ALbufferlistitem *BufferListItem, ALbufferlistitem *&BufferLoopItem,
- const ALsizei NumChannels, const ALsizei SampleSize, const ALsizei chan, ALsizei DataPosInt,
+ const ALsizei NumChannels, const ALsizei SampleSize, const ALsizei chan, ALuint DataPosInt,
al::span<ALfloat> SrcBuffer)
{
/* TODO: For static sources, loop points are taken from the first buffer
* (should be adjusted by any buffer offset, to possibly be added later).
*/
- const ALbuffer *Buffer0{BufferListItem->buffers[0]};
- const ALsizei LoopStart{Buffer0->LoopStart};
- const ALsizei LoopEnd{Buffer0->LoopEnd};
+ const ALbuffer *Buffer0{BufferListItem->front()};
+ const ALuint LoopStart{Buffer0->LoopStart};
+ const ALuint LoopEnd{Buffer0->LoopEnd};
ASSUME(LoopStart >= 0);
ASSUME(LoopEnd > LoopStart);
@@ -416,10 +416,9 @@ ALfloat *LoadBufferStatic(ALbufferlistitem *BufferListItem, ALbufferlistitem *&B
return CompLen;
};
/* It's impossible to have a buffer list item with no entries. */
- ASSUME(BufferListItem->num_buffers > 0);
- auto buffers_end = BufferListItem->buffers + BufferListItem->num_buffers;
- SrcBuffer = SrcBuffer.subspan(std::accumulate(BufferListItem->buffers, buffers_end,
- size_t{0u}, load_buffer));
+ ASSUME(BufferListItem->mNumBuffers > 0);
+ SrcBuffer = SrcBuffer.subspan(std::accumulate(BufferListItem->begin(),
+ BufferListItem->end(), size_t{0u}, load_buffer));
}
else
{
@@ -442,10 +441,9 @@ ALfloat *LoadBufferStatic(ALbufferlistitem *BufferListItem, ALbufferlistitem *&B
LoadSamples(SrcData.data(), Data, NumChannels, buffer->mFmtType, DataSize);
return CompLen;
};
- ASSUME(BufferListItem->num_buffers > 0);
- auto buffers_end = BufferListItem->buffers + BufferListItem->num_buffers;
- SrcBuffer = SrcBuffer.subspan(std::accumulate(BufferListItem->buffers, buffers_end,
- size_t{0u}, load_buffer));
+ ASSUME(BufferListItem->mNumBuffers > 0);
+ SrcBuffer = SrcBuffer.subspan(std::accumulate(BufferListItem->begin(),
+ BufferListItem->end(), size_t{0u}, load_buffer));
const auto LoopSize = static_cast<size_t>(LoopEnd - LoopStart);
while(!SrcBuffer.empty())
@@ -468,24 +466,24 @@ ALfloat *LoadBufferStatic(ALbufferlistitem *BufferListItem, ALbufferlistitem *&B
LoadSamples(SrcData.data(), Data, NumChannels, buffer->mFmtType, DataSize);
return CompLen;
};
- SrcBuffer = SrcBuffer.subspan(std::accumulate(BufferListItem->buffers, buffers_end,
- size_t{0u}, load_buffer_loop));
+ SrcBuffer = SrcBuffer.subspan(std::accumulate(BufferListItem->begin(),
+ BufferListItem->end(), size_t{0u}, load_buffer_loop));
}
}
return SrcBuffer.begin();
}
ALfloat *LoadBufferQueue(ALbufferlistitem *BufferListItem, ALbufferlistitem *BufferLoopItem,
- const ALsizei NumChannels, const ALsizei SampleSize, const ALsizei chan, ALsizei DataPosInt,
+ const ALsizei NumChannels, const ALsizei SampleSize, const ALsizei chan, ALuint DataPosInt,
al::span<ALfloat> SrcBuffer)
{
/* Crawl the buffer queue to fill in the temp buffer */
while(BufferListItem && !SrcBuffer.empty())
{
- if(DataPosInt >= BufferListItem->max_samples)
+ if(DataPosInt >= BufferListItem->mMaxSamples)
{
- DataPosInt -= BufferListItem->max_samples;
- BufferListItem = BufferListItem->next.load(std::memory_order_acquire);
+ DataPosInt -= BufferListItem->mMaxSamples;
+ BufferListItem = BufferListItem->mNext.load(std::memory_order_acquire);
if(!BufferListItem) BufferListItem = BufferLoopItem;
continue;
}
@@ -505,15 +503,14 @@ ALfloat *LoadBufferQueue(ALbufferlistitem *BufferListItem, ALbufferlistitem *Buf
LoadSamples(SrcBuffer.data(), Data, NumChannels, buffer->mFmtType, DataSize);
return CompLen;
};
- ASSUME(BufferListItem->num_buffers > 0);
- auto buffers_end = BufferListItem->buffers + BufferListItem->num_buffers;
- SrcBuffer = SrcBuffer.subspan(std::accumulate(BufferListItem->buffers, buffers_end,
- size_t{0u}, load_buffer));
+ ASSUME(BufferListItem->mNumBuffers > 0);
+ SrcBuffer = SrcBuffer.subspan(std::accumulate(BufferListItem->begin(),
+ BufferListItem->end(), size_t{0u}, load_buffer));
if(SrcBuffer.empty())
break;
DataPosInt = 0;
- BufferListItem = BufferListItem->next.load(std::memory_order_acquire);
+ BufferListItem = BufferListItem->mNext.load(std::memory_order_acquire);
if(!BufferListItem) BufferListItem = BufferLoopItem;
}
@@ -530,7 +527,7 @@ void MixVoice(ALvoice *voice, ALvoice::State vstate, const ALuint SourceID, ALCc
/* Get voice info */
const bool isstatic{(voice->mFlags&VOICE_IS_STATIC) != 0};
- ALsizei DataPosInt{static_cast<ALsizei>(voice->mPosition.load(std::memory_order_relaxed))};
+ ALuint DataPosInt{voice->mPosition.load(std::memory_order_relaxed)};
ALsizei DataPosFrac{voice->mPositionFrac.load(std::memory_order_relaxed)};
ALbufferlistitem *BufferListItem{voice->mCurrentBuffer.load(std::memory_order_relaxed)};
ALbufferlistitem *BufferLoopItem{voice->mLoopBuffer.load(std::memory_order_relaxed)};
@@ -538,7 +535,6 @@ void MixVoice(ALvoice *voice, ALvoice::State vstate, const ALuint SourceID, ALCc
const ALsizei SampleSize{voice->mSampleSize};
const ALint increment{voice->mStep};
- ASSUME(DataPosInt >= 0);
ASSUME(DataPosFrac >= 0);
ASSUME(NumChannels > 0);
ASSUME(SampleSize > 0);
@@ -868,9 +864,9 @@ void MixVoice(ALvoice *voice, ALvoice::State vstate, const ALuint SourceID, ALCc
if(BufferLoopItem)
{
/* Handle looping static source */
- const ALbuffer *Buffer{BufferListItem->buffers[0]};
- const ALsizei LoopStart{Buffer->LoopStart};
- const ALsizei LoopEnd{Buffer->LoopEnd};
+ const ALbuffer *Buffer{BufferListItem->front()};
+ const ALuint LoopStart{Buffer->LoopStart};
+ const ALuint LoopEnd{Buffer->LoopEnd};
if(DataPosInt >= LoopEnd)
{
assert(LoopEnd > LoopStart);
@@ -880,7 +876,7 @@ void MixVoice(ALvoice *voice, ALvoice::State vstate, const ALuint SourceID, ALCc
else
{
/* Handle non-looping static source */
- if(DataPosInt >= BufferListItem->max_samples)
+ if(DataPosInt >= BufferListItem->mMaxSamples)
{
if(LIKELY(vstate == ALvoice::Playing))
vstate = ALvoice::Stopped;
@@ -892,13 +888,13 @@ void MixVoice(ALvoice *voice, ALvoice::State vstate, const ALuint SourceID, ALCc
else while(1)
{
/* Handle streaming source */
- if(BufferListItem->max_samples > DataPosInt)
+ if(BufferListItem->mMaxSamples > DataPosInt)
break;
- DataPosInt -= BufferListItem->max_samples;
+ DataPosInt -= BufferListItem->mMaxSamples;
- buffers_done += BufferListItem->num_buffers;
- BufferListItem = BufferListItem->next.load(std::memory_order_relaxed);
+ buffers_done += BufferListItem->mNumBuffers;
+ BufferListItem = BufferListItem->mNext.load(std::memory_order_relaxed);
if(!BufferListItem && !(BufferListItem=BufferLoopItem))
{
if(LIKELY(vstate == ALvoice::Playing))