src/protocols/zephyr/ZPeekIfNot.c

   1 /* This file is part of the Project Athena Zephyr Notification System.
   2  * It contains source for the ZPeekIfNotice 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 #ifndef lint
  16 static char rcsid_ZPeekIfNotice_c[] = "$Header$";
  17 #endif
  18
  19 #include <internal.h>
  20
  21 Code_t ZPeekIfNotice(notice, from, predicate, args)
  22     ZNotice_t *notice;
  23     struct sockaddr_in *from;
  24     int (*predicate)();
  25     char *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     for (;;) {
  36         qptr = Z_GetFirstComplete();
  37         while (qptr) {
  38             if ((retval = ZParseNotice(qptr->packet, qptr->packet_len,
  39                                        &tmpnotice)) != ZERR_NONE)
  40                 return (retval);
  41             if ((*predicate)(&tmpnotice, args)) {
  42                 if (!(buffer = (char *) malloc((unsigned) qptr->packet_len)))
  43                     return (ENOMEM);
  44                 (void) memcpy(buffer, qptr->packet, qptr->packet_len);
  45                 if (from)
  46                     *from = qptr->from;
  47                 if ((retval = ZParseNotice(buffer, qptr->packet_len,
  48                                            notice)) != ZERR_NONE) {
  49                     free(buffer);
  50                     return (retval);
  51                 }
  52                 return (ZERR_NONE);
  53             }
  54             qptr = Z_GetNextComplete(qptr);
  55         }
  56         if ((retval = Z_ReadWait()) != ZERR_NONE)
  57             return (retval);
  58     }
  59 }