Lines Matching refs:r2t
454 struct iscsi_r2t_info *r2t; in iscsi_tcp_cleanup_task() local
462 while (kfifo_out(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*))) { in iscsi_tcp_cleanup_task()
463 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t, in iscsi_tcp_cleanup_task()
468 r2t = tcp_task->r2t; in iscsi_tcp_cleanup_task()
469 if (r2t != NULL) { in iscsi_tcp_cleanup_task()
470 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t, in iscsi_tcp_cleanup_task()
472 tcp_task->r2t = NULL; in iscsi_tcp_cleanup_task()
532 struct iscsi_r2t_info *r2t; in iscsi_tcp_r2t_rsp() local
583 rc = kfifo_out(&tcp_task->r2tpool.queue, (void *)&r2t, sizeof(void *)); in iscsi_tcp_r2t_rsp()
592 r2t->exp_statsn = rhdr->statsn; in iscsi_tcp_r2t_rsp()
593 r2t->data_length = data_length; in iscsi_tcp_r2t_rsp()
594 r2t->data_offset = data_offset; in iscsi_tcp_r2t_rsp()
596 r2t->ttt = rhdr->ttt; /* no flip */ in iscsi_tcp_r2t_rsp()
597 r2t->datasn = 0; in iscsi_tcp_r2t_rsp()
598 r2t->sent = 0; in iscsi_tcp_r2t_rsp()
601 kfifo_in(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*)); in iscsi_tcp_r2t_rsp()
992 struct iscsi_r2t_info *r2t = NULL; in iscsi_tcp_get_curr_r2t() local
995 r2t = &task->unsol_r2t; in iscsi_tcp_get_curr_r2t()
998 if (tcp_task->r2t) { in iscsi_tcp_get_curr_r2t()
999 r2t = tcp_task->r2t; in iscsi_tcp_get_curr_r2t()
1001 if (r2t->data_length <= r2t->sent) { in iscsi_tcp_get_curr_r2t()
1003 " done with r2t %p\n", r2t); in iscsi_tcp_get_curr_r2t()
1005 (void *)&tcp_task->r2t, in iscsi_tcp_get_curr_r2t()
1007 tcp_task->r2t = r2t = NULL; in iscsi_tcp_get_curr_r2t()
1011 if (r2t == NULL) { in iscsi_tcp_get_curr_r2t()
1013 (void *)&tcp_task->r2t, sizeof(void *)) != in iscsi_tcp_get_curr_r2t()
1015 r2t = NULL; in iscsi_tcp_get_curr_r2t()
1017 r2t = tcp_task->r2t; in iscsi_tcp_get_curr_r2t()
1022 return r2t; in iscsi_tcp_get_curr_r2t()
1037 struct iscsi_r2t_info *r2t; in iscsi_tcp_task_xmit() local
1057 r2t = iscsi_tcp_get_curr_r2t(task); in iscsi_tcp_task_xmit()
1058 if (r2t == NULL) { in iscsi_tcp_task_xmit()
1067 iscsi_prep_data_out_pdu(task, r2t, (struct iscsi_data *) task->hdr); in iscsi_tcp_task_xmit()
1070 r2t, r2t->datasn - 1, task->hdr->itt, in iscsi_tcp_task_xmit()
1071 r2t->data_offset + r2t->sent, r2t->data_count); in iscsi_tcp_task_xmit()
1073 rc = conn->session->tt->init_pdu(task, r2t->data_offset + r2t->sent, in iscsi_tcp_task_xmit()
1074 r2t->data_count); in iscsi_tcp_task_xmit()
1080 r2t->sent += r2t->data_count; in iscsi_tcp_task_xmit()