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);
518 selector_init(&world.selector);
524 selector_add_listener(&world.selector, world.listen_fd);
527 selector_add_tunala(&world.selector, world.tunnels + loop);
529 switch(selector_select(&world.selector)) {
536 fprintf(stderr, "Warn, selector interrupted by a signal\n");
546 &world.selector, world.listen_fd,
562 if(!tunala_item_io(&world.selector, t_item)) {
843 static void selector_init(tunala_selector_t *selector)
845 selector_sets_init(&selector->last_selected);
846 selector_sets_init(&selector->next_select);
864 static void selector_add_listener(tunala_selector_t *selector, int fd)
866 selector_add_raw_fd(selector, fd, SEL_READS);
897 static int selector_select(tunala_selector_t *selector)
899 memcpy(&selector->last_selected, &selector->next_select,
901 selector_sets_init(&selector->next_select);
902 return select(selector->last_selected.max,
903 &selector->last_selected.reads,
904 &selector->last_selected.sends,
905 &selector->last_selected.excepts, NULL);
910 static int selector_get_listener(tunala_selector_t *selector, int fd, int *newfd)
912 if(FD_ISSET(fd, &selector->last_selected.excepts))
914 if(!FD_ISSET(fd, &selector->last_selected.reads))
1015 static int tunala_item_io(tunala_selector_t *selector, tunala_item_t *item)
1021 &selector->last_selected.excepts))
1024 &selector->last_selected.excepts))
1027 &selector->last_selected.excepts))
1030 &selector->last_selected.excepts))
1035 c_r = FD_ISSET(item->clean_read, &selector->last_selected.reads);
1037 c_s = FD_ISSET(item->clean_send, &selector->last_selected.sends);
1039 d_r = FD_ISSET(item->dirty_read, &selector->last_selected.reads);
1041 d_s = FD_ISSET(item->dirty_send, &selector->last_selected.sends);