smc_wr.h 3.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  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_MAX_CQE 32768 /* max. # of completion queue elements */
  19. #define SMC_WR_BUF_CNT 16 /* # of ctrl buffers per link */
  20. #define SMC_WR_TX_WAIT_FREE_SLOT_TIME (10 * HZ)
  21. #define SMC_WR_TX_WAIT_PENDING_TIME (5 * HZ)
  22. #define SMC_WR_TX_SIZE 44 /* actual size of wr_send data (<=SMC_WR_BUF_SIZE) */
  23. #define SMC_WR_TX_PEND_PRIV_SIZE 32
  24. struct smc_wr_tx_pend_priv {
  25. u8 priv[SMC_WR_TX_PEND_PRIV_SIZE];
  26. };
  27. typedef void (*smc_wr_tx_handler)(struct smc_wr_tx_pend_priv *,
  28. struct smc_link *,
  29. enum ib_wc_status);
  30. typedef bool (*smc_wr_tx_filter)(struct smc_wr_tx_pend_priv *,
  31. unsigned long);
  32. typedef void (*smc_wr_tx_dismisser)(struct smc_wr_tx_pend_priv *);
  33. struct smc_wr_rx_handler {
  34. struct hlist_node list; /* hash table collision resolution */
  35. void (*handler)(struct ib_wc *, void *);
  36. u8 type;
  37. };
  38. /* Only used by RDMA write WRs.
  39. * All other WRs (CDC/LLC) use smc_wr_tx_send handling WR_ID implicitly
  40. */
  41. static inline long smc_wr_tx_get_next_wr_id(struct smc_link *link)
  42. {
  43. return atomic_long_inc_return(&link->wr_tx_id);
  44. }
  45. static inline void smc_wr_tx_set_wr_id(atomic_long_t *wr_tx_id, long val)
  46. {
  47. atomic_long_set(wr_tx_id, val);
  48. }
  49. /* post a new receive work request to fill a completed old work request entry */
  50. static inline int smc_wr_rx_post(struct smc_link *link)
  51. {
  52. struct ib_recv_wr *bad_recv_wr = NULL;
  53. int rc;
  54. u64 wr_id, temp_wr_id;
  55. u32 index;
  56. wr_id = ++link->wr_rx_id; /* tasklet context, thus not atomic */
  57. temp_wr_id = wr_id;
  58. index = do_div(temp_wr_id, link->wr_rx_cnt);
  59. link->wr_rx_ibs[index].wr_id = wr_id;
  60. rc = ib_post_recv(link->roce_qp, &link->wr_rx_ibs[index], &bad_recv_wr);
  61. return rc;
  62. }
  63. int smc_wr_create_link(struct smc_link *lnk);
  64. int smc_wr_alloc_link_mem(struct smc_link *lnk);
  65. void smc_wr_free_link(struct smc_link *lnk);
  66. void smc_wr_free_link_mem(struct smc_link *lnk);
  67. void smc_wr_remember_qp_attr(struct smc_link *lnk);
  68. void smc_wr_remove_dev(struct smc_ib_device *smcibdev);
  69. void smc_wr_add_dev(struct smc_ib_device *smcibdev);
  70. int smc_wr_tx_get_free_slot(struct smc_link *link, smc_wr_tx_handler handler,
  71. struct smc_wr_buf **wr_buf,
  72. struct smc_wr_tx_pend_priv **wr_pend_priv);
  73. int smc_wr_tx_put_slot(struct smc_link *link,
  74. struct smc_wr_tx_pend_priv *wr_pend_priv);
  75. int smc_wr_tx_send(struct smc_link *link,
  76. struct smc_wr_tx_pend_priv *wr_pend_priv);
  77. void smc_wr_tx_cq_handler(struct ib_cq *ib_cq, void *cq_context);
  78. bool smc_wr_tx_has_pending(struct smc_link *link, u8 wr_rx_hdr_type,
  79. smc_wr_tx_filter filter, unsigned long data);
  80. void smc_wr_tx_dismiss_slots(struct smc_link *lnk, u8 wr_rx_hdr_type,
  81. smc_wr_tx_filter filter,
  82. smc_wr_tx_dismisser dismisser,
  83. unsigned long data);
  84. int smc_wr_rx_register_handler(struct smc_wr_rx_handler *handler);
  85. int smc_wr_rx_post_init(struct smc_link *link);
  86. void smc_wr_rx_cq_handler(struct ib_cq *ib_cq, void *cq_context);
  87. int smc_wr_reg_send(struct smc_link *link, struct ib_mr *mr);
  88. #endif /* SMC_WR_H */