Cast:Adding signaling and infrastructure for adjustable delay

media/cast/cast_receiver_impl.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 "media/cast/cast_receiver_impl.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop.h"
@@ skipping 82 matching lines @@
 
 CastReceiverImpl::CastReceiverImpl(
     scoped_refptr<CastEnvironment> cast_environment,
     const AudioReceiverConfig& audio_config,
     const VideoReceiverConfig& video_config,
     transport::PacketSender* const packet_sender)
     : pacer_(cast_environment->Clock(),
              packet_sender,
              cast_environment->GetTaskRunner(CastEnvironment::TRANSPORT)),
       audio_receiver_(cast_environment, audio_config, &pacer_),
-      video_receiver_(cast_environment, video_config, &pacer_),
+      video_receiver_(cast_environment,
+                      video_config,
+                      &pacer_,
+                      base::Bind(&CastReceiverImpl::UpdateTargetDelay,
+                                 base::Unretained(this))),
       frame_receiver_(new LocalFrameReceiver(cast_environment,
                                              &audio_receiver_,
                                              &video_receiver_)),
       cast_environment_(cast_environment),
       ssrc_of_audio_sender_(audio_config.incoming_ssrc),
       ssrc_of_video_sender_(video_config.incoming_ssrc) {}
 
 CastReceiverImpl::~CastReceiverImpl() {}
 
 // The video and audio receivers should only be called from the main thread.
@@ skipping 25 matching lines @@
                                 FROM_HERE,
                                 base::Bind(&VideoReceiver::IncomingPacket,
                                            video_receiver_.AsWeakPtr(),
                                            base::Passed(&packet)));
   } else {
     VLOG(1) << "Received a packet with a non matching sender SSRC "
             << ssrc_of_sender;
   }
 }
 
+void CastReceiverImpl::UpdateTargetDelay(base::TimeDelta target_delay_ms) {
+  audio_receiver_.SetTargetDelay(target_delay_ms);
+}
+
 transport::PacketReceiverCallback CastReceiverImpl::packet_receiver() {
   return base::Bind(&CastReceiverImpl::ReceivedPacket, base::Unretained(this));
 }
 
 scoped_refptr<FrameReceiver> CastReceiverImpl::frame_receiver() {
   return frame_receiver_;
 }
 
 }  // namespace cast
 }  // namespace media