Clean perfspect defunct process after collection (#995)

Enable perfspect debug with the verbose option

Signed-off-by: Min Lim <min.yeol.lim@intel.com>

Author: mlim19

gprofiler/hw_metrics.py

@@ -57,6 +57,7 @@ def __init__(
         perfspect_path: Optional[Path] = None,
         perfspect_duration: int = 60,
         polling_rate_seconds: int = DEFAULT_POLLING_INTERVAL_SECONDS,
+        verbose: bool = False,
     ):
         self._polling_rate_seconds = polling_rate_seconds
         self._stop_event = stop_event
@@ -65,6 +66,7 @@ def __init__(
         self._ps_process: Optional[subprocess.Popen[bytes]] = None
         self._perfspect_path: Optional[Path] = perfspect_path
         self._perfspect_duration = perfspect_duration
+        self._verbose = verbose
 
         self._ps_raw_csv_filename = PERFSPECT_DATA_DIRECTORY + "/" + platform.node() + "_metrics.csv"
         self._ps_summary_csv_filename = PERFSPECT_DATA_DIRECTORY + "/" + platform.node() + "_metrics_summary.csv"
@@ -93,7 +95,17 @@ def start(self) -> None:
             PERFSPECT_DATA_DIRECTORY,
         ]
 
+        # Add --debug if verbose is enabled
+        if self._verbose:
+            ps_cmd.append("--debug")
+
         self._ps_process = subprocess.Popen(ps_cmd, stdout=subprocess.PIPE)
+        Thread(target=self._reap_ps_process, daemon=True).start()
+
+    def _reap_ps_process(self) -> None:
+        if self._ps_process is not None:
+            self._ps_process.wait()
+            self._ps_process = None
 
     def stop(self) -> None:
         if self._ps_process:

gprofiler/main.py

@@ -126,6 +126,7 @@ def __init__(
         heartbeat_file_path: Optional[Path] = None,
         perfspect_path: Optional[Path] = None,
         perfspect_duration: int = 60,
+        verbose: bool = False,
     ):
         self._output_dir = output_dir
         self._flamegraph = flamegraph
@@ -182,6 +183,7 @@ def __init__(
                 self._profiler_state.stop_event,
                 perfspect_path=self._perfspect_path,
                 perfspect_duration=self._perfspect_duration,
+                verbose=verbose,
             )
         else:
             self._hw_metrics_monitor = NoopHWMetricsMonitor()
@@ -1228,6 +1230,7 @@ def main() -> None:
             heartbeat_file_path=heartbeat_file_path,
             perfspect_path=perfspect_path,
             perfspect_duration=getattr(args, "tool_perfspect_duration", 60),
+            verbose=args.verbose,
         )
         logger.info("gProfiler initialized and ready to start profiling")
         if args.continuous: