target/iscsi/iscsi_target_util.c

158 	struct se_session *se_sess = conn->sess->se_sess;
241 static inline int iscsit_check_received_cmdsn(struct iscsit_session *sess, u32 cmdsn)
252 	max_cmdsn = atomic_read(&sess->max_cmd_sn);
258 	} else if (cmdsn == sess->exp_cmd_sn) {
259 		sess->exp_cmd_sn++;
262 		      sess->exp_cmd_sn);
265 	} else if (iscsi_sna_gt(cmdsn, sess->exp_cmd_sn)) {
268 		      cmdsn, sess->exp_cmd_sn);
274 		       sess->exp_cmd_sn);
292 	mutex_lock(&conn->sess->cmdsn_mutex);
294 	cmdsn_ret = iscsit_check_received_cmdsn(conn->sess, be32_to_cpu(cmdsn));
298 		if ((ret >= 0) && !list_empty(&conn->sess->sess_ooo_cmdsn_list))
299 			iscsit_execute_ooo_cmdsns(conn->sess);
306 		ret = iscsit_handle_ooo_cmdsn(conn->sess, cmd, be32_to_cpu(cmdsn));
327 	mutex_unlock(&conn->sess->cmdsn_mutex);
343 	if (conn->sess->sess_ops->InitialR2T) {
352 	     conn->sess->sess_ops->FirstBurstLength) {
356 				conn->sess->sess_ops->FirstBurstLength);
367 	      conn->sess->sess_ops->FirstBurstLength)) {
372 			conn->sess->sess_ops->FirstBurstLength, cmd->se_cmd.data_length);
449 	struct iscsit_session *sess,
460 	spin_lock(&sess->cr_i_lock);
461 	list_for_each_entry(cr, &sess->cr_inactive_list, cr_list) {
466 				spin_unlock(&sess->cr_i_lock);
475 	spin_unlock(&sess->cr_i_lock);
480 	spin_lock(&sess->cr_a_lock);
481 	list_for_each_entry(cr, &sess->cr_active_list, cr_list) {
486 				spin_unlock(&sess->cr_a_lock);
495 	spin_unlock(&sess->cr_a_lock);
699 	struct iscsit_session *sess;
705 		sess = cmd->conn->sess;
707 		sess = cmd->sess;
709 	BUG_ON(!sess || !sess->se_sess);
719 	target_free_tag(sess->se_sess, se_cmd);
765 bool iscsit_check_session_usage_count(struct iscsit_session *sess,
768 	spin_lock_bh(&sess->session_usage_lock);
769 	if (sess->session_usage_count != 0) {
770 		sess->session_waiting_on_uc = 1;
771 		spin_unlock_bh(&sess->session_usage_lock);
775 		wait_for_completion(&sess->session_waiting_on_uc_comp);
778 	spin_unlock_bh(&sess->session_usage_lock);
783 void iscsit_dec_session_usage_count(struct iscsit_session *sess)
785 	spin_lock_bh(&sess->session_usage_lock);
786 	sess->session_usage_count--;
788 	if (!sess->session_usage_count && sess->session_waiting_on_uc)
789 		complete(&sess->session_waiting_on_uc_comp);
791 	spin_unlock_bh(&sess->session_usage_lock);
794 void iscsit_inc_session_usage_count(struct iscsit_session *sess)
796 	spin_lock_bh(&sess->session_usage_lock);
797 	sess->session_usage_count++;
798 	spin_unlock_bh(&sess->session_usage_lock);
801 struct iscsit_conn *iscsit_get_conn_from_cid(struct iscsit_session *sess, u16 cid)
805 	spin_lock_bh(&sess->conn_lock);
806 	list_for_each_entry(conn, &sess->sess_conn_list, conn_list) {
810 			spin_unlock_bh(&sess->conn_lock);
814 	spin_unlock_bh(&sess->conn_lock);
819 struct iscsit_conn *iscsit_get_conn_from_cid_rcfr(struct iscsit_session *sess, u16 cid)
823 	spin_lock_bh(&sess->conn_lock);
824 	list_for_each_entry(conn, &sess->sess_conn_list, conn_list) {
830 			spin_unlock_bh(&sess->conn_lock);
834 	spin_unlock_bh(&sess->conn_lock);
884 			     session_get_next_ttt(conn->sess) : 0xFFFFFFFF;
899 	struct iscsit_session *sess = conn->sess;
912 		conn->cid, sess->sess_ops->InitiatorName, sess->isid,
913 		sess->tpg->tpg_tiqn->tiqn, (u32)sess->tpg->tpgt);
917 	iscsit_fill_cxn_timeout_err_stats(sess);
924 	struct iscsit_session *sess = conn->sess;
925 	struct iscsi_node_attrib *na = iscsit_tpg_get_node_attrib(sess);
940 	struct iscsit_session *sess = conn->sess;
941 	struct iscsi_node_attrib *na = iscsit_tpg_get_node_attrib(sess);
997 	struct iscsit_session *sess = conn->sess;
998 	struct iscsi_node_attrib *na = iscsit_tpg_get_node_attrib(sess);
1255 void iscsit_print_session_params(struct iscsit_session *sess)
1260 		" SID: %u]-----------------------------\n", sess->sid);
1261 	spin_lock_bh(&sess->conn_lock);
1262 	list_for_each_entry(conn, &sess->sess_conn_list, conn_list)
1264 	spin_unlock_bh(&sess->conn_lock);
1266 	iscsi_dump_sess_ops(sess->sess_ops);
1408 void iscsit_fill_cxn_timeout_err_stats(struct iscsit_session *sess)
1410 	struct iscsi_portal_group *tpg = sess->tpg;
1418 			sess->sess_ops->InitiatorName,
1423 	atomic_long_inc(&sess->conn_timeout_errors);