ib_srpt.h 14 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444
  1. /*
  2. * Copyright (c) 2006 - 2009 Mellanox Technology Inc. All rights reserved.
  3. * Copyright (C) 2009 - 2010 Bart Van Assche <bvanassche@acm.org>.
  4. *
  5. * This software is available to you under a choice of one of two
  6. * licenses. You may choose to be licensed under the terms of the GNU
  7. * General Public License (GPL) Version 2, available from the file
  8. * COPYING in the main directory of this source tree, or the
  9. * OpenIB.org BSD license below:
  10. *
  11. * Redistribution and use in source and binary forms, with or
  12. * without modification, are permitted provided that the following
  13. * conditions are met:
  14. *
  15. * - Redistributions of source code must retain the above
  16. * copyright notice, this list of conditions and the following
  17. * disclaimer.
  18. *
  19. * - Redistributions in binary form must reproduce the above
  20. * copyright notice, this list of conditions and the following
  21. * disclaimer in the documentation and/or other materials
  22. * provided with the distribution.
  23. *
  24. * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  25. * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  26. * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  27. * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
  28. * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  29. * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
  30. * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
  31. * SOFTWARE.
  32. *
  33. */
  34. #ifndef IB_SRPT_H
  35. #define IB_SRPT_H
  36. #include <linux/types.h>
  37. #include <linux/list.h>
  38. #include <linux/wait.h>
  39. #include <rdma/ib_verbs.h>
  40. #include <rdma/ib_sa.h>
  41. #include <rdma/ib_cm.h>
  42. #include <scsi/srp.h>
  43. #include "ib_dm_mad.h"
  44. /*
  45. * The prefix the ServiceName field must start with in the device management
  46. * ServiceEntries attribute pair. See also the SRP specification.
  47. */
  48. #define SRP_SERVICE_NAME_PREFIX "SRP.T10:"
  49. enum {
  50. /*
  51. * SRP IOControllerProfile attributes for SRP target ports that have
  52. * not been defined in <scsi/srp.h>. Source: section B.7, table B.7
  53. * in the SRP specification.
  54. */
  55. SRP_PROTOCOL = 0x0108,
  56. SRP_PROTOCOL_VERSION = 0x0001,
  57. SRP_IO_SUBCLASS = 0x609e,
  58. SRP_SEND_TO_IOC = 0x01,
  59. SRP_SEND_FROM_IOC = 0x02,
  60. SRP_RDMA_READ_FROM_IOC = 0x08,
  61. SRP_RDMA_WRITE_FROM_IOC = 0x20,
  62. /*
  63. * srp_login_cmd.req_flags bitmasks. See also table 9 in the SRP
  64. * specification.
  65. */
  66. SRP_MTCH_ACTION = 0x03, /* MULTI-CHANNEL ACTION */
  67. SRP_LOSOLNT = 0x10, /* logout solicited notification */
  68. SRP_CRSOLNT = 0x20, /* credit request solicited notification */
  69. SRP_AESOLNT = 0x40, /* asynchronous event solicited notification */
  70. /*
  71. * srp_cmd.sol_nt / srp_tsk_mgmt.sol_not bitmasks. See also tables
  72. * 18 and 20 in the SRP specification.
  73. */
  74. SRP_SCSOLNT = 0x02, /* SCSOLNT = successful solicited notification */
  75. SRP_UCSOLNT = 0x04, /* UCSOLNT = unsuccessful solicited notification */
  76. /*
  77. * srp_rsp.sol_not / srp_t_logout.sol_not bitmasks. See also tables
  78. * 16 and 22 in the SRP specification.
  79. */
  80. SRP_SOLNT = 0x01, /* SOLNT = solicited notification */
  81. /* See also table 24 in the SRP specification. */
  82. SRP_TSK_MGMT_SUCCESS = 0x00,
  83. SRP_TSK_MGMT_FUNC_NOT_SUPP = 0x04,
  84. SRP_TSK_MGMT_FAILED = 0x05,
  85. /* See also table 21 in the SRP specification. */
  86. SRP_CMD_SIMPLE_Q = 0x0,
  87. SRP_CMD_HEAD_OF_Q = 0x1,
  88. SRP_CMD_ORDERED_Q = 0x2,
  89. SRP_CMD_ACA = 0x4,
  90. SRP_LOGIN_RSP_MULTICHAN_NO_CHAN = 0x0,
  91. SRP_LOGIN_RSP_MULTICHAN_TERMINATED = 0x1,
  92. SRP_LOGIN_RSP_MULTICHAN_MAINTAINED = 0x2,
  93. SRPT_DEF_SG_TABLESIZE = 128,
  94. SRPT_DEF_SG_PER_WQE = 16,
  95. MIN_SRPT_SQ_SIZE = 16,
  96. DEF_SRPT_SQ_SIZE = 4096,
  97. SRPT_RQ_SIZE = 128,
  98. MIN_SRPT_SRQ_SIZE = 4,
  99. DEFAULT_SRPT_SRQ_SIZE = 4095,
  100. MAX_SRPT_SRQ_SIZE = 65535,
  101. MAX_SRPT_RDMA_SIZE = 1U << 24,
  102. MAX_SRPT_RSP_SIZE = 1024,
  103. MIN_MAX_REQ_SIZE = 996,
  104. DEFAULT_MAX_REQ_SIZE
  105. = sizeof(struct srp_cmd)/*48*/
  106. + sizeof(struct srp_indirect_buf)/*20*/
  107. + 128 * sizeof(struct srp_direct_buf)/*16*/,
  108. MIN_MAX_RSP_SIZE = sizeof(struct srp_rsp)/*36*/ + 4,
  109. DEFAULT_MAX_RSP_SIZE = 256, /* leaves 220 bytes for sense data */
  110. DEFAULT_MAX_RDMA_SIZE = 65536,
  111. };
  112. enum srpt_opcode {
  113. SRPT_RECV,
  114. SRPT_SEND,
  115. SRPT_RDMA_MID,
  116. SRPT_RDMA_ABORT,
  117. SRPT_RDMA_READ_LAST,
  118. SRPT_RDMA_WRITE_LAST,
  119. };
  120. static inline u64 encode_wr_id(u8 opcode, u32 idx)
  121. {
  122. return ((u64)opcode << 32) | idx;
  123. }
  124. static inline enum srpt_opcode opcode_from_wr_id(u64 wr_id)
  125. {
  126. return wr_id >> 32;
  127. }
  128. static inline u32 idx_from_wr_id(u64 wr_id)
  129. {
  130. return (u32)wr_id;
  131. }
  132. struct rdma_iu {
  133. u64 raddr;
  134. u32 rkey;
  135. struct ib_sge *sge;
  136. u32 sge_cnt;
  137. int mem_id;
  138. };
  139. /**
  140. * enum srpt_command_state - SCSI command state managed by SRPT.
  141. * @SRPT_STATE_NEW: New command arrived and is being processed.
  142. * @SRPT_STATE_NEED_DATA: Processing a write or bidir command and waiting
  143. * for data arrival.
  144. * @SRPT_STATE_DATA_IN: Data for the write or bidir command arrived and is
  145. * being processed.
  146. * @SRPT_STATE_CMD_RSP_SENT: SRP_RSP for SRP_CMD has been sent.
  147. * @SRPT_STATE_MGMT: Processing a SCSI task management command.
  148. * @SRPT_STATE_MGMT_RSP_SENT: SRP_RSP for SRP_TSK_MGMT has been sent.
  149. * @SRPT_STATE_DONE: Command processing finished successfully, command
  150. * processing has been aborted or command processing
  151. * failed.
  152. */
  153. enum srpt_command_state {
  154. SRPT_STATE_NEW = 0,
  155. SRPT_STATE_NEED_DATA = 1,
  156. SRPT_STATE_DATA_IN = 2,
  157. SRPT_STATE_CMD_RSP_SENT = 3,
  158. SRPT_STATE_MGMT = 4,
  159. SRPT_STATE_MGMT_RSP_SENT = 5,
  160. SRPT_STATE_DONE = 6,
  161. };
  162. /**
  163. * struct srpt_ioctx - Shared SRPT I/O context information.
  164. * @buf: Pointer to the buffer.
  165. * @dma: DMA address of the buffer.
  166. * @index: Index of the I/O context in its ioctx_ring array.
  167. */
  168. struct srpt_ioctx {
  169. void *buf;
  170. dma_addr_t dma;
  171. uint32_t index;
  172. };
  173. /**
  174. * struct srpt_recv_ioctx - SRPT receive I/O context.
  175. * @ioctx: See above.
  176. * @wait_list: Node for insertion in srpt_rdma_ch.cmd_wait_list.
  177. */
  178. struct srpt_recv_ioctx {
  179. struct srpt_ioctx ioctx;
  180. struct list_head wait_list;
  181. };
  182. /**
  183. * struct srpt_send_ioctx - SRPT send I/O context.
  184. * @ioctx: See above.
  185. * @ch: Channel pointer.
  186. * @free_list: Node in srpt_rdma_ch.free_list.
  187. * @n_rbuf: Number of data buffers in the received SRP command.
  188. * @rbufs: Pointer to SRP data buffer array.
  189. * @single_rbuf: SRP data buffer if the command has only a single buffer.
  190. * @sg: Pointer to sg-list associated with this I/O context.
  191. * @sg_cnt: SG-list size.
  192. * @mapped_sg_count: ib_dma_map_sg() return value.
  193. * @n_rdma_ius: Number of elements in the rdma_ius array.
  194. * @rdma_ius: Array with information about the RDMA mapping.
  195. * @tag: Tag of the received SRP information unit.
  196. * @spinlock: Protects 'state'.
  197. * @state: I/O context state.
  198. * @rdma_aborted: If initiating a multipart RDMA transfer failed, whether
  199. * the already initiated transfers have finished.
  200. * @cmd: Target core command data structure.
  201. * @sense_data: SCSI sense data.
  202. */
  203. struct srpt_send_ioctx {
  204. struct srpt_ioctx ioctx;
  205. struct srpt_rdma_ch *ch;
  206. struct kref kref;
  207. struct rdma_iu *rdma_ius;
  208. struct srp_direct_buf *rbufs;
  209. struct srp_direct_buf single_rbuf;
  210. struct scatterlist *sg;
  211. struct list_head free_list;
  212. spinlock_t spinlock;
  213. enum srpt_command_state state;
  214. bool rdma_aborted;
  215. struct se_cmd cmd;
  216. struct completion tx_done;
  217. u64 tag;
  218. int sg_cnt;
  219. int mapped_sg_count;
  220. u16 n_rdma_ius;
  221. u8 n_rdma;
  222. u8 n_rbuf;
  223. bool queue_status_only;
  224. u8 sense_data[SCSI_SENSE_BUFFERSIZE];
  225. };
  226. /**
  227. * enum rdma_ch_state - SRP channel state.
  228. * @CH_CONNECTING: QP is in RTR state; waiting for RTU.
  229. * @CH_LIVE: QP is in RTS state.
  230. * @CH_DISCONNECTING: DREQ has been received; waiting for DREP
  231. * or DREQ has been send and waiting for DREP
  232. * or .
  233. * @CH_DRAINING: QP is in ERR state; waiting for last WQE event.
  234. * @CH_RELEASING: Last WQE event has been received; releasing resources.
  235. */
  236. enum rdma_ch_state {
  237. CH_CONNECTING,
  238. CH_LIVE,
  239. CH_DISCONNECTING,
  240. CH_DRAINING,
  241. CH_RELEASING
  242. };
  243. /**
  244. * struct srpt_rdma_ch - RDMA channel.
  245. * @wait_queue: Allows the kernel thread to wait for more work.
  246. * @thread: Kernel thread that processes the IB queues associated with
  247. * the channel.
  248. * @cm_id: IB CM ID associated with the channel.
  249. * @qp: IB queue pair used for communicating over this channel.
  250. * @cq: IB completion queue for this channel.
  251. * @rq_size: IB receive queue size.
  252. * @rsp_size IB response message size in bytes.
  253. * @sq_wr_avail: number of work requests available in the send queue.
  254. * @sport: pointer to the information of the HCA port used by this
  255. * channel.
  256. * @i_port_id: 128-bit initiator port identifier copied from SRP_LOGIN_REQ.
  257. * @t_port_id: 128-bit target port identifier copied from SRP_LOGIN_REQ.
  258. * @max_ti_iu_len: maximum target-to-initiator information unit length.
  259. * @req_lim: request limit: maximum number of requests that may be sent
  260. * by the initiator without having received a response.
  261. * @req_lim_delta: Number of credits not yet sent back to the initiator.
  262. * @spinlock: Protects free_list and state.
  263. * @free_list: Head of list with free send I/O contexts.
  264. * @state: channel state. See also enum rdma_ch_state.
  265. * @ioctx_ring: Send ring.
  266. * @wc: IB work completion array for srpt_process_completion().
  267. * @list: Node for insertion in the srpt_device.rch_list list.
  268. * @cmd_wait_list: List of SCSI commands that arrived before the RTU event. This
  269. * list contains struct srpt_ioctx elements and is protected
  270. * against concurrent modification by the cm_id spinlock.
  271. * @sess: Session information associated with this SRP channel.
  272. * @sess_name: Session name.
  273. * @release_work: Allows scheduling of srpt_release_channel().
  274. * @release_done: Enables waiting for srpt_release_channel() completion.
  275. */
  276. struct srpt_rdma_ch {
  277. wait_queue_head_t wait_queue;
  278. struct task_struct *thread;
  279. struct ib_cm_id *cm_id;
  280. struct ib_qp *qp;
  281. struct ib_cq *cq;
  282. int rq_size;
  283. u32 rsp_size;
  284. atomic_t sq_wr_avail;
  285. struct srpt_port *sport;
  286. u8 i_port_id[16];
  287. u8 t_port_id[16];
  288. int max_ti_iu_len;
  289. atomic_t req_lim;
  290. atomic_t req_lim_delta;
  291. spinlock_t spinlock;
  292. struct list_head free_list;
  293. enum rdma_ch_state state;
  294. struct srpt_send_ioctx **ioctx_ring;
  295. struct ib_wc wc[16];
  296. struct list_head list;
  297. struct list_head cmd_wait_list;
  298. struct se_session *sess;
  299. u8 sess_name[36];
  300. struct work_struct release_work;
  301. struct completion *release_done;
  302. };
  303. /**
  304. * struct srpt_port_attib - Attributes for SRPT port
  305. * @srp_max_rdma_size: Maximum size of SRP RDMA transfers for new connections.
  306. * @srp_max_rsp_size: Maximum size of SRP response messages in bytes.
  307. * @srp_sq_size: Shared receive queue (SRQ) size.
  308. */
  309. struct srpt_port_attrib {
  310. u32 srp_max_rdma_size;
  311. u32 srp_max_rsp_size;
  312. u32 srp_sq_size;
  313. };
  314. /**
  315. * struct srpt_port - Information associated by SRPT with a single IB port.
  316. * @sdev: backpointer to the HCA information.
  317. * @mad_agent: per-port management datagram processing information.
  318. * @enabled: Whether or not this target port is enabled.
  319. * @port_guid: ASCII representation of Port GUID
  320. * @port: one-based port number.
  321. * @sm_lid: cached value of the port's sm_lid.
  322. * @lid: cached value of the port's lid.
  323. * @gid: cached value of the port's gid.
  324. * @port_acl_lock spinlock for port_acl_list:
  325. * @work: work structure for refreshing the aforementioned cached values.
  326. * @port_tpg_1 Target portal group = 1 data.
  327. * @port_wwn: Target core WWN data.
  328. * @port_acl_list: Head of the list with all node ACLs for this port.
  329. */
  330. struct srpt_port {
  331. struct srpt_device *sdev;
  332. struct ib_mad_agent *mad_agent;
  333. bool enabled;
  334. u8 port_guid[64];
  335. u8 port;
  336. u16 sm_lid;
  337. u16 lid;
  338. union ib_gid gid;
  339. spinlock_t port_acl_lock;
  340. struct work_struct work;
  341. struct se_portal_group port_tpg_1;
  342. struct se_wwn port_wwn;
  343. struct list_head port_acl_list;
  344. struct srpt_port_attrib port_attrib;
  345. };
  346. /**
  347. * struct srpt_device - Information associated by SRPT with a single HCA.
  348. * @device: Backpointer to the struct ib_device managed by the IB core.
  349. * @pd: IB protection domain.
  350. * @mr: L_Key (local key) with write access to all local memory.
  351. * @srq: Per-HCA SRQ (shared receive queue).
  352. * @cm_id: Connection identifier.
  353. * @dev_attr: Attributes of the InfiniBand device as obtained during the
  354. * ib_client.add() callback.
  355. * @srq_size: SRQ size.
  356. * @ioctx_ring: Per-HCA SRQ.
  357. * @rch_list: Per-device channel list -- see also srpt_rdma_ch.list.
  358. * @ch_releaseQ: Enables waiting for removal from rch_list.
  359. * @spinlock: Protects rch_list and tpg.
  360. * @port: Information about the ports owned by this HCA.
  361. * @event_handler: Per-HCA asynchronous IB event handler.
  362. * @list: Node in srpt_dev_list.
  363. */
  364. struct srpt_device {
  365. struct ib_device *device;
  366. struct ib_pd *pd;
  367. struct ib_mr *mr;
  368. struct ib_srq *srq;
  369. struct ib_cm_id *cm_id;
  370. struct ib_device_attr dev_attr;
  371. int srq_size;
  372. struct srpt_recv_ioctx **ioctx_ring;
  373. struct list_head rch_list;
  374. wait_queue_head_t ch_releaseQ;
  375. spinlock_t spinlock;
  376. struct srpt_port port[2];
  377. struct ib_event_handler event_handler;
  378. struct list_head list;
  379. };
  380. /**
  381. * struct srpt_node_acl - Per-initiator ACL data (managed via configfs).
  382. * @i_port_id: 128-bit SRP initiator port ID.
  383. * @sport: port information.
  384. * @nacl: Target core node ACL information.
  385. * @list: Element of the per-HCA ACL list.
  386. */
  387. struct srpt_node_acl {
  388. u8 i_port_id[16];
  389. struct srpt_port *sport;
  390. struct se_node_acl nacl;
  391. struct list_head list;
  392. };
  393. /*
  394. * SRP-releated SCSI persistent reservation definitions.
  395. *
  396. * See also SPC4r28, section 7.6.1 (Protocol specific parameters introduction).
  397. * See also SPC4r28, section 7.6.4.5 (TransportID for initiator ports using
  398. * SCSI over an RDMA interface).
  399. */
  400. enum {
  401. SCSI_TRANSPORTID_PROTOCOLID_SRP = 4,
  402. };
  403. struct spc_rdma_transport_id {
  404. uint8_t protocol_identifier;
  405. uint8_t reserved[7];
  406. uint8_t i_port_id[16];
  407. };
  408. #endif /* IB_SRPT_H */