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

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: Created 4 years 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
« no previous file with comments | « no previous file | no next file » | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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/strings/utf_string_conversions.h" 9 #include "base/strings/utf_string_conversions.h"
10 #include "content/child/scoped_child_process_reference.h" 10 #include "content/child/scoped_child_process_reference.h"
(...skipping 25 matching lines...) Expand all
36 stop_callback_.Reset(); 36 stop_callback_.Reset();
37 wrapper_ = nullptr; 37 wrapper_ = nullptr;
38 } 38 }
39 39
40 void EmbeddedWorkerInstanceClientImpl::StartWorker( 40 void EmbeddedWorkerInstanceClientImpl::StartWorker(
41 const EmbeddedWorkerStartParams& params, 41 const EmbeddedWorkerStartParams& params,
42 mojom::ServiceWorkerEventDispatcherRequest dispatcher_request) { 42 mojom::ServiceWorkerEventDispatcherRequest dispatcher_request) {
43 DCHECK(ChildThreadImpl::current()); 43 DCHECK(ChildThreadImpl::current());
44 DCHECK(!wrapper_); 44 DCHECK(!wrapper_);
45 TRACE_EVENT0("ServiceWorker", 45 TRACE_EVENT0("ServiceWorker",
46 "EmbeddedWorkerInstanceClientImpl::StartWorker"); 46 "EmbeddedWorkerInstanceClientImpl::StartWorker");
nhiroki 2016/12/15 05:43:26 DCHECK(!embedded_worker_id_);
shimazu 2016/12/15 08:52:28 Done.
47 embedded_worker_id_ = params.embedded_worker_id; 47 embedded_worker_id_ = params.embedded_worker_id;
48 48
49 std::unique_ptr<EmbeddedWorkerDispatcher::WorkerWrapper> wrapper = 49 std::unique_ptr<EmbeddedWorkerDispatcher::WorkerWrapper> wrapper =
50 dispatcher_->StartWorkerContext( 50 dispatcher_->StartWorkerContext(
51 params, 51 params,
52 base::MakeUnique<ServiceWorkerContextClient>( 52 base::MakeUnique<ServiceWorkerContextClient>(
53 params.embedded_worker_id, params.service_worker_version_id, 53 params.embedded_worker_id, params.service_worker_version_id,
54 params.scope, params.script_url, 54 params.scope, params.script_url,
55 params.worker_devtools_agent_route_id, 55 params.worker_devtools_agent_route_id,
56 std::move(dispatcher_request), std::move(temporal_self_))); 56 std::move(dispatcher_request), std::move(temporal_self_)));
57 wrapper_ = wrapper.get(); 57 wrapper_ = wrapper.get();
58 dispatcher_->RegisterWorker(params.embedded_worker_id, std::move(wrapper)); 58 dispatcher_->RegisterWorker(params.embedded_worker_id, std::move(wrapper));
59 } 59 }
60 60
61 void EmbeddedWorkerInstanceClientImpl::StopWorker( 61 void EmbeddedWorkerInstanceClientImpl::StopWorker(
62 const StopWorkerCallback& callback) { 62 const StopWorkerCallback& callback) {
63 DCHECK(ChildThreadImpl::current()); 63 DCHECK(ChildThreadImpl::current());
64 DCHECK(embedded_worker_id_);
nhiroki 2016/12/15 05:43:26 Instead of removing this, can you move this after
shimazu 2016/12/15 08:52:28 Done.
65 // StopWorker is possible to be called twice or before StartWorker(). 64 // StopWorker is possible to be called twice or before StartWorker().
66 if (stop_callback_ || !wrapper_) 65 if (stop_callback_ || !wrapper_)
67 return; 66 return;
68 TRACE_EVENT0("ServiceWorker", "EmbeddedWorkerInstanceClientImpl::StopWorker"); 67 TRACE_EVENT0("ServiceWorker", "EmbeddedWorkerInstanceClientImpl::StopWorker");
69 stop_callback_ = std::move(callback); 68 stop_callback_ = std::move(callback);
70 dispatcher_->RecordStopWorkerTimer(embedded_worker_id_.value()); 69 dispatcher_->RecordStopWorkerTimer(embedded_worker_id_.value());
71 wrapper_->worker()->terminateWorkerContext(); 70 wrapper_->worker()->terminateWorkerContext();
72 } 71 }
73 72
74 EmbeddedWorkerInstanceClientImpl::EmbeddedWorkerInstanceClientImpl( 73 EmbeddedWorkerInstanceClientImpl::EmbeddedWorkerInstanceClientImpl(
75 EmbeddedWorkerDispatcher* dispatcher, 74 EmbeddedWorkerDispatcher* dispatcher,
76 mojo::InterfaceRequest<mojom::EmbeddedWorkerInstanceClient> request) 75 mojo::InterfaceRequest<mojom::EmbeddedWorkerInstanceClient> request)
77 : dispatcher_(dispatcher), 76 : dispatcher_(dispatcher),
78 binding_(this, std::move(request)), 77 binding_(this, std::move(request)),
79 temporal_self_(std::unique_ptr<EmbeddedWorkerInstanceClientImpl>(this)), 78 temporal_self_(std::unique_ptr<EmbeddedWorkerInstanceClientImpl>(this)),
80 wrapper_(nullptr) { 79 wrapper_(nullptr) {
81 binding_.set_connection_error_handler(base::Bind( 80 binding_.set_connection_error_handler(base::Bind(
82 &EmbeddedWorkerInstanceClientImpl::OnError, base::Unretained(this))); 81 &EmbeddedWorkerInstanceClientImpl::OnError, base::Unretained(this)));
83 } 82 }
84 83
85 EmbeddedWorkerInstanceClientImpl::~EmbeddedWorkerInstanceClientImpl() {} 84 EmbeddedWorkerInstanceClientImpl::~EmbeddedWorkerInstanceClientImpl() {}
86 85
87 void EmbeddedWorkerInstanceClientImpl::OnError() { 86 void EmbeddedWorkerInstanceClientImpl::OnError() {
88 // Removes myself if it's owned by myself. 87 // Removes myself if it's owned by myself.
89 temporal_self_.reset(); 88 temporal_self_.reset();
90 } 89 }
91 90
92 } // namespace content 91 } // namespace content
OLDNEW
« no previous file with comments | « no previous file | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698