workbench/libs/rexxsupport/portcleanup.c

   1 #include <proto/exec.h>
   2 #include <proto/rexxsyslib.h>
   3 #include <rexx/storage.h>
   4 #include <rexx/errors.h>
   5
   6 #include <string.h>
   7
   8 #include "portnode.h"
   9
  10 #include "rexxsupport_intern.h"
  11
  12 void portcleanup(struct Library *RexxSupportBase, struct PortNode *node)
  13 {
  14     struct RexxMsg *msg;
  15     struct PortNodeData *data = &node->data;
  16
  17     Remove(&data->node);
  18     if (IsListEmpty(&RSBI(RexxSupportBase)->openports))
  19         RexxSupportBase->lib_OpenCnt--;
  20
  21     RemPort(data->port);
  22
  23     ForeachNode(&data->msgs, msg)
  24     {
  25         if (IsRexxMsg(msg))
  26         {
  27             msg->rm_Result1 = RC_ERROR;
  28             msg->rm_Result2 = (IPTR)ERR10_013;
  29         }
  30         ReplyMsg((struct Message *)msg);
  31     }
  32
  33     while ((msg = (struct RexxMsg *)GetMsg(node->data.port)) != NULL)
  34     {
  35         if (IsRexxMsg(msg))
  36         {
  37             msg->rm_Result1 = RC_ERROR;
  38             msg->rm_Result2 = (IPTR)ERR10_013;
  39         }
  40         ReplyMsg((struct Message *)msg);
  41     }
  42
  43     DeleteMsgPort(data->port);
  44
  45     FreeMem(data->node.ln_Name, strlen(data->node.ln_Name)+1);
  46     FreeMem(node, sizeof(struct PortNode));
  47 }