Lines Matching refs:conn
88 inline void iscsi_conn_queue_work(struct iscsi_conn *conn) in iscsi_conn_queue_work() argument
90 struct Scsi_Host *shost = conn->session->host; in iscsi_conn_queue_work()
94 queue_work(ihost->workq, &conn->xmitwork); in iscsi_conn_queue_work()
139 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() local
153 if (left > conn->max_xmit_dlength) { in iscsi_prep_data_out_pdu()
154 hton24(hdr->dlength, conn->max_xmit_dlength); in iscsi_prep_data_out_pdu()
155 r2t->data_count = conn->max_xmit_dlength; in iscsi_prep_data_out_pdu()
162 conn->dataout_pdus_cnt++; in iscsi_prep_data_out_pdu()
212 ISCSI_DBG_SESSION(task->conn->session, in iscsi_prep_ecdb_ahs()
238 ISCSI_DBG_SESSION(task->conn->session, in iscsi_prep_bidi_ahs()
261 struct iscsi_conn *conn = task->conn; in iscsi_check_tmf_restrictions() local
262 struct iscsi_tm *tmf = &conn->tmhdr; in iscsi_check_tmf_restrictions()
265 if (conn->tmf_state == TMF_INITIAL) in iscsi_check_tmf_restrictions()
285 iscsi_conn_printk(KERN_INFO, conn, in iscsi_check_tmf_restrictions()
297 if (conn->session->fast_abort) { in iscsi_check_tmf_restrictions()
298 iscsi_conn_printk(KERN_INFO, conn, in iscsi_check_tmf_restrictions()
315 ISCSI_DBG_SESSION(conn->session, in iscsi_check_tmf_restrictions()
337 struct iscsi_conn *conn = task->conn; in iscsi_prep_scsi_cmd_pdu() local
338 struct iscsi_session *session = conn->session; in iscsi_prep_scsi_cmd_pdu()
349 if (conn->session->tt->alloc_pdu) { in iscsi_prep_scsi_cmd_pdu()
350 rc = conn->session->tt->alloc_pdu(task, ISCSI_OP_SCSI_CMD); in iscsi_prep_scsi_cmd_pdu()
362 task->conn->session->age); in iscsi_prep_scsi_cmd_pdu()
371 hdr->exp_statsn = cpu_to_be32(conn->exp_statsn); in iscsi_prep_scsi_cmd_pdu()
419 conn->max_xmit_dlength); in iscsi_prep_scsi_cmd_pdu()
422 conn->max_xmit_dlength); in iscsi_prep_scsi_cmd_pdu()
433 r2t->exp_statsn = cpu_to_be32(conn->exp_statsn); in iscsi_prep_scsi_cmd_pdu()
463 conn->scsicmd_pdus_cnt++; in iscsi_prep_scsi_cmd_pdu()
468 "write" : "read", conn->id, sc, sc->cmnd[0], in iscsi_prep_scsi_cmd_pdu()
486 struct iscsi_conn *conn = task->conn; in iscsi_free_task() local
487 struct iscsi_session *session = conn->session; in iscsi_free_task()
500 if (conn->login_task == task) in iscsi_free_task()
532 struct iscsi_session *session = task->conn->session; in iscsi_put_task()
550 struct iscsi_conn *conn = task->conn; in iscsi_complete_task() local
552 ISCSI_DBG_SESSION(conn->session, in iscsi_complete_task()
566 if (conn->task == task) in iscsi_complete_task()
567 conn->task = NULL; in iscsi_complete_task()
569 if (conn->ping_task == task) in iscsi_complete_task()
570 conn->ping_task = NULL; in iscsi_complete_task()
590 struct iscsi_conn *conn = task->conn; in iscsi_complete_scsi_task() local
592 ISCSI_DBG_SESSION(conn->session, "[itt 0x%x]\n", task->itt); in iscsi_complete_scsi_task()
594 conn->last_recv = jiffies; in iscsi_complete_scsi_task()
595 __iscsi_update_cmdsn(conn->session, exp_cmdsn, max_cmdsn); in iscsi_complete_scsi_task()
608 struct iscsi_conn *conn = task->conn; in fail_scsi_task() local
626 conn->session->queued_cmdsn--; in fail_scsi_task()
643 spin_lock_bh(&conn->session->back_lock); in fail_scsi_task()
645 spin_unlock_bh(&conn->session->back_lock); in fail_scsi_task()
648 static int iscsi_prep_mgmt_task(struct iscsi_conn *conn, in iscsi_prep_mgmt_task() argument
651 struct iscsi_session *session = conn->session; in iscsi_prep_mgmt_task()
656 if (conn->session->state == ISCSI_STATE_LOGGING_OUT) in iscsi_prep_mgmt_task()
660 nop->exp_statsn = cpu_to_be32(conn->exp_statsn); in iscsi_prep_mgmt_task()
674 if (conn->c_stage == ISCSI_CONN_STARTED && in iscsi_prep_mgmt_task()
695 __iscsi_conn_send_pdu(struct iscsi_conn *conn, struct iscsi_hdr *hdr, in __iscsi_conn_send_pdu() argument
698 struct iscsi_session *session = conn->session; in __iscsi_conn_send_pdu()
714 if (conn->login_task->state != ISCSI_TASK_FREE) { in __iscsi_conn_send_pdu()
715 iscsi_conn_printk(KERN_ERR, conn, "Login/Text in " in __iscsi_conn_send_pdu()
721 …iscsi_conn_printk(KERN_ERR, conn, "Invalid buffer len of %u for login task. Max len is %u\n", data… in __iscsi_conn_send_pdu()
725 task = conn->login_task; in __iscsi_conn_send_pdu()
731 …iscsi_conn_printk(KERN_ERR, conn, "Can not send data buffer of len %u for op 0x%x\n", data_size, o… in __iscsi_conn_send_pdu()
735 BUG_ON(conn->c_stage == ISCSI_CONN_INITIAL_STAGE); in __iscsi_conn_send_pdu()
736 BUG_ON(conn->c_stage == ISCSI_CONN_STOPPED); in __iscsi_conn_send_pdu()
748 task->conn = conn; in __iscsi_conn_send_pdu()
759 if (conn->session->tt->alloc_pdu) { in __iscsi_conn_send_pdu()
760 if (conn->session->tt->alloc_pdu(task, hdr->opcode)) { in __iscsi_conn_send_pdu()
761 iscsi_conn_printk(KERN_ERR, conn, "Could not allocate " in __iscsi_conn_send_pdu()
776 task->conn->session->age); in __iscsi_conn_send_pdu()
780 if (iscsi_prep_mgmt_task(conn, task)) in __iscsi_conn_send_pdu()
786 list_add_tail(&task->running, &conn->mgmtqueue); in __iscsi_conn_send_pdu()
787 iscsi_conn_queue_work(conn); in __iscsi_conn_send_pdu()
803 struct iscsi_conn *conn = cls_conn->dd_data; in iscsi_conn_send_pdu() local
804 struct iscsi_session *session = conn->session; in iscsi_conn_send_pdu()
808 if (!__iscsi_conn_send_pdu(conn, hdr, data, data_size)) in iscsi_conn_send_pdu()
826 static void iscsi_scsi_cmd_rsp(struct iscsi_conn *conn, struct iscsi_hdr *hdr, in iscsi_scsi_cmd_rsp() argument
831 struct iscsi_session *session = conn->session; in iscsi_scsi_cmd_rsp()
835 conn->exp_statsn = be32_to_cpu(rhdr->statsn) + 1; in iscsi_scsi_cmd_rsp()
873 iscsi_conn_printk(KERN_ERR, conn, in iscsi_scsi_cmd_rsp()
918 conn->scsirsp_pdus_cnt++; in iscsi_scsi_cmd_rsp()
929 iscsi_data_in_rsp(struct iscsi_conn *conn, struct iscsi_hdr *hdr, in iscsi_data_in_rsp() argument
938 iscsi_update_cmdsn(conn->session, (struct iscsi_nopin *)hdr); in iscsi_data_in_rsp()
940 conn->exp_statsn = be32_to_cpu(rhdr->statsn) + 1; in iscsi_data_in_rsp()
953 ISCSI_DBG_SESSION(conn->session, "data in with status done " in iscsi_data_in_rsp()
956 conn->scsirsp_pdus_cnt++; in iscsi_data_in_rsp()
960 static void iscsi_tmf_rsp(struct iscsi_conn *conn, struct iscsi_hdr *hdr) in iscsi_tmf_rsp() argument
964 conn->exp_statsn = be32_to_cpu(hdr->statsn) + 1; in iscsi_tmf_rsp()
965 conn->tmfrsp_pdus_cnt++; in iscsi_tmf_rsp()
967 if (conn->tmf_state != TMF_QUEUED) in iscsi_tmf_rsp()
971 conn->tmf_state = TMF_SUCCESS; in iscsi_tmf_rsp()
973 conn->tmf_state = TMF_NOT_FOUND; in iscsi_tmf_rsp()
975 conn->tmf_state = TMF_FAILED; in iscsi_tmf_rsp()
976 wake_up(&conn->ehwait); in iscsi_tmf_rsp()
979 static int iscsi_send_nopout(struct iscsi_conn *conn, struct iscsi_nopin *rhdr) in iscsi_send_nopout() argument
984 if (!rhdr && conn->ping_task) in iscsi_send_nopout()
998 task = __iscsi_conn_send_pdu(conn, (struct iscsi_hdr *)&hdr, NULL, 0); in iscsi_send_nopout()
1000 iscsi_conn_printk(KERN_ERR, conn, "Could not send nopout\n"); in iscsi_send_nopout()
1004 conn->ping_task = task; in iscsi_send_nopout()
1005 conn->last_ping = jiffies; in iscsi_send_nopout()
1014 struct iscsi_conn *conn = task->conn; in iscsi_nop_out_rsp() local
1017 if (conn->ping_task != task) { in iscsi_nop_out_rsp()
1022 if (iscsi_recv_pdu(conn->cls_conn, (struct iscsi_hdr *)nop, in iscsi_nop_out_rsp()
1026 mod_timer(&conn->transport_timer, jiffies + conn->recv_timeout); in iscsi_nop_out_rsp()
1031 static int iscsi_handle_reject(struct iscsi_conn *conn, struct iscsi_hdr *hdr, in iscsi_handle_reject() argument
1038 conn->exp_statsn = be32_to_cpu(reject->statsn) + 1; in iscsi_handle_reject()
1042 iscsi_conn_printk(KERN_ERR, conn, "Cannot handle rejected " in iscsi_handle_reject()
1053 iscsi_conn_printk(KERN_ERR, conn, in iscsi_handle_reject()
1059 iscsi_conn_printk(KERN_ERR, conn, in iscsi_handle_reject()
1080 spin_unlock(&conn->session->back_lock); in iscsi_handle_reject()
1081 spin_lock(&conn->session->frwd_lock); in iscsi_handle_reject()
1082 iscsi_send_nopout(conn, in iscsi_handle_reject()
1084 spin_unlock(&conn->session->frwd_lock); in iscsi_handle_reject()
1085 spin_lock(&conn->session->back_lock); in iscsi_handle_reject()
1092 task = iscsi_itt_to_task(conn, rejected_pdu.itt); in iscsi_handle_reject()
1094 iscsi_conn_printk(KERN_ERR, conn, in iscsi_handle_reject()
1105 iscsi_conn_printk(KERN_ERR, conn, in iscsi_handle_reject()
1124 struct iscsi_task *iscsi_itt_to_task(struct iscsi_conn *conn, itt_t itt) in iscsi_itt_to_task() argument
1126 struct iscsi_session *session = conn->session; in iscsi_itt_to_task()
1133 session->tt->parse_pdu_itt(conn, itt, &i, NULL); in iscsi_itt_to_task()
1154 int __iscsi_complete_pdu(struct iscsi_conn *conn, struct iscsi_hdr *hdr, in __iscsi_complete_pdu() argument
1157 struct iscsi_session *session = conn->session; in __iscsi_complete_pdu()
1162 conn->last_recv = jiffies; in __iscsi_complete_pdu()
1163 rc = iscsi_verify_itt(conn, hdr->itt); in __iscsi_complete_pdu()
1173 opcode, conn->id, itt, datalen); in __iscsi_complete_pdu()
1191 iscsi_send_nopout(conn, (struct iscsi_nopin*)hdr); in __iscsi_complete_pdu()
1196 rc = iscsi_handle_reject(conn, hdr, data, datalen); in __iscsi_complete_pdu()
1199 conn->exp_statsn = be32_to_cpu(hdr->statsn) + 1; in __iscsi_complete_pdu()
1200 if (iscsi_recv_pdu(conn->cls_conn, hdr, data, datalen)) in __iscsi_complete_pdu()
1213 task = iscsi_itt_to_ctask(conn, hdr->itt); in __iscsi_complete_pdu()
1228 task = iscsi_itt_to_task(conn, hdr->itt); in __iscsi_complete_pdu()
1238 iscsi_scsi_cmd_rsp(conn, hdr, task, data, datalen); in __iscsi_complete_pdu()
1241 iscsi_data_in_rsp(conn, hdr, task); in __iscsi_complete_pdu()
1249 conn->exp_statsn = be32_to_cpu(hdr->statsn) + 1; in __iscsi_complete_pdu()
1266 iscsi_tmf_rsp(conn, hdr); in __iscsi_complete_pdu()
1275 conn->exp_statsn = be32_to_cpu(hdr->statsn) + 1; in __iscsi_complete_pdu()
1288 if (iscsi_recv_pdu(conn->cls_conn, hdr, data, datalen)) in __iscsi_complete_pdu()
1295 int iscsi_complete_pdu(struct iscsi_conn *conn, struct iscsi_hdr *hdr, in iscsi_complete_pdu() argument
1300 spin_lock(&conn->session->back_lock); in iscsi_complete_pdu()
1301 rc = __iscsi_complete_pdu(conn, hdr, data, datalen); in iscsi_complete_pdu()
1302 spin_unlock(&conn->session->back_lock); in iscsi_complete_pdu()
1307 int iscsi_verify_itt(struct iscsi_conn *conn, itt_t itt) in iscsi_verify_itt() argument
1309 struct iscsi_session *session = conn->session; in iscsi_verify_itt()
1316 session->tt->parse_pdu_itt(conn, itt, &i, &age); in iscsi_verify_itt()
1323 iscsi_conn_printk(KERN_ERR, conn, in iscsi_verify_itt()
1330 iscsi_conn_printk(KERN_ERR, conn, in iscsi_verify_itt()
1348 struct iscsi_task *iscsi_itt_to_ctask(struct iscsi_conn *conn, itt_t itt) in iscsi_itt_to_ctask() argument
1352 if (iscsi_verify_itt(conn, itt)) in iscsi_itt_to_ctask()
1355 task = iscsi_itt_to_task(conn, itt); in iscsi_itt_to_ctask()
1359 if (task->sc->SCp.phase != conn->session->age) { in iscsi_itt_to_ctask()
1360 iscsi_session_printk(KERN_ERR, conn->session, in iscsi_itt_to_ctask()
1362 task->sc->SCp.phase, conn->session->age); in iscsi_itt_to_ctask()
1373 struct iscsi_conn *conn; in iscsi_session_failure() local
1377 conn = session->leadconn; in iscsi_session_failure()
1378 if (session->state == ISCSI_STATE_TERMINATE || !conn) { in iscsi_session_failure()
1383 dev = get_device(&conn->cls_conn->dev); in iscsi_session_failure()
1393 iscsi_conn_error_event(conn->cls_conn, err); in iscsi_session_failure()
1395 iscsi_conn_failure(conn, err); in iscsi_session_failure()
1400 void iscsi_conn_failure(struct iscsi_conn *conn, enum iscsi_err err) in iscsi_conn_failure() argument
1402 struct iscsi_session *session = conn->session; in iscsi_conn_failure()
1410 if (conn->stop_stage == 0) in iscsi_conn_failure()
1414 set_bit(ISCSI_SUSPEND_BIT, &conn->suspend_tx); in iscsi_conn_failure()
1415 set_bit(ISCSI_SUSPEND_BIT, &conn->suspend_rx); in iscsi_conn_failure()
1416 iscsi_conn_error_event(conn->cls_conn, err); in iscsi_conn_failure()
1420 static int iscsi_check_cmdsn_window_closed(struct iscsi_conn *conn) in iscsi_check_cmdsn_window_closed() argument
1422 struct iscsi_session *session = conn->session; in iscsi_check_cmdsn_window_closed()
1437 static int iscsi_xmit_task(struct iscsi_conn *conn) in iscsi_xmit_task() argument
1439 struct iscsi_task *task = conn->task; in iscsi_xmit_task()
1442 if (test_bit(ISCSI_SUSPEND_BIT, &conn->suspend_tx)) in iscsi_xmit_task()
1446 spin_unlock_bh(&conn->session->frwd_lock); in iscsi_xmit_task()
1447 rc = conn->session->tt->xmit_task(task); in iscsi_xmit_task()
1448 spin_lock_bh(&conn->session->frwd_lock); in iscsi_xmit_task()
1452 conn->task = NULL; in iscsi_xmit_task()
1455 spin_lock(&conn->session->back_lock); in iscsi_xmit_task()
1457 spin_unlock(&conn->session->back_lock); in iscsi_xmit_task()
1471 struct iscsi_conn *conn = task->conn; in iscsi_requeue_task() local
1478 list_add_tail(&task->running, &conn->requeue); in iscsi_requeue_task()
1479 iscsi_conn_queue_work(conn); in iscsi_requeue_task()
1492 static int iscsi_data_xmit(struct iscsi_conn *conn) in iscsi_data_xmit() argument
1497 spin_lock_bh(&conn->session->frwd_lock); in iscsi_data_xmit()
1498 if (test_bit(ISCSI_SUSPEND_BIT, &conn->suspend_tx)) { in iscsi_data_xmit()
1499 ISCSI_DBG_SESSION(conn->session, "Tx suspended!\n"); in iscsi_data_xmit()
1500 spin_unlock_bh(&conn->session->frwd_lock); in iscsi_data_xmit()
1504 if (conn->task) { in iscsi_data_xmit()
1505 rc = iscsi_xmit_task(conn); in iscsi_data_xmit()
1516 while (!list_empty(&conn->mgmtqueue)) { in iscsi_data_xmit()
1517 conn->task = list_entry(conn->mgmtqueue.next, in iscsi_data_xmit()
1519 list_del_init(&conn->task->running); in iscsi_data_xmit()
1520 if (iscsi_prep_mgmt_task(conn, conn->task)) { in iscsi_data_xmit()
1522 spin_lock_bh(&conn->session->back_lock); in iscsi_data_xmit()
1523 __iscsi_put_task(conn->task); in iscsi_data_xmit()
1524 spin_unlock_bh(&conn->session->back_lock); in iscsi_data_xmit()
1525 conn->task = NULL; in iscsi_data_xmit()
1528 rc = iscsi_xmit_task(conn); in iscsi_data_xmit()
1534 while (!list_empty(&conn->cmdqueue)) { in iscsi_data_xmit()
1535 conn->task = list_entry(conn->cmdqueue.next, struct iscsi_task, in iscsi_data_xmit()
1537 list_del_init(&conn->task->running); in iscsi_data_xmit()
1538 if (conn->session->state == ISCSI_STATE_LOGGING_OUT) { in iscsi_data_xmit()
1539 fail_scsi_task(conn->task, DID_IMM_RETRY); in iscsi_data_xmit()
1542 rc = iscsi_prep_scsi_cmd_pdu(conn->task); in iscsi_data_xmit()
1545 list_add_tail(&conn->task->running, in iscsi_data_xmit()
1546 &conn->cmdqueue); in iscsi_data_xmit()
1547 conn->task = NULL; in iscsi_data_xmit()
1550 fail_scsi_task(conn->task, DID_ABORT); in iscsi_data_xmit()
1553 rc = iscsi_xmit_task(conn); in iscsi_data_xmit()
1561 if (!list_empty(&conn->mgmtqueue)) in iscsi_data_xmit()
1565 while (!list_empty(&conn->requeue)) { in iscsi_data_xmit()
1569 if (conn->session->state == ISCSI_STATE_LOGGING_OUT) in iscsi_data_xmit()
1572 task = list_entry(conn->requeue.next, struct iscsi_task, in iscsi_data_xmit()
1577 conn->task = task; in iscsi_data_xmit()
1578 list_del_init(&conn->task->running); in iscsi_data_xmit()
1579 conn->task->state = ISCSI_TASK_RUNNING; in iscsi_data_xmit()
1580 rc = iscsi_xmit_task(conn); in iscsi_data_xmit()
1583 if (!list_empty(&conn->mgmtqueue)) in iscsi_data_xmit()
1586 spin_unlock_bh(&conn->session->frwd_lock); in iscsi_data_xmit()
1590 spin_unlock_bh(&conn->session->frwd_lock); in iscsi_data_xmit()
1596 struct iscsi_conn *conn = in iscsi_xmitworker() local
1603 rc = iscsi_data_xmit(conn); in iscsi_xmitworker()
1607 static inline struct iscsi_task *iscsi_alloc_task(struct iscsi_conn *conn, in iscsi_alloc_task() argument
1612 if (!kfifo_out(&conn->session->cmdpool.queue, in iscsi_alloc_task()
1616 sc->SCp.phase = conn->session->age; in iscsi_alloc_task()
1621 task->conn = conn; in iscsi_alloc_task()
1650 struct iscsi_conn *conn; in iscsi_queuecommand() local
1700 conn = session->leadconn; in iscsi_queuecommand()
1701 if (!conn) { in iscsi_queuecommand()
1707 if (test_bit(ISCSI_SUSPEND_BIT, &conn->suspend_tx)) { in iscsi_queuecommand()
1713 if (iscsi_check_cmdsn_window_closed(conn)) { in iscsi_queuecommand()
1718 task = iscsi_alloc_task(conn, sc); in iscsi_queuecommand()
1741 list_add_tail(&task->running, &conn->cmdqueue); in iscsi_queuecommand()
1742 iscsi_conn_queue_work(conn); in iscsi_queuecommand()
1786 struct iscsi_conn *conn = (struct iscsi_conn *)data; in iscsi_tmf_timedout() local
1787 struct iscsi_session *session = conn->session; in iscsi_tmf_timedout()
1790 if (conn->tmf_state == TMF_QUEUED) { in iscsi_tmf_timedout()
1791 conn->tmf_state = TMF_TIMEDOUT; in iscsi_tmf_timedout()
1794 wake_up(&conn->ehwait); in iscsi_tmf_timedout()
1799 static int iscsi_exec_task_mgmt_fn(struct iscsi_conn *conn, in iscsi_exec_task_mgmt_fn() argument
1803 struct iscsi_session *session = conn->session; in iscsi_exec_task_mgmt_fn()
1806 task = __iscsi_conn_send_pdu(conn, (struct iscsi_hdr *)hdr, in iscsi_exec_task_mgmt_fn()
1810 iscsi_conn_printk(KERN_ERR, conn, "Could not send TMF.\n"); in iscsi_exec_task_mgmt_fn()
1811 iscsi_conn_failure(conn, ISCSI_ERR_CONN_FAILED); in iscsi_exec_task_mgmt_fn()
1815 conn->tmfcmd_pdus_cnt++; in iscsi_exec_task_mgmt_fn()
1816 conn->tmf_timer.expires = timeout * HZ + jiffies; in iscsi_exec_task_mgmt_fn()
1817 conn->tmf_timer.function = iscsi_tmf_timedout; in iscsi_exec_task_mgmt_fn()
1818 conn->tmf_timer.data = (unsigned long)conn; in iscsi_exec_task_mgmt_fn()
1819 add_timer(&conn->tmf_timer); in iscsi_exec_task_mgmt_fn()
1833 wait_event_interruptible(conn->ehwait, age != session->age || in iscsi_exec_task_mgmt_fn()
1835 conn->tmf_state != TMF_QUEUED); in iscsi_exec_task_mgmt_fn()
1838 del_timer_sync(&conn->tmf_timer); in iscsi_exec_task_mgmt_fn()
1853 static void fail_scsi_tasks(struct iscsi_conn *conn, u64 lun, int error) in fail_scsi_tasks() argument
1858 for (i = 0; i < conn->session->cmds_max; i++) { in fail_scsi_tasks()
1859 task = conn->session->cmds[i]; in fail_scsi_tasks()
1866 ISCSI_DBG_SESSION(conn->session, in fail_scsi_tasks()
1884 void iscsi_suspend_queue(struct iscsi_conn *conn) in iscsi_suspend_queue() argument
1886 spin_lock_bh(&conn->session->frwd_lock); in iscsi_suspend_queue()
1887 set_bit(ISCSI_SUSPEND_BIT, &conn->suspend_tx); in iscsi_suspend_queue()
1888 spin_unlock_bh(&conn->session->frwd_lock); in iscsi_suspend_queue()
1900 void iscsi_suspend_tx(struct iscsi_conn *conn) in iscsi_suspend_tx() argument
1902 struct Scsi_Host *shost = conn->session->host; in iscsi_suspend_tx()
1905 set_bit(ISCSI_SUSPEND_BIT, &conn->suspend_tx); in iscsi_suspend_tx()
1911 static void iscsi_start_tx(struct iscsi_conn *conn) in iscsi_start_tx() argument
1913 clear_bit(ISCSI_SUSPEND_BIT, &conn->suspend_tx); in iscsi_start_tx()
1914 iscsi_conn_queue_work(conn); in iscsi_start_tx()
1923 static int iscsi_has_ping_timed_out(struct iscsi_conn *conn) in iscsi_has_ping_timed_out() argument
1925 if (conn->ping_task && in iscsi_has_ping_timed_out()
1926 time_before_eq(conn->last_recv + (conn->recv_timeout * HZ) + in iscsi_has_ping_timed_out()
1927 (conn->ping_timeout * HZ), jiffies)) in iscsi_has_ping_timed_out()
1939 struct iscsi_conn *conn; in iscsi_eh_cmd_timed_out() local
1967 conn = session->leadconn; in iscsi_eh_cmd_timed_out()
1968 if (!conn) { in iscsi_eh_cmd_timed_out()
1991 if (!conn->recv_timeout && !conn->ping_timeout) in iscsi_eh_cmd_timed_out()
1997 if (iscsi_has_ping_timed_out(conn)) { in iscsi_eh_cmd_timed_out()
2002 for (i = 0; i < conn->session->cmds_max; i++) { in iscsi_eh_cmd_timed_out()
2003 running_task = conn->session->cmds[i]; in iscsi_eh_cmd_timed_out()
2047 if (conn->ping_task) { in iscsi_eh_cmd_timed_out()
2054 iscsi_send_nopout(conn, NULL); in iscsi_eh_cmd_timed_out()
2069 struct iscsi_conn *conn = (struct iscsi_conn *)data; in iscsi_check_transport_timeouts() local
2070 struct iscsi_session *session = conn->session; in iscsi_check_transport_timeouts()
2077 recv_timeout = conn->recv_timeout; in iscsi_check_transport_timeouts()
2082 last_recv = conn->last_recv; in iscsi_check_transport_timeouts()
2084 if (iscsi_has_ping_timed_out(conn)) { in iscsi_check_transport_timeouts()
2085 iscsi_conn_printk(KERN_ERR, conn, "ping timeout of %d secs " in iscsi_check_transport_timeouts()
2088 conn->ping_timeout, conn->recv_timeout, in iscsi_check_transport_timeouts()
2089 last_recv, conn->last_ping, jiffies); in iscsi_check_transport_timeouts()
2091 iscsi_conn_failure(conn, ISCSI_ERR_NOP_TIMEDOUT); in iscsi_check_transport_timeouts()
2097 ISCSI_DBG_CONN(conn, "Sending nopout as ping\n"); in iscsi_check_transport_timeouts()
2098 if (iscsi_send_nopout(conn, NULL)) in iscsi_check_transport_timeouts()
2101 next_timeout = conn->last_ping + (conn->ping_timeout * HZ); in iscsi_check_transport_timeouts()
2105 ISCSI_DBG_CONN(conn, "Setting next tmo %lu\n", next_timeout); in iscsi_check_transport_timeouts()
2106 mod_timer(&conn->transport_timer, next_timeout); in iscsi_check_transport_timeouts()
2127 struct iscsi_conn *conn; in iscsi_eh_abort() local
2164 conn = session->leadconn; in iscsi_eh_abort()
2165 conn->eh_abort_cnt++; in iscsi_eh_abort()
2184 if (conn->tmf_state != TMF_INITIAL) in iscsi_eh_abort()
2186 conn->tmf_state = TMF_QUEUED; in iscsi_eh_abort()
2188 hdr = &conn->tmhdr; in iscsi_eh_abort()
2191 if (iscsi_exec_task_mgmt_fn(conn, hdr, age, session->abort_timeout)) { in iscsi_eh_abort()
2196 switch (conn->tmf_state) { in iscsi_eh_abort()
2203 iscsi_suspend_tx(conn); in iscsi_eh_abort()
2211 conn->tmf_state = TMF_INITIAL; in iscsi_eh_abort()
2214 iscsi_start_tx(conn); in iscsi_eh_abort()
2218 iscsi_conn_failure(conn, ISCSI_ERR_SCSI_EH_SESSION_RST); in iscsi_eh_abort()
2222 conn->tmf_state = TMF_INITIAL; in iscsi_eh_abort()
2231 conn->tmf_state = TMF_INITIAL; in iscsi_eh_abort()
2267 struct iscsi_conn *conn; in iscsi_eh_device_reset() local
2285 conn = session->leadconn; in iscsi_eh_device_reset()
2288 if (conn->tmf_state != TMF_INITIAL) in iscsi_eh_device_reset()
2290 conn->tmf_state = TMF_QUEUED; in iscsi_eh_device_reset()
2292 hdr = &conn->tmhdr; in iscsi_eh_device_reset()
2295 if (iscsi_exec_task_mgmt_fn(conn, hdr, session->age, in iscsi_eh_device_reset()
2301 switch (conn->tmf_state) { in iscsi_eh_device_reset()
2306 iscsi_conn_failure(conn, ISCSI_ERR_SCSI_EH_SESSION_RST); in iscsi_eh_device_reset()
2309 conn->tmf_state = TMF_INITIAL; in iscsi_eh_device_reset()
2316 iscsi_suspend_tx(conn); in iscsi_eh_device_reset()
2320 fail_scsi_tasks(conn, sc->device->lun, DID_ERROR); in iscsi_eh_device_reset()
2321 conn->tmf_state = TMF_INITIAL; in iscsi_eh_device_reset()
2324 iscsi_start_tx(conn); in iscsi_eh_device_reset()
2362 struct iscsi_conn *conn; in iscsi_eh_session_reset() local
2366 conn = session->leadconn; in iscsi_eh_session_reset()
2375 conn->persistent_address, session->age); in iscsi_eh_session_reset()
2387 iscsi_conn_failure(conn, ISCSI_ERR_SCSI_EH_SESSION_RST); in iscsi_eh_session_reset()
2390 wait_event_interruptible(conn->ehwait, in iscsi_eh_session_reset()
2402 session->targetname, conn->persistent_address); in iscsi_eh_session_reset()
2430 struct iscsi_conn *conn; in iscsi_eh_target_reset() local
2448 conn = session->leadconn; in iscsi_eh_target_reset()
2451 if (conn->tmf_state != TMF_INITIAL) in iscsi_eh_target_reset()
2453 conn->tmf_state = TMF_QUEUED; in iscsi_eh_target_reset()
2455 hdr = &conn->tmhdr; in iscsi_eh_target_reset()
2458 if (iscsi_exec_task_mgmt_fn(conn, hdr, session->age, in iscsi_eh_target_reset()
2464 switch (conn->tmf_state) { in iscsi_eh_target_reset()
2469 iscsi_conn_failure(conn, ISCSI_ERR_SCSI_EH_SESSION_RST); in iscsi_eh_target_reset()
2472 conn->tmf_state = TMF_INITIAL; in iscsi_eh_target_reset()
2479 iscsi_suspend_tx(conn); in iscsi_eh_target_reset()
2483 fail_scsi_tasks(conn, -1, DID_ERROR); in iscsi_eh_target_reset()
2484 conn->tmf_state = TMF_INITIAL; in iscsi_eh_target_reset()
2487 iscsi_start_tx(conn); in iscsi_eh_target_reset()
2877 struct iscsi_conn *conn; in iscsi_conn_setup() local
2881 cls_conn = iscsi_create_conn(cls_session, sizeof(*conn) + dd_size, in iscsi_conn_setup()
2885 conn = cls_conn->dd_data; in iscsi_conn_setup()
2886 memset(conn, 0, sizeof(*conn) + dd_size); in iscsi_conn_setup()
2888 conn->dd_data = cls_conn->dd_data + sizeof(*conn); in iscsi_conn_setup()
2889 conn->session = session; in iscsi_conn_setup()
2890 conn->cls_conn = cls_conn; in iscsi_conn_setup()
2891 conn->c_stage = ISCSI_CONN_INITIAL_STAGE; in iscsi_conn_setup()
2892 conn->id = conn_idx; in iscsi_conn_setup()
2893 conn->exp_statsn = 0; in iscsi_conn_setup()
2894 conn->tmf_state = TMF_INITIAL; in iscsi_conn_setup()
2896 init_timer(&conn->transport_timer); in iscsi_conn_setup()
2897 conn->transport_timer.data = (unsigned long)conn; in iscsi_conn_setup()
2898 conn->transport_timer.function = iscsi_check_transport_timeouts; in iscsi_conn_setup()
2900 INIT_LIST_HEAD(&conn->mgmtqueue); in iscsi_conn_setup()
2901 INIT_LIST_HEAD(&conn->cmdqueue); in iscsi_conn_setup()
2902 INIT_LIST_HEAD(&conn->requeue); in iscsi_conn_setup()
2903 INIT_WORK(&conn->xmitwork, iscsi_xmitworker); in iscsi_conn_setup()
2908 (void*)&conn->login_task, in iscsi_conn_setup()
2919 conn->login_task->data = conn->data = data; in iscsi_conn_setup()
2921 init_timer(&conn->tmf_timer); in iscsi_conn_setup()
2922 init_waitqueue_head(&conn->ehwait); in iscsi_conn_setup()
2927 kfifo_in(&session->cmdpool.queue, (void*)&conn->login_task, in iscsi_conn_setup()
2944 struct iscsi_conn *conn = cls_conn->dd_data; in iscsi_conn_teardown() local
2945 struct iscsi_session *session = conn->session; in iscsi_conn_teardown()
2947 del_timer_sync(&conn->transport_timer); in iscsi_conn_teardown()
2951 conn->c_stage = ISCSI_CONN_CLEANUP_WAIT; in iscsi_conn_teardown()
2952 if (session->leadconn == conn) { in iscsi_conn_teardown()
2957 wake_up(&conn->ehwait); in iscsi_conn_teardown()
2962 iscsi_suspend_tx(conn); in iscsi_conn_teardown()
2965 free_pages((unsigned long) conn->data, in iscsi_conn_teardown()
2967 kfree(conn->persistent_address); in iscsi_conn_teardown()
2968 kfree(conn->local_ipaddr); in iscsi_conn_teardown()
2971 kfifo_in(&session->cmdpool.queue, (void*)&conn->login_task, in iscsi_conn_teardown()
2974 if (session->leadconn == conn) in iscsi_conn_teardown()
2985 struct iscsi_conn *conn = cls_conn->dd_data; in iscsi_conn_start() local
2986 struct iscsi_session *session = conn->session; in iscsi_conn_start()
2989 iscsi_conn_printk(KERN_ERR, conn, in iscsi_conn_start()
2996 iscsi_conn_printk(KERN_INFO, conn, "invalid burst lengths: " in iscsi_conn_start()
3002 if (conn->ping_timeout && !conn->recv_timeout) { in iscsi_conn_start()
3003 iscsi_conn_printk(KERN_ERR, conn, "invalid recv timeout of " in iscsi_conn_start()
3005 conn->recv_timeout = 5; in iscsi_conn_start()
3008 if (conn->recv_timeout && !conn->ping_timeout) { in iscsi_conn_start()
3009 iscsi_conn_printk(KERN_ERR, conn, "invalid ping timeout of " in iscsi_conn_start()
3011 conn->ping_timeout = 5; in iscsi_conn_start()
3015 conn->c_stage = ISCSI_CONN_STARTED; in iscsi_conn_start()
3019 conn->last_recv = jiffies; in iscsi_conn_start()
3020 conn->last_ping = jiffies; in iscsi_conn_start()
3021 if (conn->recv_timeout && conn->ping_timeout) in iscsi_conn_start()
3022 mod_timer(&conn->transport_timer, in iscsi_conn_start()
3023 jiffies + (conn->recv_timeout * HZ)); in iscsi_conn_start()
3025 switch(conn->stop_stage) { in iscsi_conn_start()
3031 conn->stop_stage = 0; in iscsi_conn_start()
3032 conn->tmf_state = TMF_INITIAL; in iscsi_conn_start()
3038 conn->stop_stage = 0; in iscsi_conn_start()
3046 wake_up(&conn->ehwait); in iscsi_conn_start()
3052 fail_mgmt_tasks(struct iscsi_session *session, struct iscsi_conn *conn) in fail_mgmt_tasks() argument
3057 for (i = 0; i < conn->session->cmds_max; i++) { in fail_mgmt_tasks()
3058 task = conn->session->cmds[i]; in fail_mgmt_tasks()
3065 ISCSI_DBG_SESSION(conn->session, in fail_mgmt_tasks()
3077 struct iscsi_conn *conn, int flag) in iscsi_start_session_recovery() argument
3083 if (conn->stop_stage == STOP_CONN_TERM) { in iscsi_start_session_recovery()
3096 else if (conn->stop_stage != STOP_CONN_RECOVER) in iscsi_start_session_recovery()
3099 old_stop_stage = conn->stop_stage; in iscsi_start_session_recovery()
3100 conn->stop_stage = flag; in iscsi_start_session_recovery()
3103 del_timer_sync(&conn->transport_timer); in iscsi_start_session_recovery()
3104 iscsi_suspend_tx(conn); in iscsi_start_session_recovery()
3107 conn->c_stage = ISCSI_CONN_STOPPED; in iscsi_start_session_recovery()
3117 conn->hdrdgst_en = 0; in iscsi_start_session_recovery()
3118 conn->datadgst_en = 0; in iscsi_start_session_recovery()
3130 fail_scsi_tasks(conn, -1, DID_TRANSPORT_DISRUPTED); in iscsi_start_session_recovery()
3131 fail_mgmt_tasks(session, conn); in iscsi_start_session_recovery()
3132 memset(&conn->tmhdr, 0, sizeof(conn->tmhdr)); in iscsi_start_session_recovery()
3139 struct iscsi_conn *conn = cls_conn->dd_data; in iscsi_conn_stop() local
3140 struct iscsi_session *session = conn->session; in iscsi_conn_stop()
3145 iscsi_start_session_recovery(session, conn, flag); in iscsi_conn_stop()
3148 iscsi_conn_printk(KERN_ERR, conn, in iscsi_conn_stop()
3158 struct iscsi_conn *conn = cls_conn->dd_data; in iscsi_conn_bind() local
3162 session->leadconn = conn; in iscsi_conn_bind()
3168 clear_bit(ISCSI_SUSPEND_BIT, &conn->suspend_rx); in iscsi_conn_bind()
3169 clear_bit(ISCSI_SUSPEND_BIT, &conn->suspend_tx); in iscsi_conn_bind()
3196 struct iscsi_conn *conn = cls_conn->dd_data; in iscsi_set_param() local
3197 struct iscsi_session *session = conn->session; in iscsi_set_param()
3214 sscanf(buf, "%d", &conn->ping_timeout); in iscsi_set_param()
3217 sscanf(buf, "%d", &conn->recv_timeout); in iscsi_set_param()
3220 sscanf(buf, "%d", &conn->max_recv_dlength); in iscsi_set_param()
3223 sscanf(buf, "%d", &conn->max_xmit_dlength); in iscsi_set_param()
3226 sscanf(buf, "%d", &conn->hdrdgst_en); in iscsi_set_param()
3229 sscanf(buf, "%d", &conn->datadgst_en); in iscsi_set_param()
3256 sscanf(buf, "%u", &conn->exp_statsn); in iscsi_set_param()
3274 sscanf(buf, "%d", &conn->persistent_port); in iscsi_set_param()
3277 return iscsi_switch_str_param(&conn->persistent_address, buf); in iscsi_set_param()
3298 return iscsi_switch_str_param(&conn->local_ipaddr, buf); in iscsi_set_param()
3488 struct iscsi_conn *conn = cls_conn->dd_data; in iscsi_conn_get_param() local
3493 len = sprintf(buf, "%u\n", conn->ping_timeout); in iscsi_conn_get_param()
3496 len = sprintf(buf, "%u\n", conn->recv_timeout); in iscsi_conn_get_param()
3499 len = sprintf(buf, "%u\n", conn->max_recv_dlength); in iscsi_conn_get_param()
3502 len = sprintf(buf, "%u\n", conn->max_xmit_dlength); in iscsi_conn_get_param()
3505 len = sprintf(buf, "%d\n", conn->hdrdgst_en); in iscsi_conn_get_param()
3508 len = sprintf(buf, "%d\n", conn->datadgst_en); in iscsi_conn_get_param()
3511 len = sprintf(buf, "%d\n", conn->ifmarker_en); in iscsi_conn_get_param()
3514 len = sprintf(buf, "%d\n", conn->ofmarker_en); in iscsi_conn_get_param()
3517 len = sprintf(buf, "%u\n", conn->exp_statsn); in iscsi_conn_get_param()
3520 len = sprintf(buf, "%d\n", conn->persistent_port); in iscsi_conn_get_param()
3523 len = sprintf(buf, "%s\n", conn->persistent_address); in iscsi_conn_get_param()
3526 len = sprintf(buf, "%u\n", conn->statsn); in iscsi_conn_get_param()
3529 len = sprintf(buf, "%u\n", conn->max_segment_size); in iscsi_conn_get_param()
3532 len = sprintf(buf, "%u\n", conn->keepalive_tmo); in iscsi_conn_get_param()
3535 len = sprintf(buf, "%u\n", conn->local_port); in iscsi_conn_get_param()
3538 len = sprintf(buf, "%u\n", conn->tcp_timestamp_stat); in iscsi_conn_get_param()
3541 len = sprintf(buf, "%u\n", conn->tcp_nagle_disable); in iscsi_conn_get_param()
3544 len = sprintf(buf, "%u\n", conn->tcp_wsf_disable); in iscsi_conn_get_param()
3547 len = sprintf(buf, "%u\n", conn->tcp_timer_scale); in iscsi_conn_get_param()
3550 len = sprintf(buf, "%u\n", conn->tcp_timestamp_en); in iscsi_conn_get_param()
3553 len = sprintf(buf, "%u\n", conn->fragment_disable); in iscsi_conn_get_param()
3556 len = sprintf(buf, "%u\n", conn->ipv4_tos); in iscsi_conn_get_param()
3559 len = sprintf(buf, "%u\n", conn->ipv6_traffic_class); in iscsi_conn_get_param()
3562 len = sprintf(buf, "%u\n", conn->ipv6_flow_label); in iscsi_conn_get_param()
3565 len = sprintf(buf, "%u\n", conn->is_fw_assigned_ipv6); in iscsi_conn_get_param()
3568 len = sprintf(buf, "%u\n", conn->tcp_xmit_wsf); in iscsi_conn_get_param()
3571 len = sprintf(buf, "%u\n", conn->tcp_recv_wsf); in iscsi_conn_get_param()
3574 len = sprintf(buf, "%s\n", conn->local_ipaddr); in iscsi_conn_get_param()