Home | History | Annotate | Download | only in pepper 
      1 // Copyright 2013 The Chromium Authors. All rights reserved.
      2 // Use of this source code is governed by a BSD-style license that can be
      3 // found in the LICENSE file.
      4 
      5 #ifndef CONTENT_BROWSER_RENDERER_HOST_PEPPER_PEPPER_TCP_SERVER_SOCKET_MESSAGE_FILTER_H_
      6 #define CONTENT_BROWSER_RENDERER_HOST_PEPPER_PEPPER_TCP_SERVER_SOCKET_MESSAGE_FILTER_H_
      7 
      8 #include "base/basictypes.h"
      9 #include "base/compiler_specific.h"
     10 #include "base/memory/ref_counted.h"
     11 #include "base/memory/scoped_ptr.h"
     12 #include "content/common/content_export.h"
     13 #include "net/base/ip_endpoint.h"
     14 #include "net/socket/tcp_socket.h"
     15 #include "ppapi/c/pp_instance.h"
     16 #include "ppapi/host/resource_message_filter.h"
     17 
     18 struct PP_NetAddress_Private;
     19 
     20 namespace ppapi {
     21 namespace host {
     22 class PpapiHost;
     23 }
     24 }
     25 
     26 namespace content {
     27 
     28 class BrowserPpapiHostImpl;
     29 class ContentBrowserPepperHostFactory;
     30 
     31 // TODO(yzshen): Remove this class entirely and let
     32 // TCPServerSocketPrivateResource inherit TCPSocketResourceBase.
     33 class CONTENT_EXPORT PepperTCPServerSocketMessageFilter
     34     : public ppapi::host::ResourceMessageFilter {
     35  public:
     36   PepperTCPServerSocketMessageFilter(
     37       ContentBrowserPepperHostFactory* factory,
     38       BrowserPpapiHostImpl* host,
     39       PP_Instance instance,
     40       bool private_api);
     41 
     42   static size_t GetNumInstances();
     43 
     44  protected:
     45   virtual ~PepperTCPServerSocketMessageFilter();
     46 
     47  private:
     48   enum State {
     49     STATE_BEFORE_LISTENING,
     50     STATE_LISTEN_IN_PROGRESS,
     51     STATE_LISTENING,
     52     STATE_ACCEPT_IN_PROGRESS,
     53     STATE_CLOSED
     54   };
     55 
     56   // ppapi::host::ResourceMessageFilter overrides.
     57   virtual scoped_refptr<base::TaskRunner> OverrideTaskRunnerForMessage(
     58       const IPC::Message& message) OVERRIDE;
     59   virtual int32_t OnResourceMessageReceived(
     60       const IPC::Message& msg,
     61       ppapi::host::HostMessageContext* context) OVERRIDE;
     62 
     63   int32_t OnMsgListen(const ppapi::host::HostMessageContext* context,
     64                       const PP_NetAddress_Private& addr,
     65                       int32_t backlog);
     66   int32_t OnMsgAccept(const ppapi::host::HostMessageContext* context);
     67   int32_t OnMsgStopListening(const ppapi::host::HostMessageContext* context);
     68 
     69   void DoListen(const ppapi::host::ReplyMessageContext& context,
     70                 const PP_NetAddress_Private& addr,
     71                 int32_t backlog);
     72 
     73   void OnListenCompleted(const ppapi::host::ReplyMessageContext& context,
     74                          int net_result);
     75   void OnAcceptCompleted(const ppapi::host::ReplyMessageContext& context,
     76                          int net_result);
     77 
     78   void SendListenReply(const ppapi::host::ReplyMessageContext& context,
     79                        int32_t pp_result,
     80                        const PP_NetAddress_Private& local_addr);
     81   void SendListenError(const ppapi::host::ReplyMessageContext& context,
     82                        int32_t pp_result);
     83   void SendAcceptReply(const ppapi::host::ReplyMessageContext& context,
     84                        int32_t pp_result,
     85                        int pending_resource_id,
     86                        const PP_NetAddress_Private& local_addr,
     87                        const PP_NetAddress_Private& remote_addr);
     88   void SendAcceptError(const ppapi::host::ReplyMessageContext& context,
     89                        int32_t pp_result);
     90 
     91   // Following fields are initialized and used only on the IO thread.
     92   // Non-owning ptr.
     93   ppapi::host::PpapiHost* ppapi_host_;
     94   // Non-owning ptr.
     95   ContentBrowserPepperHostFactory* factory_;
     96   PP_Instance instance_;
     97 
     98   State state_;
     99   scoped_ptr<net::TCPSocket> socket_;
    100   scoped_ptr<net::TCPSocket> accepted_socket_;
    101   net::IPEndPoint accepted_address_;
    102 
    103   // Following fields are initialized on the IO thread but used only
    104   // on the UI thread.
    105   const bool external_plugin_;
    106   const bool private_api_;
    107   int render_process_id_;
    108   int render_view_id_;
    109 
    110   DISALLOW_COPY_AND_ASSIGN(PepperTCPServerSocketMessageFilter);
    111 };
    112 
    113 }  // namespace content
    114 
    115 #endif  // CONTENT_BROWSER_RENDERER_HOST_PEPPER_PEPPER_TCP_SERVER_SOCKET_MESSAGE_FILTER_H_
    116