rom/exec/putmsg.c

   1 /*
   2     Copyright © 1995-2011, The AROS Development Team. All rights reserved.
   3     $Id$
   4
   5     Desc: Send a message to a port.
   6     Lang: english
   7 */
   8
   9 #include <aros/debug.h>
  10 #include <aros/libcall.h>
  11 #include <exec/ports.h>
  12 #include <proto/exec.h>
  13
  14 #include "exec_intern.h"
  15 #include "exec_util.h"
  16
  17 /*****************************************************************************
  18
  19     NAME */
  20
  21         AROS_LH2(void, PutMsg,
  22
  23 /*  SYNOPSIS */
  24         AROS_LHA(struct MsgPort *, port,    A0),
  25         AROS_LHA(struct Message *, message, A1),
  26
  27 /*  LOCATION */
  28         struct ExecBase *, SysBase, 61, Exec)
  29
  30 /*  FUNCTION
  31         Sends a message to a given message port. Messages are not copied
  32         from one task to another but must lie in shared memory instead.
  33         Therefore the owner of the message may generally not reuse it before
  34         it is returned. But this depends on the two tasks sharing the message.
  35
  36     INPUTS
  37         port    - Pointer to messageport.
  38         message - Pointer to message.
  39
  40     RESULT
  41
  42     NOTES
  43         It is legal to send a message from within interrupts.
  44
  45         Messages may either trigger a signal at the owner of the messageport
  46         or raise a software interrupt, depending on port->mp_Flags&PF_ACTION.
  47
  48     EXAMPLE
  49
  50     BUGS
  51
  52     SEE ALSO
  53         WaitPort(), GetMsg()
  54
  55     INTERNALS
  56
  57 ******************************************************************************/
  58 {
  59     AROS_LIBFUNC_INIT
  60     ASSERT_VALID_PTR(message);
  61     ASSERT_VALID_PTR(port);
  62
  63     /* FASTCALL is a special case that operates without the message list
  64      * locked, so we have to check it before anything */
  65     if (port->mp_Flags & PA_FASTCALL)
  66     {
  67         FastPutMsg(port, message, SysBase);
  68         return;
  69     }
  70
  71     /*
  72         Messages may be sent from interrupts. Therefore the message list
  73         of the message port must be protected with Disable().
  74     */
  75     Disable();
  76
  77     /* Set the node type to NT_MESSAGE == sent message. */
  78     message->mn_Node.ln_Type=NT_MESSAGE;
  79
  80     InternalPutMsg(port, message, SysBase);
  81
  82     /* All done. */
  83     Enable();
  84     AROS_LIBFUNC_EXIT
  85 } /* PutMsg() */
  86
  87 void FastPutMsg(struct MsgPort *port, struct Message *message, struct ExecBase *SysBase)
  88 {
  89     if (port->mp_SoftInt == NULL || ((struct Interrupt *) port->mp_SoftInt)->is_Code == NULL)
  90         return;
  91
  92     ASSERT_VALID_PTR(port->mp_SoftInt);
  93     ASSERT_VALID_PTR(((struct Interrupt *) port->mp_SoftInt)->is_Code);
  94
  95     /* call the "interrupt" with the message as an argument */
  96     AROS_UFC4NR(void, ((struct Interrupt *) port->mp_SoftInt)->is_Code,
  97              AROS_UFCA(APTR, ((struct Interrupt *) port->mp_SoftInt)->is_Data, A1),
  98                  AROS_UFCA(ULONG_FUNC, (ULONG_FUNC)((struct Interrupt *) port->mp_SoftInt)->is_Code, A5),
  99              AROS_UFCA(struct Message *,  message, D0),
 100              AROS_UFCA(struct ExecBase *, SysBase, A6));
 101 }
 102
 103 void InternalPutMsg(struct MsgPort *port, struct Message *message, struct ExecBase *SysBase)
 104 {
 105     /* Add it to the message list. */
 106     AddTail(&port->mp_MsgList,&message->mn_Node);
 107
 108     if (port->mp_SigTask)
 109     {
 110         ASSERT_VALID_PTR(port->mp_SigTask);
 111
 112         /* And trigger the action. */
 113         switch(port->mp_Flags & PF_ACTION)
 114         {
 115             case PA_SIGNAL:
 116                 /* Send the signal */
 117                 Signal((struct Task *)port->mp_SigTask,1<<port->mp_SigBit);
 118                 break;
 119
 120             case PA_SOFTINT:
 121                 D(bug("PutMsg: PA_SOFTINT, port 0x%p, msg 0x%p, int %s\n", port, message, ((struct Interrupt *)port->mp_SoftInt)->is_Node.ln_Name));
 122
 123                 /* Raise a software interrupt */
 124                 Cause((struct Interrupt *)port->mp_SoftInt);
 125                 break;
 126
 127             case PA_IGNORE:
 128                 /* Do nothing. */
 129                 break;
 130
 131             case PA_CALL:
 132                 /* Call the function in mp_SigTask. */
 133                 AROS_UFC2NR(void, port->mp_SigTask,
 134                     AROS_UFCA(struct MsgPort *,  port,    D0),
 135                     AROS_UFCA(struct ExecBase *, SysBase, A6));
 136                 break;
 137         }
 138     }
 139 }