PluginProcessManager.cpp [plain text]
#include "config.h"
#include "PluginProcessManager.h"
#if ENABLE(NETSCAPE_PLUGIN_API)
#include "PluginProcessProxy.h"
#include <wtf/CryptographicallyRandomNumber.h>
#include <wtf/StdLibExtras.h>
#include <wtf/text/WTFString.h>
namespace WebKit {
PluginProcessManager& PluginProcessManager::singleton()
{
static NeverDestroyed<PluginProcessManager> pluginProcessManager;
return pluginProcessManager;
}
PluginProcessManager::PluginProcessManager()
#if PLATFORM(COCOA)
: m_processSuppressionDisabledForPageCounter([this](bool value) { updateProcessSuppressionDisabled(value); })
#endif
{
}
uint64_t PluginProcessManager::pluginProcessToken(const PluginModuleInfo& pluginModuleInfo, PluginProcessType pluginProcessType, PluginProcessSandboxPolicy pluginProcessSandboxPolicy)
{
for (size_t i = 0; i < m_pluginProcessTokens.size(); ++i) {
const PluginProcessAttributes& attributes = m_pluginProcessTokens[i].first;
if (attributes.moduleInfo.path == pluginModuleInfo.path
&& attributes.processType == pluginProcessType
&& attributes.sandboxPolicy == pluginProcessSandboxPolicy)
return m_pluginProcessTokens[i].second;
}
uint64_t token;
while (true) {
cryptographicallyRandomValues(&token, sizeof(token));
if (m_knownTokens.isValidValue(token) && !m_knownTokens.contains(token))
break;
}
PluginProcessAttributes attributes;
attributes.moduleInfo = pluginModuleInfo;
attributes.processType = pluginProcessType;
attributes.sandboxPolicy = pluginProcessSandboxPolicy;
m_pluginProcessTokens.append(std::make_pair(WTF::move(attributes), token));
m_knownTokens.add(token);
return token;
}
void PluginProcessManager::getPluginProcessConnection(uint64_t pluginProcessToken, PassRefPtr<Messages::WebProcessProxy::GetPluginProcessConnection::DelayedReply> reply)
{
ASSERT(pluginProcessToken);
PluginProcessProxy* pluginProcess = getOrCreatePluginProcess(pluginProcessToken);
pluginProcess->getPluginProcessConnection(reply);
}
void PluginProcessManager::removePluginProcessProxy(PluginProcessProxy* pluginProcessProxy)
{
size_t vectorIndex = m_pluginProcesses.find(pluginProcessProxy);
ASSERT(vectorIndex != notFound);
m_pluginProcesses.remove(vectorIndex);
}
void PluginProcessManager::fetchWebsiteData(const PluginModuleInfo& plugin, std::function<void (Vector<String>)> completionHandler)
{
PluginProcessProxy* pluginProcess = getOrCreatePluginProcess(pluginProcessToken(plugin, PluginProcessTypeNormal, PluginProcessSandboxPolicyNormal));
pluginProcess->fetchWebsiteData(WTF::move(completionHandler));
}
void PluginProcessManager::deleteWebsiteData(const PluginModuleInfo& plugin, std::chrono::system_clock::time_point modifiedSince, std::function<void ()> completionHandler)
{
PluginProcessProxy* pluginProcess = getOrCreatePluginProcess(pluginProcessToken(plugin, PluginProcessTypeNormal, PluginProcessSandboxPolicyNormal));
pluginProcess->deleteWebsiteData(modifiedSince, WTF::move(completionHandler));
}
void PluginProcessManager::deleteWebsiteDataForHostNames(const PluginModuleInfo& plugin, const Vector<String>& hostNames, std::function<void ()> completionHandler)
{
PluginProcessProxy* pluginProcess = getOrCreatePluginProcess(pluginProcessToken(plugin, PluginProcessTypeNormal, PluginProcessSandboxPolicyNormal));
pluginProcess->deleteWebsiteDataForHostNames(hostNames, WTF::move(completionHandler));
}
PluginProcessProxy* PluginProcessManager::getOrCreatePluginProcess(uint64_t pluginProcessToken)
{
for (size_t i = 0; i < m_pluginProcesses.size(); ++i) {
if (m_pluginProcesses[i]->pluginProcessToken() == pluginProcessToken)
return m_pluginProcesses[i].get();
}
for (size_t i = 0; i < m_pluginProcessTokens.size(); ++i) {
auto& attributesAndToken = m_pluginProcessTokens[i];
if (attributesAndToken.second == pluginProcessToken) {
RefPtr<PluginProcessProxy> pluginProcess = PluginProcessProxy::create(this, attributesAndToken.first, attributesAndToken.second);
PluginProcessProxy* pluginProcessPtr = pluginProcess.get();
m_pluginProcesses.append(pluginProcess.release());
return pluginProcessPtr;
}
}
return nullptr;
}
}
#endif // ENABLE(NETSCAPE_PLUGIN_API)