PluginProcessConnection.cpp [plain text]
#include "config.h"
#include "PluginProcessConnection.h"
#if ENABLE(PLUGIN_PROCESS)
#include <runtime/JSObject.h>
#include <runtime/ScopeChain.h>
#include "NPRemoteObjectMap.h"
#include "NPRuntimeObjectMap.h"
#include "PluginProcessConnectionManager.h"
#include "PluginProxy.h"
#include "WebProcess.h"
#include "WebProcessProxyMessages.h"
#include <WebCore/FileSystem.h>
using namespace WebCore;
namespace WebKit {
PluginProcessConnection::PluginProcessConnection(PluginProcessConnectionManager* pluginProcessConnectionManager, const String& pluginPath, CoreIPC::Connection::Identifier connectionIdentifier)
: m_pluginProcessConnectionManager(pluginProcessConnectionManager)
, m_pluginPath(pluginPath)
{
m_connection = CoreIPC::Connection::createClientConnection(connectionIdentifier, this, WebProcess::shared().runLoop());
m_npRemoteObjectMap = NPRemoteObjectMap::create(m_connection.get());
m_connection->open();
}
PluginProcessConnection::~PluginProcessConnection()
{
ASSERT(!m_connection);
ASSERT(!m_npRemoteObjectMap);
}
void PluginProcessConnection::addPluginProxy(PluginProxy* plugin)
{
ASSERT(!m_plugins.contains(plugin->pluginInstanceID()));
m_plugins.set(plugin->pluginInstanceID(), plugin);
}
void PluginProcessConnection::removePluginProxy(PluginProxy* plugin)
{
ASSERT(m_plugins.contains(plugin->pluginInstanceID()));
m_plugins.remove(plugin->pluginInstanceID());
m_npRemoteObjectMap->pluginDestroyed(plugin);
if (!m_plugins.isEmpty())
return;
m_npRemoteObjectMap = nullptr;
ASSERT(m_connection);
m_connection->invalidate();
m_connection = nullptr;
m_pluginProcessConnectionManager->removePluginProcessConnection(this);
}
void PluginProcessConnection::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::ArgumentDecoder* arguments)
{
ASSERT(arguments->destinationID());
PluginProxy* pluginProxy = m_plugins.get(arguments->destinationID());
if (!pluginProxy)
return;
pluginProxy->didReceivePluginProxyMessage(connection, messageID, arguments);
}
void PluginProcessConnection::didReceiveSyncMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::ArgumentDecoder* arguments, OwnPtr<CoreIPC::ArgumentEncoder>& reply)
{
if (messageID.is<CoreIPC::MessageClassNPObjectMessageReceiver>()) {
m_npRemoteObjectMap->didReceiveSyncMessage(connection, messageID, arguments, reply);
return;
}
uint64_t destinationID = arguments->destinationID();
if (!destinationID) {
didReceiveSyncPluginProcessConnectionMessage(connection, messageID, arguments, reply);
return;
}
PluginProxy* pluginProxy = m_plugins.get(destinationID);
if (!pluginProxy)
return;
pluginProxy->didReceiveSyncPluginProxyMessage(connection, messageID, arguments, reply);
}
void PluginProcessConnection::didClose(CoreIPC::Connection*)
{
for (HashMap<uint64_t, PluginProxy*>::const_iterator::Values it = m_plugins.begin().values(), end = m_plugins.end().values(); it != end; ++it) {
PluginProxy* pluginProxy = (*it);
pluginProxy->pluginProcessCrashed();
}
}
void PluginProcessConnection::didReceiveInvalidMessage(CoreIPC::Connection*, CoreIPC::MessageID)
{
}
void PluginProcessConnection::setException(const String& exceptionString)
{
NPRuntimeObjectMap::setGlobalException(exceptionString);
}
}
#endif // ENABLE(PLUGIN_PROCESS)