smc_wr.h 3.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131
  1. /* SPDX-License-Identifier: GPL-2.0 */
  2. /*
  3. * Shared Memory Communications over RDMA (SMC-R) and RoCE
  4. *
  5. * Work Requests exploiting Infiniband API
  6. *
  7. * Copyright IBM Corp. 2016
  8. *
  9. * Author(s): Steffen Maier <maier@linux.vnet.ibm.com>
  10. */
  11. #ifndef SMC_WR_H
  12. #define SMC_WR_H
  13. #include <linux/atomic.h>
  14. #include <rdma/ib_verbs.h>
  15. #include <asm/div64.h>
  16. #include "smc.h"
  17. #include "smc_core.h"
  18. #define SMC_WR_BUF_CNT 16 /* # of ctrl buffers per link */
  19. #define SMC_WR_TX_WAIT_FREE_SLOT_TIME (10 * HZ)
  20. #define SMC_WR_TX_SIZE 44 /* actual size of wr_send data (<=SMC_WR_BUF_SIZE) */
  21. #define SMC_WR_TX_PEND_PRIV_SIZE 32
  22. struct smc_wr_tx_pend_priv {
  23. u8 priv[SMC_WR_TX_PEND_PRIV_SIZE];
  24. };
  25. typedef void (*smc_wr_tx_handler)(struct smc_wr_tx_pend_priv *,
  26. struct smc_link *,
  27. enum ib_wc_status);
  28. typedef bool (*smc_wr_tx_filter)(struct smc_wr_tx_pend_priv *,
  29. unsigned long);
  30. typedef void (*smc_wr_tx_dismisser)(struct smc_wr_tx_pend_priv *);
  31. struct smc_wr_rx_handler {
  32. struct hlist_node list; /* hash table collision resolution */
  33. void (*handler)(struct ib_wc *, void *);
  34. u8 type;
  35. };
  36. /* Only used by RDMA write WRs.
  37. * All other WRs (CDC/LLC) use smc_wr_tx_send handling WR_ID implicitly
  38. */
  39. static inline long smc_wr_tx_get_next_wr_id(struct smc_link *link)
  40. {
  41. return atomic_long_inc_return(&link->wr_tx_id);
  42. }
  43. static inline void smc_wr_tx_set_wr_id(atomic_long_t *wr_tx_id, long val)
  44. {
  45. atomic_long_set(wr_tx_id, val);
  46. }
  47. static inline bool smc_wr_tx_link_hold(struct smc_link *link)
  48. {
  49. if (!smc_link_sendable(link))
  50. return false;
  51. atomic_inc(&link->wr_tx_refcnt);
  52. return true;
  53. }
  54. static inline void smc_wr_tx_link_put(struct smc_link *link)
  55. {
  56. if (atomic_dec_and_test(&link->wr_tx_refcnt))
  57. wake_up_all(&link->wr_tx_wait);
  58. }
  59. static inline void smc_wr_wakeup_tx_wait(struct smc_link *lnk)
  60. {
  61. wake_up_all(&lnk->wr_tx_wait);
  62. }
  63. static inline void smc_wr_wakeup_reg_wait(struct smc_link *lnk)
  64. {
  65. wake_up(&lnk->wr_reg_wait);
  66. }
  67. /* post a new receive work request to fill a completed old work request entry */
  68. static inline int smc_wr_rx_post(struct smc_link *link)
  69. {
  70. int rc;
  71. u64 wr_id, temp_wr_id;
  72. u32 index;
  73. wr_id = ++link->wr_rx_id; /* tasklet context, thus not atomic */
  74. temp_wr_id = wr_id;
  75. index = do_div(temp_wr_id, link->wr_rx_cnt);
  76. link->wr_rx_ibs[index].wr_id = wr_id;
  77. rc = ib_post_recv(link->roce_qp, &link->wr_rx_ibs[index], NULL);
  78. return rc;
  79. }
  80. int smc_wr_create_link(struct smc_link *lnk);
  81. int smc_wr_alloc_link_mem(struct smc_link *lnk);
  82. void smc_wr_free_link(struct smc_link *lnk);
  83. void smc_wr_free_link_mem(struct smc_link *lnk);
  84. void smc_wr_remember_qp_attr(struct smc_link *lnk);
  85. void smc_wr_remove_dev(struct smc_ib_device *smcibdev);
  86. void smc_wr_add_dev(struct smc_ib_device *smcibdev);
  87. int smc_wr_tx_get_free_slot(struct smc_link *link, smc_wr_tx_handler handler,
  88. struct smc_wr_buf **wr_buf,
  89. struct smc_rdma_wr **wrs,
  90. struct smc_wr_tx_pend_priv **wr_pend_priv);
  91. int smc_wr_tx_put_slot(struct smc_link *link,
  92. struct smc_wr_tx_pend_priv *wr_pend_priv);
  93. int smc_wr_tx_send(struct smc_link *link,
  94. struct smc_wr_tx_pend_priv *wr_pend_priv);
  95. int smc_wr_tx_send_wait(struct smc_link *link, struct smc_wr_tx_pend_priv *priv,
  96. unsigned long timeout);
  97. void smc_wr_tx_cq_handler(struct ib_cq *ib_cq, void *cq_context);
  98. void smc_wr_tx_dismiss_slots(struct smc_link *lnk, u8 wr_rx_hdr_type,
  99. smc_wr_tx_filter filter,
  100. smc_wr_tx_dismisser dismisser,
  101. unsigned long data);
  102. void smc_wr_tx_wait_no_pending_sends(struct smc_link *link);
  103. int smc_wr_rx_register_handler(struct smc_wr_rx_handler *handler);
  104. int smc_wr_rx_post_init(struct smc_link *link);
  105. void smc_wr_rx_cq_handler(struct ib_cq *ib_cq, void *cq_context);
  106. int smc_wr_reg_send(struct smc_link *link, struct ib_mr *mr);
  107. #endif /* SMC_WR_H */