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

Side by Side Diff: content/renderer/service_worker/embedded_worker_instance_client_impl.cc

Issue 2578023002: ServiceWorker: Stop don't send a message before connection established (Closed)
Patch Set: Reset starting_phase when releasing the process Created 3 years, 11 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 unified diff | Download patch
OLDNEW
1 // Copyright (c) 2016 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2016 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/renderer/service_worker/embedded_worker_instance_client_impl.h " 5 #include "content/renderer/service_worker/embedded_worker_instance_client_impl.h "
6 6
7 #include <memory> 7 #include <memory>
8 8
9 #include "base/memory/ptr_util.h" 9 #include "base/memory/ptr_util.h"
10 #include "base/strings/utf_string_conversions.h" 10 #include "base/strings/utf_string_conversions.h"
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after
42 dispatcher_->UnregisterWorker(embedded_worker_id_.value()); 42 dispatcher_->UnregisterWorker(embedded_worker_id_.value());
43 embedded_worker_id_.reset(); 43 embedded_worker_id_.reset();
44 wrapper_ = nullptr; 44 wrapper_ = nullptr;
45 } 45 }
46 46
47 void EmbeddedWorkerInstanceClientImpl::StartWorker( 47 void EmbeddedWorkerInstanceClientImpl::StartWorker(
48 const EmbeddedWorkerStartParams& params, 48 const EmbeddedWorkerStartParams& params,
49 mojom::ServiceWorkerEventDispatcherRequest dispatcher_request) { 49 mojom::ServiceWorkerEventDispatcherRequest dispatcher_request) {
50 DCHECK(ChildThreadImpl::current()); 50 DCHECK(ChildThreadImpl::current());
51 DCHECK(!wrapper_); 51 DCHECK(!wrapper_);
52 DCHECK(!embedded_worker_id_);
52 TRACE_EVENT0("ServiceWorker", 53 TRACE_EVENT0("ServiceWorker",
53 "EmbeddedWorkerInstanceClientImpl::StartWorker"); 54 "EmbeddedWorkerInstanceClientImpl::StartWorker");
54 embedded_worker_id_ = params.embedded_worker_id; 55 embedded_worker_id_ = params.embedded_worker_id;
55 56
56 std::unique_ptr<EmbeddedWorkerDispatcher::WorkerWrapper> wrapper = 57 std::unique_ptr<EmbeddedWorkerDispatcher::WorkerWrapper> wrapper =
57 dispatcher_->StartWorkerContext( 58 dispatcher_->StartWorkerContext(
58 params, 59 params,
59 base::MakeUnique<ServiceWorkerContextClient>( 60 base::MakeUnique<ServiceWorkerContextClient>(
60 params.embedded_worker_id, params.service_worker_version_id, 61 params.embedded_worker_id, params.service_worker_version_id,
61 params.scope, params.script_url, 62 params.scope, params.script_url,
62 params.worker_devtools_agent_route_id, 63 params.worker_devtools_agent_route_id,
63 std::move(dispatcher_request), std::move(temporal_self_))); 64 std::move(dispatcher_request), std::move(temporal_self_)));
64 wrapper_ = wrapper.get(); 65 wrapper_ = wrapper.get();
65 dispatcher_->RegisterWorker(params.embedded_worker_id, std::move(wrapper)); 66 dispatcher_->RegisterWorker(params.embedded_worker_id, std::move(wrapper));
66 } 67 }
67 68
68 void EmbeddedWorkerInstanceClientImpl::StopWorker( 69 void EmbeddedWorkerInstanceClientImpl::StopWorker(
69 const StopWorkerCallback& callback) { 70 const StopWorkerCallback& callback) {
71 // StopWorker must be called after StartWorker is called.
70 DCHECK(ChildThreadImpl::current()); 72 DCHECK(ChildThreadImpl::current());
73 DCHECK(wrapper_);
71 DCHECK(embedded_worker_id_); 74 DCHECK(embedded_worker_id_);
72 // StopWorker is possible to be called twice or before StartWorker(). 75 DCHECK(!stop_callback_);
73 if (stop_callback_ || !wrapper_) 76
74 return;
75 TRACE_EVENT0("ServiceWorker", "EmbeddedWorkerInstanceClientImpl::StopWorker"); 77 TRACE_EVENT0("ServiceWorker", "EmbeddedWorkerInstanceClientImpl::StopWorker");
76 stop_callback_ = std::move(callback); 78 stop_callback_ = callback;
77 dispatcher_->RecordStopWorkerTimer(embedded_worker_id_.value()); 79 dispatcher_->RecordStopWorkerTimer(embedded_worker_id_.value());
78 wrapper_->worker()->terminateWorkerContext(); 80 wrapper_->worker()->terminateWorkerContext();
79 } 81 }
80 82
81 EmbeddedWorkerInstanceClientImpl::EmbeddedWorkerInstanceClientImpl( 83 EmbeddedWorkerInstanceClientImpl::EmbeddedWorkerInstanceClientImpl(
82 EmbeddedWorkerDispatcher* dispatcher, 84 EmbeddedWorkerDispatcher* dispatcher,
83 mojo::InterfaceRequest<mojom::EmbeddedWorkerInstanceClient> request) 85 mojo::InterfaceRequest<mojom::EmbeddedWorkerInstanceClient> request)
84 : dispatcher_(dispatcher), 86 : dispatcher_(dispatcher),
85 binding_(this, std::move(request)), 87 binding_(this, std::move(request)),
86 temporal_self_(std::unique_ptr<EmbeddedWorkerInstanceClientImpl>(this)), 88 temporal_self_(std::unique_ptr<EmbeddedWorkerInstanceClientImpl>(this)),
87 wrapper_(nullptr) { 89 wrapper_(nullptr) {
88 binding_.set_connection_error_handler(base::Bind( 90 binding_.set_connection_error_handler(base::Bind(
89 &EmbeddedWorkerInstanceClientImpl::OnError, base::Unretained(this))); 91 &EmbeddedWorkerInstanceClientImpl::OnError, base::Unretained(this)));
90 } 92 }
91 93
92 EmbeddedWorkerInstanceClientImpl::~EmbeddedWorkerInstanceClientImpl() {} 94 EmbeddedWorkerInstanceClientImpl::~EmbeddedWorkerInstanceClientImpl() {}
93 95
94 void EmbeddedWorkerInstanceClientImpl::OnError() { 96 void EmbeddedWorkerInstanceClientImpl::OnError() {
95 // Removes myself if it's owned by myself. 97 // Removes myself if it's owned by myself.
96 temporal_self_.reset(); 98 temporal_self_.reset();
97 } 99 }
98 100
99 } // namespace content 101 } // namespace content
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698