1c942fddfSThomas Gleixner /* SPDX-License-Identifier: GPL-2.0-or-later */ 2a081c13eSMike Christie /* 3a081c13eSMike Christie * iSCSI over TCP/IP Data-Path lib 4a081c13eSMike Christie * 5a081c13eSMike Christie * Copyright (C) 2008 Mike Christie 6a081c13eSMike Christie * Copyright (C) 2008 Red Hat, Inc. All rights reserved. 7a081c13eSMike Christie * maintained by open-iscsi@googlegroups.com 8a081c13eSMike Christie */ 9a081c13eSMike Christie 10a081c13eSMike Christie #ifndef LIBISCSI_TCP_H 11a081c13eSMike Christie #define LIBISCSI_TCP_H 12a081c13eSMike Christie 13a081c13eSMike Christie #include <scsi/libiscsi.h> 14a081c13eSMike Christie 15a081c13eSMike Christie struct iscsi_tcp_conn; 16a081c13eSMike Christie struct iscsi_segment; 17a081c13eSMike Christie struct sk_buff; 18a081c13eSMike Christie struct ahash_request; 19a081c13eSMike Christie 205d6ac29bSHerbert Xu typedef int iscsi_segment_done_fn_t(struct iscsi_tcp_conn *, 21a081c13eSMike Christie struct iscsi_segment *); 22a081c13eSMike Christie 23a081c13eSMike Christie struct iscsi_segment { 24a081c13eSMike Christie unsigned char *data; 25a081c13eSMike Christie unsigned int size; 26a081c13eSMike Christie unsigned int copied; 27a081c13eSMike Christie unsigned int total_size; 28a081c13eSMike Christie unsigned int total_copied; 29a081c13eSMike Christie 30a081c13eSMike Christie struct ahash_request *hash; 31a081c13eSMike Christie unsigned char padbuf[ISCSI_PAD_LEN]; 325d6ac29bSHerbert Xu unsigned char recv_digest[ISCSI_DIGEST_SIZE]; 332856830bSKaren Xie unsigned char digest[ISCSI_DIGEST_SIZE]; 34a081c13eSMike Christie unsigned int digest_len; 35a081c13eSMike Christie 36a081c13eSMike Christie struct scatterlist *sg; 37a081c13eSMike Christie void *sg_mapped; 38a081c13eSMike Christie unsigned int sg_offset; 39a081c13eSMike Christie bool atomic_mapped; 40a081c13eSMike Christie 4170c7c88aSMike Christie iscsi_segment_done_fn_t *done; 42a081c13eSMike Christie }; 43a081c13eSMike Christie 44a081c13eSMike Christie /* Socket connection receive helper */ 45a081c13eSMike Christie struct iscsi_tcp_recv { 4625985edcSLucas De Marchi struct iscsi_hdr *hdr; 47a081c13eSMike Christie struct iscsi_segment segment; 48a081c13eSMike Christie 49a081c13eSMike Christie /* Allocate buffer for BHS + AHS */ 50a081c13eSMike Christie uint32_t hdr_buf[64]; 51a081c13eSMike Christie 52a081c13eSMike Christie /* copied and flipped values */ 53a081c13eSMike Christie int datalen; 54a081c13eSMike Christie }; 55a081c13eSMike Christie 56a081c13eSMike Christie struct iscsi_tcp_conn { 57a081c13eSMike Christie struct iscsi_conn *iscsi_conn; 58a081c13eSMike Christie void *dd_data; 59a081c13eSMike Christie int stop_stage; /* conn_stop() flag: * 60a081c13eSMike Christie * stop to recover, * 61a081c13eSMike Christie * stop to terminate */ 62a081c13eSMike Christie /* control data */ 63a081c13eSMike Christie struct iscsi_tcp_recv in; /* TCP receive context */ 64a081c13eSMike Christie /* CRC32C (Rx) LLD should set this is they do not offload */ 65a081c13eSMike Christie struct ahash_request *rx_hash; 66a081c13eSMike Christie }; 675d6ac29bSHerbert Xu 68a081c13eSMike Christie struct iscsi_tcp_task { 69a081c13eSMike Christie uint32_t exp_datasn; /* expected target's R2TSN/DataSN */ 70a081c13eSMike Christie int data_offset; 71a081c13eSMike Christie struct iscsi_r2t_info *r2t; /* in progress solict R2T */ 72a081c13eSMike Christie struct iscsi_pool r2tpool; 73a081c13eSMike Christie struct kfifo r2tqueue; 74a081c13eSMike Christie void *dd_data; 7545465487SStefani Seibold spinlock_t pool2queue; 76a081c13eSMike Christie spinlock_t queue2pool; 77659743b0SShlomo Pongratz }; 78659743b0SShlomo Pongratz 79a081c13eSMike Christie enum { 80a081c13eSMike Christie ISCSI_TCP_SEGMENT_DONE, /* curr seg has been processed */ 81a081c13eSMike Christie ISCSI_TCP_SKB_DONE, /* skb is out of data */ 82a081c13eSMike Christie ISCSI_TCP_CONN_ERR, /* iscsi layer has fired a conn err */ 83a081c13eSMike Christie ISCSI_TCP_SUSPENDED, /* conn is suspended */ 84a081c13eSMike Christie }; 85a081c13eSMike Christie 86a081c13eSMike Christie extern void iscsi_tcp_hdr_recv_prep(struct iscsi_tcp_conn *tcp_conn); 87a081c13eSMike Christie extern int iscsi_tcp_recv_skb(struct iscsi_conn *conn, struct sk_buff *skb, 88a081c13eSMike Christie unsigned int offset, bool offloaded, int *status); 89a081c13eSMike Christie extern void iscsi_tcp_cleanup_task(struct iscsi_task *task); 90a081c13eSMike Christie extern int iscsi_tcp_task_init(struct iscsi_task *task); 91a081c13eSMike Christie extern int iscsi_tcp_task_xmit(struct iscsi_task *task); 92a081c13eSMike Christie 93a081c13eSMike Christie /* segment helpers */ 94a081c13eSMike Christie extern int iscsi_tcp_recv_segment_is_hdr(struct iscsi_tcp_conn *tcp_conn); 95a081c13eSMike Christie extern int iscsi_tcp_segment_done(struct iscsi_tcp_conn *tcp_conn, 96a081c13eSMike Christie struct iscsi_segment *segment, int recv, 976df19a79SMike Christie unsigned copied); 986df19a79SMike Christie extern void iscsi_tcp_segment_unmap(struct iscsi_segment *segment); 99a081c13eSMike Christie 100a081c13eSMike Christie extern void iscsi_segment_init_linear(struct iscsi_segment *segment, 101a081c13eSMike Christie void *data, size_t size, 102a081c13eSMike Christie iscsi_segment_done_fn_t *done, 103a081c13eSMike Christie struct ahash_request *hash); 104a081c13eSMike Christie extern int 1055d6ac29bSHerbert Xu iscsi_segment_seek_sg(struct iscsi_segment *segment, 106a081c13eSMike Christie struct scatterlist *sg_list, unsigned int sg_count, 107a081c13eSMike Christie unsigned int offset, size_t size, 108a081c13eSMike Christie iscsi_segment_done_fn_t *done, 109a081c13eSMike Christie struct ahash_request *hash); 1105d6ac29bSHerbert Xu 1115d6ac29bSHerbert Xu /* digest helpers */ 112a081c13eSMike Christie extern void iscsi_tcp_dgst_header(struct ahash_request *hash, const void *hdr, 113a081c13eSMike Christie size_t hdrlen, 1145d6ac29bSHerbert Xu unsigned char digest[ISCSI_DIGEST_SIZE]); 115a081c13eSMike Christie extern struct iscsi_cls_conn * 116a081c13eSMike Christie iscsi_tcp_conn_setup(struct iscsi_cls_session *cls_session, int dd_data_size, 117a081c13eSMike Christie uint32_t conn_idx); 118a081c13eSMike Christie extern void iscsi_tcp_conn_teardown(struct iscsi_cls_conn *cls_conn); 119a081c13eSMike Christie 120a081c13eSMike Christie /* misc helpers */ 121a081c13eSMike Christie extern int iscsi_tcp_r2tpool_alloc(struct iscsi_session *session); 122a081c13eSMike Christie extern void iscsi_tcp_r2tpool_free(struct iscsi_session *session); 123a081c13eSMike Christie extern int iscsi_tcp_set_max_r2t(struct iscsi_conn *conn, char *buf); 124a081c13eSMike Christie extern void iscsi_tcp_conn_get_stats(struct iscsi_cls_conn *cls_conn, 1251304be5fSMike Christie struct iscsi_stats *stats); 126a081c13eSMike Christie #endif /* LIBISCSI_TCP_H */ 127a081c13eSMike Christie