| OLD | NEW |
| 1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "build/build_config.h" |
| 6 |
| 7 #if defined(OS_WIN) |
| 5 #include <windows.h> | 8 #include <windows.h> |
| 6 #include <objidl.h> | 9 #include <objidl.h> |
| 7 #include <mlang.h> | 10 #include <mlang.h> |
| 11 #endif |
| 8 | 12 |
| 9 #include "chrome/renderer/render_process.h" | 13 #include "chrome/renderer/render_process.h" |
| 10 | 14 |
| 11 #include "base/basictypes.h" | 15 #include "base/basictypes.h" |
| 12 #include "base/command_line.h" | 16 #include "base/command_line.h" |
| 17 #include "base/compiler_specific.h" |
| 13 #include "base/message_loop.h" | 18 #include "base/message_loop.h" |
| 14 #include "base/histogram.h" | 19 #include "base/histogram.h" |
| 15 #include "base/path_service.h" | 20 #include "base/path_service.h" |
| 21 #include "base/sys_info.h" |
| 16 #include "chrome/browser/net/dns_global.h" // TODO(jar): DNS calls should be re
nderer specific, not including browser. | 22 #include "chrome/browser/net/dns_global.h" // TODO(jar): DNS calls should be re
nderer specific, not including browser. |
| 17 #include "chrome/common/chrome_switches.h" | 23 #include "chrome/common/chrome_switches.h" |
| 18 #include "chrome/common/chrome_paths.h" | 24 #include "chrome/common/chrome_paths.h" |
| 19 #include "chrome/common/ipc_channel.h" | 25 #include "chrome/common/ipc_channel.h" |
| 20 #include "chrome/common/ipc_message_utils.h" | 26 #include "chrome/common/ipc_message_utils.h" |
| 21 #include "chrome/common/render_messages.h" | 27 #include "chrome/common/render_messages.h" |
| 22 #include "chrome/renderer/render_view.h" | 28 #include "chrome/renderer/render_view.h" |
| 23 #include "webkit/glue/webkit_glue.h" | 29 #include "webkit/glue/webkit_glue.h" |
| 24 | 30 |
| 25 //----------------------------------------------------------------------------- | 31 //----------------------------------------------------------------------------- |
| 26 | 32 |
| 27 bool RenderProcess::load_plugins_in_process_ = false; | 33 bool RenderProcess::load_plugins_in_process_ = false; |
| 28 | 34 |
| 29 //----------------------------------------------------------------------------- | 35 //----------------------------------------------------------------------------- |
| 30 | 36 |
| 31 RenderProcess::RenderProcess(const std::wstring& channel_name) | 37 RenderProcess::RenderProcess(const std::wstring& channel_name) |
| 32 : render_thread_(channel_name), | 38 : render_thread_(channel_name), |
| 33 #pragma warning(suppress: 4355) // Okay to pass "this" here. | 39 ALLOW_THIS_IN_INITIALIZER_LIST(clearer_factory_(this)) { |
| 34 clearer_factory_(this) { | 40 for (size_t i = 0; i < arraysize(shared_mem_cache_); ++i) |
| 35 for (int i = 0; i < arraysize(shared_mem_cache_); ++i) | |
| 36 shared_mem_cache_[i] = NULL; | 41 shared_mem_cache_[i] = NULL; |
| 37 } | 42 } |
| 38 | 43 |
| 39 RenderProcess::~RenderProcess() { | 44 RenderProcess::~RenderProcess() { |
| 40 // We need to stop the RenderThread as the clearer_factory_ | 45 // We need to stop the RenderThread as the clearer_factory_ |
| 41 // member could be in use while the object itself is destroyed, | 46 // member could be in use while the object itself is destroyed, |
| 42 // as a result of the containing RenderProcess object being destroyed. | 47 // as a result of the containing RenderProcess object being destroyed. |
| 43 // This race condition causes a crash when the renderer process is shutting | 48 // This race condition causes a crash when the renderer process is shutting |
| 44 // down. | 49 // down. |
| 45 render_thread_.Stop(); | 50 render_thread_.Stop(); |
| 46 ClearSharedMemCache(); | 51 ClearSharedMemCache(); |
| 47 } | 52 } |
| 48 | 53 |
| 49 // static | 54 // static |
| 50 bool RenderProcess::GlobalInit(const std::wstring &channel_name) { | 55 bool RenderProcess::GlobalInit(const std::wstring &channel_name) { |
| 56 #if defined(OS_WIN) |
| 51 // HACK: See http://b/issue?id=1024307 for rationale. | 57 // HACK: See http://b/issue?id=1024307 for rationale. |
| 52 if (GetModuleHandle(L"LPK.DLL") == NULL) { | 58 if (GetModuleHandle(L"LPK.DLL") == NULL) { |
| 53 // Makes sure lpk.dll is loaded by gdi32 to make sure ExtTextOut() works | 59 // Makes sure lpk.dll is loaded by gdi32 to make sure ExtTextOut() works |
| 54 // when buffering into a EMF buffer for printing. | 60 // when buffering into a EMF buffer for printing. |
| 55 typedef BOOL (__stdcall *GdiInitializeLanguagePack)(int LoadedShapingDLLs); | 61 typedef BOOL (__stdcall *GdiInitializeLanguagePack)(int LoadedShapingDLLs); |
| 56 GdiInitializeLanguagePack gdi_init_lpk = | 62 GdiInitializeLanguagePack gdi_init_lpk = |
| 57 reinterpret_cast<GdiInitializeLanguagePack>(GetProcAddress( | 63 reinterpret_cast<GdiInitializeLanguagePack>(GetProcAddress( |
| 58 GetModuleHandle(L"GDI32.DLL"), | 64 GetModuleHandle(L"GDI32.DLL"), |
| 59 "GdiInitializeLanguagePack")); | 65 "GdiInitializeLanguagePack")); |
| 60 DCHECK(gdi_init_lpk); | 66 DCHECK(gdi_init_lpk); |
| 61 if (gdi_init_lpk) { | 67 if (gdi_init_lpk) { |
| 62 gdi_init_lpk(0); | 68 gdi_init_lpk(0); |
| 63 } | 69 } |
| 64 } | 70 } |
| 71 #endif |
| 65 | 72 |
| 66 const CommandLine& command_line = *CommandLine::ForCurrentProcess(); | 73 const CommandLine& command_line = *CommandLine::ForCurrentProcess(); |
| 67 if (command_line.HasSwitch(switches::kJavaScriptFlags)) { | 74 if (command_line.HasSwitch(switches::kJavaScriptFlags)) { |
| 68 webkit_glue::SetJavaScriptFlags( | 75 webkit_glue::SetJavaScriptFlags( |
| 69 command_line.GetSwitchValue(switches::kJavaScriptFlags)); | 76 command_line.GetSwitchValue(switches::kJavaScriptFlags)); |
| 70 } | 77 } |
| 71 if (command_line.HasSwitch(switches::kPlaybackMode) || | 78 if (command_line.HasSwitch(switches::kPlaybackMode) || |
| 72 command_line.HasSwitch(switches::kRecordMode)) { | 79 command_line.HasSwitch(switches::kRecordMode)) { |
| 73 webkit_glue::SetRecordPlaybackMode(true); | 80 webkit_glue::SetRecordPlaybackMode(true); |
| 74 } | 81 } |
| 75 | 82 |
| 76 if (command_line.HasSwitch(switches::kInProcessPlugins) || | 83 if (command_line.HasSwitch(switches::kInProcessPlugins) || |
| 77 command_line.HasSwitch(switches::kSingleProcess)) | 84 command_line.HasSwitch(switches::kSingleProcess)) |
| 78 load_plugins_in_process_ = true; | 85 load_plugins_in_process_ = true; |
| 79 | 86 |
| 80 if (command_line.HasSwitch(switches::kEnableWatchdog)) { | 87 if (command_line.HasSwitch(switches::kEnableWatchdog)) { |
| 81 // TODO(JAR): Need to implement renderer IO msgloop watchdog. | 88 // TODO(JAR): Need to implement renderer IO msgloop watchdog. |
| 82 } | 89 } |
| 83 | 90 |
| 84 if (command_line.HasSwitch(switches::kDumpHistogramsOnExit)) { | 91 if (command_line.HasSwitch(switches::kDumpHistogramsOnExit)) { |
| 85 StatisticsRecorder::set_dump_on_exit(true); | 92 StatisticsRecorder::set_dump_on_exit(true); |
| 86 } | 93 } |
| 87 | 94 |
| 88 if (command_line.HasSwitch(switches::kGearsInRenderer)) { | 95 if (command_line.HasSwitch(switches::kGearsInRenderer)) { |
| 96 #if defined(OS_WIN) |
| 89 // Load gears.dll on startup so we can access it before the sandbox | 97 // Load gears.dll on startup so we can access it before the sandbox |
| 90 // blocks us. | 98 // blocks us. |
| 91 std::wstring path; | 99 std::wstring path; |
| 92 if (PathService::Get(chrome::FILE_GEARS_PLUGIN, &path)) | 100 if (PathService::Get(chrome::FILE_GEARS_PLUGIN, &path)) |
| 93 LoadLibrary(path.c_str()); | 101 LoadLibrary(path.c_str()); |
| 102 #else |
| 103 // TODO(port) Need to handle loading gears on non-Windows platforms |
| 104 NOTIMPLEMENTED(); |
| 105 #endif |
| 94 } | 106 } |
| 95 | 107 |
| 96 ChildProcessFactory<RenderProcess> factory; | 108 ChildProcessFactory<RenderProcess> factory; |
| 97 return ChildProcess::GlobalInit(channel_name, &factory); | 109 return ChildProcess::GlobalInit(channel_name, &factory); |
| 98 } | 110 } |
| 99 | 111 |
| 100 // static | 112 // static |
| 101 void RenderProcess::GlobalCleanup() { | 113 void RenderProcess::GlobalCleanup() { |
| 102 ChildProcess::GlobalCleanup(); | 114 ChildProcess::GlobalCleanup(); |
| 103 } | 115 } |
| 104 | 116 |
| 105 // static | 117 // static |
| 106 bool RenderProcess::ShouldLoadPluginsInProcess() { | 118 bool RenderProcess::ShouldLoadPluginsInProcess() { |
| 107 return load_plugins_in_process_; | 119 return load_plugins_in_process_; |
| 108 } | 120 } |
| 109 | 121 |
| 110 // static | 122 // static |
| 111 base::SharedMemory* RenderProcess::AllocSharedMemory(size_t size) { | 123 base::SharedMemory* RenderProcess::AllocSharedMemory(size_t size) { |
| 112 self()->clearer_factory_.RevokeAll(); | 124 self()->clearer_factory_.RevokeAll(); |
| 113 | 125 |
| 114 base::SharedMemory* mem = self()->GetSharedMemFromCache(size); | 126 base::SharedMemory* mem = self()->GetSharedMemFromCache(size); |
| 115 if (mem) | 127 if (mem) |
| 116 return mem; | 128 return mem; |
| 117 | 129 |
| 118 // Round-up size to allocation granularity | 130 // Round-up size to allocation granularity |
| 119 SYSTEM_INFO info; | 131 size_t allocation_granularity = base::SysInfo::VMAllocationGranularity(); |
| 120 GetSystemInfo(&info); | 132 size = size / allocation_granularity + 1; |
| 121 | 133 size = size * allocation_granularity; |
| 122 size = size / info.dwAllocationGranularity + 1; | |
| 123 size = size * info.dwAllocationGranularity; | |
| 124 | 134 |
| 125 mem = new base::SharedMemory(); | 135 mem = new base::SharedMemory(); |
| 126 if (!mem) | 136 if (!mem) |
| 127 return NULL; | 137 return NULL; |
| 128 if (!mem->Create(L"", false, true, size)) { | 138 if (!mem->Create(L"", false, true, size)) { |
| 129 delete mem; | 139 delete mem; |
| 130 return NULL; | 140 return NULL; |
| 131 } | 141 } |
| 132 | 142 |
| 133 return mem; | 143 return mem; |
| 134 } | 144 } |
| 135 | 145 |
| 136 // static | 146 // static |
| 137 void RenderProcess::FreeSharedMemory(base::SharedMemory* mem) { | 147 void RenderProcess::FreeSharedMemory(base::SharedMemory* mem) { |
| 138 if (self()->PutSharedMemInCache(mem)) { | 148 if (self()->PutSharedMemInCache(mem)) { |
| 139 self()->ScheduleCacheClearer(); | 149 self()->ScheduleCacheClearer(); |
| 140 return; | 150 return; |
| 141 } | 151 } |
| 142 DeleteSharedMem(mem); | 152 DeleteSharedMem(mem); |
| 143 } | 153 } |
| 144 | 154 |
| 145 // static | 155 // static |
| 146 void RenderProcess::DeleteSharedMem(base::SharedMemory* mem) { | 156 void RenderProcess::DeleteSharedMem(base::SharedMemory* mem) { |
| 147 delete mem; | 157 delete mem; |
| 148 } | 158 } |
| 149 | 159 |
| 150 base::SharedMemory* RenderProcess::GetSharedMemFromCache(size_t size) { | 160 base::SharedMemory* RenderProcess::GetSharedMemFromCache(size_t size) { |
| 151 // look for a cached object that is suitable for the requested size. | 161 // look for a cached object that is suitable for the requested size. |
| 152 for (int i = 0; i < arraysize(shared_mem_cache_); ++i) { | 162 for (size_t i = 0; i < arraysize(shared_mem_cache_); ++i) { |
| 153 base::SharedMemory* mem = shared_mem_cache_[i]; | 163 base::SharedMemory* mem = shared_mem_cache_[i]; |
| 154 if (mem && mem->max_size() >= size) { | 164 if (mem && mem->max_size() >= size) { |
| 155 shared_mem_cache_[i] = NULL; | 165 shared_mem_cache_[i] = NULL; |
| 156 return mem; | 166 return mem; |
| 157 } | 167 } |
| 158 } | 168 } |
| 159 return NULL; | 169 return NULL; |
| 160 } | 170 } |
| 161 | 171 |
| 162 bool RenderProcess::PutSharedMemInCache(base::SharedMemory* mem) { | 172 bool RenderProcess::PutSharedMemInCache(base::SharedMemory* mem) { |
| 163 // simple algorithm: | 173 // simple algorithm: |
| 164 // - look for an empty slot to store mem, or | 174 // - look for an empty slot to store mem, or |
| 165 // - if full, then replace any existing cache entry that is smaller than the | 175 // - if full, then replace any existing cache entry that is smaller than the |
| 166 // given shared memory object. | 176 // given shared memory object. |
| 167 for (int i = 0; i < arraysize(shared_mem_cache_); ++i) { | 177 for (size_t i = 0; i < arraysize(shared_mem_cache_); ++i) { |
| 168 if (!shared_mem_cache_[i]) { | 178 if (!shared_mem_cache_[i]) { |
| 169 shared_mem_cache_[i] = mem; | 179 shared_mem_cache_[i] = mem; |
| 170 return true; | 180 return true; |
| 171 } | 181 } |
| 172 } | 182 } |
| 173 for (int i = 0; i < arraysize(shared_mem_cache_); ++i) { | 183 for (size_t i = 0; i < arraysize(shared_mem_cache_); ++i) { |
| 174 base::SharedMemory* cached_mem = shared_mem_cache_[i]; | 184 base::SharedMemory* cached_mem = shared_mem_cache_[i]; |
| 175 if (cached_mem->max_size() < mem->max_size()) { | 185 if (cached_mem->max_size() < mem->max_size()) { |
| 176 shared_mem_cache_[i] = mem; | 186 shared_mem_cache_[i] = mem; |
| 177 DeleteSharedMem(cached_mem); | 187 DeleteSharedMem(cached_mem); |
| 178 return true; | 188 return true; |
| 179 } | 189 } |
| 180 } | 190 } |
| 181 return false; | 191 return false; |
| 182 } | 192 } |
| 183 | 193 |
| 184 void RenderProcess::ClearSharedMemCache() { | 194 void RenderProcess::ClearSharedMemCache() { |
| 185 for (int i = 0; i < arraysize(shared_mem_cache_); ++i) { | 195 for (size_t i = 0; i < arraysize(shared_mem_cache_); ++i) { |
| 186 if (shared_mem_cache_[i]) { | 196 if (shared_mem_cache_[i]) { |
| 187 DeleteSharedMem(shared_mem_cache_[i]); | 197 DeleteSharedMem(shared_mem_cache_[i]); |
| 188 shared_mem_cache_[i] = NULL; | 198 shared_mem_cache_[i] = NULL; |
| 189 } | 199 } |
| 190 } | 200 } |
| 191 } | 201 } |
| 192 | 202 |
| 193 void RenderProcess::ScheduleCacheClearer() { | 203 void RenderProcess::ScheduleCacheClearer() { |
| 194 // If we already have a deferred clearer, then revoke it so we effectively | 204 // If we already have a deferred clearer, then revoke it so we effectively |
| 195 // delay cache clearing until idle for our desired interval. | 205 // delay cache clearing until idle for our desired interval. |
| 196 clearer_factory_.RevokeAll(); | 206 clearer_factory_.RevokeAll(); |
| 197 | 207 |
| 198 MessageLoop::current()->PostDelayedTask(FROM_HERE, | 208 MessageLoop::current()->PostDelayedTask(FROM_HERE, |
| 199 clearer_factory_.NewRunnableMethod(&RenderProcess::ClearSharedMemCache), | 209 clearer_factory_.NewRunnableMethod(&RenderProcess::ClearSharedMemCache), |
| 200 5000 /* 5 seconds */); | 210 5000 /* 5 seconds */); |
| 201 } | 211 } |
| 202 | 212 |
| 203 void RenderProcess::Cleanup() { | 213 void RenderProcess::Cleanup() { |
| 204 #ifndef NDEBUG | 214 #ifndef NDEBUG |
| 205 // log important leaked objects | 215 // log important leaked objects |
| 206 webkit_glue::CheckForLeaks(); | 216 webkit_glue::CheckForLeaks(); |
| 207 #endif | 217 #endif |
| 208 } | 218 } |
| 209 | |
| OLD | NEW |