Adding pulseaudio input support to chrome

media/audio/pulse/pulse_util.cc

Index: media/audio/pulse/pulse_util.cc
diff --git a/media/audio/pulse/pulse_util.cc b/media/audio/pulse/pulse_util.cc
new file mode 100644
index 0000000000000000000000000000000000000000..868dc4ebeecacc55ecf317bc497a59a78a96fc3f
--- /dev/null
+++ b/media/audio/pulse/pulse_util.cc
@@ -0,0 +1,130 @@
+// 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 "base/logging.h"
+#include "base/time.h"
+#include "media/audio/audio_manager_base.h"
+#include "media/audio/pulse/pulse_wrapper.h"
+
+namespace media {
+
+namespace {
+
+pa_channel_position ChromiumToPAChannelPosition(Channels channel) {
+  switch (channel) {
+    // PulseAudio does not differentiate between left/right and
+    // stereo-left/stereo-right, both translate to front-left/front-right.
+    case LEFT:
+      return PA_CHANNEL_POSITION_FRONT_LEFT;
+    case RIGHT:
+      return PA_CHANNEL_POSITION_FRONT_RIGHT;
+    case CENTER:
+      return PA_CHANNEL_POSITION_FRONT_CENTER;
+    case LFE:
+      return PA_CHANNEL_POSITION_LFE;
+    case BACK_LEFT:
+      return PA_CHANNEL_POSITION_REAR_LEFT;
+    case BACK_RIGHT:
+      return PA_CHANNEL_POSITION_REAR_RIGHT;
+    case LEFT_OF_CENTER:
+      return PA_CHANNEL_POSITION_FRONT_LEFT_OF_CENTER;
+    case RIGHT_OF_CENTER:
+      return PA_CHANNEL_POSITION_FRONT_RIGHT_OF_CENTER;
+    case BACK_CENTER:
+      return PA_CHANNEL_POSITION_REAR_CENTER;
+    case SIDE_LEFT:
+      return PA_CHANNEL_POSITION_SIDE_LEFT;
+    case SIDE_RIGHT:
+      return PA_CHANNEL_POSITION_SIDE_RIGHT;
+    case CHANNELS_MAX:
+      return PA_CHANNEL_POSITION_INVALID;
+    default:
+      NOTREACHED() << "Invalid channel: " << channel;
+      return PA_CHANNEL_POSITION_INVALID;
+  }
+}
+
+}  // namespace
+
+AutoPulseLock::AutoPulseLock(PulseWrapper* wrapper,
+                             pa_threaded_mainloop* pa_mainloop)
+    : wrapper_(wrapper),
+      pa_mainloop_(pa_mainloop) {
+  wrapper_->pa_threaded_mainloop_lock_(pa_mainloop_);
+}
+
+AutoPulseLock::~AutoPulseLock() {
+  wrapper_->pa_threaded_mainloop_unlock_(pa_mainloop_);
+}
+
+pa_sample_format_t BitsToPASampleFormat(PulseWrapper* wrapper,
+                                        int bits_per_sample) {
+  switch (bits_per_sample) {
+    case 8:
+      return PA_SAMPLE_U8;
+    case 16:
+      return PA_SAMPLE_S16LE;
+    case 24:
+      return PA_SAMPLE_S24LE;
+    case 32:
+      return PA_SAMPLE_S32LE;
+    default:
+      NOTREACHED() << "Invalid bits per sample: " << bits_per_sample;
+      return PA_SAMPLE_INVALID;
+  }
+}
+
+pa_channel_map ChannelLayoutToPAChannelMap(PulseWrapper* wrapper,
+                                           ChannelLayout channel_layout) {
+  pa_channel_map channel_map;
+  wrapper->pa_channel_map_init_(&channel_map);
+
+  channel_map.channels = ChannelLayoutToChannelCount(channel_layout);
+  for (Channels ch = LEFT; ch < CHANNELS_MAX;
+      ch = static_cast<Channels>(ch + 1)) {
+    int channel_index = ChannelOrder(channel_layout, ch);
+    if (channel_index < 0)
+      continue;
+
+    channel_map.map[channel_index] = ChromiumToPAChannelPosition(ch);
+  }
+
+  return channel_map;
+}
+
+void WaitForOperationCompletion(PulseWrapper* wrapper,
+                                pa_threaded_mainloop* pa_mainloop,
+                                pa_operation* operation) {
+  if (!operation) {
+    DLOG(WARNING) << "Operation is NULL";
+    return;
+  }
+
+  while (wrapper->pa_operation_get_state_(operation) == PA_OPERATION_RUNNING)
+    wrapper->pa_threaded_mainloop_wait_(pa_mainloop);
+
+  wrapper->pa_operation_unref_(operation);
+}
+
+int GetHardwareLatencyInBytes(PulseWrapper* wrapper,
+                              pa_stream* stream,
+                              int sample_rate,
+                              int bytes_per_frame) {
+  DCHECK(stream);
+  int negative = 0;
+  pa_usec_t latency_micros = 0;
+  if (wrapper->pa_stream_get_latency_(stream, &latency_micros, &negative) != 0)
+    return 0;
+
+  if (negative)
+    return 0;
+
+  return latency_micros * sample_rate * bytes_per_frame /
+      base::Time::kMicrosecondsPerSecond;
+
+}
+
+}  // namespace media