Lines Matching refs:tcp_task
434 * iscsi_tcp_cleanup_task - free tcp_task resources
441 struct iscsi_tcp_task *tcp_task = task->dd_data;
449 while (kfifo_out(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*))) {
450 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t,
455 r2t = tcp_task->r2t;
457 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t,
459 tcp_task->r2t = NULL;
472 struct iscsi_tcp_task *tcp_task = task->dd_data;
487 if (tcp_task->exp_datasn != datasn) {
489 "\n", tcp_task->exp_datasn, datasn);
493 tcp_task->exp_datasn++;
495 tcp_task->data_offset = be32_to_cpu(rhdr->offset);
496 if (tcp_task->data_offset + tcp_conn->in.datalen > total_in_length) {
498 "total_length_in(%d)\n", tcp_task->data_offset,
515 struct iscsi_tcp_task *tcp_task = task->dd_data;
529 if (tcp_task->exp_datasn != r2tsn){
531 tcp_task->exp_datasn, r2tsn);
545 rc = kfifo_out(&tcp_task->r2tpool.queue, (void*)&r2t, sizeof(void*));
558 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t,
574 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t,
583 tcp_task->exp_datasn = r2tsn + 1;
584 kfifo_in(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*));
670 struct iscsi_tcp_task *tcp_task = task->dd_data;
688 tcp_task->data_offset,
694 tcp_task->data_offset,
940 struct iscsi_tcp_task *tcp_task = task->dd_data;
955 BUG_ON(kfifo_len(&tcp_task->r2tqueue));
956 tcp_task->exp_datasn = 0;
973 struct iscsi_tcp_task *tcp_task = task->dd_data;
980 if (tcp_task->r2t) {
981 r2t = tcp_task->r2t;
986 kfifo_in(&tcp_task->r2tpool.queue,
987 (void *)&tcp_task->r2t,
989 tcp_task->r2t = r2t = NULL;
994 if (kfifo_out(&tcp_task->r2tqueue,
995 (void *)&tcp_task->r2t, sizeof(void *)) !=
999 r2t = tcp_task->r2t;
1118 struct iscsi_tcp_task *tcp_task = task->dd_data;
1127 if (iscsi_pool_init(&tcp_task->r2tpool,
1134 if (kfifo_alloc(&tcp_task->r2tqueue,
1136 iscsi_pool_free(&tcp_task->r2tpool);
1146 struct iscsi_tcp_task *tcp_task = task->dd_data;
1148 kfifo_free(&tcp_task->r2tqueue);
1149 iscsi_pool_free(&tcp_task->r2tpool);
1161 struct iscsi_tcp_task *tcp_task = task->dd_data;
1163 kfifo_free(&tcp_task->r2tqueue);
1164 iscsi_pool_free(&tcp_task->r2tpool);