cast: Support for low-latency interactive mode

chrome/renderer/media/cast_rtp_stream.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.
 
 #include "chrome/renderer/media/cast_rtp_stream.h"
 
 #include <algorithm>
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
@@ skipping 153 matching lines @@
   config->ssrc = params.payload.ssrc;
   config->receiver_ssrc = params.payload.feedback_ssrc;
   if (config->ssrc == config->receiver_ssrc)
     return false;
   config->min_playout_delay = base::TimeDelta::FromMilliseconds(
                                   params.payload.min_latency_ms ?
                                   params.payload.min_latency_ms :
                                   params.payload.max_latency_ms);
   config->max_playout_delay =
       base::TimeDelta::FromMilliseconds(params.payload.max_latency_ms);
+  config->animated_playout_delay =
+      base::TimeDelta::FromMilliseconds(params.payload.animated_latency_ms);
   if (config->min_playout_delay <= base::TimeDelta())
     return false;
   if (config->min_playout_delay > config->max_playout_delay)
     return false;
+  if (config->animated_playout_delay < config->min_playout_delay ||
+      config->animated_playout_delay > config->max_playout_delay)
+    return false;
   config->rtp_payload_type = params.payload.payload_type;
   config->use_external_encoder = false;
   config->frequency = params.payload.clock_rate;
   // Sampling rate must be one of the Opus-supported values.
   switch (config->frequency) {
     case 48000:
     case 24000:
     case 16000:
     case 12000:
     case 8000:
@@ skipping 19 matching lines @@
   config->ssrc = params.payload.ssrc;
   config->receiver_ssrc = params.payload.feedback_ssrc;
   if (config->ssrc == config->receiver_ssrc)
     return false;
   config->min_playout_delay = base::TimeDelta::FromMilliseconds(
                                   params.payload.min_latency_ms ?
                                   params.payload.min_latency_ms :
                                   params.payload.max_latency_ms);
   config->max_playout_delay =
       base::TimeDelta::FromMilliseconds(params.payload.max_latency_ms);
+  config->animated_playout_delay =
+      base::TimeDelta::FromMilliseconds(params.payload.animated_latency_ms);
   if (config->min_playout_delay <= base::TimeDelta())
     return false;
   if (config->min_playout_delay > config->max_playout_delay)
     return false;
+  if (config->animated_playout_delay < config->min_playout_delay ||
+      config->animated_playout_delay > config->max_playout_delay)
+    return false;
   config->rtp_payload_type = params.payload.payload_type;
   config->min_bitrate = config->start_bitrate =
       params.payload.min_bitrate * kBitrateMultiplier;
   config->max_bitrate = params.payload.max_bitrate * kBitrateMultiplier;
   if (config->min_bitrate > config->max_bitrate)
     return false;
   config->start_bitrate = config->min_bitrate;
   config->max_frame_rate = static_cast<int>(
       std::max(1.0, params.payload.max_frame_rate) + 0.5);
   if (config->max_frame_rate > media::limits::kMaxFramesPerSecond)
@@ skipping 348 matching lines @@
   DCHECK(content::RenderThread::Get());
   DVLOG(1) << "CastRtpStream::DidEncounterError(" << message << ") = "
            << (IsAudio() ? "audio" : "video");
   // Save the WeakPtr first because the error callback might delete this object.
   base::WeakPtr<CastRtpStream> ptr = weak_factory_.GetWeakPtr();
   error_callback_.Run(message);
   base::ThreadTaskRunnerHandle::Get()->PostTask(
       FROM_HERE,
       base::Bind(&CastRtpStream::Stop, ptr));
 }