From: Jeremy Spewock <jspew...@iol.unh.edu>
The ability to change the configuration of a port at runtime is a
crucial aspect of DPDK. This patch adds both the steps required to
modify the number of queues on a port at runtime and also the
verification steps to ensure that the command behaved as expected.
Signed-off-by: Jeremy Spewock <jspew...@iol.unh.edu>
---
Depends-on: patch-144270 ("dts: add VLAN methods to testpmd shell")
Depends-on: patch-144458 ("dts: add text parser for testpmd verbose output")
dts/framework/remote_session/testpmd_shell.py | 36 +++++++++++++++++++
1 file changed, 36 insertions(+)
diff --git a/dts/framework/remote_session/testpmd_shell.py
b/dts/framework/remote_session/testpmd_shell.py
index 893cf7255c..4325a7d9c5 100644
--- a/dts/framework/remote_session/testpmd_shell.py
+++ b/dts/framework/remote_session/testpmd_shell.py
@@ -1713,6 +1713,42 @@ def extract_verbose_output(output: str) ->
list[TestPmdVerbosePacket]:
out.append(TestPmdVerbosePacket.parse(f"{prev_header}\n{match.group('PACKET')}"))
return out
+ def set_num_queues_all(self, num_queues: int, is_rx: bool, verify: bool =
True) -> None:
+ """Modify the number of Rx/Tx queues configured on all ports.
+
+ Args:
+ num_queues: Number of queues to set on all ports.
+ is_rx: If :data:`True` then the number of Rx queues will be
modified, otherwise the
+ number of Tx queues will be modified.
+ verify: If :data:`True` then an additional command will be sent to
check the info of
+ `port_id` and verify that the number of queues is equal to
`num_queues`.
+
+ Raises:
+ InteractiveCommandExecutionError: If `verify` is :data:`True` and
testpmd failed to
+ update the number of queues on the ports.
+ """
+ queue_type = "rxq" if is_rx else "txq"
+ self.stop_all_ports(verify=verify)
+ port_config_output = self.send_command(f"port config all {queue_type}
{num_queues}")
+ # ports have to be started before the output can be verified.
+ self.start_all_ports(verify=verify)
+ if verify:
+ all_ports_modified = all(
+ queues == num_queues
+ for queues in map(
+ lambda info: info.rx_queues_num if is_rx else
info.tx_queues_num,
+ self.show_port_info_all(),
+ )
+ )
+ if not all_ports_modified:
+ self._logger.debug(
+ f"Failed to set number of queues on all ports to "
+ f"{num_queues}:\n{port_config_output}"
+ )
+ raise InteractiveCommandExecutionError(
+ "Testpmd failed to update the number of queues on all
ports."
+ )
+
def _close(self) -> None:
"""Overrides :meth:`~.interactive_shell.close`."""
self.stop()
--
2.46.0
