src/protocols/zephyr/ZIfNotice.c

   1 /* This file is part of the Project Athena Zephyr Notification System.
   2  * It contains source for the ZIfNotice function.
   3  *
   4  *      Created by:     Robert French
   5  *
   6  *      $Source$
   7  *      $Author: warmenhoven $
   8  *
   9  *      Copyright (c) 1987,1988 by the Massachusetts Institute of Technology.
  10  *      For copying and distribution information, see the file
  11  *      "mit-copyright.h".
  12  */
  13 /* $Header$ */
  14
  15 #include <internal.h>
  16
  17 #ifndef lint
  18 static const char rcsid_ZIfNotice_c[] = "$Id: ZIfNotice.c 2096 2001-07-31 01:00:39Z warmenhoven $";
  19 #endif
  20
  21 Code_t ZIfNotice(notice, from, predicate, args)
  22     ZNotice_t *notice;
  23     struct sockaddr_in *from;
  24     int (*predicate) __P((ZNotice_t *, void *));
  25     void *args;
  26 {
  27     ZNotice_t tmpnotice;
  28     Code_t retval;
  29     char *buffer;
  30     struct _Z_InputQ *qptr;
  31
  32     if ((retval = Z_WaitForComplete()) != ZERR_NONE)
  33         return (retval);
  34
  35     qptr = Z_GetFirstComplete();
  36
  37     for (;;) {
  38         while (qptr) {
  39             if ((retval = ZParseNotice(qptr->packet, qptr->packet_len,
  40                                        &tmpnotice)) != ZERR_NONE)
  41                 return (retval);
  42             if ((*predicate)(&tmpnotice, args)) {
  43                 if (!(buffer = (char *) malloc((unsigned) qptr->packet_len)))
  44                     return (ENOMEM);
  45                 (void) memcpy(buffer, qptr->packet, qptr->packet_len);
  46                 if (from)
  47                     *from = qptr->from;
  48                 if ((retval = ZParseNotice(buffer, qptr->packet_len,
  49                                            notice)) != ZERR_NONE) {
  50                     free(buffer);
  51                     return (retval);
  52                 }
  53                 Z_RemQueue(qptr);
  54                 return (ZERR_NONE);
  55             }
  56             qptr = Z_GetNextComplete(qptr);
  57         }
  58         if ((retval = Z_ReadWait()) != ZERR_NONE)
  59             return (retval);
  60         qptr = Z_GetFirstComplete();    /* need to look over all of
  61                                            the queued messages, in case
  62                                            a fragment has been reassembled */
  63     }
  64 }