Lines Matching defs:conn
403 struct iscsi_conn *conn = tcp_conn->iscsi_conn;
409 rc = iscsi_complete_pdu(conn, tcp_conn->in.hdr,
410 conn->data, tcp_conn->in.datalen);
421 struct iscsi_conn *conn = tcp_conn->iscsi_conn;
424 if (conn->datadgst_en &&
425 !(conn->session->tt->caps & CAP_DIGEST_OFFLOAD))
429 conn->data, tcp_conn->in.datalen,
452 ISCSI_DBG_TCP(task->conn, "pending r2t dropped\n");
466 * @conn: iscsi connection
469 static int iscsi_tcp_data_in(struct iscsi_conn *conn, struct iscsi_task *task)
471 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
482 iscsi_update_cmdsn(conn->session, (struct iscsi_nopin*)rhdr);
488 ISCSI_DBG_TCP(conn, "task->exp_datasn(%d) != rhdr->datasn(%d)"
497 ISCSI_DBG_TCP(conn, "data_offset(%d) + data_len(%d) > "
503 conn->datain_pdus_cnt++;
509 * @conn: iscsi connection
512 static int iscsi_tcp_r2t_rsp(struct iscsi_conn *conn, struct iscsi_task *task)
514 struct iscsi_session *session = conn->session;
516 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
523 iscsi_conn_printk(KERN_ERR, conn,
530 ISCSI_DBG_TCP(conn, "task->exp_datasn(%d) != rhdr->r2tsn(%d)\n",
539 iscsi_conn_printk(KERN_INFO, conn,
547 iscsi_conn_printk(KERN_ERR, conn, "Could not allocate R2T. "
556 iscsi_conn_printk(KERN_ERR, conn,
564 ISCSI_DBG_TCP(conn, "invalid R2T with data len %u and max "
570 iscsi_conn_printk(KERN_ERR, conn,
585 conn->r2t_pdus_cnt++;
598 struct iscsi_conn *conn = tcp_conn->iscsi_conn;
607 rc = iscsi_complete_pdu(conn, tcp_conn->in.hdr, NULL, 0);
618 * @conn: iSCSI connection
627 iscsi_tcp_hdr_dissect(struct iscsi_conn *conn, struct iscsi_hdr *hdr)
630 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
635 if (tcp_conn->in.datalen > conn->max_recv_dlength) {
636 iscsi_conn_printk(KERN_ERR, conn,
638 tcp_conn->in.datalen, conn->max_recv_dlength);
649 rc = iscsi_verify_itt(conn, hdr->itt);
653 ISCSI_DBG_TCP(conn, "opcode 0x%x ahslen %d datalen %d\n",
658 spin_lock(&conn->session->lock);
659 task = iscsi_itt_to_ctask(conn, hdr->itt);
663 rc = iscsi_tcp_data_in(conn, task);
665 spin_unlock(&conn->session->lock);
682 if (conn->datadgst_en &&
683 !(conn->session->tt->caps & CAP_DIGEST_OFFLOAD))
686 ISCSI_DBG_TCP(conn, "iscsi_tcp_begin_data_in( "
698 spin_unlock(&conn->session->lock);
701 rc = __iscsi_complete_pdu(conn, hdr, NULL, 0);
702 spin_unlock(&conn->session->lock);
709 rc = iscsi_complete_pdu(conn, hdr, NULL, 0);
712 spin_lock(&conn->session->lock);
713 task = iscsi_itt_to_ctask(conn, hdr->itt);
720 rc = iscsi_tcp_r2t_rsp(conn, task);
723 spin_unlock(&conn->session->lock);
735 iscsi_conn_printk(KERN_ERR, conn,
737 "len %u but conn buffer is only %u "
756 rc = iscsi_complete_pdu(conn, hdr, NULL, 0);
785 struct iscsi_conn *conn = tcp_conn->iscsi_conn;
811 if (conn->hdrdgst_en &&
812 !(conn->session->tt->caps & CAP_DIGEST_OFFLOAD)) {
833 return iscsi_tcp_hdr_dissect(conn, hdr);
838 * @tcp_conn: iscsi tcp conn
851 * @conn: iscsi connection
859 int iscsi_tcp_recv_skb(struct iscsi_conn *conn, struct sk_buff *skb,
862 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
868 ISCSI_DBG_TCP(conn, "in %d bytes\n", skb->len - offset);
874 conn->last_recv = jiffies;
876 if (unlikely(conn->suspend_rx)) {
877 ISCSI_DBG_TCP(conn, "Rx suspended!\n");
894 ISCSI_DBG_TCP(conn, "no more data avail. Consumed %d\n",
902 ISCSI_DBG_TCP(conn, "skb %p ptr=%p avail=%u\n", skb, ptr,
916 ISCSI_DBG_TCP(conn, "segment done\n");
920 ISCSI_DBG_TCP(conn, "Error receiving PDU, errno=%d\n", rc);
921 iscsi_conn_failure(conn, rc);
927 conn->rxdata_octets += consumed;
934 * @conn: iscsi connection
941 struct iscsi_conn *conn = task->conn;
950 ISCSI_DBG_TCP(conn, "mtask deq [itt 0x%x]\n", task->itt);
952 return conn->session->tt->init_pdu(task, 0, task->data_count);
959 ISCSI_DBG_TCP(conn, "task deq [itt 0x%x imm %d unsol %d]\n",
962 err = conn->session->tt->init_pdu(task, 0, task->imm_count);
972 struct iscsi_session *session = task->conn->session;
984 ISCSI_DBG_TCP(task->conn,
1017 struct iscsi_conn *conn = task->conn;
1018 struct iscsi_session *session = conn->session;
1042 ISCSI_DBG_TCP(conn, "no R2Ts yet\n");
1046 rc = conn->session->tt->alloc_pdu(task, ISCSI_OP_SCSI_DATA_OUT);
1051 ISCSI_DBG_TCP(conn, "sol dout %p [dsn %d itt 0x%x doff %d dlen %d]\n",
1055 rc = conn->session->tt->init_pdu(task, r2t->data_offset + r2t->sent,
1058 iscsi_conn_failure(conn, ISCSI_ERR_XMIT_FAILED);
1072 struct iscsi_conn *conn;
1079 conn = cls_conn->dd_data;
1084 conn->max_recv_dlength = ISCSI_DEF_MAX_RECV_SEG_LEN;
1086 tcp_conn = conn->dd_data;
1087 tcp_conn->iscsi_conn = conn;
1100 struct iscsi_conn *conn = cls_conn->dd_data;
1101 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
1172 struct iscsi_conn *conn = cls_conn->dd_data;
1174 stats->txdata_octets = conn->txdata_octets;
1175 stats->rxdata_octets = conn->rxdata_octets;
1176 stats->scsicmd_pdus = conn->scsicmd_pdus_cnt;
1177 stats->dataout_pdus = conn->dataout_pdus_cnt;
1178 stats->scsirsp_pdus = conn->scsirsp_pdus_cnt;
1179 stats->datain_pdus = conn->datain_pdus_cnt;
1180 stats->r2t_pdus = conn->r2t_pdus_cnt;
1181 stats->tmfcmd_pdus = conn->tmfcmd_pdus_cnt;
1182 stats->tmfrsp_pdus = conn->tmfrsp_pdus_cnt;