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
131
132
133
134
135
136
|
// Copyright (c) 2012 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_DEVTOOLS_WORKER_DEVTOOLS_MANAGER_H_
#define CONTENT_BROWSER_DEVTOOLS_WORKER_DEVTOOLS_MANAGER_H_
#include <list>
#include <map>
#include <string>
#include "base/basictypes.h"
#include "base/memory/singleton.h"
#include "content/browser/worker_host/worker_process_host.h"
#include "content/common/content_export.h"
namespace content {
class DevToolsAgentHost;
// All methods are supposed to be called on the IO thread.
class WorkerDevToolsManager {
public:
typedef std::pair<int, int> WorkerId;
class WorkerDevToolsAgentHost;
// Returns the WorkerDevToolsManager singleton.
static WorkerDevToolsManager* GetInstance();
// Called on the UI thread.
static DevToolsAgentHost* GetDevToolsAgentHostForWorker(
int worker_process_id,
int worker_route_id);
// Called on the UI thread.
static bool HasDevToolsAgentHostForWorker(
int worker_process_id,
int worker_route_id);
void ForwardToDevToolsClient(int worker_process_id,
int worker_route_id,
const std::string& message);
void SaveAgentRuntimeState(int worker_process_id,
int worker_route_id,
const std::string& state);
// Called on the IO thread.
void WorkerCreated(
WorkerProcessHost* process,
const WorkerProcessHost::WorkerInstance& instance);
void WorkerDestroyed(WorkerProcessHost* process, int worker_route_id);
void WorkerContextStarted(WorkerProcessHost* process, int worker_route_id);
private:
friend struct DefaultSingletonTraits<WorkerDevToolsManager>;
class DetachedClientHosts;
struct InspectedWorker {
InspectedWorker(WorkerProcessHost* host, int route_id, const GURL& url,
const base::string16& name)
: host(host),
route_id(route_id),
worker_url(url),
worker_name(name) {}
WorkerProcessHost* const host;
int const route_id;
GURL worker_url;
base::string16 worker_name;
};
typedef std::list<InspectedWorker> InspectedWorkersList;
WorkerDevToolsManager();
virtual ~WorkerDevToolsManager();
void RemoveInspectedWorkerData(const WorkerId& id);
InspectedWorkersList::iterator FindInspectedWorker(int host_id, int route_id);
void ConnectDevToolsAgentHostToWorker(int worker_process_id,
int worker_route_id);
void ForwardToWorkerDevToolsAgent(int worker_process_host_id,
int worker_route_id,
const IPC::Message& message);
static void ForwardToDevToolsClientOnUIThread(
int worker_process_id,
int worker_route_id,
const std::string& message);
static void SaveAgentRuntimeStateOnUIThread(
int worker_process_id,
int worker_route_id,
const std::string& state);
static void NotifyConnectionFailedOnIOThread(int worker_process_id,
int worker_route_id);
static void NotifyConnectionFailedOnUIThread(int worker_process_id,
int worker_route_id);
static void SendResumeToWorker(const WorkerId& id);
InspectedWorkersList inspected_workers_;
struct TerminatedInspectedWorker {
TerminatedInspectedWorker(WorkerId id, const GURL& url, const base::string16& name)
: old_worker_id(id),
worker_url(url),
worker_name(name) {}
WorkerId old_worker_id;
GURL worker_url;
base::string16 worker_name;
};
typedef std::list<TerminatedInspectedWorker> TerminatedInspectedWorkers;
// List of terminated workers for which there may be a devtools client on
// the UI thread. Worker entry is added into this list when inspected worker
// is terminated and will be removed in one of two cases:
// - shared worker with the same URL and name is started(in wich case we will
// try to reattach existing DevTools client to the new worker).
// - DevTools client which was inspecting terminated worker is closed on the
// UI thread and and WorkerDevToolsManager is notified about that on the IO
// thread.
TerminatedInspectedWorkers terminated_workers_;
typedef std::map<WorkerId, WorkerId> PausedWorkers;
// Map from old to new worker id for the inspected workers that have been
// terminated and started again in paused state. Worker data will be removed
// from this list in one of two cases:
// - DevTools client is closed on the UI thread, WorkerDevToolsManager was
// notified about that on the IO thread and sent "resume" message to the
// worker.
// - Existing DevTools client was reattached to the new worker.
PausedWorkers paused_workers_;
DISALLOW_COPY_AND_ASSIGN(WorkerDevToolsManager);
};
} // namespace content
#endif // CONTENT_BROWSER_DEVTOOLS_WORKER_DEVTOOLS_MANAGER_H_
|
