XMMS Input plugin support

based on patches by Balatoni Denes <pnis@coder.hu>
changes by me: glib dependency removed, files merged, code simplified, some bugfixes


git-svn-id: svn://svn.mplayerhq.hu/mplayer/trunk@8529 b3059339-0415-0410-9bf9-f77b7e298cf2

1 files changed, 336 insertions, 0 deletions

diff --git a/libmpdemux/demux_xmms.c b/libmpdemux/demux_xmms.c
new file mode 100644
index 0000000000..2a03a0be3c
--- /dev/null
+++ b/libmpdemux/demux_xmms.c
@@ -0,0 +1,336 @@
+// This is not reentrant (because of global variables shared with demux_xmms_output.c)
+// and the plugins are not reentrant either perhaps 
+#include "config.h"
+
+#include <stdlib.h>
+#include <stdio.h>
+#include <unistd.h>
+#include <pthread.h>
+#include <dlfcn.h>
+#include <dirent.h>
+#include <inttypes.h>
+
+#include "../cfgparser.h"
+#include "../libao2/afmt.h"
+#include "stream.h"
+#include "demuxer.h"
+#include "stheader.h"
+
+#include <dirent.h>
+#include <string.h>
+#include <sys/stat.h>
+//#include <glib.h>
+
+#define XMMS_PACKETSIZE 65536  // some plugins won't play if this is too small
+
+#include "demux_xmms_plugin.h"
+//#include "demux_xmms_pluginenum.h"
+//#include "demux_xmms_input.h"
+
+//extern OutputPlugin xmms_output_plugin;
+
+static pthread_mutex_t xmms_mutex;
+static int format = 0x1; // Raw PCM
+static char xmms_audiobuffer[XMMS_PACKETSIZE];
+static uint32_t xmms_channels;
+static uint32_t xmms_samplerate;
+static uint32_t xmms_afmt;
+static int xmms_length;
+static char *xmms_title=NULL;
+static uint32_t xmms_audiopos=0;
+
+static uint64_t written = 0;
+
+static void disk_close(void) {}
+static void disk_flush(int time) {}
+static void disk_pause(short p) {}
+static void disk_init(void) {}
+
+static int disk_free(void) { // vqf plugin sends more than it should
+    return (XMMS_PACKETSIZE-xmms_audiopos<XMMS_PACKETSIZE/4 ? 0:XMMS_PACKETSIZE-xmms_audiopos-XMMS_PACKETSIZE/4);
+}
+
+static int disk_playing(void) {
+	return 0; //??
+}
+
+static int disk_get_output_time(void) {
+	return 10;
+}
+
+static int disk_open(AFormat fmt, int rate, int nch) {
+    switch (fmt) {
+	case FMT_U8:
+	    xmms_afmt=AFMT_U8;
+	    break;
+	case FMT_S8:
+	    xmms_afmt=AFMT_S8;
+	    break;
+	case FMT_U16_LE:
+	    xmms_afmt=AFMT_U16_LE;
+	    break;
+	case FMT_U16_NE:
+#if WORDS_BIGENDIAN
+	    xmms_afmt=AFMT_U16_BE;
+#else
+	    xmms_afmt=AFMT_U16_LE;
+#endif
+	    break;
+	case FMT_U16_BE:
+	    xmms_afmt=AFMT_U16_BE;
+	    break;
+	case FMT_S16_NE:
+	    xmms_afmt=AFMT_S16_NE;
+	    break;
+	case FMT_S16_LE:
+	    xmms_afmt=AFMT_S16_LE;
+	    break;
+	case FMT_S16_BE:
+	    xmms_afmt=AFMT_S16_BE;
+	    break;
+    }
+    xmms_samplerate=rate;
+    xmms_channels=nch;
+    return 1;
+}
+
+static void disk_write(void *ptr, int length) {
+	pthread_mutex_lock(&xmms_mutex);
+	written += length;
+	memcpy(&xmms_audiobuffer[xmms_audiopos],ptr,length);
+	xmms_audiopos+=length;
+	pthread_mutex_unlock(&xmms_mutex);
+}
+
+static OutputPlugin xmms_output_plugin =
+{
+	NULL,
+	NULL,
+	"Mplayer output interface Plugin ", /* Description */
+	disk_init,
+	NULL,			/* about */
+	NULL,			/* configure */
+	NULL,			/* get_volume */
+	NULL,			/* set_volume */
+	disk_open,
+	disk_write,
+	disk_close,
+	disk_flush,
+	disk_pause,
+	disk_free,
+	disk_playing,
+	disk_get_output_time,
+	disk_get_output_time
+};
+
+
+
+typedef struct {
+    uint32_t spos;
+    InputPlugin* ip;
+}  xmms_priv_t;
+
+static InputPlugin* input_plugins[100];
+static int no_plugins=0;
+
+/* Dummy functions  */
+static int input_get_vis_type(){return 0;}
+//static void input_add_vis(int time, unsigned char *s, InputVisType type){}
+static void input_add_vis_pcm(int time, AFormat fmt, int nch, int length, void *ptr){}
+//static void input_update_vis(gint time){}
+//static gchar *input_get_info_text(void){return NULL;}
+static void input_set_info_text(char * text){}
+static void input_set_info(char* ha,int a, int b, int c, int d){};
+/* Dummy functions  END*/
+
+static void init_plugins(){
+    DIR *dir;
+    struct dirent *ent;
+    
+    no_plugins=0;
+
+    dir = opendir(XMMS_INPUT_PLUGIN_DIR);
+    if (!dir) return;
+    
+    while ((ent = readdir(dir)) != NULL){
+	char filename[strlen(XMMS_INPUT_PLUGIN_DIR)+strlen(ent->d_name)+4];
+	void* handle;
+	sprintf(filename,XMMS_INPUT_PLUGIN_DIR "/%s",ent->d_name);
+	handle=dlopen(filename, RTLD_NOW);
+	if(handle){
+	    void *(*gpi) (void);
+	    gpi=dlsym(handle, "get_iplugin_info");
+	    if(gpi){
+		InputPlugin *p=gpi();
+		printf("XMMS: found plugin: %s (%s)\n",ent->d_name,p->description);
+		p->handle = handle;
+		p->filename = strdup(filename);
+		p->get_vis_type = input_get_vis_type;
+		p->add_vis_pcm = input_add_vis_pcm;
+		p->set_info = input_set_info;
+		p->set_info_text = input_set_info_text;
+		if(p->init) p->init();
+		input_plugins[no_plugins++]=p;
+	    } else
+		dlclose(handle);
+	}
+    }
+    closedir(dir);
+}
+
+static void cleanup_plugins(){
+    while(no_plugins>0){
+	--no_plugins;
+	printf("XMMS: Closing plugin %s\n",input_plugins[no_plugins]->filename);
+	if(input_plugins[no_plugins]->cleanup)
+	    input_plugins[no_plugins]->cleanup();
+	dlclose(input_plugins[no_plugins]->handle);
+    }
+}
+
+extern void resync_audio_stream(sh_audio_t *sh_audio);
+
+int demux_xmms_open(demuxer_t* demuxer) {
+  InputPlugin* ip = NULL;
+  sh_audio_t* sh_audio;
+  WAVEFORMATEX* w;
+  xmms_priv_t *priv;
+  int i;
+
+  init_plugins();
+  for(i=0;i<no_plugins;i++){
+      if (input_plugins[i]->is_our_file(demuxer->stream->url)){
+          ip=input_plugins[i]; break;
+      }
+  }
+  if(!ip) return 0; // no plugin to handle this...
+  
+  pthread_mutex_init(&xmms_mutex,NULL);    
+
+  priv=(xmms_priv_t *)malloc(sizeof(xmms_priv_t));
+  memset(priv,0,sizeof(xmms_priv_t));
+  priv->ip=ip;
+
+  memset(xmms_audiobuffer,0,XMMS_PACKETSIZE);
+
+  xmms_channels=0;
+  sh_audio = new_sh_audio(demuxer,0);
+  sh_audio->wf = w = (WAVEFORMATEX*)malloc(sizeof(WAVEFORMATEX));
+  w->wFormatTag = sh_audio->format = format;
+      
+  demuxer->movi_start = 0;
+  demuxer->movi_end = 100;
+  demuxer->audio->id = 0;
+  demuxer->audio->sh = sh_audio;
+  demuxer->priv=priv;
+  sh_audio->ds = demuxer->audio;
+
+  xmms_output_plugin.init();
+  ip->get_song_info(demuxer->stream->url,&xmms_title,&xmms_length);
+  if (xmms_length<=0) demuxer->seekable=0;
+//  printf("XMMS song title='%s' length=%d\n",xmms_title,xmms_length);
+//  input_play(demuxer->stream->url);
+  ip->output = &xmms_output_plugin;
+  ip->play_file(demuxer->stream->url);
+
+  mp_msg(MSGT_DEMUX,MSGL_INFO,"Waiting for the XMMS plugin to start playback of '%s'...\n",demuxer->stream->url);
+  while (xmms_channels==0) {
+    usleep(10000);
+    if(ip->get_time()<0) return 0;
+  }
+  sh_audio->sample_format= xmms_afmt;
+  switch (xmms_afmt) {
+    case AFMT_S16_LE:
+    case AFMT_S16_BE:
+    case AFMT_U16_LE:
+    case AFMT_U16_BE:
+        sh_audio->samplesize = 2;
+	break;
+    default:
+	sh_audio->samplesize = 1;
+  }
+  w->wBitsPerSample = sh_audio->samplesize*8;
+  w->nChannels = sh_audio->channels = xmms_channels;
+  w->nSamplesPerSec = sh_audio->samplerate = xmms_samplerate; 
+  w->nAvgBytesPerSec = xmms_samplerate*sh_audio->channels*sh_audio->samplesize;
+  w->nBlockAlign = sh_audio->samplesize*sh_audio->channels;
+  w->cbSize = 0;
+  
+  return 1;
+}
+
+int demux_xmms_fill_buffer(demuxer_t* demuxer, demux_stream_t *ds) {
+  sh_audio_t *sh_audio = demuxer->audio->sh;
+  xmms_priv_t *priv=demuxer->priv;
+  demux_packet_t*  dp;
+
+  while (xmms_audiopos<XMMS_PACKETSIZE/2) {
+    if(priv->ip->get_time()<0) return 0;
+    usleep(1000);    
+  }
+
+  pthread_mutex_lock(&xmms_mutex);
+  dp = new_demux_packet(XMMS_PACKETSIZE/2);
+  ds->pts = priv->spos / (float)(sh_audio->wf->nAvgBytesPerSec);
+  ds->pos = priv->spos;
+  priv->spos+=XMMS_PACKETSIZE/2;
+  memcpy(dp->buffer,xmms_audiobuffer,XMMS_PACKETSIZE/2);
+  memcpy(xmms_audiobuffer,&xmms_audiobuffer[XMMS_PACKETSIZE/2],xmms_audiopos-XMMS_PACKETSIZE/2);
+  xmms_audiopos-=XMMS_PACKETSIZE/2;
+  pthread_mutex_unlock(&xmms_mutex);
+
+  ds_add_packet(ds,dp);
+  
+  return 1;
+}
+
+void demux_xmms_seek(demuxer_t *demuxer,float rel_seek_secs,int flags){
+  stream_t* s = demuxer->stream;
+  sh_audio_t* sh_audio = demuxer->audio->sh;
+  xmms_priv_t *priv=demuxer->priv;
+  float pos;
+
+  if(priv->ip->get_time()<0) return;
+  
+  pos = (flags & 1) ? 0 : priv->spos / (float)(sh_audio->wf->nAvgBytesPerSec);
+  if (flags & 2) 
+    pos+= rel_seek_secs*xmms_length;
+  else 
+    pos+= rel_seek_secs;  
+
+  if (pos<0) pos=0;
+  if (pos>=xmms_length) pos=xmms_length-1;
+
+  priv->ip->seek((pos<0)?0:(int)pos);
+  priv->spos=pos * (float)(sh_audio->wf->nAvgBytesPerSec);;
+}
+
+int demux_close_xmms(demuxer_t* demuxer) {
+  xmms_priv_t *priv=demuxer->priv;
+  priv->ip->stop();
+  free(priv); demuxer->priv=NULL;
+  cleanup_plugins();
+  return 1;
+}
+
+int demux_xmms_control(demuxer_t *demuxer,int cmd, void *arg){
+    demux_stream_t *d_video=demuxer->video;
+    sh_audio_t *sh_audio=demuxer->audio->sh;
+    xmms_priv_t *priv=demuxer->priv;
+
+    switch(cmd) {
+	case DEMUXER_CTRL_GET_TIME_LENGTH:
+	    if (xmms_length<=0) return DEMUXER_CTRL_DONTKNOW;
+	    *((unsigned long *)arg)=(unsigned long)xmms_length/1000;
+	    return DEMUXER_CTRL_GUESS;
+
+	case DEMUXER_CTRL_GET_PERCENT_POS:
+	    if (xmms_length<=0) 
+    		return DEMUXER_CTRL_DONTKNOW;
+    	    *((int *)arg)=(int)( priv->spos / (float)(sh_audio->wf->nAvgBytesPerSec) / xmms_length );
+	    return DEMUXER_CTRL_OK;
+
+	default:
+	    return DEMUXER_CTRL_NOTIMPL;
+    }
+}