Move some webkit_glue embedder functions into WebKitPlatformSupport virtual methods

webkit/glue/websocketstreamhandle_impl.cc

 // 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.
 
 // An implementation of WebSocketStreamHandle.
 
 #include "webkit/glue/websocketstreamhandle_impl.h"
 
 #include <vector>
 
 #include "base/compiler_specific.h"
 #include "base/logging.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebData.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebURL.h"
 #include "third_party/WebKit/Source/WebKit/chromium/public/WebSocketStreamHandleClient.h"
+#include "webkit/glue/webkitplatformsupport_impl.h"
 #include "webkit/glue/websocketstreamhandle_bridge.h"
 #include "webkit/glue/websocketstreamhandle_delegate.h"
 
 namespace webkit_glue {
 
 // WebSocketStreamHandleImpl::Context -----------------------------------------
 
 class WebSocketStreamHandleImpl::Context
     : public base::RefCounted<Context>,
       public WebSocketStreamHandleDelegate {
  public:
   explicit Context(WebSocketStreamHandleImpl* handle);
 
   WebKit::WebSocketStreamHandleClient* client() const { return client_; }
   void set_client(WebKit::WebSocketStreamHandleClient* client) {
     client_ = client;
   }
 
-  void Connect(const WebKit::WebURL& url);
+  void Connect(const WebKit::WebURL& url, WebKitPlatformSupportImpl* platform);
   bool Send(const WebKit::WebData& data);
   void Close();
 
   // Must be called before |handle_| or |client_| is deleted.
   // Once detached, it never calls |client_| back.
   void Detach();
 
   // WebSocketStreamHandleDelegate methods:
   virtual void DidOpenStream(WebKit::WebSocketStreamHandle*, int);
   virtual void DidSendData(WebKit::WebSocketStreamHandle*, int);
@@ skipping 17 matching lines @@
 
   DISALLOW_COPY_AND_ASSIGN(Context);
 };
 
 WebSocketStreamHandleImpl::Context::Context(WebSocketStreamHandleImpl* handle)
     : handle_(handle),
       client_(NULL),
       bridge_(NULL) {
 }
 
-void WebSocketStreamHandleImpl::Context::Connect(const WebKit::WebURL& url) {
+void WebSocketStreamHandleImpl::Context::Connect(
+    const WebKit::WebURL& url,
+    WebKitPlatformSupportImpl* platform) {
   VLOG(1) << "Connect url=" << url;
   DCHECK(!bridge_);
-  bridge_ = WebSocketStreamHandleBridge::Create(handle_, this);
+  bridge_ = platform->CreateWebSocketBridge(handle_, this);
   AddRef();  // Will be released by DidClose().
   bridge_->Connect(url);
 }
 
 bool WebSocketStreamHandleImpl::Context::Send(const WebKit::WebData& data) {
   VLOG(1) << "Send data.size=" << data.size();
   DCHECK(bridge_);
   return bridge_->Send(
       std::vector<char>(data.data(), data.data() + data.size()));
 }
@@ skipping 43 matching lines @@
   if (client_) {
     WebKit::WebSocketStreamHandleClient* client = client_;
     client_ = NULL;
     client->didClose(handle);
   }
   Release();
 }
 
 // WebSocketStreamHandleImpl ------------------------------------------------
 
-WebSocketStreamHandleImpl::WebSocketStreamHandleImpl()
-    : ALLOW_THIS_IN_INITIALIZER_LIST(context_(new Context(this))) {
+WebSocketStreamHandleImpl::WebSocketStreamHandleImpl(
+    WebKitPlatformSupportImpl* platform)
+    : ALLOW_THIS_IN_INITIALIZER_LIST(context_(new Context(this))),
+      platform_(platform) {
 }
 
 WebSocketStreamHandleImpl::~WebSocketStreamHandleImpl() {
   // We won't receive any events from |context_|.
   // |context_| is ref counted, and will be released when it received
   // DidClose.
   context_->Detach();
 }
 
 void WebSocketStreamHandleImpl::connect(
     const WebKit::WebURL& url, WebKit::WebSocketStreamHandleClient* client) {
   VLOG(1) << "connect url=" << url;
   DCHECK(!context_->client());
   context_->set_client(client);
 
-  context_->Connect(url);
+  context_->Connect(url, platform_);
 }
 
 bool WebSocketStreamHandleImpl::send(const WebKit::WebData& data) {
   return context_->Send(data);
 }
 
 void WebSocketStreamHandleImpl::close() {
   context_->Close();
 }
 
 }  // namespace webkit_glue