sandey/blender
1
0
Fork 0
forked from bartvdbraak/blender
Code Pull Requests Activity

3D Audio GSoC:

Browse Source 
Streaming improved.
This commit is contained in:
Joerg Mueller 2011-06-21 20:14:53 +00:00
parent 7ba4362c72
commit cc71dcc218
43 changed files with 175 additions and 108 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
intern/audaspace/FX/AUD_BaseIIRFilterReader.cpp
View File

@ -55,9 +55,9 @@ AUD_BaseIIRFilterReader::~AUD_BaseIIRFilterReader()
delete[] m_y;
}
void AUD_BaseIIRFilterReader::read(int & length, sample_t* buffer)
void AUD_BaseIIRFilterReader::read(int& length, bool& eos, sample_t* buffer)
{
m_reader->read(length, buffer);
m_reader->read(length, eos, buffer);
for(m_channel = 0; m_channel < m_channels; m_channel++)
{

2
intern/audaspace/FX/AUD_BaseIIRFilterReader.h
View File

@ -107,7 +107,7 @@ public:
virtual ~AUD_BaseIIRFilterReader();
virtual void read(int & length, sample_t* buffer);
virtual void read(int& length, bool& eos, sample_t* buffer);
virtual sample_t filter()=0;
};

7
intern/audaspace/FX/AUD_DelayReader.cpp
View File

@ -69,7 +69,7 @@ int AUD_DelayReader::getPosition() const
return m_reader->getPosition() + m_delay;
}
void AUD_DelayReader::read(int & length, sample_t* buffer)
void AUD_DelayReader::read(int& length, bool& eos, sample_t* buffer)
{
if(m_remdelay > 0)
{
@ -81,9 +81,8 @@ void AUD_DelayReader::read(int & length, sample_t* buffer)
memset(buffer, 0, m_remdelay * samplesize);
int len = length - m_remdelay;
m_reader->read(len, buffer + m_remdelay * specs.channels);
m_reader->read(len, eos, buffer + m_remdelay * specs.channels);
if(len < length-m_remdelay)
length = m_remdelay + len;
m_remdelay = 0;
@ -95,5 +94,5 @@ void AUD_DelayReader::read(int & length, sample_t* buffer)
}
}
else
m_reader->read(length, buffer);
m_reader->read(length, eos, buffer);
}

2
intern/audaspace/FX/AUD_DelayReader.h
View File

@ -66,7 +66,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_DELAYREADER

12
intern/audaspace/FX/AUD_DoubleReader.cpp
View File

@ -89,29 +89,27 @@ AUD_Specs AUD_DoubleReader::getSpecs() const
return m_reader1->getSpecs();
}
void AUD_DoubleReader::read(int & length, sample_t* buffer)
void AUD_DoubleReader::read(int& length, bool& eos, sample_t* buffer)
{
if(!m_finished1)
{
int len = length;
m_reader1->read(len, buffer);
m_reader1->read(len, m_finished1, buffer);
if(len < length)
if(m_finished1)
{
const AUD_Specs specs = m_reader1->getSpecs();
len = length - len;
length -= len;
m_reader2->read(len, buffer + length * specs.channels);
m_reader2->read(len, eos, buffer + length * specs.channels);
length += len;
m_finished1 = true;
}
}
else
{
m_reader2->read(length, buffer);
m_reader2->read(length, eos, buffer);
}
}

2
intern/audaspace/FX/AUD_DoubleReader.h
View File

@ -85,7 +85,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_DOUBLEREADER

4
intern/audaspace/FX/AUD_EffectReader.cpp
View File

@ -65,7 +65,7 @@ AUD_Specs AUD_EffectReader::getSpecs() const
return m_reader->getSpecs();
}
void AUD_EffectReader::read(int & length, sample_t* buffer)
void AUD_EffectReader::read(int& length, bool& eos, sample_t* buffer)
{
m_reader->read(length, buffer);
m_reader->read(length, eos, buffer);
}

2
intern/audaspace/FX/AUD_EffectReader.h
View File

@ -69,7 +69,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_EFFECTREADER

4
intern/audaspace/FX/AUD_FaderReader.cpp
View File

