Add Streamer class

[libs/al.git] / source / streamer.cpp

diff --git a/source/streamer.cpp b/source/streamer.cpp
new file mode 100644 (file)
index 0000000..36545f6
--- /dev/null
+++ b/source/streamer.cpp
@@ -0,0 +1,84 @@
+/* $Id$
+
+This file is part of libmspal
+Copyright © 2008 Mikko Rasa, Mikkosoft Productions
+Distributed under the LGPL
+*/
+
+#include "buffer.h"
+#include "sound.h"
+#include "streamer.h"
+
+using namespace std;
+
+namespace Msp {
+namespace AL {
+
+Streamer::Streamer(Source &s):
+       src(s),
+       snd(0)
+{ }
+
+Streamer::~Streamer()
+{
+       src.stop();
+       src.clear_buffers();
+       for(list<Buffer *>::iterator i=buffers.begin(); i!=buffers.end(); ++i)
+               delete *i;
+}
+
+void Streamer::play(Sound &s)
+{
+       snd=&s;
+       tick();
+       src.play();
+}
+
+void Streamer::stop()
+{
+       snd=0;
+       src.stop();
+}
+
+void Streamer::tick()
+{
+       if(unsigned n=src.get_buffers_processed())
+       {
+               for(unsigned i=0; i<n; ++i)
+               {
+                       src.unqueue_buffer(*buffers.front());
+                       delete buffers.front();
+                       buffers.erase(buffers.begin());
+               }
+       }
+
+       if(!snd)
+               return;
+
+       unsigned freq=snd->get_frequency();
+       unsigned chunk_size=freq&~0xF;
+       unsigned queued=src.get_buffers_queued();
+       for(unsigned i=queued; i<4; ++i)
+       {
+               char data[chunk_size];
+               unsigned pos=0;
+               while(pos<chunk_size)
+               {
+                       unsigned len=snd->read(data+pos, chunk_size-pos);
+                       if(len==0)
+                               break;
+                       pos+=len;
+               }
+
+               if(pos)
+               {
+                       Buffer *buf=new Buffer;
+                       buf->data(snd->get_format(), data, pos, freq);
+                       src.queue_buffer(*buf);
+                       buffers.push_back(buf);
+               }
+       }
+}
+
+} // namespace AL
+} // namespace Msp