Lines Matching refs:r2t
457 struct iscsi_r2t_info *r2t;
464 /* flush task's r2t queues */
465 while (kfifo_out(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*))) {
466 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t,
468 ISCSI_DBG_TCP(task->conn, "pending r2t dropped\n");
471 r2t = tcp_task->r2t;
472 if (r2t != NULL) {
473 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t,
475 tcp_task->r2t = NULL;
535 struct iscsi_r2t_info *r2t;
622 rc = kfifo_out(&tcp_task->r2tpool.queue, (void *)&r2t, sizeof(void *));
632 r2t->exp_statsn = rhdr->statsn;
633 r2t->data_length = data_length;
634 r2t->data_offset = data_offset;
636 r2t->ttt = rhdr->ttt; /* no flip */
637 r2t->datasn = 0;
638 r2t->sent = 0;
641 kfifo_in(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*));
1028 struct iscsi_r2t_info *r2t = NULL;
1031 r2t = &task->unsol_r2t;
1034 if (tcp_task->r2t) {
1035 r2t = tcp_task->r2t;
1037 if (r2t->data_length <= r2t->sent) {
1039 " done with r2t %p\n", r2t);
1041 (void *)&tcp_task->r2t,
1043 tcp_task->r2t = r2t = NULL;
1047 if (r2t == NULL) {
1049 (void *)&tcp_task->r2t, sizeof(void *)) !=
1051 r2t = NULL;
1053 r2t = tcp_task->r2t;
1058 return r2t;
1073 struct iscsi_r2t_info *r2t;
1093 r2t = iscsi_tcp_get_curr_r2t(task);
1094 if (r2t == NULL) {
1103 iscsi_prep_data_out_pdu(task, r2t, (struct iscsi_data *) task->hdr);
1106 r2t, r2t->datasn - 1, task->hdr->itt,
1107 r2t->data_offset + r2t->sent, r2t->data_count);
1109 rc = conn->session->tt->init_pdu(task, r2t->data_offset + r2t->sent,
1110 r2t->data_count);
1116 r2t->sent += r2t->data_count;