rom/exec/replymsg.c

   1 /*
   2     Copyright © 1995-2001, The AROS Development Team. All rights reserved.
   3     $Id$
   4
   5     Desc: Reply a message
   6     Lang: english
   7 */
   8 #include "exec_intern.h"
   9 #include <aros/libcall.h>
  10 #include <exec/ports.h>
  11 #include <proto/exec.h>
  12
  13 /*****************************************************************************
  14
  15     NAME */
  16
  17         AROS_LH1(void, ReplyMsg,
  18
  19 /*  SYNOPSIS */
  20         AROS_LHA(struct Message *, message, A1),
  21
  22 /*  LOCATION */
  23         struct ExecBase *, SysBase, 63, Exec)
  24
  25 /*  FUNCTION
  26         Send a message back to where it came from. It's generally not
  27         wise to access the fields of a message after it has been replied.
  28
  29     INPUTS
  30         message - a message got with GetMsg().
  31
  32     RESULT
  33
  34     NOTES
  35
  36     EXAMPLE
  37
  38     BUGS
  39
  40     SEE ALSO
  41         WaitPort(), GetMsg(), PutMsg()
  42
  43     INTERNALS
  44
  45 ******************************************************************************/
  46 {
  47     AROS_LIBFUNC_INIT
  48
  49     struct MsgPort *port;
  50
  51     /* handle FASTCALL before doing locking or anything else. yes, there's a
  52      * potential race here if some task was to change mn_ReplyPort before/as
  53      * we read it. thats why we fetch it again further down, after Disable().
  54      * all bets are of when using FASTCALL */
  55     port = message->mn_ReplyPort;
  56
  57     if (port != NULL && port->mp_Flags & PA_FASTCALL)
  58     {
  59         if (port->mp_SoftInt == NULL || ((struct Interrupt *) port->mp_SoftInt)->is_Code == NULL)
  60             return;
  61
  62         ASSERT_VALID_PTR(port->mp_SoftInt);
  63         ASSERT_VALID_PTR(((struct Interrupt *) port->mp_SoftInt)->is_Code);
  64
  65         message->mn_Node.ln_Type = NT_REPLYMSG;
  66
  67         /* call the "interrupt" with the message as an argument */
  68         AROS_UFC4(void, ((struct Interrupt *) port->mp_SoftInt)->is_Code,
  69             AROS_UFCA(APTR,              ((struct Interrupt *) port->mp_SoftInt)->is_Data, A1),
  70             AROS_UFCA(ULONG_FUNC,        ((struct Interrupt *) port->mp_SoftInt)->is_Code, A5),
  71             AROS_UFCA(struct Message *,  message,                                          D0),
  72             AROS_UFCA(struct ExecBase *, SysBase,                                          A6));
  73
  74         return;
  75     }
  76
  77     /* Protect the message against access by other tasks. */
  78     Disable();
  79
  80     /* Get replyport */
  81     port=message->mn_ReplyPort;
  82
  83     /* Not set? Only mark the message as no longer sent. */
  84     if(port==NULL)
  85         message->mn_Node.ln_Type=NT_FREEMSG;
  86     else
  87     {
  88         /* Mark the message as replied */
  89         message->mn_Node.ln_Type=NT_REPLYMSG;
  90
  91         /* Add it to the replyport's list */
  92         AddTail(&port->mp_MsgList,&message->mn_Node);
  93
  94         if(port->mp_SigTask)
  95         {
  96             /* And trigger the arrival action. */
  97             switch(port->mp_Flags&PF_ACTION)
  98             {
  99                 case PA_SIGNAL:
 100                     /* Send a signal */
 101                     Signal((struct Task *)port->mp_SigTask,1<<port->mp_SigBit);
 102                     break;
 103
 104                 case PA_SOFTINT:
 105                     /* Raise a software interrupt */
 106                     Cause((struct Interrupt *)port->mp_SoftInt);
 107                     break;
 108
 109                 case PA_IGNORE:
 110                     /* Do nothing */
 111                     break;
 112
 113                 case PA_CALL:
 114                     /* Call the function in mp_SigTask. */
 115                     AROS_UFC2(void, port->mp_SigTask,
 116                         AROS_UFCA(struct MsgPort *,  port,    D0),
 117                         AROS_UFCA(struct ExecBase *, SysBase, A6));
 118                     break;
 119             }
 120         }
 121     }
 122
 123     /* All done */
 124     Enable();
 125     AROS_LIBFUNC_EXIT
 126 } /* ReplyMsg() */
 127