PluginProcessConnection.cpp [plain text]
#include "config.h"
#include "PluginProcessConnection.h"
#if ENABLE(PLUGIN_PROCESS)
#include "NPRemoteObjectMap.h"
#include "PluginProcessConnectionManager.h"
#include "PluginProxy.h"
#include "WebProcess.h"
#include "WebProcessProxyMessages.h"
#include <WebCore/FileSystem.h>
using namespace WebCore;
namespace WebKit {
static const double syncMessageTimeout = 45;
static double defaultSyncMessageTimeout(const String& pluginPath)
{
if (pathGetFileName(pluginPath) == "AppleConnect.plugin")
return CoreIPC::Connection::NoTimeout;
if (pathGetFileName(pluginPath) == "SharePointBrowserPlugin.plugin")
return CoreIPC::Connection::NoTimeout;
if (pathGetFileName(pluginPath) == "PersonalPlugin.bundle")
return CoreIPC::Connection::NoTimeout;
return syncMessageTimeout;
}
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_connection->setDefaultSyncMessageTimeout(defaultSyncMessageTimeout(m_pluginPath));
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)
{
if (arguments->destinationID()) {
if (PluginProxy* pluginProxy = m_plugins.get(arguments->destinationID()))
pluginProxy->didReceivePluginProxyMessage(connection, messageID, arguments);
return;
}
ASSERT_NOT_REACHED();
}
CoreIPC::SyncReplyMode PluginProcessConnection::didReceiveSyncMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::ArgumentDecoder* arguments, CoreIPC::ArgumentEncoder* reply)
{
if (messageID.is<CoreIPC::MessageClassNPObjectMessageReceiver>())
return m_npRemoteObjectMap->didReceiveSyncMessage(connection, messageID, arguments, reply);
if (PluginProxy* pluginProxy = m_plugins.get(arguments->destinationID()))
return pluginProxy->didReceiveSyncPluginProxyMessage(connection, messageID, arguments, reply);
ASSERT_NOT_REACHED();
return CoreIPC::AutomaticReply;
}
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::syncMessageSendTimedOut(CoreIPC::Connection*)
{
WebProcess::shared().connection()->send(Messages::WebProcessProxy::PluginSyncMessageSendTimedOut(m_pluginPath), 0);
}
}
#endif // ENABLE(PLUGIN_PROCESS)