Lines Matching refs:queue
40 static struct fpm_event_s *fpm_event_queue_isset(struct fpm_event_queue_s *queue, struct fpm_event_…
41 static int fpm_event_queue_add(struct fpm_event_queue_s **queue, struct fpm_event_s *ev);
42 static int fpm_event_queue_del(struct fpm_event_queue_s **queue, struct fpm_event_s *ev);
43 static void fpm_event_queue_destroy(struct fpm_event_queue_s **queue);
126 static struct fpm_event_s *fpm_event_queue_isset(struct fpm_event_queue_s *queue, struct fpm_event_… in fpm_event_queue_isset() argument
132 while (queue) { in fpm_event_queue_isset()
133 if (queue->ev == ev) { in fpm_event_queue_isset()
136 queue = queue->next; in fpm_event_queue_isset()
143 static int fpm_event_queue_add(struct fpm_event_queue_s **queue, struct fpm_event_s *ev) /* {{{ */ in fpm_event_queue_add() argument
147 if (!queue || !ev) { in fpm_event_queue_add()
151 if (fpm_event_queue_isset(*queue, ev)) { in fpm_event_queue_add()
163 if (*queue) { in fpm_event_queue_add()
164 (*queue)->prev = elt; in fpm_event_queue_add()
165 elt->next = *queue; in fpm_event_queue_add()
167 *queue = elt; in fpm_event_queue_add()
170 if (*queue == fpm_event_queue_fd && module->add) { in fpm_event_queue_add()
178 static int fpm_event_queue_del(struct fpm_event_queue_s **queue, struct fpm_event_s *ev) /* {{{ */ in fpm_event_queue_del() argument
181 if (!queue || !ev) { in fpm_event_queue_del()
184 q = *queue; in fpm_event_queue_del()
193 if (q == *queue) { in fpm_event_queue_del()
194 *queue = q->next; in fpm_event_queue_del()
195 if (*queue) { in fpm_event_queue_del()
196 (*queue)->prev = NULL; in fpm_event_queue_del()
201 if (*queue == fpm_event_queue_fd && module->remove) { in fpm_event_queue_del()
214 static void fpm_event_queue_destroy(struct fpm_event_queue_s **queue) /* {{{ */ in fpm_event_queue_destroy() argument
218 if (!queue) { in fpm_event_queue_destroy()
222 if (*queue == fpm_event_queue_fd && module->clean) { in fpm_event_queue_destroy()
226 q = *queue; in fpm_event_queue_destroy()
233 *queue = NULL; in fpm_event_queue_destroy()
