use pactl package

pyproject.toml

@@ -34,6 +34,7 @@ pillow = "^9.2.0"
 poetry = "==1.2.2"
 protobuf = "==3.20.1"
 psutil = "^5.9.1"
+pulsectl = "^22.3.2"
 pycapnp = "==1.1.0"
 pycryptodome = "^3.15.0"
 PyJWT = "^2.5.0"

system/hardware/pc/hardware.py

@@ -1,5 +1,7 @@
 import random
-import subprocess
+import time
+
+import pulsectl
 
 from cereal import log
 from system.hardware.base import HardwareBase, ThermalConfig
@@ -9,6 +11,9 @@
 
 
 class Pc(HardwareBase):
+  def __init__(self):
+    self.pulse = pulsectl.Pulse('openpilot')
+
   def get_os_version(self):
     return None
 
@@ -19,7 +24,11 @@ def get_sound_card_online(self):
     return True
 
   def is_sound_playing(self):
-    return "RUNNING" in subprocess.check_output(["pactl", "list", "short", "sinks"]).decode('utf8')
+    start_time = time.time()
+    result = any(s.state == 'RUNNING' for s in self.pulse.sink_input_list())
+    duration = time.time() - start_time
+    print(f"is_sound_playing took {duration:.2f}s")
+    return result
 
   def reboot(self, reason=None):
     print("REBOOT!")

system/hardware/tici/hardware.py

@@ -7,6 +7,8 @@
 from functools import cached_property
 from pathlib import Path
 
+import pulsectl
+
 from cereal import log
 from common.gpio import gpio_set, gpio_init
 from system.hardware.base import HardwareBase, ThermalConfig
@@ -68,6 +70,9 @@ def affine_irq(val, irq):
 
 
 class Tici(HardwareBase):
+  def __init__(self):
+    self.pulse = pulsectl.Pulse('openpilot')
+
   @cached_property
   def bus(self):
     import dbus  # pylint: disable=import-error
@@ -97,7 +102,11 @@ def get_sound_card_online(self):
             open('/proc/asound/card0/state').read().strip() == 'ONLINE')
 
   def is_sound_playing(self):
-    return "RUNNING" in subprocess.check_output(["pactl", "list", "short", "sinks"]).decode('utf8')
+    start_time = time.time()
+    result = any(s.state == 'RUNNING' for s in self.pulse.sink_input_list())
+    duration = time.time() - start_time
+    print(f"is_sound_playing took {duration:.2f}s")
+    return result
 
   def reboot(self, reason=None):
     subprocess.check_output(["sudo", "reboot"])

system/micd.py

@@ -5,6 +5,7 @@
 from cereal import messaging
 from common.filter_simple import FirstOrderFilter
 from common.realtime import Ratekeeper
+from system.hardware import HARDWARE
 from system.swaglog import cloudlog
 
 RATE = 10
@@ -60,9 +61,8 @@ def update(self):
       sound_pressure, _ = calculate_spl(self.measurements)
       measurements_weighted = apply_a_weighting(self.measurements)
       sound_pressure_weighted, sound_pressure_level_weighted = calculate_spl(measurements_weighted)
-      # FIXME: HARDWARE.is_sound_playing uses 25%+ CPU onroad
-      # if not HARDWARE.is_sound_playing():
-      self.spl_filter_weighted.update(sound_pressure_level_weighted)
+      if not HARDWARE.is_sound_playing():
+        self.spl_filter_weighted.update(sound_pressure_level_weighted)
     else:
       sound_pressure = 0
       sound_pressure_weighted = 0