// 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 "content/common/gpu/media/gl_surface_capturer.h"

#include "base/message_loop/message_loop_proxy.h"
#include "content/common/gpu/gpu_channel.h"
#include "content/common/gpu/gpu_messages.h"
#include "ipc/ipc_message_macros.h"

namespace content {

namespace {

enum {
  kMaxCaptureSize = 4096,
};

}  // anonymous namespace

GLSurfaceCapturer::GLSurfaceCapturer(int32 route_id, GpuCommandBufferStub* stub)
    : thread_checker_(),
      route_id_(route_id),
      stub_(stub),
      output_format_(media::VideoFrame::INVALID) {
  DCHECK(thread_checker_.CalledOnValidThread());
  stub_->AddDestructionObserver(this);
  stub_->channel()->AddRoute(route_id_, this);
}

GLSurfaceCapturer::~GLSurfaceCapturer() {
  DCHECK(thread_checker_.CalledOnValidThread());
  if (surface_capturer_)
    surface_capturer_.release()->Destroy();

  stub_->channel()->RemoveRoute(route_id_);
  stub_->RemoveDestructionObserver(this);
}

bool GLSurfaceCapturer::OnMessageReceived(const IPC::Message& message) {
  bool handled = true;
  IPC_BEGIN_MESSAGE_MAP(GLSurfaceCapturer, message)
    IPC_MESSAGE_HANDLER(SurfaceCapturerMsg_Initialize, OnInitialize)
    IPC_MESSAGE_HANDLER(SurfaceCapturerMsg_TryCapture, OnTryCapture)
    IPC_MESSAGE_HANDLER(SurfaceCapturerMsg_CopyCaptureToVideoFrame,
                        OnCopyCaptureToVideoFrame)
    IPC_MESSAGE_HANDLER(SurfaceCapturerMsg_Destroy, OnDestroy)
    IPC_MESSAGE_UNHANDLED(handled = false)
  IPC_END_MESSAGE_MAP()
  return handled;
}

void GLSurfaceCapturer::NotifyCaptureParameters(const gfx::Size& buffer_size,
                                                const gfx::Rect& visible_rect) {
  DCHECK(thread_checker_.CalledOnValidThread());
  if (buffer_size.width() < 1 || buffer_size.width() > kMaxCaptureSize ||
      buffer_size.height() < 1 || buffer_size.height() > kMaxCaptureSize ||
      visible_rect.x() < 0 || visible_rect.x() > kMaxCaptureSize - 1 ||
      visible_rect.y() < 0 || visible_rect.y() > kMaxCaptureSize - 1 ||
      visible_rect.width() < 1 || visible_rect.width() > kMaxCaptureSize ||
      visible_rect.height() < 1 || visible_rect.height() > kMaxCaptureSize) {
    DLOG(ERROR) << "NotifyCaptureParameters(): parameters out of bounds: "
                   "buffer_size=" << buffer_size.ToString()
                << ", visible_rect=" << visible_rect.ToString();
    NotifyError(SurfaceCapturer::kInvalidArgumentError);
    return;
  }
  output_buffer_size_ = buffer_size;
  output_visible_rect_ = visible_rect;
  Send(new SurfaceCapturerHostMsg_NotifyCaptureParameters(
      route_id_, buffer_size, visible_rect));
}

void GLSurfaceCapturer::NotifyCopyCaptureDone(
    const scoped_refptr<media::VideoFrame>& frame) {
  DCHECK(thread_checker_.CalledOnValidThread());
  FrameIdMap::iterator iter = frame_id_map_.find(frame);
  if (iter == frame_id_map_.end()) {
    DLOG(ERROR) << "NotifyCopyCaptureDone(): invalid frame";
    NotifyError(SurfaceCapturer::kInvalidArgumentError);
    return;
  }
  Send(new SurfaceCapturerHostMsg_NotifyCopyCaptureDone(route_id_,
                                                        iter->second));
  frame_id_map_.erase(iter);
}

void GLSurfaceCapturer::NotifyError(SurfaceCapturer::Error error) {
  DCHECK(thread_checker_.CalledOnValidThread());
  Send(new SurfaceCapturerHostMsg_NotifyError(route_id_, error));
}

void GLSurfaceCapturer::OnWillDestroyStub() {
  DCHECK(thread_checker_.CalledOnValidThread());
  delete this;
}

void GLSurfaceCapturer::OnInitialize(media::VideoFrame::Format format) {
  DVLOG(2) << "OnInitialize(): format=" << format;
  DCHECK(thread_checker_.CalledOnValidThread());
  DCHECK(!surface_capturer_);

  // TODO(sheu): actually create a surface capturer.

  if (!surface_capturer_) {
    NOTIMPLEMENTED() << "OnInitialize(): GL surface capturing not available";
    NotifyError(SurfaceCapturer::kPlatformFailureError);
    return;
  }

  output_format_ = format;
  surface_capturer_->Initialize(output_format_);
}

void GLSurfaceCapturer::OnTryCapture() {
  DVLOG(3) << "OnTryCapture()";
  DCHECK(thread_checker_.CalledOnValidThread());
  if (!surface_capturer_)
    return;
  surface_capturer_->TryCapture();
}

static void DeleteShm(scoped_ptr<base::SharedMemory> shm) {
  // Just let shm fall out of scope.
}

void GLSurfaceCapturer::OnCopyCaptureToVideoFrame(
    int32 frame_id,
    base::SharedMemoryHandle buffer_shm,
    uint32_t buffer_size) {
  DVLOG(3) << "OnCopyCaptureToVideoFrame(): frame_id=" << frame_id
           << ", buffer_size=" << buffer_size;
  DCHECK(thread_checker_.CalledOnValidThread());
  if (!surface_capturer_)
    return;
  if (frame_id < 0) {
    DLOG(ERROR) << "OnCopyCaptureToVideoFrame(): invalid frame_id=" << frame_id;
    NotifyError(SurfaceCapturer::kPlatformFailureError);
    return;
  }

  scoped_ptr<base::SharedMemory> shm(new base::SharedMemory(buffer_shm, false));
  if (!shm->Map(buffer_size)) {
    DLOG(ERROR) << "OnCopyCaptureToVideoFrame(): could not map "
                   "frame_id=" << frame_id;
    NotifyError(SurfaceCapturer::kPlatformFailureError);
    return;
  }
  scoped_refptr<media::VideoFrame> frame =
      media::VideoFrame::WrapExternalSharedMemory(
          output_format_,
          output_buffer_size_,
          output_visible_rect_,
          output_visible_rect_.size(),
          reinterpret_cast<uint8*>(shm->memory()),
          buffer_size,
          buffer_shm,
          base::TimeDelta(),
          base::Bind(&DeleteShm, base::Passed(&shm)));
  if (!frame) {
    DLOG(ERROR) << "OnCopyCaptureToVideoFrame(): could not create frame for"
                   "frame_id=" << frame_id;
    NotifyError(SurfaceCapturer::kPlatformFailureError);
    return;
  }
  frame_id_map_[frame] = frame_id;
  surface_capturer_->CopyCaptureToVideoFrame(frame);
}

void GLSurfaceCapturer::OnDestroy() {
  DVLOG(2) << "OnDestroy()";
  DCHECK(thread_checker_.CalledOnValidThread());
  delete this;
}

void GLSurfaceCapturer::Send(IPC::Message* message) {
  DCHECK(thread_checker_.CalledOnValidThread());
  uint32 type = message->type();
  if (!stub_->channel()->Send(message)) {
    DLOG(ERROR) << "Send(): send failed: message->type()=" << type;
    NotifyError(SurfaceCapturer::kPlatformFailureError);
  }
}

}  // namespace content