Lines Matching refs:item
85 static int tunala_item_io(tunala_selector_t *selector, tunala_item_t *item);
565 * the next item is moving to us! */
591 /* Move to the next item */
951 tunala_item_t *item;
962 item = world->tunnels + (world->tunnels_used++);
963 state_machine_init(&item->sm);
964 item->clean_read = item->clean_send =
965 item->dirty_read = item->dirty_send = -1;
974 item->dirty_read = item->dirty_send = fd;
975 item->clean_read = item->clean_send = newfd;
977 item->clean_read = item->clean_send = fd;
978 item->dirty_read = item->dirty_send = newfd;
982 if(!state_machine_set_SSL(&item->sm, new_ssl, world->server_mode))
993 tunala_item_t *item = world->tunnels + idx;
994 if(item->clean_read != -1)
995 close(item->clean_read);
996 if(item->clean_send != item->clean_read)
997 close(item->clean_send);
998 item->clean_read = item->clean_send = -1;
999 if(item->dirty_read != -1)
1000 close(item->dirty_read);
1001 if(item->dirty_send != item->dirty_read)
1002 close(item->dirty_send);
1003 item->dirty_read = item->dirty_send = -1;
1004 state_machine_close(&item->sm);
1005 /* OK, now we fix the item array */
1015 static int tunala_item_io(tunala_selector_t *selector, tunala_item_t *item)
1020 if((item->clean_read != -1) && FD_ISSET(item->clean_read,
1023 if((item->clean_send != -1) && FD_ISSET(item->clean_send,
1026 if((item->dirty_read != -1) && FD_ISSET(item->dirty_read,
1029 if((item->dirty_send != -1) && FD_ISSET(item->dirty_send,
1034 if(item->clean_read != -1)
1035 c_r = FD_ISSET(item->clean_read, &selector->last_selected.reads);
1036 if(item->clean_send != -1)
1037 c_s = FD_ISSET(item->clean_send, &selector->last_selected.sends);
1038 if(item->dirty_read != -1)
1039 d_r = FD_ISSET(item->dirty_read, &selector->last_selected.reads);
1040 if(item->dirty_send != -1)
1041 d_s = FD_ISSET(item->dirty_send, &selector->last_selected.sends);
1046 c_r = (buffer_from_fd(state_machine_get_buffer(&item->sm,
1047 SM_CLEAN_IN), item->clean_read) <= 0);
1049 c_s = (buffer_to_fd(state_machine_get_buffer(&item->sm,
1050 SM_CLEAN_OUT), item->clean_send) <= 0);
1052 d_r = (buffer_from_fd(state_machine_get_buffer(&item->sm,
1053 SM_DIRTY_IN), item->dirty_read) <= 0);
1055 d_s = (buffer_to_fd(state_machine_get_buffer(&item->sm,
1056 SM_DIRTY_OUT), item->dirty_send) <= 0);
1059 close(item->clean_read);
1060 if(item->clean_send == item->clean_read)
1061 item->clean_send = -1;
1062 item->clean_read = -1;
1064 if(c_s && (item->clean_send != -1)) {
1065 close(item->clean_send);
1066 if(item->clean_send == item->clean_read)
1067 item->clean_read = -1;
1068 item->clean_send = -1;
1071 close(item->dirty_read);
1072 if(item->dirty_send == item->dirty_read)
1073 item->dirty_send = -1;
1074 item->dirty_read = -1;
1076 if(d_s && (item->dirty_send != -1)) {
1077 close(item->dirty_send);
1078 if(item->dirty_send == item->dirty_read)
1079 item->dirty_read = -1;
1080 item->dirty_send = -1;
1085 if(!state_machine_churn(&item->sm))
1092 if(((item->clean_read == -1) || (item->clean_send == -1)) &&
1093 ((item->dirty_read == -1) || (item->dirty_send == -1)))
1097 if((item->clean_read == -1) || (item->clean_send == -1)) {
1098 if(!state_machine_close_clean(&item->sm))
1101 if((item->dirty_read == -1) || (item->dirty_send == -1)) {
1102 if(!state_machine_close_dirty(&item->sm))