[PATCH 1/2] Add infrastructure for statistics on SCSI device level

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

 



To introduce statistics on SCSI device level we need to accumulate them
for each ITL (initiator-target-lun) nexus.

For example in case of iscsi, this is a granularity which is finer than
a session (IT nexus), as it represents access to a specific lun within
the session.

Statistics counters are added to the ITL object, "struct it_nexus_lu_info".
They need to be shown later in various scopes (connection, device, target etc.)
requiring two-way access, both from a device (lun to all its ITLs) and
from an IT nexus (IT nexus to all its ITLs).

Thus a linked list's head called "it_nexus_lu_info_list" is added to both
struct scsi_lu and struct it_nexus, while struct it_nexus_lu_info
becomes a memeber in these two lists, thru the entries called:
itn_siblings and lu_siblings.

Signed-off-by: Alexander Nezhinsky <alexandern@xxxxxxxxxxxx>
---
 usr/scsi.c   |   16 +++++++++++++-
 usr/target.c |   67 +++++++++++++++++++++++++++++++++++++++------------------
 usr/tgtd.h   |   27 ++++++++++++++++++++++-
 3 files changed, 87 insertions(+), 23 deletions(-)

diff --git a/usr/scsi.c b/usr/scsi.c
index 5ec3b4d..861d213 100644
--- a/usr/scsi.c
+++ b/usr/scsi.c
@@ -201,6 +201,20 @@ int scsi_cmd_perform(int host_no, struct scsi_cmd *cmd)
 	unsigned char op = cmd->scb[0];
 	struct it_nexus_lu_info *itn_lu;
 
