test: add option to test with pipewire

Signed-off-by: Emilia Kurdybelska <emiliax.kurdybelska@intel.com>

Author: ekurdybx

case-lib/hijack.sh

@@ -12,6 +12,10 @@ function func_exit_handler()
 
     dlogi "Starting func_exit_handler($exit_status)"
 
+    if [ "$TEST_WITH_PIPEWIRE" == true ]; then
+        func_lib_disable_pipewire
+    fi
+
     # call trace
     if [ "$exit_status" -ne 0 ] ; then
         dloge "Starting ${FUNCNAME[0]}(), exit status=$exit_status, FUNCNAME stack:"

case-lib/lib.sh

@@ -83,6 +83,10 @@ minvalue() { printf '%d' $(( "$1" < "$2"  ? "$1" : "$2" )); }
 #
 start_test()
 {
+    if [ "$TEST_WITH_PIPEWIRE" == true ]; then
+        func_lib_enable_pipewire
+    fi
+    
     if is_subtest; then
         return 0
     fi
@@ -571,6 +575,44 @@ func_lib_check_sudo()
     }
 }
 
+func_lib_enable_pipewire()
+{
+    dlogi "Starting Pipewire..."
+    systemctl --user daemon-reexec
+    systemctl --user daemon-reload
+    systemctl --user unmask pipewire{,-pulse}.{socket,service}
+    systemctl --user start pipewire{,-pulse}.{socket,service}
+    systemctl --user unmask wireplumber.service
+    systemctl --user start wireplumber.service
+
+    # Wait for pipewire to start
+    sleep 5s
+
+    if [ "$(ps -C pipewire --no-header)" ]; then
+        dlogi "Pipewire started"
+    else
+        die "Failed to start pipewire"
+    fi
+}
+
+func_lib_disable_pipewire()
+{
+    dlogi "Stopping Pipewire..."
+
+    # Kill any left pipewire processes
+    # pkill -9 arecord
+    # pkill -9 aplay
+    sleep 2s
+
+    systemctl --user stop pipewire{,-pulse}.{socket,service}
+    systemctl --user mask pipewire{,-pulse}.{socket,service}
+    systemctl --user stop wireplumber.service
+    systemctl --user mask wireplumber.service
+
+    # Wait for pipewire to stop
+    sleep 2s
+
+
 systemctl_show_pulseaudio()
 {
     printf '\n'

test-case/check-performance.sh

@@ -51,27 +51,63 @@ func_pipeline_export "$tplg" "type:any"
 aplay_num=0
 arecord_num=0
 
-for idx in $(seq 0 $((PIPELINE_COUNT - 1)))
-do
-        channel=$(func_pipeline_parse_value "$idx" channel)
-        rate=$(func_pipeline_parse_value "$idx" rate)
-        dev=$(func_pipeline_parse_value "$idx" dev)
-        pcm=$(func_pipeline_parse_value "$idx" pcm)
-        type=$(func_pipeline_parse_value "$idx" type)
-
-        # Currently, copier will convert bit depth to S32_LE despite what bit depth
-        # is used in aplay, so make S32_LE as base bit depth for performance analysis.
-        fmt=S32_LE
-
-        dlogi "Running (PCM: $pcm [$dev]<$type>) in background"
-        if [ "$type" == "playback" ]; then
-            aplay_opts -D "$dev" -c "$channel" -r "$rate" -f "$fmt" -d "$duration" /dev/zero -q &
-            aplay_num=$((aplay_num+1))
-        else
-            arecord_opts -D "$dev" -c "$channel" -r "$rate" -f "$fmt" -d "$duration" /dev/null -q &
-            arecord_num=$((arecord_num+1))
+if [ "$TEST_WITH_PIPEWIRE" == true ]; then
+
+    # aplay's for sinks
+    pw_outputs_list=("Speaker" "Headphones" "HDMI")
+
+    for sink_type in "${pw_outputs_list[@]}"
+    do
+        sink_id=$(wpctl status | grep -A6 "Sinks" | grep -A3 -i "$sink_type" | tr -d '*' | awk '{print $2}' | tr -d '.' | head -n 1)
+        if [ -z "$sink_id" ]; then
+            echo "No $sink_type found, skipping to the next one"
+            continue # skip if that device type isn't available
         fi
-done
+        echo "Setting default sink to $sink_id: $sink_type"
+        wpctl set-default "$sink_id"
+        aplay_opts -Ddefault /dev/zero -q &
+        aplay_num=$((aplay_num+1))
+    done
+
+    # arecord's for sources
+    pw_inputs_list=("Digital Microphone" "Headset Microphone" "SoundWire microphones")
+
+    for source_type in "${pw_inputs_list[@]}"
+    do
+        source_id=$(wpctl status | grep -A6 "Sources" | grep -A3 -i "$source_type" | tr -d '*' | awk '{print $2}' | tr -d '.' | head -n 1)
+        if [ -z "$source_id" ]; then
+            continue # skip if that device type isn't available
+        fi
+        echo "Setting default source to $source_id: $source_type"
+        wpctl set-default "$source_id"
+        arecord_opts -Ddefault /dev/zero -q &
+        arecord_num=$((arecord_num+1))
+    done
+
+else
+
+    for idx in $(seq 0 $((PIPELINE_COUNT - 1)))
+    do
+            channel=$(func_pipeline_parse_value "$idx" channel)
+            rate=$(func_pipeline_parse_value "$idx" rate)
+            dev=$(func_pipeline_parse_value "$idx" dev)
+            pcm=$(func_pipeline_parse_value "$idx" pcm)
+            type=$(func_pipeline_parse_value "$idx" type)
+
+            # Currently, copier will convert bit depth to S32_LE despite what bit depth
+            # is used in aplay, so make S32_LE as base bit depth for performance analysis.
+            fmt=S32_LE
+
+            dlogi "Running (PCM: $pcm [$dev]<$type>) in background"
+            if [ "$type" == "playback" ]; then
+                aplay_opts -D "$dev" -c "$channel" -r "$rate" -f "$fmt" -d "$duration" /dev/zero -q &
+                aplay_num=$((aplay_num+1))
+            else
+                arecord_opts -D "$dev" -c "$channel" -r "$rate" -f "$fmt" -d "$duration" /dev/null -q &
+                arecord_num=$((arecord_num+1))
+            fi
+    done
+fi
 
 sleep 1 # waiting stable streaming of aplay/arecord
 dlogi "Number of aplay/arecord process started: $aplay_num, $arecord_num"