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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
// Copyright 2015 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.
#ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CONTEXT_WATCHER_H_
#define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CONTEXT_WATCHER_H_
#include <stdint.h>
#include <unordered_map>
#include <vector>
#include "base/callback.h"
#include "content/browser/service_worker/service_worker_context_core_observer.h"
#include "content/browser/service_worker/service_worker_info.h"
#include "content/common/content_export.h"
#include "third_party/blink/public/mojom/service_worker/service_worker_provider_type.mojom.h"
namespace content {
class ServiceWorkerContextWrapper;
enum class EmbeddedWorkerStatus;
// Used to monitor the status change of the ServiceWorker registrations and
// versions in the ServiceWorkerContext from UI thread.
class CONTENT_EXPORT ServiceWorkerContextWatcher
: public ServiceWorkerContextCoreObserver,
public base::RefCountedThreadSafe<ServiceWorkerContextWatcher> {
public:
typedef base::Callback<void(
const std::vector<ServiceWorkerRegistrationInfo>&)>
WorkerRegistrationUpdatedCallback;
typedef base::Callback<void(const std::vector<ServiceWorkerVersionInfo>&)>
WorkerVersionUpdatedCallback;
typedef base::Callback<void(int64_t /* registration_id */,
int64_t /* version_id */,
const ErrorInfo&)> WorkerErrorReportedCallback;
ServiceWorkerContextWatcher(
scoped_refptr<ServiceWorkerContextWrapper> context,
const WorkerRegistrationUpdatedCallback& registration_callback,
const WorkerVersionUpdatedCallback& version_callback,
const WorkerErrorReportedCallback& error_callback);
void Start();
void Stop();
private:
friend class base::RefCountedThreadSafe<ServiceWorkerContextWatcher>;
friend class ServiceWorkerContextWatcherTest;
~ServiceWorkerContextWatcher() override;
void GetStoredRegistrationsOnIOThread();
void OnStoredRegistrationsOnIOThread(
ServiceWorkerStatusCode status,
const std::vector<ServiceWorkerRegistrationInfo>& stored_registrations);
void StopOnIOThread();
void StoreRegistrationInfo(
const ServiceWorkerRegistrationInfo& registration,
std::unordered_map<int64_t,
std::unique_ptr<ServiceWorkerRegistrationInfo>>*
info_map);
void StoreVersionInfo(const ServiceWorkerVersionInfo& version);
void SendRegistrationInfo(
int64_t registration_id,
const GURL& pattern,
ServiceWorkerRegistrationInfo::DeleteFlag delete_flag);
void SendVersionInfo(const ServiceWorkerVersionInfo& version);
void RunWorkerRegistrationUpdatedCallback(
std::unique_ptr<std::vector<ServiceWorkerRegistrationInfo>>
registrations);
void RunWorkerVersionUpdatedCallback(
std::unique_ptr<std::vector<ServiceWorkerVersionInfo>> versions);
void RunWorkerErrorReportedCallback(int64_t registration_id,
int64_t version_id,
std::unique_ptr<ErrorInfo> error_info);
// ServiceWorkerContextCoreObserver implements
void OnNewLiveRegistration(int64_t registration_id,
const GURL& pattern) override;
void OnNewLiveVersion(const ServiceWorkerVersionInfo& version_info) override;
void OnRunningStateChanged(
int64_t version_id,
content::EmbeddedWorkerStatus running_status) override;
void OnVersionStateChanged(
int64_t version_id,
content::ServiceWorkerVersion::Status status) override;
void OnVersionDevToolsRoutingIdChanged(int64_t version_id,
int process_id,
int devtools_agent_route_id) override;
void OnMainScriptHttpResponseInfoSet(
int64_t version_id,
base::Time script_response_time,
base::Time script_last_modified) override;
void OnErrorReported(int64_t version_id,
int process_id,
int thread_id,
const ErrorInfo& info) override;
void OnReportConsoleMessage(int64_t version_id,
int process_id,
int thread_id,
const ConsoleMessage& message) override;
void OnControlleeAdded(int64_t version_id,
const std::string& uuid,
const ServiceWorkerClientInfo& info) override;
void OnControlleeRemoved(int64_t version_id,
const std::string& uuid) override;
void OnRegistrationCompleted(int64_t registration_id,
const GURL& pattern) override;
void OnRegistrationDeleted(int64_t registration_id,
const GURL& pattern) override;
std::unordered_map<int64_t, std::unique_ptr<ServiceWorkerVersionInfo>>
version_info_map_;
scoped_refptr<ServiceWorkerContextWrapper> context_;
WorkerRegistrationUpdatedCallback registration_callback_;
WorkerVersionUpdatedCallback version_callback_;
WorkerErrorReportedCallback error_callback_;
// Should be used on UI thread only.
bool stop_called_ = false;
// Should be used on IO thread only.
bool is_stopped_ = false;
};
} // namespace content
#endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_CONTEXT_WATCHER_H_
|
