Lines Matching refs:tcp_conn
63 static int iscsi_tcp_hdr_recv_done(struct iscsi_tcp_conn *tcp_conn,
176 * @tcp_conn: iscsi tcp connection
190 int iscsi_tcp_segment_done(struct iscsi_tcp_conn *tcp_conn,
197 ISCSI_DBG_TCP(tcp_conn->iscsi_conn, "copied %u %u size %u %s\n",
233 ISCSI_DBG_TCP(tcp_conn->iscsi_conn, "total copied %u total size %u\n",
245 if (!(tcp_conn->iscsi_conn->session->tt->caps & CAP_PADDING_OFFLOAD)) {
248 ISCSI_DBG_TCP(tcp_conn->iscsi_conn,
276 * @tcp_conn: the iSCSI TCP connection
292 iscsi_tcp_segment_recv(struct iscsi_tcp_conn *tcp_conn,
298 while (!iscsi_tcp_segment_done(tcp_conn, segment, 1, copy)) {
300 ISCSI_DBG_TCP(tcp_conn->iscsi_conn,
306 ISCSI_DBG_TCP(tcp_conn->iscsi_conn, "copying %d\n", copy);
326 iscsi_tcp_dgst_verify(struct iscsi_tcp_conn *tcp_conn,
334 ISCSI_DBG_TCP(tcp_conn->iscsi_conn, "digest mismatch\n");
394 * @tcp_conn: iscsi connection to prep for
400 void iscsi_tcp_hdr_recv_prep(struct iscsi_tcp_conn *tcp_conn)
402 ISCSI_DBG_TCP(tcp_conn->iscsi_conn,
403 "(%s)\n", tcp_conn->iscsi_conn->hdrdgst_en ?
405 iscsi_segment_init_linear(&tcp_conn->in.segment,
406 tcp_conn->in.hdr_buf, sizeof(struct iscsi_hdr),
415 iscsi_tcp_data_recv_done(struct iscsi_tcp_conn *tcp_conn,
418 struct iscsi_conn *conn = tcp_conn->iscsi_conn;
421 if (!iscsi_tcp_dgst_verify(tcp_conn, segment))
424 rc = iscsi_complete_pdu(conn, tcp_conn->in.hdr,
425 conn->data, tcp_conn->in.datalen);
429 iscsi_tcp_hdr_recv_prep(tcp_conn);
434 iscsi_tcp_data_recv_prep(struct iscsi_tcp_conn *tcp_conn)
436 struct iscsi_conn *conn = tcp_conn->iscsi_conn;
441 rx_hash = tcp_conn->rx_hash;
443 iscsi_segment_init_linear(&tcp_conn->in.segment,
444 conn->data, tcp_conn->in.datalen,
488 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
490 struct iscsi_data_rsp *rhdr = (struct iscsi_data_rsp *)tcp_conn->in.hdr;
501 if (tcp_conn->in.datalen == 0)
513 if (tcp_task->data_offset + tcp_conn->in.datalen > total_in_length) {
516 tcp_conn->in.datalen, total_in_length);
533 struct iscsi_tcp_conn *tcp_conn;
563 tcp_conn = conn->dd_data;
564 rhdr = (struct iscsi_r2t_rsp *)tcp_conn->in.hdr;
569 if (tcp_conn->in.datalen) {
572 tcp_conn->in.datalen);
653 iscsi_tcp_process_data_in(struct iscsi_tcp_conn *tcp_conn,
656 struct iscsi_conn *conn = tcp_conn->iscsi_conn;
657 struct iscsi_hdr *hdr = tcp_conn->in.hdr;
660 if (!iscsi_tcp_dgst_verify(tcp_conn, segment))
665 rc = iscsi_complete_pdu(conn, tcp_conn->in.hdr, NULL, 0);
670 iscsi_tcp_hdr_recv_prep(tcp_conn);
688 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
692 tcp_conn->in.datalen = ntoh24(hdr->dlength);
693 if (tcp_conn->in.datalen > conn->max_recv_dlength) {
696 tcp_conn->in.datalen, conn->max_recv_dlength);
712 opcode, ahslen, tcp_conn->in.datalen);
727 if (tcp_conn->in.datalen) {
742 rx_hash = tcp_conn->rx_hash;
747 tcp_conn->in.datalen);
749 rc = iscsi_segment_seek_sg(&tcp_conn->in.segment,
753 tcp_conn->in.datalen,
763 if (tcp_conn->in.datalen) {
764 iscsi_tcp_data_recv_prep(tcp_conn);
785 if (ISCSI_DEF_MAX_RECV_SEG_LEN < tcp_conn->in.datalen) {
790 tcp_conn->in.datalen,
799 if (tcp_conn->in.datalen) {
800 iscsi_tcp_data_recv_prep(tcp_conn);
817 if (tcp_conn->in.datalen)
819 iscsi_tcp_hdr_recv_prep(tcp_conn);
827 * @tcp_conn: iSCSI TCP connection
835 iscsi_tcp_hdr_recv_done(struct iscsi_tcp_conn *tcp_conn,
838 struct iscsi_conn *conn = tcp_conn->iscsi_conn;
845 hdr = (struct iscsi_hdr *) tcp_conn->in.hdr_buf;
853 if (sizeof(*hdr) + ahslen > sizeof(tcp_conn->in.hdr_buf))
877 iscsi_tcp_dgst_header(tcp_conn->rx_hash, hdr,
881 if (!iscsi_tcp_dgst_verify(tcp_conn, segment))
885 tcp_conn->in.hdr = hdr;
891 * @tcp_conn: iscsi tcp conn
896 inline int iscsi_tcp_recv_segment_is_hdr(struct iscsi_tcp_conn *tcp_conn)
898 return tcp_conn->in.segment.done == iscsi_tcp_hdr_recv_done;
916 struct iscsi_tcp_conn *tcp_conn = conn->dd_data;
917 struct iscsi_segment *segment = &tcp_conn->in.segment;
957 rc = iscsi_tcp_segment_recv(tcp_conn, segment, ptr, avail);
970 rc = segment->done(tcp_conn, segment);
1124 struct iscsi_tcp_conn *tcp_conn;
1127 sizeof(*tcp_conn) + dd_data_size, conn_idx);
1137 tcp_conn = conn->dd_data;
1138 tcp_conn->iscsi_conn = conn;
1139 tcp_conn->dd_data = conn->dd_data + sizeof(*tcp_conn);