Improving the decoder pipeline.

remoting/client/frame_consumer_proxy.cc

 // Copyright (c) 2012 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 "remoting/client/frame_consumer_proxy.h"
 
 #include "base/bind.h"
 #include "base/message_loop.h"
+#include "ppapi/cpp/image_data.h"
 
 namespace remoting {
 
 FrameConsumerProxy::FrameConsumerProxy(
-    FrameConsumer* frame_consumer,
     base::MessageLoopProxy* frame_consumer_message_loop)
-    : frame_consumer_(frame_consumer),
+    : frame_consumer_(NULL),
       frame_consumer_message_loop_(frame_consumer_message_loop) {
 }
 
 FrameConsumerProxy::~FrameConsumerProxy() {
 }
 
-void FrameConsumerProxy::AllocateFrame(
-    media::VideoFrame::Format format,
-    const SkISize& size,
-    scoped_refptr<media::VideoFrame>* frame_out,
-    const base::Closure& done) {
+void FrameConsumerProxy::ApplyBuffer(const SkISize& view_size,
+                                     const SkIRect& clip_area,
+                                     pp::ImageData* buffer,
+                                     const SkRegion& region) {
   if (!frame_consumer_message_loop_->BelongsToCurrentThread()) {
     frame_consumer_message_loop_->PostTask(FROM_HERE, base::Bind(
-        &FrameConsumerProxy::AllocateFrame, this, format, size, frame_out,
-        done));
-    return;
-  }
-
-  if (frame_consumer_) {
-    frame_consumer_->AllocateFrame(format, size, frame_out, done);
-  }
-}
-
-void FrameConsumerProxy::ReleaseFrame(media::VideoFrame* frame) {
-  if (!frame_consumer_message_loop_->BelongsToCurrentThread()) {
-    frame_consumer_message_loop_->PostTask(FROM_HERE, base::Bind(
-        &FrameConsumerProxy::ReleaseFrame, this, make_scoped_refptr(frame)));
+        &FrameConsumerProxy::ApplyBuffer, this,
+        view_size, clip_area, buffer, region));
     return;
   }
 
   if (frame_consumer_)
-    frame_consumer_->ReleaseFrame(frame);
+    frame_consumer_->ApplyBuffer(view_size, clip_area, buffer, region);
 }
 
-void FrameConsumerProxy::OnPartialFrameOutput(media::VideoFrame* frame,
-                                              SkRegion* region,
-                                              const base::Closure& done) {
+void FrameConsumerProxy::ReturnBuffer(pp::ImageData* buffer) {
   if (!frame_consumer_message_loop_->BelongsToCurrentThread()) {
     frame_consumer_message_loop_->PostTask(FROM_HERE, base::Bind(
-        &FrameConsumerProxy::OnPartialFrameOutput, this,
-        make_scoped_refptr(frame), region, done));
+        &FrameConsumerProxy::ReturnBuffer, this, buffer));
     return;
   }
 
   if (frame_consumer_)
-    frame_consumer_->OnPartialFrameOutput(frame, region, done);
+    frame_consumer_->ReturnBuffer(buffer);
+}
+
+void FrameConsumerProxy::SetSourceSize(const SkISize& source_size) {
+  if (!frame_consumer_message_loop_->BelongsToCurrentThread()) {
+    frame_consumer_message_loop_->PostTask(FROM_HERE, base::Bind(
+        &FrameConsumerProxy::SetSourceSize, this, source_size));
+    return;
+  }
+
+  if (frame_consumer_)
+    frame_consumer_->SetSourceSize(source_size);
+}
+
+void FrameConsumerProxy::Attach(FrameConsumer* frame_consumer) {
+  DCHECK(frame_consumer_message_loop_->BelongsToCurrentThread());
+  DCHECK(frame_consumer_ == NULL);
+  frame_consumer_ = frame_consumer;
 }
 
 void FrameConsumerProxy::Detach() {
   DCHECK(frame_consumer_message_loop_->BelongsToCurrentThread());
   frame_consumer_ = NULL;
 }
 
 }  // namespace remoting