Lines Matching defs:conn
85 struct iscsi_conn *conn = rd_desc->arg.data;
89 ISCSI_SW_TCP_DBG(conn, "in %d bytes\n", skb->len - offset);
93 consumed = iscsi_tcp_recv_skb(conn, skb, offset, 0, &status);
98 ISCSI_SW_TCP_DBG(conn, "read %d bytes status %d\n",
113 struct iscsi_conn *conn = (struct iscsi_conn*)sk->sk_user_data;
117 ISCSI_SW_TCP_DBG(conn, "TCP_CLOSE|TCP_CLOSE_WAIT\n");
118 iscsi_conn_failure(conn, ISCSI_ERR_TCP_CONN_CLOSE);
126 struct iscsi_conn *conn = sk->sk_user_data;
127 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
133 * Use rd_desc to pass 'conn' to iscsi_tcp_recv.
138 rd_desc.arg.data = conn;
155 struct iscsi_conn *conn;
161 conn = (struct iscsi_conn*)sk->sk_user_data;
162 session = conn->session;
166 tcp_conn = conn->dd_data;
181 struct iscsi_conn *conn = (struct iscsi_conn*)sk->sk_user_data;
182 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
186 ISCSI_SW_TCP_DBG(conn, "iscsi_write_space\n");
187 iscsi_conn_queue_work(conn);
190 static void iscsi_sw_tcp_conn_set_callbacks(struct iscsi_conn *conn)
192 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
198 sk->sk_user_data = conn;
209 iscsi_sw_tcp_conn_restore_callbacks(struct iscsi_conn *conn)
211 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
286 static int iscsi_sw_tcp_xmit(struct iscsi_conn *conn)
288 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
297 * We may not have been able to send data because the conn
320 ISCSI_SW_TCP_DBG(conn, "xmit %d bytes\n", consumed);
322 conn->txdata_octets += consumed;
328 ISCSI_SW_TCP_DBG(conn, "Error sending PDU, errno=%d\n", rc);
329 iscsi_conn_failure(conn, rc);
336 static inline int iscsi_sw_tcp_xmit_qlen(struct iscsi_conn *conn)
338 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
347 struct iscsi_conn *conn = task->conn;
350 while (iscsi_sw_tcp_xmit_qlen(conn)) {
351 rc = iscsi_sw_tcp_xmit(conn);
378 static void iscsi_sw_tcp_send_hdr_prep(struct iscsi_conn *conn, void *hdr,
381 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
384 ISCSI_SW_TCP_DBG(conn, "%s\n", conn->hdrdgst_en ?
397 if (conn->hdrdgst_en) {
418 iscsi_sw_tcp_send_data_prep(struct iscsi_conn *conn, struct scatterlist *sg,
422 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
427 ISCSI_SW_TCP_DBG(conn, "offset=%d, datalen=%d %s\n", offset, len,
428 conn->datadgst_en ?
436 if (conn->datadgst_en)
445 iscsi_sw_tcp_send_linear_data_prep(struct iscsi_conn *conn, void *data,
448 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
453 ISCSI_SW_TCP_DBG(conn, "datalen=%zd %s\n", len, conn->datadgst_en ?
461 if (conn->datadgst_en)
471 struct iscsi_conn *conn = task->conn;
474 iscsi_sw_tcp_send_hdr_prep(conn, task->hdr, task->hdr_len);
480 iscsi_sw_tcp_send_linear_data_prep(conn, task->data, count);
484 err = iscsi_sw_tcp_send_data_prep(conn, sdb->table.sgl,
509 struct iscsi_conn *conn;
518 conn = cls_conn->dd_data;
519 tcp_conn = conn->dd_data;
540 iscsi_conn_printk(KERN_ERR, conn,
549 static void iscsi_sw_tcp_release_conn(struct iscsi_conn *conn)
551 struct iscsi_session *session = conn->session;
552 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
560 iscsi_sw_tcp_conn_restore_callbacks(conn);
571 struct iscsi_conn *conn = cls_conn->dd_data;
572 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
575 iscsi_sw_tcp_release_conn(conn);
587 struct iscsi_conn *conn = cls_conn->dd_data;
588 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
597 * Older tools called conn stop before ep_disconnect
601 set_bit(ISCSI_SUSPEND_BIT, &conn->suspend_rx);
608 iscsi_sw_tcp_release_conn(conn);
611 static int iscsi_sw_tcp_get_addr(struct iscsi_conn *conn, struct socket *sock,
634 spin_lock_bh(&conn->session->lock);
637 spin_unlock_bh(&conn->session->lock);
641 spin_lock_bh(&conn->session->lock);
644 spin_unlock_bh(&conn->session->lock);
659 struct iscsi_conn *conn = cls_conn->dd_data;
660 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
669 iscsi_conn_printk(KERN_ERR, conn,
678 err = iscsi_sw_tcp_get_addr(conn, sock, conn->portal_address,
679 &conn->portal_port, kernel_getpeername);
683 err = iscsi_sw_tcp_get_addr(conn, sock, ihost->local_address,
701 iscsi_sw_tcp_conn_set_callbacks(conn);
718 struct iscsi_conn *conn = cls_conn->dd_data;
719 struct iscsi_session *session = conn->session;
720 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
730 tcp_sw_conn->sendpage = conn->datadgst_en ?
754 struct iscsi_conn *conn = cls_conn->dd_data;
759 spin_lock_bh(&conn->session->lock);
760 len = sprintf(buf, "%hu\n", conn->portal_port);
761 spin_unlock_bh(&conn->session->lock);
764 spin_lock_bh(&conn->session->lock);
765 len = sprintf(buf, "%s\n", conn->portal_address);
766 spin_unlock_bh(&conn->session->lock);
779 struct iscsi_conn *conn = cls_conn->dd_data;
780 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
789 stats->custom[2].value = conn->eh_abort_cnt;