Enable the AudioInputTest tests + Fix PCMQueueInAudioInputStream.

media/audio/audio_input_unittest.cc

 // Copyright (c) 2011 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 "base/basictypes.h"
 #include "base/environment.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/threading/platform_thread.h"
 #include "media/audio/audio_io.h"
@@ skipping 70 matching lines @@
     if (callback_count() > block_after_callback_)
       base::PlatformThread::Sleep(block_for_ms_);
   }
 
  private:
   int block_after_callback_;
   int block_for_ms_;
 };
 
 static bool CanRunAudioTests(AudioManager* audio_man) {
-  if (NULL == audio_man)
-    return false;
+  bool has_input = audio_man->HasAudioInputDevices();
 
-  scoped_ptr<base::Environment> env(base::Environment::Create());
-  if (env->HasVar("CHROME_HEADLESS"))
-    return false;
+  if (!has_input)
+    LOG(WARNING) << "No input devices detected";
 
-  return audio_man->HasAudioInputDevices();
+  return has_input;
 }
 
 static AudioInputStream* CreateTestAudioInputStream(AudioManager* audio_man) {
   AudioInputStream* ais = audio_man->MakeAudioInputStream(
       AudioParameters(AudioParameters::AUDIO_PCM_LINEAR, CHANNEL_LAYOUT_STEREO,
                       kSamplingRate, 16, kSamplesPerPacket),
                       AudioManagerBase::kDefaultDeviceId);
   EXPECT_TRUE(NULL != ais);
   return ais;
 }
@@ skipping 78 matching lines @@
   message_loop.PostDelayedTask(FROM_HERE, MessageLoop::QuitClosure(), 590);
   message_loop.Run();
   EXPECT_GE(test_callback.callback_count(), 10);
   EXPECT_FALSE(test_callback.had_error());
 
   ais->Stop();
   ais->Close();
 }
 
 // Test a recording sequence with delays in the audio callback.
+// TODO(joth): See bug 107546.  This fails on slow bots.  Once fixed, remove the
+// CHROME_HEADLESS check below.
 TEST(AudioInputTest, RecordWithSlowSink) {
   scoped_refptr<AudioManager> audio_man(AudioManager::Create());
   if (!CanRunAudioTests(audio_man.get()))
     return;
+
+  scoped_ptr<base::Environment> env(base::Environment::Create());
+  if (env->HasVar("CHROME_HEADLESS"))
+    return;
+
   MessageLoop message_loop(MessageLoop::TYPE_DEFAULT);
   AudioInputStream* ais = CreateTestAudioInputStream(audio_man.get());
   EXPECT_TRUE(ais->Open());
 
   // We should normally get a callback every 50ms, and a 20ms delay inside each
   // callback should not change this sequence.
   TestInputCallbackBlocking test_callback(kSamplesPerPacket * 4, 0, 20);
   ais->Start(&test_callback);
   // Verify at least 500ms worth of audio was recorded, after giving sufficient
   // extra time.
   message_loop.PostDelayedTask(FROM_HERE, MessageLoop::QuitClosure(), 590);
   message_loop.Run();
   EXPECT_GE(test_callback.callback_count(), 10);
   EXPECT_FALSE(test_callback.had_error());
 
   ais->Stop();
   ais->Close();
 }