/*************************************
  Threaded sound driver system
**************************************/

// comminicates with sound sub-system via shared memory

#include "macs.hpp"
#include "sound.hpp"
#include "readwav.hpp"
#include "dprint.hpp"
#include "jmalloc.hpp"
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include "timing.hpp"
#include <sys/ipc.h>
#include <sys/shm.h>
#include <signal.h>
#include <unistd.h>

enum { SFXCMD_QUIT,
       SFXCMD_REGISTER,
       SFXCMD_UNREGISTER,
       SFXCMD_PLAY
     };

#define DIN_NAME  "/tmp/sfxdrv.signal"
#define DOUT_NAME "/tmp/sfxdrv.command"

class sfx_handle
{
  public :
  int shm_id;
  sound_effect *me;
  sfx_handle   *next;  
  void         *user_data_pointer;
  void         *shm_data_pointer;
  sfx_handle(sound_effect *Me, sfx_handle *Next, void  *UData, void  *SData, int Shm_id)
  { me=Me;
    next=Next;
    shm_id=Shm_id;
    user_data_pointer=UData;
    shm_data_pointer=SData;
  }
} ;

static sfx_handle *sfx_list=NULL;
static ushort last_allocated_sfx_id=0;
static int sfx_driver_out_fd=-1,sfx_driver_in_fd=-1;
static int sdriver_pid=0;


static void kill_sound_driver()
{
  if (sfx_driver_out_fd>=0)
  {
    uchar cmd=SFXCMD_QUIT;        // failed, tell the driver good-bye
    write(sfx_driver_out_fd,&cmd,1);
    close(sfx_driver_out_fd);
    close(sfx_driver_in_fd);
    sfx_driver_out_fd=-1;

    milli_wait(10);
    kill(sdriver_pid,SIGUSR1);
    unlink(DIN_NAME);
    unlink(DOUT_NAME);
  }
}



#ifdef __sgi
static void sfx_clean_up(...)
#else
static void sfx_clean_up(int why)      // on exit unattach all shared memory links
#endif
{  
  while (sfx_list)
  {
    if (sfx_driver_out_fd>=0)
    {
      int fail=0;
      uchar cmd=SFXCMD_UNREGISTER;
      if (write(sfx_driver_out_fd,&cmd,1)!=1)
        fail=1;
      else if (write(sfx_driver_out_fd,&sfx_list->shm_id,
		     sizeof(sfx_list->shm_id))!=sizeof(sfx_list->shm_id))
        fail=1;
      if (fail) 
      { kill_sound_driver(); }
    }

    shmdt((char *)sfx_list->shm_data_pointer);  // detach the shared memory from us

    sfx_handle *last=sfx_list;
    sfx_list=sfx_list->next;
    jfree(last);
  }
}



#define TOTAL_SIGS 29

int sigs[TOTAL_SIGS]={SIGHUP,SIGINT,SIGQUIT,SIGILL,SIGTRAP,
		      SIGABRT,SIGIOT,SIGBUS,SIGFPE,SIGKILL,
		      SIGUSR1,SIGSEGV,SIGUSR2,SIGPIPE,SIGALRM,
		      SIGTERM,SIGCHLD,SIGCONT,SIGSTOP,
		      SIGTSTP,SIGTTIN,SIGTTOU,SIGIO,
		      SIGURG,SIGXCPU,SIGXFSZ,SIGVTALRM,SIGPROF,
		      SIGWINCH};

#include <errno.h>

sound_effect::sound_effect(char *filename)
{
  if (sfx_driver_out_fd>=0)
  {
    long sample_speed;
    void *dat=read_wav(filename,sample_speed,size); 

    int id=shmget(IPC_PRIVATE,size,IPC_CREAT | 0777);
    if (id==-1)
    {
      dprintf("Unable to allocate a shared memory id, please clean up\n");
      jfree(dat);
      data=NULL;
    } else
    {
      void *shm_addr=shmat(id,NULL,0);  // attach as read/write
      if ((long)shm_addr==-1)                   // if not able to attach
      {
	dprintf("shmat failed, too many shared memory segements or permission denied\n");
	if (shmctl(id,IPC_RMID,NULL)!=0)
	  dprintf("shmctl failed, why?\n");
	jfree(dat);
	data=NULL;
      } else
      {
	memcpy(shm_addr,dat,size);
	jfree(dat);

	int fail=0;
	uchar cmd=SFXCMD_REGISTER;
	if (write(sfx_driver_out_fd,&cmd,1)==0)
	  fail=1;
	else if (write(sfx_driver_out_fd,&id,sizeof(id))!=sizeof(id))
	  fail=1;
	else if (write(sfx_driver_out_fd,&size,sizeof(size))!=sizeof(size))
	  fail=1;
	else if (read(sfx_driver_in_fd,&cmd,1)!=1)
	  fail=1;
	else if (cmd!=1)    // did we get an 'OK' back so when can delete the shm ID?
	  fail=1;

	if (shmctl(id,IPC_RMID,NULL)!=0)
	  dprintf("shmctl failed, why?\n");

	if (fail)
	{
	  kill_sound_driver();
	  shmdt((char *)shm_addr);
	  data=NULL;
	} else 
	{
	  sfx_list=new sfx_handle(this,sfx_list,dat,shm_addr,id);	
	  data=(void *)sfx_list;
	}
      }      
    }
  }
}


