TESTS: simple LU RESET TMF test
Dispatch a write and subsequently reset the logical unit via iSCSI TMF. This is based on the AbortTaskSimpleAsync test. Signed-off-by: David Disseldorp <ddiss@suse.de>
This commit is contained in:
David Disseldorp
committed by
Ronnie Sahlberg
Ronnie Sahlberg
parent
d3ef192021
commit
e6f7d5328c
@@ -233,7 +233,8 @@ iscsi_test_cu_SOURCES = iscsi-test-cu.c \
|
||||
test_multipathio_async_caw.c \
|
||||
test_async_read.c \
|
||||
test_async_write.c \
|
||||
test_async_abort_simple.c
|
||||
test_async_abort_simple.c \
|
||||
test_async_lu_reset_simple.c
|
||||
|
||||
endif
|
||||
|
||||
|
||||
@@ -580,6 +580,7 @@ static CU_TestInfo tests_iscsi_residuals[] = {
|
||||
|
||||
static CU_TestInfo tests_iscsi_tmf[] = {
|
||||
{ (char *)"AbortTaskSimpleAsync", test_async_abort_simple },
|
||||
{ (char *)"LUNResetSimpleAsync", test_async_lu_reset_simple },
|
||||
CU_TEST_INFO_NULL
|
||||
};
|
||||
|
||||
|
||||
@@ -322,5 +322,6 @@ void test_multipathio_compareandwrite(void);
|
||||
void test_mpio_async_caw(void);
|
||||
|
||||
void test_async_abort_simple(void);
|
||||
void test_async_lu_reset_simple(void);
|
||||
|
||||
#endif /* _ISCSI_TEST_CU_H_ */
|
||||
|
||||
195
test-tool/test_async_lu_reset_simple.c
Normal file
195
test-tool/test_async_lu_reset_simple.c
Normal file
@@ -0,0 +1,195 @@
|
||||
/*
|
||||
Copyright (C) SUSE LINUX GmbH 2016
|
||||
|
||||
This program is free software; you can redistribute it and/or modify
|
||||
it under the terms of the GNU General Public License as published by
|
||||
the Free Software Foundation; either version 2 of the License, or
|
||||
(at your option) any later version.
|
||||
|
||||
This program is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with this program; if not, see <http://www.gnu.org/licenses/>.
|
||||
*/
|
||||
|
||||
#include <stdio.h>
|
||||
#include <signal.h>
|
||||
#include <poll.h>
|
||||
|
||||
#include <CUnit/CUnit.h>
|
||||
|
||||
#include "iscsi.h"
|
||||
#include "scsi-lowlevel.h"
|
||||
#include "iscsi-support.h"
|
||||
#include "iscsi-test-cu.h"
|
||||
|
||||
struct tests_async_reset_state {
|
||||
struct scsi_task *wtask;
|
||||
uint32_t wr_cancelled;
|
||||
uint32_t wr_good;
|
||||
uint32_t reset_ok;
|
||||
};
|
||||
|
||||
static void
|
||||
test_async_write_cb(struct iscsi_context *iscsi __attribute__((unused)),
|
||||
int status, void *command_data,
|
||||
void *private_data)
|
||||
{
|
||||
struct scsi_task *wtask = command_data;
|
||||
struct tests_async_reset_state *state = private_data;
|
||||
|
||||
if (status == SCSI_STATUS_GOOD) {
|
||||
state->wr_good++;
|
||||
logging(LOG_VERBOSE, "WRITE10 successful: (CmdSN=0x%x, "
|
||||
"ITT=0x%x)", wtask->cmdsn, wtask->itt);
|
||||
} else if (status == SCSI_STATUS_CANCELLED) {
|
||||
state->wr_cancelled++;
|
||||
logging(LOG_VERBOSE, "WRITE10 cancelled: (CmdSN=0x%x, "
|
||||
"ITT=0x%x)", wtask->cmdsn, wtask->itt);
|
||||
} else {
|
||||
CU_ASSERT_NOT_EQUAL(status, SCSI_STATUS_CHECK_CONDITION);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
test_async_reset_cb(struct iscsi_context *iscsi __attribute__((unused)),
|
||||
int status, void *command_data,
|
||||
void *private_data)
|
||||
{
|
||||
uint32_t tmf_response;
|
||||
struct tests_async_reset_state *state = private_data;
|
||||
|
||||
/* command_data NULL if a reconnect occured. see iscsi_reconnect_cb() */
|
||||
CU_ASSERT_PTR_NOT_NULL_FATAL(command_data);
|
||||
tmf_response = *(uint32_t *)command_data;
|
||||
|
||||
logging(LOG_VERBOSE, "LU RESET: TMF response %d for"
|
||||
" RefCmdSN=0x%x, RefITT=0x%x",
|
||||
tmf_response, state->wtask->cmdsn, state->wtask->itt);
|
||||
if (tmf_response == ISCSI_TMR_FUNC_COMPLETE) {
|
||||
state->reset_ok++;
|
||||
logging(LOG_VERBOSE, "LU RESET completed");
|
||||
} else {
|
||||
logging(LOG_NORMAL, "LU RESET: unexpected TMF response %d for"
|
||||
" RefCmdSN=0x%x, RefITT=0x%x",
|
||||
tmf_response, state->wtask->cmdsn, state->wtask->itt);
|
||||
CU_ASSERT_FATAL((tmf_response != ISCSI_TMR_FUNC_COMPLETE)
|
||||
&& (tmf_response != ISCSI_TMR_TASK_DOES_NOT_EXIST));
|
||||
}
|
||||
CU_ASSERT_NOT_EQUAL(status, SCSI_STATUS_CHECK_CONDITION);
|
||||
}
|
||||
|
||||
void
|
||||
test_async_lu_reset_simple(void)
|
||||
{
|
||||
int ret;
|
||||
struct tests_async_reset_state state = { NULL, 0, 0, 0, };
|
||||
int blocksize = 512;
|
||||
int blocks_per_io = 8;
|
||||
unsigned char buf[blocksize * blocks_per_io];
|
||||
uint64_t timeout_sec;
|
||||
|
||||
CHECK_FOR_DATALOSS;
|
||||
CHECK_FOR_SBC;
|
||||
if (sd->iscsi_ctx == NULL) {
|
||||
CU_PASS("[SKIPPED] Non-iSCSI");
|
||||
return;
|
||||
}
|
||||
|
||||
if (maximum_transfer_length
|
||||
&& (maximum_transfer_length < (int)(blocks_per_io))) {
|
||||
CU_PASS("[SKIPPED] device too small for async_reset test");
|
||||
return;
|
||||
}
|
||||
|
||||
memset(buf, 0, blocksize * blocks_per_io);
|
||||
|
||||
/* queue and dispatch write before the reset */
|
||||
state.wtask = scsi_cdb_write10(0, blocks_per_io * blocksize,
|
||||
blocksize, 0, 0, 0, 0, 0);
|
||||
CU_ASSERT_PTR_NOT_NULL_FATAL(state.wtask);
|
||||
|
||||
ret = scsi_task_add_data_out_buffer(state.wtask,
|
||||
blocks_per_io * blocksize,
|
||||
buf);
|
||||
CU_ASSERT_EQUAL(ret, 0);
|
||||
|
||||
ret = iscsi_scsi_command_async(sd->iscsi_ctx, sd->iscsi_lun,
|
||||
state.wtask, test_async_write_cb, NULL,
|
||||
&state);
|
||||
CU_ASSERT_EQUAL(ret, 0);
|
||||
|
||||
logging(LOG_VERBOSE, "WRITE10 queued: (CmdSN=0x%x, ITT=0x%x)",
|
||||
state.wtask->cmdsn, state.wtask->itt);
|
||||
|
||||
CU_ASSERT_EQUAL(iscsi_out_queue_length(sd->iscsi_ctx), 1);
|
||||
|
||||
logging(LOG_VERBOSE, "dispatching out queue...");
|
||||
while ((uint32_t)iscsi_out_queue_length(sd->iscsi_ctx) > 0) {
|
||||
struct pollfd pfd;
|
||||
|
||||
pfd.fd = iscsi_get_fd(sd->iscsi_ctx);
|
||||
pfd.events = POLLOUT; /* only send */
|
||||
|
||||
ret = poll(&pfd, 1, 1000);
|
||||
CU_ASSERT_NOT_EQUAL(ret, -1);
|
||||
|
||||
ret = iscsi_service(sd->iscsi_ctx, pfd.revents);
|
||||
CU_ASSERT_EQUAL(ret, 0);
|
||||
}
|
||||
logging(LOG_VERBOSE, "dispatched");
|
||||
|
||||
/*
|
||||
* queue reset. TMF req should be sent to the target.
|
||||
*/
|
||||
ret = iscsi_task_mgmt_async(sd->iscsi_ctx,
|
||||
state.wtask->lun, ISCSI_TM_LUN_RESET,
|
||||
0xffffffff, 0,
|
||||
test_async_reset_cb, &state);
|
||||
CU_ASSERT_EQUAL(ret, 0);
|
||||
|
||||
logging(LOG_VERBOSE, "LU RESET queued");
|
||||
|
||||
/*
|
||||
* wait for reset response, timeout in 5 seconds. Expected responses:
|
||||
* + WRITE:good, RESET:ok - write handled before reset
|
||||
* + WRITE:no-response, RESET:ok - write aborted by reset
|
||||
*/
|
||||
logging(LOG_VERBOSE, "dispatching reset and handling responses...");
|
||||
timeout_sec = test_get_clock_sec() + 5;
|
||||
while (test_get_clock_sec() <= timeout_sec) {
|
||||
struct pollfd pfd;
|
||||
|
||||
pfd.fd = iscsi_get_fd(sd->iscsi_ctx);
|
||||
pfd.events = iscsi_which_events(sd->iscsi_ctx);
|
||||
|
||||
ret = poll(&pfd, 1, 1000);
|
||||
CU_ASSERT_NOT_EQUAL(ret, -1);
|
||||
|
||||
ret = iscsi_service(sd->iscsi_ctx, pfd.revents);
|
||||
CU_ASSERT_EQUAL(ret, 0);
|
||||
|
||||
if (state.reset_ok == 1) {
|
||||
logging(LOG_VERBOSE, "received all expected responses");
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
logging(LOG_VERBOSE, "%d IOs completed, %d resets successful",
|
||||
state.wr_good, state.reset_ok);
|
||||
|
||||
if (state.reset_ok == 1) {
|
||||
/*
|
||||
* don't assert on wr_good, as whether the WRITE was aborted
|
||||
* or handled is time dependent.
|
||||
*/
|
||||
CU_ASSERT_EQUAL(state.wr_cancelled, 0);
|
||||
} else {
|
||||
CU_FAIL("unexpected WRITE/RESET state");
|
||||
}
|
||||
|
||||
scsi_free_scsi_task(state.wtask);
|
||||
}
|
||||
Reference in New Issue
Block a user