Lines Matching refs:module
43 static struct fpm_event_module_s *module; variable
188 if (*queue == fpm_event_queue_fd && module->add) { in fpm_event_queue_add()
189 module->add(ev); in fpm_event_queue_add()
219 if (*queue == fpm_event_queue_fd && module->remove) { in fpm_event_queue_del()
220 module->remove(ev); in fpm_event_queue_del()
240 if (*queue == fpm_event_queue_fd && module->clean) { in fpm_event_queue_destroy()
241 module->clean(); in fpm_event_queue_destroy()
258 module = fpm_event_kqueue_module(); in fpm_event_pre_init()
259 if (module) { in fpm_event_pre_init()
260 if (!mechanism || strcasecmp(module->name, mechanism) == 0) { in fpm_event_pre_init()
266 module = fpm_event_port_module(); in fpm_event_pre_init()
267 if (module) { in fpm_event_pre_init()
268 if (!mechanism || strcasecmp(module->name, mechanism) == 0) { in fpm_event_pre_init()
274 module = fpm_event_epoll_module(); in fpm_event_pre_init()
275 if (module) { in fpm_event_pre_init()
276 if (!mechanism || strcasecmp(module->name, mechanism) == 0) { in fpm_event_pre_init()
282 module = fpm_event_poll_module(); in fpm_event_pre_init()
283 if (module) { in fpm_event_pre_init()
284 if (!mechanism || strcasecmp(module->name, mechanism) == 0) { in fpm_event_pre_init()
290 module = fpm_event_select_module(); in fpm_event_pre_init()
291 if (module) { in fpm_event_pre_init()
292 if (!mechanism || strcasecmp(module->name, mechanism) == 0) { in fpm_event_pre_init()
308 return module ? module->name : NULL; in fpm_event_mechanism_name()
313 return module ? module->support_edge_trigger : 0; in fpm_event_support_edge_trigger()
321 if (!module) { in fpm_event_init_main()
326 if (!module->wait) { in fpm_event_init_main()
340 if (module->init(max) < 0) { in fpm_event_init_main()
341 zlog(ZLOG_ERROR, "Unable to initialize the event module %s", module->name); in fpm_event_init_main()
345 zlog(ZLOG_DEBUG, "event module is %s and %d fds have been reserved", module->name, max); in fpm_event_init_main()
418 ret = module->wait(fpm_event_queue_fd, timeout); in fpm_event_loop()
