Move rtc_video_decoder* from media/filter/ to content/renderer/media/.

media/filters/rtc_video_decoder.cc

Index: media/filters/rtc_video_decoder.cc
===================================================================
--- media/filters/rtc_video_decoder.cc	(revision 90607)
+++ media/filters/rtc_video_decoder.cc	(working copy)
@@ -1,277 +0,0 @@
-// Copyright (c) 2011 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/filters/rtc_video_decoder.h"
-
-#include <deque>
-
-#include "base/task.h"
-#include "googleurl/src/gurl.h"
-#include "media/base/callback.h"
-#include "media/base/filter_host.h"
-#include "media/base/filters.h"
-#include "media/base/limits.h"
-#include "media/base/media_format.h"
-#include "media/base/video_frame.h"
-
-namespace media {
-
-static const char kMediaScheme[] = "media";
-
-RTCVideoDecoder::RTCVideoDecoder(MessageLoop* message_loop,
-                                 const std::string& url)
-    : message_loop_(message_loop),
-      width_(176),
-      height_(144),
-      url_(url),
-      state_(kUnInitialized) {
-}
-
-RTCVideoDecoder::~RTCVideoDecoder() {
-}
-
-void RTCVideoDecoder::Initialize(DemuxerStream* demuxer_stream,
-                                 FilterCallback* filter_callback,
-                                 StatisticsCallback* stat_callback) {
-  if (MessageLoop::current() != message_loop_) {
-    message_loop_->PostTask(
-        FROM_HERE,
-        NewRunnableMethod(this,
-                          &RTCVideoDecoder::Initialize,
-                          make_scoped_refptr(demuxer_stream),
-                          filter_callback, stat_callback));
-    return;
-  }
-
-  DCHECK_EQ(MessageLoop::current(), message_loop_);
-
-  lock_.Acquire();
-  frame_queue_available_.clear();
-  lock_.Release();
-  media_format_.SetAsInteger(MediaFormat::kWidth, width_);
-  media_format_.SetAsInteger(MediaFormat::kHeight, height_);
-  media_format_.SetAsInteger(MediaFormat::kSurfaceType,
-                             static_cast<int>(VideoFrame::YV12));
-  media_format_.SetAsInteger(MediaFormat::kSurfaceFormat,
-                             static_cast<int>(VideoFrame::TYPE_SYSTEM_MEMORY));
-
-  state_ = kNormal;
-
-  filter_callback->Run();
-  delete filter_callback;
-
-  // TODO(acolwell): Implement stats.
-  delete stat_callback;
-}
-
-void RTCVideoDecoder::Play(FilterCallback* callback) {
-  if (MessageLoop::current() != message_loop_) {
-    message_loop_->PostTask(FROM_HERE,
-                             NewRunnableMethod(this,
-                                               &RTCVideoDecoder::Play,
-                                               callback));
-    return;
-  }
-
-  DCHECK_EQ(MessageLoop::current(), message_loop_);
-
-  VideoDecoder::Play(callback);
-}
-
-void RTCVideoDecoder::Pause(FilterCallback* callback) {
-  if (MessageLoop::current() != message_loop_) {
-    message_loop_->PostTask(FROM_HERE,
-                            NewRunnableMethod(this,
-                                              &RTCVideoDecoder::Pause,
-                                              callback));
-    return;
-  }
-
-  DCHECK_EQ(MessageLoop::current(), message_loop_);
-
-  state_ = kPaused;
-
-  VideoDecoder::Pause(callback);
-}
-
-void RTCVideoDecoder::Stop(FilterCallback* callback) {
-  if (MessageLoop::current() != message_loop_) {
-    message_loop_->PostTask(FROM_HERE,
-                            NewRunnableMethod(this,
-                                              &RTCVideoDecoder::Stop,
-                                              callback));
-    return;
-  }
-
-  DCHECK_EQ(MessageLoop::current(), message_loop_);
-
-  state_ = kStopped;
-
-  VideoDecoder::Stop(callback);
-
-  // TODO(ronghuawu): Stop rtc
-}
-
-void RTCVideoDecoder::Seek(base::TimeDelta time, const FilterStatusCB& cb) {
-  if (MessageLoop::current() != message_loop_) {
-     message_loop_->PostTask(FROM_HERE,
-                             NewRunnableMethod(this, &RTCVideoDecoder::Seek,
-                                               time, cb));
-     return;
-  }
-
-  DCHECK_EQ(MessageLoop::current(), message_loop_);
-
-  state_ = kSeeking;
-  // Create output buffer pool and pass the frames to renderer
-  // so that the renderer can complete the seeking
-  for (size_t i = 0; i < Limits::kMaxVideoFrames; ++i) {
-    scoped_refptr<VideoFrame> video_frame;
-    VideoFrame::CreateFrame(VideoFrame::YV12,
-                            width_,
-                            height_,
-                            kNoTimestamp,
-                            kNoTimestamp,
-                            &video_frame);
-    if (!video_frame.get()) {
-      break;
-    }
-
-    // Create black frame
-    const uint8 kBlackY = 0x00;
-    const uint8 kBlackUV = 0x80;
-    // Fill the Y plane.
-    uint8* y_plane = video_frame->data(VideoFrame::kYPlane);
-    for (size_t i = 0; i < height_; ++i) {
-      memset(y_plane, kBlackY, width_);
-      y_plane += video_frame->stride(VideoFrame::kYPlane);
-    }
-    // Fill the U and V planes.
-    uint8* u_plane = video_frame->data(VideoFrame::kUPlane);
-    uint8* v_plane = video_frame->data(VideoFrame::kVPlane);
-    for (size_t i = 0; i < (height_ / 2); ++i) {
-      memset(u_plane, kBlackUV, width_ / 2);
-      memset(v_plane, kBlackUV, width_ / 2);
-      u_plane += video_frame->stride(VideoFrame::kUPlane);
-      v_plane += video_frame->stride(VideoFrame::kVPlane);
-    }
-
-    VideoFrameReady(video_frame);
-  }
-
-  state_ = kNormal;
-
-  cb.Run(PIPELINE_OK);
-
-  // TODO(ronghuawu): Start rtc
-}
-
-const MediaFormat& RTCVideoDecoder::media_format() {
-  return media_format_;
-}
-
-void RTCVideoDecoder::ProduceVideoFrame(
-    scoped_refptr<VideoFrame> video_frame) {
-  if (MessageLoop::current() != message_loop_) {
-    message_loop_->PostTask(
-        FROM_HERE,
-        NewRunnableMethod(this,
-                          &RTCVideoDecoder::ProduceVideoFrame, video_frame));
-    return;
-  }
-  DCHECK_EQ(MessageLoop::current(), message_loop_);
-  lock_.Acquire();
-  frame_queue_available_.push_back(video_frame);
-  lock_.Release();
-}
-
-bool RTCVideoDecoder::ProvidesBuffer() {
-  return true;
-}
-
-int RTCVideoDecoder::FrameSizeChange(unsigned int width,
-                                     unsigned int height,
-                                     unsigned int number_of_streams) {
-  width_ = width;
-  height_ = height;
-
-  media_format_.SetAsInteger(MediaFormat::kWidth, width_);
-  media_format_.SetAsInteger(MediaFormat::kHeight, height_);
-  host()->SetVideoSize(width_, height_);
-  return 0;
-}
-
-int RTCVideoDecoder::DeliverFrame(unsigned char* buffer,
-                                  int buffer_size) {
-  DCHECK(buffer);
-
-  if (frame_queue_available_.size() == 0)
-    return 0;
-
-  if (state_ != kNormal)
-    return 0;
-
-  // This is called from another thread
-  lock_.Acquire();
-  scoped_refptr<VideoFrame> video_frame = frame_queue_available_.front();
-  frame_queue_available_.pop_front();
-  lock_.Release();
-
-  // Check if there's a size change
-  if (video_frame->width() != width_ || video_frame->height() != height_) {
-    video_frame.release();
-    // Allocate new buffer based on the new size
-    VideoFrame::CreateFrame(VideoFrame::YV12,
-                            width_,
-                            height_,
-                            kNoTimestamp,
-                            kNoTimestamp,
-                            &video_frame);
-    if (!video_frame.get()) {
-      return -1;
-    }
-  }
-
-  video_frame->SetTimestamp(host()->GetTime());
-  video_frame->SetDuration(base::TimeDelta::FromMilliseconds(30));
-
-  uint8* y_plane = video_frame->data(VideoFrame::kYPlane);
-  for (size_t row = 0; row < video_frame->height(); ++row) {
-    memcpy(y_plane, buffer, width_);
-    y_plane += video_frame->stride(VideoFrame::kYPlane);
-    buffer += width_;
-  }
-  size_t uv_width = width_/2;
-  uint8* u_plane = video_frame->data(VideoFrame::kUPlane);
-  for (size_t row = 0; row < video_frame->height(); row += 2) {
-    memcpy(u_plane, buffer, uv_width);
-    u_plane += video_frame->stride(VideoFrame::kUPlane);
-    buffer += uv_width;
-  }
-  uint8* v_plane = video_frame->data(VideoFrame::kVPlane);
-  for (size_t row = 0; row < video_frame->height(); row += 2) {
-    memcpy(v_plane, buffer, uv_width);
-    v_plane += video_frame->stride(VideoFrame::kVPlane);
-    buffer += uv_width;
-  }
-
-  if (MessageLoop::current() != message_loop_) {
-    message_loop_->PostTask(
-        FROM_HERE,
-        NewRunnableMethod(this,
-                          &RTCVideoDecoder::VideoFrameReady,
-                          video_frame));
-  } else {
-    VideoFrameReady(video_frame);
-  }
-
-  return 0;
-}
-
-bool RTCVideoDecoder::IsUrlSupported(const std::string& url) {
-  GURL gurl(url);
-  return gurl.SchemeIs(kMediaScheme);
-}
-
-}  // namespace media