libpurple/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  *      Copyright (c) 1987,1988 by the Massachusetts Institute of Technology.
   7  *      For copying and distribution information, see the file
   8  *      "mit-copyright.h".
   9  */
  10
  11 #include "internal.h"
  12
  13 Code_t ZIfNotice(notice, from, predicate, args)
  14     ZNotice_t *notice;
  15     struct sockaddr_in *from;
  16     int (*predicate)(ZNotice_t *, void *);
  17     void *args;
  18 {
  19     ZNotice_t tmpnotice;
  20     Code_t retval;
  21     char *buffer;
  22     struct _Z_InputQ *qptr;
  23
  24     if ((retval = Z_WaitForComplete()) != ZERR_NONE)
  25         return (retval);
  26
  27     qptr = Z_GetFirstComplete();
  28
  29     for (;;) {
  30         while (qptr) {
  31             if ((retval = ZParseNotice(qptr->packet, qptr->packet_len,
  32                                        &tmpnotice)) != ZERR_NONE)
  33                 return (retval);
  34             if ((*predicate)(&tmpnotice, args)) {
  35                 if (!(buffer = (char *) malloc((unsigned) qptr->packet_len)))
  36                     return (ENOMEM);
  37                 (void) memcpy(buffer, qptr->packet, qptr->packet_len);
  38                 if (from)
  39                     *from = qptr->from;
  40                 if ((retval = ZParseNotice(buffer, qptr->packet_len,
  41                                            notice)) != ZERR_NONE) {
  42                     free(buffer);
  43                     return (retval);
  44                 }
  45                 Z_RemQueue(qptr);
  46                 return (ZERR_NONE);
  47             }
  48             qptr = Z_GetNextComplete(qptr);
  49         }
  50         if ((retval = Z_ReadWait()) != ZERR_NONE)
  51             return (retval);
  52         qptr = Z_GetFirstComplete();    /* need to look over all of
  53                                            the queued messages, in case
  54                                            a fragment has been reassembled */
  55     }
  56 }