Lines Matching defs:conn
49 isert_put_response(struct iscsi_conn *conn, struct iscsi_cmd *cmd);
76 isert_prot_cmd(struct isert_conn *conn, struct se_cmd *cmd)
78 return (conn->pi_support &&
88 isert_err("%s (%d): conn %p\n",
192 isert_err("conn %p failed to allocate rx descriptors\n", isert_conn);
452 isert_set_nego_params(isert_conn, &event->param.conn);
491 isert_dbg("conn %p\n", isert_conn);
520 isert_info("conn %p\n", isert_conn);
541 isert_info("conn %p final kref %s/%d\n", isert_conn, current->comm,
591 isert_info("Terminating conn %p state %d\n",
644 iscsit_cause_connection_reinstatement(isert_conn->conn, 0);
647 isert_warn("conn %p terminating in state %d\n",
916 isert_put_login_tx(struct iscsi_conn *conn, struct iscsi_login *login,
919 struct isert_conn *isert_conn = conn->context;
983 struct iscsi_conn *conn = isert_conn->conn;
984 struct iscsi_login *login = conn->conn_login;
987 isert_info("conn %p\n", isert_conn);
1024 schedule_delayed_work(&conn->login_work, 0);
1028 *isert_allocate_cmd(struct iscsi_conn *conn, struct iser_rx_desc *rx_desc)
1030 struct isert_conn *isert_conn = conn->context;
1034 cmd = iscsit_allocate_cmd(conn, TASK_INTERRUPTIBLE);
1040 isert_cmd->conn = isert_conn;
1052 struct iscsi_conn *conn = isert_conn->conn;
1058 rc = iscsit_setup_scsi_cmd(conn, cmd, buf);
1069 rc = iscsit_process_scsi_cmd(conn, cmd, hdr);
1106 rc = iscsit_sequence_cmd(conn, cmd, buf, hdr->cmdsn);
1121 struct iscsi_conn *conn = isert_conn->conn;
1127 rc = iscsit_check_dataout_hdr(conn, buf, &cmd);
1181 struct iscsi_conn *conn = isert_conn->conn;
1185 rc = iscsit_setup_nop_out(conn, cmd, hdr);
1192 return iscsit_process_nop_out(conn, cmd, hdr);
1200 struct iscsi_conn *conn = isert_conn->conn;
1205 rc = iscsit_setup_text_cmd(conn, cmd, hdr);
1218 return iscsit_process_text_cmd(conn, cmd, hdr);
1227 struct iscsi_conn *conn = isert_conn->conn;
1233 if (conn->sess->sess_ops->SessionType &&
1242 cmd = isert_allocate_cmd(conn, rx_desc);
1257 cmd = isert_allocate_cmd(conn, rx_desc);
1270 cmd = isert_allocate_cmd(conn, rx_desc);
1274 ret = iscsit_handle_task_mgt_cmd(conn, cmd,
1278 cmd = isert_allocate_cmd(conn, rx_desc);
1282 ret = iscsit_handle_logout_cmd(conn, cmd, (unsigned char *)hdr);
1286 cmd = iscsit_find_cmd_from_itt(conn, hdr->itt);
1288 cmd = isert_allocate_cmd(conn, rx_desc);
1332 iscsit_cause_connection_reinstatement(isert_conn->conn, 0);
1393 if (isert_conn->conn) {
1394 struct iscsi_login *login = isert_conn->conn->conn_login;
1409 isert_rdma_rw_ctx_destroy(struct isert_cmd *cmd, struct isert_conn *conn)
1417 if (isert_prot_cmd(conn, se_cmd)) {
1418 rdma_rw_ctx_destroy_signature(&cmd->rw, conn->qp,
1419 conn->cm_id->port_num, se_cmd->t_data_sg,
1423 rdma_rw_ctx_destroy(&cmd->rw, conn->qp, conn->cm_id->port_num,
1434 struct isert_conn *isert_conn = isert_cmd->conn;
1435 struct iscsi_conn *conn = isert_conn->conn;
1442 spin_lock_bh(&conn->cmd_lock);
1445 spin_unlock_bh(&conn->cmd_lock);
1467 spin_lock_bh(&conn->cmd_lock);
1470 spin_unlock_bh(&conn->cmd_lock);
1482 spin_lock_bh(&conn->cmd_lock);
1485 spin_unlock_bh(&conn->cmd_lock);
1588 iscsit_cause_connection_reinstatement(isert_conn->conn, 0);
1611 ret = isert_put_response(isert_conn->conn, isert_cmd->iscsi_cmd);
1631 iscsit_cause_connection_reinstatement(isert_conn->conn, 0);
1667 struct isert_conn *isert_conn = isert_cmd->conn;
1675 iscsit_tmr_post_handler(cmd, cmd->conn);
1684 iscsit_logout_post_handler(cmd, cmd->conn);
1703 iscsit_cause_connection_reinstatement(isert_conn->conn, 0);
1720 iscsit_cause_connection_reinstatement(isert_conn->conn, 0);
1762 isert_put_response(struct iscsi_conn *conn, struct iscsi_cmd *cmd)
1765 struct isert_conn *isert_conn = conn->context;
1771 iscsit_build_rsp_pdu(cmd, conn, true, hdr);
1813 isert_aborted_task(struct iscsi_conn *conn, struct iscsi_cmd *cmd)
1816 struct isert_conn *isert_conn = conn->context;
1818 spin_lock_bh(&conn->cmd_lock);
1821 spin_unlock_bh(&conn->cmd_lock);
1829 isert_get_sup_prot_ops(struct iscsi_conn *conn)
1831 struct isert_conn *isert_conn = conn->context;
1834 if (conn->tpg->tpg_attrib.t10_pi) {
1836 isert_info("conn %p PI offload enabled\n", isert_conn);
1842 isert_info("conn %p PI offload disabled\n", isert_conn);
1849 isert_put_nopin(struct iscsi_cmd *cmd, struct iscsi_conn *conn,
1853 struct isert_conn *isert_conn = conn->context;
1857 iscsit_build_nopin_rsp(cmd, conn, (struct iscsi_nopin *)
1863 isert_dbg("conn %p Posting NOPIN Response\n", isert_conn);
1869 isert_put_logout_rsp(struct iscsi_cmd *cmd, struct iscsi_conn *conn)
1872 struct isert_conn *isert_conn = conn->context;
1876 iscsit_build_logout_rsp(cmd, conn, (struct iscsi_logout_rsp *)
1881 isert_dbg("conn %p Posting Logout Response\n", isert_conn);
1887 isert_put_tm_rsp(struct iscsi_cmd *cmd, struct iscsi_conn *conn)
1890 struct isert_conn *isert_conn = conn->context;
1894 iscsit_build_task_mgt_rsp(cmd, conn, (struct iscsi_tm_rsp *)
1899 isert_dbg("conn %p Posting Task Management Response\n", isert_conn);
1905 isert_put_reject(struct iscsi_cmd *cmd, struct iscsi_conn *conn)
1908 struct isert_conn *isert_conn = conn->context;
1917 iscsit_build_reject(cmd, conn, hdr);
1934 isert_dbg("conn %p Posting Reject\n", isert_conn);
1940 isert_put_text_rsp(struct iscsi_cmd *cmd, struct iscsi_conn *conn)
1943 struct isert_conn *isert_conn = conn->context;
1951 rc = iscsit_build_text_rsp(cmd, conn, hdr, ISCSI_INFINIBAND);
1977 isert_dbg("conn %p Text Response\n", isert_conn);
2039 isert_rdma_rw_ctx_post(struct isert_cmd *cmd, struct isert_conn *conn,
2044 u8 port_num = conn->cm_id->port_num;
2062 if (isert_prot_cmd(conn, se_cmd)) {
2070 ret = rdma_rw_ctx_signature_init(&cmd->rw, conn->qp, port_num,
2075 ret = rdma_rw_ctx_init(&cmd->rw, conn->qp, port_num,
2088 ret = rdma_rw_ctx_post(&cmd->rw, conn->qp, port_num, cqe, chain_wr);
2095 isert_put_datain(struct iscsi_conn *conn, struct iscsi_cmd *cmd)
2099 struct isert_conn *isert_conn = conn->context;
2116 iscsit_build_rsp_pdu(cmd, conn, true, (struct iscsi_scsi_rsp *)
2136 isert_get_dataout(struct iscsi_conn *conn, struct iscsi_cmd *cmd, bool recovery)
2145 ret = isert_rdma_rw_ctx_post(isert_cmd, conn->context,
2154 isert_immediate_queue(struct iscsi_conn *conn, struct iscsi_cmd *cmd, int state)
2161 spin_lock_bh(&conn->cmd_lock);
2163 spin_unlock_bh(&conn->cmd_lock);
2167 ret = isert_put_nopin(cmd, conn, false);
2179 isert_response_queue(struct iscsi_conn *conn, struct iscsi_cmd *cmd, int state)
2181 struct isert_conn *isert_conn = conn->context;
2186 ret = isert_put_logout_rsp(cmd, conn);
2191 ret = isert_put_nopin(cmd, conn, true);
2194 ret = isert_put_tm_rsp(cmd, conn);
2197 ret = isert_put_reject(cmd, conn);
2200 ret = isert_put_text_rsp(cmd, conn);
2207 ret = isert_put_response(conn, cmd);
2329 isert_get_login_rx(struct iscsi_conn *conn, struct iscsi_login *login)
2331 struct isert_conn *isert_conn = conn->context;
2334 isert_info("before login_req comp conn: %p\n", isert_conn);
2345 * kick schedule_delayed_work(&conn->login_work) as the packet is
2354 isert_info("before login_comp conn: %p\n", conn);
2365 isert_set_conn_info(struct iscsi_np *np, struct iscsi_conn *conn,
2371 conn->login_family = np->np_sockaddr.ss_family;
2373 conn->login_sockaddr = cm_route->addr.dst_addr;
2374 conn->local_sockaddr = cm_route->addr.src_addr;
2378 isert_accept_np(struct iscsi_np *np, struct iscsi_conn *conn)
2412 conn->context = isert_conn;
2413 isert_conn->conn = conn;
2416 isert_set_conn_info(np, conn, isert_conn);
2479 isert_info("Starting release conn %p\n", isert_conn);
2485 isert_info("Destroying conn %p\n", isert_conn);
2492 struct iscsi_conn *conn = isert_conn->conn;
2494 isert_info("conn %p\n", isert_conn);
2497 isert_info("conn %p wait for conn_logout_comp\n", isert_conn);
2498 wait_for_completion_timeout(&conn->conn_logout_comp,
2504 isert_wait4cmds(struct iscsi_conn *conn)
2506 isert_info("iscsi_conn %p\n", conn);
2508 if (conn->sess) {
2509 target_sess_cmd_list_set_waiting(conn->sess->se_sess);
2510 target_wait_for_sess_cmds(conn->sess->se_sess);
2517 * @conn: iscsi connection
2524 isert_put_unsol_pending_cmds(struct iscsi_conn *conn)
2529 spin_lock_bh(&conn->cmd_lock);
2530 list_for_each_entry_safe(cmd, tmp, &conn->conn_cmd_list, i_conn_node) {
2532 (cmd->write_data_done < conn->sess->sess_ops->FirstBurstLength) &&
2536 spin_unlock_bh(&conn->cmd_lock);
2543 isert_info("conn %p dropping cmd %p\n", conn, cmd);
2549 static void isert_wait_conn(struct iscsi_conn *conn)
2551 struct isert_conn *isert_conn = conn->context;
2553 isert_info("Starting conn %p\n", isert_conn);
2560 isert_put_unsol_pending_cmds(conn);
2561 isert_wait4cmds(conn);
2567 static void isert_free_conn(struct iscsi_conn *conn)
2569 struct isert_conn *isert_conn = conn->context;
2575 static void isert_get_rx_pdu(struct iscsi_conn *conn)