45 static void _ft_dump_cmd(struct ft_cmd *cmd, const char *caller)  in _ft_dump_cmd()  argument
53 	se_cmd = &cmd->se_cmd;  in _ft_dump_cmd()
55 		caller, cmd, cmd->sess, cmd->seq, se_cmd);  in _ft_dump_cmd()
58 		caller, cmd, se_cmd->t_data_nents,  in _ft_dump_cmd()
64 			caller, cmd, sg,  in _ft_dump_cmd()
67 	sp = cmd->seq;  in _ft_dump_cmd()
72 			caller, cmd, ep->sid, ep->did, ep->oxid, ep->rxid,  in _ft_dump_cmd()
77 void ft_dump_cmd(struct ft_cmd *cmd, const char *caller)  in ft_dump_cmd()  argument
80 		_ft_dump_cmd(cmd, caller);  in ft_dump_cmd()
83 static void ft_free_cmd(struct ft_cmd *cmd)  in ft_free_cmd()  argument
89 	if (!cmd)  in ft_free_cmd()
91 	sess = cmd->sess;  in ft_free_cmd()
92 	fp = cmd->req_frame;  in ft_free_cmd()
97 	percpu_ida_free(&sess->se_sess->sess_tag_pool, cmd->se_cmd.map_tag);  in ft_free_cmd()
103 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_release_cmd()  local
105 	ft_free_cmd(cmd);  in ft_release_cmd()
119 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_queue_status()  local
127 	if (cmd->aborted)  in ft_queue_status()
129 	ft_dump_cmd(cmd, __func__);  in ft_queue_status()
130 	ep = fc_seq_exch(cmd->seq);  in ft_queue_status()
165 	cmd->seq = lport->tt.seq_start_next(cmd->seq);  in ft_queue_status()
169 	rc = lport->tt.seq_send(lport, cmd->seq, fp);  in ft_queue_status()
181 	lport->tt.exch_done(cmd->seq);  in ft_queue_status()
187 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_write_pending_status()  local
189 	return cmd->write_data_len != se_cmd->data_length;  in ft_write_pending_status()
197 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_write_pending()  local
205 	ft_dump_cmd(cmd, __func__);  in ft_write_pending()
207 	if (cmd->aborted)  in ft_write_pending()
209 	ep = fc_seq_exch(cmd->seq);  in ft_write_pending()
219 	cmd->seq = lport->tt.seq_start_next(cmd->seq);  in ft_write_pending()
237 				cmd->was_ddp_setup = 1;  in ft_write_pending()
240 	lport->tt.seq_send(lport, cmd->seq, fp);  in ft_write_pending()
254 	struct ft_cmd *cmd = arg;  in ft_recv_seq()  local
259 		cmd->seq = NULL;  in ft_recv_seq()
260 		cmd->aborted = true;  in ft_recv_seq()
268 		ft_recv_write_data(cmd, fp);  in ft_recv_seq()
276 		ft_invl_hw_context(cmd);  in ft_recv_seq()
278 		transport_generic_free_cmd(&cmd->se_cmd, 0);  in ft_recv_seq()
331 static void ft_send_resp_code(struct ft_cmd *cmd,  in ft_send_resp_code()  argument
334 	ft_send_resp_status(cmd->sess->tport->lport,  in ft_send_resp_code()
335 			    cmd->req_frame, SAM_STAT_GOOD, code);  in ft_send_resp_code()
343 static void ft_send_resp_code_and_free(struct ft_cmd *cmd,  in ft_send_resp_code_and_free()  argument
346 	ft_send_resp_code(cmd, code);  in ft_send_resp_code_and_free()
347 	ft_free_cmd(cmd);  in ft_send_resp_code_and_free()
353 static void ft_send_tm(struct ft_cmd *cmd)  in ft_send_tm()  argument
359 	fcp = fc_frame_payload_get(cmd->req_frame, sizeof(*fcp));  in ft_send_tm()
383 		ft_send_resp_code_and_free(cmd, FCP_CMND_FIELDS_INVALID);  in ft_send_tm()
388 	rc = target_submit_tmr(&cmd->se_cmd, cmd->sess->se_sess,  in ft_send_tm()
389 		&cmd->ft_sense_buffer[0], scsilun_to_int(&fcp->fc_lun),  in ft_send_tm()
390 		cmd, tm_func, GFP_KERNEL, 0, 0);  in ft_send_tm()
392 		ft_send_resp_code_and_free(cmd, FCP_TMF_FAILED);  in ft_send_tm()
400 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_queue_tm_resp()  local
404 	if (cmd->aborted)  in ft_queue_tm_resp()
424 	ft_send_resp_code(cmd, code);  in ft_queue_tm_resp()
439 	struct ft_cmd *cmd;  in ft_recv_cmd()  local
448 	cmd = &((struct ft_cmd *)se_sess->sess_cmd_map)[tag];  in ft_recv_cmd()
449 	memset(cmd, 0, sizeof(struct ft_cmd));  in ft_recv_cmd()
451 	cmd->se_cmd.map_tag = tag;  in ft_recv_cmd()
452 	cmd->sess = sess;  in ft_recv_cmd()
453 	cmd->seq = lport->tt.seq_assign(lport, fp);  in ft_recv_cmd()
454 	if (!cmd->seq) {  in ft_recv_cmd()
458 	cmd->req_frame = fp;		/* hold frame during cmd */  in ft_recv_cmd()
460 	INIT_WORK(&cmd->work, ft_send_work);  in ft_recv_cmd()
461 	queue_work(sess->tport->tpg->workqueue, &cmd->work);  in ft_recv_cmd()
503 	struct ft_cmd *cmd = container_of(work, struct ft_cmd, work);  in ft_send_work()  local
504 	struct fc_frame_header *fh = fc_frame_header_get(cmd->req_frame);  in ft_send_work()
509 	fcp = fc_frame_payload_get(cmd->req_frame, sizeof(*fcp));  in ft_send_work()
520 		ft_send_tm(cmd);  in ft_send_work()
555 	fc_seq_exch(cmd->seq)->lp->tt.seq_set_resp(cmd->seq, ft_recv_seq, cmd);  in ft_send_work()
556 	cmd->se_cmd.tag = fc_seq_exch(cmd->seq)->rxid;  in ft_send_work()
561 	if (target_submit_cmd(&cmd->se_cmd, cmd->sess->se_sess, fcp->fc_cdb,  in ft_send_work()
562 			      &cmd->ft_sense_buffer[0], scsilun_to_int(&fcp->fc_lun),  in ft_send_work()
570 	ft_send_resp_code_and_free(cmd, FCP_CMND_FIELDS_INVALID);  in ft_send_work()