rom/dos/endnotify.c

   1 /*
   2     Copyright © 1995-2001, 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     AROS_LIBBASE_EXT_DECL(struct DosLibrary *,DOSBase)
  57
  58     struct IOFileSys iofs;
  59
  60     /* Prepare I/O request. */
  61     InitIOFS(&iofs, FSA_REMOVE_NOTIFY, DOSBase);
  62
  63     iofs.io_Union.io_NOTIFY.io_NotificationRequest = notify;
  64
  65     if (strchr(notify->nr_Name, ':'))
  66     {
  67         DoName(&iofs, notify->nr_Name, DOSBase);
  68     }
  69     else
  70     {
  71         iofs.IOFS.io_Device = (struct Device *)notify->nr_Device;
  72
  73         if (iofs.IOFS.io_Device == NULL)
  74         {
  75             return;
  76         }
  77
  78         DosDoIO(&iofs.IOFS);
  79     }
  80
  81     if (notify->nr_Flags & NRF_SEND_MESSAGE)
  82     {
  83         struct Node          *tempNode;
  84         struct NotifyMessage *nm;
  85
  86         Disable();
  87
  88         ForeachNodeSafe(&notify->nr_stuff.nr_Msg.nr_Port->mp_MsgList,
  89                         nm, tempNode)
  90         {
  91             if (notify->nr_MsgCount == 0)
  92             {
  93                 break;
  94             }
  95
  96             if (nm->nm_NReq == notify)
  97             {
  98                 notify->nr_MsgCount--;
  99                 Remove((struct Node *)nm);
 100                 ReplyMsg((struct Message *)nm);
 101             }
 102         }
 103
 104         Enable();
 105     }
 106
 107     SetIoErr(iofs.io_DosError);
 108
 109     AROS_LIBFUNC_EXIT
 110 } /* EndNotify */