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 */
953 tunala_item_t *item;
964 item = world->tunnels + (world->tunnels_used++);
965 state_machine_init(&item->sm);
966 item->clean_read = item->clean_send =
967 item->dirty_read = item->dirty_send = -1;
976 item->dirty_read = item->dirty_send = fd;
977 item->clean_read = item->clean_send = newfd;
979 item->clean_read = item->clean_send = fd;
980 item->dirty_read = item->dirty_send = newfd;
984 if(!state_machine_set_SSL(&item->sm, new_ssl, world->server_mode))
995 tunala_item_t *item = world->tunnels + idx;
996 if(item->clean_read != -1)
997 close(item->clean_read);
998 if(item->clean_send != item->clean_read)
999 close(item->clean_send);
1000 item->clean_read = item->clean_send = -1;
1001 if(item->dirty_read != -1)
1002 close(item->dirty_read);
1003 if(item->dirty_send != item->dirty_read)
1004 close(item->dirty_send);
1005 item->dirty_read = item->dirty_send = -1;
1006 state_machine_close(&item->sm);
1007 /* OK, now we fix the item array */
1017 static int tunala_item_io(tunala_selector_t *selector, tunala_item_t *item)
1022 if((item->clean_read != -1) && FD_ISSET(item->clean_read,
1025 if((item->clean_send != -1) && FD_ISSET(item->clean_send,
1028 if((item->dirty_read != -1) && FD_ISSET(item->dirty_read,
1031 if((item->dirty_send != -1) && FD_ISSET(item->dirty_send,
1036 if(item->clean_read != -1)
1037 c_r = FD_ISSET(item->clean_read, &selector->last_selected.reads);
1038 if(item->clean_send != -1)
1039 c_s = FD_ISSET(item->clean_send, &selector->last_selected.sends);
1040 if(item->dirty_read != -1)
1041 d_r = FD_ISSET(item->dirty_read, &selector->last_selected.reads);
1042 if(item->dirty_send != -1)
1043 d_s = FD_ISSET(item->dirty_send, &selector->last_selected.sends);
1048 c_r = (buffer_from_fd(state_machine_get_buffer(&item->sm,
1049 SM_CLEAN_IN), item->clean_read) <= 0);
1051 c_s = (buffer_to_fd(state_machine_get_buffer(&item->sm,
1052 SM_CLEAN_OUT), item->clean_send) <= 0);
1054 d_r = (buffer_from_fd(state_machine_get_buffer(&item->sm,
1055 SM_DIRTY_IN), item->dirty_read) <= 0);
1057 d_s = (buffer_to_fd(state_machine_get_buffer(&item->sm,
1058 SM_DIRTY_OUT), item->dirty_send) <= 0);
1061 close(item->clean_read);
1062 if(item->clean_send == item->clean_read)
1063 item->clean_send = -1;
1064 item->clean_read = -1;
1066 if(c_s && (item->clean_send != -1)) {
1067 close(item->clean_send);
1068 if(item->clean_send == item->clean_read)
1069 item->clean_read = -1;
1070 item->clean_send = -1;
1073 close(item->dirty_read);
1074 if(item->dirty_send == item->dirty_read)
1075 item->dirty_send = -1;
1076 item->dirty_read = -1;
1078 if(d_s && (item->dirty_send != -1)) {
1079 close(item->dirty_send);
1080 if(item->dirty_send == item->dirty_read)
1081 item->dirty_read = -1;
1082 item->dirty_send = -1;
1087 if(!state_machine_churn(&item->sm))
1094 if(((item->clean_read == -1) || (item->clean_send == -1)) &&
1095 ((item->dirty_read == -1) || (item->dirty_send == -1)))
1099 if((item->clean_read == -1) || (item->clean_send == -1)) {
1100 if(!state_machine_close_clean(&item->sm))
1103 if((item->dirty_read == -1) || (item->dirty_send == -1)) {
1104 if(!state_machine_close_dirty(&item->sm))