Fix AudioCapturer implementation to read from audio pipe even when there are no active clients.

remoting/host/remoting_me2me_host.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.
 //
 // This file implements a standalone host process for Me2Me.
 
 #include <string>
 
 #include "base/at_exit.h"
 #include "base/bind.h"
@@ skipping 426 matching lines @@
 }
 
 void HostProcess::StartHostProcess() {
   DCHECK(context_->ui_task_runner()->BelongsToCurrentThread());
 
   if (!InitWithCommandLine(CommandLine::ForCurrentProcess())) {
     OnConfigWatcherError();
     return;
   }
 
+#if defined(OS_LINUX)
+  // TODO(sergeyu): Pass configuration parameters to the Linux-specific version
+  // of DesktopEnvironmentFactory when we have it.
+  remoting::VideoFrameCapturer::EnableXDamage(true);
+
+  // Initialize AudioCapturer with the pipe name we get in command line and
+  // provide it with a task runner for the thread it should work on.

[Wez, 2012/10/31 00:56:28]

nit: Suggest "If an audio pipe is specific on the command-line then initialize
AudioCapturerLinux to capture from it."

[Sergey Ulanov, 2012/10/31 18:41:24]

Done.

+  FilePath audio_pipe_name = CommandLine::ForCurrentProcess()->
+      GetSwitchValuePath(kAudioPipeSwitchName);
+  if (!audio_pipe_name.empty()) {
+    remoting::AudioCapturerLinux::InitializePipeReader(
+        context_->audio_task_runner(), audio_pipe_name);
+  }
+#endif  // defined(OS_LINUX)
+
   // Create a desktop environment factory appropriate to the build type &
   // platform.
 #if defined(OS_WIN)
 
 #if defined(REMOTING_MULTI_PROCESS)
   IpcDesktopEnvironmentFactory* desktop_environment_factory =
       new IpcDesktopEnvironmentFactory(
           daemon_channel_.get(),
           context_->input_task_runner(),
           context_->network_task_runner(),
@@ skipping 433 matching lines @@
   net::EnableSSLServerSockets();
 
   // Create the main message loop and start helper threads.
   MessageLoop message_loop(MessageLoop::TYPE_UI);
   base::Closure quit_message_loop = base::Bind(&QuitMessageLoop, &message_loop);
   scoped_ptr<remoting::ChromotingHostContext> context(
       new remoting::ChromotingHostContext(
           new remoting::AutoThreadTaskRunner(message_loop.message_loop_proxy(),
                                              quit_message_loop)));
 
-#if defined(OS_LINUX)
-  // TODO(sergeyu): Pass configuration parameters to the Linux-specific version
-  // of DesktopEnvironmentFactory when we have it.
-  remoting::VideoFrameCapturer::EnableXDamage(true);
-  remoting::AudioCapturerLinux::SetPipeName(CommandLine::ForCurrentProcess()->
-      GetSwitchValuePath(kAudioPipeSwitchName));
-#endif  // defined(OS_LINUX)
-
   if (!context->Start())
     return remoting::kInitializationFailed;
 
   // Create the host process instance and enter the main message loop.
   remoting::HostProcess me2me_host(context.Pass());
   me2me_host.StartHostProcess();
   message_loop.Run();
   return me2me_host.get_exit_code();
 }
 
@@ skipping 31 matching lines @@
             user32.GetFunctionPointer("SetProcessDPIAware"));
     set_process_dpi_aware();
   }
 
   // CommandLine::Init() ignores the passed |argc| and |argv| on Windows getting
   // the command line from GetCommandLineW(), so we can safely pass NULL here.
   return main(0, NULL);
 }
 
 #endif  // defined(OS_WIN)