summaryrefslogtreecommitdiffstats
path: root/oggvorbis_artsplugin/oggPlayObject_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'oggvorbis_artsplugin/oggPlayObject_impl.cpp')
-rw-r--r--oggvorbis_artsplugin/oggPlayObject_impl.cpp313
1 files changed, 313 insertions, 0 deletions
diff --git a/oggvorbis_artsplugin/oggPlayObject_impl.cpp b/oggvorbis_artsplugin/oggPlayObject_impl.cpp
new file mode 100644
index 00000000..80fd058e
--- /dev/null
+++ b/oggvorbis_artsplugin/oggPlayObject_impl.cpp
@@ -0,0 +1,313 @@
+/* $Id$ */
+
+#include <sys/types.h>
+#include <sys/ipc.h>
+#include <sys/sem.h>
+#include <sys/stat.h>
+#include <sys/shm.h>
+#include <sys/wait.h>
+
+#include <assert.h>
+#include <errno.h>
+#include <fcntl.h>
+#include <math.h>
+#include <signal.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <math.h>
+#include <vorbis/codec.h>
+#include <vorbis/vorbisfile.h>
+
+/////////////////////////////////////////////////////////////
+// aRts interface
+
+#include <stdsynthmodule.h>
+#include "oggarts.h"
+#include <convert.h>
+#include <debug.h>
+
+
+#include "oggPlayObject_impl.h"
+
+using namespace Arts;
+
+oggPlayObject_impl::oggPlayObject_impl()
+{
+ struct shmid_ds bleh;
+ shm_id = shmget(IPC_PRIVATE, sizeof(*shm_buf), 0600);
+ shm_buf = (struct buf_t *)shmat(shm_id, 0, 0);
+
+ // mark it to be destroyed after the last detach
+ shmctl(shm_id, IPC_RMID, &bleh);
+
+ // sem0 has base
+ // sem1 remaining space
+ // sem2 seekTo
+ buflen_sem = semget(IPC_PRIVATE, 4, 0600);
+ child_pid = 0;
+}
+
+oggPlayObject_impl::~oggPlayObject_impl()
+{
+ halt();
+ union semun foo;
+ arts_debug("oggvorbis: removing IPC resources");
+ semctl(buflen_sem, 0, IPC_RMID, foo);
+}
+
+bool oggPlayObject_impl::loadMedia(const std::string &filename)
+{
+ halt(); // stop playing any previous stream
+ currentFile = filename;
+
+ //throw off a process to handle the decoding
+ //fill the buffers first...
+
+ short decode_buf[BACKBUFSIZ];
+
+ struct sembuf semoper;
+ semoper.sem_flg = 0;
+
+ buf_pos = 0;
+ // setup the initial semaphore joy
+
+ union semun foo;
+
+ foo.val = 0;
+ if (semctl(buflen_sem, 0, SETVAL, foo))
+ arts_debug("oggvorbis: couldn't clear queue %d, %s", errno, strerror(errno)); // no data in the queue
+
+ foo.val = 0;
+ // seekTo is -1 (ie, no seek)
+ if (semctl(buflen_sem, 2, SETVAL, foo))
+ arts_debug("oggvorbis: couldn't clear seekTo, %s",strerror(errno));
+
+ semctl(buflen_sem, 3, SETVAL, foo);
+ arts_debug("oggvorbis: seekTo is %d", semctl(buflen_sem, 2, GETVAL, foo));
+
+ // setup the starting free space in the buffer
+ foo.val = BACKBUFSIZ;
+ if (semctl(buflen_sem, 1, SETVAL, foo))
+ arts_debug("oggvorbis: couldn't mark buffer empty");
+
+ FILE *ogg_fp;
+ ogg_fp = fopen(filename.c_str(), "r");
+ int current_section=0;
+
+ ov_open(ogg_fp, &vf, NULL, 0);
+ if (!(child_pid = fork())) {
+ arts_debug("oggvorbis: child process");
+ do {
+ // get more data
+
+ int seekTo = semctl(buflen_sem, 2, GETVAL, foo);
+ if (seekTo) {
+ arts_debug("oggvorbis: seeking to %d", seekTo);
+ // we have a seek command
+ int ret = ov_time_seek(&vf, (double)seekTo-1);
+ arts_debug("oggvorbis: ov_time_seek returned: %d\n", ret);
+ foo.val=0;
+ semctl(buflen_sem, 2, SETVAL, foo); // we've done it
+ }
+ foo.val=(long)ov_time_tell(&vf);
+ if (foo.val == -1) foo.val=0;
+ semctl(buflen_sem, 3, SETVAL, foo);
+
+ int thisPass = ov_read(&vf, (char *)decode_buf, BACKBUFSIZ*sizeof(short), 0, 2, 1, &current_section);
+ if (thisPass == 0) {
+ // we're done, or we errored (in which case we're done)
+ break;
+ }
+ thisPass = (thisPass / 4);
+
+
+ semoper.sem_num = 1;
+ semoper.sem_op = -thisPass;
+ semop(buflen_sem, &semoper, 1);
+
+ // block until there's enough space to stick in this frame
+ int roomFor = semctl(buflen_sem, 1, GETVAL, foo);
+ if (roomFor > BACKBUFSIZ) {
+ arts_debug("oggvorbis: exit requested, bye!");
+ // this can never go above BACKBUFSIZ in normal operation,
+ // the consumer wants us to exit
+ break;
+ }
+
+ for (int i=0 ; i <thisPass ; ++i, buf_pos = ((buf_pos + 1) % BACKBUFSIZ)) {
+ shm_buf->left[buf_pos] = conv_16le_float(decode_buf[2*i]);
+ shm_buf->right[buf_pos] = conv_16le_float(decode_buf[2*i+1]);
+ }
+
+ //arts_debug("oggvorbis: enqueued them");
+ semoper.sem_num = 0;
+ semoper.sem_op = thisPass;
+ semop(buflen_sem, &semoper, 1); // mark the additional data now available
+
+ //arts_debug("oggvorbis: calculated %d more samples",shm_buf->back$
+ } while(1);
+
+ //signal completion
+ foo.val = 0;
+ // no more data available
+ semctl(buflen_sem, 0, SETVAL, foo);
+ // and no room either (ie, none coming)
+ semctl(buflen_sem, 1, SETVAL, foo);
+
+ arts_debug("oggvorbis: decoder process exiting");
+ exit(0);
+ }
+ return true;
+}
+
+std::string oggPlayObject_impl::description()
+{
+ return "ogg/vorbis artsplugin - this is my w00t!";
+}
+
+poTime oggPlayObject_impl::currentTime()
+{
+ poTime time;
+ union semun foo;
+ foo.val=0;
+ time.seconds = semctl(buflen_sem, 3, GETVAL, foo);
+ if (time.seconds == -1)
+ time.seconds = 0; // Eek infinite loop time.
+ time.ms=0;
+ //arts_debug("oggvorbis: time is now %d\n", time.seconds);
+ return time;
+}
+
+poTime oggPlayObject_impl::overallTime() {
+ poTime time;
+ time.seconds=(long)ov_time_total(&vf, -1);
+ time.ms=0;
+ return time;
+}
+
+poCapabilities oggPlayObject_impl::capabilities() {
+ return static_cast<poCapabilities>(capPause|capSeek);
+}
+
+std::string oggPlayObject_impl::mediaName() {
+ return currentFile;
+}
+
+poState oggPlayObject_impl::state() {
+ return mState;
+}
+
+void oggPlayObject_impl::play() {
+ arts_debug("oggvorbis: play");
+ mState = posPlaying;
+}
+
+void oggPlayObject_impl::halt()
+{
+ mState = posIdle;
+ union semun foo;
+
+ if (child_pid) {
+ arts_debug("oggvorbis: killing decoder process");
+ foo.val = 2*BACKBUFSIZ;
+ semctl(buflen_sem, 1, SETVAL, foo);
+ waitpid(child_pid, NULL, 0);
+ child_pid = 0;
+ }
+ // tell the producer to exit (would also result in us halting, if we weren't already)
+
+ // mainly this is to ensure that the decoder wakes up to notice
+}
+
+void oggPlayObject_impl::seek(const class poTime &t)
+{
+ union semun foo;
+
+ // this index is one-based so 0 can represent no seek
+ foo.val = static_cast<int>(t.seconds);
+ arts_debug("requesting seek to %d", foo.val);
+ semctl(buflen_sem, 2, SETVAL, foo); // we've done it
+}
+
+void oggPlayObject_impl::pause()
+{
+ mState = posPaused;
+}
+
+void oggPlayObject_impl::streamInit()
+{
+ arts_debug("oggvorbis: streamInit");
+}
+
+void oggPlayObject_impl::streamStart()
+{
+ arts_debug("ogg_vorbis: streamStart");
+}
+
+void oggPlayObject_impl::calculateBlock(unsigned long samples)
+{
+ int samplesAvailable = 0;
+
+ //arts_debug("oggvorbis: calculateBlock");
+
+ if (mState == posPlaying) {
+ //arts_debug("oggvorbis: calculateBlock, %d(%d) of %d samples in buffer",
+ //shm_buf->buflen - bufpos, shm_buf->backbuflen,samples);
+
+ struct sembuf bleh;
+
+ bleh.sem_num = 0;
+ bleh.sem_flg = IPC_NOWAIT;
+ //arts_debug("oggvorbis: %d samples wanted", samplesAvailable);
+ bleh.sem_op = -samples; // does the buffer have sufficient samples?
+ if (semop(buflen_sem, &bleh, 1) == -1) {
+ if (errno == EAGAIN) {
+ union semun foo;
+ arts_debug("oggvorbis: buffer underrun");
+ samplesAvailable = semctl(buflen_sem, 0, GETVAL, foo);
+ // no samples AND no room is the decoder's way of signalling completion
+ if (semctl(buflen_sem, 1, GETVAL, foo) == 0) {
+ halt();
+ samplesAvailable = 0;
+ }
+ } else {
+ // something awful has happened
+ halt();
+ samplesAvailable = 0;
+ }
+ } else {
+ samplesAvailable = samples; // number of samples we pushed from buffers
+ // used to calculate the number we should zero out for an underrun
+ }
+ bleh.sem_flg = 0; // back to normal now
+
+ //arts_debug("oggvorbis: %d samples available",samplesAvailable);
+ for (int i = 0; i < samplesAvailable;
+ ++i, buf_pos = ((buf_pos + 1) % BACKBUFSIZ)) {
+
+ left[i] = shm_buf->left[buf_pos];
+ right[i] = shm_buf->right[buf_pos];
+ }
+
+ bleh.sem_num = 1;
+ bleh.sem_op = samplesAvailable;
+ semop(buflen_sem, &bleh, 1); // mark the now-free space
+ }
+ // zero out any samples we didn't have enough to complete
+ while(static_cast<unsigned long>(samplesAvailable) < samples) {
+ left[samplesAvailable] = 0.0;
+ right[samplesAvailable] = 0.0;
+ samplesAvailable++;
+ }
+}
+
+void oggPlayObject_impl::streamEnd()
+{
+ arts_debug("oggvorbis: streamEnd");
+}
+
+REGISTER_IMPLEMENTATION(oggPlayObject_impl);