Lines Matching refs:conn
415 struct iscsi_conn *conn = tcp_conn->iscsi_conn; in iscsi_tcp_data_recv_done() local
421 rc = iscsi_complete_pdu(conn, tcp_conn->in.hdr, in iscsi_tcp_data_recv_done()
422 conn->data, tcp_conn->in.datalen); in iscsi_tcp_data_recv_done()
433 struct iscsi_conn *conn = tcp_conn->iscsi_conn; in iscsi_tcp_data_recv_prep() local
436 if (conn->datadgst_en && in iscsi_tcp_data_recv_prep()
437 !(conn->session->tt->caps & CAP_DIGEST_OFFLOAD)) in iscsi_tcp_data_recv_prep()
441 conn->data, tcp_conn->in.datalen, in iscsi_tcp_data_recv_prep()
464 ISCSI_DBG_TCP(task->conn, "pending r2t dropped\n"); in iscsi_tcp_cleanup_task()
481 static int iscsi_tcp_data_in(struct iscsi_conn *conn, struct iscsi_task *task) in iscsi_tcp_data_in() argument
483 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_tcp_data_in()
494 iscsi_update_cmdsn(conn->session, (struct iscsi_nopin*)rhdr); in iscsi_tcp_data_in()
500 ISCSI_DBG_TCP(conn, "task->exp_datasn(%d) != rhdr->datasn(%d)" in iscsi_tcp_data_in()
509 ISCSI_DBG_TCP(conn, "data_offset(%d) + data_len(%d) > " in iscsi_tcp_data_in()
515 conn->datain_pdus_cnt++; in iscsi_tcp_data_in()
524 static int iscsi_tcp_r2t_rsp(struct iscsi_conn *conn, struct iscsi_task *task) in iscsi_tcp_r2t_rsp() argument
526 struct iscsi_session *session = conn->session; in iscsi_tcp_r2t_rsp()
528 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_tcp_r2t_rsp()
535 iscsi_conn_printk(KERN_ERR, conn, in iscsi_tcp_r2t_rsp()
542 ISCSI_DBG_TCP(conn, "task->exp_datasn(%d) != rhdr->r2tsn(%d)\n", in iscsi_tcp_r2t_rsp()
551 iscsi_conn_printk(KERN_INFO, conn, in iscsi_tcp_r2t_rsp()
559 iscsi_conn_printk(KERN_ERR, conn, "Could not allocate R2T. " in iscsi_tcp_r2t_rsp()
568 iscsi_conn_printk(KERN_ERR, conn, in iscsi_tcp_r2t_rsp()
576 ISCSI_DBG_TCP(conn, "invalid R2T with data len %u and max " in iscsi_tcp_r2t_rsp()
582 iscsi_conn_printk(KERN_ERR, conn, in iscsi_tcp_r2t_rsp()
597 conn->r2t_pdus_cnt++; in iscsi_tcp_r2t_rsp()
610 struct iscsi_conn *conn = tcp_conn->iscsi_conn; in iscsi_tcp_process_data_in() local
619 rc = iscsi_complete_pdu(conn, tcp_conn->in.hdr, NULL, 0); in iscsi_tcp_process_data_in()
639 iscsi_tcp_hdr_dissect(struct iscsi_conn *conn, struct iscsi_hdr *hdr) in iscsi_tcp_hdr_dissect() argument
642 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_tcp_hdr_dissect()
647 if (tcp_conn->in.datalen > conn->max_recv_dlength) { in iscsi_tcp_hdr_dissect()
648 iscsi_conn_printk(KERN_ERR, conn, in iscsi_tcp_hdr_dissect()
650 tcp_conn->in.datalen, conn->max_recv_dlength); in iscsi_tcp_hdr_dissect()
661 rc = iscsi_verify_itt(conn, hdr->itt); in iscsi_tcp_hdr_dissect()
665 ISCSI_DBG_TCP(conn, "opcode 0x%x ahslen %d datalen %d\n", in iscsi_tcp_hdr_dissect()
670 spin_lock(&conn->session->lock); in iscsi_tcp_hdr_dissect()
671 task = iscsi_itt_to_ctask(conn, hdr->itt); in iscsi_tcp_hdr_dissect()
675 rc = iscsi_tcp_data_in(conn, task); in iscsi_tcp_hdr_dissect()
677 spin_unlock(&conn->session->lock); in iscsi_tcp_hdr_dissect()
694 if (conn->datadgst_en && in iscsi_tcp_hdr_dissect()
695 !(conn->session->tt->caps & CAP_DIGEST_OFFLOAD)) in iscsi_tcp_hdr_dissect()
698 ISCSI_DBG_TCP(conn, "iscsi_tcp_begin_data_in( " in iscsi_tcp_hdr_dissect()
710 spin_unlock(&conn->session->lock); in iscsi_tcp_hdr_dissect()
713 rc = __iscsi_complete_pdu(conn, hdr, NULL, 0); in iscsi_tcp_hdr_dissect()
714 spin_unlock(&conn->session->lock); in iscsi_tcp_hdr_dissect()
721 rc = iscsi_complete_pdu(conn, hdr, NULL, 0); in iscsi_tcp_hdr_dissect()
724 spin_lock(&conn->session->lock); in iscsi_tcp_hdr_dissect()
725 task = iscsi_itt_to_ctask(conn, hdr->itt); in iscsi_tcp_hdr_dissect()
732 rc = iscsi_tcp_r2t_rsp(conn, task); in iscsi_tcp_hdr_dissect()
735 spin_unlock(&conn->session->lock); in iscsi_tcp_hdr_dissect()
747 iscsi_conn_printk(KERN_ERR, conn, in iscsi_tcp_hdr_dissect()
768 rc = iscsi_complete_pdu(conn, hdr, NULL, 0); in iscsi_tcp_hdr_dissect()
797 struct iscsi_conn *conn = tcp_conn->iscsi_conn; in iscsi_tcp_hdr_recv_done() local
823 if (conn->hdrdgst_en && in iscsi_tcp_hdr_recv_done()
824 !(conn->session->tt->caps & CAP_DIGEST_OFFLOAD)) { in iscsi_tcp_hdr_recv_done()
845 return iscsi_tcp_hdr_dissect(conn, hdr); in iscsi_tcp_hdr_recv_done()
871 int iscsi_tcp_recv_skb(struct iscsi_conn *conn, struct sk_buff *skb, in iscsi_tcp_recv_skb() argument
874 struct iscsi_tcp_conn *tcp_conn = conn->dd_data; in iscsi_tcp_recv_skb()
880 ISCSI_DBG_TCP(conn, "in %d bytes\n", skb->len - offset); in iscsi_tcp_recv_skb()
886 conn->last_recv = jiffies; in iscsi_tcp_recv_skb()
888 if (unlikely(conn->suspend_rx)) { in iscsi_tcp_recv_skb()
889 ISCSI_DBG_TCP(conn, "Rx suspended!\n"); in iscsi_tcp_recv_skb()
906 ISCSI_DBG_TCP(conn, "no more data avail. Consumed %d\n", in iscsi_tcp_recv_skb()
914 ISCSI_DBG_TCP(conn, "skb %p ptr=%p avail=%u\n", skb, ptr, in iscsi_tcp_recv_skb()
928 ISCSI_DBG_TCP(conn, "segment done\n"); in iscsi_tcp_recv_skb()
932 ISCSI_DBG_TCP(conn, "Error receiving PDU, errno=%d\n", rc); in iscsi_tcp_recv_skb()
933 iscsi_conn_failure(conn, rc); in iscsi_tcp_recv_skb()
939 conn->rxdata_octets += consumed; in iscsi_tcp_recv_skb()
953 struct iscsi_conn *conn = task->conn; in iscsi_tcp_task_init() local
962 ISCSI_DBG_TCP(conn, "mtask deq [itt 0x%x]\n", task->itt); in iscsi_tcp_task_init()
964 return conn->session->tt->init_pdu(task, 0, task->data_count); in iscsi_tcp_task_init()
971 ISCSI_DBG_TCP(conn, "task deq [itt 0x%x imm %d unsol %d]\n", in iscsi_tcp_task_init()
974 err = conn->session->tt->init_pdu(task, 0, task->imm_count); in iscsi_tcp_task_init()
984 struct iscsi_session *session = task->conn->session; in iscsi_tcp_get_curr_r2t()
996 ISCSI_DBG_TCP(task->conn, in iscsi_tcp_get_curr_r2t()
1029 struct iscsi_conn *conn = task->conn; in iscsi_tcp_task_xmit() local
1030 struct iscsi_session *session = conn->session; in iscsi_tcp_task_xmit()
1054 ISCSI_DBG_TCP(conn, "no R2Ts yet\n"); in iscsi_tcp_task_xmit()
1058 rc = conn->session->tt->alloc_pdu(task, ISCSI_OP_SCSI_DATA_OUT); in iscsi_tcp_task_xmit()
1063 ISCSI_DBG_TCP(conn, "sol dout %p [dsn %d itt 0x%x doff %d dlen %d]\n", in iscsi_tcp_task_xmit()
1067 rc = conn->session->tt->init_pdu(task, r2t->data_offset + r2t->sent, in iscsi_tcp_task_xmit()
1070 iscsi_conn_failure(conn, ISCSI_ERR_XMIT_FAILED); in iscsi_tcp_task_xmit()
1084 struct iscsi_conn *conn; in iscsi_tcp_conn_setup() local
1092 conn = cls_conn->dd_data; in iscsi_tcp_conn_setup()
1097 conn->max_recv_dlength = ISCSI_DEF_MAX_RECV_SEG_LEN; in iscsi_tcp_conn_setup()
1099 tcp_conn = conn->dd_data; in iscsi_tcp_conn_setup()
1100 tcp_conn->iscsi_conn = conn; in iscsi_tcp_conn_setup()
1101 tcp_conn->dd_data = conn->dd_data + sizeof(*tcp_conn); in iscsi_tcp_conn_setup()
1173 int iscsi_tcp_set_max_r2t(struct iscsi_conn *conn, char *buf) in iscsi_tcp_set_max_r2t() argument
1175 struct iscsi_session *session = conn->session; in iscsi_tcp_set_max_r2t()
1194 struct iscsi_conn *conn = cls_conn->dd_data; in iscsi_tcp_conn_get_stats() local
1196 stats->txdata_octets = conn->txdata_octets; in iscsi_tcp_conn_get_stats()
1197 stats->rxdata_octets = conn->rxdata_octets; in iscsi_tcp_conn_get_stats()
1198 stats->scsicmd_pdus = conn->scsicmd_pdus_cnt; in iscsi_tcp_conn_get_stats()
1199 stats->dataout_pdus = conn->dataout_pdus_cnt; in iscsi_tcp_conn_get_stats()
1200 stats->scsirsp_pdus = conn->scsirsp_pdus_cnt; in iscsi_tcp_conn_get_stats()
1201 stats->datain_pdus = conn->datain_pdus_cnt; in iscsi_tcp_conn_get_stats()
1202 stats->r2t_pdus = conn->r2t_pdus_cnt; in iscsi_tcp_conn_get_stats()
1203 stats->tmfcmd_pdus = conn->tmfcmd_pdus_cnt; in iscsi_tcp_conn_get_stats()
1204 stats->tmfrsp_pdus = conn->tmfrsp_pdus_cnt; in iscsi_tcp_conn_get_stats()