blob: 3b18932447a8b5a4f4e8ae64845d76997d689594 (
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 (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.
#include "ppapi/proxy/dispatcher.h"
#include <string.h> // For memset.
#include <map>
#include "base/compiler_specific.h"
#include "base/logging.h"
#include "base/memory/singleton.h"
#include "ppapi/proxy/ppapi_messages.h"
#include "ppapi/proxy/var_serialization_rules.h"
namespace ppapi {
namespace proxy {
Dispatcher::Dispatcher(PP_GetInterface_Func local_get_interface,
const PpapiPermissions& permissions)
: local_get_interface_(local_get_interface),
permissions_(permissions) {
}
Dispatcher::~Dispatcher() {
}
void Dispatcher::AddFilter(IPC::Listener* listener) {
filters_.push_back(listener);
}
InterfaceProxy* Dispatcher::GetInterfaceProxy(ApiID id) {
InterfaceProxy* proxy = proxies_[id].get();
if (!proxy) {
// Handle the first time for a given API by creating the proxy for it.
InterfaceProxy::Factory factory =
InterfaceList::GetInstance()->GetFactoryForID(id);
if (!factory) {
NOTREACHED();
return NULL;
}
proxy = factory(this);
DCHECK(proxy);
proxies_[id].reset(proxy);
}
return proxy;
}
base::MessageLoopProxy* Dispatcher::GetIPCMessageLoop() {
return delegate()->GetIPCMessageLoop();
}
void Dispatcher::AddIOThreadMessageFilter(
IPC::ChannelProxy::MessageFilter* filter) {
// Our filter is refcounted. The channel will call the destruct method on the
// filter when the channel is done with it, so the corresponding Release()
// happens there.
channel()->AddFilter(filter);
}
bool Dispatcher::OnMessageReceived(const IPC::Message& msg) {
if (msg.routing_id() <= 0 || msg.routing_id() >= API_ID_COUNT) {
OnInvalidMessageReceived();
return true;
}
InterfaceProxy* proxy = GetInterfaceProxy(
static_cast<ApiID>(msg.routing_id()));
if (!proxy) {
NOTREACHED();
return true;
}
return proxy->OnMessageReceived(msg);
}
void Dispatcher::SetSerializationRules(
VarSerializationRules* var_serialization_rules) {
serialization_rules_ = var_serialization_rules;
}
void Dispatcher::OnInvalidMessageReceived() {
}
} // namespace proxy
} // namespace ppapi
|