sound_effect::~sound_effect()
{
  if (sfx_driver_out_fd>=0 && data)
  { 
    sfx_handle *h=(sfx_handle *)data;
    uchar cmd=SFXCMD_UNREGISTER;
    int fail=0;
    if (write(sfx_driver_out_fd,&cmd,1)!=1)
      fail=1;
    else if (write(sfx_driver_out_fd,&h->shm_id,sizeof(h->shm_id))!=sizeof(h->shm_id))
      fail=1;

    if (fail)
    { kill_sound_driver(); }

    shmdt((char *)h->shm_data_pointer);
      
  }
}


void sound_effect::play(int volume, int pitch, int panpot)
{
  if (sfx_driver_out_fd>=0 && data)
  {   
    sfx_handle *h=(sfx_handle *)data;
    uchar cmd=SFXCMD_PLAY;
    int fail=0;
    if (write(sfx_driver_out_fd,&cmd,1)!=1)
      fail=1;
    else if (write(sfx_driver_out_fd,&h->shm_id,sizeof(h->shm_id))!=sizeof(h->shm_id))
      fail=1;
    else if (write(sfx_driver_out_fd,&volume,sizeof(volume))!=sizeof(volume))
       fail=1;

    if (fail) 
       kill_sound_driver();
  }
}


int sound_init(int argc, char **argv) 
{
  int i;
  for (i=1;i<argc;i++)
  {
    if (!strcmp(argv[i],"-nosound"))
    {
      dprintf("sound : disabled with (-nosound)\n");
      sfx_driver_out_fd=-1;
      return 0;
    }
  }

#ifdef __linux__
  FILE *sfx_driver_fp=popen("lnx_sdrv","r");
#else
  FILE *sfx_driver_fp=popen("sgi_sdrv","r");
#endif

  if (!sfx_driver_fp)
  {
    dprintf("Error starting sound effect, could not run sgisfx_driver\n"
	    "make sure it is in your path and you execute permission\n");
    sfx_driver_out_fd=-1;
    return 0;
  }

  char str[100];
  if (!fgets(str,100,sfx_driver_fp) || !sscanf(str,"%d",&sdriver_pid) || sdriver_pid<0)
  {
    pclose(sfx_driver_fp);
    dprintf("sound effects driver returned failure, sound effects disabled\n");
    pclose(sfx_driver_fp);
    sfx_driver_out_fd=-1;
    return 0;
  } else
  {
    pclose(sfx_driver_fp);

    do
    { milli_wait(50);
    } while (access(DIN_NAME,R_OK)); 
    sfx_driver_in_fd=open(DIN_NAME,O_RDWR);

    do
    { milli_wait(50);
    } while (access(DOUT_NAME,W_OK)); 
    fprintf(stderr,"opening %s for writing\n",DOUT_NAME);
    sfx_driver_out_fd=open(DOUT_NAME,O_RDWR);

    for (int i=0;i<TOTAL_SIGS;i++)
       signal(sigs[i],sfx_clean_up);

    atexit(sound_uninit);
  }
  
  return SFX_INITIALIZED;
}


void sound_uninit()
{
  if (sfx_driver_out_fd>=0)
  {
    if (sfx_list)
    {
#ifdef __sgi
      sfx_clean_up();
#else
      sfx_clean_up(1);
#endif
    }
   
    uchar cmd;
    cmd=SFXCMD_QUIT;
    write(sfx_driver_out_fd,&cmd,1);   // send quit commmand to the driver
    close(sfx_driver_out_fd);          // close connection
    close(sfx_driver_in_fd);          // close connection
    sfx_driver_out_fd=-1;
    sfx_driver_in_fd=-1;
  }
}






song::song(char *filename) { ; }

void song::play(unsigned char volume) { ; }
int song::playing() { return 0; }
void song::set_volume(int vol)  { ; }
void song::stop(long fadeout_time) { ;  }
int playing() { return 0; }
song::~song() { ; }