Lines Matching refs:ctx

142 void evmap_io_initmap_(struct event_io_map *ctx)
144 HT_INIT(event_io_map, ctx);
147 void evmap_io_clear_(struct event_io_map *ctx) in evmap_io_clear_() argument
150 for (ent = HT_START(event_io_map, ctx); ent; ent = next) { in evmap_io_clear_()
152 next = HT_NEXT_RMV(event_io_map, ctx, ent); in evmap_io_clear_()
155 HT_CLEAR(event_io_map, ctx); /* remove all storage held by the ctx. */ in evmap_io_clear_()
189 evmap_io_initmap_(struct event_io_map* ctx) in evmap_io_initmap_() argument
191 evmap_signal_initmap_(ctx); in evmap_io_initmap_()
194 evmap_io_clear_(struct event_io_map* ctx) in evmap_io_clear_() argument
196 evmap_signal_clear_(ctx); in evmap_io_clear_()
235 evmap_signal_initmap_(struct event_signal_map *ctx) in evmap_signal_initmap_() argument
237 ctx->nentries = 0; in evmap_signal_initmap_()
238 ctx->entries = NULL; in evmap_signal_initmap_()
242 evmap_signal_clear_(struct event_signal_map *ctx) in evmap_signal_clear_() argument
244 if (ctx->entries != NULL) { in evmap_signal_clear_()
246 for (i = 0; i < ctx->nentries; ++i) { in evmap_signal_clear_()
247 if (ctx->entries[i] != NULL) in evmap_signal_clear_()
248 mm_free(ctx->entries[i]); in evmap_signal_clear_()
250 mm_free(ctx->entries); in evmap_signal_clear_()
251 ctx->entries = NULL; in evmap_signal_clear_()
253 ctx->nentries = 0; in evmap_signal_clear_()
277 struct evmap_io *ctx = NULL; in evmap_io_add_() local
293 GET_IO_SLOT_AND_CTOR(ctx, io, fd, evmap_io, evmap_io_init, in evmap_io_add_()
296 nread = ctx->nread; in evmap_io_add_()
297 nwrite = ctx->nwrite; in evmap_io_add_()
298 nclose = ctx->nclose; in evmap_io_add_()
325 (old_ev = LIST_FIRST(&ctx->events)) && in evmap_io_add_()
333 void *extra = ((char*)ctx) + sizeof(struct evmap_io); in evmap_io_add_()
343 ctx->nread = (ev_uint16_t) nread; in evmap_io_add_()
344 ctx->nwrite = (ev_uint16_t) nwrite; in evmap_io_add_()
345 ctx->nclose = (ev_uint16_t) nclose; in evmap_io_add_()
346 LIST_INSERT_HEAD(&ctx->events, ev, ev_io_next); in evmap_io_add_()
358 struct evmap_io *ctx; in evmap_io_del_() local
372 GET_IO_SLOT(ctx, io, fd, evmap_io); in evmap_io_del_()
374 nread = ctx->nread; in evmap_io_del_()
375 nwrite = ctx->nwrite; in evmap_io_del_()
376 nclose = ctx->nclose; in evmap_io_del_()
402 void *extra = ((char*)ctx) + sizeof(struct evmap_io); in evmap_io_del_()
411 ctx->nread = nread; in evmap_io_del_()
412 ctx->nwrite = nwrite; in evmap_io_del_()
413 ctx->nclose = nclose; in evmap_io_del_()
423 struct evmap_io *ctx; in evmap_io_active_() local
430 GET_IO_SLOT(ctx, io, fd, evmap_io); in evmap_io_active_()
432 if (NULL == ctx) in evmap_io_active_()
434 LIST_FOREACH(ev, &ctx->events, ev_io_next) { in evmap_io_active_()
454 struct evmap_signal *ctx = NULL; in evmap_signal_add_() local
464 GET_SIGNAL_SLOT_AND_CTOR(ctx, map, sig, evmap_signal, evmap_signal_init, in evmap_signal_add_()
467 if (LIST_EMPTY(&ctx->events)) { in evmap_signal_add_()
473 LIST_INSERT_HEAD(&ctx->events, ev, ev_signal_next); in evmap_signal_add_()
483 struct evmap_signal *ctx; in evmap_signal_del_() local
488 GET_SIGNAL_SLOT(ctx, map, sig, evmap_signal); in evmap_signal_del_()
492 if (LIST_FIRST(&ctx->events) == NULL) { in evmap_signal_del_()
504 struct evmap_signal *ctx; in evmap_signal_active_() local
509 GET_SIGNAL_SLOT(ctx, map, sig, evmap_signal); in evmap_signal_active_()
511 if (!ctx) in evmap_signal_active_()
513 LIST_FOREACH(ev, &ctx->events, ev_signal_next) in evmap_signal_active_()
520 struct evmap_io *ctx; in evmap_io_get_fdinfo_() local
521 GET_IO_SLOT(ctx, map, fd, evmap_io); in evmap_io_get_fdinfo_()
522 if (ctx) in evmap_io_get_fdinfo_()
523 return ((char*)ctx) + sizeof(struct evmap_io); in evmap_io_get_fdinfo_()
556 struct evmap_io *ctx = &(*mapent)->ent.evmap_io; local
560 struct evmap_io *ctx = iomap->entries[fd];
561 if (!ctx)
564 if ((r = fn(base, fd, ctx, arg)))
594 struct evmap_signal *ctx = sigmap->entries[signum]; local
595 if (!ctx)
597 if ((r = fn(base, signum, ctx, arg)))
608 struct evmap_io *ctx, void *arg) argument
615 EVUTIL_ASSERT(ctx);
617 extra = ((char*)ctx) + sizeof(struct evmap_io);
618 if (ctx->nread)
620 if (ctx->nwrite)
622 if (ctx->nclose)
627 (ev = LIST_FIRST(&ctx->events)) &&
640 int signum, struct evmap_signal *ctx, void *arg) argument
645 if (!LIST_EMPTY(&ctx->events)) {
722 struct evmap_signal *ctx; local
723 GET_SIGNAL_SLOT(ctx, &base->sigmap, change->fd, evmap_signal);
724 ptr = ((char*)ctx) + sizeof(struct evmap_signal);
726 struct evmap_io *ctx; local
727 GET_IO_SLOT(ctx, &base->io, change->fd, evmap_io);
728 ptr = ((char*)ctx) + sizeof(struct evmap_io);