workbench/libs/camd/receiverproc.c

   1 /*
   2     Copyright © 1995-2004, The AROS Development Team. All rights reserved.
   3     $Id$
   4 */
   5
   6 #include <proto/dos.h>
   7 #include <proto/exec.h>
   8 #include <dos/dostags.h>
   9 #include <dos/dos.h>
  10 #include <proto/utility.h>
  11
  12 #include "camd_intern.h"
  13
  14
  15 struct DriverData *driverdatatemp=NULL;
  16
  17 SAVEDS void ReceiverFunc(void){
  18         ULONG sig;
  19         struct DriverData *driverdata=driverdatatemp;
  20
  21         driverdata->ReceiverSig=AllocSignal(-1);
  22         if(driverdata->ReceiverSig==-1){
  23                 driverdata->isReceiverProcessAlive=2;
  24                 return;
  25         }
  26
  27         driverdata->isReceiverProcessAlive=1;
  28
  29         for(;;){
  30                 sig=Wait(
  31                         1L<<driverdata->ReceiverSig |
  32                         SIGBREAKF_CTRL_C
  33                 );
  34
  35                 if(sig&1L<<driverdata->ReceiverSig){
  36                         while(driverdata->unpicked>0){
  37                                 Receiver_first(driverdata);
  38                         }
  39                 }
  40                 if(sig&SIGBREAKF_CTRL_C) break;
  41         }
  42
  43         FreeSignal(driverdata->ReceiverSig);
  44
  45         driverdata->isReceiverProcessAlive=0;
  46
  47 }
  48
  49
  50 /* CL_Linkages must be locked first (exclusive). */
  51
  52 BOOL CreateReceiverProc(
  53         struct DriverData *driverdata,
  54         char *inname,
  55         LONG portnum,
  56         ULONG *ErrorCode,
  57         struct CamdBase *CamdBase
  58 ){
  59         struct Process *process;
  60         char *name;
  61
  62         name=AllocVec(mystrlen(inname)+70,MEMF_ANY | MEMF_PUBLIC);
  63         if(name==NULL){
  64                 if(ErrorCode!=NULL){
  65                         *ErrorCode=CME_NoMem;
  66                 }
  67                 return FALSE;
  68         }
  69
  70         mysprintf(CamdBase,name,"CAMD ReceiverProc %s %ld",inname,portnum);
  71
  72
  73         driverdatatemp=driverdata;
  74
  75         driverdata->isReceiverProcessAlive=0;
  76
  77         process=CreateNewProcTags(
  78                 NP_Entry, (IPTR) ReceiverFunc,
  79                 NP_Name, (IPTR) name,
  80                 NP_Priority,36,
  81                 TAG_END
  82         );
  83         if(process==NULL){
  84                 if(ErrorCode!=NULL){
  85                         *ErrorCode=CME_NoMem;
  86                 }
  87                 FreeVec(name);
  88                 return FALSE;
  89         }
  90
  91         while(driverdata->isReceiverProcessAlive == 0){
  92                 Delay(1);
  93         }
  94
  95         if(driverdata->isReceiverProcessAlive==2){
  96                 driverdata->isReceiverProcessAlive=0;
  97                 if(ErrorCode!=NULL){
  98                         *ErrorCode=CME_NoSignals;
  99                 }
 100                 FreeVec(name);
 101                 return FALSE;
 102         }
 103
 104         driverdata->ReceiverProc=process;
 105         driverdata->ReceiverProcName=name;
 106
 107         return TRUE;
 108 }
 109
 110 /* CL_Linkages must be locked first. */
 111
 112 void EndReceiverProc(
 113         struct DriverData *driverdata,
 114         struct CamdBase *CamdBase
 115 ){
 116         Signal((struct Task *)driverdata->ReceiverProc,SIGBREAKF_CTRL_C);
 117         while(driverdata->isReceiverProcessAlive==1) Delay(1);
 118         FreeVec(driverdata->ReceiverProcName);
 119 }
 120