Add GetAssociatedOutputDeviceID support to pulse.

media/audio/pulse/pulse_util.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "media/audio/pulse/pulse_util.h"
 
 #include <stdint.h>
 
 #include "base/logging.h"
 #include "base/macros.h"
 #include "base/time/time.h"
 #include "media/audio/audio_device_description.h"
 #include "media/base/audio_parameters.h"
 
+int strcmp(const char* s1, const char* s2);
+
 namespace media {
 
 namespace pulse {
 
 namespace {
 
 #if defined(GOOGLE_CHROME_BUILD)
 static const char kBrowserDisplayName[] = "google-chrome";
 #else
 static const char kBrowserDisplayName[] = "chromium-browser";
@@ skipping 36 matching lines @@
   ScopedPropertyList() : property_list_(pa_proplist_new()) {}
   ~ScopedPropertyList() { pa_proplist_free(property_list_); }
 
   pa_proplist* get() const { return property_list_; }
 
  private:
   pa_proplist* property_list_;
   DISALLOW_COPY_AND_ASSIGN(ScopedPropertyList);
 };
 
+struct InputBusData {
+  InputBusData(pa_threaded_mainloop* loop, const std::string& name)
+      : loop_(loop), name_(name), bus_() {}
+
+  pa_threaded_mainloop* loop_;
+  const std::string& name_;
+  std::string bus_;
+};
+
+struct OutputBusData {
+  OutputBusData(pa_threaded_mainloop* loop, const std::string& bus)
+      : loop_(loop), name_(), bus_(bus) {}
+
+  pa_threaded_mainloop* loop_;
+  std::string name_;
+  const std::string& bus_;
+};
+
+void InputBusCallback(pa_context* context,
+                      const pa_source_info* info,
+                      int error,
+                      void* user_data) {
+  InputBusData* data = reinterpret_cast<InputBusData*>(user_data);
+
+  if (error) {
+    // We have checked all the devices now.
+    pa_threaded_mainloop_signal(data->loop_, 0);
+    return;
+  }
+
+  if (strcmp(info->name, data->name_.c_str()) == 0 &&
+      pa_proplist_contains(info->proplist, PA_PROP_DEVICE_BUS)) {
+    data->bus_ = pa_proplist_gets(info->proplist, PA_PROP_DEVICE_BUS);
+  }
+}
+
+void OutputBusCallback(pa_context* context,
+                       const pa_sink_info* info,
+                       int error,
+                       void* user_data) {
+  OutputBusData* data = reinterpret_cast<OutputBusData*>(user_data);
+
+  if (error) {
+    // We have checked all the devices now.
+    pa_threaded_mainloop_signal(data->loop_, 0);
+    return;
+  }
+
+  if (pa_proplist_contains(info->proplist, PA_PROP_DEVICE_BUS) &&
+      strcmp(pa_proplist_gets(info->proplist, PA_PROP_DEVICE_BUS),
+             data->bus_.c_str()) == 0) {
+    data->name_ = info->name;
+  }
+}
 }  // namespace
 
 // static, pa_stream_success_cb_t
 void StreamSuccessCallback(pa_stream* s, int error, void* mainloop) {
   pa_threaded_mainloop* pa_mainloop =
       static_cast<pa_threaded_mainloop*>(mainloop);
   pa_threaded_mainloop_signal(pa_mainloop, 0);
 }
 
 // |pa_context| and |pa_stream| state changed cb.
@@ skipping 267 matching lines @@
     RETURN_ON_FAILURE(
         PA_STREAM_IS_GOOD(stream_state), "Invalid PulseAudio stream state");
     if (stream_state == PA_STREAM_READY)
       break;
     pa_threaded_mainloop_wait(*mainloop);
   }
 
   return true;
 }
 
+std::string GetBusOfInput(const std::string& name,
+                          pa_threaded_mainloop* input_mainloop,
+                          pa_context* input_context) {
+  DCHECK(input_mainloop);
+  DCHECK(input_context);
+  AutoPulseLock auto_lock(input_mainloop);
+  InputBusData data(input_mainloop, name);
+  pa_operation* operation =
+      pa_context_get_source_info_list(input_context, InputBusCallback, &data);
+  WaitForOperationCompletion(input_mainloop, operation);
+  return data.bus_;
+}
+
+std::string GetOutputCorrespondingTo(const std::string& input_bus,
+                                     pa_threaded_mainloop* input_mainloop,
+                                     pa_context* input_context) {
+  DCHECK(input_mainloop);
+  DCHECK(input_context);
+  AutoPulseLock auto_lock(input_mainloop);
+  OutputBusData data(input_mainloop, input_bus);
+  pa_operation* operation =
+      pa_context_get_sink_info_list(input_context, OutputBusCallback, &data);
+  WaitForOperationCompletion(input_mainloop, operation);
+  return data.name_;
+}
+
 #undef RETURN_ON_FAILURE
 
 }  // namespace pulse
 
 }  // namespace media