rom/dos/endnotify.c

   1 /*
   2     Copyright © 1995-2007, The AROS Development Team. All rights reserved.
   3     $Id$
   4
   5     Desc:
   6     Lang: English
   7 */
   8
   9 #include "dos_intern.h"
  10 #include <exec/lists.h>
  11 #include <proto/exec.h>
  12
  13 /*****************************************************************************
  14
  15     NAME */
  16
  17 #include <dos/notify.h>
  18 #include <proto/dos.h>
  19
  20 #include <string.h>
  21
  22         AROS_LH1(void, EndNotify,
  23
  24 /*  SYNOPSIS */
  25         AROS_LHA(struct NotifyRequest *, notify, D1),
  26
  27 /*  LOCATION */
  28         struct DosLibrary *, DOSBase, 149, Dos)
  29
  30 /*  FUNCTION
  31
  32     End a notification (quit notifying for a request previously sent with
  33     StartNotify()).
  34
  35     INPUTS
  36
  37     notify  --  NotifyRequest used with StartNotify()
  38
  39     RESULT
  40
  41     NOTES
  42
  43     EXAMPLE
  44
  45     BUGS
  46
  47     SEE ALSO
  48
  49     StartNotify()
  50
  51     INTERNALS
  52
  53 *****************************************************************************/
  54 {
  55     AROS_LIBFUNC_INIT
  56
  57     struct IOFileSys iofs;
  58     struct DevProc *dvp;
  59
  60     /* get the device pointer and dir lock. note that we don't just use
  61      * nr_Handler here, because we also need to supply a unit pointer so
  62      * packet.handler can get its mount context */
  63     if ((dvp = GetDeviceProc(notify->nr_FullName, NULL)) == NULL)
  64         return;
  65
  66     /* setup the call */
  67     InitIOFS(&iofs, FSA_REMOVE_NOTIFY, DOSBase);
  68     iofs.io_Union.io_NOTIFY.io_NotificationRequest = notify;
  69
  70     iofs.IOFS.io_Device = (struct Device *) dvp->dvp_Port;
  71
  72     /* take the root lock from either the doslist entry or from the devproc */
  73     if (dvp->dvp_Lock == NULL)
  74         iofs.IOFS.io_Unit = dvp->dvp_DevNode->dol_Ext.dol_AROS.dol_Unit;
  75     else
  76         iofs.IOFS.io_Unit = ((struct FileHandle *) BADDR(dvp->dvp_Lock))->fh_Unit;
  77
  78     FreeDeviceProc(dvp);
  79
  80     /* go */
  81     do {
  82         DosDoIO(&iofs.IOFS);
  83     } while (iofs.io_DosError != 0 && ErrorReport(iofs.io_DosError, REPORT_LOCK, 0, dvp->dvp_Port) == DOSFALSE);
  84
  85     /* free fullname if it was built in StartNotify() */
  86     if (notify->nr_FullName != notify->nr_Name)
  87         FreeVec(notify->nr_FullName);
  88
  89     /* if the filesystem has outstanding messages, they need to be replied */
  90     if (notify->nr_Flags & NRF_SEND_MESSAGE &&
  91         (notify->nr_Flags & NRF_WAIT_REPLY || notify->nr_MsgCount > 0)) {
  92
  93         struct MsgPort *port = notify->nr_stuff.nr_Msg.nr_Port;
  94         struct NotifyMessage *nm, *tmp;
  95
  96         notify->nr_Flags &= ~NRF_MAGIC;
  97
  98         /* protect access to the message list */
  99         Disable();
 100
 101         /* loop over the messages */
 102         ForeachNodeSafe(&port->mp_MsgList, nm, tmp) {
 103             /* if its one of our notify messages */
 104             if (nm->nm_Class == NOTIFY_CLASS &&
 105                 nm->nm_Code == NOTIFY_CODE &&
 106                 nm->nm_NReq == notify) {
 107
 108                 /* remove and reply */
 109                 Remove((struct Node *) nm);
 110                 ReplyMsg((struct Message *) nm);
 111
 112                 /* decrement the count. bail early if we've done them all */
 113                 notify->nr_MsgCount--;
 114                 if (notify->nr_MsgCount == 0)
 115                     break;
 116             }
 117         }
 118
 119         /* unlock the list */
 120         Enable();
 121     }
 122
 123     SetIoErr(iofs.io_DosError);
 124
 125     AROS_LIBFUNC_EXIT
 126 } /* EndNotify */