Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(45)

Unified Diff: content/browser/service_worker/embedded_worker_instance.cc

Issue 2418373002: Reduce FOR_EACH_OBSERVER usage in content/browser/service_worker (Closed)
Patch Set: Created 4 years, 2 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: content/browser/service_worker/embedded_worker_instance.cc
diff --git a/content/browser/service_worker/embedded_worker_instance.cc b/content/browser/service_worker/embedded_worker_instance.cc
index 8e81ee915edfcf7a3dc0c8a01fe186ef4f6338aa..5298c55934b55d170000065b0db91b05ec76af6c 100644
--- a/content/browser/service_worker/embedded_worker_instance.cc
+++ b/content/browser/service_worker/embedded_worker_instance.cc
@@ -452,7 +452,8 @@ void EmbeddedWorkerInstance::Start(
network_accessed_for_script_ = false;
interface_registry_.reset(new shell::InterfaceRegistry);
remote_interfaces_.reset(new shell::InterfaceProvider);
- FOR_EACH_OBSERVER(Listener, listener_list_, OnStarting());
+ for (auto& observer : listener_list_)
+ observer.OnStarting();
params->embedded_worker_id = embedded_worker_id_;
params->worker_devtools_agent_route_id = MSG_ROUTING_NONE;
@@ -498,7 +499,8 @@ ServiceWorkerStatusCode EmbeddedWorkerInstance::Stop() {
}
status_ = EmbeddedWorkerStatus::STOPPING;
- FOR_EACH_OBSERVER(Listener, listener_list_, OnStopping());
+ for (auto& observer : listener_list_)
+ observer.OnStopping();
return status;
}
@@ -575,7 +577,8 @@ void EmbeddedWorkerInstance::OnProcessAllocated(
process_handle_ = std::move(handle);
starting_phase_ = REGISTERING_TO_DEVTOOLS;
start_situation_ = start_situation;
- FOR_EACH_OBSERVER(Listener, listener_list_, OnProcessAllocated());
+ for (auto& observer : listener_list_)
+ observer.OnProcessAllocated();
}
void EmbeddedWorkerInstance::OnRegisteredToDevToolsManager(
@@ -592,7 +595,8 @@ void EmbeddedWorkerInstance::OnRegisteredToDevToolsManager(
// we set the NULL time here.
step_time_ = base::TimeTicks();
}
- FOR_EACH_OBSERVER(Listener, listener_list_, OnRegisteredToDevToolsManager());
+ for (auto& observer : listener_list_)
+ observer.OnRegisteredToDevToolsManager();
}
void EmbeddedWorkerInstance::SendMojoStartWorker(
@@ -614,7 +618,8 @@ void EmbeddedWorkerInstance::OnStartWorkerMessageSent() {
}
starting_phase_ = SENT_START_WORKER;
- FOR_EACH_OBSERVER(Listener, listener_list_, OnStartWorkerMessageSent());
+ for (auto& observer : listener_list_)
+ observer.OnStartWorkerMessageSent();
}
void EmbeddedWorkerInstance::OnReadyForInspection() {
@@ -655,7 +660,8 @@ void EmbeddedWorkerInstance::OnScriptLoaded() {
}
starting_phase_ = SCRIPT_LOADED;
- FOR_EACH_OBSERVER(Listener, listener_list_, OnScriptLoaded());
+ for (auto& observer : listener_list_)
+ observer.OnScriptLoaded();
// |this| may be destroyed by the callback.
}
@@ -695,7 +701,8 @@ void EmbeddedWorkerInstance::OnThreadStarted(int thread_id) {
}
thread_id_ = thread_id;
- FOR_EACH_OBSERVER(Listener, listener_list_, OnThreadStarted());
+ for (auto& observer : listener_list_)
+ observer.OnThreadStarted();
shell::mojom::InterfaceProviderPtr exposed_interfaces;
interface_registry_->Bind(mojo::GetProxy(&exposed_interfaces));
@@ -716,7 +723,8 @@ void EmbeddedWorkerInstance::OnScriptLoadFailed() {
TRACE_EVENT_ASYNC_STEP_PAST0("ServiceWorker", "EmbeddedWorkerInstance::Start",
inflight_start_task_.get(),
"OnScriptLoadFailed");
- FOR_EACH_OBSERVER(Listener, listener_list_, OnScriptLoadFailed());
+ for (auto& observer : listener_list_)
+ observer.OnScriptLoadFailed();
}
void EmbeddedWorkerInstance::OnScriptEvaluated(bool success) {
@@ -750,19 +758,22 @@ void EmbeddedWorkerInstance::OnStarted() {
DCHECK(status_ == EmbeddedWorkerStatus::STARTING);
status_ = EmbeddedWorkerStatus::RUNNING;
inflight_start_task_.reset();
- FOR_EACH_OBSERVER(Listener, listener_list_, OnStarted());
+ for (auto& observer : listener_list_)
+ observer.OnStarted();
}
void EmbeddedWorkerInstance::OnStopped() {
EmbeddedWorkerStatus old_status = status_;
ReleaseProcess();
- FOR_EACH_OBSERVER(Listener, listener_list_, OnStopped(old_status));
+ for (auto& observer : listener_list_)
+ observer.OnStopped(old_status);
}
void EmbeddedWorkerInstance::OnDetached() {
EmbeddedWorkerStatus old_status = status_;
ReleaseProcess();
- FOR_EACH_OBSERVER(Listener, listener_list_, OnDetached(old_status));
+ for (auto& observer : listener_list_)
+ observer.OnDetached(old_status);
}
void EmbeddedWorkerInstance::Detach() {
@@ -787,10 +798,10 @@ void EmbeddedWorkerInstance::OnReportException(
int line_number,
int column_number,
const GURL& source_url) {
- FOR_EACH_OBSERVER(
- Listener,
- listener_list_,
- OnReportException(error_message, line_number, column_number, source_url));
+ for (auto& observer : listener_list_) {
+ observer.OnReportException(error_message, line_number, column_number,
+ source_url);
+ }
}
void EmbeddedWorkerInstance::OnReportConsoleMessage(
@@ -799,11 +810,10 @@ void EmbeddedWorkerInstance::OnReportConsoleMessage(
const base::string16& message,
int line_number,
const GURL& source_url) {
- FOR_EACH_OBSERVER(
- Listener,
- listener_list_,
- OnReportConsoleMessage(
- source_identifier, message_level, message, line_number, source_url));
+ for (auto& observer : listener_list_) {
+ observer.OnReportConsoleMessage(source_identifier, message_level, message,
+ line_number, source_url);
+ }
}
int EmbeddedWorkerInstance::process_id() const {

Powered by Google App Engine
This is Rietveld 408576698