Skip to content

Commit

Permalink
Perftest: Query correct RDMA/atomic caps for DC
Browse files Browse the repository at this point in the history
Currently, verbs exposed those caps only for RC,
therefore for DC we need to query it through DEVX.

Without this fix, we use the RC caps for DC QPs, this
cause perfomance degredation in ConnectX-7.

Signed-off-by: Maor Gottlieb <[email protected]>
  • Loading branch information
maorgottlieb authored and HassanKhadour committed Jul 18, 2022
1 parent 3e594ed commit e63987c
Show file tree
Hide file tree
Showing 2 changed files with 48 additions and 7 deletions.
8 changes: 8 additions & 0 deletions configure.ac
Original file line number Diff line number Diff line change
Expand Up @@ -142,6 +142,14 @@ AC_TRY_LINK([
[int x = MLX5DV_QP_INIT_ATTR_MASK_QP_CREATE_FLAGS;],[HAVE_MLX5DV=yes], [HAVE_MLX5DV=no])
AM_CONDITIONAL([HAVE_MLX5DV],[test "x$HAVE_MLX5DV" = "xyes"])

AC_TRY_LINK([
#include <infiniband/mlx5dv.h>],
[int x = __devx_dw_off(32);],[HAVE_MLX5_DEVX=yes], [HAVE_MLX5_DEVX=no])
AM_CONDITIONAL([HAVE_MLX5_DEVX],[test "x$HAVE_MLX5_DEVX" = "xyes"])
if [test $HAVE_MLX5_DEVX = yes] && [test $HAVE_MLX5DV = yes]; then
AC_DEFINE([HAVE_MLX5_DEVX], [1], [Have MLX5 DEVX support])
fi

AC_TRY_LINK([
#include <infiniband/mlx5dv.h>],
[int x = MLX5DV_QP_INIT_ATTR_MASK_DCI_STREAMS;],[HAVE_DCS=yes], [HAVE_DCS=no])
Expand Down
47 changes: 40 additions & 7 deletions src/perftest_parameters.c
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@
#include <sys/stat.h>
#endif
#include "perftest_parameters.h"
#include "mlx5_devx.h"
#include "raw_ethernet_resources.h"
#include<math.h>
#ifdef HAVE_RO
Expand Down Expand Up @@ -1974,17 +1975,49 @@ static int set_link_layer(struct ibv_context *context, struct perftest_parameter
return SUCCESS;
}

static int get_device_max_reads_dc(struct ibv_context *context)
{
#ifdef HAVE_MLX5_DEVX
uint32_t in[DEVX_ST_SZ_DW(query_hca_cap_in)] = {};
uint32_t out[DEVX_ST_SZ_DW(query_hca_cap_out)] = {};
uint16_t opmod = HCA_CAP_OPMOD_GET_CUR;
int ret;

DEVX_SET(query_hca_cap_in, in, opcode, MLX5_CMD_OP_QUERY_HCA_CAP);
DEVX_SET(query_hca_cap_in, in, op_mod, opmod);

ret = mlx5dv_devx_general_cmd(context, in, sizeof(in), out,
sizeof(out));
if (!ret)
return (1 << DEVX_GET(query_hca_cap_out, out,
cmd_hca_cap.log_max_ra_req_dc));
#endif
return 0;
}

static int get_device_max_reads(struct ibv_context *context,
struct perftest_parameters *user_param)
{
struct ibv_device_attr attr;
int max_reads = 0;

if (user_param->connection_type == DC)
max_reads = get_device_max_reads_dc(context);
if (!max_reads && !ibv_query_device(context,&attr))
max_reads = attr.max_qp_rd_atom;
return max_reads;
}

/******************************************************************************
*
******************************************************************************/
static int ctx_set_out_reads(struct ibv_context *context,int num_user_reads)
static int ctx_set_out_reads(struct ibv_context *context,
struct perftest_parameters *user_param)
{
int max_reads = 0;
struct ibv_device_attr attr;
int num_user_reads = user_param->out_reads;

if (!ibv_query_device(context,&attr)) {
max_reads = attr.max_qp_rd_atom;
}
max_reads = get_device_max_reads(context, user_param);

if (num_user_reads > max_reads) {
printf(RESULT_LINE);
Expand Down Expand Up @@ -3043,7 +3076,7 @@ int check_link_and_mtu(struct ibv_context *context,struct perftest_parameters *u
ctx_set_max_inline(context,user_param);

if (user_param->verb == READ || user_param->verb == ATOMIC)
user_param->out_reads = ctx_set_out_reads(context,user_param->out_reads);
user_param->out_reads = ctx_set_out_reads(context,user_param);
else
user_param->out_reads = 1;

Expand Down Expand Up @@ -3109,7 +3142,7 @@ int check_link(struct ibv_context *context,struct perftest_parameters *user_para
ctx_set_max_inline(context,user_param);

if (user_param->verb == READ || user_param->verb == ATOMIC)
user_param->out_reads = ctx_set_out_reads(context,user_param->out_reads);
user_param->out_reads = ctx_set_out_reads(context,user_param);
else
user_param->out_reads = 1;

Expand Down

0 comments on commit e63987c

Please sign in to comment.