OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "content/browser/service_worker/service_worker_dispatcher_host.h" | 5 #include "content/browser/service_worker/service_worker_dispatcher_host.h" |
6 | 6 |
7 #include <utility> | 7 #include <utility> |
8 | 8 |
9 #include "base/debug/crash_logging.h" | 9 #include "base/debug/crash_logging.h" |
10 #include "base/logging.h" | 10 #include "base/logging.h" |
(...skipping 109 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
120 return; | 120 return; |
121 } | 121 } |
122 | 122 |
123 context_wrapper_ = context_wrapper; | 123 context_wrapper_ = context_wrapper; |
124 if (!GetContext()) | 124 if (!GetContext()) |
125 return; | 125 return; |
126 GetContext()->embedded_worker_registry()->AddChildProcessSender( | 126 GetContext()->embedded_worker_registry()->AddChildProcessSender( |
127 render_process_id_, this, message_port_message_filter_); | 127 render_process_id_, this, message_port_message_filter_); |
128 } | 128 } |
129 | 129 |
130 void ServiceWorkerDispatcherHost::OnFilterAdded(IPC::Sender* sender) { | 130 void ServiceWorkerDispatcherHost::OnFilterAdded(IPC::Channel* channel) { |
131 TRACE_EVENT0("ServiceWorker", | 131 TRACE_EVENT0("ServiceWorker", |
132 "ServiceWorkerDispatcherHost::OnFilterAdded"); | 132 "ServiceWorkerDispatcherHost::OnFilterAdded"); |
133 channel_ready_ = true; | 133 channel_ready_ = true; |
134 std::vector<std::unique_ptr<IPC::Message>> messages; | 134 std::vector<std::unique_ptr<IPC::Message>> messages; |
135 messages.swap(pending_messages_); | 135 messages.swap(pending_messages_); |
136 for (auto& message : messages) { | 136 for (auto& message : messages) { |
137 BrowserMessageFilter::Send(message.release()); | 137 BrowserMessageFilter::Send(message.release()); |
138 } | 138 } |
139 } | 139 } |
140 | 140 |
(...skipping 1289 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1430 if (!handle) { | 1430 if (!handle) { |
1431 bad_message::ReceivedBadMessage(this, | 1431 bad_message::ReceivedBadMessage(this, |
1432 bad_message::SWDH_TERMINATE_BAD_HANDLE); | 1432 bad_message::SWDH_TERMINATE_BAD_HANDLE); |
1433 return; | 1433 return; |
1434 } | 1434 } |
1435 handle->version()->StopWorker( | 1435 handle->version()->StopWorker( |
1436 base::Bind(&ServiceWorkerUtils::NoOpStatusCallback)); | 1436 base::Bind(&ServiceWorkerUtils::NoOpStatusCallback)); |
1437 } | 1437 } |
1438 | 1438 |
1439 } // namespace content | 1439 } // namespace content |
OLD | NEW |