Lines Matching refs:conn
85 iscsit_add_cmd_to_immediate_queue(cmd, cmd->conn, ISTATE_SEND_R2T); in iscsit_add_r2t_to_list()
154 struct iscsi_cmd *iscsit_allocate_cmd(struct iscsi_conn *conn, int state) in iscsit_allocate_cmd() argument
157 struct se_session *se_sess = conn->sess->se_sess; in iscsit_allocate_cmd()
164 size = sizeof(struct iscsi_cmd) + conn->conn_transport->priv_size; in iscsit_allocate_cmd()
169 cmd->conn = conn; in iscsit_allocate_cmd()
278 int iscsit_sequence_cmd(struct iscsi_conn *conn, struct iscsi_cmd *cmd, in iscsit_sequence_cmd() argument
285 mutex_lock(&conn->sess->cmdsn_mutex); in iscsit_sequence_cmd()
287 cmdsn_ret = iscsit_check_received_cmdsn(conn->sess, be32_to_cpu(cmdsn)); in iscsit_sequence_cmd()
291 if ((ret >= 0) && !list_empty(&conn->sess->sess_ooo_cmdsn_list)) in iscsit_sequence_cmd()
292 iscsit_execute_ooo_cmdsns(conn->sess); in iscsit_sequence_cmd()
299 ret = iscsit_handle_ooo_cmdsn(conn->sess, cmd, be32_to_cpu(cmdsn)); in iscsit_sequence_cmd()
311 iscsit_add_cmd_to_immediate_queue(cmd, conn, cmd->i_state); in iscsit_sequence_cmd()
320 mutex_unlock(&conn->sess->cmdsn_mutex); in iscsit_sequence_cmd()
331 struct iscsi_conn *conn = cmd->conn; in iscsit_check_unsolicited_dataout() local
336 if (conn->sess->sess_ops->InitialR2T) { in iscsit_check_unsolicited_dataout()
345 conn->sess->sess_ops->FirstBurstLength) { in iscsit_check_unsolicited_dataout()
349 conn->sess->sess_ops->FirstBurstLength); in iscsit_check_unsolicited_dataout()
360 conn->sess->sess_ops->FirstBurstLength)) { in iscsit_check_unsolicited_dataout()
365 conn->sess->sess_ops->FirstBurstLength, cmd->se_cmd.data_length); in iscsit_check_unsolicited_dataout()
374 struct iscsi_conn *conn, in iscsit_find_cmd_from_itt() argument
379 spin_lock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_itt()
380 list_for_each_entry(cmd, &conn->conn_cmd_list, i_conn_node) { in iscsit_find_cmd_from_itt()
382 spin_unlock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_itt()
386 spin_unlock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_itt()
389 init_task_tag, conn->cid); in iscsit_find_cmd_from_itt()
395 struct iscsi_conn *conn, in iscsit_find_cmd_from_itt_or_dump() argument
401 spin_lock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_itt_or_dump()
402 list_for_each_entry(cmd, &conn->conn_cmd_list, i_conn_node) { in iscsit_find_cmd_from_itt_or_dump()
406 spin_unlock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_itt_or_dump()
410 spin_unlock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_itt_or_dump()
413 " dumping payload\n", init_task_tag, conn->cid); in iscsit_find_cmd_from_itt_or_dump()
415 iscsit_dump_data_payload(conn, length, 1); in iscsit_find_cmd_from_itt_or_dump()
421 struct iscsi_conn *conn, in iscsit_find_cmd_from_ttt() argument
426 spin_lock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_ttt()
427 list_for_each_entry(cmd, &conn->conn_cmd_list, i_conn_node) { in iscsit_find_cmd_from_ttt()
429 spin_unlock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_ttt()
433 spin_unlock_bh(&conn->cmd_lock); in iscsit_find_cmd_from_ttt()
436 targ_xfer_tag, conn->cid); in iscsit_find_cmd_from_ttt()
494 struct iscsi_conn *conn, in iscsit_add_cmd_to_immediate_queue() argument
509 spin_lock_bh(&conn->immed_queue_lock); in iscsit_add_cmd_to_immediate_queue()
510 list_add_tail(&qr->qr_list, &conn->immed_queue_list); in iscsit_add_cmd_to_immediate_queue()
512 atomic_set(&conn->check_immediate_queue, 1); in iscsit_add_cmd_to_immediate_queue()
513 spin_unlock_bh(&conn->immed_queue_lock); in iscsit_add_cmd_to_immediate_queue()
515 wake_up(&conn->queues_wq); in iscsit_add_cmd_to_immediate_queue()
518 struct iscsi_queue_req *iscsit_get_cmd_from_immediate_queue(struct iscsi_conn *conn) in iscsit_get_cmd_from_immediate_queue() argument
522 spin_lock_bh(&conn->immed_queue_lock); in iscsit_get_cmd_from_immediate_queue()
523 if (list_empty(&conn->immed_queue_list)) { in iscsit_get_cmd_from_immediate_queue()
524 spin_unlock_bh(&conn->immed_queue_lock); in iscsit_get_cmd_from_immediate_queue()
527 qr = list_first_entry(&conn->immed_queue_list, in iscsit_get_cmd_from_immediate_queue()
533 spin_unlock_bh(&conn->immed_queue_lock); in iscsit_get_cmd_from_immediate_queue()
540 struct iscsi_conn *conn) in iscsit_remove_cmd_from_immediate_queue() argument
544 spin_lock_bh(&conn->immed_queue_lock); in iscsit_remove_cmd_from_immediate_queue()
546 spin_unlock_bh(&conn->immed_queue_lock); in iscsit_remove_cmd_from_immediate_queue()
550 list_for_each_entry_safe(qr, qr_tmp, &conn->immed_queue_list, qr_list) { in iscsit_remove_cmd_from_immediate_queue()
558 spin_unlock_bh(&conn->immed_queue_lock); in iscsit_remove_cmd_from_immediate_queue()
569 struct iscsi_conn *conn, in iscsit_add_cmd_to_response_queue() argument
584 spin_lock_bh(&conn->response_queue_lock); in iscsit_add_cmd_to_response_queue()
585 list_add_tail(&qr->qr_list, &conn->response_queue_list); in iscsit_add_cmd_to_response_queue()
587 spin_unlock_bh(&conn->response_queue_lock); in iscsit_add_cmd_to_response_queue()
589 wake_up(&conn->queues_wq); in iscsit_add_cmd_to_response_queue()
592 struct iscsi_queue_req *iscsit_get_cmd_from_response_queue(struct iscsi_conn *conn) in iscsit_get_cmd_from_response_queue() argument
596 spin_lock_bh(&conn->response_queue_lock); in iscsit_get_cmd_from_response_queue()
597 if (list_empty(&conn->response_queue_list)) { in iscsit_get_cmd_from_response_queue()
598 spin_unlock_bh(&conn->response_queue_lock); in iscsit_get_cmd_from_response_queue()
602 qr = list_first_entry(&conn->response_queue_list, in iscsit_get_cmd_from_response_queue()
608 spin_unlock_bh(&conn->response_queue_lock); in iscsit_get_cmd_from_response_queue()
615 struct iscsi_conn *conn) in iscsit_remove_cmd_from_response_queue() argument
619 spin_lock_bh(&conn->response_queue_lock); in iscsit_remove_cmd_from_response_queue()
621 spin_unlock_bh(&conn->response_queue_lock); in iscsit_remove_cmd_from_response_queue()
625 list_for_each_entry_safe(qr, qr_tmp, &conn->response_queue_list, in iscsit_remove_cmd_from_response_queue()
634 spin_unlock_bh(&conn->response_queue_lock); in iscsit_remove_cmd_from_response_queue()
643 bool iscsit_conn_all_queues_empty(struct iscsi_conn *conn) in iscsit_conn_all_queues_empty() argument
647 spin_lock_bh(&conn->immed_queue_lock); in iscsit_conn_all_queues_empty()
648 empty = list_empty(&conn->immed_queue_list); in iscsit_conn_all_queues_empty()
649 spin_unlock_bh(&conn->immed_queue_lock); in iscsit_conn_all_queues_empty()
654 spin_lock_bh(&conn->response_queue_lock); in iscsit_conn_all_queues_empty()
655 empty = list_empty(&conn->response_queue_list); in iscsit_conn_all_queues_empty()
656 spin_unlock_bh(&conn->response_queue_lock); in iscsit_conn_all_queues_empty()
661 void iscsit_free_queue_reqs_for_conn(struct iscsi_conn *conn) in iscsit_free_queue_reqs_for_conn() argument
665 spin_lock_bh(&conn->immed_queue_lock); in iscsit_free_queue_reqs_for_conn()
666 list_for_each_entry_safe(qr, qr_tmp, &conn->immed_queue_list, qr_list) { in iscsit_free_queue_reqs_for_conn()
673 spin_unlock_bh(&conn->immed_queue_lock); in iscsit_free_queue_reqs_for_conn()
675 spin_lock_bh(&conn->response_queue_lock); in iscsit_free_queue_reqs_for_conn()
676 list_for_each_entry_safe(qr, qr_tmp, &conn->response_queue_list, in iscsit_free_queue_reqs_for_conn()
684 spin_unlock_bh(&conn->response_queue_lock); in iscsit_free_queue_reqs_for_conn()
692 if (cmd->conn) in iscsit_release_cmd()
693 sess = cmd->conn->sess; in iscsit_release_cmd()
713 struct iscsi_conn *conn = cmd->conn; in __iscsit_free_cmd() local
724 if (conn && check_queues) { in __iscsit_free_cmd()
725 iscsit_remove_cmd_from_immediate_queue(cmd, conn); in __iscsit_free_cmd()
726 iscsit_remove_cmd_from_response_queue(cmd, conn); in __iscsit_free_cmd()
816 int iscsit_set_sync_and_steering_values(struct iscsi_conn *conn) in iscsit_set_sync_and_steering_values() argument
822 u32 IFMarkInt = (conn->conn_ops->IFMarkInt * 4); in iscsit_set_sync_and_steering_values()
823 u32 OFMarkInt = (conn->conn_ops->OFMarkInt * 4); in iscsit_set_sync_and_steering_values()
825 if (conn->conn_ops->OFMarker) { in iscsit_set_sync_and_steering_values()
830 conn->of_marker += ISCSI_HDR_LEN; in iscsit_set_sync_and_steering_values()
831 if (conn->of_marker <= OFMarkInt) { in iscsit_set_sync_and_steering_values()
832 conn->of_marker = (OFMarkInt - conn->of_marker); in iscsit_set_sync_and_steering_values()
834 login_ofmarker_count = (conn->of_marker / OFMarkInt); in iscsit_set_sync_and_steering_values()
837 conn->of_marker = (next_marker - conn->of_marker); in iscsit_set_sync_and_steering_values()
839 conn->of_marker_offset = 0; in iscsit_set_sync_and_steering_values()
841 " Markerless Interval.\n", conn->of_marker); in iscsit_set_sync_and_steering_values()
844 if (conn->conn_ops->IFMarker) { in iscsit_set_sync_and_steering_values()
845 if (conn->if_marker <= IFMarkInt) { in iscsit_set_sync_and_steering_values()
846 conn->if_marker = (IFMarkInt - conn->if_marker); in iscsit_set_sync_and_steering_values()
848 login_ifmarker_count = (conn->if_marker / IFMarkInt); in iscsit_set_sync_and_steering_values()
851 conn->if_marker = (next_marker - conn->if_marker); in iscsit_set_sync_and_steering_values()
854 " Markerless Interval.\n", conn->if_marker); in iscsit_set_sync_and_steering_values()
862 struct iscsi_conn *conn; in iscsit_get_conn_from_cid() local
865 list_for_each_entry(conn, &sess->sess_conn_list, conn_list) { in iscsit_get_conn_from_cid()
866 if ((conn->cid == cid) && in iscsit_get_conn_from_cid()
867 (conn->conn_state == TARG_CONN_STATE_LOGGED_IN)) { in iscsit_get_conn_from_cid()
868 iscsit_inc_conn_usage_count(conn); in iscsit_get_conn_from_cid()
870 return conn; in iscsit_get_conn_from_cid()
880 struct iscsi_conn *conn; in iscsit_get_conn_from_cid_rcfr() local
883 list_for_each_entry(conn, &sess->sess_conn_list, conn_list) { in iscsit_get_conn_from_cid_rcfr()
884 if (conn->cid == cid) { in iscsit_get_conn_from_cid_rcfr()
885 iscsit_inc_conn_usage_count(conn); in iscsit_get_conn_from_cid_rcfr()
886 spin_lock(&conn->state_lock); in iscsit_get_conn_from_cid_rcfr()
887 atomic_set(&conn->connection_wait_rcfr, 1); in iscsit_get_conn_from_cid_rcfr()
888 spin_unlock(&conn->state_lock); in iscsit_get_conn_from_cid_rcfr()
890 return conn; in iscsit_get_conn_from_cid_rcfr()
898 void iscsit_check_conn_usage_count(struct iscsi_conn *conn) in iscsit_check_conn_usage_count() argument
900 spin_lock_bh(&conn->conn_usage_lock); in iscsit_check_conn_usage_count()
901 if (conn->conn_usage_count != 0) { in iscsit_check_conn_usage_count()
902 conn->conn_waiting_on_uc = 1; in iscsit_check_conn_usage_count()
903 spin_unlock_bh(&conn->conn_usage_lock); in iscsit_check_conn_usage_count()
905 wait_for_completion(&conn->conn_waiting_on_uc_comp); in iscsit_check_conn_usage_count()
908 spin_unlock_bh(&conn->conn_usage_lock); in iscsit_check_conn_usage_count()
911 void iscsit_dec_conn_usage_count(struct iscsi_conn *conn) in iscsit_dec_conn_usage_count() argument
913 spin_lock_bh(&conn->conn_usage_lock); in iscsit_dec_conn_usage_count()
914 conn->conn_usage_count--; in iscsit_dec_conn_usage_count()
916 if (!conn->conn_usage_count && conn->conn_waiting_on_uc) in iscsit_dec_conn_usage_count()
917 complete(&conn->conn_waiting_on_uc_comp); in iscsit_dec_conn_usage_count()
919 spin_unlock_bh(&conn->conn_usage_lock); in iscsit_dec_conn_usage_count()
922 void iscsit_inc_conn_usage_count(struct iscsi_conn *conn) in iscsit_inc_conn_usage_count() argument
924 spin_lock_bh(&conn->conn_usage_lock); in iscsit_inc_conn_usage_count()
925 conn->conn_usage_count++; in iscsit_inc_conn_usage_count()
926 spin_unlock_bh(&conn->conn_usage_lock); in iscsit_inc_conn_usage_count()
929 static int iscsit_add_nopin(struct iscsi_conn *conn, int want_response) in iscsit_add_nopin() argument
934 cmd = iscsit_allocate_cmd(conn, TASK_RUNNING); in iscsit_add_nopin()
943 session_get_next_ttt(conn->sess) : 0xFFFFFFFF; in iscsit_add_nopin()
944 spin_lock_bh(&conn->cmd_lock); in iscsit_add_nopin()
945 list_add_tail(&cmd->i_conn_node, &conn->conn_cmd_list); in iscsit_add_nopin()
946 spin_unlock_bh(&conn->cmd_lock); in iscsit_add_nopin()
949 iscsit_start_nopin_response_timer(conn); in iscsit_add_nopin()
950 iscsit_add_cmd_to_immediate_queue(cmd, conn, state); in iscsit_add_nopin()
957 struct iscsi_conn *conn = (struct iscsi_conn *) data; in iscsit_handle_nopin_response_timeout() local
959 iscsit_inc_conn_usage_count(conn); in iscsit_handle_nopin_response_timeout()
961 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_handle_nopin_response_timeout()
962 if (conn->nopin_response_timer_flags & ISCSI_TF_STOP) { in iscsit_handle_nopin_response_timeout()
963 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_handle_nopin_response_timeout()
964 iscsit_dec_conn_usage_count(conn); in iscsit_handle_nopin_response_timeout()
969 " SID: %u, failing connection.\n", conn->cid, in iscsit_handle_nopin_response_timeout()
970 conn->sess->sid); in iscsit_handle_nopin_response_timeout()
971 conn->nopin_response_timer_flags &= ~ISCSI_TF_RUNNING; in iscsit_handle_nopin_response_timeout()
972 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_handle_nopin_response_timeout()
975 struct iscsi_portal_group *tpg = conn->sess->tpg; in iscsit_handle_nopin_response_timeout()
981 conn->sess->sess_ops->InitiatorName); in iscsit_handle_nopin_response_timeout()
985 atomic_long_inc(&conn->sess->conn_timeout_errors); in iscsit_handle_nopin_response_timeout()
990 iscsit_cause_connection_reinstatement(conn, 0); in iscsit_handle_nopin_response_timeout()
991 iscsit_dec_conn_usage_count(conn); in iscsit_handle_nopin_response_timeout()
994 void iscsit_mod_nopin_response_timer(struct iscsi_conn *conn) in iscsit_mod_nopin_response_timer() argument
996 struct iscsi_session *sess = conn->sess; in iscsit_mod_nopin_response_timer()
999 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_mod_nopin_response_timer()
1000 if (!(conn->nopin_response_timer_flags & ISCSI_TF_RUNNING)) { in iscsit_mod_nopin_response_timer()
1001 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_mod_nopin_response_timer()
1005 mod_timer(&conn->nopin_response_timer, in iscsit_mod_nopin_response_timer()
1007 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_mod_nopin_response_timer()
1013 void iscsit_start_nopin_response_timer(struct iscsi_conn *conn) in iscsit_start_nopin_response_timer() argument
1015 struct iscsi_session *sess = conn->sess; in iscsit_start_nopin_response_timer()
1018 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_start_nopin_response_timer()
1019 if (conn->nopin_response_timer_flags & ISCSI_TF_RUNNING) { in iscsit_start_nopin_response_timer()
1020 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_start_nopin_response_timer()
1024 init_timer(&conn->nopin_response_timer); in iscsit_start_nopin_response_timer()
1025 conn->nopin_response_timer.expires = in iscsit_start_nopin_response_timer()
1027 conn->nopin_response_timer.data = (unsigned long)conn; in iscsit_start_nopin_response_timer()
1028 conn->nopin_response_timer.function = iscsit_handle_nopin_response_timeout; in iscsit_start_nopin_response_timer()
1029 conn->nopin_response_timer_flags &= ~ISCSI_TF_STOP; in iscsit_start_nopin_response_timer()
1030 conn->nopin_response_timer_flags |= ISCSI_TF_RUNNING; in iscsit_start_nopin_response_timer()
1031 add_timer(&conn->nopin_response_timer); in iscsit_start_nopin_response_timer()
1034 " seconds\n", conn->cid, na->nopin_response_timeout); in iscsit_start_nopin_response_timer()
1035 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_start_nopin_response_timer()
1038 void iscsit_stop_nopin_response_timer(struct iscsi_conn *conn) in iscsit_stop_nopin_response_timer() argument
1040 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_response_timer()
1041 if (!(conn->nopin_response_timer_flags & ISCSI_TF_RUNNING)) { in iscsit_stop_nopin_response_timer()
1042 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_response_timer()
1045 conn->nopin_response_timer_flags |= ISCSI_TF_STOP; in iscsit_stop_nopin_response_timer()
1046 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_response_timer()
1048 del_timer_sync(&conn->nopin_response_timer); in iscsit_stop_nopin_response_timer()
1050 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_response_timer()
1051 conn->nopin_response_timer_flags &= ~ISCSI_TF_RUNNING; in iscsit_stop_nopin_response_timer()
1052 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_response_timer()
1057 struct iscsi_conn *conn = (struct iscsi_conn *) data; in iscsit_handle_nopin_timeout() local
1059 iscsit_inc_conn_usage_count(conn); in iscsit_handle_nopin_timeout()
1061 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_handle_nopin_timeout()
1062 if (conn->nopin_timer_flags & ISCSI_TF_STOP) { in iscsit_handle_nopin_timeout()
1063 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_handle_nopin_timeout()
1064 iscsit_dec_conn_usage_count(conn); in iscsit_handle_nopin_timeout()
1067 conn->nopin_timer_flags &= ~ISCSI_TF_RUNNING; in iscsit_handle_nopin_timeout()
1068 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_handle_nopin_timeout()
1070 iscsit_add_nopin(conn, 1); in iscsit_handle_nopin_timeout()
1071 iscsit_dec_conn_usage_count(conn); in iscsit_handle_nopin_timeout()
1077 void __iscsit_start_nopin_timer(struct iscsi_conn *conn) in __iscsit_start_nopin_timer() argument
1079 struct iscsi_session *sess = conn->sess; in __iscsit_start_nopin_timer()
1087 if (conn->nopin_timer_flags & ISCSI_TF_RUNNING) in __iscsit_start_nopin_timer()
1090 init_timer(&conn->nopin_timer); in __iscsit_start_nopin_timer()
1091 conn->nopin_timer.expires = (get_jiffies_64() + na->nopin_timeout * HZ); in __iscsit_start_nopin_timer()
1092 conn->nopin_timer.data = (unsigned long)conn; in __iscsit_start_nopin_timer()
1093 conn->nopin_timer.function = iscsit_handle_nopin_timeout; in __iscsit_start_nopin_timer()
1094 conn->nopin_timer_flags &= ~ISCSI_TF_STOP; in __iscsit_start_nopin_timer()
1095 conn->nopin_timer_flags |= ISCSI_TF_RUNNING; in __iscsit_start_nopin_timer()
1096 add_timer(&conn->nopin_timer); in __iscsit_start_nopin_timer()
1099 " interval\n", conn->cid, na->nopin_timeout); in __iscsit_start_nopin_timer()
1102 void iscsit_start_nopin_timer(struct iscsi_conn *conn) in iscsit_start_nopin_timer() argument
1104 struct iscsi_session *sess = conn->sess; in iscsit_start_nopin_timer()
1112 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_start_nopin_timer()
1113 if (conn->nopin_timer_flags & ISCSI_TF_RUNNING) { in iscsit_start_nopin_timer()
1114 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_start_nopin_timer()
1118 init_timer(&conn->nopin_timer); in iscsit_start_nopin_timer()
1119 conn->nopin_timer.expires = (get_jiffies_64() + na->nopin_timeout * HZ); in iscsit_start_nopin_timer()
1120 conn->nopin_timer.data = (unsigned long)conn; in iscsit_start_nopin_timer()
1121 conn->nopin_timer.function = iscsit_handle_nopin_timeout; in iscsit_start_nopin_timer()
1122 conn->nopin_timer_flags &= ~ISCSI_TF_STOP; in iscsit_start_nopin_timer()
1123 conn->nopin_timer_flags |= ISCSI_TF_RUNNING; in iscsit_start_nopin_timer()
1124 add_timer(&conn->nopin_timer); in iscsit_start_nopin_timer()
1127 " interval\n", conn->cid, na->nopin_timeout); in iscsit_start_nopin_timer()
1128 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_start_nopin_timer()
1131 void iscsit_stop_nopin_timer(struct iscsi_conn *conn) in iscsit_stop_nopin_timer() argument
1133 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_timer()
1134 if (!(conn->nopin_timer_flags & ISCSI_TF_RUNNING)) { in iscsit_stop_nopin_timer()
1135 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_timer()
1138 conn->nopin_timer_flags |= ISCSI_TF_STOP; in iscsit_stop_nopin_timer()
1139 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_timer()
1141 del_timer_sync(&conn->nopin_timer); in iscsit_stop_nopin_timer()
1143 spin_lock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_timer()
1144 conn->nopin_timer_flags &= ~ISCSI_TF_RUNNING; in iscsit_stop_nopin_timer()
1145 spin_unlock_bh(&conn->nopin_timer_lock); in iscsit_stop_nopin_timer()
1150 struct iscsi_conn *conn, in iscsit_send_tx_data() argument
1168 tx_sent = tx_data(conn, &iov[0], iov_count, tx_size); in iscsit_send_tx_data()
1183 struct iscsi_conn *conn) in iscsit_fe_sendpage_sg() argument
1193 if (conn->conn_ops->HeaderDigest) in iscsit_fe_sendpage_sg()
1199 tx_sent = tx_data(conn, &iov, 1, tx_hdr_size); in iscsit_fe_sendpage_sg()
1213 if (conn->conn_ops->DataDigest) { in iscsit_fe_sendpage_sg()
1229 tx_sent = conn->sock->ops->sendpage(conn->sock, in iscsit_fe_sendpage_sg()
1252 tx_sent = tx_data(conn, iov_p, 1, cmd->padding); in iscsit_fe_sendpage_sg()
1263 if (conn->conn_ops->DataDigest) { in iscsit_fe_sendpage_sg()
1266 tx_sent = tx_data(conn, iov_d, 1, ISCSI_CRC_LEN); in iscsit_fe_sendpage_sg()
1287 int iscsit_tx_login_rsp(struct iscsi_conn *conn, u8 status_class, u8 status_detail) in iscsit_tx_login_rsp() argument
1290 struct iscsi_login *login = conn->conn_login; in iscsit_tx_login_rsp()
1293 iscsit_collect_login_stats(conn, status_class, status_detail); in iscsit_tx_login_rsp()
1301 hdr->itt = conn->login_itt; in iscsit_tx_login_rsp()
1303 return conn->conn_transport->iscsit_put_login_tx(conn, login, 0); in iscsit_tx_login_rsp()
1308 struct iscsi_conn *conn; in iscsit_print_session_params() local
1313 list_for_each_entry(conn, &sess->sess_conn_list, conn_list) in iscsit_print_session_params()
1314 iscsi_dump_conn_ops(conn->conn_ops); in iscsit_print_session_params()
1321 struct iscsi_conn *conn, in iscsit_do_rx_data() argument
1327 if (!conn || !conn->sock || !conn->conn_ops) in iscsit_do_rx_data()
1335 rx_loop = sock_recvmsg(conn->sock, &msg, in iscsit_do_rx_data()
1351 struct iscsi_conn *conn, in iscsit_do_tx_data() argument
1358 if (!conn || !conn->sock || !conn->conn_ops) in iscsit_do_tx_data()
1371 ret = kernel_sendmsg(conn->sock, &msg, iov_p, iov_len, in iscsit_do_tx_data()
1384 struct iscsi_conn *conn, in rx_data() argument
1391 if (!conn || !conn->sock || !conn->conn_ops) in rx_data()
1400 return iscsit_do_rx_data(conn, &c); in rx_data()
1404 struct iscsi_conn *conn, in tx_data() argument
1411 if (!conn || !conn->sock || !conn->conn_ops) in tx_data()
1420 return iscsit_do_tx_data(conn, &c); in tx_data()
1424 struct iscsi_conn *conn, in iscsit_collect_login_stats() argument
1432 tiqn = iscsit_snmp_get_tiqn(conn); in iscsit_collect_login_stats()
1439 if (!strcmp(conn->login_ip, ls->last_intr_fail_ip_addr) && in iscsit_collect_login_stats()
1470 if (conn->param_list) in iscsit_collect_login_stats()
1472 conn->param_list); in iscsit_collect_login_stats()
1477 ls->last_intr_fail_ip_family = conn->login_family; in iscsit_collect_login_stats()
1480 "%s", conn->login_ip); in iscsit_collect_login_stats()
1487 struct iscsi_tiqn *iscsit_snmp_get_tiqn(struct iscsi_conn *conn) in iscsit_snmp_get_tiqn() argument
1491 if (!conn || !conn->sess) in iscsit_snmp_get_tiqn()
1494 tpg = conn->sess->tpg; in iscsit_snmp_get_tiqn()