rom/dos/endnotify.c

   1 /*
   2     Copyright © 1995-2011, The AROS Development Team. All rights reserved.
   3     $Id$
   4
   5     Desc:
   6     Lang: English
   7 */
   8
   9 #include <aros/debug.h>
  10 #include <exec/lists.h>
  11 #include <proto/exec.h>
  12
  13 #include "dos_intern.h"
  14
  15 /*****************************************************************************
  16
  17     NAME */
  18
  19 #include <dos/notify.h>
  20 #include <proto/dos.h>
  21
  22 #include <string.h>
  23
  24         AROS_LH1(void, EndNotify,
  25
  26 /*  SYNOPSIS */
  27         AROS_LHA(struct NotifyRequest *, notify, D1),
  28
  29 /*  LOCATION */
  30         struct DosLibrary *, DOSBase, 149, Dos)
  31
  32 /*  FUNCTION
  33
  34     End a notification (quit notifying for a request previously sent with
  35     StartNotify()).
  36
  37     INPUTS
  38
  39     notify  --  NotifyRequest used with StartNotify()
  40
  41     RESULT
  42
  43     NOTES
  44
  45     EXAMPLE
  46
  47     BUGS
  48
  49     SEE ALSO
  50
  51     StartNotify()
  52
  53     INTERNALS
  54
  55 *****************************************************************************/
  56 {
  57     AROS_LIBFUNC_INIT
  58
  59     /*
  60      * Packet handlers love to replace nr_Handler of active requests with a pointer
  61      * to own real message port. It's not possible to prevent this by (simple) external
  62      * means.
  63      * This is why we use packet I/O here on all architectures. If nr_Handler points
  64      * to packet message port, the packet will be sent directly, bypassing IOFS layer.
  65      * This is 100% safe because we don't pass any locks and/or filehandles here.
  66      * If nr_Handler still points to IOFS device, packet I/O emulator will take care about
  67      * this.
  68      */
  69     dopacket1(DOSBase, NULL, notify->nr_Handler, ACTION_REMOVE_NOTIFY, (SIPTR)notify);
  70
  71     /* free fullname if it was built in StartNotify() */
  72     if (notify->nr_FullName != notify->nr_Name)
  73         FreeVec(notify->nr_FullName);
  74
  75     /* if the filesystem has outstanding messages, they need to be replied */
  76     if ((notify->nr_Flags & NRF_SEND_MESSAGE) &&
  77         ((notify->nr_Flags & NRF_WAIT_REPLY) || notify->nr_MsgCount > 0))
  78     {
  79         struct MsgPort *port = notify->nr_stuff.nr_Msg.nr_Port;
  80         struct NotifyMessage *nm, *tmp;
  81
  82         notify->nr_Flags &= ~NRF_MAGIC;
  83
  84         /* protect access to the message list */
  85         Disable();
  86
  87         /* loop over the messages */
  88         ForeachNodeSafe(&port->mp_MsgList, nm, tmp) {
  89             /* if its one of our notify messages */
  90             if (nm->nm_Class == NOTIFY_CLASS &&
  91                 nm->nm_Code == NOTIFY_CODE &&
  92                 nm->nm_NReq == notify) {
  93
  94                 /* remove and reply */
  95                 Remove((struct Node *) nm);
  96                 ReplyMsg((struct Message *) nm);
  97
  98                 /* decrement the count. bail early if we've done them all */
  99                 notify->nr_MsgCount--;
 100                 if (notify->nr_MsgCount == 0)
 101                     break;
 102             }
 103         }
 104
 105         /* unlock the list */
 106         Enable();
 107     }
 108
 109     AROS_LIBFUNC_EXIT
 110 } /* EndNotify */