blob: 5731e4bb998d841b07d346dbc46d6e7b4a3d6646 (
plain)
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
|
// 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/devtools/shared_worker_devtools_manager.h"
#include "content/browser/devtools/shared_worker_devtools_agent_host.h"
#include "content/browser/shared_worker/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(live_hosts_.find(worker_host) == live_hosts_.end());
auto it =
std::find_if(terminated_hosts_.begin(), terminated_hosts_.end(),
[&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) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
live_hosts_[worker_host]->WorkerReadyForInspection();
}
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);
}
SharedWorkerDevToolsManager::SharedWorkerDevToolsManager() {
}
SharedWorkerDevToolsManager::~SharedWorkerDevToolsManager() {
}
} // namespace content
|
