1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
// Copyright 2014 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "content/browser/service_worker/service_worker_fetch_dispatcher.h"
#include "base/bind.h"
#include "base/debug/trace_event.h"
#include "content/browser/service_worker/service_worker_version.h"
namespace content {
ServiceWorkerFetchDispatcher::ServiceWorkerFetchDispatcher(
scoped_ptr<ServiceWorkerFetchRequest> request,
ServiceWorkerVersion* version,
const base::Closure& prepare_callback,
const FetchCallback& fetch_callback)
: version_(version),
prepare_callback_(prepare_callback),
fetch_callback_(fetch_callback),
request_(request.Pass()),
weak_factory_(this) {
}
ServiceWorkerFetchDispatcher::~ServiceWorkerFetchDispatcher() {}
void ServiceWorkerFetchDispatcher::Run() {
DCHECK(version_->status() == ServiceWorkerVersion::ACTIVATING ||
version_->status() == ServiceWorkerVersion::ACTIVATED)
<< version_->status();
if (version_->status() == ServiceWorkerVersion::ACTIVATING) {
version_->RegisterStatusChangeCallback(
base::Bind(&ServiceWorkerFetchDispatcher::DidWaitActivation,
weak_factory_.GetWeakPtr()));
return;
}
DispatchFetchEvent();
}
void ServiceWorkerFetchDispatcher::DidWaitActivation() {
if (version_->status() != ServiceWorkerVersion::ACTIVATED) {
DCHECK_EQ(ServiceWorkerVersion::INSTALLED, version_->status());
DidFailActivation();
return;
}
DispatchFetchEvent();
}
void ServiceWorkerFetchDispatcher::DidFailActivation() {
// The previous activation seems to have failed, abort the step
// with activate error. (The error should be separately reported
// to the associated documents and association must be dropped
// at this point)
DidFinish(SERVICE_WORKER_ERROR_ACTIVATE_WORKER_FAILED,
SERVICE_WORKER_FETCH_EVENT_RESULT_FALLBACK,
ServiceWorkerResponse());
}
void ServiceWorkerFetchDispatcher::DispatchFetchEvent() {
TRACE_EVENT_ASYNC_BEGIN0(
"ServiceWorker",
"ServiceWorkerFetchDispatcher::DispatchFetchEvent",
request_.get());
version_->DispatchFetchEvent(
*request_.get(),
base::Bind(&ServiceWorkerFetchDispatcher::DidPrepare,
weak_factory_.GetWeakPtr()),
base::Bind(&ServiceWorkerFetchDispatcher::DidFinish,
weak_factory_.GetWeakPtr()));
}
void ServiceWorkerFetchDispatcher::DidPrepare() {
DCHECK(!prepare_callback_.is_null());
base::Closure prepare_callback = prepare_callback_;
prepare_callback.Run();
}
void ServiceWorkerFetchDispatcher::DidFinish(
ServiceWorkerStatusCode status,
ServiceWorkerFetchEventResult fetch_result,
const ServiceWorkerResponse& response) {
TRACE_EVENT_ASYNC_END0(
"ServiceWorker",
"ServiceWorkerFetchDispatcher::DispatchFetchEvent",
request_.get());
DCHECK(!fetch_callback_.is_null());
FetchCallback fetch_callback = fetch_callback_;
fetch_callback.Run(status, fetch_result, response);
}
} // namespace content
|
