1 #include <linux/socket.h>
4 #include <rdma/ib_verbs.h>
5 #include <rdma/rdma_cm.h>
10 #define DRV_NAME "isert"
11 #define PFX DRV_NAME ": "
13 #define isert_dbg(fmt, arg...) \
15 if (unlikely(isert_debug_level > 2)) \
16 printk(KERN_DEBUG PFX "%s: " fmt,\
20 #define isert_warn(fmt, arg...) \
22 if (unlikely(isert_debug_level > 0)) \
23 pr_warn(PFX "%s: " fmt, \
27 #define isert_info(fmt, arg...) \
29 if (unlikely(isert_debug_level > 1)) \
30 pr_info(PFX "%s: " fmt, \
34 #define isert_err(fmt, arg...) \
35 pr_err(PFX "%s: " fmt, __func__ , ## arg)
37 /* Constant PDU lengths calculations */
38 #define ISER_HEADERS_LEN (sizeof(struct iser_ctrl) + \
39 sizeof(struct iscsi_hdr))
40 #define ISER_RX_PAYLOAD_SIZE (ISER_HEADERS_LEN + ISCSI_DEF_MAX_RECV_SEG_LEN)
43 /* Maximal bounds on received asynchronous PDUs */
44 #define ISERT_MAX_TX_MISC_PDUS 4 /* NOOP_IN(2) , ASYNC_EVENT(2) */
46 #define ISERT_MAX_RX_MISC_PDUS 6 /*
47 * NOOP_OUT(2), TEXT(1),
48 * SCSI_TMFUNC(2), LOGOUT(1)
51 #define ISCSI_DEF_XMIT_CMDS_MAX 128 /* from libiscsi.h, must be power of 2 */
53 #define ISERT_QP_MAX_RECV_DTOS (ISCSI_DEF_XMIT_CMDS_MAX)
55 #define ISERT_MIN_POSTED_RX (ISCSI_DEF_XMIT_CMDS_MAX >> 2)
57 #define ISERT_QP_MAX_REQ_DTOS (ISCSI_DEF_XMIT_CMDS_MAX + \
58 ISERT_MAX_TX_MISC_PDUS + \
59 ISERT_MAX_RX_MISC_PDUS)
61 #define ISER_RX_PAD_SIZE (ISCSI_DEF_MAX_RECV_SEG_LEN + 4096 - \
62 (ISER_RX_PAYLOAD_SIZE + sizeof(u64) + sizeof(struct ib_sge) + \
63 sizeof(struct ib_cqe)))
65 #define ISCSI_ISER_SG_TABLESIZE 256
67 enum isert_desc_type {
72 enum iser_conn_state {
76 ISER_CONN_FULL_FEATURE,
77 ISER_CONN_TERMINATING,
82 struct iser_ctrl iser_header;
83 struct iscsi_hdr iscsi_header;
84 char data[ISCSI_DEF_MAX_RECV_SEG_LEN];
88 char pad[ISER_RX_PAD_SIZE];
91 static inline struct iser_rx_desc *cqe_to_rx_desc(struct ib_cqe *cqe)
93 return container_of(cqe, struct iser_rx_desc, rx_cqe);
97 struct iser_ctrl iser_header;
98 struct iscsi_hdr iscsi_header;
99 enum isert_desc_type type;
101 struct ib_sge tx_sg[2];
102 struct ib_cqe tx_cqe;
104 struct ib_send_wr send_wr;
107 static inline struct iser_tx_desc *cqe_to_tx_desc(struct ib_cqe *cqe)
109 return container_of(cqe, struct iser_tx_desc, tx_cqe);
120 struct isert_conn *conn;
121 struct iscsi_cmd *iscsi_cmd;
122 struct iser_tx_desc tx_desc;
123 struct iser_rx_desc *rx_desc;
124 struct rdma_rw_ctx rw;
125 struct work_struct comp_work;
126 struct scatterlist sg;
130 static inline struct isert_cmd *tx_desc_to_cmd(struct iser_tx_desc *desc)
132 return container_of(desc, struct isert_cmd, tx_desc);
138 enum iser_conn_state state;
139 u32 responder_resources;
142 struct iser_rx_desc *login_req_buf;
147 struct iser_rx_desc *rx_descs;
148 struct ib_recv_wr rx_wr[ISERT_QP_MAX_RECV_DTOS];
149 struct iscsi_conn *conn;
150 struct list_head node;
151 struct completion login_comp;
152 struct completion login_req_comp;
153 struct iser_tx_desc login_tx_desc;
154 struct rdma_cm_id *cm_id;
156 struct isert_device *device;
159 struct work_struct release_work;
162 wait_queue_head_t rem_wait;
166 #define ISERT_MAX_CQ 64
169 * struct isert_comp - iSER completion context
171 * @device: pointer to device handle
172 * @cq: completion queue
173 * @active_qps: Number of active QPs attached
174 * to completion context
177 struct isert_device *device;
182 struct isert_device {
185 struct ib_device *ib_device;
187 struct isert_comp *comps;
189 struct list_head dev_node;
194 struct semaphore sem;
195 struct rdma_cm_id *cm_id;
197 struct list_head accepted;
198 struct list_head pending;