WebSocket implementation in Chromium.

chrome/renderer/renderer_glue.cc

 // Copyright (c) 2009 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.
 
 // This file provides the embedder's side of random webkit glue functions.
 
 #include "build/build_config.h"
 
 #include <vector>
 
 #if defined(OS_WIN)
 #include <windows.h>
 #include <wininet.h>
 #endif
 
 #include "app/clipboard/clipboard.h"
 #include "app/clipboard/scoped_clipboard_writer.h"
 #include "app/resource_bundle.h"
 #include "base/string_util.h"
 #include "chrome/common/chrome_switches.h"
 #include "chrome/common/render_messages.h"
 #include "chrome/common/url_constants.h"
 #include "chrome/plugin/npobject_util.h"
 #include "chrome/renderer/net/render_dns_master.h"
 #include "chrome/renderer/render_process.h"
 #include "chrome/renderer/render_thread.h"
+#include "chrome/renderer/socket_stream_dispatcher.h"
 #include "googleurl/src/url_util.h"
 #include "third_party/skia/include/core/SkBitmap.h"
 #include "webkit/api/public/WebKit.h"
 #include "webkit/api/public/WebKitClient.h"
 #include "webkit/api/public/WebString.h"
 #include "webkit/glue/scoped_clipboard_writer_glue.h"
 #include "webkit/glue/webkit_glue.h"
+#include "webkit/glue/websocketstreamhandle_bridge.h"
 
 #if defined(OS_WIN)
 #include <strsafe.h>  // note: per msdn docs, this must *follow* other includes
 #endif
 
 template <typename T, size_t stack_capacity>
 class ResizableStackArray {
  public:
   ResizableStackArray()
       : cur_buffer_(stack_buffer_), cur_capacity_(stack_capacity) {
@@ skipping 192 matching lines @@
     ResourceType::Type resource_type,
     int appcache_host_id,
     int routing_id) {
   ResourceDispatcher* dispatch = ChildThread::current()->resource_dispatcher();
   return dispatch->CreateBridge(method, url, first_party_for_cookies, referrer,
                                 frame_origin, main_frame_origin, headers,
                                 load_flags, origin_pid, resource_type, 0,
                                 appcache_host_id, routing_id);
 }
 
+// static factory function
+webkit_glue::WebSocketStreamHandleBridge* WebSocketStreamHandleBridge::Create(
+    WebKit::WebSocketStreamHandle* handle,
+    webkit_glue::WebSocketStreamHandleDelegate* delegate) {
+  SocketStreamDispatcher* dispatch =
+          RenderThread::current()->socket_stream_dispatcher();
+  return dispatch->CreateBridge(handle, delegate);
+}
+
 void NotifyCacheStats() {
   // Update the browser about our cache
   // NOTE: Since this can be called from the plugin process, we might not have
   // a RenderThread.  Do nothing in that case.
   if (RenderThread::current())
     RenderThread::current()->InformHostOfCacheStatsLater();
 }
 
 void CloseIdleConnections() {
   RenderThread::current()->CloseIdleConnections();
 }
 
 void SetCacheMode(bool enabled) {
   RenderThread::current()->SetCacheMode(enabled);
 }
 
 }  // namespace webkit_glue