rom/dos/endnotify.c

   1 /*
   2     Copyright © 1995-2013, 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         End a notification (quit notifying for a request previously sent with
  34         StartNotify()).
  35
  36     INPUTS
  37         notify - NotifyRequest used with StartNotify()
  38
  39     RESULT
  40
  41     NOTES
  42
  43     EXAMPLE
  44
  45     BUGS
  46
  47     SEE ALSO
  48         StartNotify()
  49
  50     INTERNALS
  51
  52 *****************************************************************************/
  53 {
  54     AROS_LIBFUNC_INIT
  55
  56     /*
  57      * Packet handlers love to replace nr_Handler of active requests with a pointer
  58      * to own real message port. It's not possible to prevent this by (simple) external
  59      * means.
  60      * This is why we use packet I/O here on all architectures. If nr_Handler points
  61      * to packet message port, the packet will be sent directly, bypassing IOFS layer.
  62      * This is 100% safe because we don't pass any locks and/or filehandles here.
  63      * If nr_Handler still points to IOFS device, packet I/O emulator will take care about
  64      * this.
  65      */
  66     dopacket1(DOSBase, NULL, notify->nr_Handler, ACTION_REMOVE_NOTIFY, (SIPTR)notify);
  67
  68     /* free fullname if it was built in StartNotify() */
  69     if (notify->nr_FullName != notify->nr_Name)
  70         FreeVec(notify->nr_FullName);
  71
  72     /* if the filesystem has outstanding messages, they need to be replied */
  73     if ((notify->nr_Flags & NRF_SEND_MESSAGE) &&
  74         ((notify->nr_Flags & NRF_WAIT_REPLY) || notify->nr_MsgCount > 0))
  75     {
  76         struct MsgPort *port = notify->nr_stuff.nr_Msg.nr_Port;
  77         struct NotifyMessage *nm, *tmp;
  78
  79         notify->nr_Flags &= ~NRF_MAGIC;
  80
  81         /* protect access to the message list */
  82         Disable();
  83
  84         /* loop over the messages */
  85         ForeachNodeSafe(&port->mp_MsgList, nm, tmp) {
  86             /* if its one of our notify messages */
  87             if (nm->nm_Class == NOTIFY_CLASS &&
  88                 nm->nm_Code == NOTIFY_CODE &&
  89                 nm->nm_NReq == notify) {
  90
  91                 /* remove and reply */
  92                 Remove((struct Node *) nm);
  93                 ReplyMsg((struct Message *) nm);
  94
  95                 /* decrement the count. bail early if we've done them all */
  96                 notify->nr_MsgCount--;
  97                 if (notify->nr_MsgCount == 0)
  98                     break;
  99             }
 100         }
 101
 102         /* unlock the list */
 103         Enable();
 104     }
 105
 106     AROS_LIBFUNC_EXIT
 107 } /* EndNotify */