PluginProcessManager.cpp [plain text]
#include "config.h"
#include "PluginProcessManager.h"
#if ENABLE(NETSCAPE_PLUGIN_API)
#include "PluginProcessProxy.h"
#include "WebsiteDataFetchOption.h"
#include <wtf/CryptographicallyRandomNumber.h>
#include <wtf/NeverDestroyed.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](RefCounterEvent event) { updateProcessSuppressionDisabled(event); })
#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(WTFMove(attributes), token));
m_knownTokens.add(token);
return token;
}
void PluginProcessManager::getPluginProcessConnection(uint64_t pluginProcessToken, Messages::WebProcessProxy::GetPluginProcessConnection::DelayedReply&& reply)
{
ASSERT(pluginProcessToken);
PluginProcessProxy* pluginProcess = getOrCreatePluginProcess(pluginProcessToken);
pluginProcess->getPluginProcessConnection(WTFMove(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, OptionSet<WebsiteDataFetchOption> fetchOptions, WTF::Function<void (Vector<String>)>&& completionHandler)
{
auto token = pluginProcessToken(plugin, PluginProcessTypeNormal, PluginProcessSandboxPolicyNormal);
auto pluginProcess = fetchOptions.contains(WebsiteDataFetchOption::DoNotCreateProcesses) ? getPluginProcess(token) : getOrCreatePluginProcess(token);
if (!pluginProcess) {
completionHandler({ });
return;
}
pluginProcess->fetchWebsiteData(WTFMove(completionHandler));
}
void PluginProcessManager::deleteWebsiteData(const PluginModuleInfo& plugin, WallTime modifiedSince, WTF::Function<void ()>&& completionHandler)
{
PluginProcessProxy* pluginProcess = getOrCreatePluginProcess(pluginProcessToken(plugin, PluginProcessTypeNormal, PluginProcessSandboxPolicyNormal));
pluginProcess->deleteWebsiteData(modifiedSince, WTFMove(completionHandler));
}
void PluginProcessManager::deleteWebsiteDataForHostNames(const PluginModuleInfo& plugin, const Vector<String>& hostNames,WTF::Function<void ()>&& completionHandler)
{
PluginProcessProxy* pluginProcess = getOrCreatePluginProcess(pluginProcessToken(plugin, PluginProcessTypeNormal, PluginProcessSandboxPolicyNormal));
pluginProcess->deleteWebsiteDataForHostNames(hostNames, WTFMove(completionHandler));
}
PluginProcessProxy* PluginProcessManager::getPluginProcess(uint64_t pluginProcessToken)
{
for (const auto& pluginProcess : m_pluginProcesses) {
if (pluginProcess->pluginProcessToken() == pluginProcessToken)
return pluginProcess.get();
}
return nullptr;
}
#if OS(LINUX)
void PluginProcessManager::sendMemoryPressureEvent(bool isCritical)
{
for (auto& pluginProcess : m_pluginProcesses)
pluginProcess->sendMemoryPressureEvent(isCritical);
}
#endif
PluginProcessProxy* PluginProcessManager::getOrCreatePluginProcess(uint64_t pluginProcessToken)
{
if (auto existingProcess = getPluginProcess(pluginProcessToken))
return existingProcess;
for (auto& attributesAndToken : m_pluginProcessTokens) {
if (attributesAndToken.second == pluginProcessToken) {
auto pluginProcess = PluginProcessProxy::create(this, attributesAndToken.first, attributesAndToken.second);
PluginProcessProxy* pluginProcessPtr = pluginProcess.ptr();
m_pluginProcesses.append(WTFMove(pluginProcess));
return pluginProcessPtr;
}
}
return nullptr;
}
}
#endif // ENABLE(NETSCAPE_PLUGIN_API)