content/renderer/pepper/ppb_tcp_server_socket_private_impl.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 "content/renderer/pepper/ppb_tcp_server_socket_private_impl.h"

#include "base/logging.h"
#include "content/renderer/pepper/host_globals.h"
#include "content/renderer/pepper/pepper_plugin_delegate_impl.h"
#include "content/renderer/pepper/ppb_tcp_socket_private_impl.h"
#include "content/renderer/pepper/resource_helper.h"
#include "ppapi/proxy/ppapi_messages.h"

namespace content {

PPB_TCPServerSocket_Private_Impl::PPB_TCPServerSocket_Private_Impl(
    PP_Instance instance)
    : ::ppapi::PPB_TCPServerSocket_Shared(instance) {
}

PPB_TCPServerSocket_Private_Impl::~PPB_TCPServerSocket_Private_Impl() {
  StopListening();
}

PP_Resource PPB_TCPServerSocket_Private_Impl::CreateResource(
    PP_Instance instance) {
  PPB_TCPServerSocket_Private_Impl* socket =
      new PPB_TCPServerSocket_Private_Impl(instance);
  return socket->GetReference();
}

void PPB_TCPServerSocket_Private_Impl::OnAcceptCompleted(
    bool succeeded,
    uint32 accepted_socket_id,
    const PP_NetAddress_Private& local_addr,
    const PP_NetAddress_Private& remote_addr) {
  if (!::ppapi::TrackedCallback::IsPending(accept_callback_) ||
      !tcp_socket_buffer_) {
    NOTREACHED();
    return;
  }

  if (succeeded) {
    *tcp_socket_buffer_ =
        PPB_TCPSocket_Private_Impl::CreateConnectedSocket(pp_instance(),
                                                          accepted_socket_id,
                                                          local_addr,
                                                          remote_addr);
  }
  tcp_socket_buffer_ = NULL;

  accept_callback_->Run(succeeded ? PP_OK : PP_ERROR_FAILED);
}

void PPB_TCPServerSocket_Private_Impl::SendListen(
    const PP_NetAddress_Private& addr,
    int32_t backlog) {
  PepperPluginDelegateImpl* plugin_delegate = GetPluginDelegate();
  if (!plugin_delegate)
    return;

  plugin_delegate->Send(new PpapiHostMsg_PPBTCPServerSocket_Listen(
      plugin_delegate->routing_id(), 0, pp_resource(), addr, backlog));
}

void PPB_TCPServerSocket_Private_Impl::SendAccept() {
  PepperPluginDelegateImpl* plugin_delegate = GetPluginDelegate();
  if (!plugin_delegate)
    return;

  plugin_delegate->Send(new PpapiHostMsg_PPBTCPServerSocket_Accept(
      plugin_delegate->routing_id(), socket_id_));
}

void PPB_TCPServerSocket_Private_Impl::SendStopListening() {
  PepperPluginDelegateImpl* plugin_delegate = GetPluginDelegate();
  if (!plugin_delegate)
    return;

  if (socket_id_ != 0) {
    plugin_delegate->Send(new PpapiHostMsg_PPBTCPServerSocket_Destroy(
        socket_id_));
    plugin_delegate->TCPServerSocketStopListening(socket_id_);
  }
}

PepperPluginDelegateImpl*
    PPB_TCPServerSocket_Private_Impl::GetPluginDelegate() {
  return static_cast<PepperPluginDelegateImpl*>(
      ResourceHelper::GetPluginDelegate(this));
}

}  // namespace content