workbench/libs/commodities/brokercommand.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 #ifndef  DEBUG
  14 #define  DEBUG 0
  15 #endif
  16
  17 #include "cxintern.h"
  18
  19 #include <aros/debug.h>
  20
  21 #include <dos/dos.h>
  22 #include <proto/exec.h>
  23 #include <libraries/commodities.h>
  24
  25     AROS_LH2(ULONG, BrokerCommand,
  26
  27 /*  SYNOPSIS */
  28
  29         AROS_LHA(STRPTR, name   , A0),
  30         AROS_LHA(ULONG , command, D0),
  31
  32 /*  LOCATION */
  33
  34         struct Library *, CxBase, 33, Commodities)
  35
  36 /*  FUNCTION
  37
  38     Notify a task connected to a certain broker of a state change.
  39
  40     INPUTS
  41
  42     name     --  The name of the broker
  43     command  --  What to tell the task
  44
  45     RESULT
  46
  47     0 if everything was OK, a negative value otherwise:
  48     -1    --   Unknown broker 'name'
  49     -2    --   No broker message port
  50     -3    --   No memory for operation
  51
  52     NOTES
  53
  54     This function is present in AmigaOS too but undocumented.
  55
  56     EXAMPLE
  57
  58     BUGS
  59
  60     SEE ALSO
  61
  62     INTERNALS
  63
  64     HISTORY
  65
  66 ******************************************************************************/
  67
  68 {
  69     AROS_LIBFUNC_INIT
  70
  71     static char Exg[] = "Exchange";
  72
  73     ULONG error;
  74     CxObj *co;
  75
  76     if (name == NULL)
  77     {
  78         name = Exg;
  79     }
  80
  81     D(bug("Notifying %s\n", name));
  82
  83     ObtainSemaphore(&GPB(CxBase)->cx_SignalSemaphore);
  84
  85     co = (CxObj *)FindName(&GPB(CxBase)->cx_BrokerList, name);
  86     error = CheckStatus(co, command, CxBase);
  87
  88     ReleaseSemaphore(&GPB(CxBase)->cx_SignalSemaphore);
  89
  90     D(bug("Notification done!\n"));
  91
  92     return error;
  93
  94     AROS_LIBFUNC_EXIT
  95 } /* BrokerCommand */
  96
  97
  98 ULONG CheckStatus(CxObj *broker, ULONG command, struct Library *CxBase)
  99 {
 100     CxMsg *msg;
 101
 102     if (broker == NULL)
 103     {
 104         return -1;
 105     }
 106
 107     if (broker->co_Ext.co_BExt->bext_MsgPort == NULL)
 108     {
 109         if (command == CXCMD_KILL && broker->co_Ext.co_BExt->bext_Task != NULL)
 110         {
 111             /* Tell the task to shut itself down */
 112             Signal(broker->co_Ext.co_BExt->bext_Task, SIGBREAKF_CTRL_E);
 113
 114             return 0;
 115         }
 116
 117         return -2;
 118     }
 119
 120     msg = (CxMsg *)AllocCxStructure(CX_MESSAGE, CXM_SINGLE, CxBase);
 121
 122     if (msg == NULL)
 123     {
 124         return -3;
 125     }
 126
 127     msg->cxm_ID = command;
 128     PutMsg(broker->co_Ext.co_BExt->bext_MsgPort, (struct Message *)msg);
 129
 130     return 0;
 131 }