NetworkProcessProxy.cpp [plain text]
#include "config.h"
#include "NetworkProcessProxy.h"
#if ENABLE(NETWORK_PROCESS)
#include "AuthenticationChallengeProxy.h"
#include "CustomProtocolManagerProxyMessages.h"
#include "DownloadProxyMessages.h"
#include "NetworkProcessCreationParameters.h"
#include "NetworkProcessMessages.h"
#include "WebContext.h"
#include "WebProcessMessages.h"
#include <WebCore/RunLoop.h>
#if USE(SECURITY_FRAMEWORK)
#include "SecItemShimProxy.h"
#endif
#define MESSAGE_CHECK(assertion) MESSAGE_CHECK_BASE(assertion, connection())
using namespace WebCore;
namespace WebKit {
PassRefPtr<NetworkProcessProxy> NetworkProcessProxy::create(WebContext* webContext)
{
return adoptRef(new NetworkProcessProxy(webContext));
}
NetworkProcessProxy::NetworkProcessProxy(WebContext* webContext)
: m_webContext(webContext)
, m_numPendingConnectionRequests(0)
#if ENABLE(CUSTOM_PROTOCOLS)
, m_customProtocolManagerProxy(this)
#endif
{
connect();
}
NetworkProcessProxy::~NetworkProcessProxy()
{
}
void NetworkProcessProxy::getLaunchOptions(ProcessLauncher::LaunchOptions& launchOptions)
{
launchOptions.processType = ProcessLauncher::NetworkProcess;
platformGetLaunchOptions(launchOptions);
}
void NetworkProcessProxy::connectionWillOpen(CoreIPC::Connection* connection)
{
#if USE(SECURITY_FRAMEWORK)
SecItemShimProxy::shared().initializeConnection(connection);
#endif
}
void NetworkProcessProxy::connectionWillClose(CoreIPC::Connection*)
{
}
void NetworkProcessProxy::getNetworkProcessConnection(PassRefPtr<Messages::WebProcessProxy::GetNetworkProcessConnection::DelayedReply> reply)
{
m_pendingConnectionReplies.append(reply);
if (isLaunching()) {
m_numPendingConnectionRequests++;
return;
}
connection()->send(Messages::NetworkProcess::CreateNetworkConnectionToWebProcess(), 0, CoreIPC::DispatchMessageEvenWhenWaitingForSyncReply);
}
DownloadProxy* NetworkProcessProxy::createDownloadProxy()
{
if (!m_downloadProxyMap)
m_downloadProxyMap = adoptPtr(new DownloadProxyMap(this));
return m_downloadProxyMap->createDownloadProxy(m_webContext);
}
void NetworkProcessProxy::networkProcessCrashedOrFailedToLaunch()
{
while (!m_pendingConnectionReplies.isEmpty()) {
RefPtr<Messages::WebProcessProxy::GetNetworkProcessConnection::DelayedReply> reply = m_pendingConnectionReplies.takeFirst();
#if PLATFORM(MAC)
reply->send(CoreIPC::Attachment(0, MACH_MSG_TYPE_MOVE_SEND));
#else
notImplemented();
#endif
}
m_webContext->networkProcessCrashed(this);
}
void NetworkProcessProxy::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageDecoder& decoder)
{
if (dispatchMessage(connection, decoder))
return;
if (m_webContext->dispatchMessage(connection, decoder))
return;
didReceiveNetworkProcessProxyMessage(connection, decoder);
}
void NetworkProcessProxy::didReceiveSyncMessage(CoreIPC::Connection* connection, CoreIPC::MessageDecoder& decoder, OwnPtr<CoreIPC::MessageEncoder>& replyEncoder)
{
if (dispatchSyncMessage(connection, decoder, replyEncoder))
return;
ASSERT_NOT_REACHED();
}
void NetworkProcessProxy::didClose(CoreIPC::Connection*)
{
if (m_downloadProxyMap)
m_downloadProxyMap->processDidClose();
networkProcessCrashedOrFailedToLaunch();
}
void NetworkProcessProxy::didReceiveInvalidMessage(CoreIPC::Connection*, CoreIPC::StringReference, CoreIPC::StringReference)
{
}
void NetworkProcessProxy::didCreateNetworkConnectionToWebProcess(const CoreIPC::Attachment& connectionIdentifier)
{
ASSERT(!m_pendingConnectionReplies.isEmpty());
RefPtr<Messages::WebProcessProxy::GetNetworkProcessConnection::DelayedReply> reply = m_pendingConnectionReplies.takeFirst();
#if PLATFORM(MAC)
reply->send(CoreIPC::Attachment(connectionIdentifier.port(), MACH_MSG_TYPE_MOVE_SEND));
#else
notImplemented();
#endif
}
void NetworkProcessProxy::didReceiveAuthenticationChallenge(uint64_t pageID, uint64_t frameID, const WebCore::AuthenticationChallenge& coreChallenge, uint64_t challengeID)
{
WebPageProxy* page = WebProcessProxy::webPage(pageID);
MESSAGE_CHECK(page);
RefPtr<AuthenticationChallengeProxy> authenticationChallenge = AuthenticationChallengeProxy::create(coreChallenge, challengeID, connection());
page->didReceiveAuthenticationChallengeProxy(frameID, authenticationChallenge.release());
}
void NetworkProcessProxy::didFinishLaunching(ProcessLauncher* launcher, CoreIPC::Connection::Identifier connectionIdentifier)
{
ChildProcessProxy::didFinishLaunching(launcher, connectionIdentifier);
if (CoreIPC::Connection::identifierIsNull(connectionIdentifier)) {
return;
}
for (unsigned i = 0; i < m_numPendingConnectionRequests; ++i)
connection()->send(Messages::NetworkProcess::CreateNetworkConnectionToWebProcess(), 0);
m_numPendingConnectionRequests = 0;
#if PLATFORM(MAC)
if (m_webContext->canEnableProcessSuppressionForNetworkProcess())
setProcessSuppressionEnabled(true);
#endif
}
}
#endif // ENABLE(NETWORK_PROCESS)