blob: b611b25e0862db597975978df404c8a351274870 [file] [log] [blame]
/*
* Copyright (C) 2010-2019 Apple Inc. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' AND
* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
* WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS BE LIABLE FOR
* ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
* CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#include "config.h"
#include "WebPage.h"
#include "ArgumentCoders.h"
#include "Decoder.h"
#include "HandleMessage.h"
#include "TestClassName.h"
#if ENABLE(TEST_FEATURE)
#include "TestTwoStateEnum.h"
#endif
#include "WebPageMessages.h"
#include <wtf/Optional.h>
#include <wtf/text/WTFString.h>
namespace Messages {
namespace WebPage {
#if ENABLE(TEST_FEATURE)
void TestAsyncMessage::callReply(IPC::Decoder& decoder, CompletionHandler<void(uint64_t&&)>&& completionHandler)
{
Optional<uint64_t> result;
decoder >> result;
if (!result) {
ASSERT_NOT_REACHED();
cancelReply(WTFMove(completionHandler));
return;
}
completionHandler(WTFMove(*result));
}
void TestAsyncMessage::cancelReply(CompletionHandler<void(uint64_t&&)>&& completionHandler)
{
completionHandler(IPC::AsyncReplyError<uint64_t>::create());
}
void TestAsyncMessage::send(std::unique_ptr<IPC::Encoder>&& encoder, IPC::Connection& connection, uint64_t result)
{
*encoder << result;
connection.sendSyncReply(WTFMove(encoder));
}
#endif
#if ENABLE(TEST_FEATURE)
void TestAsyncMessageWithNoArguments::callReply(IPC::Decoder& decoder, CompletionHandler<void()>&& completionHandler)
{
completionHandler();
}
void TestAsyncMessageWithNoArguments::cancelReply(CompletionHandler<void()>&& completionHandler)
{
completionHandler();
}
void TestAsyncMessageWithNoArguments::send(std::unique_ptr<IPC::Encoder>&& encoder, IPC::Connection& connection)
{
connection.sendSyncReply(WTFMove(encoder));
}
#endif
#if ENABLE(TEST_FEATURE)
void TestAsyncMessageWithMultipleArguments::callReply(IPC::Decoder& decoder, CompletionHandler<void(bool&&, uint64_t&&)>&& completionHandler)
{
Optional<bool> flag;
decoder >> flag;
if (!flag) {
ASSERT_NOT_REACHED();
cancelReply(WTFMove(completionHandler));
return;
}
Optional<uint64_t> value;
decoder >> value;
if (!value) {
ASSERT_NOT_REACHED();
cancelReply(WTFMove(completionHandler));
return;
}
completionHandler(WTFMove(*flag), WTFMove(*value));
}
void TestAsyncMessageWithMultipleArguments::cancelReply(CompletionHandler<void(bool&&, uint64_t&&)>&& completionHandler)
{
completionHandler(IPC::AsyncReplyError<bool>::create(), IPC::AsyncReplyError<uint64_t>::create());
}
void TestAsyncMessageWithMultipleArguments::send(std::unique_ptr<IPC::Encoder>&& encoder, IPC::Connection& connection, bool flag, uint64_t value)
{
*encoder << flag;
*encoder << value;
connection.sendSyncReply(WTFMove(encoder));
}
#endif
void TestSyncMessage::send(std::unique_ptr<IPC::Encoder>&& encoder, IPC::Connection& connection, uint8_t reply)
{
*encoder << reply;
connection.sendSyncReply(WTFMove(encoder));
}
void TestSynchronousMessage::send(std::unique_ptr<IPC::Encoder>&& encoder, IPC::Connection& connection, const Optional<WebKit::TestClassName>& optionalReply)
{
*encoder << optionalReply;
connection.sendSyncReply(WTFMove(encoder));
}
} // namespace WebPage
} // namespace Messages
namespace WebKit {
void WebPage::didReceiveMessage(IPC::Connection& connection, IPC::Decoder& decoder)
{
if (decoder.messageName() == Messages::WebPage::LoadURL::name()) {
IPC::handleMessage<Messages::WebPage::LoadURL>(decoder, this, &WebPage::loadURL);
return;
}
#if ENABLE(TEST_FEATURE)
if (decoder.messageName() == Messages::WebPage::TestAsyncMessage::name()) {
IPC::handleMessageAsync<Messages::WebPage::TestAsyncMessage>(connection, decoder, this, &WebPage::testAsyncMessage);
return;
}
#endif
#if ENABLE(TEST_FEATURE)
if (decoder.messageName() == Messages::WebPage::TestAsyncMessageWithNoArguments::name()) {
IPC::handleMessageAsync<Messages::WebPage::TestAsyncMessageWithNoArguments>(connection, decoder, this, &WebPage::testAsyncMessageWithNoArguments);
return;
}
#endif
#if ENABLE(TEST_FEATURE)
if (decoder.messageName() == Messages::WebPage::TestAsyncMessageWithMultipleArguments::name()) {
IPC::handleMessageAsync<Messages::WebPage::TestAsyncMessageWithMultipleArguments>(connection, decoder, this, &WebPage::testAsyncMessageWithMultipleArguments);
return;
}
#endif
WebPageBase::didReceiveMessage(connection, decoder);
}
void WebPage::didReceiveSyncMessage(IPC::Connection& connection, IPC::Decoder& decoder, std::unique_ptr<IPC::Encoder>& replyEncoder)
{
if (decoder.messageName() == Messages::WebPage::TestSyncMessage::name()) {
IPC::handleMessageSynchronous<Messages::WebPage::TestSyncMessage>(connection, decoder, replyEncoder, this, &WebPage::testSyncMessage);
return;
}
if (decoder.messageName() == Messages::WebPage::TestSynchronousMessage::name()) {
IPC::handleMessageSynchronous<Messages::WebPage::TestSynchronousMessage>(connection, decoder, replyEncoder, this, &WebPage::testSynchronousMessage);
return;
}
UNUSED_PARAM(connection);
UNUSED_PARAM(decoder);
UNUSED_PARAM(replyEncoder);
ASSERT_NOT_REACHED();
}
} // namespace WebKit