@ -42,13 +42,13 @@ AUD_FaderReader::AUD_FaderReader(AUD_Reference<AUD_IReader> reader, AUD_FadeType
{
}
void AUD_FaderReader::read(int & length, sample_t* buffer)
void AUD_FaderReader::read(int& length, bool& eos, sample_t* buffer)
{
int position = m_reader->getPosition();
AUD_Specs specs = m_reader->getSpecs();
int samplesize = AUD_SAMPLE_SIZE(specs);
m_reader->read(length, buffer);
m_reader->read(length, eos, buffer);
if((position + length) / (float)specs.rate <= m_start)
{

2
intern/audaspace/FX/AUD_FaderReader.h
View File

@ -72,7 +72,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_FADERREADER

42
intern/audaspace/FX/AUD_LimiterReader.cpp
View File

@ -49,13 +49,15 @@ AUD_LimiterReader::AUD_LimiterReader(AUD_Reference<AUD_IReader> reader,
// skip first m_start samples by reading them
int length = AUD_DEFAULT_BUFFER_SIZE;
AUD_Buffer buffer(AUD_DEFAULT_BUFFER_SIZE * AUD_SAMPLE_SIZE(m_reader->getSpecs()));
bool eos = false;
for(int len = m_start;
length == AUD_DEFAULT_BUFFER_SIZE;
length == AUD_DEFAULT_BUFFER_SIZE && !eos;
len -= AUD_DEFAULT_BUFFER_SIZE)
{
if(len < AUD_DEFAULT_BUFFER_SIZE)
length = len;
m_reader->read(length, buffer.getBuffer());
m_reader->read(length, eos, buffer.getBuffer());
}
}
}
@ -80,18 +82,50 @@ int AUD_LimiterReader::getPosition() const
return AUD_MIN(pos, m_end) - m_start;
}
void AUD_LimiterReader::read(int & length, sample_t* buffer)
void AUD_LimiterReader::read(int& length, bool& eos, sample_t* buffer)
{
eos = false;
if(m_end >= 0)
{
int position = m_reader->getPosition();
if(position + length > m_end)
{
length = m_end - position;
eos = true;
}
if(position < m_start)
{
int len2 = length;
for(int len = m_start - position;
len2 == length && !eos;
len -= length)
{
if(len < length)
len2 = len;
m_reader->read(len2, eos, buffer);
position += len2;
}
if(position < m_start)
{
length = 0;
return;
}
}
if(length < 0)
{
length = 0;
return;
}
}
m_reader->read(length, buffer);
if(eos)
{
m_reader->read(length, eos, buffer);
eos = true;
}
else
m_reader->read(length, eos, buffer);
}

2
intern/audaspace/FX/AUD_LimiterReader.h
View File

@ -67,7 +67,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_LIMITERREADER

19
intern/audaspace/FX/AUD_LoopReader.cpp
View File

@ -68,21 +68,20 @@ int AUD_LoopReader::getPosition() const
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, bool& eos, sample_t* buffer)
{
AUD_Specs specs = m_reader->getSpecs();
const AUD_Specs specs = m_reader->getSpecs();
int len = length;
m_reader->read(len, buffer);
m_reader->read(length, eos, buffer);
if(len < length && m_left)
if(length < len && eos && m_left)
{
int pos = 0;
int pos = length;
length = len;
pos += len;
while(pos < length && m_left)
while(pos < length && eos && m_left)
{
if(m_left > 0)
m_left--;
@ -90,7 +89,7 @@ void AUD_LoopReader::read(int & length, sample_t* buffer)
m_reader->seek(0);
len = length - pos;
m_reader->read(len, buffer + pos * specs.channels);
m_reader->read(len, eos, buffer + pos * specs.channels);
// prevent endless loop
if(!len)
@ -101,6 +100,4 @@ void AUD_LoopReader::read(int & length, sample_t* buffer)
length = pos;
}
else
length = len;
}

2
intern/audaspace/FX/AUD_LoopReader.h
View File

@ -68,7 +68,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_LOOPREADER

6
intern/audaspace/FX/AUD_ReverseReader.cpp
View File

@ -60,7 +60,7 @@ int AUD_ReverseReader::getPosition() const
return m_position;
}
void AUD_ReverseReader::read(int & length, sample_t* buffer)
void AUD_ReverseReader::read(int& length, bool& eos, sample_t* buffer)
{
// first correct the length
if(m_position + length > m_length)
@ -69,6 +69,7 @@ void AUD_ReverseReader::read(int & length, sample_t* buffer)
if(length <= 0)
{
length = 0;
eos = true;
return;
}
@ -81,7 +82,7 @@ void AUD_ReverseReader::read(int & length, sample_t* buffer)
// read from reader
m_reader->seek(m_length - m_position - len);
m_reader->read(len, buffer);
m_reader->read(len, eos, buffer);
// set null if reader didn't give enough data
if(len < length)
@ -102,4 +103,5 @@ void AUD_ReverseReader::read(int & length, sample_t* buffer)
}
m_position += length;
eos = false;
}

