workbench/devs/audio/libfunctions.c

   1 /*
   2      Copyright 2010, The AROS Development Team. All rights reserved.
   3      $Id$
   4  */
   5
   6 /*
   7  * audio.device
   8  *
   9  * by Nexus Development 2003
  10  * coded by Emanuele Cesaroni
  11  *
  12  * $Id$
  13  */
  14
  15 #include "audio_intern.h"
  16 #define DEBUG 0
  17 #include <aros/debug.h>
  18
  19 #include <aros/symbolsets.h>
  20
  21 #include LC_LIBDEFS_FILE
  22
  23 /***********************************************************************/
  24
  25 AROS_LH1(void, beginio,
  26         AROS_LHA(struct IOAudio *, ioreq, A1),
  27         struct audiobase *, AudioDevice, 5, Audio)
  28 {
  29     AROS_LIBFUNC_INIT
  30
  31     ioreq->ioa_Request.io_Error = 0;
  32     ioreq->ioa_Request.io_Message.mn_Node.ln_Type = NT_MESSAGE;
  33
  34     D(bug("BeginIO: Task 0x%lx\n", FindTask(NULL)));
  35
  36     switch(ioreq->ioa_Request.io_Command)
  37     {
  38         case CMD_CLEAR:
  39         D(bug("CMD_CLEAR\n"));
  40         audio_CLEAR(ioreq);
  41         break;
  42
  43         case CMD_FLUSH:
  44         D(bug("CMD_FLUSH\n"));
  45         audio_FLUSH(ioreq);
  46         break;
  47
  48         case CMD_READ:
  49         D(bug("CMD_READ\n"));
  50         audio_READ(ioreq);
  51         break;
  52
  53         case CMD_RESET:
  54         D(bug("CMD_RESET\n"));
  55         audio_RESET(ioreq);
  56         break;
  57
  58         case CMD_START:
  59         D(bug("CMD_START\n"));
  60         audio_START(ioreq);
  61         break;
  62
  63         case CMD_STOP:
  64         D(bug("CMD_STOP\n"));
  65         audio_STOP(ioreq);
  66         break;
  67
  68         case CMD_UPDATE:
  69         D(bug("CMD_UPDATE\n"));
  70         audio_UPDATE(ioreq);
  71         break;
  72
  73         case CMD_WRITE:
  74         D(bug("CMD_WRITE\n"));
  75         audio_WRITE(ioreq);
  76         break;
  77
  78         case ADCMD_ALLOCATE:
  79         audio_ALLOCATE(ioreq);
  80         break;
  81
  82         case ADCMD_FINISH:
  83         D(bug("CMD_FINISH\n"));
  84         audio_FINISH(ioreq);
  85         break;
  86
  87         case ADCMD_FREE:
  88         audio_FREE(ioreq);
  89         break;
  90
  91         case ADCMD_LOCK:
  92         audio_LOCK(ioreq);
  93         break;
  94
  95         case ADCMD_PERVOL:
  96         D(bug("CMD_PERVOL\n"));
  97         audio_PERVOL(ioreq);
  98         break;
  99
 100         case ADCMD_SETPREC:
 101         D(bug("CMD_SETPREC\n"));
 102         audio_SETPREC(ioreq);
 103         break;
 104
 105         case ADCMD_WAITCYCLE:
 106         D(bug("CMD_WAITCYCLE\n"));
 107         audio_WAITCYCLE(ioreq);
 108         break;
 109
 110         default:
 111         ((struct IOAudio*) ioreq)->ioa_Request.io_Error = IOERR_NOCMD;
 112
 113         if((ioreq->ioa_Request.io_Flags & IOF_QUICK) == 0)
 114         {
 115             ReplyMsg(&ioreq->ioa_Request.io_Message);
 116         }
 117
 118         break;
 119     }
 120
 121     AROS_LIBFUNC_EXIT
 122 }
 123
 124 /***********************************************************************/
 125
 126 AROS_LH1(LONG, abortio,
 127         AROS_LHA(struct IOAudio *, ioreq, A1),
 128         struct audiobase *, AudioDevice, 6, Audio)
 129 {
 130     AROS_LIBFUNC_INIT
 131
 132     audio_ABORTIO(ioreq,global_eta);
 133
 134     return 0;
 135
 136     AROS_LIBFUNC_EXIT
 137 }
 138
 139 /***********************************************************************/
 140 static int GM_UNIQUENAME( Init)
 141 (LIBBASETYPEPTR AudiolDevice)
 142 {
 143     memset(&emasys0.es_devsem,0,sizeof(struct SignalSemaphore));
 144     InitSemaphore(&emasys0.es_devsem);
 145
 146     return TRUE;
 147 }
 148
 149 /***********************************************************************/
 150 static int DevClose(struct IOAudio *MyIORequest, LIBBASETYPEPTR MyDevBase)
 151 {
 152     UWORD Command;
 153     UBYTE Flags;
 154     BYTE Error;
 155     struct MsgPort *Msgport;
 156     struct Unit *Unita;
 157
 158     ObtainSemaphore(&emasys0.es_devsem);
 159
 160     D(bug("NEWD: CLOSEDEVICE called\n"));
 161
 162     Command = MyIORequest->ioa_Request.io_Command;
 163     Flags = MyIORequest->ioa_Request.io_Flags;
 164     Error = MyIORequest->ioa_Request.io_Error;
 165     Msgport = MyIORequest->ioa_Request.io_Message.mn_ReplyPort;
 166     Unita = MyIORequest->ioa_Request.io_Unit;
 167
 168     MyIORequest->ioa_Request.io_Unit = (struct Unit*) 15;
 169     MyIORequest->ioa_Request.io_Command = ADCMD_FREE;
 170     //MyIORequest->ioa_Request.io_Message.mn_ReplyPort = NULL;
 171     MyIORequest->ioa_Request.io_Flags = IOF_QUICK;
 172     //MyIORequest->ioa_Request.io_Flags                = 0;
 173     BeginIO(&MyIORequest->ioa_Request);
 174     WaitIO(&MyIORequest->ioa_Request);
 175
 176     //WaitPort(MyIOreuest->ioa_Request.io_Message->mn_ReplyPort);
 177
 178     //MyIORequest->ioa_Request.io_Flags   = 0;                                                          // I try the waiting method.
 179     //DoIO(&MyIORequest->ioa_Request);
 180     //BeginIO(&MyIORequest->ioa_Request);
 181     //WaitIO(&MyIORequest->ioa_Request);
 182
 183     MyIORequest->ioa_Request.io_Device = (struct Device*) -1;
 184     MyIORequest->ioa_Request.io_Command = Command;
 185     MyIORequest->ioa_Request.io_Flags = Flags;
 186     MyIORequest->ioa_Request.io_Error = Error;
 187     MyIORequest->ioa_Request.io_Message.mn_ReplyPort = Msgport;
 188     MyIORequest->ioa_Request.io_Unit = Unita;
 189
 190     // If this is the last client closing, free allocated resources
 191     if (MyDevBase->Dev.dd_Library.lib_OpenCnt == 1)
 192     {
 193         FreeSLAVE(MyIORequest); /* break Forbid() */// 24.9 Changed the order so actually never modify this order!!!!!!
 194         FreeESYS(); // ok
 195     }
 196
 197     ReleaseSemaphore(&emasys0.es_devsem);
 198     return TRUE;
 199 }
 200
 201 /***********************************************************************/
 202 static int GM_UNIQUENAME( Open)
 203 (
 204         LIBBASETYPEPTR AudioDevice,
 205         struct IORequest *ioreq,
 206         ULONG unitnum,
 207         ULONG flags
 208 )
 209 {
 210     UBYTE tflags;
 211     UWORD oldcmd;
 212     struct IOAudio * audioio = (struct IOAudio *)ioreq;
 213
 214     ObtainSemaphore(&emasys0.es_devsem);
 215
 216     ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 217     // 24.9 Ok each time OpenDevice() is called do these: set no error.
 218
 219     audioio->ioa_Request.io_Error = 0; // Ok, called for now no errors.
 220
 221     ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 222     // 24.9 First thing.
 223     //      It the device is opened for the first time it needs to have the ESYS ready to accepts new task arriving.
 224     //      So if this is the first time please inits the ESYS system before all the other.
 225
 226     if(AudioDevice->Dev.dd_Library.lib_OpenCnt == 0)
 227     {
 228         audioio->ioa_Request.io_Error = IOERR_OPENFAIL;
 229
 230         if(InitESYS() == OKEY)
 231         {
 232             ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 233             // 24.9 Well if no error i have the ESYS ready, and a task into the tasklist system.
 234             //      So please if the slave process isn't ready let
 235             //      it ready when the device is for the first time opened.
 236             if(InitSLAVE(audioio) == OKEY)
 237             {
 238                 audioio->ioa_Request.io_Error = 0;
 239             }
 240         }
 241     }
 242
 243     ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
 244     // 24.9     This a well know piece of code still valid.
 245     //
 246     audioio->ioa_Request.io_Device = (struct Device*) AudioDevice;
 247
 248     if(audioio->ioa_Request.io_Error == 0)
 249     {
 250         if(audioio->ioa_Length)
 251         {
 252             D(bug("NEWD: ADCMD_ALLOCATE during opendevice\n"));
 253
 254             tflags = audioio->ioa_Request.io_Flags;
 255             oldcmd = audioio->ioa_Request.io_Command;
 256             audioio->ioa_Request.io_Command = ADCMD_ALLOCATE;
 257             audioio->ioa_Request.io_Flags = (IOF_QUICK | ADIOF_NOWAIT);
 258             //MyIORequest->ioa_Request.io_Flags   = 0;                                                  // add.
 259             BeginIO(&audioio->ioa_Request); // add
 260             WaitIO(&audioio->ioa_Request); // add
 261
 262             D(bug("NEWD: ADCMD_ALLOCATE after the well know situation\n"));
 263
 264             //DoIO(&MyIORequest->ioa_Request);                                                                                  // prev
 265             audioio->ioa_Request.io_Flags = tflags;
 266             audioio->ioa_Request.io_Command = oldcmd;
 267         }
 268     }
 269
 270     if(audioio->ioa_Request.io_Error == 0)
 271     {
 272         AudioDevice->DevState &= ~DEVF_DELEXP;
 273     }
 274     else
 275     {
 276         DevClose(audioio, AudioDevice);
 277     }
 278
 279     ReleaseSemaphore(&emasys0.es_devsem);
 280
 281     return TRUE;
 282 }
 283
 284 /***********************************************************************/
 285
 286 static int GM_UNIQUENAME( Close)
 287 (
 288         LIBBASETYPEPTR AudioDevice,
 289         struct IORequest *ioreq
 290 )
 291 {
 292     return DevClose((struct IOAudio *)ioreq, AudioDevice);
 293 }
 294
 295 ADD2INITLIB(GM_UNIQUENAME(Init), 0)
 296 ADD2OPENDEV(GM_UNIQUENAME(Open), 0)
 297 ADD2CLOSEDEV(GM_UNIQUENAME(Close), 0)