Switch audio synchronization from sleep() based to select() based.

media/audio/audio_device_thread.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/audio_device_thread.h"
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/logging.h"
@@ skipping 139 matching lines @@
   }
 
   Run();
 
   // Release the reference for the thread. Note that after this, the Thread
   // instance will most likely be deleted.
   Release();
 }
 
 void AudioDeviceThread::Thread::Run() {
+  uint32_t buffer_index = 0;
   while (true) {
     int pending_data = 0;
     size_t bytes_read = socket_.Receive(&pending_data, sizeof(pending_data));
     if (bytes_read != sizeof(pending_data)) {
       DCHECK_EQ(bytes_read, 0U);
       break;
     }
 
-    base::AutoLock auto_lock(callback_lock_);
-    if (callback_)
-      callback_->Process(pending_data);
+    {
+      base::AutoLock auto_lock(callback_lock_);
+      if (callback_)
+        callback_->Process(pending_data);
+    }
+
+    // Let AudioSyncReader know which buffer we just filled.
+    buffer_index++;

[henrika (OOO until Aug 14), 2013/08/20 07:50:30]

Perhaps I am missing something here but isn't new code required to deal with the
new Send call on the render side?

[tommi (sloooow) - chröme, 2013/08/20 10:55:57]

nit: ++buffer_index;

[DaleCurtis, 2013/09/11 01:16:03]

This is handled in the new WaitTilDataReady().

[DaleCurtis, 2013/09/11 01:16:03]

Done.

+    CHECK_EQ(socket_.Send(&buffer_index, sizeof(buffer_index)),
+             sizeof(buffer_index));
   }
 }
 
 // AudioDeviceThread::Callback implementation
 
 AudioDeviceThread::Callback::Callback(
     const AudioParameters& audio_parameters,
     base::SharedMemoryHandle memory,
     int memory_length,
     int total_segments)
@@ skipping 13 matching lines @@
 }
 
 AudioDeviceThread::Callback::~Callback() {}
 
 void AudioDeviceThread::Callback::InitializeOnAudioThread() {
   MapSharedMemory();
   CHECK(shared_memory_.memory());
 }
 
 }  // namespace media.