#include <cstdio>
#include <deque>
+#include <list>
#include <string>
-#include <vector>
#include <AL/al.h>
#include <vorbis/codec.h>
#include <vorbis/vorbisfile.h>
-#include "Exception.hh"
+#include "Engine.hh"
#include "Library.hh"
#include "Log.hh"
#include "Sound.hh"
if (result < 0)
{
- logWarning("error while loading sound %s",
- getName().c_str());
- throw Exception(ErrorCode::UNKNOWN_AUDIO_FORMAT);
+ logWarning << "error while loading sound "
+ << getName() << std::endl;
+ throw Error(Error::UNKNOWN_AUDIO_FORMAT, getName());
}
vorbis_info* vorbisInfo = ov_info(&mOggStream, -1);
mFormat = getAudioFormat(vorbisInfo);
mFreq = vorbisInfo->rate;
-
- logDebug(" channels: %d", vorbisInfo->channels);
- logDebug(" frequency: %d", vorbisInfo->rate);
}
}
if (size == 0)
{
- logWarning("decoded no bytes from %s", getName().c_str());
- //throw Exception("file_not_found");
+ logWarning << "decoded no bytes from "
+ << getName() << std::endl;
return;
}
void init()
{
- ALfloat zero[] = {0.0f, 0.0f, 0.0f};
-
+ mIsLoaded = false;
+ mIsPlaying = false;
+ mIsLooping = false;
+
alGenSources(1, &mSource);
+ ALfloat zero[] = {0.0f, 0.0f, 0.0f};
alSourcef(mSource, AL_PITCH, 1.0f);
alSourcef(mSource, AL_GAIN, 1.0f);
alSourcefv(mSource, AL_POSITION, zero);
alSourcefv(mSource, AL_VELOCITY, zero);
- mIsPlaying = false;
- mIsLooping = false;
+ alSourcei(mSource, AL_LOOPING, mIsLooping);
}
~Impl()
alDeleteSources(1, &mSource);
- while (!mBufferObjects.empty())
+ while (!mBuffers.empty())
{
- alDeleteBuffers(1, &mBufferObjects.back());
- mBufferObjects.pop_back();
+ alDeleteBuffers(1, &mBuffers.back());
+ mBuffers.pop_back();
}
}
{
if (mQueue.empty()) return;
- ALenum type;
- alGetSourcei(mSource, AL_SOURCE_TYPE, &type);
-
- if (type != AL_STATIC)
- {
- mQueue.front()->loadAll(mSource);
- }
+ if (!mIsLoaded) mQueue.front()->loadAll(mSource);
- alSourcei(mSource, AL_LOOPING, mIsLooping);
alSourcePlay(mSource);
- mIsPlaying = true;
+ mIsLoaded = true;
}
- void stream()
+ void playStream()
{
- stop();
+ if (mQueue.empty()) return;
- alSourcei(mSource, AL_BUFFER, AL_NONE);
- mQueue.front()->rewind();
- beginStream();
+ if (!mIsPlaying)
+ {
+ alSourcei(mSource, AL_LOOPING, false);
+ bufferStream();
+ }
+
+ if (!mStreamTimer.isValid())
+ {
+ mStreamTimer.init(boost::bind(&Impl::streamUpdate, this, _1, _2),
+ 1.0, Timer::REPEAT);
+ }
- alSourcei(mSource, AL_LOOPING, AL_FALSE);
alSourcePlay(mSource);
mIsPlaying = true;
-
- mStreamTimer.init(boost::bind(&Impl::streamUpdate, this, _1, _2), 1.0,
- Timer::REPEAT);
}
- void beginStream()
+ void bufferStream()
{
ALuint buffer;
- for (int i = mBufferObjects.size(); i < 8; ++i)
+ for (int i = mBuffers.size(); i <= 8; ++i)
{
alGenBuffers(1, &buffer);
- mBufferObjects.push_back(buffer);
- }
- for (int i = 0; i < 8; ++i)
- {
- buffer = mBufferObjects[i];
- mQueue.front()->stream(buffer);
- alSourceQueueBuffers(mSource, 1, &buffer);
+
+ if (mQueue.front()->stream(buffer))
+ {
+ alSourceQueueBuffers(mSource, 1, &buffer);
+ mBuffers.push_back(buffer);
+ }
+ else
+ {
+ alDeleteBuffers(1, &buffer);
+ break;
+ }
}
}
mQueue.front()->stream(bufferObj);
alSourceQueueBuffers(mSource, 1, &bufferObj);
logInfo("loading new buffer");
+
+ // queue up any unused buffers
+ bufferStream();
}
else if (mIsLooping)
{
alSourceQueueBuffers(mSource, 1, &bufferObj);
logInfo("looping same buffer");
}
+ else
+ {
+ // nothing more to play, stopping...
+ mIsPlaying = false;
+ std::remove(mBuffers.begin(), mBuffers.end(), bufferObj);
+ }
}
}
mStreamTimer.invalidate();
}
- void resume()
- {
- alSourcePlay(mSource);
- mIsPlaying = true;
-
- ALenum type;
- alGetSourcei(mSource, AL_SOURCE_TYPE, &type);
-
- if (type == AL_STREAMING)
- {
- mStreamTimer.init(boost::bind(&Impl::streamUpdate, this, _1, _2),
- 1.0, Timer::REPEAT);
- }
- }
-
void setSample(const std::string& name)
{
- bool playing = isPlaying();
- ALenum type;
- alGetSourcei(mSource, AL_SOURCE_TYPE, &type);
-
stop();
+ alSourcei(mSource, AL_BUFFER, AL_NONE);
+
mQueue.clear();
+ mIsLoaded = false;
- //alSourcei(mSource, AL_BUFFER, AL_NONE);
enqueue(name);
- if (playing)
+ while (!mBuffers.empty())
{
- if (type == AL_STREAMING) stream();
- else play();
+ alDeleteBuffers(1, &mBuffers.back());
+ mBuffers.pop_back();
}
}
ALuint mSource;
- std::vector<ALuint> mBufferObjects;
+ std::list<ALuint> mBuffers;
+ bool mIsLoaded;
bool mIsPlaying;
bool mIsLooping;
mImpl(new Sound::Impl(name)) {}
-void Sound::play()
+void Sound::setSample(const std::string& name)
{
// pass through
- mImpl->play();
+ mImpl->setSample(name);
}
-void Sound::stream()
+
+void Sound::play()
{
// pass through
- mImpl->stream();
+ mImpl->play();
}
-
void Sound::stop()
{
// pass through
mImpl->pause();
}
-void Sound::resume()
-{
- // pass through
- mImpl->resume();
-}
void Sound::toggle()
{
- if (mImpl->mIsPlaying) pause();
- else resume();
+ if (isPlaying()) pause();
+ else play();
}
-
-void Sound::setSample(const std::string& name)
-{
- // pass through
- mImpl->setSample(name);
-}
-
-void Sound::enqueue(const std::string& name)
-{
- // pass through
- mImpl->enqueue(name);
-}
-
-
bool Sound::isPlaying() const
{
// pass through
return mImpl->isPlaying();
}
+
void Sound::setPosition(const Vector3& position)
{
- float p[3] = {position[0], position[1], position[2]};
- alSourcefv(mImpl->mSource, AL_POSITION, p);
+ float vec[3] = {position[0], position[1], position[2]};
+ alSourcefv(mImpl->mSource, AL_POSITION, vec);
}
void Sound::setVelocity(const Vector3& velocity)
{
- float v[3] = {velocity[0], velocity[1], velocity[2]};
- alSourcefv(mImpl->mSource, AL_VELOCITY, v);
+ float vec[3] = {velocity[0], velocity[1], velocity[2]};
+ alSourcefv(mImpl->mSource, AL_VELOCITY, vec);
}
void Sound::setGain(Scalar gain)
void Sound::setListenerPosition(const Vector3& position)
{
- alListener3f(AL_POSITION, float(position[0]), float(position[1]),
- float(position[2]));
+ //alListener3f(AL_POSITION, float(position[0]), float(position[1]),
+ //float(position[2]));
+ float vec[] = {position[0], position[1], position[2]};
+ alListenerfv(AL_POSITION, vec);
}
void Sound::setListenerVelocity(const Vector3& velocity)
{
- alListener3f(AL_VELOCITY, float(velocity[0]), float(velocity[1]),
- float(velocity[2]));
+ //alListener3f(AL_VELOCITY, float(velocity[0]), float(velocity[1]),
+ //float(velocity[2]));
+ float vec[] = {velocity[0], velocity[1], velocity[2]};
+ alListenerfv(AL_VELOCITY, vec);
}
void Sound::setListenerOrientation(const Vector3& forward, const Vector3& up)
}
+//~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+
+
+void SoundStream::enqueue(const std::string& name)
+{
+ // pass through
+ mImpl->enqueue(name);
+}
+
+
+void SoundStream::play()
+{
+ // pass through
+ mImpl->playStream();
+}
+
+
} // namespace Mf
/** vim: set ts=4 sw=4 tw=80: *************************************************/