Websocket to TCP proxy running in a separate thread (only on ChromeOS).

chrome/browser/browser_main.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.
 
 #include "chrome/browser/browser_main.h"
 
 #include <algorithm>
 #include <string>
 #include <vector>
 
@@ skipping 110 matching lines @@
 #if defined(OS_POSIX) && !defined(OS_MACOSX)
 #include <dbus/dbus-glib.h>
 #include "chrome/browser/browser_main_gtk.h"
 #include "chrome/browser/ui/gtk/gtk_util.h"
 #endif
 
 #if defined(OS_CHROMEOS)
 #include "chrome/browser/chromeos/boot_times_loader.h"
 #include "chrome/browser/chromeos/brightness_observer.h"
 #include "chrome/browser/chromeos/system_key_event_listener.h"
+#include "chrome/browser/chromeos/webproxy_task.h"
 #include "chrome/browser/oom_priority_manager.h"
 #endif
 
 // TODO(port): several win-only methods have been pulled out of this, but
 // BrowserMain() as a whole needs to be broken apart so that it's usable by
 // other platforms. For now, it's just a stub. This is a serious work in
 // progress and should not be taken as an indication of a real refactoring.
 
 #if defined(OS_WIN)
 #include <commctrl.h>
@@ skipping 493 matching lines @@
 
 // Creates key child threads. We need to do this explicitly since
 // BrowserThread::PostTask silently deletes a posted task if the target message
 // loop isn't created.
 void CreateChildThreads(BrowserProcessImpl* process) {
   process->db_thread();
   process->file_thread();
   process->process_launcher_thread();
   process->cache_thread();
   process->io_thread();
+#if defined(OS_CHROMEOS)
+  process->webproxy_thread();
+#endif
   // Create watchdog thread after creating all other threads because it will
   // watch the other threads and they must be running.
   process->watchdog_thread();
 }
 
 // Returns the new local state object, guaranteed non-NULL.
 PrefService* InitializeLocalState(const CommandLine& parsed_command_line,
                                   bool is_first_run) {
   FilePath local_state_path;
   PathService::Get(chrome::FILE_LOCAL_STATE, &local_state_path);
@@ skipping 809 matching lines @@
 
   PrefService* user_prefs = profile->GetPrefs();
   DCHECK(user_prefs);
 
   // Tests should be able to tune login manager before showing it.
   // Thus only show login manager in normal (non-testing) mode.
   if (!parameters.ui_task) {
     OptionallyRunChromeOSLoginManager(parsed_command_line);
   }
 
+#if defined(OS_CHROMEOS)
+  // We delay launching websocket to TCP proxy because we do not want to

[zel, 2011/04/07 16:54:12]

can we make this launch when API is being used for the first time instead? same
goes for process->webproxy_thread(). Most of the users won't really have this
running anyway.

[Denis Lagno, 2011/04/07 17:48:22]

it is possible but in this case I need to either merge this CL with private
JSAPI CL into single CL, or just not to launch proxy in this CL at all.

[Denis Lagno, 2011/04/11 23:21:27]

launching webproxy is on demand now.
Idle webproxy thread is still started on startup. 

+  // increase startup time accidentally.
+  const int kWebProxyDelayMs = 5000;
+  // TODO(dilmah): remove webproxy thread, instead implement the same
+  // functionality via hooks into websocket layer.
+  g_browser_process->webproxy_thread()->message_loop()->PostDelayedTask(
+      FROM_HERE, new chromeos::WebproxyTask(), kWebProxyDelayMs);
+#endif
+
 #if !defined(OS_MACOSX)
   // Importing other browser settings is done in a browser-like process
   // that exits when this task has finished.
   // TODO(port): Port the Mac's IPC-based implementation to other platforms to
   //             replace this implementation. http://crbug.com/22142
   if (parsed_command_line.HasSwitch(switches::kImport) ||
       parsed_command_line.HasSwitch(switches::kImportFromFile)) {
     return FirstRun::ImportNow(profile, parsed_command_line);
   }
 #endif
@@ skipping 392 matching lines @@
 #if defined(OS_CHROMEOS)
   // To be precise, logout (browser shutdown) is not yet done, but the
   // remaining work is negligible, hence we say LogoutDone here.
   chromeos::BootTimesLoader::Get()->AddLogoutTimeMarker("LogoutDone",
                                                         false);
   chromeos::BootTimesLoader::Get()->WriteLogoutTimes();
 #endif
   TRACE_EVENT_END("BrowserMain", 0, 0);
   return result_code;
 }