| from tests.base import RCResources, UDResources, XRCResources | |
| from tests.utils import traffic, xrc_traffic | |
| from tests.base import RDMATestCase | |
| from pyverbs.mr import MR | |
| import pyverbs.enums as e | |
| class RoUD(UDResources): | |
| def create_mr(self): | |
| self.mr = MR(self.pd, self.msg_size + self.GRH_SIZE, | |
| e.IBV_ACCESS_LOCAL_WRITE | e.IBV_ACCESS_RELAXED_ORDERING) | |
| class RoRC(RCResources): | |
| def create_mr(self): | |
| self.mr = MR(self.pd, self.msg_size, | |
| e.IBV_ACCESS_LOCAL_WRITE | e.IBV_ACCESS_RELAXED_ORDERING) | |
| class RoXRC(XRCResources): | |
| def create_mr(self): | |
| self.mr = MR(self.pd, self.msg_size, | |
| e.IBV_ACCESS_LOCAL_WRITE | e.IBV_ACCESS_RELAXED_ORDERING) | |
| class RoTestCase(RDMATestCase): | |
| def setUp(self): | |
| super(RoTestCase, self).setUp() | |
| self.iters = 100 | |
| def test_ro_rc_traffic(self): | |
| self.create_players(RoRC) | |
| traffic(**self.traffic_args) | |
| def test_ro_ud_traffic(self): | |
| self.create_players(RoUD) | |
| traffic(**self.traffic_args) | |
| def test_ro_xrc_traffic(self): | |
| self.create_players(RoXRC) | |
| xrc_traffic(self.client, self.server) |