Motown: Convert MediaSink to expose MediaTimelineControlSite

services/media/audio/audio_pipe.cc

 // Copyright 2015 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 <limits>
 #include <vector>
 
 #include "services/media/audio/audio_pipe.h"
 #include "services/media/audio/audio_server_impl.h"
 #include "services/media/audio/audio_track_impl.h"
 
 namespace mojo {
 namespace media {
 namespace audio {
 
 AudioPipe::AudioPacketRef::AudioPacketRef(
     MediaPacketStatePtr state,
     AudioServerImpl* server,
     std::vector<Region>&& regions,  // NOLINT(build/c++11)
     int64_t start_pts,
-    int64_t end_pts)
+    int64_t end_pts,
+    uint32_t frame_count)
   : state_(std::move(state)),
     server_(server),
     regions_(std::move(regions)),
     start_pts_(start_pts),
-    end_pts_(end_pts)  {
+    end_pts_(end_pts),
+    frame_count_(frame_count) {
   DCHECK(state_);
   DCHECK(server_);
 }
 
 AudioPipe::AudioPacketRef::~AudioPacketRef() {
   DCHECK(server_);
   server_->SchedulePacketCleanup(std::move(state_));
 }
 
 AudioPipe::AudioPipe(AudioTrackImpl* owner,
@@ skipping 86 matching lines @@
   int64_t pts_delta = (static_cast<int64_t>(frame_count)
                     << AudioTrackImpl::PTS_FRACTIONAL_BITS);
   next_pts_ = start_pts + pts_delta;
   next_pts_known_ = true;
 
   owner_->OnPacketReceived(AudioPacketRefPtr(
         new AudioPacketRef(std::move(state),
                            server_,
                            std::move(regions),
                            start_pts,
-                           next_pts_)));
+                           next_pts_,
+                           frame_count)));
 
    if (!prime_callback_.is_null()) {
      // Prime was requested. Call the callback to indicate priming is complete.
      // TODO(dalesat): Don't do this until low water mark is reached.
      prime_callback_.Run();
      prime_callback_.reset();
    }
 }
 
 void AudioPipe::OnPrimeRequested(const PrimeCallback& cbk) {
   if (!prime_callback_.is_null()) {
     // Prime was already requested. Complete the old one and warn.
     LOG(WARNING) << "multiple prime requests received";
     prime_callback_.Run();
   }
   prime_callback_ = cbk;
 }
 
 bool AudioPipe::OnFlushRequested(const FlushCallback& cbk) {
   DCHECK(owner_);
   next_pts_known_ = false;
   return owner_->OnFlushRequested(cbk);
 }
 
 }  // namespace audio
 }  // namespace media
 }  // namespace mojo