workbench/libs/commodities/cxbroker.c

   1 /*
   2     Copyright © 1995-2001, The AROS Development Team. All rights reserved.
   3     $Id$
   4
   5     Desc:
   6     Lang: English
   7 */
   8
   9 /*****************************************************************************
  10
  11     NAME */
  12
  13 #define  AROS_ALMOST_COMPATIBLE
  14
  15 #ifndef  DEBUG
  16 #define  DEBUG 0
  17 #endif
  18
  19 #include "cxintern.h"
  20
  21 #include <aros/debug.h>
  22
  23 #include <devices/input.h>
  24 #include <proto/commodities.h>
  25 #include <proto/exec.h>
  26 #include <devices/inputevent.h>
  27 #include <libraries/commodities.h>
  28 #include <exec/lists.h>
  29 #include <aros/asmcall.h>
  30
  31 #ifdef __MORPHOS__
  32 extern const struct EmulLibEntry cxIHandler_Gate;
  33 #else
  34 extern struct InputEvent *cxIHandler();
  35 #endif
  36
  37
  38     AROS_LH2(CxObj *, CxBroker,
  39
  40 /*  SYNOPSIS */
  41
  42         AROS_LHA(struct NewBroker *, nb   , A0),
  43         AROS_LHA(LONG *            , error, D0),
  44
  45 /*  LOCATION */
  46
  47         struct Library *, CxBase, 6, Commodities)
  48
  49 /*  FUNCTION
  50
  51     Create a commodity broker from the specifications found in the structure
  52     pointed to by 'nb'. The NewBroker structure is described in <Libraries/
  53     Commodities.h>, see this file for more info. After the call, the
  54     NewBroker structure isn't needed anymore and may be discarded.
  55
  56     INPUTS
  57
  58     nb    --  pointer to an initialized NewBroker structure
  59     error --  pointer to a LONG where the possible error of the CxBroker
  60               function is stored (may be NULL)
  61
  62     RESULT
  63
  64     A pointer to a commodity broker, or NULL upon failure.  If 'error' is
  65     NULL, no error information is stored. The possible error types are
  66
  67     CBERR_OK       --  everything went just fine
  68
  69     CBERR_SYSERR   --  system problems, typically not enough memory
  70
  71     CBERR_DUP      --  another broker with the same name already exists
  72                        (and your nb_Unique indicates that only one is
  73                        allowed)
  74
  75     CBERR_VERSION  --  the version found in nb_Version is unknown to the
  76                        library
  77
  78     NOTES
  79
  80     EXAMPLE
  81
  82     BUGS
  83
  84     SEE ALSO
  85
  86     SetCxObjPri(), <libraries/commodities.h>
  87
  88     INTERNALS
  89
  90     HISTORY
  91
  92 ******************************************************************************/
  93
  94 {
  95     AROS_LIBFUNC_INIT
  96
  97     LONG    myerr = CBERR_OK;
  98     CxObj  *co = NULL;
  99     CxObj  *temp;
 100
 101     D(bug("Entering CxBroker\n"));
 102
 103     ObtainSemaphore(&GPB(CxBase)->cx_SignalSemaphore);
 104
 105     /* No duplicates allowed? */
 106     if (nb->nb_Unique & NBU_UNIQUE)
 107     {
 108         temp = (CxObj *)FindName(&GPB(CxBase)->cx_BrokerList, nb->nb_Name);
 109
 110         if (temp != NULL)
 111         {
 112             if(nb->nb_Unique & NBU_NOTIFY)
 113             {
 114                 CheckStatus(temp, CXCMD_UNIQUE, CxBase);
 115             }
 116
 117             myerr = CBERR_DUP;
 118         }
 119     }
 120
 121     if (myerr == CBERR_OK)
 122     {
 123         if ((co = CreateCxObj(CX_BROKER, (IPTR)nb, (IPTR)NULL)) != NULL)
 124         {
 125             if (co->co_Ext.co_BExt->bext_MsgPort != NULL)
 126             {
 127                 if (!GPB(CxBase)->cx_Running)
 128                 {
 129                     if (SetupIHandler((struct CommoditiesBase *)CxBase) == FALSE)
 130                     {
 131                         goto sysErr;
 132                     }
 133                     else
 134                     {
 135                         GPB(CxBase)->cx_Running = TRUE;
 136                     }
 137                 }
 138                 else
 139                 {
 140                     BrokerCommand(NULL, CXCMD_LIST_CHG);
 141                 }
 142
 143                 Enqueue(&GPB(CxBase)->cx_BrokerList, (struct Node *)co);
 144                 co->co_Flags |= COF_VALID;
 145             }
 146             else
 147             {
 148                 // Don't set error because Garshneblanker creates a broker
 149                 // with nb->nb_Port set to NULL
 150                 // myerr = CBERR_VERSION;
 151             }
 152         }
 153         else
 154         {
 155         sysErr:
 156             myerr = CBERR_SYSERR;
 157         }
 158     }
 159
 160     ReleaseSemaphore(&GPB(CxBase)->cx_SignalSemaphore);
 161
 162     if (error != NULL)
 163     {
 164         *error = myerr;
 165     }
 166
 167     D(bug("CxBroker: returning co=%p\n", co));
 168
 169     return co;
 170
 171     AROS_LIBFUNC_EXIT
 172 } /* CxBroker */
 173
 174
 175 BOOL SetupIHandler(struct CommoditiesBase *CxBase)
 176 {
 177     D(bug("CxBroker: Setting up input handler.\n"));
 178
 179     CxBase->cx_InputMP.mp_Node.ln_Type = NT_MSGPORT;
 180     CxBase->cx_InputMP.mp_Flags = PA_SIGNAL;
 181     CxBase->cx_InputMP.mp_SigBit = SIGB_SINGLE;
 182     CxBase->cx_InputMP.mp_SigTask = FindTask(NULL);
 183     NEWLIST(&CxBase->cx_InputMP.mp_MsgList);
 184     CxBase->cx_IORequest.io_Message.mn_Node.ln_Type = NT_REPLYMSG;
 185     CxBase->cx_IORequest.io_Message.mn_Length = sizeof(struct IOStdReq);
 186     CxBase->cx_IORequest.io_Message.mn_ReplyPort = &CxBase->cx_InputMP;
 187
 188     if (OpenDevice("input.device", 0,
 189                    (struct IORequest *)&CxBase->cx_IORequest, 0) != 0)
 190     {
 191         // kprintf("Input.device didn't open\n");
 192         return FALSE;
 193     }
 194
 195     //  kprintf("CxBroker: Opened input.device.\n");
 196
 197     CxBase->cx_Interrupt.is_Code = (VOID (*)())AROS_ASMSYMNAME(cxIHandler);
 198     CxBase->cx_Interrupt.is_Data = CxBase;
 199     CxBase->cx_Interrupt.is_Node.ln_Pri = 53;
 200     CxBase->cx_Interrupt.is_Node.ln_Name = CxBase->cx_Lib.lib_Node.ln_Name;
 201     CxBase->cx_IORequest.io_Command = IND_ADDHANDLER;
 202     CxBase->cx_IORequest.io_Data = &CxBase->cx_Interrupt;
 203
 204     DoIO((struct IORequest *)&CxBase->cx_IORequest);
 205
 206     // kprintf("CxBroker: Handler up and running.\n");
 207
 208     return TRUE;
 209 }