69 notif->
write (event, own_buf);
85 for (i = 0; i < ARRAY_SIZE (notifs); i++)
90 && packet_len == strlen (ack_name))
94 if (i == ARRAY_SIZE (notifs))
107 fprintf (stderr,
"%s: acking %d\n", np->
ack_name,
127 fprintf (stderr,
"pending events: %s %d\n", notif->
notif_name,
152 np->
write (new_event, p);
168 for (i = 0; i < ARRAY_SIZE (notifs); i++)
void notif_push(struct notif_server *np, struct notif_event *new_event)
#define QUEUE_enque(TYPE, Q, V)
void notif_event_enque(struct notif_server *notif, struct notif_event *event)
#define QUEUE_length(TYPE, Q)
#define QUEUE_is_empty(TYPE, Q)
static void notif_event_xfree(struct notif_event *event)
int handle_notif_ack(char *own_buf, int packet_len)
void(* write)(struct notif_event *event, char *own_buf)
static int startswith(const char *string, const char *pattern)
#define QUEUE_deque(TYPE, Q)
int putpkt_notif(char *buf)
#define QUEUE_alloc(TYPE, FREE_FUNC)
int xsnprintf(char *str, size_t size, const char *format,...)
struct notif_server notif_stop
#define QUEUE_peek(TYPE, Q)
void notif_write_event(struct notif_server *notif, char *own_buf)
void initialize_notif(void)