drivers/scsi/iscsi_tcp.c

88 	struct iscsi_conn *conn = rd_desc->arg.data;
92 	ISCSI_SW_TCP_DBG(conn, "in %d bytes\n", skb->len - offset);
96 		consumed = iscsi_tcp_recv_skb(conn, skb, offset, 0, &status);
101 	ISCSI_SW_TCP_DBG(conn, "read %d bytes status %d\n",
118 	struct iscsi_conn *conn = sk->sk_user_data;
121 	    (conn->session->state != ISCSI_STATE_LOGGING_OUT) &&
123 		ISCSI_SW_TCP_DBG(conn, "TCP_CLOSE|TCP_CLOSE_WAIT\n");
124 		iscsi_conn_failure(conn, ISCSI_ERR_TCP_CONN_CLOSE);
130 static void iscsi_sw_tcp_recv_data(struct iscsi_conn *conn)
132 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
138 	 * Use rd_desc to pass 'conn' to iscsi_tcp_recv.
143 	rd_desc.arg.data = conn;
157 	struct iscsi_conn *conn = container_of(work, struct iscsi_conn,
159 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
164 	iscsi_sw_tcp_recv_data(conn);
172 	struct iscsi_conn *conn;
177 	conn = sk->sk_user_data;
178 	if (!conn) {
182 	tcp_conn = conn->dd_data;
186 		iscsi_conn_queue_recv(conn);
188 		iscsi_sw_tcp_recv_data(conn);
196 	struct iscsi_conn *conn;
200 	conn = sk->sk_user_data;
201 	if (!conn) {
208 	tcp_conn = conn->dd_data;
223 	struct iscsi_conn *conn;
229 	conn = sk->sk_user_data;
230 	if (!conn) {
235 	tcp_conn = conn->dd_data;
242 	ISCSI_SW_TCP_DBG(conn, "iscsi_write_space\n");
243 	iscsi_conn_queue_xmit(conn);
246 static void iscsi_sw_tcp_conn_set_callbacks(struct iscsi_conn *conn)
248 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
254 	sk->sk_user_data = conn;
265 iscsi_sw_tcp_conn_restore_callbacks(struct iscsi_conn *conn)
267 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
341  * @conn: iscsi connection
343 static int iscsi_sw_tcp_xmit(struct iscsi_conn *conn)
345 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
354 		 * We may not have been able to send data because the conn
377 	ISCSI_SW_TCP_DBG(conn, "xmit %d bytes\n", consumed);
379 	conn->txdata_octets += consumed;
385 	ISCSI_SW_TCP_DBG(conn, "Error sending PDU, errno=%d\n", rc);
386 	iscsi_conn_failure(conn, rc);
392  * @conn: iscsi connection
394 static inline int iscsi_sw_tcp_xmit_qlen(struct iscsi_conn *conn)
396 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
405 	struct iscsi_conn *conn = task->conn;
407 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
412 		iscsi_conn_printk(KERN_ERR, conn,
419 	while (iscsi_sw_tcp_xmit_qlen(conn)) {
420 		rc = iscsi_sw_tcp_xmit(conn);
451 static void iscsi_sw_tcp_send_hdr_prep(struct iscsi_conn *conn, void *hdr,
454 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
457 	ISCSI_SW_TCP_DBG(conn, "%s\n", conn->hdrdgst_en ?
470 	if (conn->hdrdgst_en) {
491 iscsi_sw_tcp_send_data_prep(struct iscsi_conn *conn, struct scatterlist *sg,
495 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
500 	ISCSI_SW_TCP_DBG(conn, "offset=%d, datalen=%d %s\n", offset, len,
501 			 conn->datadgst_en ?
509 	if (conn->datadgst_en)
518 iscsi_sw_tcp_send_linear_data_prep(struct iscsi_conn *conn, void *data,
521 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
526 	ISCSI_SW_TCP_DBG(conn, "datalen=%zd %s\n", len, conn->datadgst_en ?
534 	if (conn->datadgst_en)
544 	struct iscsi_conn *conn = task->conn;
547 	iscsi_sw_tcp_send_hdr_prep(conn, task->hdr, task->hdr_len);
553 		iscsi_sw_tcp_send_linear_data_prep(conn, task->data, count);
557 		err = iscsi_sw_tcp_send_data_prep(conn, sdb->table.sgl,
582 	struct iscsi_conn *conn;
592 	conn = cls_conn->dd_data;
593 	tcp_conn = conn->dd_data;
595 	INIT_WORK(&conn->recvwork, iscsi_sw_tcp_recv_data_work);
623 	iscsi_conn_printk(KERN_ERR, conn,
632 static void iscsi_sw_tcp_release_conn(struct iscsi_conn *conn)
634 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
653 	iscsi_sw_tcp_conn_restore_callbacks(conn);
656 	iscsi_suspend_rx(conn);
666 	struct iscsi_conn *conn = cls_conn->dd_data;
667 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
670 	iscsi_sw_tcp_release_conn(conn);
686 	struct iscsi_conn *conn = cls_conn->dd_data;
687 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
699 	iscsi_suspend_tx(conn);
702 	iscsi_sw_tcp_release_conn(conn);
712 	struct iscsi_conn *conn = cls_conn->dd_data;
713 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
722 		iscsi_conn_printk(KERN_ERR, conn,
749 	iscsi_sw_tcp_conn_set_callbacks(conn);
765 	struct iscsi_conn *conn = cls_conn->dd_data;
766 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
783 		return iscsi_tcp_set_max_r2t(conn, buf);
794 	struct iscsi_conn *conn = cls_conn->dd_data;
805 		spin_lock_bh(&conn->session->frwd_lock);
806 		if (!conn->session->leadconn) {
807 			spin_unlock_bh(&conn->session->frwd_lock);
811 		 * The conn has been setup and bound, so just grab a ref
814 		iscsi_get_conn(conn->cls_conn);
815 		spin_unlock_bh(&conn->session->frwd_lock);
817 		tcp_conn = conn->dd_data;
835 		iscsi_put_conn(conn->cls_conn);
853 	struct iscsi_conn *conn;
867 		conn = session->leadconn;
868 		if (!conn) {
872 		tcp_conn = conn->dd_data;
875 		 * The conn has been setup and bound, so just grab a ref
878 		iscsi_get_conn(conn->cls_conn);
888 		iscsi_put_conn(conn->cls_conn);
906 	struct iscsi_conn *conn = cls_conn->dd_data;
907 	struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
916 	stats->custom[2].value = conn->eh_abort_cnt;
1064 	struct iscsi_conn *conn = session->leadconn;
1066 	if (conn->datadgst_en)