2
intern/audaspace/FX/AUD_ReverseReader.h
View File

@ -68,7 +68,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_REVERSEREADER

8
intern/audaspace/FX/AUD_SuperposeReader.cpp
View File

@ -82,7 +82,7 @@ AUD_Specs AUD_SuperposeReader::getSpecs() const
return m_reader1->getSpecs();
}
void AUD_SuperposeReader::read(int & length, sample_t* buffer)
void AUD_SuperposeReader::read(int& length, bool& eos, sample_t* buffer)
{
AUD_Specs specs = m_reader1->getSpecs();
int samplesize = AUD_SAMPLE_SIZE(specs);
@ -90,17 +90,19 @@ void AUD_SuperposeReader::read(int & length, sample_t* buffer)
m_buffer.assureSize(length * samplesize);
int len1 = length;
m_reader1->read(len1, buffer);
m_reader1->read(len1, eos, buffer);
if(len1 < length)
memset(buffer + len1 * specs.channels, 0, (length - len1) * samplesize);
int len2 = length;
bool eos2;
sample_t* buf = m_buffer.getBuffer();
m_reader2->read(len2, buf);
m_reader2->read(len2, eos2, buf);
for(int i = 0; i < len2 * specs.channels; i++)
buffer[i] += buf[i];
length = AUD_MAX(len1, len2);
eos &= eos2;
}

2
intern/audaspace/FX/AUD_SuperposeReader.h
View File

@ -80,7 +80,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_SUPERPOSEREADER

35
intern/audaspace/OpenAL/AUD_OpenALDevice.cpp
View File

