Commit 9166bb3c authored by Shuhei Matsumoto's avatar Shuhei Matsumoto Committed by Ben Walker
Browse files

ut/iscsi: Add UT for clear_all_transfer_tasks (Delete all or LUN specific tasks) 



Change-Id: I4694b2fdfafa64e7d2621e5b004f46a7072173e7
Signed-off-by: default avatarShuhei Matsumoto <shuhei.matsumoto.xt@hitachi.com>
Reviewed-on: https://review.gerrithub.io/418761


Tested-by: default avatarSPDK Automated Test System <sys_sgsw@intel.com>
Reviewed-by: default avatarJim Harris <james.r.harris@intel.com>
Reviewed-by: default avatarBen Walker <benjamin.walker@intel.com>
parent d02e91b3

test/unit/lib/iscsi/iscsi.c/iscsi_ut.c

+125 −0
Original line number Diff line number Diff line
@@ -789,6 +789,129 @@ del_transfer_task_test(void) 
	spdk_put_pdu(pdu1);

}



static void

clear_all_transfer_tasks_test(void)

{

	struct spdk_iscsi_sess sess;

	struct spdk_iscsi_conn conn;

	struct spdk_iscsi_task *task1, *task2, *task3, *task4, *task5;

	struct spdk_iscsi_pdu *pdu1, *pdu2, *pdu3, *pdu4, *pdu5, *pdu;

	struct spdk_scsi_lun lun1, lun2;

	int rc;



	memset(&sess, 0, sizeof(sess));

	memset(&conn, 0, sizeof(conn));

	memset(&lun1, 0, sizeof(lun1));

	memset(&lun2, 0, sizeof(lun2));



	sess.MaxBurstLength = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	sess.MaxOutstandingR2T = 1;



	conn.sess = &sess;

	TAILQ_INIT(&conn.active_r2t_tasks);

	TAILQ_INIT(&conn.queued_r2t_tasks);



	task1 = spdk_iscsi_task_get(&conn, NULL, NULL);

	SPDK_CU_ASSERT_FATAL(task1 != NULL);

	pdu1 = spdk_get_pdu();

	SPDK_CU_ASSERT_FATAL(pdu1 != NULL);



	pdu1->data_segment_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task1->scsi.transfer_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task1->scsi.lun = &lun1;

	spdk_iscsi_task_set_pdu(task1, pdu1);



	rc = spdk_add_transfer_task(&conn, task1);

	CU_ASSERT(rc == SPDK_SUCCESS);



	task2 = spdk_iscsi_task_get(&conn, NULL, NULL);

	SPDK_CU_ASSERT_FATAL(task2 != NULL);

	pdu2 = spdk_get_pdu();

	SPDK_CU_ASSERT_FATAL(pdu2 != NULL);



	pdu2->data_segment_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task2->scsi.transfer_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task2->scsi.lun = &lun1;

	spdk_iscsi_task_set_pdu(task2, pdu2);



	rc = spdk_add_transfer_task(&conn, task2);

	CU_ASSERT(rc == SPDK_SUCCESS);



	task3 = spdk_iscsi_task_get(&conn, NULL, NULL);

	SPDK_CU_ASSERT_FATAL(task3 != NULL);

	pdu3 = spdk_get_pdu();

	SPDK_CU_ASSERT_FATAL(pdu3 != NULL);



	pdu3->data_segment_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task3->scsi.transfer_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task3->scsi.lun = &lun1;

	spdk_iscsi_task_set_pdu(task3, pdu3);



	rc = spdk_add_transfer_task(&conn, task3);

	CU_ASSERT(rc == SPDK_SUCCESS);



	task4 = spdk_iscsi_task_get(&conn, NULL, NULL);

	SPDK_CU_ASSERT_FATAL(task4 != NULL);

	pdu4 = spdk_get_pdu();

	SPDK_CU_ASSERT_FATAL(pdu4 != NULL);



	pdu4->data_segment_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task4->scsi.transfer_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task4->scsi.lun = &lun2;

	spdk_iscsi_task_set_pdu(task4, pdu4);



	rc = spdk_add_transfer_task(&conn, task4);

	CU_ASSERT(rc == SPDK_SUCCESS);



	task5 = spdk_iscsi_task_get(&conn, NULL, NULL);

	SPDK_CU_ASSERT_FATAL(task5 != NULL);

	pdu5 = spdk_get_pdu();

	SPDK_CU_ASSERT_FATAL(pdu5 != NULL);



	pdu5->data_segment_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task5->scsi.transfer_len = SPDK_ISCSI_MAX_RECV_DATA_SEGMENT_LENGTH;

	task5->scsi.lun = &lun2;

	spdk_iscsi_task_set_pdu(task5, pdu5);



	rc = spdk_add_transfer_task(&conn, task5);

	CU_ASSERT(rc == SPDK_SUCCESS);



	CU_ASSERT(conn.ttt == 4);



	CU_ASSERT(spdk_get_transfer_task(&conn, 1) == task1);

	CU_ASSERT(spdk_get_transfer_task(&conn, 2) == task2);

	CU_ASSERT(spdk_get_transfer_task(&conn, 3) == task3);

	CU_ASSERT(spdk_get_transfer_task(&conn, 4) == task4);

	CU_ASSERT(spdk_get_transfer_task(&conn, 5) == NULL);



	spdk_clear_all_transfer_task(&conn, &lun1);



	CU_ASSERT(spdk_get_transfer_task(&conn, 1) == NULL);

	CU_ASSERT(spdk_get_transfer_task(&conn, 2) == NULL);

	CU_ASSERT(spdk_get_transfer_task(&conn, 3) == NULL);

	CU_ASSERT(spdk_get_transfer_task(&conn, 4) == task4);

	CU_ASSERT(spdk_get_transfer_task(&conn, 5) == NULL);



	spdk_clear_all_transfer_task(&conn, NULL);



	CU_ASSERT(spdk_get_transfer_task(&conn, 4) == NULL);

	CU_ASSERT(spdk_get_transfer_task(&conn, 5) == NULL);



	CU_ASSERT(TAILQ_EMPTY(&conn.queued_r2t_tasks));

	CU_ASSERT(TAILQ_EMPTY(&conn.active_r2t_tasks));

	while (!TAILQ_EMPTY(&g_write_pdu_list)) {

		pdu = TAILQ_FIRST(&g_write_pdu_list);

		TAILQ_REMOVE(&g_write_pdu_list, pdu, tailq);

		spdk_put_pdu(pdu);

	}



	spdk_put_pdu(pdu5);

	spdk_put_pdu(pdu4);

	spdk_put_pdu(pdu3);

	spdk_put_pdu(pdu2);

	spdk_put_pdu(pdu1);

}



int

main(int argc, char **argv)

{
@@ -819,6 +942,8 @@ main(int argc, char **argv) 
		|| CU_add_test(suite, "add transfer task test", add_transfer_task_test) == NULL

		|| CU_add_test(suite, "get transfer task test", get_transfer_task_test) == NULL

		|| CU_add_test(suite, "del transfer task test", del_transfer_task_test) == NULL

		|| CU_add_test(suite, "clear all transfer tasks test",

			       clear_all_transfer_tasks_test) == NULL

	) {

		CU_cleanup_registry();

		return CU_get_error();