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
|
// 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.
#ifndef CONTENT_RENDERER_SHARED_WORKER_EMBEDDED_SHARED_WORKER_STUB_H_
#define CONTENT_RENDERER_SHARED_WORKER_EMBEDDED_SHARED_WORKER_STUB_H_
#include <vector>
#include "base/macros.h"
#include "content/child/child_message_filter.h"
#include "content/child/scoped_child_process_reference.h"
#include "ipc/ipc_listener.h"
#include "third_party/WebKit/public/platform/WebAddressSpace.h"
#include "third_party/WebKit/public/platform/WebString.h"
#include "third_party/WebKit/public/web/WebContentSecurityPolicy.h"
#include "third_party/WebKit/public/web/WebSharedWorkerClient.h"
#include "url/gurl.h"
namespace blink {
class WebApplicationCacheHost;
class WebApplicationCacheHostClient;
class WebMessagePortChannel;
class WebNotificationPresenter;
class WebSecurityOrigin;
class WebSharedWorker;
class WebWorkerContentSettingsClientProxy;
}
namespace content {
class SharedWorkerDevToolsAgent;
class WebApplicationCacheHostImpl;
class WebMessagePortChannelImpl;
// A stub class to receive IPC from browser process and talk to
// blink::WebSharedWorker. Implements blink::WebSharedWorkerClient.
// This class is self-destruct (no one explicitly owns this), and
// deletes itself (via private Shutdown() method) when either one of
// following methods is called by blink::WebSharedWorker:
// - workerScriptLoadFailed() or
// - workerContextDestroyed()
//
// In either case the corresponding blink::WebSharedWorker also deletes
// itself.
class EmbeddedSharedWorkerStub : public IPC::Listener,
public blink::WebSharedWorkerClient {
public:
EmbeddedSharedWorkerStub(
const GURL& url,
const base::string16& name,
const base::string16& content_security_policy,
blink::WebContentSecurityPolicyType security_policy_type,
blink::WebAddressSpace creation_address_space,
bool pause_on_start,
int route_id);
// IPC::Listener implementation.
bool OnMessageReceived(const IPC::Message& message) override;
void OnChannelError() override;
// blink::WebSharedWorkerClient implementation.
void workerContextClosed() override;
void workerContextDestroyed() override;
void workerReadyForInspection() override;
void workerScriptLoaded() override;
void workerScriptLoadFailed() override;
void selectAppCacheID(long long) override;
blink::WebNotificationPresenter* notificationPresenter() override;
blink::WebApplicationCacheHost* createApplicationCacheHost(
blink::WebApplicationCacheHostClient*) override;
blink::WebWorkerContentSettingsClientProxy*
createWorkerContentSettingsClientProxy(
const blink::WebSecurityOrigin& origin) override;
blink::WebServiceWorkerNetworkProvider* createServiceWorkerNetworkProvider(
blink::WebDataSource*) override;
void sendDevToolsMessage(int session_id,
int call_id,
const blink::WebString& message,
const blink::WebString& state) override;
private:
~EmbeddedSharedWorkerStub() override;
void Shutdown();
bool Send(IPC::Message* message);
// WebSharedWorker will own |channel|.
void ConnectToChannel(WebMessagePortChannelImpl* channel);
void OnConnect(int sent_message_port_id, int routing_id);
void OnTerminateWorkerContext();
int route_id_;
base::string16 name_;
bool running_ = false;
GURL url_;
blink::WebSharedWorker* impl_ = nullptr;
scoped_ptr<SharedWorkerDevToolsAgent> worker_devtools_agent_;
typedef std::vector<WebMessagePortChannelImpl*> PendingChannelList;
PendingChannelList pending_channels_;
ScopedChildProcessReference process_ref_;
WebApplicationCacheHostImpl* app_cache_host_ = nullptr;
DISALLOW_COPY_AND_ASSIGN(EmbeddedSharedWorkerStub);
};
} // namespace content
#endif // CONTENT_RENDERER_SHARED_WORKER_EMBEDDED_SHARED_WORKER_STUB_H_
|