@ -70,7 +70,7 @@ struct AUD_OpenALHandle : AUD_Handle
int current;
/// Whether the stream doesn't return any more data.
bool data_end;
bool eos;
/// The loop count of the source.
int loopcount;
@ -166,11 +166,11 @@ void AUD_OpenALDevice::updateStreams()
while(info--)
{
// if there's still data to play back
if(!sound->data_end)
if(!sound->eos)
{
// read data
length = m_buffersize;
sound->reader->read(length, m_buffer.getBuffer());
sound->reader->read(length, sound->eos, m_buffer.getBuffer());
// looping necessary?
if(length == 0 && sound->loopcount)
@ -181,13 +181,15 @@ void AUD_OpenALDevice::updateStreams()
sound->reader->seek(0);
length = m_buffersize;
sound->reader->read(length, m_buffer.getBuffer());
sound->reader->read(length, sound->eos, m_buffer.getBuffer());
}
if(sound->loopcount != 0)
sound->eos = false;
// read nothing?
if(length == 0)
{
sound->data_end = true;
break;
}
@ -197,7 +199,7 @@ void AUD_OpenALDevice::updateStreams()
ALenum err;
if((err = alGetError()) != AL_NO_ERROR)
{
sound->data_end = true;
sound->eos = true;
break;
}
@ -210,7 +212,7 @@ void AUD_OpenALDevice::updateStreams()
if((err = alGetError()) != AL_NO_ERROR)
{
sound->data_end = true;
sound->eos = true;
break;
}
@ -219,7 +221,7 @@ void AUD_OpenALDevice::updateStreams()
&sound->buffers[sound->current]);
if(alGetError() != AL_NO_ERROR)
{
sound->data_end = true;
sound->eos = true;
break;
}
@ -238,7 +240,7 @@ void AUD_OpenALDevice::updateStreams()
if(info != AL_PLAYING)
{
// if it really stopped
if(sound->data_end)
if(sound->eos)
{
if(sound->stop)
sound->stop(sound->stop_data);
@ -556,7 +558,6 @@ AUD_Handle* AUD_OpenALDevice::play(AUD_Reference<AUD_IReader> reader, bool keep)
sound->reader = reader;
sound->current = 0;
sound->isBuffered = false;
sound->data_end = false;
sound->loopcount = 0;
sound->stop = NULL;
sound->stop_data = NULL;
@ -587,7 +588,7 @@ AUD_Handle* AUD_OpenALDevice::play(AUD_Reference<AUD_IReader> reader, bool keep)
for(int i = 0; i < AUD_OPENAL_CYCLE_BUFFERS; i++)
{
length = m_buffersize;
reader->read(length, m_buffer.getBuffer());
reader->read(length,sound->eos, m_buffer.getBuffer());
alBufferData(sound->buffers[i], sound->format, m_buffer.getBuffer(),
length * AUD_DEVICE_SAMPLE_SIZE(specs),
specs.rate);
@ -658,7 +659,7 @@ AUD_Handle* AUD_OpenALDevice::play(AUD_Reference<AUD_IFactory> factory, bool kee
sound->keep = keep;
sound->current = -1;
sound->isBuffered = true;
sound->data_end = true;
sound->eos = true;
sound->loopcount = 0;
sound->stop = NULL;
sound->stop_data = NULL;
@ -862,7 +863,7 @@ bool AUD_OpenALDevice::seek(AUD_Handle* handle, float position)
{
alhandle->reader->seek((int)(position *
alhandle->reader->getSpecs().rate));
alhandle->data_end = false;
alhandle->eos = false;
ALint info;
@ -887,7 +888,7 @@ bool AUD_OpenALDevice::seek(AUD_Handle* handle, float position)
for(int i = 0; i < AUD_OPENAL_CYCLE_BUFFERS; i++)
{
length = m_buffersize;
alhandle->reader->read(length, m_buffer.getBuffer());
alhandle->reader->read(length, alhandle->eos, m_buffer.getBuffer());
alBufferData(alhandle->buffers[i], alhandle->format,
m_buffer.getBuffer(),
length * AUD_DEVICE_SAMPLE_SIZE(specs),
@ -897,6 +898,9 @@ bool AUD_OpenALDevice::seek(AUD_Handle* handle, float position)
break;
}
if(alhandle->loopcount != 0)
alhandle->eos = false;
alSourceQueueBuffers(alhandle->source,
AUD_OPENAL_CYCLE_BUFFERS,
alhandle->buffers);
@ -1045,7 +1049,10 @@ bool AUD_OpenALDevice::setLoopCount(AUD_Handle* handle, int count)
lock();
bool result = isValid(handle);
if(result)
{
((AUD_OpenALHandle*)handle)->loopcount = count;
((AUD_OpenALHandle*)handle)->eos = false;
}
unlock();
return result;
}

12
intern/audaspace/SRC/AUD_SRCResampleReader.cpp
View File

@ -77,7 +77,7 @@ long AUD_SRCResampleReader::doCallback(float** data)
int length = m_buffer.getSize() / AUD_SAMPLE_SIZE(m_tspecs);
*data = m_buffer.getBuffer();
m_reader->read(length, *data);
m_reader->read(length, m_eos, *data);
return length;
}
@ -104,13 +104,17 @@ AUD_Specs AUD_SRCResampleReader::getSpecs() const
return m_tspecs;
}
void AUD_SRCResampleReader::read(int & length, sample_t* buffer)
void AUD_SRCResampleReader::read(int& length, bool& eos, sample_t* buffer)
{
int size = length * AUD_SAMPLE_SIZE(m_tspecs);
int size = length;
m_buffer.assureSize(size);
m_buffer.assureSize(length * AUD_SAMPLE_SIZE(m_tspecs));
m_eos = false;
length = src_callback_read(m_src, m_factor, length, buffer);
m_position += length;
eos = m_eos && (length < size);
}

7
intern/audaspace/SRC/AUD_SRCResampleReader.h
View File

@ -73,6 +73,11 @@ private:
*/
int m_position;
/**
* Whether reader reached end of stream.
*/
bool m_eos;
// hide copy constructor and operator=
AUD_SRCResampleReader(const AUD_SRCResampleReader&);
AUD_SRCResampleReader& operator=(const AUD_SRCResampleReader&);
@ -104,7 +109,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_SRCRESAMPLEREADER

8
intern/audaspace/ffmpeg/AUD_FFMPEGReader.cpp
View File

@ -342,13 +342,14 @@ void AUD_FFMPEGReader::seek(int position)
// read until we're at the right position
int length = AUD_DEFAULT_BUFFER_SIZE;
AUD_Buffer buffer(length * AUD_SAMPLE_SIZE(m_specs));
bool eos;
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.getBuffer());
read(length, eos, buffer.getBuffer());
}
}
}
@ -381,7 +382,7 @@ AUD_Specs AUD_FFMPEGReader::getSpecs() const
return m_specs.specs;
}
void AUD_FFMPEGReader::read(int & length, sample_t* buffer)
void AUD_FFMPEGReader::read(int& length, bool& eos, sample_t* buffer)
{
// read packages and decode them
AVPacket packet;
@ -431,7 +432,8 @@ void AUD_FFMPEGReader::read(int & length, sample_t* buffer)
pkgbuf_pos-data_size);
}
if(left > 0)
if(eos = (left > 0))
length -= left;
m_position += length;
}

