blob: e010c56c0d1e9ccbebc4d2905548d1bd12abfa63 (
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
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
|
// Copyright (c) 2006-2008 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 "chrome/renderer/plugin_channel_host.h"
#include "chrome/common/plugin_messages.h"
// A simple MessageFilter that will ignore all messages and respond to sync
// messages with an error when is_listening_ is false.
class IsListeningFilter : public IPC::ChannelProxy::MessageFilter {
public:
IsListeningFilter() {}
// MessageFilter overrides
virtual void OnFilterRemoved() {}
virtual void OnFilterAdded(IPC::Channel* channel) { channel_ = channel; }
virtual bool OnMessageReceived(const IPC::Message& message);
static bool is_listening_;
private:
IPC::Channel* channel_;
DISALLOW_EVIL_CONSTRUCTORS(IsListeningFilter);
};
bool IsListeningFilter::OnMessageReceived(const IPC::Message& message) {
if (IsListeningFilter::is_listening_) {
// Proceed with normal operation.
return false;
}
// Always process message reply to prevent renderer from hanging on sync
// messages.
if (message.is_reply() || message.is_reply_error()) {
return false;
}
// Reply to synchronous messages with an error (so they don't block while
// we're not listening).
if (message.is_sync()) {
IPC::Message* reply = IPC::SyncMessage::GenerateReply(&message);
reply->set_reply_error();
channel_->Send(reply);
}
return true;
}
// static
bool IsListeningFilter::is_listening_ = true;
// static
bool PluginChannelHost::IsListening() {
return IsListeningFilter::is_listening_;
}
// static
void PluginChannelHost::SetListening(bool flag) {
IsListeningFilter::is_listening_ = flag;
}
PluginChannelHost* PluginChannelHost::GetPluginChannelHost(
const std::string& channel_name, MessageLoop* ipc_message_loop) {
PluginChannelHost* result =
static_cast<PluginChannelHost*>(PluginChannelBase::GetChannel(
channel_name,
IPC::Channel::MODE_CLIENT,
ClassFactory,
ipc_message_loop,
true));
return result;
}
PluginChannelHost::PluginChannelHost() {
}
PluginChannelHost::~PluginChannelHost() {
}
bool PluginChannelHost::Init(MessageLoop* ipc_message_loop,
bool create_pipe_now) {
bool ret = PluginChannelBase::Init(ipc_message_loop, create_pipe_now);
is_listening_filter_ = new IsListeningFilter;
channel_->AddFilter(is_listening_filter_);
return ret;
}
int PluginChannelHost::GenerateRouteID() {
int route_id = MSG_ROUTING_NONE;
Send(new PluginMsg_GenerateRouteID(&route_id));
return route_id;
}
void PluginChannelHost::AddRoute(int route_id,
IPC::Channel::Listener* listener,
bool npobject) {
PluginChannelBase::AddRoute(route_id, listener, npobject);
if (!npobject)
proxies_[route_id] = listener;
}
void PluginChannelHost::RemoveRoute(int route_id) {
proxies_.erase(route_id);
PluginChannelBase::RemoveRoute(route_id);
}
void PluginChannelHost::OnChannelError() {
PluginChannelBase::OnChannelError();
for (ProxyMap::iterator iter = proxies_.begin();
iter != proxies_.end(); iter++) {
iter->second->OnChannelError();
}
proxies_.clear();
}
|
