@@ -2469,12 +2469,30 @@ ssize_t ib_uverbs_destroy_qp(struct ib_uverbs_file *file,
return in_len;
}
-static void *alloc_wr(size_t wr_size, __u32 num_sge)
+static void *alloc_wr(struct ib_qp *qp, size_t wr_size, __u32 num_sge)
{
- return kmalloc(ALIGN(wr_size, sizeof (struct ib_sge)) +
- num_sge * sizeof (struct ib_sge), GFP_KERNEL);
+ void *wr;
+ size_t xrc_ext = qp->qp_type == IB_QPT_XRC_INI ?
+ sizeof(struct ib_xrc_wr) - sizeof(struct ib_send_wr) :
+ 0;
+
+ wr = kmalloc(ALIGN(wr_size + xrc_ext, sizeof (struct ib_sge)) +
+ num_sge * sizeof (struct ib_sge), GFP_KERNEL);
+ if (unlikely(!wr))
+ return wr;
+
+ return wr + xrc_ext;
};
+static void free_wr(struct ib_qp *qp, struct ib_send_wr *wr)
+{
+ void *d;
+ if (unlikely(!wr))
+ return;
+ d = qp->qp_type == IB_QPT_XRC_INI ? xrc_wr(wr) : (void *)wr;
+ kfree(d);
+}
+
ssize_t ib_uverbs_post_send(struct ib_uverbs_file *file,
struct ib_device *ib_dev,
const char __user *buf, int in_len,
@@ -2509,6 +2527,7 @@ ssize_t ib_uverbs_post_send(struct ib_uverbs_file *file,
goto out;
is_ud = qp->qp_type == IB_QPT_UD;
+
sg_ind = 0;
last = NULL;
for (i = 0; i < cmd.wr_count; ++i) {
@@ -2534,7 +2553,7 @@ ssize_t ib_uverbs_post_send(struct ib_uverbs_file *file,
}
next_size = sizeof(*ud);
- ud = alloc_wr(next_size, user_wr->num_sge);
+ ud = alloc_wr(qp, next_size, user_wr->num_sge);
if (!ud) {
ret = -ENOMEM;
goto out_put;
@@ -2556,7 +2575,7 @@ ssize_t ib_uverbs_post_send(struct ib_uverbs_file *file,
struct ib_rdma_wr *rdma;
next_size = sizeof(*rdma);
- rdma = alloc_wr(next_size, user_wr->num_sge);
+ rdma = alloc_wr(qp, next_size, user_wr->num_sge);
if (!rdma) {
ret = -ENOMEM;
goto out_put;
@@ -2571,7 +2590,7 @@ ssize_t ib_uverbs_post_send(struct ib_uverbs_file *file,
struct ib_atomic_wr *atomic;
next_size = sizeof(*atomic);
- atomic = alloc_wr(next_size, user_wr->num_sge);
+ atomic = alloc_wr(qp, next_size, user_wr->num_sge);
if (!atomic) {
ret = -ENOMEM;
goto out_put;
@@ -2587,7 +2606,7 @@ ssize_t ib_uverbs_post_send(struct ib_uverbs_file *file,
user_wr->opcode == IB_WR_SEND_WITH_IMM ||
user_wr->opcode == IB_WR_SEND_WITH_INV) {
next_size = sizeof(*next);
- next = alloc_wr(next_size, user_wr->num_sge);
+ next = alloc_wr(qp, next_size, user_wr->num_sge);
if (!next) {
ret = -ENOMEM;
goto out_put;
@@ -2605,6 +2624,11 @@ ssize_t ib_uverbs_post_send(struct ib_uverbs_file *file,
next->ex.invalidate_rkey = user_wr->ex.invalidate_rkey;
}
+ if (qp->qp_type == IB_QPT_XRC_INI) {
+ struct ib_xrc_wr *xrc = xrc_wr(next);
+ xrc->remote_srqn = user_wr->xrc_remote_srq_num;
+ }
+
if (!last)
wr = next;
else
@@ -2653,7 +2677,7 @@ out_put:
if (is_ud && ud_wr(wr)->ah)
put_ah_read(ud_wr(wr)->ah);
next = wr->next;
- kfree(wr);
+ free_wr(qp, wr);
wr = next;
}
@@ -1276,6 +1276,18 @@ static inline struct ib_sig_handover_wr *sig_handover_wr(struct ib_send_wr *wr)
return container_of(wr, struct ib_sig_handover_wr, wr);
}
+struct ib_xrc_wr {
+ u32 remote_srqn;
+ u32 reserved1;
+ u64 reserved2;
+ struct ib_send_wr wr;
+};
+
+static inline struct ib_xrc_wr *xrc_wr(struct ib_send_wr *wr)
+{
+ return container_of(wr, struct ib_xrc_wr, wr);
+}
+
struct ib_recv_wr {
struct ib_recv_wr *next;
union {
@@ -725,6 +725,8 @@ struct ib_uverbs_send_wr {
__u32 reserved;
} ud;
} wr;
+ __u32 xrc_remote_srq_num;
+ __u32 reserved;
};
struct ib_uverbs_post_send {
Extends the kernel/user space interface for work requests to also provide the XRC shared receive queue number. Necessary to support kernel level implementation of user verbs for XRC. Requires a corresponding libibverbs change to support XRC. Also fix kernel support for XRC broken by commit "IB: remove xrc_remote_srq_num from struct ib_send_wr" which removed a field needed to support kernel side XRC as part of an effort to trim a work request to sizes dependent of the actual request instead of the union approach. With this commit I try to follow the pattern outlined by that cleanup to also support kernel side XRC. Since XRC attributes are associated with QP type and are (almost) orthogonal to the type of request, the XRC specific attribute(s) would have to be applicable to several different work request type specific subtypes. Since the subtypes have different sizes, putting the xrc specific attributes at the end would require accessor functions and to keep explicit track of the size of the subtype used. The chosen solution is to introduce the xrc specific attributes at the top of the struct instead, this way type checking is taking care of most issues, except that extra care is needed at deallocation time. Note that this requires padding of the xrc specific attributes that matches the size of struct ib_sge, to avoid that the ALIGN() calls used to ensure that the scatter list of the work is aligned does not extend beyond the size of the allocates space: struct ib_xrc_wr { <xrc specific part>; struct ib_send_wr wr; } < subtype extensions will still extend ib_send_wr down here > Signed-off-by: Knut Omang <knut.omang@oracle.com> --- drivers/infiniband/core/uverbs_cmd.c | 40 ++++++++++++++++++++++++++++-------- include/rdma/ib_verbs.h | 12 +++++++++++ include/uapi/rdma/ib_user_verbs.h | 2 ++ 3 files changed, 46 insertions(+), 8 deletions(-)