#include "config.h"
#include "GPUProcess.h"
#if ENABLE(GPU_PROCESS)
#include "ArgumentCoders.h"
#include "Attachment.h"
#include "AuxiliaryProcessMessages.h"
#include "DataReference.h"
#include "GPUConnectionToWebProcess.h"
#include "GPUProcessCreationParameters.h"
#include "Logging.h"
#include "WebPageProxyMessages.h"
#include "WebProcessPoolMessages.h"
#include <WebCore/LogInitialization.h>
#include <WebCore/MockAudioSharedUnit.h>
#include <wtf/Algorithms.h>
#include <wtf/CallbackAggregator.h>
#include <wtf/OptionSet.h>
#include <wtf/ProcessPrivilege.h>
#include <wtf/RunLoop.h>
#include <wtf/UniqueRef.h>
#include <wtf/text/AtomString.h>
namespace WebKit {
using namespace WebCore;
GPUProcess::GPUProcess(AuxiliaryProcessInitializationParameters&& parameters)
{
initialize(WTFMove(parameters));
}
GPUProcess::~GPUProcess()
{
}
void GPUProcess::createGPUConnectionToWebProcess(ProcessIdentifier identifier, PAL::SessionID sessionID, CompletionHandler<void(Optional<IPC::Attachment>&&)>&& completionHandler)
{
auto ipcConnection = createIPCConnectionPair();
if (!ipcConnection) {
completionHandler({ });
return;
}
auto newConnection = GPUConnectionToWebProcess::create(*this, identifier, ipcConnection->first, sessionID);
ASSERT(!m_webProcessConnections.contains(identifier));
m_webProcessConnections.add(identifier, WTFMove(newConnection));
completionHandler(WTFMove(ipcConnection->second));
}
void GPUProcess::removeGPUConnectionToWebProcess(GPUConnectionToWebProcess& connection)
{
ASSERT(m_webProcessConnections.contains(connection.webProcessIdentifier()));
m_webProcessConnections.remove(connection.webProcessIdentifier());
}
void GPUProcess::connectionToWebProcessClosed(IPC::Connection& connection)
{
}
bool GPUProcess::shouldTerminate()
{
return m_webProcessConnections.isEmpty();
}
void GPUProcess::didClose(IPC::Connection&)
{
ASSERT(RunLoop::isMain());
}
void GPUProcess::lowMemoryHandler(Critical critical)
{
WTF::releaseFastMallocFreeMemory();
}
void GPUProcess::initializeGPUProcess(GPUProcessCreationParameters&& parameters)
{
WTF::Thread::setCurrentThreadIsUserInitiated();
AtomString::init();
setMockCaptureDevicesEnabled(parameters.useMockCaptureDevices);
}
void GPUProcess::prepareToSuspend(bool isSuspensionImminent, CompletionHandler<void()>&& completionHandler)
{
RELEASE_LOG(ProcessSuspension, "%p - GPUProcess::prepareToSuspend(), isSuspensionImminent: %d", this, isSuspensionImminent);
lowMemoryHandler(Critical::Yes);
}
void GPUProcess::processDidResume()
{
RELEASE_LOG(ProcessSuspension, "%p - GPUProcess::processDidResume()", this);
resume();
}
void GPUProcess::resume()
{
}
void GPUProcess::processDidTransitionToForeground()
{
}
void GPUProcess::processDidTransitionToBackground()
{
}
GPUConnectionToWebProcess* GPUProcess::webProcessConnection(ProcessIdentifier identifier) const
{
return m_webProcessConnections.get(identifier);
}
void GPUProcess::setMockCaptureDevicesEnabled(bool isEnabled)
{
#if ENABLE(MEDIA_STREAM)
MockAudioSharedUnit::singleton().setDisableAudioSessionCheck(isEnabled);
MockRealtimeMediaSourceCenter::setMockRealtimeMediaSourceCenterEnabled(isEnabled);
#endif
}
}
#endif // ENABLE(GPU_PROCESS)