Lines Matching refs:tcp_task

456 	struct iscsi_tcp_task *tcp_task = task->dd_data;  in iscsi_tcp_cleanup_task()  local
463 spin_lock_bh(&tcp_task->queue2pool); in iscsi_tcp_cleanup_task()
465 while (kfifo_out(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*))) { in iscsi_tcp_cleanup_task()
466 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t, in iscsi_tcp_cleanup_task()
471 r2t = tcp_task->r2t; in iscsi_tcp_cleanup_task()
473 kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t, in iscsi_tcp_cleanup_task()
475 tcp_task->r2t = NULL; in iscsi_tcp_cleanup_task()
477 spin_unlock_bh(&tcp_task->queue2pool); in iscsi_tcp_cleanup_task()
489 struct iscsi_tcp_task *tcp_task = task->dd_data; in iscsi_tcp_data_in() local
504 if (tcp_task->exp_datasn != datasn) { in iscsi_tcp_data_in()
506 "\n", tcp_task->exp_datasn, datasn); in iscsi_tcp_data_in()
510 tcp_task->exp_datasn++; in iscsi_tcp_data_in()
512 tcp_task->data_offset = be32_to_cpu(rhdr->offset); in iscsi_tcp_data_in()
513 if (tcp_task->data_offset + tcp_conn->in.datalen > total_in_length) { in iscsi_tcp_data_in()
515 "total_length_in(%d)\n", tcp_task->data_offset, in iscsi_tcp_data_in()
532 struct iscsi_tcp_task *tcp_task; in iscsi_tcp_r2t_rsp() local
577 tcp_task = task->dd_data; in iscsi_tcp_r2t_rsp()
579 if (tcp_task->exp_datasn != r2tsn){ in iscsi_tcp_r2t_rsp()
581 tcp_task->exp_datasn, r2tsn); in iscsi_tcp_r2t_rsp()
617 spin_lock(&tcp_task->pool2queue); in iscsi_tcp_r2t_rsp()
618 rc = kfifo_out(&tcp_task->r2tpool.queue, (void *)&r2t, sizeof(void *)); in iscsi_tcp_r2t_rsp()
623 spin_unlock(&tcp_task->pool2queue); in iscsi_tcp_r2t_rsp()
636 tcp_task->exp_datasn = r2tsn + 1; in iscsi_tcp_r2t_rsp()
637 kfifo_in(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*)); in iscsi_tcp_r2t_rsp()
639 spin_unlock(&tcp_task->pool2queue); in iscsi_tcp_r2t_rsp()
728 struct iscsi_tcp_task *tcp_task = task->dd_data; in iscsi_tcp_hdr_dissect() local
746 tcp_task->data_offset, in iscsi_tcp_hdr_dissect()
752 tcp_task->data_offset, in iscsi_tcp_hdr_dissect()
991 struct iscsi_tcp_task *tcp_task = task->dd_data; in iscsi_tcp_task_init() local
1006 BUG_ON(kfifo_len(&tcp_task->r2tqueue)); in iscsi_tcp_task_init()
1007 tcp_task->exp_datasn = 0; in iscsi_tcp_task_init()
1023 struct iscsi_tcp_task *tcp_task = task->dd_data; in iscsi_tcp_get_curr_r2t() local
1029 spin_lock_bh(&tcp_task->queue2pool); in iscsi_tcp_get_curr_r2t()
1030 if (tcp_task->r2t) { in iscsi_tcp_get_curr_r2t()
1031 r2t = tcp_task->r2t; in iscsi_tcp_get_curr_r2t()
1036 kfifo_in(&tcp_task->r2tpool.queue, in iscsi_tcp_get_curr_r2t()
1037 (void *)&tcp_task->r2t, in iscsi_tcp_get_curr_r2t()
1039 tcp_task->r2t = r2t = NULL; in iscsi_tcp_get_curr_r2t()
1044 if (kfifo_out(&tcp_task->r2tqueue, in iscsi_tcp_get_curr_r2t()
1045 (void *)&tcp_task->r2t, sizeof(void *)) != in iscsi_tcp_get_curr_r2t()
1049 r2t = tcp_task->r2t; in iscsi_tcp_get_curr_r2t()
1051 spin_unlock_bh(&tcp_task->queue2pool); in iscsi_tcp_get_curr_r2t()
1160 struct iscsi_tcp_task *tcp_task = task->dd_data; in iscsi_tcp_r2tpool_alloc() local
1169 if (iscsi_pool_init(&tcp_task->r2tpool, in iscsi_tcp_r2tpool_alloc()
1176 if (kfifo_alloc(&tcp_task->r2tqueue, in iscsi_tcp_r2tpool_alloc()
1178 iscsi_pool_free(&tcp_task->r2tpool); in iscsi_tcp_r2tpool_alloc()
1181 spin_lock_init(&tcp_task->pool2queue); in iscsi_tcp_r2tpool_alloc()
1182 spin_lock_init(&tcp_task->queue2pool); in iscsi_tcp_r2tpool_alloc()
1190 struct iscsi_tcp_task *tcp_task = task->dd_data; in iscsi_tcp_r2tpool_alloc() local
1192 kfifo_free(&tcp_task->r2tqueue); in iscsi_tcp_r2tpool_alloc()
1193 iscsi_pool_free(&tcp_task->r2tpool); in iscsi_tcp_r2tpool_alloc()
1205 struct iscsi_tcp_task *tcp_task = task->dd_data; in iscsi_tcp_r2tpool_free() local
1207 kfifo_free(&tcp_task->r2tqueue); in iscsi_tcp_r2tpool_free()
1208 iscsi_pool_free(&tcp_task->r2tpool); in iscsi_tcp_r2tpool_free()