Lines Matching defs:selector
56 tunala_selector_t selector;
75 static void selector_init(tunala_selector_t *selector);
76 static void selector_add_listener(tunala_selector_t *selector, int fd);
77 static void selector_add_tunala(tunala_selector_t *selector, tunala_item_t *t);
78 static int selector_select(tunala_selector_t *selector);
81 static int selector_get_listener(tunala_selector_t *selector, int fd, int *newfd);
85 static int tunala_item_io(tunala_selector_t *selector, tunala_item_t *item);
512 selector_init(&world.selector);
518 selector_add_listener(&world.selector, world.listen_fd);
521 selector_add_tunala(&world.selector, world.tunnels + loop);
523 switch(selector_select(&world.selector)) {
535 &world.selector, world.listen_fd,
551 if(!tunala_item_io(&world.selector, t_item)) {
829 static void selector_init(tunala_selector_t *selector)
831 selector_sets_init(&selector->last_selected);
832 selector_sets_init(&selector->next_select);
850 static void selector_add_listener(tunala_selector_t *selector, int fd)
852 selector_add_raw_fd(selector, fd, SEL_READS);
883 static int selector_select(tunala_selector_t *selector)
885 memcpy(&selector->last_selected, &selector->next_select,
887 selector_sets_init(&selector->next_select);
888 return select(selector->last_selected.max,
889 &selector->last_selected.reads,
890 &selector->last_selected.sends,
891 &selector->last_selected.excepts, NULL);
896 static int selector_get_listener(tunala_selector_t *selector, int fd, int *newfd)
898 if(FD_ISSET(fd, &selector->last_selected.excepts))
900 if(!FD_ISSET(fd, &selector->last_selected.reads))
1001 static int tunala_item_io(tunala_selector_t *selector, tunala_item_t *item)
1007 &selector->last_selected.excepts))
1010 &selector->last_selected.excepts))
1013 &selector->last_selected.excepts))
1016 &selector->last_selected.excepts))
1021 c_r = FD_ISSET(item->clean_read, &selector->last_selected.reads);
1023 c_s = FD_ISSET(item->clean_send, &selector->last_selected.sends);
1025 d_r = FD_ISSET(item->dirty_read, &selector->last_selected.reads);
1027 d_s = FD_ISSET(item->dirty_send, &selector->last_selected.sends);