2
intern/audaspace/ffmpeg/AUD_FFMPEGReader.h
View File

@ -162,7 +162,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_FFMPEGREADER

5
intern/audaspace/intern/AUD_BufferReader.cpp
View File

@ -66,7 +66,7 @@ AUD_Specs AUD_BufferReader::getSpecs() const
return m_specs;
}
void AUD_BufferReader::read(int & length, sample_t* buffer)
void AUD_BufferReader::read(int& length, bool& eos, sample_t* buffer)
{
int sample_size = AUD_SAMPLE_SIZE(m_specs);
@ -74,7 +74,10 @@ void AUD_BufferReader::read(int & length, sample_t* buffer)
// 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;
eos = true;
}
if(length < 0)
{

2
intern/audaspace/intern/AUD_BufferReader.h
View File

@ -76,7 +76,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_BUFFERREADER

10
intern/audaspace/intern/AUD_C-API.cpp
View File

@ -804,13 +804,14 @@ float* AUD_readSoundBuffer(const char* filename, float low, float high,
int len;
int position = 0;
bool eos;
do
{
len = samplerate;
buffer.resize((position + len) * sizeof(float), true);
reader->read(len, buffer.getBuffer() + position);
reader->read(len, eos, buffer.getBuffer() + position);
position += len;
} while(len != 0);
} while(!eos);
float* result = (float*)malloc(position * sizeof(float));
memcpy(result, buffer.getBuffer(), position * sizeof(float));
@ -903,6 +904,7 @@ int AUD_readSound(AUD_Sound* sound, sample_t* buffer, int length)
int len = reader->getLength();
float samplejump = (float)len / (float)length;
float min, max;
bool eos;
for(int i = 0; i < length; i++)
{
@ -914,9 +916,9 @@ int AUD_readSound(AUD_Sound* sound, sample_t* buffer, int length)
buf = aBuffer.getBuffer();
}
reader->read(len, buf);
reader->read(len, eos, buf);
if(len < 1)
if(eos)
{
length = i;
break;

4
intern/audaspace/intern/AUD_ChannelMapperReader.cpp
View File

@ -76,13 +76,13 @@ AUD_Specs AUD_ChannelMapperReader::getSpecs() const
return m_specs;
}
void AUD_ChannelMapperReader::read(int & length, sample_t* buffer)
void AUD_ChannelMapperReader::read(int& length, bool& eos, sample_t* buffer)
{
m_buffer.assureSize(length * m_rch * sizeof(sample_t));
sample_t* in = m_buffer.getBuffer();
m_reader->read(length, in);
m_reader->read(length, eos, in);
sample_t sum;

2
intern/audaspace/intern/AUD_ChannelMapperReader.h
View File

@ -80,7 +80,7 @@ public:
~AUD_ChannelMapperReader();
virtual AUD_Specs getSpecs() const;
virtual void read(int & length, sample_t* buffer);
virtual void read(int& length, bool& eos, sample_t* buffer);
};
#endif //AUD_CHANNELMAPPERREADER

4
intern/audaspace/intern/AUD_ConverterReader.cpp
View File

@ -75,13 +75,13 @@ AUD_Specs AUD_ConverterReader::getSpecs() const
return m_specs.specs;
}
void AUD_ConverterReader::read(int & length, sample_t* buffer)
void AUD_ConverterReader::read(int& length, bool& eos, sample_t* buffer)
{
int samplesize = AUD_SAMPLE_SIZE(m_reader->getSpecs());
m_buffer.assureSize(length * samplesize);
m_reader->read(length, m_buffer.getBuffer());
m_reader->read(length, eos, m_buffer.getBuffer());
m_convert((data_t*)buffer, (data_t*)m_buffer.getBuffer(),
length * m_specs.channels);

2
intern/audaspace/intern/AUD_ConverterReader.h
View File

@ -70,7 +70,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_CONVERTERREADER

8
intern/audaspace/intern/AUD_IReader.h
View File

@ -92,15 +92,15 @@ public:
/**
* Request to read the next length samples out of the source.
* The buffer for reading has to stay valid until the next call of this
* method or until the reader is deleted.
* The buffer supplied has the needed size.
* \param[in,out] length The count of samples that should be read. Shall
* contain the real count of samples after reading, in case
* there were only fewer samples available.
* A smaller value also indicates the end of the reader.
* \param[out] buffer The pointer to the buffer with the samples.
* \param[out] eos End of stream, whether the end is reached or not.
* \param[int] buffer The pointer to the buffer to read into.
*/
virtual void read(int & length, sample_t* buffer)=0;
virtual void read(int& length, bool& eos, sample_t* buffer)=0;
};
#endif //AUD_IREADER

