[Cast] VideoFrameFactory interface to vend frames with encoder affinity.

media/cast/cast_sender_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_sender_impl.h"
 
 #include "base/bind.h"
 #include "base/callback.h"
 #include "base/logging.h"
 #include "base/message_loop/message_loop.h"
 #include "media/base/video_frame.h"
+#include "media/cast/sender/video_frame_factory.h"
 
 namespace media {
 namespace cast {
 
 // The LocalVideoFrameInput class posts all incoming video frames to the main
 // cast thread for processing.
 class LocalVideoFrameInput : public VideoFrameInput {
  public:
   LocalVideoFrameInput(scoped_refptr<CastEnvironment> cast_environment,
-                       base::WeakPtr<VideoSender> video_sender)
-      : cast_environment_(cast_environment), video_sender_(video_sender) {}
+                       base::WeakPtr<VideoSender> video_sender,
+                       scoped_ptr<VideoFrameFactory> video_frame_factory)
+      : cast_environment_(cast_environment),
+        video_sender_(video_sender),
+        video_frame_factory_(video_frame_factory.Pass()) {}
 
   void InsertRawVideoFrame(const scoped_refptr<media::VideoFrame>& video_frame,
                            const base::TimeTicks& capture_time) override {
     cast_environment_->PostTask(CastEnvironment::MAIN,
                                 FROM_HERE,
                                 base::Bind(&VideoSender::InsertRawVideoFrame,
                                            video_sender_,
                                            video_frame,
                                            capture_time));
   }
 
+  scoped_refptr<VideoFrame> CreateOptimizedFrame(
+      base::TimeDelta timestamp) override {
+    DCHECK(video_frame_factory_.get());
+    return video_frame_factory_->CreateFrame(timestamp);
+  }
+
+  bool SupportsCreateOptimizedFrame() const override {
+    return video_frame_factory_.get() != nullptr;
+  }
+
  protected:
   ~LocalVideoFrameInput() override {}
 
  private:
   friend class base::RefCountedThreadSafe<LocalVideoFrameInput>;
 
   scoped_refptr<CastEnvironment> cast_environment_;
   base::WeakPtr<VideoSender> video_sender_;
+  scoped_ptr<VideoFrameFactory> video_frame_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(LocalVideoFrameInput);
 };
 
 // The LocalAudioFrameInput class posts all incoming audio frames to the main
 // cast thread for processing. Therefore frames can be inserted from any thread.
 class LocalAudioFrameInput : public AudioFrameInput {
  public:
   LocalAudioFrameInput(scoped_refptr<CastEnvironment> cast_environment,
                        base::WeakPtr<AudioSender> audio_sender)
@@ skipping 110 matching lines @@
   }
   if (video_sender_) {
     video_sender_->SetTargetPlayoutDelay(new_target_playout_delay);
   }
 }
 
 void CastSenderImpl::OnVideoInitialized(
     const CastInitializationCallback& initialization_cb,
     media::cast::CastInitializationStatus result) {
   DCHECK(cast_environment_->CurrentlyOn(CastEnvironment::MAIN));
-  video_frame_input_ =
-      new LocalVideoFrameInput(cast_environment_, video_sender_->AsWeakPtr());
+  if (result == STATUS_VIDEO_INITIALIZED) {
+    video_frame_input_ =
+        new LocalVideoFrameInput(cast_environment_, video_sender_->AsWeakPtr(),
+                                 video_sender_->CreateVideoFrameFactory());
+  }
   initialization_cb.Run(result);
 }
 
 }  // namespace cast
 }  // namespace media