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
|
// Copyright 2014 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "content/browser/devtools/shared_worker_devtools_manager.h"
#include <algorithm>
#include "base/containers/contains.h"
#include "content/browser/devtools/shared_worker_devtools_agent_host.h"
#include "content/browser/worker_host/shared_worker_host.h"
#include "content/public/browser/browser_thread.h"
namespace content {
// static
SharedWorkerDevToolsManager* SharedWorkerDevToolsManager::GetInstance() {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
return base::Singleton<SharedWorkerDevToolsManager>::get();
}
void SharedWorkerDevToolsManager::AddAllAgentHosts(
SharedWorkerDevToolsAgentHost::List* result) {
for (auto& it : live_hosts_)
result->push_back(it.second.get());
}
void SharedWorkerDevToolsManager::WorkerCreated(
SharedWorkerHost* worker_host,
bool* pause_on_start,
base::UnguessableToken* devtools_worker_token) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
DCHECK(!base::Contains(live_hosts_, worker_host));
auto it = std::ranges::find_if(
terminated_hosts_,
[&worker_host](SharedWorkerDevToolsAgentHost* agent_host) {
return agent_host->Matches(worker_host);
});
if (it == terminated_hosts_.end()) {
*devtools_worker_token = base::UnguessableToken::Create();
live_hosts_[worker_host] =
new SharedWorkerDevToolsAgentHost(worker_host, *devtools_worker_token);
*pause_on_start = false;
return;
}
SharedWorkerDevToolsAgentHost* agent_host = *it;
terminated_hosts_.erase(it);
live_hosts_[worker_host] = agent_host;
agent_host->WorkerRestarted(worker_host);
*pause_on_start = agent_host->IsAttached();
*devtools_worker_token = agent_host->devtools_worker_token();
}
void SharedWorkerDevToolsManager::WorkerReadyForInspection(
SharedWorkerHost* worker_host,
mojo::PendingRemote<blink::mojom::DevToolsAgent> agent_remote,
mojo::PendingReceiver<blink::mojom::DevToolsAgentHost>
agent_host_receiver) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
live_hosts_[worker_host]->WorkerReadyForInspection(
std::move(agent_remote), std::move(agent_host_receiver));
}
void SharedWorkerDevToolsManager::WorkerDestroyed(
SharedWorkerHost* worker_host) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
scoped_refptr<SharedWorkerDevToolsAgentHost> agent_host =
live_hosts_[worker_host];
live_hosts_.erase(worker_host);
terminated_hosts_.insert(agent_host.get());
agent_host->WorkerDestroyed();
}
void SharedWorkerDevToolsManager::AgentHostDestroyed(
SharedWorkerDevToolsAgentHost* agent_host) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
auto it = terminated_hosts_.find(agent_host);
// Might be missing during shutdown due to different
// destruction order of this manager, shared workers
// and their agent hosts.
if (it != terminated_hosts_.end())
terminated_hosts_.erase(it);
}
SharedWorkerDevToolsAgentHost* SharedWorkerDevToolsManager::GetDevToolsHost(
SharedWorkerHost* host) {
auto it = live_hosts_.find(host);
return it == live_hosts_.end() ? nullptr : it->second.get();
}
SharedWorkerDevToolsManager::SharedWorkerDevToolsManager() = default;
SharedWorkerDevToolsManager::~SharedWorkerDevToolsManager() = default;
} // namespace content
|
