Lines Matching defs:conn
34 struct iscsi_conn *conn = cmd->conn;
42 conn->sess->sess_ops->FirstBurstLength);
46 if (!conn->sess->sess_ops->DataSequenceInOrder)
52 conn->sess->sess_ops->MaxBurstLength) ?
54 conn->sess->sess_ops->MaxBurstLength) : cmd->se_cmd.data_length;
58 conn->sess->sess_ops->MaxBurstLength) >=
61 conn->sess->sess_ops->MaxBurstLength);
69 struct iscsi_conn *conn = cmd->conn;
85 if (conn->sess->sess_ops->DataSequenceInOrder) {
103 if (conn->sess->sess_ops->DataPDUInOrder) {
128 return iscsit_dump_data_payload(conn, payload_length, 1);
136 struct iscsi_conn *conn = cmd->conn;
153 if (first_burst_len > conn->sess->sess_ops->FirstBurstLength) {
156 first_burst_len, conn->sess->sess_ops->FirstBurstLength);
172 if (!conn->sess->sess_ops->DataPDUInOrder)
176 (first_burst_len != conn->sess->sess_ops->FirstBurstLength)) {
180 conn->sess->sess_ops->FirstBurstLength,
187 if (first_burst_len == conn->sess->sess_ops->FirstBurstLength) {
191 conn->sess->sess_ops->FirstBurstLength);
211 struct iscsi_conn *conn = cmd->conn;
223 if (conn->sess->sess_ops->DataSequenceInOrder) {
237 if (iscsit_dump_data_payload(conn, payload_length, 1) < 0)
254 if (iscsit_dump_data_payload(conn, payload_length, 1) < 0)
262 if (next_burst_len > conn->sess->sess_ops->MaxBurstLength) {
267 payload_length, conn->sess->sess_ops->MaxBurstLength);
281 if (!conn->sess->sess_ops->DataPDUInOrder)
284 if (conn->sess->sess_ops->DataSequenceInOrder) {
286 conn->sess->sess_ops->MaxBurstLength) &&
303 if (conn->sess->sess_ops->DataSequenceInOrder) {
305 conn->sess->sess_ops->MaxBurstLength) {
309 conn->sess->sess_ops->MaxBurstLength);
340 struct iscsi_conn *conn = cmd->conn;
352 if (conn->sess->sess_ops->DataSequenceInOrder)
374 if (!conn->sess->sess_ops->ErrorRecoveryLevel) {
380 if (iscsit_dump_data_payload(conn, payload_length, 1) < 0)
391 struct iscsi_conn *conn = cmd->conn;
404 if (conn->sess->sess_ops->DataSequenceInOrder) {
434 if (!conn->sess->sess_ops->ErrorRecoveryLevel) {
440 if (iscsit_dump_data_payload(conn, payload_length, 1) < 0)
472 return iscsit_dump_data_payload(cmd->conn, payload_length, 1);
537 struct iscsi_conn *conn = cmd->conn;
544 conn->sess->sess_ops->FirstBurstLength) {
551 if (!conn->sess->sess_ops->DataPDUInOrder) {
561 if (conn->sess->sess_ops->DataSequenceInOrder)
576 if (conn->sess->sess_ops->DataSequenceInOrder) {
578 conn->sess->sess_ops->MaxBurstLength) {
586 if (!conn->sess->sess_ops->DataPDUInOrder) {
611 if (!conn->sess->sess_ops->DataPDUInOrder) {
630 if (send_r2t && conn->sess->sess_ops->DataSequenceInOrder)
647 struct iscsi_conn *conn = cmd->conn;
652 if (conn->sess->sess_ops->DataPDUInOrder)
686 struct iscsi_conn *conn = cmd->conn;
710 return (conn->sess->sess_ops->DataPDUInOrder) ?
724 struct iscsi_conn *conn = cmd->conn;
731 if (!conn->sess->sess_ops->ErrorRecoveryLevel) {
822 void iscsit_connection_reinstatement_rcfr(struct iscsi_conn *conn)
824 spin_lock_bh(&conn->state_lock);
825 if (atomic_read(&conn->connection_exit)) {
826 spin_unlock_bh(&conn->state_lock);
830 if (atomic_read(&conn->transport_failed)) {
831 spin_unlock_bh(&conn->state_lock);
834 spin_unlock_bh(&conn->state_lock);
836 if (conn->tx_thread && conn->tx_thread_active)
837 send_sig(SIGINT, conn->tx_thread, 1);
838 if (conn->rx_thread && conn->rx_thread_active)
839 send_sig(SIGINT, conn->rx_thread, 1);
842 wait_for_completion(&conn->conn_wait_rcfr_comp);
843 complete(&conn->conn_post_wait_comp);
846 void iscsit_cause_connection_reinstatement(struct iscsi_conn *conn, int sleep)
848 spin_lock_bh(&conn->state_lock);
849 if (atomic_read(&conn->connection_exit)) {
850 spin_unlock_bh(&conn->state_lock);
854 if (atomic_read(&conn->transport_failed)) {
855 spin_unlock_bh(&conn->state_lock);
859 if (atomic_read(&conn->connection_reinstatement)) {
860 spin_unlock_bh(&conn->state_lock);
864 if (conn->tx_thread && conn->tx_thread_active)
865 send_sig(SIGINT, conn->tx_thread, 1);
866 if (conn->rx_thread && conn->rx_thread_active)
867 send_sig(SIGINT, conn->rx_thread, 1);
869 atomic_set(&conn->connection_reinstatement, 1);
871 spin_unlock_bh(&conn->state_lock);
875 atomic_set(&conn->sleep_on_conn_wait_comp, 1);
876 spin_unlock_bh(&conn->state_lock);
878 wait_for_completion(&conn->conn_wait_comp);
879 complete(&conn->conn_post_wait_comp);
891 static void iscsit_handle_connection_cleanup(struct iscsi_conn *conn)
893 struct iscsi_session *sess = conn->sess;
898 iscsit_connection_recovery_transport_reset(conn);
901 " Connection ID: %hu from %s\n", conn->cid,
903 iscsit_close_connection(conn);
907 void iscsit_take_action_for_connection_exit(struct iscsi_conn *conn, bool *conn_freed)
911 spin_lock_bh(&conn->state_lock);
912 if (atomic_read(&conn->connection_exit)) {
913 spin_unlock_bh(&conn->state_lock);
916 atomic_set(&conn->connection_exit, 1);
918 if (conn->conn_state == TARG_CONN_STATE_IN_LOGOUT) {
919 spin_unlock_bh(&conn->state_lock);
920 iscsit_close_connection(conn);
925 if (conn->conn_state == TARG_CONN_STATE_CLEANUP_WAIT) {
926 spin_unlock_bh(&conn->state_lock);
931 conn->conn_state = TARG_CONN_STATE_CLEANUP_WAIT;
932 spin_unlock_bh(&conn->state_lock);
934 iscsit_handle_connection_cleanup(conn);