drivers/target/target_core_tmr.c

27 	struct se_cmd *se_cmd,
40 	se_cmd->se_cmd_flags |= SCF_SCSI_TMR_CDB;
41 	se_cmd->se_tmr_req = tmr;
42 	tmr->task_cmd = se_cmd;
57 		struct se_cmd *cmd)
71 static bool __target_check_io_state(struct se_cmd *se_cmd,
74 	struct se_session *sess = se_cmd->se_sess;
81 	 * this se_cmd has been passed to fabric driver and will
84 	 * Otherwise, obtain a local se_cmd->cmd_kref now for TMR
86 	 * long as se_cmd->cmd_kref is still active unless zero.
88 	spin_lock(&se_cmd->t_state_lock);
89 	if (se_cmd->transport_state & (CMD_T_COMPLETE | CMD_T_FABRIC_STOP)) {
91 			" fabric stop, skipping\n", se_cmd->tag);
92 		spin_unlock(&se_cmd->t_state_lock);
95 	se_cmd->transport_state |= CMD_T_ABORTED;
97 	if ((tmr_sess != se_cmd->se_sess) && tas)
98 		se_cmd->transport_state |= CMD_T_TAS;
100 	spin_unlock(&se_cmd->t_state_lock);
102 	return kref_get_unless_zero(&se_cmd->cmd_kref);
111 	struct se_cmd *se_cmd, *next;
121 		list_for_each_entry_safe(se_cmd, next, &dev->queues[i].state_list,
123 			if (se_sess != se_cmd->se_sess)
130 			if (se_cmd->se_cmd_flags & SCF_SCSI_TMR_CDB)
133 			ref_tag = se_cmd->tag;
138 			       se_cmd->se_tfo->fabric_name, ref_tag);
141 			rc = __target_check_io_state(se_cmd, se_sess, 0);
146 			list_move_tail(&se_cmd->state_list, &aborted_list);
147 			se_cmd->state_active = false;
154 			list_del_init(&se_cmd->state_list);
155 			target_put_cmd_and_wait(se_cmd);
183 	struct se_cmd *cmd;
197 			pr_err("Unable to locate struct se_cmd for TMR\n");
267 	struct se_cmd *prout_cmd,
274 	struct se_cmd *cmd, *next;
342 		cmd = list_entry(drain_task_list.next, struct se_cmd, state_list);
358         struct se_cmd *prout_cmd)