Media Remoting: Don't exit remoting if no enough data buffered.

media/remoting/remote_renderer_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 "media/remoting/remote_renderer_impl.h"
 
 #include <algorithm>
 #include <limits>
 #include <utility>
 
@@ skipping 572 matching lines @@
     OnFatalError(remoting::RPC_INVALID);
     return;
   }
   VLOG(2) << __func__ << ": Received RPC_RC_ONBUFFERINGSTATECHANGE with state="
           << message->rendererclient_onbufferingstatechange_rpc().state();
   base::Optional<::media::BufferingState> state =
       remoting::ToMediaBufferingState(
           message->rendererclient_onbufferingstatechange_rpc().state());
   if (!state.has_value())
     return;
+  if (state == BufferingState::BUFFERING_HAVE_NOTHING) {
+    is_waiting_for_buffering_ = true;
+  } else if (is_waiting_for_buffering_) {
+    is_waiting_for_buffering_ = false;
+    ResetMeasurements();
+  }
+
   client_->OnBufferingStateChange(state.value());
 }
 
 void RemoteRendererImpl::OnVideoNaturalSizeChange(
     std::unique_ptr<remoting::pb::RpcMessage> message) {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
   DCHECK(message);
   // Shutdown remoting session if receiving malformed RPC message.
   if (!message->has_rendererclient_onvideonatualsizechange_rpc()) {
     VLOG(1) << __func__ << " missing required RPC message";
@@ skipping 117 matching lines @@
     interstitial_background_ = background_image.value();
   canvas_size_ = canvas_size;
   PaintRemotingInterstitial(interstitial_background_, canvas_size_,
                             interstitial_type, video_renderer_sink_);
 }
 
 void RemoteRendererImpl::OnMediaTimeUpdated() {
   DCHECK(media_task_runner_->BelongsToCurrentThread());
   if (!flush_cb_.is_null())
     return;  // Don't manage and check the queue when Flush() is on-going.
+  if (is_waiting_for_buffering_)
+    return;  // Don't manage and check the queue when buffering is on-going.
 
   base::TimeTicks current_time = base::TimeTicks::Now();
   if (current_time < ignore_updates_until_time_)
     return;  // Not stable yet.
 
   media_time_queue_.push_back(
       std::make_pair(current_time, current_media_time_));
   base::TimeDelta window_duration =
       current_time - media_time_queue_.front().first;
   if (window_duration < kTrackingWindow)
@@ skipping 117 matching lines @@
          kDataFlowPollPeriod.InSecondsF()) /
         kBytesPerKilobit;
     DCHECK_GE(kilobits_per_second, 0);
     const base::CheckedNumeric<int> checked_kbps = kilobits_per_second;
     metrics_recorder_.OnVideoRateEstimate(
         checked_kbps.ValueOrDefault(std::numeric_limits<int>::max()));
   }
 }
 
 }  // namespace media