workbench/devs/AHI/Drivers/Alsa/alsa-playslave.c

   1 /*
   2     Copyright © 2015, The AROS Development Team. All rights reserved.
   3     $Id$
   4 */
   5
   6 #include <config.h>
   7
   8 #include <devices/ahi.h>
   9 #include <exec/execbase.h>
  10 #include <libraries/ahi_sub.h>
  11
  12 #include "DriverData.h"
  13 #include "library.h"
  14
  15 #define dd ((struct AlsaData*) AudioCtrl->ahiac_DriverData)
  16
  17 #define min(a,b) ( (a) < (b) ? (a) : (b) )
  18
  19 /******************************************************************************
  20 ** The slave process **********************************************************
  21 ******************************************************************************/
  22
  23 #undef SysBase
  24
  25 void Slave( struct ExecBase* SysBase );
  26
  27 #include <aros/asmcall.h>
  28
  29 AROS_UFH3(LONG, SlaveEntry,
  30       AROS_UFHA(STRPTR, argPtr, A0),
  31       AROS_UFHA(ULONG, argSize, D0),
  32       AROS_UFHA(struct ExecBase *, SysBase, A6))
  33 {
  34    AROS_USERFUNC_INIT
  35    Slave( SysBase );
  36    AROS_USERFUNC_EXIT
  37 }
  38
  39 void
  40 Slave( struct ExecBase* SysBase )
  41 {
  42   struct AHIAudioCtrlDrv* AudioCtrl;
  43   struct DriverBase*      AHIsubBase;
  44   struct AlsaBase*        AlsaBase;
  45   BOOL                    running;
  46   ULONG                   signals;
  47   LONG                    framesready = 0;
  48   APTR                    framesptr = NULL;
  49
  50   AudioCtrl  = (struct AHIAudioCtrlDrv*) FindTask(NULL)->tc_UserData;
  51   AHIsubBase = (struct DriverBase*) dd->ahisubbase;
  52   AlsaBase   = (struct AlsaBase*) AHIsubBase;
  53
  54   dd->slavesignal = AllocSignal( -1 );
  55
  56   if( dd->slavesignal != -1 )
  57   {
  58     // Everything set up. Tell Master we're alive and healthy.
  59
  60     Signal( (struct Task*) dd->mastertask,
  61             1L << dd->mastersignal );
  62
  63     running = TRUE;
  64
  65     while( running )
  66     {
  67       signals = SetSignal(0L,0L);
  68
  69       if( signals & ( SIGBREAKF_CTRL_C | (1L << dd->slavesignal) ) )
  70       {
  71         running = FALSE;
  72       }
  73       else
  74       {
  75         LONG framesfree = 0;
  76
  77         while(TRUE)
  78         {
  79           framesfree = ALSA_Avail(dd->alsahandle);
  80           if (framesfree > 1024)
  81             break;
  82           Delay(1);
  83         }
  84
  85         /* Loop until alsa buffer is filled */
  86         while (framesfree > 0)
  87         {
  88           LONG written;
  89
  90           if (framesready == 0)
  91           {
  92             CallHookPkt(AudioCtrl->ahiac_PlayerFunc, AudioCtrl, NULL );
  93             CallHookPkt(AudioCtrl->ahiac_MixerFunc, AudioCtrl, dd->mixbuffer );
  94             framesready = AudioCtrl->ahiac_BuffSamples;
  95             framesptr = dd->mixbuffer;
  96           }
  97
  98           written = ALSA_Write(dd->alsahandle, framesptr, min(framesready, framesfree));
  99
 100           framesready -= written;
 101           framesfree  -= written;
 102           framesptr += written * 4;
 103
 104           CallHookA(AudioCtrl->ahiac_PostTimerFunc, (Object*) AudioCtrl, 0);
 105         }
 106       }
 107     }
 108   }
 109
 110   FreeSignal( dd->slavesignal );
 111   dd->slavesignal = -1;
 112
 113   Forbid();
 114
 115   // Tell the Master we're dying
 116
 117   Signal( (struct Task*) dd->mastertask, 1L << dd->mastersignal );
 118
 119   dd->slavetask = NULL;
 120
 121   // Multitaking will resume when we are dead.
 122 }