From: Edward Srouji <edwards@xxxxxxxxxx>
Extend the mlx5 tests' infrastructure to support mlx5 DevX objects
creation.
Add a data path test that creates all the needed resources to be able
to create an RC QP, modify it to RTS state and does SEMD_IMM traffic
over DevX objects.
The tests does validate the data including the received "immediate"
value, and checks the validity of the received CQEs.
Reviewed-by: Ido Kalir <idok@xxxxxxxxxx>
Signed-off-by: Edward Srouji <edwards@xxxxxxxxxx>
---
tests/CMakeLists.txt | 2 +
tests/base.py | 1 +
tests/mlx5_base.py | 460 +++++++++++++++++++-
tests/mlx5_prm_structs.py | 1046 +++++++++++++++++++++++++++++++++++++++++++++
tests/test_mlx5_devx.py | 23 +
5 files changed, 1529 insertions(+), 3 deletions(-)
create mode 100644 tests/mlx5_prm_structs.py
create mode 100644 tests/test_mlx5_devx.py
diff --git a/tests/CMakeLists.txt b/tests/CMakeLists.txt
index 7333f25..7b079d8 100644
--- a/tests/CMakeLists.txt
+++ b/tests/CMakeLists.txt
@@ -8,6 +8,7 @@ rdma_python_test(tests
base_rdmacm.py
efa_base.py
mlx5_base.py
+ mlx5_prm_structs.py
rdmacm_utils.py
test_addr.py
test_cq.py
@@ -20,6 +21,7 @@ rdma_python_test(tests
test_fork.py
test_mlx5_cq.py
test_mlx5_dc.py
+ test_mlx5_devx.py
test_mlx5_dm_ops.py
test_mlx5_dr.py
test_mlx5_flow.py
diff --git a/tests/base.py b/tests/base.py
index f5518d1..e9f36ab 100644
--- a/tests/base.py
+++ b/tests/base.py
@@ -30,6 +30,7 @@ PATH_MTU = e.IBV_MTU_1024
MAX_DEST_RD_ATOMIC = 1
NUM_OF_PROCESSES = 2
MC_IP_PREFIX = '230'
+MAX_RDMA_ATOMIC = 20
MAX_RD_ATOMIC = 1
MIN_RNR_TIMER =12
RETRY_CNT = 7
diff --git a/tests/mlx5_base.py b/tests/mlx5_base.py
index ded4bc1..47e6ebc 100644
--- a/tests/mlx5_base.py
+++ b/tests/mlx5_base.py
@@ -2,20 +2,35 @@
# Copyright (c) 2020 NVIDIA Corporation . All rights reserved. See COPYING file
import unittest
+import resource
import random
+import struct
import errno
+import math
+import time
from pyverbs.providers.mlx5.mlx5dv import Mlx5Context, Mlx5DVContextAttr, \
- Mlx5DVQPInitAttr, Mlx5QP, Mlx5DVDCInitAttr
+ Mlx5DVQPInitAttr, Mlx5QP, Mlx5DVDCInitAttr, Mlx5DevxObj, Mlx5UMEM, Mlx5UAR, \
+ WqeDataSeg, WqeCtrlSeg, Wqe, Mlx5Cqe64
from tests.base import TrafficResources, set_rnr_attributes, DCT_KEY, \
- RDMATestCase, PyverbsAPITestCase, RDMACMBaseTest
-from pyverbs.pyverbs_error import PyverbsRDMAError, PyverbsUserError
+ RDMATestCase, PyverbsAPITestCase, RDMACMBaseTest, BaseResources, PATH_MTU, \
+ RNR_RETRY, RETRY_CNT, MIN_RNR_TIMER, TIMEOUT, MAX_RDMA_ATOMIC
+from pyverbs.pyverbs_error import PyverbsRDMAError, PyverbsUserError, \
+ PyverbsError
+from pyverbs.providers.mlx5.mlx5dv_objects import Mlx5DvObj
from pyverbs.qp import QPCap, QPInitAttrEx, QPAttr
import pyverbs.providers.mlx5.mlx5_enums as dve
from pyverbs.addr import AHAttr, GlobalRoute
+import pyverbs.mem_alloc as mem
+import pyverbs.dma_util as dma
import pyverbs.device as d
+from pyverbs.pd import PD
import pyverbs.enums as e
from pyverbs.mr import MR
+import tests.utils
+
+MLX5_CQ_SET_CI = 0
+POLL_CQ_TIMEOUT = 5 # In seconds
MELLANOX_VENDOR_ID = 0x02c9
@@ -155,3 +170,442 @@ class Mlx5DcResources(TrafficResources):
if ex.error_code == errno.EOPNOTSUPP:
raise unittest.SkipTest(f'Create DC QP is not supported')
raise ex
+
+
+class WqAttrs:
+ def __init__(self):
+ super().__init__()
+ self.wqe_num = 0
+ self.wqe_size = 0
+ self.wq_size = 0
+ self.head = 0
+ self.post_idx = 0
+ self.wqe_shift = 0
+ self.offset = 0
+
+ def __str__(self):
+ return str(vars(self))
+
+ def __format__(self, format_spec):
+ return str(self).__format__(format_spec)
+
+
+class CqAttrs:
+ def __init__(self):
+ super().__init__()
+ self.cons_idx = 0
+ self.cqe_size = 64
+ self.ncqes = 256
+
+ def __str__(self):
+ return str(vars(self))
+
+ def __format__(self, format_spec):
+ return str(self).__format__(format_spec)
+
+
+class QueueAttrs:
+ def __init__(self):
+ self.rq = WqAttrs()
+ self.sq = WqAttrs()
+ self.cq = CqAttrs()
+
+ def __str__(self):
+ print_format = '{}:\n\t{}\n'
+ return print_format.format('RQ Attributes', self.rq) + \
+ print_format.format('SQ Attributes', self.sq) + \
+ print_format.format('CQ Attributes', self.cq)
+
+
+class Mlx5DevxRcResources(BaseResources):
+ """
+ Creates all the DevX resources needed for a traffic-ready RC DevX QP,
+ including methods to transit the WQs into RTS state.
+ It also includes traffic methods for post send/receive and poll.
+ The class currently supports post send with immediate, but can be
+ easily extended to support other opcodes in the future.
+ """
+ def __init__(self, dev_name, ib_port, gid_index, msg_size=1024):
+ super().__init__(dev_name, ib_port, gid_index)
+ self.umems = {}
+ self.msg_size = msg_size
+ self.num_msgs = 1000
+ self.imm = 0x03020100
+ self.uar = {}
+ self.max_recv_sge = 1
+ self.eqn = None
+ self.pd = None
+ self.dv_pd = None
+ self.mr = None
+ self.cq = None
+ self.qp = None
+ self.qpn = None
+ self.psn = None
+ self.lid = None
+ self.gid = [0, 0, 0, 0]
+ # Remote attrs
+ self.rqpn = None
+ self.rpsn = None
+ self.rlid = None
+ self.rgid = [0, 0, 0, 0]
+ self.rmac = None
+ self.devx_objs = []
+ self.qattr = QueueAttrs()
+ self.init_resources()
+
+ def init_resources(self):
+ if not self.is_eth():
+ self.query_lid()
+ else:
+ self.query_gid()
+ self.create_pd()
+ self.create_mr()
+ self.query_eqn()
+ self.create_uar()
+ self.create_queue_attrs()
+ self.create_cq()
+ self.create_qp()
+ # Objects closure order is important, and must be done manually in DevX
+ self.devx_objs = [self.qp, self.cq] + list(self.uar.values()) + list(self.umems.values())
+
+ def query_lid(self):
+ from tests.mlx5_prm_structs import QueryHcaVportContextIn, \
+ QueryHcaVportContextOut, QueryHcaCapIn, QueryCmdHcaCapOut
+
+ query_cap_in = QueryHcaCapIn(op_mod=0x1)
+ query_cap_out = QueryCmdHcaCapOut(self.ctx.devx_general_cmd(
+ query_cap_in, len(QueryCmdHcaCapOut())))
+ if query_cap_out.status:
+ raise PyverbsRDMAError('Failed to query general HCA CAPs with syndrome '
+ f'({query_port_out.syndrome}')
+ port_num = self.ib_port if query_cap_out.capability.num_ports >= 2 else 0
+ query_port_in = QueryHcaVportContextIn(port_num=port_num)
+ query_port_out = QueryHcaVportContextOut(self.ctx.devx_general_cmd(
+ query_port_in, len(QueryHcaVportContextOut())))
+ if query_port_out.status:
+ raise PyverbsRDMAError('Failed to query vport with syndrome '
+ f'({query_port_out.syndrome})')
+ self.lid = query_port_out.hca_vport_context.lid
+
+ def query_gid(self):
+ gid = self.ctx.query_gid(self.ib_port, self.gid_index).gid.split(':')
+ for i in range(0, len(gid), 2):
+ self.gid[int(i/2)] = int(gid[i] + gid[i+1], 16)
+
+ def is_eth(self):
+ from tests.mlx5_prm_structs import QueryHcaCapIn, \
+ QueryCmdHcaCapOut
+
+ query_cap_in = QueryHcaCapIn(op_mod=0x1)
+ query_cap_out = QueryCmdHcaCapOut(self.ctx.devx_general_cmd(
+ query_cap_in, len(QueryCmdHcaCapOut())))
+ if query_cap_out.status:
+ raise PyverbsRDMAError('Failed to query general HCA CAPs with syndrome '
+ f'({query_port_out.syndrome})')
+ return query_cap_out.capability.port_type # 0:IB, 1:ETH
+
+ @staticmethod
+ def roundup_pow_of_two(val):
+ return pow(2, math.ceil(math.log2(val)))
+
+ def create_queue_attrs(self):
+ # RQ calculations
+ wqe_size = WqeDataSeg.sizeof() * self.max_recv_sge
+ self.qattr.rq.wqe_size = self.roundup_pow_of_two(wqe_size)
+ max_recv_wr = self.roundup_pow_of_two(self.num_msgs)
+ self.qattr.rq.wq_size = max(self.qattr.rq.wqe_size * max_recv_wr,
+ dve.MLX5_SEND_WQE_BB)
+ self.qattr.rq.wqe_num = math.ceil(self.qattr.rq.wq_size / self.qattr.rq.wqe_size)
+ self.qattr.rq.wqe_shift = int(math.log2(self.qattr.rq.wqe_size - 1)) + 1
+
+ # SQ calculations
+ self.qattr.sq.offset = self.qattr.rq.wq_size
+ # 192 = max overhead size of all structs needed for all operations in RC
+ wqe_size = 192 + WqeDataSeg.sizeof()
+ # Align wqe size to MLX5_SEND_WQE_BB
+ self.qattr.sq.wqe_size = (wqe_size + dve.MLX5_SEND_WQE_BB - 1) & ~(dve.MLX5_SEND_WQE_BB - 1)
+ self.qattr.sq.wq_size = self.roundup_pow_of_two(self.qattr.sq.wqe_size * self.num_msgs)
+ self.qattr.sq.wqe_num = math.ceil(self.qattr.sq.wq_size / dve.MLX5_SEND_WQE_BB)
+ self.qattr.sq.wqe_shift = int(math.log2(dve.MLX5_SEND_WQE_BB))
+
+ def create_context(self):
+ try:
+ attr = Mlx5DVContextAttr(dve.MLX5DV_CONTEXT_FLAGS_DEVX)
+ self.ctx = Mlx5Context(attr, self.dev_name)
+ except PyverbsUserError as ex:
+ raise unittest.SkipTest(f'Could not open mlx5 context ({ex})')
+ except PyverbsRDMAError:
+ raise unittest.SkipTest('Opening mlx5 DevX context is not supported')
+
+ def create_pd(self):
+ self.pd = PD(self.ctx)
+ self.dv_pd = Mlx5DvObj(dve.MLX5DV_OBJ_PD, pd=self.pd).dvpd
+
+ def create_mr(self):
+ access = e.IBV_ACCESS_REMOTE_WRITE | e.IBV_ACCESS_LOCAL_WRITE | \
+ e.IBV_ACCESS_REMOTE_READ
+ self.mr = MR(self.pd, self.msg_size, access)
+
+ def create_umem(self, size,
+ access=e.IBV_ACCESS_LOCAL_WRITE,
+ alignment=resource.getpagesize()):
+ return Mlx5UMEM(self.ctx, size=size, alignment=alignment, access=access)
+
+ def create_uar(self):
+ self.uar['qp'] = Mlx5UAR(self.ctx, dve._MLX5DV_UAR_ALLOC_TYPE_NC)
+ self.uar['cq'] = Mlx5UAR(self.ctx, dve._MLX5DV_UAR_ALLOC_TYPE_NC)
+ if not self.uar['cq'].page_id or not self.uar['qp'].page_id:
+ raise PyverbsRDMAError('Failed to allocate UAR')
+
+ def query_eqn(self):
+ self.eqn = self.ctx.devx_query_eqn(0)
+
+ def create_cq(self):
+ from tests.mlx5_prm_structs import CreateCqIn, SwCqc, CreateCqOut
+
+ cq_size = self.roundup_pow_of_two(self.qattr.cq.cqe_size * self.qattr.cq.ncqes)
+ # Align to page size
+ pg_size = resource.getpagesize()
+ cq_size = (cq_size + pg_size - 1) & ~(pg_size - 1)
+ self.umems['cq'] = self.create_umem(size=cq_size)
+ self.umems['cq_dbr'] = self.create_umem(size=8, alignment=8)
+ log_cq_size = math.ceil(math.log2(self.qattr.cq.ncqes))
+ cmd_in = CreateCqIn(cq_umem_valid=1, cq_umem_id=self.umems['cq'].umem_id,
+ sw_cqc=SwCqc(c_eqn=self.eqn, uar_page=self.uar['cq'].page_id,
+ log_cq_size=log_cq_size, dbr_umem_valid=1,
+ dbr_umem_id=self.umems['cq_dbr'].umem_id))
+ self.cq = Mlx5DevxObj(self.ctx, cmd_in, len(CreateCqOut()))
+
+ def create_qp(self):
+ self.psn = random.getrandbits(24)
+ from tests.mlx5_prm_structs import SwQpc, CreateQpIn, DevxOps,\
+ CreateQpOut, CreateCqOut
+
+ self.psn = random.getrandbits(24)
+ qp_size = self.roundup_pow_of_two(self.qattr.rq.wq_size + self.qattr.sq.wq_size)
+ # Align to page size
+ pg_size = resource.getpagesize()
+ qp_size = (qp_size + pg_size - 1) & ~(pg_size - 1)
+ self.umems['qp'] = self.create_umem(size=qp_size)
+ self.umems['qp_dbr'] = self.create_umem(size=8, alignment=8)
+ log_rq_size = int(math.log2(self.qattr.rq.wqe_num - 1)) + 1
+ # Size of a receive WQE is 16*pow(2, log_rq_stride)
+ log_rq_stride = self.qattr.rq.wqe_shift - 4
+ log_sq_size = int(math.log2(self.qattr.sq.wqe_num - 1)) + 1
+ cqn = CreateCqOut(self.cq.out_view).cqn
+ qpc = SwQpc(st=DevxOps.MLX5_QPC_ST_RC, pd=self.dv_pd.pdn,
+ pm_state=DevxOps.MLX5_QPC_PM_STATE_MIGRATED,
+ log_rq_size=log_rq_size, log_sq_size=log_sq_size, ts_format=0x1,
+ log_rq_stride=log_rq_stride, uar_page=self.uar['qp'].page_id,
+ cqn_snd=cqn, cqn_rcv=cqn, dbr_umem_id=self.umems['qp_dbr'].umem_id,
+ dbr_umem_valid=1)
+ cmd_in = CreateQpIn(sw_qpc=qpc, wq_umem_id=self.umems['qp'].umem_id,
+ wq_umem_valid=1)
+ self.qp = Mlx5DevxObj(self.ctx, cmd_in, len(CreateQpOut()))
+ self.qpn = CreateQpOut(self.qp.out_view).qpn
+
+ def to_rts(self):
+ """
+ Moves the created QP to RTS state by modifying it using DevX through all
+ the needed states with all the required attributes.
+ rlid, rpsn, rqpn and rgid (when valid) must be already updated before
+ calling this method.
+ """
+ from tests.mlx5_prm_structs import DevxOps, ModifyQpIn, ModifyQpOut,\
+ CreateQpOut, SwQpc
+ cmd_out_len = len(ModifyQpOut())
+
+ # RST2INIT
+ qpn = CreateQpOut(self.qp.out_view).qpn
+ swqpc = SwQpc(rre=1, rwe=1)
+ swqpc.primary_address_path.vhca_port_num = self.ib_port
+ cmd_in = ModifyQpIn(opcode=DevxOps.MLX5_CMD_OP_RST2INIT_QP, qpn=qpn,
+ sw_qpc=swqpc)
+ self.qp.modify(cmd_in, cmd_out_len)
+
+ # INIT2RTR
+ swqpc = SwQpc(mtu=PATH_MTU, log_msg_max=20, remote_qpn=self.rqpn,
+ min_rnr_nak=MIN_RNR_TIMER, next_rcv_psn=self.rpsn)
+ swqpc.primary_address_path.vhca_port_num = self.ib_port
+ swqpc.primary_address_path.rlid = self.rlid
+ if self.is_eth():
+ # GID field is a must for Eth (or if GRH is set in IB)
+ swqpc.primary_address_path.rgid_rip = self.rgid
+ swqpc.primary_address_path.rmac = self.rmac
+ swqpc.primary_address_path.src_addr_index = self.gid_index
+ swqpc.primary_address_path.hop_limit = tests.utils.PacketConsts.TTL_HOP_LIMIT
+ # UDP sport must be reserved for roce v1 and v1.5
+ if self.ctx.query_gid_type(self.ib_port, self.gid_index) == e.IBV_GID_TYPE_SYSFS_ROCE_V2:
+ swqpc.primary_address_path.udp_sport = 0xdcba
+ else:
+ swqpc.primary_address_path.rlid = self.rlid
+ cmd_in = ModifyQpIn(opcode=DevxOps.MLX5_CMD_OP_INIT2RTR_QP, qpn=qpn,
+ sw_qpc=swqpc)
+ self.qp.modify(cmd_in, cmd_out_len)
+
+ # RTR2RTS
+ swqpc = SwQpc(retry_count=RETRY_CNT, rnr_retry=RNR_RETRY,
+ next_send_psn=self.psn, log_sra_max=MAX_RDMA_ATOMIC)
+ swqpc.primary_address_path.vhca_port_num = self.ib_port
+ swqpc.primary_address_path.ack_timeout = TIMEOUT
+ cmd_in = ModifyQpIn(opcode=DevxOps.MLX5_CMD_OP_RTR2RTS_QP, qpn=qpn,
+ sw_qpc=swqpc)
+ self.qp.modify(cmd_in, cmd_out_len)
+
+ def pre_run(self, rpsn, rqpn, rgid=0, rlid=0, rmac=0):
+ """
+ Configure Resources before running traffic
+ :param rpsns: Remote PSN (packet serial number)
+ :param rqpn: Remote QP number
+ :param rgid: Remote GID
+ :param rlid: Remote LID
+ :param rmac: Remote MAC (valid for RoCE)
+ :return: None
+ """
+ self.rpsn = rpsn
+ self.rqpn = rqpn
+ self.rgid = rgid
+ self.rlid = rlid
+ self.rmac = rmac
+ self.to_rts()
+
+ def post_send(self):
+ """
+ Posts one send WQE to the SQ by doing all the required work such as
+ building the control/data segments, updating and ringing the dbr,
+ updating the producer indexes, etc.
+ """
+ idx = self.qattr.sq.post_idx if self.qattr.sq.post_idx < self.qattr.sq.wqe_num else 0
+ buf_offset = self.qattr.sq.offset + (idx << dve.MLX5_SEND_WQE_SHIFT)
+ # Prepare WQE
+ imm_be32 = struct.unpack("<I", struct.pack(">I", self.imm + self.qattr.sq.post_idx))[0]
+ ctrl_seg = WqeCtrlSeg(imm=imm_be32, fm_ce_se=dve.MLX5_WQE_CTRL_CQ_UPDATE)
+ data_seg = WqeDataSeg(self.mr.length, self.mr.lkey, self.mr.buf)
+ ctrl_seg.opmod_idx_opcode = (self.qattr.sq.post_idx & 0xffff) << 8 | dve.MLX5_OPCODE_SEND_IMM
+ size_in_octowords = int((ctrl_seg.sizeof() + data_seg.sizeof()) / 16)
+ ctrl_seg.qpn_ds = self.qpn << 8 | size_in_octowords
+ Wqe([ctrl_seg, data_seg], self.umems['qp'].umem_addr + buf_offset)
+ self.qattr.sq.post_idx += int((size_in_octowords * 16 +
+ dve.MLX5_SEND_WQE_BB - 1) / dve.MLX5_SEND_WQE_BB)
+ # Make sure descriptors are written
+ dma.udma_to_dev_barrier()
+ # Update the doorbell record
+ mem.writebe32(self.umems['qp_dbr'].umem_addr,
+ self.qattr.sq.post_idx & 0xffff, dve.MLX5_SND_DBR)
+ dma.udma_to_dev_barrier()
+ # Ring the doorbell and post the WQE
+ dma.mmio_write64_as_be(self.uar['qp'].reg_addr, mem.read64(ctrl_seg.addr))
+
+ def post_recv(self):
+ """
+ Posts one receive WQE to the RQ by doing all the required work such as
+ building the control/data segments, updating the dbr and the producer
+ indexes.
+ """
+ buf_offset = self.qattr.rq.offset + self.qattr.rq.wqe_size * self.qattr.rq.head
+ # Prepare WQE
+ data_seg = WqeDataSeg(self.mr.length, self.mr.lkey, self.mr.buf)
+ Wqe([data_seg], self.umems['qp'].umem_addr + buf_offset)
+ # Update indexes
+ self.qattr.rq.post_idx += 1
+ self.qattr.rq.head = self.qattr.rq.head + 1 if self.qattr.rq.head + 1 < self.qattr.rq.wqe_num else 0
+ # Update the doorbell record
+ dma.udma_to_dev_barrier()
+ mem.writebe32(self.umems['qp_dbr'].umem_addr,
+ self.qattr.rq.post_idx & 0xffff, dve.MLX5_RCV_DBR)
+
+ def poll_cq(self):
+ """
+ Polls the CQ once and updates the consumer index upon success.
+ The CQE opcode and owner bit are checked and verified.
+ This method does busy-waiting as long as it gets an empty CQE, until a
+ timeout of POLL_CQ_TIMEOUT seconds.
+ """
+ idx = self.qattr.cq.cons_idx % self.qattr.cq.ncqes
+ cq_owner_flip = not(not(self.qattr.cq.cons_idx & self.qattr.cq.ncqes))
+ cqe_start_addr = self.umems['cq'].umem_addr + (idx * self.qattr.cq.cqe_size)
+ cqe = None
+ start_poll_t = time.perf_counter()
+ while cqe is None:
+ cqe = Mlx5Cqe64(cqe_start_addr)
+ if (cqe.opcode == dve.MLX5_CQE_INVALID) or \
+ (cqe.owner ^ cq_owner_flip) or cqe.is_empty():
+ if time.perf_counter() - start_poll_t >= POLL_CQ_TIMEOUT:
+ raise PyverbsRDMAError(f'CQE #{self.qattr.cq.cons_idx} '
+ f'is empty or invalid:\n{cqe.dump()}')
+ cqe = None
+
+ # After CQE ownership check, must do memory barrier and re-read the CQE.
+ dma.udma_from_dev_barrier()
+ cqe = Mlx5Cqe64(cqe_start_addr)
+
+ if cqe.opcode == dve.MLX5_CQE_RESP_ERR:
+ raise PyverbsRDMAError(f'Got a CQE #{self.qattr.cq.cons_idx} '
+ f'with responder error:\n{cqe.dump()}')
+ elif cqe.opcode == dve.MLX5_CQE_REQ_ERR:
+ raise PyverbsRDMAError(f'Got a CQE #{self.qattr.cq.cons_idx} '
+ f'with requester error:\n{cqe.dump()}')
+
+ self.qattr.cq.cons_idx += 1
+ mem.writebe32(self.umems['cq_dbr'].umem_addr,
+ self.qattr.cq.cons_idx & 0xffffff, MLX5_CQ_SET_CI)
+ return cqe
+
+ def close_resources(self):
+ for obj in self.devx_objs:
+ if obj:
+ obj.close()
+
+
+class Mlx5DevxTrafficBase(Mlx5RDMATestCase):
+ """
+ A base class for mlx5 DevX traffic tests.
+ This class does not include any tests, but provides quick players (client,
+ server) creation and provides a traffic method.
+ """
+ def tearDown(self):
+ if self.server:
+ self.server.close_resources()
+ if self.client:
+ self.client.close_resources()
+ super().tearDown()
+
+ def create_players(self, resources, **resource_arg):
+ """
+ Initialize tests resources.
+ :param resources: The RDMA resources to use.
+ :param resource_arg: Dictionary of args that specify the resources
+ specific attributes.
+ :return: None
+ """
+ self.server = resources(**self.dev_info, **resource_arg)
+ self.client = resources(**self.dev_info, **resource_arg)
+ self.pre_run()
+
+ def pre_run(self):
+ self.server.pre_run(self.client.psn, self.client.qpn, self.client.gid,
+ self.client.lid, self.mac_addr)
+ self.client.pre_run(self.server.psn, self.server.qpn, self.server.gid,
+ self.server.lid, self.mac_addr)
+
+ def send_imm_traffic(self):
+ self.client.mr.write('c' * self.client.msg_size, self.client.msg_size)
+ for _ in range(self.client.num_msgs):
+ cons_idx = self.client.qattr.cq.cons_idx
+ self.server.post_recv()
+ self.client.post_send()
+ # Poll client and verify received cqe opcode
+ send_cqe = self.client.poll_cq()
+ self.assertEqual(send_cqe.opcode, dve.MLX5_CQE_REQ,
+ 'Unexpected CQE opcode')
+ # Poll server and verify received cqe opcode
+ recv_cqe = self.server.poll_cq()
+ self.assertEqual(recv_cqe.opcode, dve.MLX5_CQE_RESP_SEND_IMM,
+ 'Unexpected CQE opcode')
+ msg_received = self.server.mr.read(self.server.msg_size, 0)
+ # Validate data (of received message and immediate value)
+ tests.utils.validate(msg_received, True, self.server.msg_size)
+ self.assertEqual(recv_cqe.imm_inval_pkey,
+ self.client.imm + cons_idx)
+ self.server.mr.write('s' * self.server.msg_size,
+ self.server.msg_size)
diff --git a/tests/mlx5_prm_structs.py b/tests/mlx5_prm_structs.py
new file mode 100644
index 0000000..1999a3b
--- /dev/null
+++ b/tests/mlx5_prm_structs.py
@@ -0,0 +1,1046 @@
+# SPDX-License-Identifier: (GPL-2.0 OR Linux-OpenIB)
+# Copyright (c) 2021 Nvidia Inc. All rights reserved. See COPYING file
+
+"""
+This module provides scapy based classes that represent the mlx5 PRM structs.
+"""
+import unittest
+
+try:
+ import logging
+ logging.getLogger("scapy.runtime").setLevel(logging.ERROR)
+ from scapy.packet import Packet
+ from scapy.fields import BitField, ByteField, IntField, \
+ ShortField, LongField, StrFixedLenField, PacketField, \
+ PacketListField, ConditionalField, PadField, FieldListField, MACField
+except ImportError:
+ raise unittest.SkipTest('scapy package is needed in order to run DevX tests')
+
+
+class DevxOps:
+ MLX5_CMD_OP_ALLOC_PD = 0x800
+ MLX5_CMD_OP_CREATE_CQ = 0x400
+ MLX5_CMD_OP_QUERY_CQ = 0x402
+ MLX5_CMD_OP_MODIFY_CQ = 0x403
+ MLX5_CMD_OP_CREATE_QP = 0x500
+ MLX5_CMD_OP_QUERY_QP = 0x50b
+ MLX5_CMD_OP_RST2INIT_QP = 0x502
+ MLX5_CMD_OP_INIT2RTR_QP = 0x503
+ MLX5_CMD_OP_RTR2RTS_QP = 0x504
+ MLX5_CMD_OP_RTS2RTS_QP = 0x505
+ MLX5_CMD_OP_QUERY_HCA_VPORT_CONTEXT = 0x762
+ MLX5_CMD_OP_QUERY_HCA_VPORT_GID = 0x764
+ MLX5_QPC_ST_RC = 0X0
+ MLX5_QPC_PM_STATE_MIGRATED = 0x3
+ MLX5_CMD_OP_QUERY_HCA_CAP = 0x100
+
+
+# Common
+class SwPas(Packet):
+ fields_desc = [
+ IntField('pa_h', 0),
+ BitField('pa_l', 0, 20),
+ BitField('reserved1', 0, 12),
+ ]
+
+
+# PD
+class AllocPdIn(Packet):
+ fields_desc = [
+ ShortField('opcode', DevxOps.MLX5_CMD_OP_ALLOC_PD),
+ ShortField('uid', 0),
+ ShortField('reserved1', 0),
+ ShortField('op_mod', 0),
+ StrFixedLenField('reserved2', None, length=8),
+ ]
+
+
+class AllocPdOut(Packet):
+ fields_desc = [
+ ByteField('status', 0),
+ BitField('reserved1', 0, 24),
+ IntField('syndrome', 0),
+ ByteField('reserved2', 0),
+ BitField('pd', 0, 24),
+ StrFixedLenField('reserved3', None, length=4),
+ ]
+
+
+# CQ
+class CmdInputFieldSelectResizeCq(Packet):
+ fields_desc = [
+ BitField('reserved1', 0, 28),
+ BitField('umem', 0, 1),
+ BitField('log_page_size', 0, 1),
+ BitField('page_offset', 0, 1),
+ BitField('log_cq_size', 0, 1),
+ ]
+
+
+class CmdInputFieldSelectModifyCqFields(Packet):
+ fields_desc = [
+ BitField('reserved_0', 0, 26),
+ BitField('status', 0, 1),
+ BitField('cq_period_mode', 0, 1),
+ BitField('c_eqn', 0, 1),
+ BitField('oi', 0, 1),
+ BitField('cq_max_count', 0, 1),
+ BitField('cq_period', 0, 1),
+ ]
+
+
+class SwCqc(Packet):
+ fields_desc = [
+ BitField('status', 0, 4),
+ BitField('as_notify', 0, 1),
+ BitField('initiator_src_dct', 0, 1),
+ BitField('dbr_umem_valid', 0, 1),
+ BitField('reserved1', 0, 1),
+ BitField('cqe_sz', 0, 3),
+ BitField('cc', 0, 1),
+ BitField('reserved2', 0, 1),
+ BitField('scqe_break_moderation_en', 0, 1),
+ BitField('oi', 0, 1),
+ BitField('cq_period_mode', 0, 2),
+ BitField('cqe_compression_en', 0, 1),
+ BitField('mini_cqe_res_format', 0, 2),
+ BitField('st', 0, 4),
+ ByteField('reserved3', 0),
+ IntField('dbr_umem_id', 0),
+ BitField('reserved4', 0, 20),
+ BitField('page_offset', 0, 6),
+ BitField('reserved5', 0, 6),
+ BitField('reserved6', 0, 3),
+ BitField('log_cq_size', 0, 5),
+ BitField('uar_page', 0, 24),
+ BitField('reserved7', 0, 4),
+ BitField('cq_period', 0, 12),
+ ShortField('cq_max_count', 0),
+ BitField('reserved8', 0, 24),
+ ByteField('c_eqn', 0),
+ BitField('reserved9', 0, 3),
+ BitField('log_page_size', 0, 5),
+ BitField('reserved10', 0, 24),
+ StrFixedLenField('reserved11', None, length=4),
+ ByteField('reserved12', 0),
+ BitField('last_notified_index', 0, 24),
+ ByteField('reserved13', 0),
+ BitField('last_solicit_index', 0, 24),
+ ByteField('reserved14', 0),
+ BitField('consumer_counter', 0, 24),
+ ByteField('reserved15', 0),
+ BitField('producer_counter', 0, 24),
+ BitField('local_partition_id', 0, 12),
+ BitField('process_id', 0, 20),
+ ShortField('reserved16', 0),
+ ShortField('thread_id', 0),
+ IntField('db_record_addr_63_32', 0),
+ BitField('db_record_addr_31_3', 0, 29),
+ BitField('reserved17', 0, 3),
+ ]
+
+
+class CreateCqIn(Packet):
+ fields_desc = [
+ ShortField('opcode', DevxOps.MLX5_CMD_OP_CREATE_CQ),
+ ShortField('uid', 0),
+ ShortField('reserved1', 0),
+ ShortField('op_mod', 0),
+ ByteField('reserved2', 0),
+ BitField('cqn', 0, 24),
+ StrFixedLenField('reserved3', None, length=4),
+ PacketField('sw_cqc', SwCqc(), SwCqc),
+ LongField('e_mtt_pointer_or_cq_umem_offset', 0),
+ IntField('cq_umem_id', 0),
+ BitField('cq_umem_valid', 0, 1),
+ BitField('reserved4', 0, 31),
+ StrFixedLenField('reserved5', None, length=176),
+ PacketListField('pas', [SwPas() for x in range(0)], SwPas, count_from=lambda pkt: 0),
+ ]
+
+
+class CreateCqOut(Packet):
+ fields_desc = [
+ ByteField('status', 0),
+ BitField('reserved1', 0, 24),
+ IntField('syndrome', 0),
+ ByteField('reserved2', 0),
+ BitField('cqn', 0, 24),
+ StrFixedLenField('reserved3', None, length=4),
+ ]
+
+
+# QP
+class SwAds(Packet):
+ fields_desc = [
+ BitField('fl', 0, 1),
+ BitField('free_ar', 0, 1),
+ BitField('reserved1', 0, 14),
+ ShortField('pkey_index', 0),
+ ByteField('reserved2', 0),
+ BitField('grh', 0, 1),
+ BitField('mlid', 0, 7),
+ ShortField('rlid', 0),
+ BitField('ack_timeout', 0, 5),
+ BitField('reserved3', 0, 3),
+ ByteField('src_addr_index', 0),
+ BitField('log_rtm', 0, 4),
+ BitField('stat_rate', 0, 4),
+ ByteField('hop_limit', 0),
+ BitField('reserved4', 0, 4),
+ BitField('tclass', 0, 8),
+ BitField('flow_label', 0, 20),
+ FieldListField('rgid_rip', [0 for x in range(4)], IntField('', 0),
+ count_from=lambda pkt: 4),
+ BitField('reserved5', 0, 4),
+ BitField('f_dscp', 0, 1),
+ BitField('f_ecn', 0, 1),
+ BitField('reserved6', 0, 1),
+ BitField('f_eth_prio', 0, 1),
+ BitField('ecn', 0, 2),
+ BitField('dscp', 0, 6),
+ ShortField('udp_sport', 0),
+ BitField('dei_cfi_reserved_from_prm_041', 0, 1),
+ BitField('eth_prio', 0, 3),
+ BitField('sl', 0, 4),
+ ByteField('vhca_port_num', 0),
+ MACField('rmac', '00:00:00:00:00:00'),
+
+ ]
+
+
+class SwQpc(Packet):
+ fields_desc = [
+ BitField('state', 0, 4),
+ BitField('lag_tx_port_affinity', 0, 4),
+ ByteField('st', 0),
+ BitField('reserved1', 0, 3),
+ BitField('pm_state', 0, 2),
+ BitField('reserved2', 0, 1),
+ BitField('req_e2e_credit_mode', 0, 2),
+ BitField('offload_type', 0, 4),
+ BitField('end_padding_mode', 0, 2),
+ BitField('reserved3', 0, 2),
+ BitField('wq_signature', 0, 1),
+ BitField('block_lb_mc', 0, 1),
+ BitField('atomic_like_write_en', 0, 1),
+ BitField('latency_sensitive', 0, 1),
+ BitField('dual_write', 0, 1),
+ BitField('drain_sigerr', 0, 1),
+ BitField('multi_path', 0, 1),
+ BitField('reserved4', 0, 1),
+ BitField('pd', 0, 24),
+ BitField('mtu', 0, 3),
+ BitField('log_msg_max', 0, 5),
+ BitField('reserved5', 0, 1),
+ BitField('log_rq_size', 0, 4),
+ BitField('log_rq_stride', 0, 3),
+ BitField('no_sq', 0, 1),
+ BitField('log_sq_size', 0, 4),
+ BitField('reserved6', 0, 1),
+ BitField('retry_mode', 0, 2),
+ BitField('ts_format', 0, 2),
+ BitField('data_in_order', 0, 1),
+ BitField('rlkey', 0, 1),
+ BitField('ulp_stateless_offload_mode', 0, 4),
+ ByteField('counter_set_id', 0),
+ BitField('uar_page', 0, 24),
+ BitField('reserved7', 0, 3),
+ BitField('full_handshake', 0, 1),
+ BitField('cnak_reverse_sl', 0, 4),
+ BitField('user_index', 0, 24),
+ BitField('reserved8', 0, 3),
+ BitField('log_page_size', 0, 5),
+ BitField('remote_qpn', 0, 24),
+ PacketField('primary_address_path', SwAds(), SwAds),
+ PacketField('secondary_address_path', SwAds(), SwAds),
+ BitField('log_ack_req_freq', 0, 4),
+ BitField('reserved9', 0, 4),
+ BitField('log_sra_max', 0, 3),
+ BitField('extended_rnr_retry_valid', 0, 1),
+ BitField('reserved10', 0, 1),
+ BitField('retry_count', 0, 3),
+ BitField('rnr_retry', 0, 3),
+ BitField('extended_retry_count_valid', 0, 1),
+ BitField('fre', 0, 1),
+ BitField('cur_rnr_retry', 0, 3),
+ BitField('cur_retry_count', 0, 3),
+ BitField('extended_log_rnr_retry', 0, 5),
+ ShortField('extended_cur_rnr_retry', 0),
+ ShortField('packet_pacing_rate_limit_index', 0),
+ ByteField('reserved11', 0),
+ BitField('next_send_psn', 0, 24),
+ ByteField('reserved12', 0),
+ BitField('cqn_snd', 0, 24),
+ ByteField('reserved13', 0),
+ BitField('deth_sqpn', 0, 24),
+ ByteField('reserved14', 0),
+ ByteField('extended_retry_count', 0),
+ ByteField('reserved15', 0),
+ ByteField('extended_cur_retry_count', 0),
+ ByteField('reserved16', 0),
+ BitField('last_acked_psn', 0, 24),
+ ByteField('reserved17', 0),
+ BitField('ssn', 0, 24),
+ ByteField('reserved18', 0),
+ BitField('log_rra_max', 0, 3),
+ BitField('reserved19', 0, 1),
+ BitField('atomic_mode', 0, 4),
+ BitField('rre', 0, 1),
+ BitField('rwe', 0, 1),
+ BitField('rae', 0, 1),
+ BitField('reserved20', 0, 1),
+ BitField('page_offset', 0, 6),
+ BitField('reserved21', 0, 3),
+ BitField('cd_slave_receive', 0, 1),
+ BitField('cd_slave_send', 0, 1),
+ BitField('cd_master', 0, 1),
+ BitField('reserved22', 0, 3),
+ BitField('min_rnr_nak', 0, 5),
+ BitField('next_rcv_psn', 0, 24),
+ ByteField('reserved23', 0),
+ BitField('xrcd', 0, 24),
+ ByteField('reserved24', 0),
+ BitField('cqn_rcv', 0, 24),
+ LongField('dbr_addr', 0),
+ IntField('q_key', 0),
+ BitField('reserved25', 0, 5),
+ BitField('rq_type', 0, 3),
+ BitField('srqn_rmpn_xrqn', 0, 24),
+ ByteField('reserved26', 0),
+ BitField('rmsn', 0, 24),
+ ShortField('hw_sq_wqebb_counter', 0),
+ ShortField('sw_sq_wqebb_counter', 0),
+ IntField('hw_rq_counter', 0),
+ IntField('sw_rq_counter', 0),
+ ByteField('reserved27', 0),
+ BitField('roce_adp_retrans_rtt', 0, 24),
+ BitField('reserved28', 0, 15),
+ BitField('cgs', 0, 1),
+ ByteField('cs_req', 0),
+ ByteField('cs_res', 0),
+ LongField('dc_access_key', 0),
+ BitField('rdma_active', 0, 1),
+ BitField('comm_est', 0, 1),
+ BitField('suspended', 0, 1),
+ BitField('dbr_umem_valid', 0, 1),
+ BitField('reserved29', 0, 4),
+ BitField('send_msg_psn', 0, 24),
+ ByteField('reserved30', 0),
+ BitField('rcv_msg_psn', 0, 24),
+ LongField('rdma_va', 0),
+ IntField('rdma_key', 0),
+ IntField('dbr_umem_id', 0),
+ ]
+
+
+class CreateQpIn(Packet):
+ fields_desc = [
+ ShortField('opcode', DevxOps.MLX5_CMD_OP_CREATE_QP),
+ ShortField('uid', 0),
+ ShortField('reserved1', 0),
+ ShortField('op_mod', 0),
+ ByteField('reserved2', 0),
+ BitField('input_qpn', 0, 24),
+ BitField('reserved3', 0, 1),
+ BitField('cmd_on_behalf', 0, 1),
+ BitField('reserved4', 0, 14),
+ ShortField('vhca_id', 0),
+ IntField('opt_param_mask', 0),
+ StrFixedLenField('reserved5', None, length=4),
+ PacketField('sw_qpc', SwQpc(), SwQpc),
+ LongField('e_mtt_pointer_or_wq_umem_offset', 0),
+ IntField('wq_umem_id', 0),
+ BitField('wq_umem_valid', 0, 1),
+ BitField('reserved6', 0, 31),
+ PacketListField('pas', [SwPas() for x in range(0)], SwPas,
+ count_from=lambda pkt: 0),
+ ]
+
+
+class CreateQpOut(Packet):
+ fields_desc = [
+ ByteField('status', 0),
+ BitField('reserved1', 0, 24),
+ IntField('syndrome', 0),
+ ByteField('reserved2', 0),
+ BitField('qpn', 0, 24),
+ StrFixedLenField('reserved3', None, length=4),
+ ]
+
+
+class ModifyQpIn(Packet):
+ fields_desc = [
+ ShortField('opcode', 0),
+ ShortField('uid', 0),
+ ShortField('vhca_tunnel_id', 0),
+ ShortField('op_mod', 0),
+ ByteField('reserved2', 0),
+ BitField('qpn', 0, 24),
+ IntField('reserved3', 0),
+ IntField('opt_param_mask', 0),
+ IntField('ece', 0),
+ PacketField('sw_qpc', SwQpc(), SwQpc),
+ StrFixedLenField('reserved4', None, length=16),
+ ]
+
+
+class ModifyQpOut(Packet):
+ fields_desc = [
+ ByteField('status', 0),
+ BitField('reserved1', 0, 24),
+ IntField('syndrome', 0),
+ StrFixedLenField('reserved2', None, length=8),
+ ]
+
+
+class QueryQpIn(Packet):
+ fields_desc = [
+ ShortField('opcode', DevxOps.MLX5_CMD_OP_QUERY_QP),
+ ShortField('uid', 0),
+ ShortField('reserved1', 0),
+ ShortField('op_mod', 0),
+ ByteField('reserved2', 0),
+ BitField('qpn', 0, 24),
+ StrFixedLenField('reserved3', None, length=4),
+ ]
+
+
+class QueryQpOut(Packet):
+ fields_desc = [
+ ByteField('status', 0),
+ BitField('reserved1', 0, 24),
+ IntField('syndrome', 0),
+ StrFixedLenField('reserved2', None, length=8),
+ IntField('opt_param_mask', 0),
+ StrFixedLenField('reserved3', None, length=4),
+ PacketField('sw_qpc', SwQpc(), SwQpc),
+ LongField('e_mtt_pointer', 0),
+ StrFixedLenField('reserved4', None, length=8),
+ PacketListField('pas', [SwPas() for x in range(0)], SwPas,
+ count_from=lambda pkt: 0),
+ ]
+
+
+# Query HCA VPORT Context
+class QueryHcaVportContextIn(Packet):
+ fields_desc = [
+ ShortField('opcode', DevxOps.MLX5_CMD_OP_QUERY_HCA_VPORT_CONTEXT),
+ ShortField('uid', 0),
+ ShortField('reserved1', 0),
+ ShortField('op_mod', 0),
+ BitField('other_vport', 0, 1),
+ BitField('reserved2', 0, 11),
+ BitField('port_num', 0, 4),
+ ShortField('vport_number', 0),
+ StrFixedLenField('reserved3', None, length=4),
+ ]
+
+
+class HcaVportContext(Packet):
+ fields_desc = [
+ IntField('field_select', 0),
+ StrFixedLenField('reserved1', None, length=28),
+ BitField('sm_virt_aware', 0, 1),
+ BitField('has_smi', 0, 1),
+ BitField('has_raw', 0, 1),
+ BitField('grh_required', 0, 1),
+ BitField('reserved2', 0, 1),
+ BitField('min_wqe_inline_mode', 0, 3),
+ ByteField('reserved3', 0),
+ BitField('port_physical_state', 0, 4),
+ BitField('vport_state_policy', 0, 4),
+ BitField('port_state', 0, 4),
+ BitField('vport_state', 0, 4),
+ StrFixedLenField('reserved4', None, length=4),
+ LongField('system_image_guid', 0),
+ LongField('port_guid', 0),
+ LongField('node_guid', 0),
+ IntField('cap_mask1', 0),
+ IntField('cap_mask1_field_select', 0),
+ IntField('cap_mask2', 0),
+ IntField('cap_mask2_field_select', 0),
+ ShortField('reserved5', 0),
+ ShortField('ooo_sl_mask', 0),
+ StrFixedLenField('reserved6', None, length=12),
+ ShortField('lid', 0),
+ BitField('reserved7', 0, 4),
+ BitField('init_type_reply', 0, 4),
+ BitField('lmc', 0, 3),
+ BitField('subnet_timeout', 0, 5),
+ ShortField('sm_lid', 0),
+ BitField('sm_sl', 0, 4),
+ BitField('reserved8', 0, 12),
+ ShortField('qkey_violation_counter', 0),
+ ShortField('pkey_violation_counter', 0),
+ StrFixedLenField('reserved9', None, length=404),
+ ]
+
+
+class QueryHcaVportContextOut(Packet):
+ fields_desc = [
+ ByteField('status', 0),
+ BitField('reserved1', 0, 24),
+ IntField('syndrome', 0),
+ StrFixedLenField('reserved2', None, length=8),
+ PacketField('hca_vport_context', HcaVportContext(), HcaVportContext),
+ ]
+
+
+# Query HCA VPORT GID
+class QueryHcaVportGidIn(Packet):
+ fields_desc = [
+ ShortField('opcode', DevxOps.MLX5_CMD_OP_QUERY_HCA_VPORT_GID),
+ ShortField('uid', 0),
+ ShortField('reserved1', 0),
+ ShortField('op_mod', 0),
+ BitField('other_vport', 0, 1),
+ BitField('reserved2', 0, 11),
+ BitField('port_num', 0, 4),
+ ShortField('vport_number', 0),
+ ShortField('reserved3', 0),
+ ShortField('gid_index', 0),
+ ]
+
+
+class IbGidCmd(Packet):
+ fields_desc = [
+ LongField('prefix', 0),
+ LongField('guid', 0),
+ ]
+
+
+class QueryHcaVportGidOut(Packet):
+ fields_desc = [
+ ByteField('status', 0),
+ BitField('reserved1', 0, 24),
+ IntField('syndrome', 0),
+ StrFixedLenField('reserved2', None, length=4),
+ ShortField('gids_num', 0),
+ ShortField('reserved3', 0),
+ PacketField('gid0', IbGidCmd(), IbGidCmd),
+ ]
+
+
+# Query HCA CAP
+class QueryHcaCapIn(Packet):
+ fields_desc = [
+ ShortField('opcode', DevxOps.MLX5_CMD_OP_QUERY_HCA_CAP),
+ ShortField('uid', 0),
+ ShortField('reserved1', 0),
+ ShortField('op_mod', 0),
+ BitField('other_function', 0, 1),
+ BitField('reserved2', 0, 15),
+ ShortField('function_id', 0),
+ StrFixedLenField('reserved3', None, length=4),
+ ]
+
+
+class CmdHcaCap(Packet):
+ fields_desc = [
+ BitField('access_other_hca_roce', 0, 1),
+ BitField('reserved1', 0, 30),
+ BitField('vhca_resource_manager', 0, 1),
+ BitField('hca_cap_2', 0, 1),
+ BitField('reserved2', 0, 2),
+ BitField('event_on_vhca_state_teardown_request', 0, 1),
+ BitField('event_on_vhca_state_in_use', 0, 1),
+ BitField('event_on_vhca_state_active', 0, 1),
+ BitField('event_on_vhca_state_allocated', 0, 1),
+ BitField('event_on_vhca_state_invalid', 0, 1),
+ ByteField('transpose_max_element_size', 0),
+ ShortField('vhca_id', 0),
+ ByteField('transpose_max_cols', 0),
+ ByteField('transpose_max_rows', 0),
+ ShortField('transpose_max_size', 0),
+ BitField('reserved3', 0, 1),
+ BitField('sw_steering_icm_large_scale_steering', 0, 1),
+ BitField('qp_data_in_order', 0, 1),
+ BitField('log_regexp_scatter_gather_size', 0, 5),
+ BitField('reserved4', 0, 3),
+ BitField('log_dma_mmo_max_size', 0, 5),
+ BitField('relaxed_ordering_write_pci_enabled', 0, 1),
+ BitField('reserved5', 0, 2),
+ BitField('log_compress_max_size', 0, 5),
+ BitField('reserved6', 0, 3),
+ BitField('log_decompress_max_size', 0, 5),
+ ByteField('log_max_srq_sz', 0),
+ ByteField('log_max_qp_sz', 0),
+ BitField('event_cap', 0, 1),
+ BitField('reserved7', 0, 2),
+ BitField('isolate_vl_tc_new', 0, 1),
+ BitField('reserved8', 0, 2),
+ BitField('nvmeotcp', 0, 1),
+ BitField('pcie_hanged', 0, 1),
+ BitField('prio_tag_required', 0, 1),
+ BitField('wqe_index_ignore_cap', 0, 1),
+ BitField('reserved9', 0, 1),
+ BitField('log_max_qp', 0, 5),
+ BitField('regexp', 0, 1),
+ BitField('regexp_params', 0, 1),
+ BitField('regexp_alloc_onbehalf_umem', 0, 1),
+ BitField('ece', 0, 1),
+ BitField('regexp_num_of_engines', 0, 4),
+ BitField('allow_pause_tx', 0, 1),
+ BitField('reg_c_preserve', 0, 1),
+ BitField('isolate_vl_tc', 0, 1),
+ BitField('log_max_srqs', 0, 5),
+ BitField('psp', 0, 1),
+ BitField('reserved10', 0, 1),
+ BitField('ts_cqe_to_dest_cqn', 0, 1),
+ BitField('regexp_log_crspace_size', 0, 5),
+ BitField('selective_repeat', 0, 1),
+ BitField('go_back_n', 0, 1),
+ BitField('reserved11', 0, 1),
+ BitField('scatter_fcs_w_decap_disable', 0, 1),
+ BitField('reserved12', 0, 4),
+ ByteField('max_sgl_for_optimized_performance', 0),
+ ByteField('log_max_cq_sz', 0),
+ BitField('relaxed_ordering_write_umr', 0, 1),
+ BitField('relaxed_ordering_read_umr', 0, 1),
+ BitField('access_register_user', 0, 1),
+ BitField('reserved13', 0, 5),
+ BitField('upt_device_emulation_manager', 0, 1),
+ BitField('virtio_net_device_emulation_manager', 0, 1),
+ BitField('virtio_blk_device_emulation_manager', 0, 1),
+ BitField('log_max_cq', 0, 5),
+ ByteField('log_max_eq_sz', 0),
+ BitField('relaxed_ordering_write', 0, 1),
+ BitField('relaxed_ordering_read', 0, 1),
+ BitField('log_max_mkey', 0, 6),
+ BitField('tunneled_atomic', 0, 1),
+ BitField('as_notify', 0, 1),
+ BitField('m_pci_port', 0, 1),
+ BitField('m_vhca_mk', 0, 1),
+ BitField('hotplug_manager', 0, 1),
+ BitField('nvme_device_emulation_manager', 0, 1),
+ BitField('terminate_scatter_list_mkey', 0, 1),
+ BitField('repeated_mkey', 0, 1),
+ BitField('dump_fill_mkey', 0, 1),
+ BitField('dpp', 0, 1),
+ BitField('resources_on_nvme_emulation_manager', 0, 1),
+ BitField('fast_teardown', 0, 1),
+ BitField('log_max_eq', 0, 4),
+ ByteField('max_indirection', 0),
+ BitField('fixed_buffer_size', 0, 1),
+ BitField('log_max_mrw_sz', 0, 7),
+ BitField('force_teardown', 0, 1),
+ BitField('prepare_fast_teardown_allways_1', 0, 1),
+ BitField('log_max_bsf_list_size', 0, 6),
+ BitField('umr_extended_translation_offset', 0, 1),
+ BitField('null_mkey', 0, 1),
+ BitField('log_max_klm_list_size', 0, 6),
+ BitField('non_wire_sq', 0, 1),
+ BitField('ats_ro_dependence', 0, 1),
+ BitField('qp_context_extension', 0, 1),
+ BitField('log_max_static_sq_wq_size', 0, 5),
+ BitField('resources_on_virtio_net_emulation_manager', 0, 1),
+ BitField('resources_on_virtio_blk_emulation_manager', 0, 1),
+ BitField('log_max_ra_req_dc', 0, 6),
+ BitField('vhca_trust_level_reg', 0, 1),
+ BitField('eth_wqe_too_small_mode', 0, 1),
+ BitField('vnic_env_eth_wqe_too_small', 0, 1),
+ BitField('log_max_static_sq_wq', 0, 5),
+ BitField('ooo_sl_mask', 0, 1),
+ BitField('vnic_env_cq_overrun', 0, 1),
+ BitField('log_max_ra_res_dc', 0, 6),
+ BitField('cc_roce_ecn_rp_classify_mode', 0, 1),
+ BitField('cc_roce_ecn_rp_dynamic_rtt', 0, 1),
+ BitField('cc_roce_ecn_rp_dynamic_ai', 0, 1),
+ BitField('cc_roce_ecn_rp_dynamic_g', 0, 1),
+ BitField('cc_roce_ecn_rp_burst_decouple', 0, 1),
+ BitField('release_all_pages', 0, 1),
+ BitField('depracated_do_not_use', 0, 1),
+ BitField('sig_crc64_xp10', 0, 1),
+ BitField('sig_crc32c', 0, 1),
+ BitField('roce_accl', 0, 1),
+ BitField('log_max_ra_req_qp', 0, 6),
+ BitField('reserved14', 0, 1),
+ BitField('rts2rts_udp_sport', 0, 1),
+ BitField('rts2rts_lag_tx_port_affinity', 0, 1),
+ BitField('dma_mmo', 0, 1),
+ BitField('compress_min_block_size', 0, 4),
+ BitField('compress', 0, 1),
+ BitField('decompress', 0, 1),
+ BitField('log_max_ra_res_qp', 0, 6),
+ BitField('end_pad', 0, 1),
+ BitField('cc_query_allowed', 0, 1),
+ BitField('cc_modify_allowed', 0, 1),
+ BitField('start_pad', 0, 1),
+ BitField('cache_line_128byte', 0, 1),
+ BitField('gid_table_size_ro', 0, 1),
+ BitField('pkey_table_size_ro', 0, 1),
+ BitField('rts2rts_qp_rmp', 0, 1),
+ BitField('rnr_nak_q_counters', 0, 1),
+ BitField('rts2rts_qp_counters_set_id', 0, 1),
+ BitField('rts2rts_qp_dscp', 0, 1),
+ BitField('gen3_cc_negotiation', 0, 1),
+ BitField('vnic_env_int_rq_oob', 0, 1),
+ BitField('sbcam_reg', 0, 1),
+ BitField('cwcam_reg', 0, 1),
+ BitField('qcam_reg', 0, 1),
+ ShortField('gid_table_size', 0),
+ BitField('out_of_seq_cnt', 0, 1),
+ BitField('vport_counters', 0, 1),
+ BitField('retransmission_q_counters', 0, 1),
+ BitField('debug', 0, 1),
+ BitField('modify_rq_counters_set_id', 0, 1),
+ BitField('rq_delay_drop', 0, 1),
+ BitField('max_qp_cnt', 0, 10),
+ ShortField('pkey_table_size', 0),
+ BitField('vport_group_manager', 0, 1),
+ BitField('vhca_group_manager', 0, 1),
+ BitField('ib_virt', 0, 1),
+ BitField('eth_virt', 0, 1),
+ BitField('vnic_env_queue_counters', 0, 1),
+ BitField('ets', 0, 1),
+ BitField('nic_flow_table', 0, 1),
+ BitField('eswitch_manager', 0, 1),
+ BitField('device_memory', 0, 1),
+ BitField('mcam_reg', 0, 1),
+ BitField('pcam_reg', 0, 1),
+ BitField('local_ca_ack_delay', 0, 5),
+ BitField('port_module_event', 0, 1),
+ BitField('enhanced_retransmission_q_counters', 0, 1),
+ BitField('port_checks', 0, 1),
+ BitField('pulse_gen_control', 0, 1),
+ BitField('disable_link_up_by_init_hca', 0, 1),
+ BitField('beacon_led', 0, 1),
+ BitField('port_type', 0, 2),
+ ByteField('num_ports', 0),
+ BitField('snapshot', 0, 1),
+ BitField('pps', 0, 1),
+ BitField('pps_modify', 0, 1),
+ BitField('log_max_msg', 0, 5),
+ BitField('multi_path_xrc_rdma', 0, 1),
+ BitField('multi_path_dc_rdma', 0, 1),
+ BitField('multi_path_rc_rdma', 0, 1),
+ BitField('traffic_fast_control', 0, 1),
+ BitField('max_tc', 0, 4),
+ BitField('temp_warn_event', 0, 1),
+ BitField('dcbx', 0, 1),
+ BitField('general_notification_event', 0, 1),
+ BitField('multi_prio_sq', 0, 1),
+ BitField('afu_owner', 0, 1),
+ BitField('fpga', 0, 1),
+ BitField('rol_s', 0, 1),
+ BitField('rol_g', 0, 1),
+ BitField('ib_port_sniffer', 0, 1),
+ BitField('wol_s', 0, 1),
+ BitField('wol_g', 0, 1),
+ BitField('wol_a', 0, 1),
+ BitField('wol_b', 0, 1),
+ BitField('wol_m', 0, 1),
+ BitField('wol_u', 0, 1),
+ BitField('wol_p', 0, 1),
+ ShortField('stat_rate_support', 0),
+ BitField('sig_block_4048', 0, 1),
+ BitField('pci_sync_for_fw_update_event', 0, 1),
+ BitField('init2rtr_drain_sigerr', 0, 1),
+ BitField('log_max_extended_rnr_retry', 0, 5),
+ BitField('init2_lag_tx_port_affinity', 0, 1),
+ BitField('flow_group_type_hash_split', 0, 1),
+ BitField('reserved15', 0, 1),
+ BitField('wqe_based_flow_table_update', 0, 1),
+ BitField('cqe_version', 0, 4),
+ BitField('compact_address_vector', 0, 1),
+ BitField('eth_striding_wq', 0, 1),
+ BitField('reserved16', 0, 1),
+ BitField('ipoib_enhanced_offloads', 0, 1),
+ BitField('ipoib_basic_offloads', 0, 1),
+ BitField('ib_link_list_striding_wq', 0, 1),
+ BitField('repeated_block_disabled', 0, 1),
+ BitField('umr_modify_entity_size_disabled', 0, 1),
+ BitField('umr_modify_atomic_disabled', 0, 1),
+ BitField('umr_indirect_mkey_disabled', 0, 1),
+ BitField('umr_fence', 0, 2),
+ BitField('dc_req_sctr_data_cqe', 0, 1),
+ BitField('dc_connect_qp', 0, 1),
+ BitField('dc_cnak_trace', 0, 1),
+ BitField('drain_sigerr', 0, 1),
+ BitField('cmdif_checksum', 0, 2),
+ BitField('sigerr_cqe', 0, 1),
+ BitField('e_psv', 0, 1),
+ BitField('wq_signature', 0, 1),
+ BitField('sctr_data_cqe', 0, 1),
+ BitField('bsf_in_create_mkey', 0, 1),
+ BitField('sho', 0, 1),
+ BitField('tph', 0, 1),
+ BitField('rf', 0, 1),
+ BitField('dct', 0, 1),
+ BitField('qos', 0, 1),
+ BitField('eth_net_offloads', 0, 1),
+ BitField('roce', 0, 1),
+ BitField('atomic', 0, 1),
+ BitField('extended_retry_count', 0, 1),
+ BitField('cq_oi', 0, 1),
+ BitField('cq_resize', 0, 1),
+ BitField('cq_moderation', 0, 1),
+ BitField('cq_period_mode_modify', 0, 1),
+ BitField('cq_invalidate', 0, 1),
+ BitField('reserved17', 0, 1),
+ BitField('cq_eq_remap', 0, 1),
+ BitField('pg', 0, 1),
+ BitField('block_lb_mc', 0, 1),
+ BitField('exponential_backoff', 0, 1),
+ BitField('scqe_break_moderation', 0, 1),
+ BitField('cq_period_start_from_cqe', 0, 1),
+ BitField('cd', 0, 1),
+ BitField('atm', 0, 1),
+ BitField('apm', 0, 1),
+ BitField('vector_calc', 0, 1),
+ BitField('umr_ptr_rlkey', 0, 1),
+ BitField('imaicl', 0, 1),
+ BitField('qp_packet_based', 0, 1),
+ BitField('ib_cyclic_striding_wq', 0, 1),
+ BitField('ipoib_enhanced_pkey_change', 0, 1),
+ BitField('initiator_src_dct_in_cqe', 0, 1),
+ BitField('qkv', 0, 1),
+ BitField('pkv', 0, 1),
+ BitField('set_deth_sqpn', 0, 1),
+ BitField('rts2rts_primary_sl', 0, 1),
+ BitField('initiator_src_dct', 0, 1),
+ BitField('dc_v2', 0, 1),
+ BitField('xrc', 0, 1),
+ BitField('ud', 0, 1),
+ BitField('uc', 0, 1),
+ BitField('rc', 0, 1),
+ BitField('uar_4k', 0, 1),
+ BitField('reserved18', 0, 7),
+ BitField('fl_rc_qp_when_roce_disabled', 0, 1),
+ BitField('reserved19', 0, 1),
+ BitField('uar_sz', 0, 6),
+ BitField('reserved20', 0, 3),
+ BitField('log_max_dc_cnak_qps', 0, 5),
+ ByteField('log_pg_sz', 0),
+ BitField('bf', 0, 1),
+ BitField('driver_version', 0, 1),
+ BitField('pad_tx_eth_packet', 0, 1),
+ BitField('query_driver_version', 0, 1),
+ BitField('max_qp_retry_freq', 0, 1),
+ BitField('qp_by_name', 0, 1),
+ BitField('mkey_by_name', 0, 1),
+ BitField('reserved21', 0, 4),
+ BitField('log_bf_reg_size', 0, 5),
+ BitField('reserved22', 0, 6),
+ BitField('lag_dct', 0, 2),
+ BitField('lag_tx_port_affinity', 0, 1),
+ BitField('lag_native_fdb_selection', 0, 1),
+ BitField('must_be_0', 0, 1),
+ BitField('lag_master', 0, 1),
+ BitField('num_lag_ports', 0, 4),
+ ShortField('num_of_diagnostic_counters', 0),
+ ShortField('max_wqe_sz_sq', 0),
+ ShortField('reserved23', 0),
+ ShortField('max_wqe_sz_rq', 0),
+ ShortField('max_flow_counter_31_16', 0),
+ ShortField('max_wqe_sz_sq_dc', 0),
+ BitField('reserved24', 0, 7),
+ BitField('max_qp_mcg', 0, 25),
+ ShortField('mlnx_tag_ethertype', 0),
+ ByteField('flow_counter_bulk_alloc', 0),
+ ByteField('log_max_mcg', 0),
+ BitField('reserved25', 0, 3),
+ BitField('log_max_transport_domain', 0, 5),
+ BitField('reserved26', 0, 3),
+ BitField('log_max_pd', 0, 5),
+ BitField('reserved27', 0, 11),
+ BitField('log_max_xrcd', 0, 5),
+ BitField('nic_receive_steering_discard', 0, 1),
+ BitField('receive_discard_vport_down', 0, 1),
+ BitField('transmit_discard_vport_down', 0, 1),
+ BitField('eq_overrun_count', 0, 1),
+ BitField('nic_receive_steering_depth', 0, 1),
+ BitField('invalid_command_count', 0, 1),
+ BitField('quota_exceeded_count', 0, 1),
+ BitField('flow_counter_by_name', 0, 1),
+ ByteField('log_max_flow_counter_bulk', 0),
+ ShortField('max_flow_counter_15_0', 0),
+ BitField('modify_tis', 0, 1),
+ BitField('flow_counters_dump', 0, 1),
+ BitField('reserved28', 0, 1),
+ BitField('log_max_rq', 0, 5),
+ BitField('reserved29', 0, 3),
+ BitField('log_max_sq', 0, 5),
+ BitField('reserved30', 0, 3),
+ BitField('log_max_tir', 0, 5),
+ BitField('reserved31', 0, 3),
+ BitField('log_max_tis', 0, 5),
+ BitField('basic_cyclic_rcv_wqe', 0, 1),
+ BitField('reserved32', 0, 2),
+ BitField('log_max_rmp', 0, 5),
+ BitField('reserved33', 0, 3),
+ BitField('log_max_rqt', 0, 5),
+ BitField('reserved34', 0, 3),
+ BitField('log_max_rqt_size', 0, 5),
+ BitField('reserved35', 0, 3),
+ BitField('log_max_tis_per_sq', 0, 5),
+ BitField('ext_stride_num_range', 0, 1),
+ BitField('reserved36', 0, 2),
+ BitField('log_max_stride_sz_rq', 0, 5),
+ BitField('reserved37', 0, 3),
+ BitField('log_min_stride_sz_rq', 0, 5),
+ BitField('reserved38', 0, 3),
+ BitField('log_max_stride_sz_sq', 0, 5),
+ BitField('reserved39', 0, 3),
+ BitField('log_min_stride_sz_sq', 0, 5),
+ BitField('hairpin_eth_raw', 0, 1),
+ BitField('reserved40', 0, 2),
+ BitField('log_max_hairpin_queues', 0, 5),
+ BitField('hairpin_ib_raw', 0, 1),
+ BitField('hairpin_eth2ipoib', 0, 1),
+ BitField('hairpin_ipoib2eth', 0, 1),
+ BitField('log_max_hairpin_wq_data_sz', 0, 5),
+ BitField('reserved41', 0, 3),
+ BitField('log_max_hairpin_num_packets', 0, 5),
+ BitField('reserved42', 0, 3),
+ BitField('log_max_wq_sz', 0, 5),
+ BitField('nic_vport_change_event', 0, 1),
+ BitField('disable_local_lb_uc', 0, 1),
+ BitField('disable_local_lb_mc', 0, 1),
+ BitField('log_min_hairpin_wq_data_sz', 0, 5),
+ BitField('system_image_guid_modifiable', 0, 1),
+ BitField('reserved43', 0, 1),
+ BitField('vhca_state', 0, 1),
+ BitField('log_max_vlan_list', 0, 5),
+ BitField('reserved44', 0, 3),
+ BitField('log_max_current_mc_list', 0, 5),
+ BitField('reserved45', 0, 3),
+ BitField('log_max_current_uc_list', 0, 5),
+ LongField('general_obj_types', 0),
+ BitField('sq_ts_format', 0, 2),
+ BitField('rq_ts_format', 0, 2),
+ BitField('steering_format_version', 0, 4),
+ BitField('create_qp_start_hint', 0, 24),
+ BitField('tls', 0, 1),
+ BitField('ats', 0, 1),
+ BitField('reserved46', 0, 1),
+ BitField('log_max_uctx', 0, 5),
+ BitField('aes_xts', 0, 1),
+ BitField('crypto', 0, 1),
+ BitField('ipsec_offload', 0, 1),
+ BitField('log_max_umem', 0, 5),
+ ShortField('max_num_eqs', 0),
+ BitField('reserved47', 0, 1),
+ BitField('tls_tx', 0, 1),
+ BitField('tls_rx', 0, 1),
+ BitField('log_max_l2_table', 0, 5),
+ ByteField('reserved48', 0),
+ ShortField('log_uar_page_sz', 0),
+ BitField('e', 0, 1),
+ BitField('reserved49', 0, 31),
+ IntField('device_frequency_mhz', 0),
+ IntField('device_frequency_khz', 0),
+ BitField('capi', 0, 1),
+ BitField('create_pec', 0, 1),
+ BitField('nvmf_target_offload', 0, 1),
+ BitField('capi_invalidate', 0, 1),
+ BitField('reserved50', 0, 23),
+ BitField('log_max_pasid', 0, 5),
+ IntField('num_of_uars_per_page', 0),
+ IntField('flex_parser_protocols', 0),
+ ByteField('max_geneve_tlv_options', 0),
+ BitField('reserved51', 0, 3),
+ BitField('max_geneve_tlv_option_data_len', 0, 5),
+ BitField('flex_parser_header_modify', 0, 1),
+ BitField('reserved52', 0, 2),
+ BitField('log_max_guaranteed_connections', 0, 5),
+ BitField('reserved53', 0, 3),
+ BitField('log_max_dct_connections', 0, 5),
+ ByteField('log_max_atomic_size_qp', 0),
+ BitField('reserved54', 0, 3),
+ BitField('log_max_dci_stream_channels', 0, 5),
+ BitField('reserved55', 0, 3),
+ BitField('log_max_dci_errored_streams', 0, 5),
+ ByteField('log_max_atomic_size_dc', 0),
+ ShortField('max_multi_user_group_size', 0),
+ BitField('reserved56', 0, 2),
+ BitField('crossing_vhca_mkey', 0, 1),
+ BitField('log_max_dek', 0, 5),
+ BitField('reserved57', 0, 1),
+ BitField('mini_cqe_resp_l3l4header', 0, 1),
+ BitField('mini_cqe_resp_flow_tag', 0, 1),
+ BitField('enhanced_cqe_compression', 0, 1),
+ BitField('mini_cqe_resp_stride_index', 0, 1),
+ BitField('cqe_128_always', 0, 1),
+ BitField('cqe_compression_128b', 0, 1),
+ BitField('cqe_compression', 0, 1),
+ ShortField('cqe_compression_timeout', 0),
+ ShortField('cqe_compression_max_num', 0),
+ BitField('reserved58', 0, 3),
+ BitField('wqe_based_flow_table_update_dest_type_offset', 0, 5),
+ BitField('flex_parser_id_gtpu_dw_0', 0, 4),
+ BitField('log_max_tm_offloaded_op_size', 0, 4),
+ BitField('tag_matching', 0, 1),
+ BitField('rndv_offload_rc', 0, 1),
+ BitField('rndv_offload_dc', 0, 1),
+ BitField('log_tag_matching_list_sz', 0, 5),
+ BitField('reserved59', 0, 3),
+ BitField('log_max_xrq', 0, 5),
+ ByteField('affiliate_nic_vport_criteria', 0),
+ ByteField('native_port_num', 0),
+ ByteField('num_vhca_ports', 0),
+ BitField('flex_parser_id_gtpu_teid', 0, 4),
+ BitField('reserved60', 0, 1),
+ BitField('trusted_vnic_vhca', 0, 1),
+ BitField('sw_owner_id', 0, 1),
+ BitField('reserve_not_to_use', 0, 1),
+ ShortField('max_num_of_monitor_counters', 0),
+ ShortField('num_ppcnt_monitor_counters', 0),
+ ShortField('max_num_sf', 0),
+ ShortField('num_q_monitor_counters', 0),
+ StrFixedLenField('reserved61', None, length=4),
+ BitField('sf', 0, 1),
+ BitField('sf_set_partition', 0, 1),
+ BitField('reserved62', 0, 1),
+ BitField('log_max_sf', 0, 5),
+ ByteField('reserved63', 0),
+ ByteField('log_min_sf_size', 0),
+ ByteField('max_num_sf_partitions', 0),
+ IntField('uctx_permission', 0),
+ BitField('flex_parser_id_mpls_over_x_cw', 0, 4),
+ BitField('flex_parser_id_geneve_tlv_option_0', 0, 4),
+ BitField('flex_parser_id_icmp_dw1', 0, 4),
+ BitField('flex_parser_id_icmp_dw0', 0, 4),
+ BitField('flex_parser_id_icmpv6_dw1', 0, 4),
+ BitField('flex_parser_id_icmpv6_dw0', 0, 4),
+ BitField('flex_parser_id_outer_first_mpls_over_gre', 0, 4),
+ BitField('flex_parser_id_outer_first_mpls_over_udp_label', 0, 4),
+ ShortField('max_num_match_definer', 0),
+ ShortField('sf_base_id', 0),
+ BitField('flex_parser_id_gtpu_dw_2', 0, 4),
+ BitField('flex_parser_id_gtpu_first_ext_dw_0', 0, 4),
+ BitField('num_total_dynamic_vf_msix', 0, 24),
+ BitField('reserved64', 0, 3),
+ BitField('log_flow_hit_aso_granularity', 0, 5),
+ BitField('reserved65', 0, 3),
+ BitField('log_flow_hit_aso_max_alloc', 0, 5),
+ BitField('reserved66', 0, 4),
+ BitField('dynamic_msix_table_size', 0, 12),
+ BitField('reserved67', 0, 3),
+ BitField('log_max_num_flow_hit_aso', 0, 5),
+ BitField('reserved68', 0, 4),
+ BitField('min_dynamic_vf_msix_table_size', 0, 4),
+ BitField('reserved69', 0, 4),
+ BitField('max_dynamic_vf_msix_table_size', 0, 12),
+ BitField('reserved70', 0, 3),
+ BitField('log_max_num_header_modify_argument', 0, 5),
+ BitField('reserved71', 0, 4),
+ BitField('log_header_modify_argument_granularity', 0, 4),
+ BitField('reserved72', 0, 3),
+ BitField('log_header_modify_argument_max_alloc', 0, 5),
+ BitField('reserved73', 0, 3),
+ BitField('max_flow_execute_aso', 0, 5),
+ LongField('vhca_tunnel_commands', 0),
+ LongField('match_definer_format_supported', 0),
+ ]
+
+
+class QueryCmdHcaCapOut(Packet):
+ fields_desc = [
+ ByteField('status', 0),
+ BitField('reserved1', 0, 24),
+ IntField('syndrome', 0),
+ StrFixedLenField('reserved2', None, length=8),
+ PadField(PacketField('capability', CmdHcaCap(), CmdHcaCap), 2048, padwith=b"\x00"),
+ ]
diff --git a/tests/test_mlx5_devx.py b/tests/test_mlx5_devx.py
new file mode 100644
index 0000000..c43dcd5
--- /dev/null
+++ b/tests/test_mlx5_devx.py
@@ -0,0 +1,23 @@
+# SPDX-License-Identifier: (GPL-2.0 OR Linux-OpenIB)
+# Copyright (c) 2021 Nvidia Inc. All rights reserved. See COPYING file
+
+"""
+Test module for mlx5 DevX.
+"""
+
+from tests.mlx5_base import Mlx5DevxRcResources, Mlx5DevxTrafficBase
+
+
+class Mlx5DevxRcTrafficTest(Mlx5DevxTrafficBase):
+ """
+ Test various functionality of mlx5 DevX objects
+ """
+
+ def test_devx_rc_qp_send_imm_traffic(self):
+ """
+ Creates two DevX RC QPs and modifies them to RTS state.
+ Then does SEND_IMM traffic.
+ """
+ self.create_players(Mlx5DevxRcResources)
+ # Send traffic
+ self.send_imm_traffic()
--
1.8.3.1
