|
2086
|
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 }
|
