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 <aros/debug.h>
   7 #include <config.h>
   8
   9 #include <devices/ahi.h>
  10 #include <exec/execbase.h>
  11 #include <libraries/ahi_sub.h>
  12
  13 #include "DriverData.h"
  14 #include "library.h"
  15
  16 #include "alsa-bridge/alsa.h"
  17
  18 #define dd ((struct AlsaData*) AudioCtrl->ahiac_DriverData)
  19
  20 #define min(a,b) ( (a) < (b) ? (a) : (b) )
  21
  22 /******************************************************************************
  23 ** The slave process **********************************************************
  24 ******************************************************************************/
  25
  26 #undef SysBase
  27
  28 void Slave( struct ExecBase* SysBase );
  29
  30 #include <aros/asmcall.h>
  31
  32 AROS_UFH3(LONG, SlaveEntry,
  33       AROS_UFHA(STRPTR, argPtr, A0),
  34       AROS_UFHA(ULONG, argSize, D0),
  35       AROS_UFHA(struct ExecBase *, SysBase, A6))
  36 {
  37    AROS_USERFUNC_INIT
  38    Slave( SysBase );
  39    AROS_USERFUNC_EXIT
  40 }
  41
  42 #include <hardware/intbits.h>
  43 #include <proto/timer.h>
  44
  45 AROS_INTH1(AHITimerTickCode, struct Task *, task)
  46 {
  47     AROS_INTFUNC_INIT
  48     Signal(task, SIGBREAKF_CTRL_F);
  49     return 0;
  50
  51     AROS_INTFUNC_EXIT
  52 }
  53
  54
  55
  56 static void SmallDelay(struct ExecBase *SysBase)
  57 {
  58     struct Interrupt i;
  59
  60     i.is_Code         = (APTR)AHITimerTickCode;
  61     i.is_Data         = FindTask(0);
  62     i.is_Node.ln_Name = "AROS AHI Driver Timer Tick Server";
  63     i.is_Node.ln_Pri  = 0;
  64     i.is_Node.ln_Type = NT_INTERRUPT;
  65
  66     SetSignal(0, SIGBREAKF_CTRL_F);
  67     AddIntServer(INTB_VERTB, &i);
  68     Wait(SIGBREAKF_CTRL_F);
  69     RemIntServer(INTB_VERTB, &i);
  70 }
  71
  72 void
  73 Slave( struct ExecBase* SysBase )
  74 {
  75   struct AHIAudioCtrlDrv* AudioCtrl;
  76   struct DriverBase*      AHIsubBase;
  77   struct AlsaBase*        AlsaBase;
  78   BOOL                    running;
  79   ULONG                   signals;
  80   LONG                    framesready = 0;
  81   APTR                    framesptr = NULL;
  82
  83   AudioCtrl  = (struct AHIAudioCtrlDrv*) FindTask(NULL)->tc_UserData;
  84   AHIsubBase = (struct DriverBase*) dd->ahisubbase;
  85   AlsaBase   = (struct AlsaBase*) AHIsubBase;
  86
  87   dd->slavesignal = AllocSignal( -1 );
  88
  89   if( dd->slavesignal != -1 )
  90   {
  91     // Everything set up. Tell Master we're alive and healthy.
  92
  93     Signal( (struct Task*) dd->mastertask,
  94             1L << dd->mastersignal );
  95
  96     running = TRUE;
  97
  98     while( running )
  99     {
 100       signals = SetSignal(0L,0L);
 101
 102       if( signals & ( SIGBREAKF_CTRL_C | (1L << dd->slavesignal) ) )
 103       {
 104         running = FALSE;
 105       }
 106       else
 107       {
 108         LONG framesfree = 0;
 109         LONG readcycles = 0;
 110
 111         while(TRUE)
 112         {
 113           framesfree = ALSA_Avail(dd->alsahandle);
 114           if (framesfree == ALSA_XRUN)
 115           {
 116               D(bug("[Alsa] ALSA_Avail() == XRUN\n"));
 117               ALSA_Prepare(dd->alsahandle);
 118               framesfree = ALSA_Avail(dd->alsahandle);
 119           }
 120
 121           if (framesfree >= 64)
 122           {
 123             readcycles++;
 124             if (framesfree >= AudioCtrl->ahiac_BuffSamples)
 125               readcycles++;
 126             break;
 127           }
 128
 129           SmallDelay(SysBase);
 130         }
 131
 132         /* Loop until alsa buffer is filled */
 133         while (framesfree > 0)
 134         {
 135           LONG written;
 136
 137           if (framesready == 0)
 138           {
 139             if (readcycles == 0)
 140               break;
 141
 142             CallHookPkt(AudioCtrl->ahiac_PlayerFunc, AudioCtrl, NULL );
 143             CallHookPkt(AudioCtrl->ahiac_MixerFunc, AudioCtrl, dd->mixbuffer );
 144             framesready = AudioCtrl->ahiac_BuffSamples;
 145             framesptr = dd->mixbuffer;
 146             readcycles--;
 147           }
 148
 149           written = ALSA_Write(dd->alsahandle, framesptr, min(framesready,
 150                   framesfree));
 151           if (written == ALSA_XRUN)
 152           {
 153               D(bug("[Alsa] ALSA_Write() == XRUN %d, %d\n", framesfree, framesready));
 154               ALSA_Prepare(dd->alsahandle);
 155               written = ALSA_Write(dd->alsahandle, framesptr, min(framesready,
 156                       framesfree));
 157           }
 158
 159           framesready -= written;
 160           framesfree  -= written;
 161           framesptr += written * 4;
 162
 163           CallHookA(AudioCtrl->ahiac_PostTimerFunc, (Object*) AudioCtrl, 0);
 164         }
 165       }
 166     }
 167   }
 168
 169   FreeSignal( dd->slavesignal );
 170   dd->slavesignal = -1;
 171
 172   Forbid();
 173
 174   // Tell the Master we're dying
 175
 176   Signal( (struct Task*) dd->mastertask, 1L << dd->mastersignal );
 177
 178   dd->slavetask = NULL;
 179
 180   // Multitaking will resume when we are dead.
 181 }