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
|
// Copyright 2019 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifndef EXTENSIONS_BROWSER_SERVICE_WORKER_WORKER_ID_SET_H_
#define EXTENSIONS_BROWSER_SERVICE_WORKER_WORKER_ID_SET_H_
#include <set>
#include <vector>
#include "base/auto_reset.h"
#include "base/debug/crash_logging.h"
#include "extensions/browser/service_worker/worker_id.h"
#include "extensions/common/extension_id.h"
namespace content {
class BrowserContext;
}
// Set of WorkersIds that provides faster retrieval/removal of workers by
// extension id, render process id etc.
namespace extensions {
class WorkerIdSet {
public:
WorkerIdSet();
WorkerIdSet(const WorkerIdSet&) = delete;
WorkerIdSet& operator=(const WorkerIdSet&) = delete;
~WorkerIdSet();
void Add(const WorkerId& worker_id, content::BrowserContext* context);
bool Remove(const WorkerId& worker_id);
bool Contains(const WorkerId& worker_id) const;
std::vector<WorkerId> GetAllForExtension(
const ExtensionId& extension_id) const;
std::vector<WorkerId> GetAllForExtension(const ExtensionId& extension_id,
int render_process_id) const;
std::vector<WorkerId> GetAllForExtension(const ExtensionId& extension_id,
int64_t worker_version_id) const;
std::vector<WorkerId> GetAllForTesting() const;
static base::AutoReset<bool> AllowMultipleWorkersPerExtensionForTesting();
size_t count_for_testing() const { return workers_.size(); }
private:
std::set<WorkerId> workers_;
};
namespace debug {
// Helper for adding a set of multiple worker related crash keys.
//
// It is meant to be created when we detect exactly two entries for the same
// worker that will be recorded in `WorkerIdSet::Add()`.
//
// These crash keys set information relevant to when two workers are attempting
// to be added to the `WorkerIdSet`. All keys are logged every time this class
// is instantiated. Each key describes its possible values.
//
// The "previous" `WorkerId` is the one that existed before
// `WorkerIdSet::Add()` is called. The "new" `WorkerId` is the duplicate that
// will be added once `WorkerIdSet::Add()` completes.
class ScopedMultiWorkerCrashKeys {
public:
explicit ScopedMultiWorkerCrashKeys(const ExtensionId& extension_id,
const WorkerId& previous_worker_id,
const WorkerId& new_worker_id,
content::BrowserContext* context);
~ScopedMultiWorkerCrashKeys();
private:
base::debug::ScopedCrashKeyString extension_id_crash_key_;
// Whether the previous and new worker version ids match. Values are: "yes",
// or "no".
base::debug::ScopedCrashKeyString identical_version_ids_crash_key_;
// The `version_id`s for each worker. A (stringified) int64_t that identifies
// what version of code a worker is running.
base::debug::ScopedCrashKeyString previous_worker_version_id_crash_key_;
base::debug::ScopedCrashKeyString new_worker_version_id_crash_key_;
// The `content::ServiceWorkerRunningInfo::ServiceWorkerStatus`
// (`ServiceWorkerVersion::Status`) for the previous and new `WorkerId`s.
base::debug::ScopedCrashKeyString previous_worker_lifecycle_state_crash_key_;
base::debug::ScopedCrashKeyString new_worker_lifecycle_state_crash_key_;
// Whether the renderer process ids for the previous and new worker match.
// Values are: "yes", or "no".
base::debug::ScopedCrashKeyString
identical_worker_render_process_ids_crash_key_;
// Whether the renderer process id for the previous and new worker for this
// specific extension are running or not. Values are: "yes", or "no".
base::debug::ScopedCrashKeyString
previous_worker_render_process_running_crash_key_;
base::debug::ScopedCrashKeyString
new_worker_render_process_running_crash_key_;
};
} // namespace debug
} // namespace extensions
#endif // EXTENSIONS_BROWSER_SERVICE_WORKER_WORKER_ID_SET_H_
|
