WebSocket implementation in Chromium.

webkit/tools/test_shell/simple_resource_loader_bridge.cc

 // Copyright (c) 2006-2008 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 contains an implementation of the ResourceLoaderBridge class.
 // The class is implemented using URLRequest, meaning it is a "simple" version
 // that directly issues requests. The more complicated one used in the
 // browser uses IPC.
 //
 // Because URLRequest only provides an asynchronous resource loading API, this
@@ skipping 32 matching lines @@
 #include "net/base/load_flags.h"
 #include "net/base/net_errors.h"
 #include "net/base/net_util.h"
 #include "net/base/upload_data.h"
 #include "net/http/http_response_headers.h"
 #include "net/proxy/proxy_service.h"
 #include "net/url_request/url_request.h"
 #include "webkit/appcache/appcache_interfaces.h"
 #include "webkit/glue/resource_loader_bridge.h"
 #include "webkit/tools/test_shell/simple_appcache_system.h"
+#include "webkit/tools/test_shell/simple_socket_stream_bridge.h"
 #include "webkit/tools/test_shell/test_shell_request_context.h"
 
 using webkit_glue::ResourceLoaderBridge;
 using net::CookiePolicy;
 using net::HttpResponseHeaders;
 
 namespace {
 
 //-----------------------------------------------------------------------------
 
 URLRequestContext* request_context = NULL;
 base::Thread* io_thread = NULL;
 
 class IOThread : public base::Thread {
  public:
   IOThread() : base::Thread("IOThread") {
   }
 
   ~IOThread() {
     // We cannot rely on our base class to stop the thread since we want our
     // CleanUp function to run.
     Stop();
   }
 
   virtual void Init() {
     SimpleAppCacheSystem::InitializeOnIOThread(request_context);
+    SimpleSocketStreamBridge::InitializeOnIOThread(request_context);
   }
 
   virtual void CleanUp() {
+    SimpleSocketStreamBridge::Cleanup();
     if (request_context) {
       request_context->Release();
       request_context = NULL;
     }
   }
 };
 
 //-----------------------------------------------------------------------------
 
 struct RequestParams {
@@ skipping 630 matching lines @@
   options.message_loop_type = MessageLoop::TYPE_IO;
   return io_thread->StartWithOptions(options);
 }
 
 // static
 void SimpleResourceLoaderBridge::SetAcceptAllCookies(bool accept_all_cookies) {
   CookiePolicy::Type policy_type = accept_all_cookies ?
       CookiePolicy::ALLOW_ALL_COOKIES : CookiePolicy::BLOCK_THIRD_PARTY_COOKIES;
   request_context->cookie_policy()->set_type(policy_type);
 }