This source file includes following definitions.
- permissions_
- GetInterfaceProxy
- AddIOThreadMessageFilter
- OnMessageReceived
- SetSerializationRules
- OnInvalidMessageReceived
#include "ppapi/proxy/dispatcher.h"
#include <string.h>
#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() {
}
InterfaceProxy* Dispatcher::GetInterfaceProxy(ApiID id) {
InterfaceProxy* proxy = proxies_[id].get();
if (!proxy) {
InterfaceProxy::Factory factory =
InterfaceList::GetInstance()->GetFactoryForID(id);
if (!factory) {
NOTREACHED();
return NULL;
}
proxy = factory(this);
DCHECK(proxy);
proxies_[id].reset(proxy);
}
return proxy;
}
void Dispatcher::AddIOThreadMessageFilter(
IPC::ChannelProxy::MessageFilter* filter) {
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() {
}
}
}