source: roaraudio/plugins/xmms/roar.c @ 457:60f64b109d75

//roar.c:

#include <roaraudio.h>

//#include "xmms/i18n.h"
#include <gtk/gtk.h>
#include <stdio.h>
#include <string.h>
#include <pthread.h>

#include "xmms/plugin.h"
#include "xmms/xmmsctrl.h"
#include "xmms/dirbrowser.h"
#include "xmms/configfile.h"
#include "xmms/util.h"

#define _(x) (x)

gint ctrlsocket_get_session_id(void);

void roar_init(void);
void roar_about(void);
void roar_configure(void);

void roar_get_volume(int *l, int *r);
void roar_fetch_volume(int *l, int *r);
void roar_set_volume(int l, int r);
void roar_mixer_init(void);
void roar_mixer_init_vol(int l, int r);

int roar_playing(void);
int roar_free(void);
void roar_write(void *ptr, int length);
void roar_close(void);
void roar_flush(int time);
void roar_pause(short p);
int roar_open(AFormat fmt, int rate, int nch);
int roar_get_output_time(void);
int roar_get_written_time(void);

int roar_update_metadata(void);
int roar_chk_metadata(void);

OutputPlugin roar_op = {
        NULL,
        NULL,
        "RoarAudio XMMS Plugin", /* Description */
        roar_init,
        roar_about,
        NULL, //roar_configure,
        NULL, //roar_get_volume,
        NULL, //roar_set_volume,
        roar_open,
        roar_write,
        roar_close,
        NULL, //roar_flush,
        roar_pause,
        roar_free,
        roar_playing,
        roar_get_output_time,
        roar_get_written_time,
};

#define STATE_CONNECTED 1
#define STATE_PLAYING   2

struct xmms_roar_out {
 int state;
 char * server;
 struct roar_connection con;
 struct roar_stream     stream;
 int data_fh;
 long unsigned int written;
 long unsigned int bps;
 int session;
 int next_test;
 int pause;
 int updateing;
} g_inst;

OutputPlugin *get_oplugin_info(void) {
 return &roar_op;
}

void roar_init(void) {
 g_inst.state = 0;
 g_inst.server = NULL;
 g_inst.updateing = 0;
 g_inst.session = ctrlsocket_get_session_id();
 ROAR_DBG("roar_init(*) = (void)");
}

int roar_playing(void) {
 return g_inst.state & STATE_PLAYING ? TRUE : FALSE;
}

void roar_write(void *ptr, int length) {
 int r;
 int need_update = 0;
 pthread_t thread;

 if ( g_inst.next_test < 1 ) {
  need_update = 1;
  g_inst.next_test = g_inst.bps;
  pthread_create(&thread, NULL, (void (*)(void*))roar_chk_metadata, NULL);
  //roar_socket_nonblock(g_inst.data_fh, ROAR_SOCKET_NONBLOCK);
 }

 if ( g_inst.pause )
  return;

 while (length) {
  if ( (r = write(g_inst.data_fh, ptr, length >= 17640 ? 17640 : length)) != -1 ) {
   g_inst.written   += r;
   ptr              += r;
   length           -= r;
   g_inst.next_test -= r;
  } else {
   if ( errno == EAGAIN ) {
    roar_socket_nonblock(g_inst.data_fh, ROAR_SOCKET_BLOCK);
   } else {
    return;
   }
  }
 }


 if ( need_update ) {
  //roar_socket_nonblock(g_inst.data_fh, ROAR_SOCKET_BLOCK);
  pthread_join(thread, NULL);
 }
}

