Pass delay and timestamp to AudioSourceCallback::OnMoreData.

media/audio/alsa/alsa_output.cc

 // Copyright 2013 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.
 //
 // THREAD SAFETY
 //
 // AlsaPcmOutputStream object is *not* thread-safe and should only be used
 // from the audio thread.  We DCHECK on this assumption whenever we can.
 //
 // SEMANTICS OF Close()
@@ skipping 107 matching lines @@
       break;
     case AlsaPcmOutputStream::kIsPlaying:
       os << "kIsPlaying";
       break;
     case AlsaPcmOutputStream::kIsStopped:
       os << "kIsStopped";
       break;
     case AlsaPcmOutputStream::kIsClosed:
       os << "kIsClosed";
       break;
-  };
+  }
   return os;
 }
 
 const char AlsaPcmOutputStream::kDefaultDevice[] = "default";
 const char AlsaPcmOutputStream::kAutoSelectDevice[] = "";
 const char AlsaPcmOutputStream::kPlugPrefix[] = "plug:";
 
 // We use 40ms as our minimum required latency. If it is needed, we may be able
 // to get it down to 20ms.
 const uint32_t AlsaPcmOutputStream::kMinLatencyMicros = 40 * 1000;
@@ skipping 215 matching lines @@
     *source_exhausted = true;
     return;
   }
 
   *source_exhausted = false;
 
   // Request more data only when we run out of data in the buffer, because
   // WritePacket() consumes only the current chunk of data.
   if (!buffer_->forward_bytes()) {
     // Before making a request to source for data we need to determine the
-    // delay (in bytes) for the requested data to be played.
-    const uint32_t hardware_delay = GetCurrentDelay() * bytes_per_frame_;
+    // time when the requested data will be played.
+    const base::TimeTicks target_playout_time =
+        base::TimeTicks::Now() +
+        FramesToTimeDelta(GetCurrentDelay(), sample_rate_);
 
     scoped_refptr<media::DataBuffer> packet =
         new media::DataBuffer(packet_size_);
-    int frames_filled = RunDataCallback(
-        audio_bus_.get(), hardware_delay);
+    int frames_filled = RunDataCallback(target_playout_time, audio_bus_.get());
 
     size_t packet_size = frames_filled * bytes_per_frame_;
     DCHECK_LE(packet_size, packet_size_);
 
     // TODO(dalecurtis): Channel downmixing, upmixing, should be done in mixer;
     // volume adjust should use SSE optimized vector_fmul() prior to interleave.
     AudioBus* output_bus = audio_bus_.get();
     ChannelLayout output_channel_layout = channel_layout_;
     if (channel_mixer_) {
       output_bus = mixed_audio_bus_.get();
@@ skipping 389 matching lines @@
   } else {
     state_ = to;
   }
   return state_;
 }
 
 AlsaPcmOutputStream::InternalState AlsaPcmOutputStream::state() {
   return state_;
 }
 
-int AlsaPcmOutputStream::RunDataCallback(AudioBus* audio_bus,
-                                         uint32_t total_bytes_delay) {
+int AlsaPcmOutputStream::RunDataCallback(base::TimeTicks target_playout_time,
+                                         AudioBus* audio_bus) {
   TRACE_EVENT0("audio", "AlsaPcmOutputStream::RunDataCallback");
 
   if (source_callback_)
-    return source_callback_->OnMoreData(audio_bus, total_bytes_delay, 0);
+    return source_callback_->OnMoreData(target_playout_time, 0, audio_bus);
 
   return 0;
 }
 
 void AlsaPcmOutputStream::RunErrorCallback(int code) {
   if (source_callback_)
     source_callback_->OnError(this);
 }
 
 // Changes the AudioSourceCallback to proxy calls to.  Pass in NULL to
 // release ownership of the currently registered callback.
 void AlsaPcmOutputStream::set_source_callback(AudioSourceCallback* callback) {
   DCHECK(CalledOnValidThread());
   source_callback_ = callback;
 }
 
 }  // namespace media