Motown: Ffmpeg video decoder

services/media/factory_service/media_sink_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/logging.h"
 #include "mojo/services/media/common/cpp/linear_transform.h"
 #include "mojo/services/media/common/cpp/local_time.h"
 #include "services/media/factory_service/media_sink_impl.h"
 #include "services/media/framework/util/conversion_pipeline_builder.h"
 #include "services/media/framework_mojo/mojo_type_conversions.h"
@@ skipping 56 matching lines @@
       });
 
   producer_->SetStatusCallback([this](MediaState state) {
     producer_state_ = state;
     status_publisher_.SendUpdates();
     if (state == MediaState::ENDED) {
       Pause();
     }
   });
 
+  // TODO(dalesat): Temporary, remove.
+  if (destination_url == "nowhere") {
+    // Throwing away the content.
+    graph_.ConnectParts(consumer_ref, producer_ref);
+    graph_.Prepare();
+    ready_.Occur();
+    return;
+  }
+
   if (destination_url != "mojo:audio_server") {
     LOG(ERROR) << "mojo:audio_server is the only supported destination";
     if (binding_.is_bound()) {
       binding_.Close();
     }
     return;
   }
 
   // TODO(dalesat): Once we have c++14, get rid of this shared pointer hack.
   std::shared_ptr<StreamType> captured_stream_type(
@@ skipping 67 matching lines @@
 void MediaSinkImpl::Pause() {
   target_rate_ = 0.0;
   MaybeSetRate();
 }
 
 void MediaSinkImpl::MaybeSetRate() {
   if (producer_state_ < MediaState::PAUSED || rate_ == target_rate_) {
     return;
   }
 
-  DCHECK(rate_control_);
+  if (!rate_control_) {
+    rate_ = target_rate_;
+    status_publisher_.SendUpdates();
+    return;
+  }
 
   // Desired rate in frames per second.
   LinearTransform::Ratio rate_frames_per_second(
       static_cast<uint32_t>(frames_per_second_ * target_rate_), 1);
 
   // Local time rate in seconds_per_tick.
   LinearTransform::Ratio local_seconds_per_tick(LocalDuration::period::num,
                                                 LocalDuration::period::den);
 
   // Desired rate in frames per local tick.
@@ skipping 75 matching lines @@
   status_transform_->quad->target_delta = rate_frames_per_tick.denominator;
   LinearTransform::Ratio::Reduce(&status_transform_->quad->reference_delta,
                                  &status_transform_->quad->target_delta);
 
   rate_ = target_rate_;
   status_publisher_.SendUpdates();
 }
 
 }  // namespace media
 }  // namespace mojo