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     if ((dvp = GetDeviceProc(notify->nr_FullName, NULL)) == NULL)
  61         return;
  62
  63     InitIOFS(&iofs, FSA_REMOVE_NOTIFY, DOSBase);
  64     iofs.io_Union.io_NOTIFY.io_NotificationRequest = notify;
  65
  66     iofs.IOFS.io_Device = (struct Device *) dvp->dvp_Port;
  67
  68     if (dvp->dvp_Lock != NULL)
  69         iofs.IOFS.io_Unit = ((struct FileHandle *) BADDR(dvp->dvp_Lock))->fh_Unit;
  70     else
  71         iofs.IOFS.io_Unit = dvp->dvp_DevNode->dol_Ext.dol_AROS.dol_Unit;
  72
  73     FreeDeviceProc(dvp);
  74
  75     DoIO(&iofs.IOFS);
  76
  77     if (notify->nr_FullName != notify->nr_Name)
  78         FreeVec(notify->nr_FullName);
  79
  80     if (notify->nr_Flags & NRF_SEND_MESSAGE &&
  81         (notify->nr_Flags & NRF_WAIT_REPLY || notify->nr_MsgCount)) {
  82
  83         struct MsgPort *port = notify->nr_stuff.nr_Msg.nr_Port;
  84         struct NotifyMessage *nm, *tmp;
  85
  86         notify->nr_Flags &= ~NRF_MAGIC;
  87
  88         Disable();
  89
  90         ForeachNodeSafe(&port->mp_MsgList, nm, tmp) {
  91             if (nm->nm_Class == NOTIFY_CLASS &&
  92                 nm->nm_Code == NOTIFY_CODE &&
  93                 nm->nm_NReq == notify) {
  94
  95                 Remove((struct Node *) nm);
  96                 ReplyMsg((struct Message *) nm);
  97
  98                 notify->nr_MsgCount--;
  99                 if (notify->nr_MsgCount == 0)
 100                     break;
 101             }
 102         }
 103
 104         Enable();
 105     }
 106
 107     AROS_LIBFUNC_EXIT
 108 } /* EndNotify */