Source/WebKit2/UIProcess/WebConnectionToWebProcess.cpp

   1 /*
   2  * Copyright (C) 2011 Apple Inc. All rights reserved.
   3  *
   4  * Redistribution and use in source and binary forms, with or without
   5  * modification, are permitted provided that the following conditions
   6  * are met:
   7  * 1. Redistributions of source code must retain the above copyright
   8  *    notice, this list of conditions and the following disclaimer.
   9  * 2. Redistributions in binary form must reproduce the above copyright
  10  *    notice, this list of conditions and the following disclaimer in the
  11  *    documentation and/or other materials provided with the distribution.
  12  *
  13  * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS''
  14  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO,
  15  * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
  16  * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS
  17  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  18  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  19  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  20  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  21  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  22  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
  23  * THE POSSIBILITY OF SUCH DAMAGE.
  24  */
  25
  26 #include "config.h"
  27 #include "WebConnectionToWebProcess.h"
  28
  29 #include "WebConnectionMessageKinds.h"
  30 #include "WebContextUserMessageCoders.h"
  31 #include "WebProcessProxy.h"
  32
  33 using namespace WebCore;
  34
  35 namespace WebKit {
  36
  37 PassRefPtr<WebConnectionToWebProcess> WebConnectionToWebProcess::create(WebProcessProxy* process, CoreIPC::Connection::Identifier connectionIdentifier, RunLoop* runLoop)
  38 {
  39     return adoptRef(new WebConnectionToWebProcess(process, connectionIdentifier, runLoop));
  40 }
  41
  42 WebConnectionToWebProcess::WebConnectionToWebProcess(WebProcessProxy* process, CoreIPC::Connection::Identifier connectionIdentifier, RunLoop* runLoop)
  43     : m_process(process)
  44     , m_connection(CoreIPC::Connection::createServerConnection(connectionIdentifier, this, runLoop))
  45 {
  46 #if OS(DARWIN)
  47     m_connection->setShouldCloseConnectionOnMachExceptions();
  48 #elif PLATFORM(QT)
  49     m_connection->setShouldCloseConnectionOnProcessTermination(process->processIdentifier());
  50 #endif
  51 }
  52
  53 void WebConnectionToWebProcess::invalidate()
  54 {
  55     m_connection->invalidate();
  56     m_connection = nullptr;
  57     m_process = 0;
  58 }
  59
  60 // WebConnection
  61
  62 void WebConnectionToWebProcess::postMessage(const String& messageName, APIObject* messageBody)
  63 {
  64     // We need to check if we have an underlying process here since a user of the API can hold
  65     // onto us and call postMessage even after the process has been invalidated.
  66     if (!m_process)
  67         return;
  68
  69     m_process->deprecatedSend(WebConnectionLegacyMessage::PostMessage, 0, CoreIPC::In(messageName, WebContextUserMessageEncoder(messageBody)));
  70 }
  71
  72 // CoreIPC::Connection::Client
  73
  74 void WebConnectionToWebProcess::didReceiveMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::ArgumentDecoder* arguments)
  75 {
  76     if (messageID.is<CoreIPC::MessageClassWebConnectionLegacy>()) {
  77         switch (messageID.get<WebConnectionLegacyMessage::Kind>()) {
  78             case WebConnectionLegacyMessage::PostMessage: {
  79                 String messageName;
  80                 RefPtr<APIObject> messageBody;
  81                 WebContextUserMessageDecoder messageDecoder(messageBody, m_process->context());
  82                 if (!arguments->decode(CoreIPC::Out(messageName, messageDecoder)))
  83                     return;
  84
  85                 forwardDidReceiveMessageToClient(messageName, messageBody.get());
  86                 return;
  87             }
  88         }
  89         return;
  90     }
  91
  92     m_process->didReceiveMessage(connection, messageID, arguments);
  93 }
  94
  95 void WebConnectionToWebProcess::didReceiveSyncMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID, CoreIPC::ArgumentDecoder* arguments, OwnPtr<CoreIPC::ArgumentEncoder>& reply)
  96 {
  97     m_process->didReceiveSyncMessage(connection, messageID, arguments, reply);
  98 }
  99
 100 void WebConnectionToWebProcess::didClose(CoreIPC::Connection* connection)
 101 {
 102     RefPtr<WebConnectionToWebProcess> protector(this);
 103
 104     m_process->didClose(connection);
 105
 106     // Tell the API client that the connection closed.
 107     m_client.didClose(this);
 108 }
 109
 110 void WebConnectionToWebProcess::didReceiveInvalidMessage(CoreIPC::Connection* connection, CoreIPC::MessageID messageID)
 111 {
 112     RefPtr<WebConnectionToWebProcess> protector = this;
 113     RefPtr<WebProcessProxy> process = m_process;
 114
 115     // This will invalidate the CoreIPC::Connection and the WebProcessProxy member
 116     // variables, so we should be careful not to use them after this call.
 117     process->didReceiveInvalidMessage(connection, messageID);
 118
 119     // Since we've invalidated the connection we'll never get a CoreIPC::Connection::Client::didClose
 120     // callback so we'll explicitly call it here instead.
 121     process->didClose(connection);
 122
 123     // Tell the API client that the connection closed.
 124     m_client.didClose(this);
 125 }
 126
 127 void WebConnectionToWebProcess::syncMessageSendTimedOut(CoreIPC::Connection* connection)
 128 {
 129     m_process->syncMessageSendTimedOut(connection);
 130 }
 131
 132 #if PLATFORM(WIN)
 133 Vector<HWND> WebConnectionToWebProcess::windowsToReceiveSentMessagesWhileWaitingForSyncReply()
 134 {
 135     return m_process->windowsToReceiveSentMessagesWhileWaitingForSyncReply();
 136 }
 137 #endif
 138
 139 } // namespace WebKit