+	if (scsi_get_data_dir(cmd) == DATA_WRITE) {
+		cmd->itn_lu_info->stat.wr_subm_sect += scsi_get_out_length(cmd) / 512;
+		cmd->itn_lu_info->stat.wr_subm_cmds++;
+	}
+	else if (scsi_get_data_dir(cmd) == DATA_READ) {
+		cmd->itn_lu_info->stat.rd_subm_sect += scsi_get_in_length(cmd) / 512;
+		cmd->itn_lu_info->stat.rd_subm_cmds++;
+	}
+	else if (scsi_get_data_dir(cmd) == DATA_BIDIRECTIONAL) {
+		cmd->itn_lu_info->stat.wr_subm_sect += scsi_get_out_length(cmd) / 512;
+		cmd->itn_lu_info->stat.rd_subm_sect += scsi_get_in_length(cmd) / 512;
+		cmd->itn_lu_info->stat.bidir_subm_cmds++;
+	}
+
 	if (CDB_CONTROL(cmd) & ((1U << 0) | (1U << 2))) {
 		/*
 		 * We don't support a linked command. SAM-3 say that
@@ -236,7 +250,7 @@ int scsi_cmd_perform(int host_no, struct scsi_cmd *cmd)
 	case REPORT_LUNS:
 		list_for_each_entry(itn_lu,
 				    &cmd->it_nexus->it_nexus_lu_info_list,
-				    lu_info_siblings)
+				    itn_siblings)
 			ua_sense_clear(itn_lu,
 				       ASC_REPORTED_LUNS_DATA_HAS_CHANGED);
 		break;
diff --git a/usr/target.c b/usr/target.c
index 68222a0..9d67195 100644
--- a/usr/target.c
+++ b/usr/target.c
@@ -81,7 +81,7 @@ static int target_name_lookup(char *name)
 	return 0;
 }
 
-static struct it_nexus *it_nexus_lookup(int tid, uint64_t itn_id)
+struct it_nexus *it_nexus_lookup(int tid, uint64_t itn_id)
 {
 	struct target *target;
 	struct it_nexus *itn;
@@ -199,11 +199,12 @@ static void it_nexus_del_lu_info(struct it_nexus *itn)
 	while(!list_empty(&itn->it_nexus_lu_info_list)) {
 		itn_lu = list_first_entry(&itn->it_nexus_lu_info_list,
 					  struct it_nexus_lu_info,
-					  lu_info_siblings);
+					  itn_siblings);
 
 		ua_sense_pending_del(itn_lu);
 
-		list_del(&itn_lu->lu_info_siblings);
+		list_del(&itn_lu->itn_siblings);
+		list_del(&itn_lu->lu_siblings);
 		free(itn_lu);
 	}
 }
@@ -221,7 +222,7 @@ void ua_sense_add_other_it_nexus(uint64_t itn_id, struct scsi_lu *lu,
 			continue;
 
 		list_for_each_entry(itn_lu, &itn->it_nexus_lu_info_list,
-				    lu_info_siblings) {
+				    itn_siblings) {
 
 			if (itn_lu->lu != lu)
 				continue;
@@ -245,7 +246,7 @@ void ua_sense_add_it_nexus(uint64_t itn_id, struct scsi_lu *lu,
 
 		if (itn->itn_id == itn_id) {
 			list_for_each_entry(itn_lu, &itn->it_nexus_lu_info_list,
-					    lu_info_siblings) {
+					    itn_siblings) {
 
 				if (itn_lu->lu == lu) {
 					ret = ua_sense_add(itn_lu, asc);
@@ -268,7 +269,7 @@ int lu_prevent_removal(struct scsi_lu *lu)
 
 	list_for_each_entry(itn, &lu->tgt->it_nexus_list, nexus_siblings) {
 		list_for_each_entry(itn_lu, &itn->it_nexus_lu_info_list,
-				    lu_info_siblings) {
+				    itn_siblings) {
 			if (itn_lu->lu == lu) {
 				if (itn_lu->prevent & PREVENT_REMOVAL)
 					return 1;
@@ -315,13 +316,17 @@ int it_nexus_create(int tid, uint64_t itn_id, int host_no, char *info)
 		if (!itn_lu)
 			goto out;
 		itn_lu->lu = lu;
+		itn_lu->itn_id = itn_id;
 		INIT_LIST_HEAD(&itn_lu->pending_ua_sense_list);
 
 		ret = ua_sense_add(itn_lu, ASC_POWERON_RESET);
 		if (ret)
 			goto out;
 
-		list_add(&itn_lu->lu_info_siblings,
+		list_add_tail(&itn_lu->lu_siblings,
+			      &lu->it_nexus_lu_info_list);
+
+		list_add(&itn_lu->itn_siblings,
 			 &itn->it_nexus_lu_info_list);
 	}
 
@@ -472,7 +477,7 @@ tgtadm_err tgt_device_create(int tid, int dev_type, uint64_t lun, char *params,
 	struct scsi_lu *lu, *pos;
 	struct device_type_template *t;
 	struct backingstore_template *bst;
-	struct it_nexus_lu_info *itn_lu;
+	struct it_nexus_lu_info *itn_lu, *itn_lu_pos;
 	struct it_nexus *itn;
 	char strflags[128];
 
@@ -573,6 +578,7 @@ tgtadm_err tgt_device_create(int tid, int dev_type, uint64_t lun, char *params,
 
 	tgt_cmd_queue_init(&lu->cmd_queue);
 	INIT_LIST_HEAD(&lu->registration_list);
+	INIT_LIST_HEAD(&lu->it_nexus_lu_info_list);
 	lu->prgeneration = 0;
 	lu->pr_holder = NULL;
 
@@ -635,21 +641,24 @@ tgtadm_err tgt_device_create(int tid, int dev_type, uint64_t lun, char *params,
 		if (!itn_lu)
 			break;
 		itn_lu->lu = lu;
+		itn_lu->itn_id = itn->itn_id;
 		INIT_LIST_HEAD(&itn_lu->pending_ua_sense_list);
 
-		list_add(&itn_lu->lu_info_siblings,
-			 &itn->it_nexus_lu_info_list);
-	}
-
-	list_for_each_entry(itn, &target->it_nexus_list, nexus_siblings) {
-		list_for_each_entry(itn_lu, &itn->it_nexus_lu_info_list,
-				    lu_info_siblings) {
+		/* signal LUNs info change thru all existing LUNs in the nexus */
+		list_for_each_entry(itn_lu_pos, &itn->it_nexus_lu_info_list,
+				    itn_siblings) {
 
-			if (ua_sense_add(itn_lu, ASC_REPORTED_LUNS_DATA_HAS_CHANGED)) {
+			if (ua_sense_add(itn_lu_pos, ASC_REPORTED_LUNS_DATA_HAS_CHANGED)) {
 				adm_err = TGTADM_NOMEM;
 				goto fail_bs_init;
 			}
 		}
+
+		list_add_tail(&itn_lu->lu_siblings,
+			      &lu->it_nexus_lu_info_list);
+
+		list_add(&itn_lu->itn_siblings,
+			 &itn->it_nexus_lu_info_list);
 	}
 
 	if (backing && !path)
@@ -712,7 +721,7 @@ tgtadm_err tgt_device_destroy(int tid, uint64_t lun, int force)
 
 	list_for_each_entry(itn, &target->it_nexus_list, nexus_siblings) {
 		list_for_each_entry_safe(itn_lu, next, &itn->it_nexus_lu_info_list,
-					 lu_info_siblings) {
+					 itn_siblings) {
 			if (itn_lu->lu == lu) {
 				ua_sense_pending_del(itn_lu);
 				break;
@@ -731,7 +740,7 @@ tgtadm_err tgt_device_destroy(int tid, uint64_t lun, int force)
 
 	list_for_each_entry(itn, &target->it_nexus_list, nexus_siblings) {
 		list_for_each_entry(itn_lu, &itn->it_nexus_lu_info_list,
-				    lu_info_siblings) {
+				    itn_siblings) {
 
 			ret = ua_sense_add(itn_lu,
 					   ASC_REPORTED_LUNS_DATA_HAS_CHANGED);
@@ -952,7 +961,7 @@ static struct it_nexus_lu_info *it_nexus_lu_info_lookup(struct it_nexus *itn,
 	struct it_nexus_lu_info *itn_lu;
 
 	list_for_each_entry(itn_lu, &itn->it_nexus_lu_info_list,
-			    lu_info_siblings) {
+			    itn_siblings) {
 		if (itn_lu->lu->lun == lun)
 			return itn_lu;
 	}
@@ -1061,6 +1070,22 @@ int target_cmd_perform_passthrough(int tid, struct scsi_cmd *cmd)
 void target_cmd_io_done(struct scsi_cmd *cmd, int result)
 {
 	scsi_set_result(cmd, result);
+	if (scsi_get_data_dir(cmd) == DATA_WRITE) {
+		cmd->itn_lu_info->stat.wr_done_sect += scsi_get_out_length(cmd) / 512;
+		cmd->itn_lu_info->stat.wr_done_cmds++;
+	}
+	else if (scsi_get_data_dir(cmd) == DATA_READ) {
+		cmd->itn_lu_info->stat.rd_done_sect += scsi_get_in_length(cmd) / 512;
+		cmd->itn_lu_info->stat.rd_done_cmds++;
+	}
+	else if (scsi_get_data_dir(cmd) == DATA_BIDIRECTIONAL) {
+		cmd->itn_lu_info->stat.wr_done_sect += scsi_get_out_length(cmd) / 512;
+		cmd->itn_lu_info->stat.rd_done_sect += scsi_get_in_length(cmd) / 512;
+		cmd->itn_lu_info->stat.bidir_done_cmds++;
+	}
+	if (result != SAM_STAT_GOOD)
+		cmd->itn_lu_info->stat.err_num++;
+
 	tgt_drivers[cmd->c_target->lid]->cmd_end_notify(cmd->cmd_itn_id,
 							result, cmd);
 	return;
@@ -1242,7 +1267,7 @@ enum mgmt_req_result target_mgmt_request(int tid, uint64_t itn_id,
 
 		list_for_each_entry(itn, &target->it_nexus_list, nexus_siblings) {
 			list_for_each_entry(itn_lu, &itn->it_nexus_lu_info_list,
-					    lu_info_siblings) {
+					    itn_siblings) {
 				if (itn_lu->lu->lun == lun) {
 					if (itn->itn_id == itn_id)
 						asc = ASC_POWERON_RESET;
@@ -1264,7 +1289,7 @@ enum mgmt_req_result target_mgmt_request(int tid, uint64_t itn_id,
 
 		list_for_each_entry(itn, &target->it_nexus_list, nexus_siblings) {
 			list_for_each_entry(itn_lu, &itn->it_nexus_lu_info_list,
-					    lu_info_siblings) {
+					    itn_siblings) {
 				if (itn_lu->lu->lun == lun) {
 					ua_sense_add(itn_lu, ASC_POWERON_RESET);
 					break;
diff --git a/usr/tgtd.h b/usr/tgtd.h
index aa9b9d5..e159c05 100644
--- a/usr/tgtd.h
+++ b/usr/tgtd.h
@@ -92,9 +92,31 @@ struct ua_sense {
 	int ua_sense_len;
 };
 
+struct lu_stat {
+	uint64_t rd_subm_sect;
+	uint64_t rd_done_sect;
+
+	uint64_t wr_subm_sect;
+	uint64_t wr_done_sect;
+
+	uint32_t rd_subm_cmds;
+	uint32_t rd_done_cmds;
+
+	uint32_t wr_subm_cmds;
+	uint32_t wr_done_cmds;
+
+	uint32_t bidir_subm_cmds;
+	uint32_t bidir_done_cmds;
+
+	uint32_t err_num;
+};
+
 struct it_nexus_lu_info {
 	struct scsi_lu *lu;
-	struct list_head lu_info_siblings;
+	uint64_t itn_id;
+	struct lu_stat stat;
+	struct list_head itn_siblings;
+	struct list_head lu_siblings;
 	struct list_head pending_ua_sense_list;
 	int prevent; /* prevent removal on this itl nexus ? */
 };
@@ -174,6 +196,8 @@ struct scsi_lu {
 	/* the list of devices belonging to a target */
 	struct list_head device_siblings;
 
+	struct list_head it_nexus_lu_info_list;
+
 	struct tgt_cmd_queue cmd_queue;
 
 	uint64_t reserve_id;
@@ -280,6 +304,7 @@ extern enum mgmt_req_result target_mgmt_request(int tid, uint64_t itn_id,
 						uint8_t *lun, uint64_t tag,
 						int host_no);
 
+extern struct it_nexus *it_nexus_lookup(int tid, uint64_t itn_id);
 extern void target_cmd_io_done(struct scsi_cmd *cmd, int result);
 extern int ua_sense_del(struct scsi_cmd *cmd, int del);
 extern void ua_sense_clear(struct it_nexus_lu_info *itn_lu, uint16_t asc);
-- 
1.7.1

--
To unsubscribe from this list: send the line "unsubscribe stgt" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at  http://vger.kernel.org/majordomo-info.html


[Index of Archives]     [Linux SCSI]     [Linux RAID]     [Linux Clusters]     [Linux USB Devel]     [Linux Audio Users]     [Yosemite News]     [Linux Kernel]

  Powered by Linux