29  * Dump cmd state for debugging.
31 static void _ft_dump_cmd(struct ft_cmd *cmd, const char *caller)  in _ft_dump_cmd()  argument
39 	se_cmd = &cmd->se_cmd;  in _ft_dump_cmd()
40 	pr_debug("%s: cmd %p sess %p seq %p se_cmd %p\n",  in _ft_dump_cmd()
41 		caller, cmd, cmd->sess, cmd->seq, se_cmd);  in _ft_dump_cmd()
43 	pr_debug("%s: cmd %p data_nents %u len %u se_cmd_flags <0x%x>\n",  in _ft_dump_cmd()
44 		caller, cmd, se_cmd->t_data_nents,  in _ft_dump_cmd()
48 		pr_debug("%s: cmd %p sg %p page %p "  in _ft_dump_cmd()
50 			caller, cmd, sg,  in _ft_dump_cmd()
53 	sp = cmd->seq;  in _ft_dump_cmd()
56 		pr_debug("%s: cmd %p sid %x did %x "  in _ft_dump_cmd()
58 			caller, cmd, ep->sid, ep->did, ep->oxid, ep->rxid,  in _ft_dump_cmd()
63 void ft_dump_cmd(struct ft_cmd *cmd, const char *caller)  in ft_dump_cmd()  argument
66 		_ft_dump_cmd(cmd, caller);  in ft_dump_cmd()
69 static void ft_free_cmd(struct ft_cmd *cmd)  in ft_free_cmd()  argument
74 	if (!cmd)  in ft_free_cmd()
76 	sess = cmd->sess;  in ft_free_cmd()
77 	fp = cmd->req_frame;  in ft_free_cmd()
81 	target_free_tag(sess->se_sess, &cmd->se_cmd);  in ft_free_cmd()
87 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_release_cmd()  local
89 	ft_free_cmd(cmd);  in ft_release_cmd()
102 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_queue_status()  local
110 	if (cmd->aborted)  in ft_queue_status()
112 	ft_dump_cmd(cmd, __func__);  in ft_queue_status()
113 	ep = fc_seq_exch(cmd->seq);  in ft_queue_status()
148 	cmd->seq = fc_seq_start_next(cmd->seq);  in ft_queue_status()
152 	rc = fc_seq_send(lport, cmd->seq, fp);  in ft_queue_status()
164 	fc_exch_done(cmd->seq);  in ft_queue_status()
170 	target_put_sess_cmd(&cmd->se_cmd);  in ft_queue_status()
179 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_write_pending()  local
187 	ft_dump_cmd(cmd, __func__);  in ft_write_pending()
189 	if (cmd->aborted)  in ft_write_pending()
191 	ep = fc_seq_exch(cmd->seq);  in ft_write_pending()
201 	cmd->seq = fc_seq_start_next(cmd->seq);  in ft_write_pending()
219 				cmd->was_ddp_setup = 1;  in ft_write_pending()
222 	fc_seq_send(lport, cmd->seq, fp);  in ft_write_pending()
231 	struct ft_cmd *cmd = arg;  in ft_recv_seq()  local
235 		/* XXX need to find cmd if queued */  in ft_recv_seq()
236 		cmd->seq = NULL;  in ft_recv_seq()
237 		cmd->aborted = true;  in ft_recv_seq()
245 		ft_recv_write_data(cmd, fp);  in ft_recv_seq()
253 		ft_invl_hw_context(cmd);  in ft_recv_seq()
255 		transport_generic_free_cmd(&cmd->se_cmd, 0);  in ft_recv_seq()
308 static void ft_send_resp_code(struct ft_cmd *cmd,  in ft_send_resp_code()  argument
311 	ft_send_resp_status(cmd->sess->tport->lport,  in ft_send_resp_code()
312 			    cmd->req_frame, SAM_STAT_GOOD, code);  in ft_send_resp_code()
318  * Always frees the cmd and associated state.
320 static void ft_send_resp_code_and_free(struct ft_cmd *cmd,  in ft_send_resp_code_and_free()  argument
323 	ft_send_resp_code(cmd, code);  in ft_send_resp_code_and_free()
324 	ft_free_cmd(cmd);  in ft_send_resp_code_and_free()
330 static void ft_send_tm(struct ft_cmd *cmd)  in ft_send_tm()  argument
336 	fcp = fc_frame_payload_get(cmd->req_frame, sizeof(*fcp));  in ft_send_tm()
360 		ft_send_resp_code_and_free(cmd, FCP_CMND_FIELDS_INVALID);  in ft_send_tm()
365 	rc = target_submit_tmr(&cmd->se_cmd, cmd->sess->se_sess,  in ft_send_tm()
366 		&cmd->ft_sense_buffer[0], scsilun_to_int(&fcp->fc_lun),  in ft_send_tm()
367 		cmd, tm_func, GFP_KERNEL, 0, TARGET_SCF_ACK_KREF);  in ft_send_tm()
369 		ft_send_resp_code_and_free(cmd, FCP_TMF_FAILED);  in ft_send_tm()
377 	struct ft_cmd *cmd = container_of(se_cmd, struct ft_cmd, se_cmd);  in ft_queue_tm_resp()  local
381 	if (cmd->aborted)  in ft_queue_tm_resp()
401 	ft_send_resp_code(cmd, code);  in ft_queue_tm_resp()
407 	target_put_sess_cmd(&cmd->se_cmd);  in ft_queue_tm_resp()
422 	struct ft_cmd *cmd;  in ft_recv_cmd()  local
431 	cmd = &((struct ft_cmd *)se_sess->sess_cmd_map)[tag];  in ft_recv_cmd()
432 	memset(cmd, 0, sizeof(struct ft_cmd));  in ft_recv_cmd()
434 	cmd->se_cmd.map_tag = tag;  in ft_recv_cmd()
435 	cmd->se_cmd.map_cpu = cpu;  in ft_recv_cmd()
436 	cmd->sess = sess;  in ft_recv_cmd()
437 	cmd->seq = fc_seq_assign(lport, fp);  in ft_recv_cmd()
438 	if (!cmd->seq) {  in ft_recv_cmd()
439 		target_free_tag(se_sess, &cmd->se_cmd);  in ft_recv_cmd()
442 	cmd->req_frame = fp;		/* hold frame during cmd */  in ft_recv_cmd()
444 	INIT_WORK(&cmd->work, ft_send_work);  in ft_recv_cmd()
445 	queue_work(sess->tport->tpg->workqueue, &cmd->work);  in ft_recv_cmd()
449 	pr_debug("cmd or seq allocation failure - sending BUSY\n");  in ft_recv_cmd()
487 	struct ft_cmd *cmd = container_of(work, struct ft_cmd, work);  in ft_send_work()  local
488 	struct fc_frame_header *fh = fc_frame_header_get(cmd->req_frame);  in ft_send_work()
493 	fcp = fc_frame_payload_get(cmd->req_frame, sizeof(*fcp));  in ft_send_work()
504 		ft_send_tm(cmd);  in ft_send_work()
539 	fc_seq_set_resp(cmd->seq, ft_recv_seq, cmd);  in ft_send_work()
540 	cmd->se_cmd.tag = fc_seq_exch(cmd->seq)->rxid;  in ft_send_work()
546 	if (target_init_cmd(&cmd->se_cmd, cmd->sess->se_sess,  in ft_send_work()
547 			    &cmd->ft_sense_buffer[0],  in ft_send_work()
552 	if (target_submit_prep(&cmd->se_cmd, fcp->fc_cdb, NULL, 0, NULL, 0,  in ft_send_work()
556 	target_submit(&cmd->se_cmd);  in ft_send_work()
557 	pr_debug("r_ctl %x target_submit_cmd %p\n", fh->fh_r_ctl, cmd);  in ft_send_work()
561 	ft_send_resp_code_and_free(cmd, FCP_CMND_FIELDS_INVALID);  in ft_send_work()