net/hw/rss_ctx.py

109 def _ntuple_rule_check(cfg, rule_id, ctx_id):
112     pattern = f"RSS Context (ID: )?{ctx_id}"
206         ctx_id = 0
209         ctx_id = ethtool_create(cfg, "-X", "context new")
210         ctx_ref = f"context {ctx_id}"
214     data = get_rss(cfg, context=ctx_id)
235         flow = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} dst-port {port} context {ctx_id}"
244     data = get_rss(cfg, context=ctx_id)
256         raise Exception(f"Driver didn't prevent us from deactivating a used queue (context {ctx_id})")
260         flow = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} dst-port {port} context {ctx_id} action 1"
268             raise Exception(f"Driver didn't prevent us from targeting a nonexistent queue (context {ctx_id})")
289             raise Exception(f"Driver didn't prevent us from deactivating a used queue (context {ctx_id})")
384     expect_tuples = set([(cfg.ifname, -1)] + [(cfg.ifname, ctx_id) for ctx_id in ids])
460             ctx_id = ethtool_create(cfg, "-X", f"context new {create_cfg}")
461             defer(ethtool, f"-X {cfg.ifname} context {ctx_id} delete")
472         _rss_key_check(cfg, context=ctx_id)
475             ethtool(f"-X {cfg.ifname} context {ctx_id} {want_cfg}")
476             _rss_key_check(cfg, context=ctx_id)
479         data = get_rss(cfg, ctx_id)
484         flow = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} dst-port {ports[i]} context {ctx_id}"
488         _ntuple_rule_check(cfg, ntuple, ctx_id)
568         ctx_id = ethtool_create(cfg, "-X", f"context new start {2 + i * 2} equal 2")
569         ctx.append(defer(ethtool, f"-X {cfg.ifname} context {ctx_id} delete"))
572         flow = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} dst-port {ports[i]} context {ctx_id}"
618     ctx_id = ethtool_create(cfg, "-X", "context new")
619     ethtool(f"-X {cfg.ifname} context {ctx_id} start 2 equal 2")
620     defer(ethtool, f"-X {cfg.ifname} context {ctx_id} delete")
642     flow = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} dst-port {port} context {ctx_id}"
670     for ctx_id in range(1, 100):
672             get_rss(cfg, context=ctx_id)
677         flow = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} dst-port 1234 context {ctx_id}"
693     ctx_id = ethtool_create(cfg, "-X", "context new")
694     ctx_deleter = defer(ethtool, f"-X {cfg.ifname} context {ctx_id} delete")
698     flow = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} dst-port {port} context {ctx_id}"
706         raise KsftFailEx(f"deleted context {ctx_id} used by rule {ntuple_id}")
733     ctx_id = ethtool_create(cfg, "-X", "context new equal 2")
734     defer(ethtool, f"-X {cfg.ifname} context {ctx_id} delete")
738     flow = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} dst-port {port} context {ctx_id} action 2"
745     _send_traffic_check(cfg, port, f"context {ctx_id}", { 'target': (2, 3),
776     ctx_id = ethtool_create(cfg, "-X", "context new start 2 equal 2")
777     defer(ethtool, f"-X {cfg.ifname} context {ctx_id} delete")
781     flow_generic = f"flow-type tcp{cfg.addr_ipver} dst-ip {cfg.addr} context {ctx_id} loc 1"
792     _ntuple_rule_check(cfg, 1, ctx_id)
801     _send_traffic_check(cfg, port_other, f"context {ctx_id}",