9
intern/audaspace/intern/AUD_LinearResampleReader.cpp
View File

@ -71,18 +71,18 @@ AUD_Specs AUD_LinearResampleReader::getSpecs() const
return m_tspecs;
}
void AUD_LinearResampleReader::read(int & length, sample_t* buffer)
void AUD_LinearResampleReader::read(int& length, bool& eos, sample_t* buffer)
{
int samplesize = AUD_SAMPLE_SIZE(m_tspecs);
int size = length * AUD_SAMPLE_SIZE(m_sspecs);
int size = length;
m_buffer.assureSize(size);
m_buffer.assureSize(size * AUD_SAMPLE_SIZE(m_sspecs));
int need = ceil((m_position + length) / m_factor) + 1 - m_sposition;
int len = need;
sample_t* buf = m_buffer.getBuffer();
m_reader->read(len, buf);
m_reader->read(len, eos, buf);
if(len < need)
length = floor((m_sposition + len - 1) * m_factor) - m_position;
@ -123,4 +123,5 @@ void AUD_LinearResampleReader::read(int & length, sample_t* buffer)
m_sposition += len;
m_position += length;
eos &= length < size;
}

2
intern/audaspace/intern/AUD_LinearResampleReader.h
View File

@ -92,7 +92,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_LINEARRESAMPLEREADER

6
intern/audaspace/intern/AUD_SequencerReader.cpp
View File

@ -113,7 +113,7 @@ AUD_Specs AUD_SequencerReader::getSpecs() const
return m_mixer->getSpecs().specs;
}
void AUD_SequencerReader::read(int & length, sample_t* buffer)
void AUD_SequencerReader::read(int& length, bool& eos, sample_t* buffer)
{
AUD_DeviceSpecs specs = m_mixer->getSpecs();
int rate = specs.rate;
@ -171,7 +171,7 @@ void AUD_SequencerReader::read(int & length, sample_t* buffer)
len -= skip;
if(strip->reader->getPosition() != current)
strip->reader->seek(current);
strip->reader->read(len, m_buffer.getBuffer());
strip->reader->read(len, eos, m_buffer.getBuffer());
m_mixer->mix(m_buffer.getBuffer(), skip, len, m_volume(m_data, strip->entry->data, (float)m_position / (float)rate));
}
}
@ -183,4 +183,6 @@ void AUD_SequencerReader::read(int & length, sample_t* buffer)
m_mixer->read((data_t*)buffer, 1.0f);
m_position += length;
eos = false;
}

2
intern/audaspace/intern/AUD_SequencerReader.h
View File

@ -100,7 +100,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_SEQUENCERREADER

3
intern/audaspace/intern/AUD_SilenceReader.cpp
View File

