Changed Readers to top-down architecture instead of bottom-up.
delete[] m_y;
}
-void AUD_BaseIIRFilterReader::read(int & length, sample_t* & buffer)
+void AUD_BaseIIRFilterReader::read(int & length, sample_t* buffer)
{
- sample_t* buf;
-
- int samplesize = AUD_SAMPLE_SIZE(m_reader->getSpecs());
-
- m_reader->read(length, buf);
-
- if(m_buffer.getSize() < length * samplesize)
- m_buffer.resize(length * samplesize);
-
- buffer = m_buffer.getBuffer();
+ m_reader->read(length, buffer);
for(m_channel = 0; m_channel < m_channels; m_channel++)
{
for(int i = 0; i < length; i++)
{
- m_x[m_xpos * CC] = buf[i * CC];
+ m_x[m_xpos * CC] = buffer[i * CC];
m_y[m_ypos * CC] = buffer[i * CC] = filter();
m_xpos = (m_xpos + 1) % m_xlen;
*/
const int m_ylen;
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
/**
* The last in samples array.
*/
virtual ~AUD_BaseIIRFilterReader();
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
virtual sample_t filter()=0;
};
AUD_DelayReader::AUD_DelayReader(AUD_Reference<AUD_IReader> reader, float delay) :
AUD_EffectReader(reader),
m_delay(int(delay * reader->getSpecs().rate)),
- m_remdelay(int(delay * reader->getSpecs().rate)),
- m_empty(true)
+ m_remdelay(int(delay * reader->getSpecs().rate))
{
}
return m_reader->getPosition() + m_delay;
}
-void AUD_DelayReader::read(int & length, sample_t* & buffer)
+void AUD_DelayReader::read(int & length, sample_t* buffer)
{
if(m_remdelay > 0)
{
AUD_Specs specs = m_reader->getSpecs();
int samplesize = AUD_SAMPLE_SIZE(specs);
- if(m_buffer.getSize() < length * samplesize)
- {
- m_buffer.resize(length * samplesize);
- m_empty = false;
- }
-
- buffer = m_buffer.getBuffer();
-
if(length > m_remdelay)
{
- if(!m_empty)
- memset(buffer, 0, m_remdelay * samplesize);
+ memset(buffer, 0, m_remdelay * samplesize);
int len = length - m_remdelay;
- sample_t* buf;
- m_reader->read(len, buf);
-
- memcpy(buffer + m_remdelay * specs.channels,
- buf, len * samplesize);
+ m_reader->read(len, buffer + m_remdelay * specs.channels);
if(len < length-m_remdelay)
length = m_remdelay + len;
m_remdelay = 0;
- m_empty = false;
}
else
{
- if(!m_empty)
- {
- memset(buffer, 0, length * samplesize);
- m_empty = true;
- }
+ memset(buffer, 0, length * samplesize);
m_remdelay -= length;
}
}
class AUD_DelayReader : public AUD_EffectReader
{
private:
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
/**
* The delay level.
*/
*/
int m_remdelay;
- /**
- * Whether the buffer is currently filled with zeros.
- */
- bool m_empty;
-
// hide copy constructor and operator=
AUD_DelayReader(const AUD_DelayReader&);
AUD_DelayReader& operator=(const AUD_DelayReader&);
virtual void seek(int position);
virtual int getLength() const;
virtual int getPosition() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_DELAYREADER
return m_reader1->getSpecs();
}
-void AUD_DoubleReader::read(int & length, sample_t* & buffer)
+void AUD_DoubleReader::read(int & length, sample_t* buffer)
{
if(!m_finished1)
{
if(len < length)
{
- AUD_Specs specs = m_reader1->getSpecs();
- int samplesize = AUD_SAMPLE_SIZE(specs);
-
- if(m_buffer.getSize() < length * samplesize)
- m_buffer.resize(length * samplesize);
-
- sample_t* buf = buffer;
- buffer = m_buffer.getBuffer();
-
- memcpy(buffer, buf, len * samplesize);
+ const AUD_Specs specs = m_reader1->getSpecs();
len = length - len;
length -= len;
- m_reader2->read(len, buf);
- memcpy(buffer + length * specs.channels, buf,
- len * samplesize);
+ m_reader2->read(len, buffer + length * specs.channels);
length += len;
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_DOUBLEREADER
return m_reader->getSpecs();
}
-void AUD_EffectReader::read(int & length, sample_t* & buffer)
+void AUD_EffectReader::read(int & length, sample_t* buffer)
{
m_reader->read(length, buffer);
}
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_EFFECTREADER
AUD_EffectReader(reader),
m_type(type),
m_start(start),
- m_length(length),
- m_empty(true)
+ m_length(length)
{
}
-void AUD_FaderReader::read(int & length, sample_t* & buffer)
+void AUD_FaderReader::read(int & length, sample_t* buffer)
{
int position = m_reader->getPosition();
AUD_Specs specs = m_reader->getSpecs();
{
if(m_type != AUD_FADE_OUT)
{
- if(m_buffer.getSize() < length * samplesize)
- {
- m_buffer.resize(length * samplesize);
- m_empty = false;
- }
-
- buffer = m_buffer.getBuffer();
-
- if(!m_empty)
- {
- memset(buffer, 0, length * samplesize);
- m_empty = true;
- }
+ memset(buffer, 0, length * samplesize);
}
}
else if(position / (float)specs.rate >= m_start+m_length)
{
if(m_type == AUD_FADE_OUT)
{
- if(m_buffer.getSize() < length * samplesize)
- {
- m_buffer.resize(length * samplesize);
- m_empty = false;
- }
-
- buffer = m_buffer.getBuffer();
-
- if(!m_empty)
- {
- memset(buffer, 0, length * samplesize);
- m_empty = true;
- }
+ memset(buffer, 0, length * samplesize);
}
}
else
{
- if(m_buffer.getSize() < length * samplesize)
- m_buffer.resize(length * samplesize);
-
- sample_t* buf = m_buffer.getBuffer();
float volume = 1.0f;
for(int i = 0; i < length * specs.channels; i++)
volume = 1.0f - volume;
}
- buf[i] = buffer[i] * volume;
+ buffer[i] = buffer[i] * volume;
}
-
- buffer = buf;
- m_empty = false;
}
}
*/
const float m_length;
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
- /**
- * Whether the buffer is empty.
- */
- bool m_empty;
-
// hide copy constructor and operator=
AUD_FaderReader(const AUD_FaderReader&);
AUD_FaderReader& operator=(const AUD_FaderReader&);
AUD_FaderReader(AUD_Reference<AUD_IReader> reader, AUD_FadeType type,
float start,float length);
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_FADERREADER
{
// skip first m_start samples by reading them
int length = AUD_DEFAULT_BUFFER_SIZE;
- sample_t* buffer;
+ AUD_Buffer buffer(AUD_DEFAULT_BUFFER_SIZE * AUD_SAMPLE_SIZE(m_reader->getSpecs()));
for(int len = m_start;
length == AUD_DEFAULT_BUFFER_SIZE;
len -= AUD_DEFAULT_BUFFER_SIZE)
{
if(len < AUD_DEFAULT_BUFFER_SIZE)
length = len;
- m_reader->read(length, buffer);
+ m_reader->read(length, buffer.getBuffer());
}
}
}
return AUD_MIN(pos, m_end) - m_start;
}
-void AUD_LimiterReader::read(int & length, sample_t* & buffer)
+void AUD_LimiterReader::read(int & length, sample_t* buffer)
{
if(m_end >= 0)
{
virtual void seek(int position);
virtual int getLength() const;
virtual int getPosition() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_LIMITERREADER
return m_reader->getPosition() * (m_count < 0 ? 1 : m_count);
}
-void AUD_LoopReader::read(int & length, sample_t* & buffer)
+void AUD_LoopReader::read(int & length, sample_t* buffer)
{
AUD_Specs specs = m_reader->getSpecs();
- int samplesize = AUD_SAMPLE_SIZE(specs);
int len = length;
{
int pos = 0;
- if(m_buffer.getSize() < length * samplesize)
- m_buffer.resize(length * samplesize);
-
- sample_t* buf = m_buffer.getBuffer();
-
- memcpy(buf + pos * specs.channels, buffer, len * samplesize);
-
pos += len;
while(pos < length && m_left)
m_reader->seek(0);
len = length - pos;
- m_reader->read(len, buffer);
+ m_reader->read(len, buffer + pos * specs.channels);
// prevent endless loop
if(!len)
break;
- memcpy(buf + pos * specs.channels, buffer, len * samplesize);
-
pos += len;
}
length = pos;
- buffer = buf;
}
else
length = len;
class AUD_LoopReader : public AUD_EffectReader
{
private:
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
/**
* The loop count.
*/
virtual void seek(int position);
virtual int getLength() const;
virtual int getPosition() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_LOOPREADER
return m_position;
}
-void AUD_ReverseReader::read(int & length, sample_t* & buffer)
+void AUD_ReverseReader::read(int & length, sample_t* buffer)
{
// first correct the length
if(m_position + length > m_length)
return;
}
- AUD_Specs specs = getSpecs();
- int samplesize = AUD_SAMPLE_SIZE(specs);
+ const AUD_Specs specs = getSpecs();
+ const int samplesize = AUD_SAMPLE_SIZE(specs);
- // resize buffer if needed
- if(m_buffer.getSize() < length * samplesize)
- m_buffer.resize(length * samplesize);
+ sample_t temp[specs.channels];
- buffer = m_buffer.getBuffer();
-
- sample_t* buf;
int len = length;
// read from reader
m_reader->seek(m_length - m_position - len);
- m_reader->read(len, buf);
+ m_reader->read(len, buffer);
// set null if reader didn't give enough data
if(len < length)
- {
memset(buffer, 0, (length - len) * samplesize);
- buffer += (length - len) * specs.channels;
- }
// copy the samples reverted
- for(int i = 0; i < len; i++)
+ for(int i = 0; i < length / 2; i++)
+ {
+ memcpy(temp,
+ buffer + (len - 1 - i) * specs.channels,
+ samplesize);
+ memcpy(buffer + (len - 1 - i) * specs.channels,
+ buffer + i * specs.channels,
+ samplesize);
memcpy(buffer + i * specs.channels,
- buf + (len - 1 - i) * specs.channels,
+ temp,
samplesize);
+ }
m_position += length;
-
- buffer = m_buffer.getBuffer();
}
*/
int m_position;
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
// hide copy constructor and operator=
AUD_ReverseReader(const AUD_ReverseReader&);
AUD_ReverseReader& operator=(const AUD_ReverseReader&);
virtual void seek(int position);
virtual int getLength() const;
virtual int getPosition() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_REVERSEREADER
return m_reader1->getSpecs();
}
-void AUD_SuperposeReader::read(int & length, sample_t* & buffer)
+void AUD_SuperposeReader::read(int & length, sample_t* buffer)
{
AUD_Specs specs = m_reader1->getSpecs();
int samplesize = AUD_SAMPLE_SIZE(specs);
if(m_buffer.getSize() < length * samplesize)
m_buffer.resize(length * samplesize);
- buffer = m_buffer.getBuffer();
int len1 = length;
- sample_t* buf;
- m_reader1->read(len1, buf);
- memcpy(buffer, buf, len1 * samplesize);
+ m_reader1->read(len1, buffer);
if(len1 < length)
memset(buffer + len1 * specs.channels, 0, (length - len1) * samplesize);
int len2 = length;
+ sample_t* buf = m_buffer.getBuffer();
m_reader2->read(len2, buf);
for(int i = 0; i < len2 * specs.channels; i++)
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_SUPERPOSEREADER
AUD_OpenALHandle* sound;
int length;
- sample_t* buffer;
ALint info;
AUD_DeviceSpecs specs = m_specs;
if(info)
{
specs.specs = sound->reader->getSpecs();
+ if(m_buffer.getSize() < m_buffersize * AUD_DEVICE_SAMPLE_SIZE(specs))
+ m_buffer.resize(m_buffersize * AUD_DEVICE_SAMPLE_SIZE(specs));
// for all empty buffers
while(info--)
{
// read data
length = m_buffersize;
- sound->reader->read(length, buffer);
+ sound->reader->read(length, m_buffer.getBuffer());
// looping necessary?
if(length == 0 && sound->loopcount)
sound->reader->seek(0);
length = m_buffersize;
- sound->reader->read(length, buffer);
+ sound->reader->read(length, m_buffer.getBuffer());
}
// read nothing?
// fill with new data
alBufferData(sound->buffers[sound->current],
sound->format,
- buffer, length *
+ m_buffer.getBuffer(), length *
AUD_DEVICE_SAMPLE_SIZE(specs),
specs.rate);
try
{
- sample_t* buf;
+ if(m_buffer.getSize() < m_buffersize * AUD_DEVICE_SAMPLE_SIZE(specs))
+ m_buffer.resize(m_buffersize * AUD_DEVICE_SAMPLE_SIZE(specs));
int length;
for(int i = 0; i < AUD_OPENAL_CYCLE_BUFFERS; i++)
{
length = m_buffersize;
- reader->read(length, buf);
- alBufferData(sound->buffers[i], sound->format, buf,
+ reader->read(length, m_buffer.getBuffer());
+ alBufferData(sound->buffers[i], sound->format, m_buffer.getBuffer(),
length * AUD_DEVICE_SAMPLE_SIZE(specs),
specs.rate);
if(alGetError() != AL_NO_ERROR)
ALenum err;
if((err = alGetError()) == AL_NO_ERROR)
{
- sample_t* buf;
int length;
AUD_DeviceSpecs specs = m_specs;
specs.specs = alhandle->reader->getSpecs();
+ if(m_buffer.getSize() < m_buffersize * AUD_DEVICE_SAMPLE_SIZE(specs))
+ m_buffer.resize(m_buffersize * AUD_DEVICE_SAMPLE_SIZE(specs));
for(int i = 0; i < AUD_OPENAL_CYCLE_BUFFERS; i++)
{
length = m_buffersize;
- alhandle->reader->read(length, buf);
+ alhandle->reader->read(length, m_buffer.getBuffer());
alBufferData(alhandle->buffers[i], alhandle->format,
- buf,
+ m_buffer.getBuffer(),
length * AUD_DEVICE_SAMPLE_SIZE(specs),
specs.rate);
#include "AUD_IDevice.h"
#include "AUD_I3DDevice.h"
+#include "AUD_Buffer.h"
struct AUD_OpenALHandle;
struct AUD_OpenALBufferedFactory;
*/
int m_buffersize;
+ /**
+ * Device buffer.
+ */
+ AUD_Buffer m_buffer;
+
/**
* Starts the streaming thread.
*/
long AUD_SRCResampleReader::doCallback(float** data)
{
int length = m_buffer.getSize() / AUD_SAMPLE_SIZE(m_tspecs);
- sample_t* buffer;
- m_reader->read(length, buffer);
+ *data = m_buffer.getBuffer();
+ m_reader->read(length, *data);
- *data = buffer;
return length;
}
return m_tspecs;
}
-void AUD_SRCResampleReader::read(int & length, sample_t* & buffer)
+void AUD_SRCResampleReader::read(int & length, sample_t* buffer)
{
int size = length * AUD_SAMPLE_SIZE(m_tspecs);
if(m_buffer.getSize() < size)
m_buffer.resize(size);
- buffer = m_buffer.getBuffer();
-
length = src_callback_read(m_src, m_factor, length, buffer);
m_position += length;
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_SRCRESAMPLEREADER
{
// read until we're at the right position
int length = AUD_DEFAULT_BUFFER_SIZE;
- sample_t* buffer;
+ AUD_Buffer buffer(length * AUD_SAMPLE_SIZE(m_specs));
for(int len = position - m_position;
length == AUD_DEFAULT_BUFFER_SIZE;
len -= AUD_DEFAULT_BUFFER_SIZE)
{
if(len < AUD_DEFAULT_BUFFER_SIZE)
length = len;
- read(length, buffer);
+ read(length, buffer.getBuffer());
}
}
}
return m_specs.specs;
}
-void AUD_FFMPEGReader::read(int & length, sample_t* & buffer)
+void AUD_FFMPEGReader::read(int & length, sample_t* buffer)
{
// read packages and decode them
AVPacket packet;
int left = length;
int sample_size = AUD_DEVICE_SAMPLE_SIZE(m_specs);
- // resize output buffer if necessary
- if(m_buffer.getSize() < length * AUD_SAMPLE_SIZE(m_specs))
- m_buffer.resize(length * AUD_SAMPLE_SIZE(m_specs));
-
- buffer = m_buffer.getBuffer();
+ sample_t* buf = buffer;
pkgbuf_pos = m_pkgbuf_left;
m_pkgbuf_left = 0;
if(pkgbuf_pos > 0)
{
data_size = AUD_MIN(pkgbuf_pos, left * sample_size);
- m_convert((data_t*) buffer, (data_t*) m_pkgbuf.getBuffer(),
+ m_convert((data_t*) buf, (data_t*) m_pkgbuf.getBuffer(),
data_size / AUD_FORMAT_SIZE(m_specs.format));
- buffer += data_size / AUD_FORMAT_SIZE(m_specs.format);
+ buf += data_size / AUD_FORMAT_SIZE(m_specs.format);
left -= data_size/sample_size;
}
// copy to output buffer
data_size = AUD_MIN(pkgbuf_pos, left * sample_size);
- m_convert((data_t*) buffer, (data_t*) m_pkgbuf.getBuffer(),
+ m_convert((data_t*) buf, (data_t*) m_pkgbuf.getBuffer(),
data_size / AUD_FORMAT_SIZE(m_specs.format));
- buffer += data_size / AUD_FORMAT_SIZE(m_specs.format);
+ buf += data_size / AUD_FORMAT_SIZE(m_specs.format);
left -= data_size/sample_size;
}
av_free_packet(&packet);
pkgbuf_pos-data_size);
}
- buffer = m_buffer.getBuffer();
-
if(left > 0)
length -= left;
m_position += length;
*/
int m_position;
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
/**
* The specification of the audio data.
*/
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_FFMPEGREADER
#include "AUD_Buffer.h"
#include "AUD_Space.h"
+#include <cstring>
+
AUD_BufferReader::AUD_BufferReader(AUD_Reference<AUD_Buffer> buffer,
AUD_Specs specs) :
m_position(0), m_buffer(buffer), m_specs(specs)
return m_specs;
}
-void AUD_BufferReader::read(int & length, sample_t* & buffer)
+void AUD_BufferReader::read(int & length, sample_t* buffer)
{
int sample_size = AUD_SAMPLE_SIZE(m_specs);
- buffer = m_buffer->getBuffer() + m_position * m_specs.channels;
+ sample_t* buf = m_buffer->getBuffer() + m_position * m_specs.channels;
// in case the end of the buffer is reached
if(m_buffer->getSize() < (m_position + length) * sample_size)
length = m_buffer->getSize() / sample_size - m_position;
if(length < 0)
+ {
length = 0;
+ return;
+ }
+
m_position += length;
+ memcpy(buffer, buf, length * sample_size);
}
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_BUFFERREADER
int len;
int position = 0;
- sample_t* readbuffer;
do
{
len = samplerate;
buffer.resize((position + len) * sizeof(float), true);
- reader->read(len, readbuffer);
- memcpy(buffer.getBuffer() + position, readbuffer, len * sizeof(float));
+ reader->read(len, buffer.getBuffer() + position);
position += len;
} while(len != 0);
{
AUD_DeviceSpecs specs;
sample_t* buf;
+ AUD_Buffer aBuffer;
specs.rate = AUD_RATE_INVALID;
specs.channels = AUD_CHANNELS_MONO;
for(int i = 0; i < length; i++)
{
len = floor(samplejump * (i+1)) - floor(samplejump * i);
+
+ if(aBuffer.getSize() < len * AUD_SAMPLE_SIZE(reader->getSpecs()))
+ {
+ aBuffer.resize(len * AUD_SAMPLE_SIZE(reader->getSpecs()));
+ buf = aBuffer.getBuffer();
+ }
+
reader->read(len, buf);
if(len < 1)
return m_specs;
}
-void AUD_ChannelMapperReader::read(int & length, sample_t* & buffer)
+void AUD_ChannelMapperReader::read(int & length, sample_t* buffer)
{
- sample_t* in = buffer;
+ if(m_buffer.getSize() < length * m_rch * sizeof(sample_t))
+ m_buffer.resize(length * m_rch * sizeof(sample_t));
- m_reader->read(length, in);
+ sample_t* in = m_buffer.getBuffer();
- if(m_buffer.getSize() < length * AUD_SAMPLE_SIZE(m_specs))
- m_buffer.resize(length * AUD_SAMPLE_SIZE(m_specs));
+ m_reader->read(length, in);
- buffer = m_buffer.getBuffer();
sample_t sum;
for(int i = 0; i < length; i++)
{
private:
/**
- * The sound output buffer.
+ * The sound reading buffer.
*/
AUD_Buffer m_buffer;
~AUD_ChannelMapperReader();
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_CHANNELMAPPERREADER
return m_specs.specs;
}
-void AUD_ConverterReader::read(int & length, sample_t* & buffer)
+void AUD_ConverterReader::read(int & length, sample_t* buffer)
{
- m_reader->read(length, buffer);
-
- int samplesize = AUD_SAMPLE_SIZE(m_specs);
+ int samplesize = AUD_SAMPLE_SIZE(m_reader->getSpecs());
if(m_buffer.getSize() < length * samplesize)
m_buffer.resize(length * samplesize);
- m_convert((data_t*)m_buffer.getBuffer(), (data_t*)buffer,
- length * m_specs.channels);
+ m_reader->read(length, m_buffer.getBuffer());
- buffer = m_buffer.getBuffer();
+ m_convert((data_t*)buffer, (data_t*)m_buffer.getBuffer(),
+ length * m_specs.channels);
}
AUD_ConverterReader(AUD_Reference<AUD_IReader> reader, AUD_DeviceSpecs specs);
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_CONVERTERREADER
* A smaller value also indicates the end of the reader.
* \param[out] buffer The pointer to the buffer with the samples.
*/
- virtual void read(int & length, sample_t* & buffer)=0;
+ virtual void read(int & length, sample_t* buffer)=0;
};
#endif //AUD_IREADER
return m_tspecs;
}
-void AUD_LinearResampleReader::read(int & length, sample_t* & buffer)
+void AUD_LinearResampleReader::read(int & length, sample_t* buffer)
{
int samplesize = AUD_SAMPLE_SIZE(m_tspecs);
- int size = length * samplesize;
+ int size = length * AUD_SAMPLE_SIZE(m_sspecs);
if(m_buffer.getSize() < size)
m_buffer.resize(size);
int need = ceil((m_position + length) / m_factor) + 1 - m_sposition;
int len = need;
- sample_t* buf;
- buffer = m_buffer.getBuffer();
+ sample_t* buf = m_buffer.getBuffer();
m_reader->read(len, buf);
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_LINEARRESAMPLEREADER
return m_specs;
}
-void AUD_Mixer::add(sample_t* buffer, int start, int length, float volume)
+void AUD_Mixer::clear(int length)
{
- AUD_MixerBuffer buf;
- buf.buffer = buffer;
- buf.start = start;
- buf.length = length;
- buf.volume = volume;
- m_buffers.push_back(buf);
-}
-
-void AUD_Mixer::superpose(data_t* buffer, int length, float volume)
-{
- AUD_MixerBuffer buf;
+ if(m_buffer.getSize() < length * m_specs.channels * AUD_SAMPLE_SIZE(m_specs))
+ m_buffer.resize(length * m_specs.channels * AUD_SAMPLE_SIZE(m_specs));
- int channels = m_specs.channels;
+ m_length = length;
- if(m_buffer.getSize() < length * channels * 4)
- m_buffer.resize(length * channels * 4);
+ memset(m_buffer.getBuffer(), 0, length * m_specs.channels * AUD_SAMPLE_SIZE(m_specs));
+}
+void AUD_Mixer::mix(sample_t* buffer, int start, int length, float volume)
+{
sample_t* out = m_buffer.getBuffer();
- sample_t* in;
-
- memset(out, 0, length * channels * 4);
- int end;
+ length = (AUD_MIN(m_length, length + start) - start) * m_specs.channels;
+ start += m_specs.channels;
- while(!m_buffers.empty())
- {
- buf = m_buffers.front();
- m_buffers.pop_front();
+ for(int i = 0; i < length; i++)
+ out[i + start] += buffer[i] * volume;
+}
- end = buf.length * channels;
- in = buf.buffer;
+void AUD_Mixer::read(data_t* buffer, float volume)
+{
+ sample_t* out = m_buffer.getBuffer();
- for(int i = 0; i < end; i++)
- out[i + buf.start * channels] += in[i] * buf.volume * volume;
- }
+ for(int i = 0; i < m_length * m_specs.channels; i++)
+ out[i] *= volume;
- m_convert(buffer, (data_t*) out, length * channels);
+ m_convert(buffer, (data_t*) out, m_length * m_specs.channels);
}
#include "AUD_Buffer.h"
#include "AUD_Reference.h"
class AUD_IReader;
-#include <list>
-
-struct AUD_MixerBuffer
-{
- sample_t* buffer;
- int start;
- int length;
- float volume;
-};
/**
* This abstract class is able to mix audiosignals of different channel count
{
protected:
/**
- * The list of buffers to superpose.
+ * The output specification.
*/
- std::list<AUD_MixerBuffer> m_buffers;
+ const AUD_DeviceSpecs m_specs;
/**
- * The output specification.
+ * The length of the mixing buffer.
*/
- const AUD_DeviceSpecs m_specs;
+ int m_length;
/**
- * The temporary mixing buffer.
+ * The mixing buffer.
*/
AUD_Buffer m_buffer;
virtual AUD_Reference<AUD_IReader> prepare(AUD_Reference<AUD_IReader> reader)=0;
/**
- * Adds a buffer for superposition.
+ * Mixes a buffer.
* \param buffer The buffer to superpose.
* \param start The start sample of the buffer.
* \param length The length of the buffer in samples.
* \param volume The mixing volume. Must be a value between 0.0 and 1.0.
*/
- virtual void add(sample_t* buffer, int start, int length, float volume);
+ virtual void mix(sample_t* buffer, int start, int length, float volume);
/**
- * Superposes all added buffers into an output buffer.
+ * Writes the mixing buffer into an output buffer.
* \param buffer The target buffer for superposing.
- * \param length The length of the buffer in samples.
* \param volume The mixing volume. Must be a value between 0.0 and 1.0.
*/
- virtual void superpose(data_t* buffer, int length, float volume);
+ virtual void read(data_t* buffer, float volume);
+
+ /**
+ * Clears the mixing buffer.
+ * \param length The length of the buffer in samples.
+ */
+ virtual void clear(int length);
};
#endif //AUD_MIXER
return m_mixer->getSpecs().specs;
}
-void AUD_SequencerReader::read(int & length, sample_t* & buffer)
+void AUD_SequencerReader::read(int & length, sample_t* buffer)
{
AUD_DeviceSpecs specs = m_mixer->getSpecs();
- int samplesize = AUD_SAMPLE_SIZE(specs);
int rate = specs.rate;
- int size = length * samplesize;
-
int start, end, current, skip, len;
AUD_Reference<AUD_SequencerStrip> strip;
- sample_t* buf;
+ if(m_buffer.getSize() < length * AUD_SAMPLE_SIZE(specs))
+ m_buffer.resize(length * AUD_SAMPLE_SIZE(specs));
- if(m_buffer.getSize() < size)
- m_buffer.resize(size);
- buffer = m_buffer.getBuffer();
+ m_mixer->clear(length);
if(!m_factory->getMute())
{
len -= skip;
if(strip->reader->getPosition() != current)
strip->reader->seek(current);
- strip->reader->read(len, buf);
- m_mixer->add(buf, skip, len, m_volume(m_data, strip->entry->data, (float)m_position / (float)rate));
+ strip->reader->read(len, m_buffer.getBuffer());
+ m_mixer->mix(m_buffer.getBuffer(), skip, len, m_volume(m_data, strip->entry->data, (float)m_position / (float)rate));
}
}
}
}
}
- m_mixer->superpose((data_t*)buffer, length, 1.0f);
+ m_mixer->read((data_t*)buffer, 1.0f);
m_position += length;
}
int m_position;
/**
- * The sound output buffer.
+ * The reading buffer.
*/
AUD_Buffer m_buffer;
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_SEQUENCERREADER
return specs;
}
-void AUD_SilenceReader::read(int & length, sample_t* & buffer)
+void AUD_SilenceReader::read(int & length, sample_t* buffer)
{
- // resize if necessary
- if(m_buffer.getSize() < length * sizeof(sample_t))
- {
- m_buffer.resize(length * sizeof(sample_t));
- memset(m_buffer.getBuffer(), 0, m_buffer.getSize());
- }
-
- buffer = m_buffer.getBuffer();
+ memset(buffer, 0, length * sizeof(sample_t));
m_position += length;
}
*/
int m_position;
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
// hide copy constructor and operator=
AUD_SilenceReader(const AUD_SilenceReader&);
AUD_SilenceReader& operator=(const AUD_SilenceReader&);
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_SILENCEREADER
return specs;
}
-void AUD_SinusReader::read(int & length, sample_t* & buffer)
+void AUD_SinusReader::read(int & length, sample_t* buffer)
{
- // resize if necessary
- if(m_buffer.getSize() < length * sizeof(sample_t))
- m_buffer.resize(length * sizeof(sample_t));
-
// fill with sine data
- buffer = m_buffer.getBuffer();
for(int i = 0; i < length; i++)
{
buffer[i] = sin((m_position + i) * 2 * M_PI * m_frequency /
*/
int m_position;
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
/**
* The sample rate for the output.
*/
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_SINUSREADER
void AUD_SoftwareDevice::mix(data_t* buffer, int length)
{
+ if(m_buffer.getSize() < length * AUD_SAMPLE_SIZE(m_specs))
+ m_buffer.resize(length * AUD_SAMPLE_SIZE(m_specs));
+
lock();
{
AUD_SoftwareHandle* sound;
int len;
int pos;
- sample_t* buf;
std::list<AUD_SoftwareHandle*> stopSounds;
- std::list<AUD_Buffer*> tempBufs;
- AUD_Buffer* tempbuf;
- int samplesize = AUD_SAMPLE_SIZE(m_specs);
+ sample_t* buf = m_buffer.getBuffer();
+
+ m_mixer->clear(length);
// for all sounds
AUD_HandleIterator it = m_playingSounds.begin();
// get the buffer from the source
pos = 0;
len = length;
+
sound->reader->read(len, buf);
// in case of looping
while(pos + len < length && sound->loopcount)
{
- tempbuf = new AUD_Buffer(len * samplesize);
- memcpy(tempbuf->getBuffer(), buf, len * samplesize);
- tempBufs.push_back(tempbuf);
- m_mixer->add(tempbuf->getBuffer(), pos, len, sound->volume);
+ m_mixer->mix(buf, pos, len, sound->volume);
pos += len;
break;
}
- m_mixer->add(buf, pos, len, sound->volume);
+ m_mixer->mix(buf, pos, len, sound->volume);
pos += len;
// in case the end of the sound is reached
}
// superpose
- m_mixer->superpose(buffer, length, m_volume);
+ m_mixer->read(buffer, m_volume);
// cleanup
while(!stopSounds.empty())
stopSounds.pop_front();
stop(sound);
}
-
- while(!tempBufs.empty())
- {
- tempbuf = tempBufs.front();
- tempBufs.pop_front();
- delete tempbuf;
- }
}
unlock();
#include "AUD_IDevice.h"
#include "AUD_Mixer.h"
+#include "AUD_Buffer.h"
struct AUD_SoftwareHandle;
-class AUD_Buffer;
#include <list>
#include <pthread.h>
virtual void playing(bool playing)=0;
private:
+ /**
+ * The reading buffer.
+ */
+ AUD_Buffer m_buffer;
+
/**
* The list of sounds that are currently playing.
*/
int sample_size = AUD_SAMPLE_SIZE(m_specs);
int length;
int index = 0;
- sample_t* buffer;
// get an approximated size if possible
int size = reader->getLength();
// read more
length = size-index;
- reader->read(length, buffer);
- memcpy(m_buffer->getBuffer() + index * m_specs.channels,
- buffer,
- length * sample_size);
+ reader->read(length, m_buffer->getBuffer() + index * m_specs.channels);
size += AUD_BUFFER_RESIZE_BYTES / sample_size;
index += length;
}
* \ingroup audjack
*/
-
-#include "AUD_Mixer.h"
#include "AUD_JackDevice.h"
#include "AUD_IReader.h"
return m_specs;
}
-void AUD_SndFileReader::read(int & length, sample_t* & buffer)
+void AUD_SndFileReader::read(int & length, sample_t* buffer)
{
- int sample_size = AUD_SAMPLE_SIZE(m_specs);
-
- // resize output buffer if necessary
- if(m_buffer.getSize() < length*sample_size)
- m_buffer.resize(length*sample_size);
-
- buffer = m_buffer.getBuffer();
-
length = sf_readf_float(m_sndfile, buffer, length);
m_position += length;
*/
AUD_Specs m_specs;
- /**
- * The playback buffer.
- */
- AUD_Buffer m_buffer;
-
/**
* The sndfile.
*/
virtual int getLength() const;
virtual int getPosition() const;
virtual AUD_Specs getSpecs() const;
- virtual void read(int & length, sample_t* & buffer);
+ virtual void read(int & length, sample_t* buffer);
};
#endif //AUD_SNDFILEREADER