Lines Matching defs:item
109 static int tunala_item_io(tunala_selector_t * selector, tunala_item_t * item);
613 * close. Don't increment loop or t_item because the next item is
641 /* Move to the next item */
1013 tunala_item_t *item;
1024 item = world->tunnels + (world->tunnels_used++);
1025 state_machine_init(&item->sm);
1026 item->clean_read = item->clean_send =
1027 item->dirty_read = item->dirty_send = -1;
1037 item->dirty_read = item->dirty_send = fd;
1038 item->clean_read = item->clean_send = newfd;
1040 item->clean_read = item->clean_send = fd;
1041 item->dirty_read = item->dirty_send = newfd;
1047 if (!state_machine_set_SSL(&item->sm, new_ssl, world->server_mode))
1058 tunala_item_t *item = world->tunnels + idx;
1059 if (item->clean_read != -1)
1060 close(item->clean_read);
1061 if (item->clean_send != item->clean_read)
1062 close(item->clean_send);
1063 item->clean_read = item->clean_send = -1;
1064 if (item->dirty_read != -1)
1065 close(item->dirty_read);
1066 if (item->dirty_send != item->dirty_read)
1067 close(item->dirty_send);
1068 item->dirty_read = item->dirty_send = -1;
1069 state_machine_close(&item->sm);
1070 /* OK, now we fix the item array */
1079 static int tunala_item_io(tunala_selector_t * selector, tunala_item_t * item)
1084 if ((item->clean_read != -1) && FD_ISSET(item->clean_read,
1088 if ((item->clean_send != -1) && FD_ISSET(item->clean_send,
1092 if ((item->dirty_read != -1) && FD_ISSET(item->dirty_read,
1096 if ((item->dirty_send != -1) && FD_ISSET(item->dirty_send,
1102 if (item->clean_read != -1)
1103 c_r = FD_ISSET(item->clean_read, &selector->last_selected.reads);
1104 if (item->clean_send != -1)
1105 c_s = FD_ISSET(item->clean_send, &selector->last_selected.sends);
1106 if (item->dirty_read != -1)
1107 d_r = FD_ISSET(item->dirty_read, &selector->last_selected.reads);
1108 if (item->dirty_send != -1)
1109 d_s = FD_ISSET(item->dirty_send, &selector->last_selected.sends);
1114 c_r = (buffer_from_fd(state_machine_get_buffer(&item->sm,
1116 item->clean_read) <= 0);
1118 c_s = (buffer_to_fd(state_machine_get_buffer(&item->sm,
1120 item->clean_send) <= 0);
1122 d_r = (buffer_from_fd(state_machine_get_buffer(&item->sm,
1124 item->dirty_read) <= 0);
1126 d_s = (buffer_to_fd(state_machine_get_buffer(&item->sm,
1128 item->dirty_send) <= 0);
1131 close(item->clean_read);
1132 if (item->clean_send == item->clean_read)
1133 item->clean_send = -1;
1134 item->clean_read = -1;
1136 if (c_s && (item->clean_send != -1)) {
1137 close(item->clean_send);
1138 if (item->clean_send == item->clean_read)
1139 item->clean_read = -1;
1140 item->clean_send = -1;
1143 close(item->dirty_read);
1144 if (item->dirty_send == item->dirty_read)
1145 item->dirty_send = -1;
1146 item->dirty_read = -1;
1148 if (d_s && (item->dirty_send != -1)) {
1149 close(item->dirty_send);
1150 if (item->dirty_send == item->dirty_read)
1151 item->dirty_read = -1;
1152 item->dirty_send = -1;
1159 if (!state_machine_churn(&item->sm))
1167 if (((item->clean_read == -1) || (item->clean_send == -1)) &&
1168 ((item->dirty_read == -1) || (item->dirty_send == -1)))
1174 if ((item->clean_read == -1) || (item->clean_send == -1)) {
1175 if (!state_machine_close_clean(&item->sm))
1178 if ((item->dirty_read == -1) || (item->dirty_send == -1)) {
1179 if (!state_machine_close_dirty(&item->sm))