Lines Matching defs:conn
50 isert_put_response(struct iscsit_conn *conn, struct iscsit_cmd *cmd);
76 isert_prot_cmd(struct isert_conn *conn, struct se_cmd *cmd)
78 return (conn->pi_support &&
87 isert_err("%s (%d): conn %p\n",
191 isert_err("conn %p failed to allocate rx descriptors\n", isert_conn);
453 isert_set_nego_params(isert_conn, &event->param.conn);
492 isert_dbg("conn %p\n", isert_conn);
521 isert_info("conn %p\n", isert_conn);
542 isert_info("conn %p final kref %s/%d\n", isert_conn, current->comm,
592 isert_info("Terminating conn %p state %d\n",
645 iscsit_cause_connection_reinstatement(isert_conn->conn, 0);
648 isert_warn("conn %p terminating in state %d\n",
917 isert_put_login_tx(struct iscsit_conn *conn, struct iscsi_login *login,
920 struct isert_conn *isert_conn = conn->context;
984 struct iscsit_conn *conn = isert_conn->conn;
985 struct iscsi_login *login = conn->conn_login;
988 isert_info("conn %p\n", isert_conn);
1024 queue_delayed_work(isert_login_wq, &conn->login_work, 0);
1028 *isert_allocate_cmd(struct iscsit_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 iscsit_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 iscsit_conn *conn = isert_conn->conn;
1127 rc = iscsit_check_dataout_hdr(conn, buf, &cmd);
1181 struct iscsit_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 iscsit_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 iscsit_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 iscsit_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->iscsit_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 iscsit_conn *conn, struct iscsit_cmd *cmd)
1765 struct isert_conn *isert_conn = conn->context;
1771 iscsit_build_rsp_pdu(cmd, conn, true, hdr);
1813 isert_aborted_task(struct iscsit_conn *conn, struct iscsit_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 iscsit_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 iscsit_cmd *cmd, struct iscsit_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 iscsit_cmd *cmd, struct iscsit_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 iscsit_cmd *cmd, struct iscsit_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 iscsit_cmd *cmd, struct iscsit_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 iscsit_cmd *cmd, struct iscsit_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 iscsit_conn *conn, struct iscsit_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 iscsit_conn *conn, struct iscsit_cmd *cmd, bool recovery)
2145 ret = isert_rdma_rw_ctx_post(isert_cmd, conn->context,
2154 isert_immediate_queue(struct iscsit_conn *conn, struct iscsit_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 iscsit_conn *conn, struct iscsit_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);
2339 isert_get_login_rx(struct iscsit_conn *conn, struct iscsi_login *login)
2341 struct isert_conn *isert_conn = conn->context;
2344 isert_info("before login_req comp conn: %p\n", isert_conn);
2355 * kick queue_delayed_work(isert_login_wq, &conn->login_work) as
2364 isert_info("before login_comp conn: %p\n", conn);
2375 isert_set_conn_info(struct iscsi_np *np, struct iscsit_conn *conn,
2381 conn->login_family = np->np_sockaddr.ss_family;
2383 conn->login_sockaddr = cm_route->addr.dst_addr;
2384 conn->local_sockaddr = cm_route->addr.src_addr;
2388 isert_accept_np(struct iscsi_np *np, struct iscsit_conn *conn)
2422 conn->context = isert_conn;
2423 isert_conn->conn = conn;
2426 isert_set_conn_info(np, conn, isert_conn);
2489 isert_info("Starting release conn %p\n", isert_conn);
2495 isert_info("Destroying conn %p\n", isert_conn);
2502 struct iscsit_conn *conn = isert_conn->conn;
2504 isert_info("conn %p\n", isert_conn);
2507 isert_info("conn %p wait for conn_logout_comp\n", isert_conn);
2508 wait_for_completion_timeout(&conn->conn_logout_comp,
2514 isert_wait4cmds(struct iscsit_conn *conn)
2516 isert_info("iscsit_conn %p\n", conn);
2518 if (conn->sess) {
2519 target_stop_cmd_counter(conn->cmd_cnt);
2520 target_wait_for_cmds(conn->cmd_cnt);
2527 * @conn: iscsi connection
2534 isert_put_unsol_pending_cmds(struct iscsit_conn *conn)
2539 spin_lock_bh(&conn->cmd_lock);
2540 list_for_each_entry_safe(cmd, tmp, &conn->conn_cmd_list, i_conn_node) {
2542 (cmd->write_data_done < conn->sess->sess_ops->FirstBurstLength) &&
2546 spin_unlock_bh(&conn->cmd_lock);
2553 isert_info("conn %p dropping cmd %p\n", conn, cmd);
2559 static void isert_wait_conn(struct iscsit_conn *conn)
2561 struct isert_conn *isert_conn = conn->context;
2563 isert_info("Starting conn %p\n", isert_conn);
2570 isert_put_unsol_pending_cmds(conn);
2571 isert_wait4cmds(conn);
2577 static void isert_free_conn(struct iscsit_conn *conn)
2579 struct isert_conn *isert_conn = conn->context;
2585 static void isert_get_rx_pdu(struct iscsit_conn *conn)