fto-orchestration yaf.py add YafZC capability

Author: pascal260303

tools/ft-analyzer/ftanalyzer/counter/counter.py

@@ -72,7 +72,7 @@ def get_std_deviation(self) -> np.float64:
         Returns:
             np.float64: the standard deviation
         """
-        return math.sqrt(self.get_variance())
+        return math.sqrt(max(self.get_variance(), 0))
 
     def get_cvar(self) -> np.float64:
         """Returns the co-variance of the observed variable

tools/ft-orchestration/src/probe/nprobe.py

@@ -201,20 +201,18 @@ def _switch_to_zc(self, interface_name: str):
             return
 
         driver = driver.split(" ")[1].strip()
-        if driver.endswith("_zc"):
-            driver = driver[:-3]
+        if not driver.endswith("_zc"):
             Tool(
                 f"pf_ringcfg --configure-driver {driver}",
                 executor=self._executor,
                 sudo=self._sudo,
             ).run()
             time.sleep(5)
         Tool(
-            f"pf_ringcfg --configure-driver {driver} --rss-queues {self._settings.rss_queues}",
+            f"ethtool --set-channels {interface_name} combined {self._settings.rss_queues}",
             executor=self._executor,
             sudo=self._sudo,
         ).run()
-        time.sleep(5)
 
     def _switch_back_zc(self, interface_name: str):
         driver, _ = Tool(

tools/ft-orchestration/src/probe/pidstat.py

@@ -53,6 +53,8 @@ def __init__(self, executor: Executor, watch_cmd: str, sudo: bool = False):
 
         pidstat_args = "-rushHvt"
 
+        self._process = None
+
         self._cmd = f"""
         pidstat {pidstat_args} -C {watch_cmd} | sed -E -e 's/^# //g' -e 's/[ ]+/;/g' -e 's/%/percent_/g' | tail -n2 > {self._outfile}
         sleep 1
@@ -88,6 +90,8 @@ def start(self):
             raise Exception("pidstat startup error")
 
     def stop(self):
+        if self._process is None:
+            return
         try:
             self._process.stop()
         except ExecutableProcessError: