Motown: Convert MediaSink to expose MediaTimelineControlSite

services/media/factory_service/media_source_impl.cc

 // Copyright 2016 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/bind.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop.h"
 #include "services/media/factory_service/media_source_impl.h"
 #include "services/media/framework/util/callback_joiner.h"
 #include "services/media/framework/util/conversion_pipeline_builder.h"
@@ skipping 23 matching lines @@
     : MediaFactoryService::Product<MediaSource>(this, request.Pass(), owner),
       allowed_media_types_(allowed_media_types.Clone()) {
   DCHECK(reader);
 
   task_runner_ = base::MessageLoop::current()->task_runner();
   DCHECK(task_runner_);
 
   status_publisher_.SetCallbackRunner(
       [this](const GetStatusCallback& callback, uint64_t version) {
         MediaSourceStatusPtr status = MediaSourceStatus::New();
-        status->state = state_;
         status->metadata =
             demux_ ? MediaMetadata::From(demux_->metadata()) : nullptr;
         callback.Run(version, status.Pass());
       });
 
   std::shared_ptr<Reader> reader_ptr = MojoReader::Create(reader.Pass());
   if (!reader_ptr) {
-    NOTREACHED() << "couldn't create reader";
-    state_ = MediaState::FAULT;
+    LOG(ERROR) << "couldn't create reader";
+    // TODO(dalesat): Add problem reporting.
     return;
   }
 
   demux_ = Demux::Create(reader_ptr);
   if (!demux_) {
-    NOTREACHED() << "couldn't create demux";
-    state_ = MediaState::FAULT;
+    LOG(ERROR) << "couldn't create demux";
+    // TODO(dalesat): Add problem reporting.
     return;
   }
 
   demux_->WhenInitialized([this](Result result) {
     task_runner_->PostTask(FROM_HERE,
                            base::Bind(&MediaSourceImpl::OnDemuxInitialized,
                                       base::Unretained(this), result));
   });
 }
 
@@ skipping 60 matching lines @@
   status_publisher_.Get(version_last_seen, callback);
 }
 
 void MediaSourceImpl::Prepare(const PrepareCallback& callback) {
   RCHECK(init_complete_.occurred());
 
   for (std::unique_ptr<Stream>& stream : streams_) {
     stream->EnsureSink();
   }
   graph_.Prepare();
-  state_ = MediaState::PAUSED;
   callback.Run();
   status_publisher_.SendUpdates();
 }
 
 void MediaSourceImpl::Prime(const PrimeCallback& callback) {
   RCHECK(init_complete_.occurred());
 
   std::shared_ptr<CallbackJoiner> callback_joiner = CallbackJoiner::Create();
 
   for (std::unique_ptr<Stream>& stream : streams_) {
@@ skipping 115 matching lines @@
     const MojoProducer::FlushConnectionCallback callback) {
   if (producer_ != nullptr) {
     producer_->FlushConnection(callback);
   } else {
     callback.Run();
   }
 }
 
 }  // namespace media
 }  // namespace mojo