PluginProcessConnectionManager.cpp [plain text]
#include "config.h"
#include "PluginProcessConnectionManager.h"
#if ENABLE(NETSCAPE_PLUGIN_API)
#include "ArgumentDecoder.h"
#include "ArgumentEncoder.h"
#include "PluginProcessConnection.h"
#include "PluginProcessConnectionManagerMessages.h"
#include "WebCoreArgumentCoders.h"
#include "WebProcess.h"
#include "WebProcessProxyMessages.h"
#if OS(DARWIN)
#include "MachPort.h"
#endif
namespace WebKit {
Ref<PluginProcessConnectionManager> PluginProcessConnectionManager::create()
{
return adoptRef(*new PluginProcessConnectionManager);
}
PluginProcessConnectionManager::PluginProcessConnectionManager()
: m_queue(WorkQueue::create("com.apple.WebKit.PluginProcessConnectionManager"))
{
}
PluginProcessConnectionManager::~PluginProcessConnectionManager()
{
}
void PluginProcessConnectionManager::initializeConnection(IPC::Connection* connection)
{
connection->addWorkQueueMessageReceiver(Messages::PluginProcessConnectionManager::messageReceiverName(), &m_queue.get(), this);
}
PluginProcessConnection* PluginProcessConnectionManager::getPluginProcessConnection(uint64_t pluginProcessToken)
{
for (size_t i = 0; i < m_pluginProcessConnections.size(); ++i) {
if (m_pluginProcessConnections[i]->pluginProcessToken() == pluginProcessToken)
return m_pluginProcessConnections[i].get();
}
IPC::Attachment encodedConnectionIdentifier;
bool supportsAsynchronousInitialization;
if (!WebProcess::singleton().parentProcessConnection()->sendSync(Messages::WebProcessProxy::GetPluginProcessConnection(pluginProcessToken),
Messages::WebProcessProxy::GetPluginProcessConnection::Reply(encodedConnectionIdentifier, supportsAsynchronousInitialization), 0))
return 0;
#if OS(DARWIN)
IPC::Connection::Identifier connectionIdentifier(encodedConnectionIdentifier.port());
#elif USE(UNIX_DOMAIN_SOCKETS)
IPC::Connection::Identifier connectionIdentifier = encodedConnectionIdentifier.releaseFileDescriptor();
#endif
if (IPC::Connection::identifierIsNull(connectionIdentifier))
return nullptr;
RefPtr<PluginProcessConnection> pluginProcessConnection = PluginProcessConnection::create(this, pluginProcessToken, connectionIdentifier, supportsAsynchronousInitialization);
m_pluginProcessConnections.append(pluginProcessConnection);
{
MutexLocker locker(m_tokensAndConnectionsMutex);
ASSERT(!m_tokensAndConnections.contains(pluginProcessToken));
m_tokensAndConnections.set(pluginProcessToken, pluginProcessConnection->connection());
}
return pluginProcessConnection.get();
}
void PluginProcessConnectionManager::removePluginProcessConnection(PluginProcessConnection* pluginProcessConnection)
{
size_t vectorIndex = m_pluginProcessConnections.find(pluginProcessConnection);
ASSERT(vectorIndex != notFound);
{
MutexLocker locker(m_tokensAndConnectionsMutex);
ASSERT(m_tokensAndConnections.contains(pluginProcessConnection->pluginProcessToken()));
m_tokensAndConnections.remove(pluginProcessConnection->pluginProcessToken());
}
m_pluginProcessConnections.remove(vectorIndex);
}
void PluginProcessConnectionManager::pluginProcessCrashed(uint64_t pluginProcessToken)
{
MutexLocker locker(m_tokensAndConnectionsMutex);
IPC::Connection* connection = m_tokensAndConnections.get(pluginProcessToken);
if (!connection)
return;
connection->postConnectionDidCloseOnConnectionWorkQueue();
}
}
#endif // ENABLE(NETSCAPE_PLUGIN_API)