| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "chrome/browser/extensions/event_router.h" | 5 #include "chrome/browser/extensions/event_router.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/command_line.h" | 8 #include "base/command_line.h" |
| 9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
| 10 #include "base/values.h" | 10 #include "base/values.h" |
| 11 #include "chrome/browser/browser_process.h" | 11 #include "chrome/browser/browser_process.h" |
| 12 #include "chrome/browser/extensions/api/processes/processes_api.h" |
| 13 #include "chrome/browser/extensions/api/processes/processes_api_constants.h" |
| 12 #include "chrome/browser/extensions/api/runtime/runtime_api.h" | 14 #include "chrome/browser/extensions/api/runtime/runtime_api.h" |
| 13 #include "chrome/browser/extensions/api/web_request/web_request_api.h" | 15 #include "chrome/browser/extensions/api/web_request/web_request_api.h" |
| 14 #include "chrome/browser/extensions/extension_devtools_manager.h" | 16 #include "chrome/browser/extensions/extension_devtools_manager.h" |
| 15 #include "chrome/browser/extensions/extension_host.h" | 17 #include "chrome/browser/extensions/extension_host.h" |
| 16 #include "chrome/browser/extensions/extension_process_manager.h" | 18 #include "chrome/browser/extensions/extension_process_manager.h" |
| 17 #include "chrome/browser/extensions/extension_processes_api.h" | |
| 18 #include "chrome/browser/extensions/extension_processes_api_constants.h" | |
| 19 #include "chrome/browser/extensions/extension_service.h" | 19 #include "chrome/browser/extensions/extension_service.h" |
| 20 #include "chrome/browser/extensions/extension_system.h" | 20 #include "chrome/browser/extensions/extension_system.h" |
| 21 #include "chrome/browser/extensions/event_names.h" | 21 #include "chrome/browser/extensions/event_names.h" |
| 22 #include "chrome/browser/extensions/lazy_background_task_queue.h" | 22 #include "chrome/browser/extensions/lazy_background_task_queue.h" |
| 23 #include "chrome/browser/extensions/process_map.h" | 23 #include "chrome/browser/extensions/process_map.h" |
| 24 #include "chrome/browser/extensions/system_info_event_router.h" | 24 #include "chrome/browser/extensions/system_info_event_router.h" |
| 25 #include "chrome/browser/profiles/profile.h" | 25 #include "chrome/browser/profiles/profile.h" |
| 26 #include "chrome/browser/profiles/profile_manager.h" | 26 #include "chrome/browser/profiles/profile_manager.h" |
| 27 #include "chrome/common/chrome_notification_types.h" | 27 #include "chrome/common/chrome_notification_types.h" |
| 28 #include "chrome/common/chrome_switches.h" | 28 #include "chrome/common/chrome_switches.h" |
| (...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 150 if (!listener->process) | 150 if (!listener->process) |
| 151 return; | 151 return; |
| 152 | 152 |
| 153 if (extension_devtools_manager_.get()) | 153 if (extension_devtools_manager_.get()) |
| 154 extension_devtools_manager_->AddEventListener(listener->event_name, | 154 extension_devtools_manager_->AddEventListener(listener->event_name, |
| 155 listener->process->GetID()); | 155 listener->process->GetID()); |
| 156 | 156 |
| 157 // We lazily tell the TaskManager to start updating when listeners to the | 157 // We lazily tell the TaskManager to start updating when listeners to the |
| 158 // processes.onUpdated or processes.onUpdatedWithMemory events arrive. | 158 // processes.onUpdated or processes.onUpdatedWithMemory events arrive. |
| 159 const std::string& event_name = listener->event_name; | 159 const std::string& event_name = listener->event_name; |
| 160 if (event_name.compare(extension_processes_api_constants::kOnUpdated) == 0 || | 160 if (event_name.compare( |
| 161 extensions::processes_api_constants::kOnUpdated) == 0 || |
| 161 event_name.compare( | 162 event_name.compare( |
| 162 extension_processes_api_constants::kOnUpdatedWithMemory) == 0) | 163 extensions::processes_api_constants::kOnUpdatedWithMemory) == 0) |
| 163 ExtensionProcessesEventRouter::GetInstance()->ListenerAdded(); | 164 extensions::ProcessesEventRouter::GetInstance()->ListenerAdded(); |
| 164 | 165 |
| 165 if (SystemInfoEventRouter::IsSystemInfoEvent(event_name)) | 166 if (SystemInfoEventRouter::IsSystemInfoEvent(event_name)) |
| 166 SystemInfoEventRouter::GetInstance()->AddEventListener(event_name); | 167 SystemInfoEventRouter::GetInstance()->AddEventListener(event_name); |
| 167 } | 168 } |
| 168 | 169 |
| 169 void EventRouter::OnListenerRemoved(const EventListener* listener) { | 170 void EventRouter::OnListenerRemoved(const EventListener* listener) { |
| 170 // We don't care about lazy events being removed. | 171 // We don't care about lazy events being removed. |
| 171 if (!listener->process) | 172 if (!listener->process) |
| 172 return; | 173 return; |
| 173 | 174 |
| 174 const std::string& event_name = listener->event_name; | 175 const std::string& event_name = listener->event_name; |
| 175 if (extension_devtools_manager_.get()) | 176 if (extension_devtools_manager_.get()) |
| 176 extension_devtools_manager_->RemoveEventListener( | 177 extension_devtools_manager_->RemoveEventListener( |
| 177 event_name, listener->process->GetID()); | 178 event_name, listener->process->GetID()); |
| 178 | 179 |
| 179 // If a processes.onUpdated or processes.onUpdatedWithMemory event listener | 180 // If a processes.onUpdated or processes.onUpdatedWithMemory event listener |
| 180 // is removed (or a process with one exits), then we let the extension API | 181 // is removed (or a process with one exits), then we let the extension API |
| 181 // know that it has one fewer listener. | 182 // know that it has one fewer listener. |
| 182 if (event_name.compare(extension_processes_api_constants::kOnUpdated) == 0 || | 183 if (event_name.compare( |
| 184 extensions::processes_api_constants::kOnUpdated) == 0 || |
| 183 event_name.compare( | 185 event_name.compare( |
| 184 extension_processes_api_constants::kOnUpdatedWithMemory) == 0) | 186 extensions::processes_api_constants::kOnUpdatedWithMemory) == 0) |
| 185 ExtensionProcessesEventRouter::GetInstance()->ListenerRemoved(); | 187 extensions::ProcessesEventRouter::GetInstance()->ListenerRemoved(); |
| 186 | 188 |
| 187 BrowserThread::PostTask( | 189 BrowserThread::PostTask( |
| 188 BrowserThread::IO, FROM_HERE, | 190 BrowserThread::IO, FROM_HERE, |
| 189 base::Bind(&NotifyEventListenerRemovedOnIOThread, | 191 base::Bind(&NotifyEventListenerRemovedOnIOThread, |
| 190 profile_, listener->extension_id, listener->event_name)); | 192 profile_, listener->extension_id, listener->event_name)); |
| 191 | 193 |
| 192 if (SystemInfoEventRouter::IsSystemInfoEvent(event_name)) | 194 if (SystemInfoEventRouter::IsSystemInfoEvent(event_name)) |
| 193 SystemInfoEventRouter::GetInstance()->RemoveEventListener(event_name); | 195 SystemInfoEventRouter::GetInstance()->RemoveEventListener(event_name); |
| 194 } | 196 } |
| 195 | 197 |
| (...skipping 415 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 611 event_args(event_args.Pass()), | 613 event_args(event_args.Pass()), |
| 612 event_url(event_url), | 614 event_url(event_url), |
| 613 restrict_to_profile(restrict_to_profile), | 615 restrict_to_profile(restrict_to_profile), |
| 614 cross_incognito_args(NULL), | 616 cross_incognito_args(NULL), |
| 615 user_gesture(user_gesture), | 617 user_gesture(user_gesture), |
| 616 info(info) {} | 618 info(info) {} |
| 617 | 619 |
| 618 Event::~Event() {} | 620 Event::~Event() {} |
| 619 | 621 |
| 620 } // namespace extensions | 622 } // namespace extensions |
| OLD | NEW |