verbs.h 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458
  1. /*
  2. * Copyright(c) 2015 - 2017 Intel Corporation.
  3. *
  4. * This file is provided under a dual BSD/GPLv2 license. When using or
  5. * redistributing this file, you may do so under either license.
  6. *
  7. * GPL LICENSE SUMMARY
  8. *
  9. * This program is free software; you can redistribute it and/or modify
  10. * it under the terms of version 2 of the GNU General Public License as
  11. * published by the Free Software Foundation.
  12. *
  13. * This program is distributed in the hope that it will be useful, but
  14. * WITHOUT ANY WARRANTY; without even the implied warranty of
  15. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  16. * General Public License for more details.
  17. *
  18. * BSD LICENSE
  19. *
  20. * Redistribution and use in source and binary forms, with or without
  21. * modification, are permitted provided that the following conditions
  22. * are met:
  23. *
  24. * - Redistributions of source code must retain the above copyright
  25. * notice, this list of conditions and the following disclaimer.
  26. * - Redistributions in binary form must reproduce the above copyright
  27. * notice, this list of conditions and the following disclaimer in
  28. * the documentation and/or other materials provided with the
  29. * distribution.
  30. * - Neither the name of Intel Corporation nor the names of its
  31. * contributors may be used to endorse or promote products derived
  32. * from this software without specific prior written permission.
  33. *
  34. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  35. * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  36. * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  37. * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  38. * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  39. * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  40. * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  41. * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  42. * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  43. * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  44. * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  45. *
  46. */
  47. #ifndef HFI1_VERBS_H
  48. #define HFI1_VERBS_H
  49. #include <linux/types.h>
  50. #include <linux/seqlock.h>
  51. #include <linux/kernel.h>
  52. #include <linux/interrupt.h>
  53. #include <linux/kref.h>
  54. #include <linux/workqueue.h>
  55. #include <linux/kthread.h>
  56. #include <linux/completion.h>
  57. #include <linux/slab.h>
  58. #include <rdma/ib_pack.h>
  59. #include <rdma/ib_user_verbs.h>
  60. #include <rdma/ib_mad.h>
  61. #include <rdma/ib_hdrs.h>
  62. #include <rdma/rdma_vt.h>
  63. #include <rdma/rdmavt_qp.h>
  64. #include <rdma/rdmavt_cq.h>
  65. struct hfi1_ctxtdata;
  66. struct hfi1_pportdata;
  67. struct hfi1_devdata;
  68. struct hfi1_packet;
  69. #include "iowait.h"
  70. #define HFI1_MAX_RDMA_ATOMIC 16
  71. #define HFI1_GUIDS_PER_PORT 5
  72. /*
  73. * Increment this value if any changes that break userspace ABI
  74. * compatibility are made.
  75. */
  76. #define HFI1_UVERBS_ABI_VERSION 2
  77. /* IB Performance Manager status values */
  78. #define IB_PMA_SAMPLE_STATUS_DONE 0x00
  79. #define IB_PMA_SAMPLE_STATUS_STARTED 0x01
  80. #define IB_PMA_SAMPLE_STATUS_RUNNING 0x02
  81. /* Mandatory IB performance counter select values. */
  82. #define IB_PMA_PORT_XMIT_DATA cpu_to_be16(0x0001)
  83. #define IB_PMA_PORT_RCV_DATA cpu_to_be16(0x0002)
  84. #define IB_PMA_PORT_XMIT_PKTS cpu_to_be16(0x0003)
  85. #define IB_PMA_PORT_RCV_PKTS cpu_to_be16(0x0004)
  86. #define IB_PMA_PORT_XMIT_WAIT cpu_to_be16(0x0005)
  87. #define HFI1_VENDOR_IPG cpu_to_be16(0xFFA0)
  88. #define IB_DEFAULT_GID_PREFIX cpu_to_be64(0xfe80000000000000ULL)
  89. #define RC_OP(x) IB_OPCODE_RC_##x
  90. #define UC_OP(x) IB_OPCODE_UC_##x
  91. /* flags passed by hfi1_ib_rcv() */
  92. enum {
  93. HFI1_HAS_GRH = (1 << 0),
  94. };
  95. struct hfi1_ahg_info {
  96. u32 ahgdesc[2];
  97. u16 tx_flags;
  98. u8 ahgcount;
  99. u8 ahgidx;
  100. };
  101. struct hfi1_sdma_header {
  102. __le64 pbc;
  103. struct ib_header hdr;
  104. } __packed;
  105. /*
  106. * hfi1 specific data structures that will be hidden from rvt after the queue
  107. * pair is made common
  108. */
  109. struct hfi1_qp_priv {
  110. struct hfi1_ahg_info *s_ahg; /* ahg info for next header */
  111. struct sdma_engine *s_sde; /* current sde */
  112. struct send_context *s_sendcontext; /* current sendcontext */
  113. u8 s_sc; /* SC[0..4] for next packet */
  114. u8 r_adefered; /* number of acks defered */
  115. struct iowait s_iowait;
  116. struct timer_list s_rnr_timer;
  117. struct rvt_qp *owner;
  118. };
  119. /*
  120. * This structure is used to hold commonly lookedup and computed values during
  121. * the send engine progress.
  122. */
  123. struct hfi1_pkt_state {
  124. struct hfi1_ibdev *dev;
  125. struct hfi1_ibport *ibp;
  126. struct hfi1_pportdata *ppd;
  127. struct verbs_txreq *s_txreq;
  128. unsigned long flags;
  129. };
  130. #define HFI1_PSN_CREDIT 16
  131. struct hfi1_opcode_stats {
  132. u64 n_packets; /* number of packets */
  133. u64 n_bytes; /* total number of bytes */
  134. };
  135. struct hfi1_opcode_stats_perctx {
  136. struct hfi1_opcode_stats stats[256];
  137. };
  138. static inline void inc_opstats(
  139. u32 tlen,
  140. struct hfi1_opcode_stats *stats)
  141. {
  142. #ifdef CONFIG_DEBUG_FS
  143. stats->n_bytes += tlen;
  144. stats->n_packets++;
  145. #endif
  146. }
  147. struct hfi1_ibport {
  148. struct rvt_qp __rcu *qp[2];
  149. struct rvt_ibport rvp;
  150. __be64 guids[HFI1_GUIDS_PER_PORT - 1]; /* writable GUIDs */
  151. /* the first 16 entries are sl_to_vl for !OPA */
  152. u8 sl_to_sc[32];
  153. u8 sc_to_sl[32];
  154. };
  155. struct hfi1_ibdev {
  156. struct rvt_dev_info rdi; /* Must be first */
  157. /* QP numbers are shared by all IB ports */
  158. /* protect wait lists */
  159. seqlock_t iowait_lock;
  160. struct list_head txwait; /* list for wait verbs_txreq */
  161. struct list_head memwait; /* list for wait kernel memory */
  162. struct list_head txreq_free;
  163. struct kmem_cache *verbs_txreq_cache;
  164. struct timer_list mem_timer;
  165. u64 n_piowait;
  166. u64 n_piodrain;
  167. u64 n_txwait;
  168. u64 n_kmem_wait;
  169. #ifdef CONFIG_DEBUG_FS
  170. /* per HFI debugfs */
  171. struct dentry *hfi1_ibdev_dbg;
  172. /* per HFI symlinks to above */
  173. struct dentry *hfi1_ibdev_link;
  174. #endif
  175. };
  176. static inline struct hfi1_ibdev *to_idev(struct ib_device *ibdev)
  177. {
  178. struct rvt_dev_info *rdi;
  179. rdi = container_of(ibdev, struct rvt_dev_info, ibdev);
  180. return container_of(rdi, struct hfi1_ibdev, rdi);
  181. }
  182. static inline struct rvt_qp *iowait_to_qp(struct iowait *s_iowait)
  183. {
  184. struct hfi1_qp_priv *priv;
  185. priv = container_of(s_iowait, struct hfi1_qp_priv, s_iowait);
  186. return priv->owner;
  187. }
  188. /*
  189. * Send if not busy or waiting for I/O and either
  190. * a RC response is pending or we can process send work requests.
  191. */
  192. static inline int hfi1_send_ok(struct rvt_qp *qp)
  193. {
  194. return !(qp->s_flags & (RVT_S_BUSY | RVT_S_ANY_WAIT_IO)) &&
  195. (qp->s_hdrwords || (qp->s_flags & RVT_S_RESP_PENDING) ||
  196. !(qp->s_flags & RVT_S_ANY_WAIT_SEND));
  197. }
  198. /*
  199. * This must be called with s_lock held.
  200. */
  201. void hfi1_bad_pqkey(struct hfi1_ibport *ibp, __be16 trap_num, u32 key, u32 sl,
  202. u32 qp1, u32 qp2, u16 lid1, u16 lid2);
  203. void hfi1_cap_mask_chg(struct rvt_dev_info *rdi, u8 port_num);
  204. void hfi1_sys_guid_chg(struct hfi1_ibport *ibp);
  205. void hfi1_node_desc_chg(struct hfi1_ibport *ibp);
  206. int hfi1_process_mad(struct ib_device *ibdev, int mad_flags, u8 port,
  207. const struct ib_wc *in_wc, const struct ib_grh *in_grh,
  208. const struct ib_mad_hdr *in_mad, size_t in_mad_size,
  209. struct ib_mad_hdr *out_mad, size_t *out_mad_size,
  210. u16 *out_mad_pkey_index);
  211. /*
  212. * The PSN_MASK and PSN_SHIFT allow for
  213. * 1) comparing two PSNs
  214. * 2) returning the PSN with any upper bits masked
  215. * 3) returning the difference between to PSNs
  216. *
  217. * The number of significant bits in the PSN must
  218. * necessarily be at least one bit less than
  219. * the container holding the PSN.
  220. */
  221. #ifndef CONFIG_HFI1_VERBS_31BIT_PSN
  222. #define PSN_MASK 0xFFFFFF
  223. #define PSN_SHIFT 8
  224. #else
  225. #define PSN_MASK 0x7FFFFFFF
  226. #define PSN_SHIFT 1
  227. #endif
  228. #define PSN_MODIFY_MASK 0xFFFFFF
  229. /*
  230. * Compare the lower 24 bits of the msn values.
  231. * Returns an integer <, ==, or > than zero.
  232. */
  233. static inline int cmp_msn(u32 a, u32 b)
  234. {
  235. return (((int)a) - ((int)b)) << 8;
  236. }
  237. /*
  238. * Compare two PSNs
  239. * Returns an integer <, ==, or > than zero.
  240. */
  241. static inline int cmp_psn(u32 a, u32 b)
  242. {
  243. return (((int)a) - ((int)b)) << PSN_SHIFT;
  244. }
  245. /*
  246. * Return masked PSN
  247. */
  248. static inline u32 mask_psn(u32 a)
  249. {
  250. return a & PSN_MASK;
  251. }
  252. /*
  253. * Return delta between two PSNs
  254. */
  255. static inline u32 delta_psn(u32 a, u32 b)
  256. {
  257. return (((int)a - (int)b) << PSN_SHIFT) >> PSN_SHIFT;
  258. }
  259. struct verbs_txreq;
  260. void hfi1_put_txreq(struct verbs_txreq *tx);
  261. int hfi1_verbs_send(struct rvt_qp *qp, struct hfi1_pkt_state *ps);
  262. void hfi1_copy_sge(struct rvt_sge_state *ss, void *data, u32 length,
  263. int release, int copy_last);
  264. void hfi1_skip_sge(struct rvt_sge_state *ss, u32 length, int release);
  265. void hfi1_cnp_rcv(struct hfi1_packet *packet);
  266. void hfi1_uc_rcv(struct hfi1_packet *packet);
  267. void hfi1_rc_rcv(struct hfi1_packet *packet);
  268. void hfi1_rc_hdrerr(
  269. struct hfi1_ctxtdata *rcd,
  270. struct ib_header *hdr,
  271. u32 rcv_flags,
  272. struct rvt_qp *qp);
  273. u8 ah_to_sc(struct ib_device *ibdev, struct ib_ah_attr *ah_attr);
  274. struct ib_ah *hfi1_create_qp0_ah(struct hfi1_ibport *ibp, u16 dlid);
  275. void hfi1_rc_rnr_retry(unsigned long arg);
  276. void hfi1_add_rnr_timer(struct rvt_qp *qp, u32 to);
  277. void hfi1_rc_timeout(unsigned long arg);
  278. void hfi1_del_timers_sync(struct rvt_qp *qp);
  279. void hfi1_stop_rc_timers(struct rvt_qp *qp);
  280. void hfi1_rc_send_complete(struct rvt_qp *qp, struct ib_header *hdr);
  281. void hfi1_rc_error(struct rvt_qp *qp, enum ib_wc_status err);
  282. void hfi1_ud_rcv(struct hfi1_packet *packet);
  283. int hfi1_lookup_pkey_idx(struct hfi1_ibport *ibp, u16 pkey);
  284. int hfi1_rvt_get_rwqe(struct rvt_qp *qp, int wr_id_only);
  285. void hfi1_migrate_qp(struct rvt_qp *qp);
  286. int hfi1_check_modify_qp(struct rvt_qp *qp, struct ib_qp_attr *attr,
  287. int attr_mask, struct ib_udata *udata);
  288. void hfi1_modify_qp(struct rvt_qp *qp, struct ib_qp_attr *attr,
  289. int attr_mask, struct ib_udata *udata);
  290. int hfi1_check_send_wqe(struct rvt_qp *qp, struct rvt_swqe *wqe);
  291. extern const u32 rc_only_opcode;
  292. extern const u32 uc_only_opcode;
  293. static inline u8 get_opcode(struct ib_header *h)
  294. {
  295. u16 lnh = be16_to_cpu(h->lrh[0]) & 3;
  296. if (lnh == IB_LNH_IBA_LOCAL)
  297. return be32_to_cpu(h->u.oth.bth[0]) >> 24;
  298. else
  299. return be32_to_cpu(h->u.l.oth.bth[0]) >> 24;
  300. }
  301. int hfi1_ruc_check_hdr(struct hfi1_ibport *ibp, struct ib_header *hdr,
  302. int has_grh, struct rvt_qp *qp, u32 bth0);
  303. u32 hfi1_make_grh(struct hfi1_ibport *ibp, struct ib_grh *hdr,
  304. struct ib_global_route *grh, u32 hwords, u32 nwords);
  305. void hfi1_make_ruc_header(struct rvt_qp *qp, struct ib_other_headers *ohdr,
  306. u32 bth0, u32 bth2, int middle,
  307. struct hfi1_pkt_state *ps);
  308. void _hfi1_do_send(struct work_struct *work);
  309. void hfi1_do_send_from_rvt(struct rvt_qp *qp);
  310. void hfi1_do_send(struct rvt_qp *qp, bool in_thread);
  311. void hfi1_send_complete(struct rvt_qp *qp, struct rvt_swqe *wqe,
  312. enum ib_wc_status status);
  313. void hfi1_send_rc_ack(struct hfi1_ctxtdata *, struct rvt_qp *qp, int is_fecn);
  314. int hfi1_make_rc_req(struct rvt_qp *qp, struct hfi1_pkt_state *ps);
  315. int hfi1_make_uc_req(struct rvt_qp *qp, struct hfi1_pkt_state *ps);
  316. int hfi1_make_ud_req(struct rvt_qp *qp, struct hfi1_pkt_state *ps);
  317. int hfi1_register_ib_device(struct hfi1_devdata *);
  318. void hfi1_unregister_ib_device(struct hfi1_devdata *);
  319. void hfi1_ib_rcv(struct hfi1_packet *packet);
  320. unsigned hfi1_get_npkeys(struct hfi1_devdata *);
  321. int hfi1_verbs_send_dma(struct rvt_qp *qp, struct hfi1_pkt_state *ps,
  322. u64 pbc);
  323. int hfi1_verbs_send_pio(struct rvt_qp *qp, struct hfi1_pkt_state *ps,
  324. u64 pbc);
  325. int hfi1_wss_init(void);
  326. void hfi1_wss_exit(void);
  327. /* platform specific: return the lowest level cache (llc) size, in KiB */
  328. static inline int wss_llc_size(void)
  329. {
  330. /* assume that the boot CPU value is universal for all CPUs */
  331. return boot_cpu_data.x86_cache_size;
  332. }
  333. /* platform specific: cacheless copy */
  334. static inline void cacheless_memcpy(void *dst, void *src, size_t n)
  335. {
  336. /*
  337. * Use the only available X64 cacheless copy. Add a __user cast
  338. * to quiet sparse. The src agument is already in the kernel so
  339. * there are no security issues. The extra fault recovery machinery
  340. * is not invoked.
  341. */
  342. __copy_user_nocache(dst, (void __user *)src, n, 0);
  343. }
  344. extern const enum ib_wc_opcode ib_hfi1_wc_opcode[];
  345. extern const u8 hdr_len_by_opcode[];
  346. extern const int ib_rvt_state_ops[];
  347. extern __be64 ib_hfi1_sys_image_guid; /* in network order */
  348. extern unsigned int hfi1_max_cqes;
  349. extern unsigned int hfi1_max_cqs;
  350. extern unsigned int hfi1_max_qp_wrs;
  351. extern unsigned int hfi1_max_qps;
  352. extern unsigned int hfi1_max_sges;
  353. extern unsigned int hfi1_max_mcast_grps;
  354. extern unsigned int hfi1_max_mcast_qp_attached;
  355. extern unsigned int hfi1_max_srqs;
  356. extern unsigned int hfi1_max_srq_sges;
  357. extern unsigned int hfi1_max_srq_wrs;
  358. extern unsigned short piothreshold;
  359. extern const u32 ib_hfi1_rnr_table[];
  360. #endif /* HFI1_VERBS_H */