int roar_open(AFormat fmt, int rate, int nch) {
 int codec = ROAR_CODEC_DEFAULT;
 int bits;

 if ( !(g_inst.state & STATE_CONNECTED) ) {
  if ( roar_simple_connect(&(g_inst.con), g_inst.server, "XMMS") == -1 ) {
   return FALSE;
  }
  g_inst.state |= STATE_CONNECTED;
 }

  bits = 16;
  switch (fmt) {
   case FMT_S8:
     bits = 8;
     codec = ROAR_CODEC_DEFAULT;
    break;
   case FMT_U8:
     bits = 8;
     codec = ROAR_CODEC_PCM_S_LE; // _LE, _BE, _PDP,... all the same for 8 bit output
    break;
   case FMT_U16_LE:
     codec = ROAR_CODEC_PCM_U_LE;
    break;
   case FMT_U16_BE:
     codec = ROAR_CODEC_PCM_U_BE;
    break;
   case FMT_U16_NE:
#if BYTE_ORDER == BIG_ENDIAN
     codec = ROAR_CODEC_PCM_U_BE;
#elif BYTE_ORDER == LITTLE_ENDIAN
     codec = ROAR_CODEC_PCM_U_LE;
#else
     codec = ROAR_CODEC_PCM_U_PDP;
#endif
    break;
   case FMT_S16_LE:
     codec = ROAR_CODEC_PCM_S_LE;
    break;
   case FMT_S16_BE:
     codec = ROAR_CODEC_PCM_S_BE;
    break;
   case FMT_S16_NE:
     codec = ROAR_CODEC_DEFAULT;
    break;
 }

 g_inst.bps       = nch * rate * bits / 8;
 g_inst.next_test = g_inst.bps;

 if ( (g_inst.data_fh = roar_simple_new_stream_obj(&(g_inst.con), &(g_inst.stream),
                              rate, nch, bits, codec, ROAR_DIR_PLAY)) == -1) {
  return FALSE;
 }
 g_inst.state |= STATE_PLAYING;

 g_inst.written = 0;
 g_inst.pause   = 0;

 roar_update_metadata();

 return TRUE;
}

void roar_close(void) {
 close(g_inst.data_fh);
 g_inst.state |= STATE_PLAYING;
 g_inst.state -= STATE_PLAYING;
 g_inst.written = 0;
}

void roar_pause(short p) {
 g_inst.pause = p;
}

int roar_free(void) {
 return 1000000; // ???
}

int roar_get_output_time(void) {
 return roar_get_written_time();
}

int roar_get_written_time(void) {
 gint64 r;

 if ( !g_inst.bps ) {
  ROAR_DBG("roar_get_written_time(void) = 0");
  return 0;
 }

 r  = g_inst.written;
 r *= 1000; // sec -> msec
 r /= g_inst.bps;
 ROAR_DBG("roar_get_written_time(void) = %lu", r);

 return r;
}


// ABOUT:

void roar_about(void) {
 static GtkWidget *dialog;

 if (dialog != NULL)
  return;

 dialog = xmms_show_message(
                _("About RoarAudio Plugin"),
                _("RoarAudio XMMS Plugin..."
                 ), _("OK"), FALSE, NULL, NULL);
 gtk_signal_connect(GTK_OBJECT(dialog), "destroy",
                    GTK_SIGNAL_FUNC(gtk_widget_destroyed),
                    &dialog);
}

// CONFIG:

// META DATA:

int roar_update_metadata(void) {
 struct roar_meta   meta;
 char empty = 0;
 char * info;
 int pos;

 g_inst.updateing++;

 if ( g_inst.updateing > 1 ) {
  g_inst.updateing--;
  return -1;
 }

 pos     = xmms_remote_get_playlist_pos(g_inst.session);

 meta.value = &empty;
 meta.key[0] = 0;
 meta.type = ROAR_META_TYPE_NONE;

 roar_stream_meta_set(&(g_inst.con), &(g_inst.stream), ROAR_META_MODE_CLEAR, &meta);

 info = xmms_remote_get_playlist_file(g_inst.session, pos);

 if ( info ) {
  if ( strncmp(info, "http:", 5) == 0 )
   meta.type = ROAR_META_TYPE_FILEURL;
  else
   meta.type = ROAR_META_TYPE_FILENAME;

  meta.value = info;
  roar_stream_meta_set(&(g_inst.con), &(g_inst.stream), ROAR_META_MODE_SET, &meta);

  free(info);
 }

 info = xmms_remote_get_playlist_title(g_inst.session, pos);

 if ( info ) {
  meta.type = ROAR_META_TYPE_TITLE;

  meta.value = info;
  roar_stream_meta_set(&(g_inst.con), &(g_inst.stream), ROAR_META_MODE_SET, &meta);

  free(info);
 }

 g_inst.updateing--;
 return 0;
}

int roar_chk_metadata(void) {
 static int    old_pos = -1;
 static char * old_title = "NEW TITLE";
 int pos;
 char * title;
 int need_update = 0;

 pos     = xmms_remote_get_playlist_pos(g_inst.session);

 if ( pos != old_pos ) {
  old_pos = pos;
  need_update = 1;
 } else {
  title = xmms_remote_get_playlist_title(g_inst.session, pos);

  if ( strcmp(title, old_title) ) {
   free(old_title);
   old_title = title;
   need_update = 1;
  } else {
   free(title);
  }
 }

 if ( need_update ) {
  roar_update_metadata();
 }

 return 0;
}

//ll