@ -66,8 +66,9 @@ AUD_Specs AUD_SilenceReader::getSpecs() const
return specs;
}
void AUD_SilenceReader::read(int & length, sample_t* buffer)
void AUD_SilenceReader::read(int& length, bool& eos, sample_t* buffer)
{
memset(buffer, 0, length * sizeof(sample_t));
m_position += length;
eos = false;
}

2
intern/audaspace/intern/AUD_SilenceReader.h
View File

@ -66,7 +66,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_SILENCEREADER

3
intern/audaspace/intern/AUD_SinusReader.cpp
View File

@ -72,7 +72,7 @@ AUD_Specs AUD_SinusReader::getSpecs() const
return specs;
}
void AUD_SinusReader::read(int & length, sample_t* buffer)
void AUD_SinusReader::read(int& length, bool& eos, sample_t* buffer)
{
// fill with sine data
for(int i = 0; i < length; i++)
@ -82,4 +82,5 @@ void AUD_SinusReader::read(int & length, sample_t* buffer)
}
m_position += length;
eos = false;
}

2
intern/audaspace/intern/AUD_SinusReader.h
View File

@ -78,7 +78,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_SINUSREADER

9
intern/audaspace/intern/AUD_SoftwareDevice.cpp
View File

@ -112,6 +112,7 @@ void AUD_SoftwareDevice::mix(data_t* buffer, int length)
AUD_SoftwareHandle* sound;
int len;
int pos;
bool eos;
std::list<AUD_SoftwareHandle*> stopSounds;
sample_t* buf = m_buffer.getBuffer();
@ -130,10 +131,10 @@ void AUD_SoftwareDevice::mix(data_t* buffer, int length)
pos = 0;
len = length;
sound->reader->read(len, buf);
sound->reader->read(len, eos, buf);
// in case of looping
while(pos + len < length && sound->loopcount)
while(pos + len < length && sound->loopcount && eos)
{
m_mixer->mix(buf, pos, len, sound->volume);
@ -145,7 +146,7 @@ void AUD_SoftwareDevice::mix(data_t* buffer, int length)
sound->reader->seek(0);
len = length - pos;
sound->reader->read(len, buf);
sound->reader->read(len, eos, buf);
// prevent endless loop
if(!len)
@ -156,7 +157,7 @@ void AUD_SoftwareDevice::mix(data_t* buffer, int length)
pos += len;
// in case the end of the sound is reached
if(pos < length)
if(eos && !sound->loopcount)
{
if(sound->stop)
sound->stop(sound->stop_data);

8
intern/audaspace/intern/AUD_StreamBufferFactory.cpp
View File

@ -45,6 +45,7 @@ AUD_StreamBufferFactory::AUD_StreamBufferFactory(AUD_Reference<AUD_IFactory> fac
int sample_size = AUD_SAMPLE_SIZE(m_specs);
int length;
int index = 0;
bool eos = false;
// get an approximated size if possible
int size = reader->getLength();
@ -54,15 +55,16 @@ AUD_StreamBufferFactory::AUD_StreamBufferFactory(AUD_Reference<AUD_IFactory> fac
else
size += m_specs.rate;
// as long as we fill our buffer to the end
while(index == m_buffer->getSize() / sample_size)
// as long as the end of the stream is not reached
while(!eos)
{
// increase
m_buffer->resize(size*sample_size, true);
// read more
length = size-index;
reader->read(length, m_buffer->getBuffer() + index * m_specs.channels);
reader->read(length, eos, m_buffer->getBuffer() + index * m_specs.channels);
if(index == m_buffer->getSize() / sample_size)
size += AUD_BUFFER_RESIZE_BYTES / sample_size;
index += length;
}

6
intern/audaspace/sndfile/AUD_SndFileReader.cpp
View File

@ -161,9 +161,13 @@ AUD_Specs AUD_SndFileReader::getSpecs() const
return m_specs;
}
void AUD_SndFileReader::read(int & length, sample_t* buffer)
void AUD_SndFileReader::read(int& length, bool& eos, sample_t* buffer)
{
int olen = length;
length = sf_readf_float(m_sndfile, buffer, length);
m_position += length;
eos = length < olen;
}

2
intern/audaspace/sndfile/AUD_SndFileReader.h
View File

@ -124,7 +124,7 @@ public:
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, bool& eos, sample_t* buffer);
};
#endif //AUD_SNDFILEREADER