drivers/scsi/libiscsi_tcp.c

449  * iscsi_tcp_cleanup_task - free tcp_task resources
456 	struct iscsi_tcp_task *tcp_task = task->dd_data;
463 	spin_lock_bh(&tcp_task->queue2pool);
465 	while (kfifo_out(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*))) {
466 		kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t,
471 	r2t = tcp_task->r2t;
473 		kfifo_in(&tcp_task->r2tpool.queue, (void*)&r2t,
475 		tcp_task->r2t = NULL;
477 	spin_unlock_bh(&tcp_task->queue2pool);
489 	struct iscsi_tcp_task *tcp_task = task->dd_data;
504 	if (tcp_task->exp_datasn != datasn) {
506 			      "\n", tcp_task->exp_datasn, datasn);
510 	tcp_task->exp_datasn++;
512 	tcp_task->data_offset = be32_to_cpu(rhdr->offset);
513 	if (tcp_task->data_offset + tcp_conn->in.datalen > total_in_length) {
515 			      "total_length_in(%d)\n", tcp_task->data_offset,
532 	struct iscsi_tcp_task *tcp_task;
581 	tcp_task = task->dd_data;
583 	if (tcp_task->exp_datasn != r2tsn){
585 			      tcp_task->exp_datasn, r2tsn);
621 	spin_lock(&tcp_task->pool2queue);
622 	rc = kfifo_out(&tcp_task->r2tpool.queue, (void *)&r2t, sizeof(void *));
627 		spin_unlock(&tcp_task->pool2queue);
640 	tcp_task->exp_datasn = r2tsn + 1;
641 	kfifo_in(&tcp_task->r2tqueue, (void*)&r2t, sizeof(void*));
643 	spin_unlock(&tcp_task->pool2queue);
732 			struct iscsi_tcp_task *tcp_task = task->dd_data;
750 				      tcp_task->data_offset,
756 						   tcp_task->data_offset,
995 	struct iscsi_tcp_task *tcp_task = task->dd_data;
1010 	BUG_ON(kfifo_len(&tcp_task->r2tqueue));
1011 	tcp_task->exp_datasn = 0;
1027 	struct iscsi_tcp_task *tcp_task = task->dd_data;
1033 		spin_lock_bh(&tcp_task->queue2pool);
1034 		if (tcp_task->r2t) {
1035 			r2t = tcp_task->r2t;
1040 				kfifo_in(&tcp_task->r2tpool.queue,
1041 					    (void *)&tcp_task->r2t,
1043 				tcp_task->r2t = r2t = NULL;
1048 			if (kfifo_out(&tcp_task->r2tqueue,
1049 			    (void *)&tcp_task->r2t, sizeof(void *)) !=
1053 				r2t = tcp_task->r2t;
1055 		spin_unlock_bh(&tcp_task->queue2pool);
1164 		struct iscsi_tcp_task *tcp_task = task->dd_data;
1173 		if (iscsi_pool_init(&tcp_task->r2tpool,
1180 		if (kfifo_alloc(&tcp_task->r2tqueue,
1182 			iscsi_pool_free(&tcp_task->r2tpool);
1185 		spin_lock_init(&tcp_task->pool2queue);
1186 		spin_lock_init(&tcp_task->queue2pool);
1194 		struct iscsi_tcp_task *tcp_task = task->dd_data;
1196 		kfifo_free(&tcp_task->r2tqueue);
1197 		iscsi_pool_free(&tcp_task->r2tpool);
1209 		struct iscsi_tcp_task *tcp_task = task->dd_data;
1211 		kfifo_free(&tcp_task->r2tqueue);
1212 		iscsi_pool_free(&tcp_task->r2tpool);