Revert 115093 because of memory test failures - WebSocket Pepper API: C++ helper class implementa...

ppapi/cpp/helper/dev/websocket_api_dev.cc

Index: ppapi/cpp/helper/dev/websocket_api_dev.cc
===================================================================
--- ppapi/cpp/helper/dev/websocket_api_dev.cc	(revision 115098)
+++ ppapi/cpp/helper/dev/websocket_api_dev.cc	(working copy)
@@ -1,120 +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 "ppapi/cpp/helper/dev/websocket_api_dev.h"
-
-#include "ppapi/c/pp_errors.h"
-#include "ppapi/c/pp_macros.h"
-#include "ppapi/cpp/completion_callback.h"
-#include "ppapi/cpp/dev/websocket_dev.h"
-#include "ppapi/cpp/instance.h"
-#include "ppapi/cpp/module.h"
-#include "ppapi/cpp/module_impl.h"
-#include "ppapi/cpp/var.h"
-
-namespace pp {
-
-namespace helper {
-
-class WebSocketAPI_Dev::Implement : public WebSocket_Dev {
- public:
-  Implement(Instance* instance, WebSocketAPI_Dev* api)
-      : WebSocket_Dev(instance),
-        api_(api),
-        callback_factory_(PP_ALLOW_THIS_IN_INITIALIZER_LIST(this)) {
-  }
-
-  ~Implement() {}
-
-  int32_t Connect(const Var& url, const Var protocols[],
-                  uint32_t protocol_count) {
-    return WebSocket_Dev::Connect(url, protocols, protocol_count,
-        callback_factory_.NewOptionalCallback(&Implement::DidConnect));
-  }
-
-  int32_t Close(uint16_t code, const Var& reason) {
-    return WebSocket_Dev::Close(code, reason,
-        callback_factory_.NewOptionalCallback(&Implement::DidClose));
-  }
-
-  void Receive() {
-    WebSocket_Dev::ReceiveMessage(&receive_message_var_,
-        callback_factory_.NewCallback(&Implement::DidReceive));
-  }
-
-  void DidConnect(int32_t result) {
-    if (result == PP_OK) {
-      api_->OnOpen();
-      Receive();
-    } else if (result != PP_ERROR_ABORTED) {
-      DidClose(result);
-    }
-  }
-
-  void DidReceive(int32_t result) {
-    if (result == PP_OK) {
-      api_->OnMessage(receive_message_var_);
-      Receive();
-    } else if (result != PP_ERROR_ABORTED) {
-      DidClose(result);
-    }
-  }
-
-  void DidClose(int32_t result) {
-    bool was_clean = GetCloseWasClean() && result == PP_OK;
-    if (!was_clean)
-      api_->OnError();
-    api_->OnClose(was_clean, GetCloseCode(), GetCloseReason());
-  }
-
- private:
-  WebSocketAPI_Dev* api_;
-  CompletionCallbackFactory<Implement> callback_factory_;
-  Var receive_message_var_;
-};
-
-WebSocketAPI_Dev::WebSocketAPI_Dev(Instance* instance)
-    : impl_(new Implement(instance, PP_ALLOW_THIS_IN_INITIALIZER_LIST(this))) {
-}
-
-WebSocketAPI_Dev::~WebSocketAPI_Dev() {
-  delete impl_;
-}
-
-int32_t WebSocketAPI_Dev::Connect(const Var& url, const Var protocols[],
-                                  uint32_t protocol_count) {
-  return impl_->Connect(url, protocols, protocol_count);
-}
-
-int32_t WebSocketAPI_Dev::Close(uint16_t code, const Var& reason) {
-  return impl_->Close(code, reason);
-}
-
-int32_t WebSocketAPI_Dev::Send(const Var& data) {
-  return impl_->SendMessage(data);
-}
-
-uint64_t WebSocketAPI_Dev::GetBufferedAmount() {
-  return impl_->GetBufferedAmount();
-}
-
-Var WebSocketAPI_Dev::GetExtensions() {
-  return impl_->GetExtensions();
-}
-
-Var WebSocketAPI_Dev::GetProtocol() {
-  return impl_->GetProtocol();
-}
-
-PP_WebSocketReadyState_Dev WebSocketAPI_Dev::GetReadyState() {
-  return impl_->GetReadyState();
-}
-
-Var WebSocketAPI_Dev::GetURL() {
-  return impl_->GetURL();
-}
-
-}  // namespace helper
-
-}  // namespace pp