PluginProcessConnection.cpp [plain text]
#include "config.h"
#include "PluginProcessConnection.h"
#if ENABLE(NETSCAPE_PLUGIN_API)
#include "NPObjectMessageReceiverMessages.h"
#include "NPRemoteObjectMap.h"
#include "NPRuntimeObjectMap.h"
#include "PluginProcessConnectionManager.h"
#include "PluginProxy.h"
#include "WebProcess.h"
#include "WebProcessProxyMessages.h"
#include <WebCore/FileSystem.h>
#include <runtime/JSObject.h>
using namespace WebCore;
namespace WebKit {
PluginProcessConnection::PluginProcessConnection(PluginProcessConnectionManager* pluginProcessConnectionManager, uint64_t pluginProcessToken, IPC::Connection::Identifier connectionIdentifier, bool supportsAsynchronousPluginInitialization)
: m_pluginProcessConnectionManager(pluginProcessConnectionManager)
, m_pluginProcessToken(pluginProcessToken)
, m_supportsAsynchronousPluginInitialization(supportsAsynchronousPluginInitialization)
, m_audioHardwareActivity(WebCore::AudioHardwareActivityType::Unknown)
{
m_connection = IPC::Connection::createClientConnection(connectionIdentifier, *this);
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(IPC::Connection& connection, IPC::MessageDecoder& decoder)
{
if (!decoder.destinationID()) {
didReceivePluginProcessConnectionMessage(connection, decoder);
return;
}
ASSERT(decoder.destinationID());
PluginProxy* pluginProxy = m_plugins.get(decoder.destinationID());
if (!pluginProxy)
return;
pluginProxy->didReceivePluginProxyMessage(connection, decoder);
}
void PluginProcessConnection::didReceiveSyncMessage(IPC::Connection& connection, IPC::MessageDecoder& decoder, std::unique_ptr<IPC::MessageEncoder>& replyEncoder)
{
if (decoder.messageReceiverName() == Messages::NPObjectMessageReceiver::messageReceiverName()) {
m_npRemoteObjectMap->didReceiveSyncMessage(connection, decoder, replyEncoder);
return;
}
uint64_t destinationID = decoder.destinationID();
if (!destinationID) {
didReceiveSyncPluginProcessConnectionMessage(connection, decoder, replyEncoder);
return;
}
PluginProxy* pluginProxy = m_plugins.get(destinationID);
if (!pluginProxy)
return;
pluginProxy->didReceiveSyncPluginProxyMessage(connection, decoder, replyEncoder);
}
void PluginProcessConnection::didClose(IPC::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(IPC::Connection&, IPC::StringReference, IPC::StringReference)
{
}
void PluginProcessConnection::setException(const String& exceptionString)
{
NPRuntimeObjectMap::setGlobalException(exceptionString);
}
void PluginProcessConnection::audioHardwareDidBecomeActive()
{
m_audioHardwareActivity = WebCore::AudioHardwareActivityType::IsActive;
}
void PluginProcessConnection::audioHardwareDidBecomeInactive()
{
m_audioHardwareActivity = WebCore::AudioHardwareActivityType::IsInactive;
}
}
#endif // ENABLE(NETSCAPE_PLUGIN_API)