51 static void _ft_dump_cmd(struct ft_cmd *cmd, const char *caller)  in _ft_dump_cmd()  argument
59 	se_cmd = &cmd->se_cmd;  in _ft_dump_cmd()
61 		caller, cmd, cmd->sess, cmd->seq, se_cmd);  in _ft_dump_cmd()
64 		caller, cmd, se_cmd->t_data_nents,  in _ft_dump_cmd()
70 			caller, cmd, sg,  in _ft_dump_cmd()
73 	sp = cmd->seq;  in _ft_dump_cmd()
78 			caller, cmd, ep->sid, ep->did, ep->oxid, ep->rxid,  in _ft_dump_cmd()
83 void ft_dump_cmd(struct ft_cmd *cmd, const char *caller)  in ft_dump_cmd()  argument
86 		_ft_dump_cmd(cmd, caller);  in ft_dump_cmd()
89 static void ft_free_cmd(struct ft_cmd *cmd)  in ft_free_cmd()  argument
95 	if (!cmd)  in ft_free_cmd()
97 	sess = cmd->sess;  in ft_free_cmd()
98 	fp = cmd->req_frame;  in ft_free_cmd()
103 	percpu_ida_free(&sess->se_sess->sess_tag_pool, cmd->se_cmd.map_tag);  in ft_free_cmd()
109 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_release_cmd()  local
111 	ft_free_cmd(cmd);  in ft_release_cmd()
125 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_queue_status()  local
133 	if (cmd->aborted)  in ft_queue_status()
135 	ft_dump_cmd(cmd, __func__);  in ft_queue_status()
136 	ep = fc_seq_exch(cmd->seq);  in ft_queue_status()
171 	cmd->seq = lport->tt.seq_start_next(cmd->seq);  in ft_queue_status()
175 	rc = lport->tt.seq_send(lport, cmd->seq, fp);  in ft_queue_status()
187 	lport->tt.exch_done(cmd->seq);  in ft_queue_status()
193 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_write_pending_status()  local
195 	return cmd->write_data_len != se_cmd->data_length;  in ft_write_pending_status()
203 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_write_pending()  local
211 	ft_dump_cmd(cmd, __func__);  in ft_write_pending()
213 	if (cmd->aborted)  in ft_write_pending()
215 	ep = fc_seq_exch(cmd->seq);  in ft_write_pending()
225 	cmd->seq = lport->tt.seq_start_next(cmd->seq);  in ft_write_pending()
243 				cmd->was_ddp_setup = 1;  in ft_write_pending()
246 	lport->tt.seq_send(lport, cmd->seq, fp);  in ft_write_pending()
252 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_get_task_tag()  local
254 	if (cmd->aborted)  in ft_get_task_tag()
256 	return fc_seq_exch(cmd->seq)->rxid;  in ft_get_task_tag()
269 	struct ft_cmd *cmd = arg;  in ft_recv_seq()  local
274 		cmd->seq = NULL;  in ft_recv_seq()
275 		cmd->aborted = true;  in ft_recv_seq()
283 		ft_recv_write_data(cmd, fp);  in ft_recv_seq()
291 		ft_invl_hw_context(cmd);  in ft_recv_seq()
293 		transport_generic_free_cmd(&cmd->se_cmd, 0);  in ft_recv_seq()
346 static void ft_send_resp_code(struct ft_cmd *cmd,  in ft_send_resp_code()  argument
349 	ft_send_resp_status(cmd->sess->tport->lport,  in ft_send_resp_code()
350 			    cmd->req_frame, SAM_STAT_GOOD, code);  in ft_send_resp_code()
358 static void ft_send_resp_code_and_free(struct ft_cmd *cmd,  in ft_send_resp_code_and_free()  argument
361 	ft_send_resp_code(cmd, code);  in ft_send_resp_code_and_free()
362 	ft_free_cmd(cmd);  in ft_send_resp_code_and_free()
368 static void ft_send_tm(struct ft_cmd *cmd)  in ft_send_tm()  argument
374 	fcp = fc_frame_payload_get(cmd->req_frame, sizeof(*fcp));  in ft_send_tm()
398 		ft_send_resp_code_and_free(cmd, FCP_CMND_FIELDS_INVALID);  in ft_send_tm()
403 	rc = target_submit_tmr(&cmd->se_cmd, cmd->sess->se_sess,  in ft_send_tm()
404 		&cmd->ft_sense_buffer[0], scsilun_to_int(&fcp->fc_lun),  in ft_send_tm()
405 		cmd, tm_func, GFP_KERNEL, 0, 0);  in ft_send_tm()
407 		ft_send_resp_code_and_free(cmd, FCP_TMF_FAILED);  in ft_send_tm()
415 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_queue_tm_resp()  local
419 	if (cmd->aborted)  in ft_queue_tm_resp()
439 	ft_send_resp_code(cmd, code);  in ft_queue_tm_resp()
454 	struct ft_cmd *cmd;  in ft_recv_cmd()  local
463 	cmd = &((struct ft_cmd *)se_sess->sess_cmd_map)[tag];  in ft_recv_cmd()
464 	memset(cmd, 0, sizeof(struct ft_cmd));  in ft_recv_cmd()
466 	cmd->se_cmd.map_tag = tag;  in ft_recv_cmd()
467 	cmd->sess = sess;  in ft_recv_cmd()
468 	cmd->seq = lport->tt.seq_assign(lport, fp);  in ft_recv_cmd()
469 	if (!cmd->seq) {  in ft_recv_cmd()
473 	cmd->req_frame = fp;		/* hold frame during cmd */  in ft_recv_cmd()
475 	INIT_WORK(&cmd->work, ft_send_work);  in ft_recv_cmd()
476 	queue_work(sess->tport->tpg->workqueue, &cmd->work);  in ft_recv_cmd()
518 	struct ft_cmd *cmd = container_of(work, struct ft_cmd, work);  in ft_send_work()  local
519 	struct fc_frame_header *fh = fc_frame_header_get(cmd->req_frame);  in ft_send_work()
524 	fcp = fc_frame_payload_get(cmd->req_frame, sizeof(*fcp));  in ft_send_work()
535 		ft_send_tm(cmd);  in ft_send_work()
570 	fc_seq_exch(cmd->seq)->lp->tt.seq_set_resp(cmd->seq, ft_recv_seq, cmd);  in ft_send_work()
575 	if (target_submit_cmd(&cmd->se_cmd, cmd->sess->se_sess, fcp->fc_cdb,  in ft_send_work()
576 			      &cmd->ft_sense_buffer[0], scsilun_to_int(&fcp->fc_lun),  in ft_send_work()
584 	ft_send_resp_code_and_free(cmd, FCP_CMND_FIELDS_INVALID);  in ft_send_work()