summaryrefslogtreecommitdiff
path: root/Source/WebKit2/SharedWorkerProcess/SharedWorkerProcess.cpp
diff options
context:
space:
mode:
authorAllan Sandfeld Jensen <allan.jensen@digia.com>2013-09-13 12:51:20 +0200
committerThe Qt Project <gerrit-noreply@qt-project.org>2013-09-19 20:50:05 +0200
commitd441d6f39bb846989d95bcf5caf387b42414718d (patch)
treee367e64a75991c554930278175d403c072de6bb8 /Source/WebKit2/SharedWorkerProcess/SharedWorkerProcess.cpp
parent0060b2994c07842f4c59de64b5e3e430525c4b90 (diff)
downloadqtwebkit-d441d6f39bb846989d95bcf5caf387b42414718d.tar.gz
Import Qt5x2 branch of QtWebkit for Qt 5.2
Importing a new snapshot of webkit. Change-Id: I2d01ad12cdc8af8cb015387641120a9d7ea5f10c Reviewed-by: Allan Sandfeld Jensen <allan.jensen@digia.com>
Diffstat (limited to 'Source/WebKit2/SharedWorkerProcess/SharedWorkerProcess.cpp')
-rw-r--r--Source/WebKit2/SharedWorkerProcess/SharedWorkerProcess.cpp38
1 files changed, 19 insertions, 19 deletions
diff --git a/Source/WebKit2/SharedWorkerProcess/SharedWorkerProcess.cpp b/Source/WebKit2/SharedWorkerProcess/SharedWorkerProcess.cpp
index c8decb4a2..36ab1076d 100644
--- a/Source/WebKit2/SharedWorkerProcess/SharedWorkerProcess.cpp
+++ b/Source/WebKit2/SharedWorkerProcess/SharedWorkerProcess.cpp
@@ -46,6 +46,7 @@
#include <sys/resource.h>
#include <sys/socket.h>
#include <unistd.h>
+#include <wtf/UniStdExtras.h>
#ifdef SOCK_SEQPACKET
#define SOCKET_TYPE SOCK_SEQPACKET
@@ -77,15 +78,6 @@ SharedWorkerProcess::~SharedWorkerProcess()
{
}
-void SharedWorkerProcess::initialize(CoreIPC::Connection::Identifier serverIdentifier, RunLoop* runLoop)
-{
- ASSERT(!m_connection);
-
- m_connection = CoreIPC::Connection::createClientConnection(serverIdentifier, this, runLoop);
- m_connection->setDidCloseOnConnectionWorkQueueCallback(didCloseOnConnectionWorkQueue);
- m_connection->open();
-}
-
void SharedWorkerProcess::removeWebProcessConnection(WebProcessConnection* webProcessConnection)
{
size_t vectorIndex = m_webProcessConnections.find(webProcessConnection);
@@ -103,9 +95,9 @@ bool SharedWorkerProcess::shouldTerminate()
return true;
}
-void SharedWorkerProcess::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::MessageDecoder& decoder)
+void SharedWorkerProcess::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageDecoder& decoder)
{
- didReceiveSharedWorkerProcessMessage(connection, messageID, decoder);
+ didReceiveSharedWorkerProcessMessage(connection, decoder);
}
void SharedWorkerProcess::didClose(CoreIPC::Connection*)
@@ -122,8 +114,6 @@ void SharedWorkerProcess::initializeSharedWorkerProcess(const SharedWorkerProces
{
setMinimumLifetime(parameters.minimumLifetime);
setTerminationTimeout(parameters.terminationTimeout);
-
- platformInitialize(parameters);
}
void SharedWorkerProcess::createWebProcessConnection()
@@ -138,7 +128,7 @@ void SharedWorkerProcess::createWebProcessConnection()
m_webProcessConnections.append(connection.release());
CoreIPC::Attachment clientPort(listeningPort, MACH_MSG_TYPE_MAKE_SEND);
- m_connection->send(Messages::SharedWorkerProcessProxy::DidCreateWebProcessConnection(clientPort), 0);
+ parentProcessConnection()->send(Messages::SharedWorkerProcessProxy::DidCreateWebProcessConnection(clientPort), 0);
#elif USE(UNIX_DOMAIN_SOCKETS)
int sockets[2];
if (socketpair(AF_UNIX, SOCKET_TYPE, 0, sockets) == -1) {
@@ -150,8 +140,8 @@ void SharedWorkerProcess::createWebProcessConnection()
while (fcntl(sockets[1], F_SETFD, FD_CLOEXEC) == -1) {
if (errno != EINTR) {
ASSERT_NOT_REACHED();
- while (close(sockets[0]) == -1 && errno == EINTR) { }
- while (close(sockets[1]) == -1 && errno == EINTR) { }
+ closeWithRetry(sockets[0]);
+ closeWithRetry(sockets[1]);
return;
}
}
@@ -160,8 +150,8 @@ void SharedWorkerProcess::createWebProcessConnection()
while (fcntl(sockets[0], F_SETFD, FD_CLOEXEC) == -1) {
if (errno != EINTR) {
ASSERT_NOT_REACHED();
- while (close(sockets[0]) == -1 && errno == EINTR) { }
- while (close(sockets[1]) == -1 && errno == EINTR) { }
+ closeWithRetry(sockets[0]);
+ closeWithRetry(sockets[1]);
return;
}
}
@@ -170,7 +160,7 @@ void SharedWorkerProcess::createWebProcessConnection()
m_webProcessConnections.append(connection.release());
CoreIPC::Attachment clientSocket(sockets[0]);
- m_connection->send(Messages::SharedWorkerProcessProxy::DidCreateWebProcessConnection(clientSocket), 0);
+ parentProcessConnection()->send(Messages::SharedWorkerProcessProxy::DidCreateWebProcessConnection(clientSocket), 0);
#else
notImplemented();
#endif
@@ -193,6 +183,16 @@ void SharedWorkerProcess::minimumLifetimeTimerFired()
enableTermination();
}
+#if !PLATFORM(MAC)
+void SharedWorkerProcess::initializeProcess(const ChildProcessInitializationParameters&)
+{
+}
+
+void SharedWorkerProcess::initializeProcessName(const ChildProcessInitializationParameters&)
+{
+}
+#endif
+
} // namespace WebKit
#endif // ENABLE(SHARED_WORKER_PROCESS)