Exposed Listen and Accept methods to plugin.

ppapi/shared_impl/private/ppb_tcp_server_socket_shared.h

+// 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.
+
+#ifndef PPAPI_SHARED_IMPL_PRIVATE_PPB_TCP_SERVER_SOCKET_SHARED_H_
+#define PPAPI_SHARED_IMPL_PRIVATE_PPB_TCP_SERVER_SOCKET_SHARED_H_
+
+#include "base/compiler_specific.h"
+#include "ppapi/c/pp_completion_callback.h"
+#include "ppapi/shared_impl/resource.h"
+#include "ppapi/shared_impl/tracked_callback.h"
+#include "ppapi/thunk/ppb_tcp_server_socket_private_api.h"
+
+namespace ppapi {
+
+// This class provides the shared implementation of a
+// PPB_TCPServerSocket_Private.  The functions that actually send
+// messages to browser are implemented differently for the proxied and
+// non-proxied derived classes.
+class PPAPI_SHARED_EXPORT PPB_TCPServerSocket_Shared
+    : public thunk::PPB_TCPServerSocket_Private_API,
+      public Resource {
+public:
+  // C-tor used in Impl case.
+  PPB_TCPServerSocket_Shared(PP_Instance instance);
+  // C-tor used in Proxy case.
+  PPB_TCPServerSocket_Shared(const HostResource& resource);
+
+  virtual ~PPB_TCPServerSocket_Shared();
+
+  // Resource overrides.
+  virtual PPB_TCPServerSocket_Private_API*
+      AsPPB_TCPServerSocket_Private_API() OVERRIDE;
+
+  // Must be called for proper initialization of TCPServerSocket object before
+  // any other calls, such as Listen, Accept of StopListening.
+  int32_t Initialize(PP_CompletionCallback callback);
+
+  // PPB_TCPServerSocket_Private_API implementation.
+  virtual int32_t Listen(const PP_NetAddress_Private* addr,
+                         int32_t backlog,
+                         PP_CompletionCallback callback) OVERRIDE;
+  virtual int32_t Accept(char* tcp_socket,
+                         PP_CompletionCallback callback) OVERRIDE;
+  virtual void StopListening() OVERRIDE;
+
+  // Notifications on operations completion.
+  void OnInitializeCompleted(uint32 socket_id);
+  void OnListenCompleted(bool succeeded);
+  virtual void OnAcceptCompleted(bool succeeded,
+                                 uint32 tcp_socket_id,
+                                 const PP_NetAddress_Private& local_addr,
+                                 const PP_NetAddress_Private& remote_addr) = 0;
+
+  // Send functions that need to be implemented differently for the
+  // proxied and non-proxied derived classes.
+  virtual void SendInitialize() = 0;
+  virtual void SendListen(const PP_NetAddress_Private& addr,
+                          int32_t backlog) = 0;
+  virtual void SendAccept() = 0;
+  virtual void SendStopListening() = 0;
+
+protected:
+  enum State {
+    // Object of this class is created, but not initialized with
+    // correct value of socket_id_.
+    NOT_INITIALIZED,
+    // Before listening (including a listen request is pending or a
+    // previous listen request failed).
+    BEFORE_LISTENING,
+    // Socket is successfully bound and in listening mode.
+    LISTENING,
+    // The socket is closed.
+    CLOSED,
+  };
+
+  void InternalInitialize(uint32 socket_id);
+  void PostAbortAndClearIfNecessary(scoped_refptr<TrackedCallback>* callback);
+
+  PP_Instance instance_;
+  uint32 socket_id_;
+  State state_;
+
+  scoped_refptr<TrackedCallback> initialize_callback_;
+  scoped_refptr<TrackedCallback> listen_callback_;
+  scoped_refptr<TrackedCallback> accept_callback_;
+
+  char* tcp_socket_buffer_;
+
+  DISALLOW_COPY_AND_ASSIGN(PPB_TCPServerSocket_Shared);
+};
+
+}  // namespace ppapi
+
+#endif  // PPAPI_SHARED_IMPL_PRIVATE_PPB_TCP_SERVER_SOCKET_SHARED_H_