commit c4f3a48a6710ad8630707986f427d1d3b226fda7
author Li-Yu Yu <aaronyu@google.com> Thu Mar 10 13:29:50 2022
committer Commit Bot <commit-bot@chromium.org> Mon Mar 14 18:16:55 2022
tree 4ff961d4d9adf59e6a4c47b6c24652b1d46f1b50
parent d38d1e4ad9d93954babd15d45d59b6c966346bcf

loopback_latency: Add flag for pinning capture device

BUG=b:224409223
TEST=loopback_latency -c -n 1000 -P <post-mix-loopback-id>

Change-Id: I626823b07fee7a96c207af04a6705a82f0f5a559
Reviewed-on: https://chromium-review.googlesource.com/c/chromiumos/platform/audiotest/+/3516726
Reviewed-by: Hsinyu Chao <hychao@chromium.org>
Tested-by: Li-Yu Yu <aaronyu@google.com>
Reviewed-by: Yu-Hsuan Hsu <yuhsuan@chromium.org>
Commit-Queue: Li-Yu Yu <aaronyu@google.com>
Reviewed-by: Chih-Yang Hsia <paulhsia@chromium.org>

src/loopback_latency.c

diff --git a/src/loopback_latency.c b/src/loopback_latency.c
index 34f28a3..36b5cb3 100644
--- a/src/loopback_latency.c
+++ b/src/loopback_latency.c
@@ -33,6 +33,7 @@
 #define PLAYBACK_SILENT_COUNT   50
 #define PLAYBACK_TIMEOUT_COUNT 100
 #define TTY_OUTPUT_SIZE       1024
+#define PIN_DEVICE_UNSET        -1
 
 static double phase = M_PI / 2;
 static unsigned rate = 48000;
@@ -52,6 +53,7 @@
 static int cold;
 static int capture_count;
 static int playback_count;
+static int pin_capture_device = PIN_DEVICE_UNSET;
 static snd_pcm_sframes_t playback_delay_frames;
 static struct timeval sine_start_tv;
 
@@ -409,7 +411,13 @@
     if (params == NULL)
         return -ENOMEM;
 
-    rc = cras_client_add_stream(client, &stream_id, params);
+    if (direction == CRAS_STREAM_INPUT &&
+            pin_capture_device != PIN_DEVICE_UNSET) {
+        rc = cras_client_add_pinned_stream(
+            client, pin_capture_device, &stream_id, params);
+    } else {
+        rc = cras_client_add_stream(client, &stream_id, params);
+    }
     if (rc < 0) {
         fprintf(stderr, "Add a stream fail.\n");
         return rc;
@@ -708,7 +716,7 @@
     char *cap_dev = NULL;
 
     int arg;
-    while ((arg = getopt(argc, argv, "b:i:o:n:r:p:ct:l:C")) != -1) {
+    while ((arg = getopt(argc, argv, "b:i:o:n:r:p:ct:l:CP:")) != -1) {
     switch (arg) {
         case 'b':
             buffer_frames = atoi(optarg);
@@ -742,6 +750,12 @@
         case 'C':
             cold = 1;
             break;
+        case 'P':
+            pin_capture_device = atoi(optarg);
+            fprintf(stderr,
+                "Pinning capture device %d\n",
+                pin_capture_device);
+            break;
         default:
             return 1;
         }