Lines Matching refs:module
45 static struct fpm_event_module_s *module; variable
170 if (*queue == fpm_event_queue_fd && module->add) { in fpm_event_queue_add()
171 module->add(ev); in fpm_event_queue_add()
201 if (*queue == fpm_event_queue_fd && module->remove) { in fpm_event_queue_del()
202 module->remove(ev); in fpm_event_queue_del()
222 if (*queue == fpm_event_queue_fd && module->clean) { in fpm_event_queue_destroy()
223 module->clean(); in fpm_event_queue_destroy()
240 module = fpm_event_kqueue_module(); in fpm_event_pre_init()
241 if (module) { in fpm_event_pre_init()
242 if (!machanism || strcasecmp(module->name, machanism) == 0) { in fpm_event_pre_init()
248 module = fpm_event_port_module(); in fpm_event_pre_init()
249 if (module) { in fpm_event_pre_init()
250 if (!machanism || strcasecmp(module->name, machanism) == 0) { in fpm_event_pre_init()
256 module = fpm_event_epoll_module(); in fpm_event_pre_init()
257 if (module) { in fpm_event_pre_init()
258 if (!machanism || strcasecmp(module->name, machanism) == 0) { in fpm_event_pre_init()
264 module = fpm_event_devpoll_module(); in fpm_event_pre_init()
265 if (module) { in fpm_event_pre_init()
266 if (!machanism || strcasecmp(module->name, machanism) == 0) { in fpm_event_pre_init()
272 module = fpm_event_poll_module(); in fpm_event_pre_init()
273 if (module) { in fpm_event_pre_init()
274 if (!machanism || strcasecmp(module->name, machanism) == 0) { in fpm_event_pre_init()
280 module = fpm_event_select_module(); in fpm_event_pre_init()
281 if (module) { in fpm_event_pre_init()
282 if (!machanism || strcasecmp(module->name, machanism) == 0) { in fpm_event_pre_init()
298 return module ? module->name : NULL; in fpm_event_machanism_name()
304 return module ? module->support_edge_trigger : 0; in fpm_event_support_edge_trigger()
313 if (!module) { in fpm_event_init_main()
318 if (!module->wait) { in fpm_event_init_main()
332 if (module->init(max) < 0) { in fpm_event_init_main()
333 zlog(ZLOG_ERROR, "Unable to initialize the event module %s", module->name); in fpm_event_init_main()
337 zlog(ZLOG_DEBUG, "event module is %s and %d fds have been reserved", module->name, max); in fpm_event_init_main()
411 ret = module->wait(fpm_event_queue_fd, timeout); in fpm_event_loop()
