Attachment #398362 for bug #211290

View Details Raw Unified Return to Bug 211290

| Differences between



2020-05-01  Youenn Fablet  <youenn@apple.com>

        Receiving WebRTC network packets should not go through the main thread
        https://bugs.webkit.org/show_bug.cgi?id=211290

        Reviewed by NOBODY (OOPS!).

        Instead of going to main thread before going to rtc network thread, we register a message receiver and dispatch directly to rtc network thread.
        This ensures rtc packets are not blocked if main thread is busy.

        * DerivedSources-input.xcfilelist:
        * DerivedSources-output.xcfilelist:
        * DerivedSources.make:
        * NetworkProcess/webrtc/LibWebRTCSocketClient.cpp:
        (WebKit::LibWebRTCSocketClient::signalReadPacket):
        (WebKit::LibWebRTCSocketClient::signalSentPacket):
        (WebKit::LibWebRTCSocketClient::signalAddressReady):
        (WebKit::LibWebRTCSocketClient::signalConnect):
        (WebKit::LibWebRTCSocketClient::signalClose):
        * NetworkProcess/webrtc/NetworkRTCProvider.cpp:
        (WebKit::NetworkRTCProvider::createSocket):
        (WebKit::NetworkRTCProvider::createServerTCPSocket):
        (WebKit::NetworkRTCProvider::createClientTCPSocket):
        (WebKit::NetworkRTCProvider::newConnection):
        (WebKit::NetworkRTCProvider::closeListeningSockets):
        * Sources.txt:
        * WebKit.xcodeproj/project.pbxproj:
        * WebProcess/Network/NetworkProcessConnection.cpp:
        (WebKit::NetworkProcessConnection::NetworkProcessConnection):
        (WebKit::NetworkProcessConnection::didReceiveMessage):
        * WebProcess/Network/webrtc/LibWebRTCNetwork.cpp: Added
        * WebProcess/Network/webrtc/LibWebRTCNetwork.h:
        (WebKit::LibWebRTCNetwork::connection):
        (WebKit::LibWebRTCNetwork::~LibWebRTCNetwork):
        (WebKit::LibWebRTCNetwork::networkProcessCrashed):
        (WebKit::LibWebRTCNetwork::setConnection):
        (WebKit::LibWebRTCNetwork::dispatchToThread):
        (WebKit::LibWebRTCNetwork::signalAddressReady):
        (WebKit::LibWebRTCNetwork::signalReadPacket):
        (WebKit::LibWebRTCNetwork::signalSentPacket):
        (WebKit::LibWebRTCNetwork::signalConnect):
        (WebKit::LibWebRTCNetwork::signalClose):
        (WebKit::LibWebRTCNetwork::signalNewConnection):
        * WebProcess/Network/webrtc/LibWebRTCNetwork.messages.in: Added.
        * WebProcess/Network/webrtc/LibWebRTCSocket.h:
        * WebProcess/Network/webrtc/LibWebRTCSocketFactory.cpp:
        * WebProcess/Network/webrtc/WebRTCSocket.cpp: Removed.
        * WebProcess/Network/webrtc/WebRTCSocket.h: Removed.

2020-05-01  Carlos Garcia Campos  <cgarcia@igalia.com>

        [GTK] Move focus out of the web view when tab is pressed and there isn't a next element to focus



    WebProcess/Inspector/WebInspectorInterruptDispatcher.messages.in
    WebProcess/Inspector/WebInspectorUI.messages.in

    WebProcess/Network/webrtc/LibWebRTCNetwork.messages.in
    WebProcess/Network/webrtc/WebMDNSRegister.messages.in
    WebProcess/Network/webrtc/WebRTCMonitor.messages.in
    WebProcess/Network/webrtc/WebRTCResolver.messages.in
    WebProcess/Network/webrtc/WebRTCSocket.messages.in

    WebProcess/Network/NetworkProcessConnection.messages.in
    WebProcess/Network/WebResourceLoader.messages.in



$(PROJECT_DIR)/WebProcess/Network/WebResourceLoader.messages.in
$(PROJECT_DIR)/WebProcess/Network/WebSocketChannel.messages.in
$(PROJECT_DIR)/WebProcess/Network/WebSocketStream.messages.in
$(PROJECT_DIR)/WebProcess/Network/webrtc/LibWebRTCNetwork.messages.in
$(PROJECT_DIR)/WebProcess/Network/webrtc/WebMDNSRegister.messages.in
$(PROJECT_DIR)/WebProcess/Network/webrtc/WebRTCMonitor.messages.in
$(PROJECT_DIR)/WebProcess/Network/webrtc/WebRTCResolver.messages.in
$(PROJECT_DIR)/WebProcess/Network/webrtc/WebRTCSocket.messages.in
$(PROJECT_DIR)/WebProcess/Notifications/WebNotificationManager.messages.in
$(PROJECT_DIR)/WebProcess/Plugins/PluginProcessConnection.messages.in
$(PROJECT_DIR)/WebProcess/Plugins/PluginProcessConnectionManager.messages.in



    LegacyCustomProtocolManagerProxy \
    LibWebRTCCodecs \
    LibWebRTCCodecsProxy \
    LibWebRTCNetwork \
    MediaPlayerPrivateRemote \
    NPObjectMessageReceiver \
    NetworkConnectionToWebProcess \

    WebProcessProxy \
    WebRTCMonitor \
    WebRTCResolver \
    WebRTCSocket \
    WebResourceLoader \
    WebSWClientConnection \
    WebSWContextManagerConnection \




#include "Connection.h"
#include "DataReference.h"
#include "LibWebRTCNetworkMessages.h"
#include "Logging.h"
#include "NetworkRTCProvider.h"
#include "WebRTCSocketMessages.h"
#include <WebCore/SharedBuffer.h>
#include <wtf/Function.h>


    auto buffer = WebCore::SharedBuffer::create(value, length);
    m_rtcProvider.sendFromMainThread([identifier = m_identifier, buffer = WTFMove(buffer), address = RTCNetwork::isolatedCopy(address), packetTime](IPC::Connection& connection) {
        IPC::DataReference data(reinterpret_cast<const uint8_t*>(buffer->data()), buffer->size());
        connection.send(Messages::LibWebRTCNetwork::SignalReadPacket(identifier, data, RTCNetwork::IPAddress(address.ipaddr()), address.port(), packetTime), 0);
    });
}


{
    ASSERT_UNUSED(socket, m_socket.get() == socket);
    m_rtcProvider.sendFromMainThread([identifier = m_identifier, sentPacket](IPC::Connection& connection) {
        connection.send(Messages::LibWebRTCNetwork::SignalSentPacket(identifier, sentPacket.packet_id, sentPacket.send_time_ms), 0);
    });
}


{
    ASSERT_UNUSED(socket, m_socket.get() == socket);
    m_rtcProvider.sendFromMainThread([identifier = m_identifier, address = RTCNetwork::isolatedCopy(address)](IPC::Connection& connection) {
        connection.send(Messages::LibWebRTCNetwork::SignalAddressReady(identifier, RTCNetwork::SocketAddress(address)), 0);
    });
}


{
    ASSERT_UNUSED(socket, m_socket.get() == socket);
    m_rtcProvider.sendFromMainThread([identifier = m_identifier](IPC::Connection& connection) {
        connection.send(Messages::LibWebRTCNetwork::SignalConnect(identifier), 0);
    });
}


{
    ASSERT_UNUSED(socket, m_socket.get() == socket);
    m_rtcProvider.sendFromMainThread([identifier = m_identifier, error](IPC::Connection& connection) {
        connection.send(Messages::LibWebRTCNetwork::SignalClose(identifier, error), 0);
    });
    // We want to remove 'this' from the socket map now but we will destroy it asynchronously
    // so that the socket parameter of signalClose remains alive as the caller of signalClose may actually being using it afterwards.




#if USE(LIBWEBRTC)

#include "LibWebRTCNetworkMessages.h"
#include "LibWebRTCSocketClient.h"
#include "Logging.h"
#include "NetworkConnectionToWebProcess.h"

#include "NetworkRTCResolver.h"
#include "NetworkRTCSocket.h"
#include "WebRTCResolverMessages.h"
#include "WebRTCSocketMessages.h"
#include <WebCore/LibWebRTCMacros.h>
#include <webrtc/rtc_base/async_packet_socket.h>
#include <webrtc/rtc_base/logging.h>

    if (!socket) {
        sendFromMainThread([this, identifier, size = m_sockets.size()](IPC::Connection& connection) {
            RELEASE_LOG_ERROR_IF_ALLOWED("createSocket with %u sockets is unable to create a new socket", size);
            connection.send(Messages::LibWebRTCNetwork::SignalClose(identifier, 1), 0);
        });
        return;
    }

{
    if (!m_isListeningSocketAuthorized) {
        if (m_connection)
            m_connection->connection().send(Messages::LibWebRTCNetwork::SignalClose(identifier, 1), 0);
        return;
    }


{
    auto* session = m_connection->networkSession();
    if (!session) {
        m_connection->connection().send(Messages::LibWebRTCNetwork::SignalClose(identifier, 1), 0);
        return;
    }
    callOnRTCNetworkThread([this, identifier, localAddress = RTCNetwork::isolatedCopy(localAddress.value), remoteAddress = RTCNetwork::isolatedCopy(remoteAddress.value), proxyInfo = proxyInfoFromSession(remoteAddress, *session), userAgent = WTFMove(userAgent).isolatedCopy(), options]() {

{
    auto incomingSocketIdentifier = LibWebRTCSocketIdentifier::generate();
    sendFromMainThread([identifier = serverSocket.identifier(), incomingSocketIdentifier, remoteAddress = RTCNetwork::isolatedCopy(newSocket->GetRemoteAddress())](IPC::Connection& connection) {
        connection.send(Messages::LibWebRTCNetwork::SignalNewConnection(identifier, incomingSocketIdentifier, RTCNetwork::SocketAddress(remoteAddress)), 0);
    });
    m_pendingIncomingSockets.add(incomingSocketIdentifier, WTFMove(newSocket));
}

        callOnMainThread([provider = makeRef(*this), listeningSocketIdentifiers = WTFMove(listeningSocketIdentifiers), completionHandler = WTFMove(completionHandler)] {
            if (provider->m_connection) {
                for (auto identifier : listeningSocketIdentifiers)
                    provider->m_connection->connection().send(Messages::LibWebRTCNetwork::SignalClose(identifier, ECONNABORTED), 0);
            }
            completionHandler();
        });



WebProcess/Network/WebSocketProvider.cpp
WebProcess/Network/WebSocketStream.cpp

WebProcess/Network/webrtc/LibWebRTCNetwork.cpp
WebProcess/Network/webrtc/LibWebRTCProvider.cpp
WebProcess/Network/webrtc/LibWebRTCResolver.cpp
WebProcess/Network/webrtc/LibWebRTCSocket.cpp

WebProcess/Network/webrtc/WebMDNSRegister.cpp
WebProcess/Network/webrtc/WebRTCMonitor.cpp
WebProcess/Network/webrtc/WebRTCResolver.cpp
WebProcess/Network/webrtc/WebRTCSocket.cpp

WebProcess/Notifications/NotificationPermissionRequestManager.cpp
WebProcess/Notifications/WebNotificationManager.cpp



#include "WebRTCMonitor.h"
#include "WebRTCMonitorMessages.h"
#include "WebRTCResolverMessages.h"
#include "WebRTCSocketMessages.h"
#include "WebResourceLoaderMessages.h"
#include "WebSWClientConnection.h"
#include "WebSWClientConnectionMessages.h"

    , m_cookieAcceptPolicy(cookieAcceptPolicy)
{
    m_connection->open();
    WebProcess::singleton().libWebRTCNetwork().setConnection(m_connection.copyRef());
}

NetworkProcessConnection::~NetworkProcessConnection()

    }

#if USE(LIBWEBRTC)
    if (decoder.messageReceiverName() == Messages::WebRTCSocket::messageReceiverName()) {
        auto& network = WebProcess::singleton().libWebRTCNetwork();
        if (network.isActive())
            network.socket(makeObjectIdentifier<LibWebRTCSocketIdentifierType>(decoder.destinationID())).didReceiveMessage(connection, decoder);
        else
            RELEASE_LOG_ERROR(WebRTC, "Received WebRTCSocket message while libWebRTCNetwork is not active");
        return;
    }
    if (decoder.messageReceiverName() == Messages::WebRTCMonitor::messageReceiverName()) {
        auto& network = WebProcess::singleton().libWebRTCNetwork();
        if (network.isActive())



/*
 * Copyright (C) 2020 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 "LibWebRTCNetwork.h"

#include "DataReference.h"
#include "LibWebRTCNetworkMessages.h"
#include "Logging.h"
#include <WebCore/SharedBuffer.h>

namespace WebKit {

LibWebRTCNetwork::~LibWebRTCNetwork()
{
    setConnection(nullptr);
}

void LibWebRTCNetwork::networkProcessCrashed()
{
    setConnection(nullptr);

#if USE(LIBWEBRTC)
    m_webNetworkMonitor.networkProcessCrashed();
#endif
}

void LibWebRTCNetwork::setConnection(RefPtr<IPC::Connection>&& connection)
{
#if USE(LIBWEBRTC)
    if (m_connection)
        m_connection->removeThreadMessageReceiver(Messages::LibWebRTCNetwork::messageReceiverName());
#endif
    m_connection = WTFMove(connection);
#if USE(LIBWEBRTC)
    if (m_connection)
        m_connection->addThreadMessageReceiver(Messages::LibWebRTCNetwork::messageReceiverName(), this);
#endif
}

bool LibWebRTCNetwork::isActive() const
{
#if USE(LIBWEBRTC)
    return WebCore::LibWebRTCProvider::hasWebRTCThreads();
#else
    return false;
#endif
}

void LibWebRTCNetwork::dispatchToThread(Function<void()>&& callback)
{
    if (!isActive()) {
        RELEASE_LOG_ERROR(WebRTC, "Received WebRTCSocket message while libWebRTCNetwork is not active");
        return;
    }

#if USE(LIBWEBRTC)
    WebCore::LibWebRTCProvider::callOnWebRTCNetworkThread(WTFMove(callback));
#else
    UNUSED_PARAM(callback);
#endif
}

#if USE(LIBWEBRTC)
void LibWebRTCNetwork::signalAddressReady(WebCore::LibWebRTCSocketIdentifier identifier, const RTCNetwork::SocketAddress& address)
{
    if (auto* socket = m_socketFactory.socket(identifier))
        socket->signalAddressReady(address.value);
}

void LibWebRTCNetwork::signalReadPacket(WebCore::LibWebRTCSocketIdentifier identifier, const IPC::DataReference& data, const RTCNetwork::IPAddress& address, uint16_t port, int64_t timestamp)
{
    if (auto* socket = m_socketFactory.socket(identifier))
        socket->signalReadPacket(data.data(), data.size(), rtc::SocketAddress(address.value, port), timestamp);
}

void LibWebRTCNetwork::signalSentPacket(WebCore::LibWebRTCSocketIdentifier identifier, int rtcPacketID, int64_t sendTimeMs)
{
    if (auto* socket = m_socketFactory.socket(identifier))
        socket->signalSentPacket(rtcPacketID, sendTimeMs);
}

void LibWebRTCNetwork::signalConnect(WebCore::LibWebRTCSocketIdentifier identifier)
{
    if (auto* socket = m_socketFactory.socket(identifier))
        socket->signalConnect();
}

void LibWebRTCNetwork::signalClose(WebCore::LibWebRTCSocketIdentifier identifier, int error)
{
    if (auto* socket = m_socketFactory.socket(identifier))
        socket->signalClose(error);
}

void LibWebRTCNetwork::signalNewConnection(WebCore::LibWebRTCSocketIdentifier identifier, WebCore::LibWebRTCSocketIdentifier newSocketIdentifier, const RTCNetwork::SocketAddress& remoteAddress)
{
    if (auto* socket = m_socketFactory.socket(identifier))
        socket->signalNewConnection(m_socketFactory.createNewConnectionSocket(*socket, newSocketIdentifier, remoteAddress.value));
}
#endif

} // namespace WebKit




#pragma once

#include "Connection.h"
#include "LibWebRTCProvider.h"
#include "LibWebRTCSocketFactory.h"
#include "WebMDNSRegister.h"
#include "WebRTCMonitor.h"
#include "WebRTCResolver.h"
#include "WebRTCSocket.h"
#endif

#include "WebMDNSRegister.h"
#include <WebCore/LibWebRTCSocketIdentifier.h>

namespace WebKit {

class LibWebRTCNetwork : public IPC::Connection::ThreadMessageReceiver {
    WTF_MAKE_FAST_ALLOCATED;
public:
    LibWebRTCNetwork() = default;
    ~LibWebRTCNetwork();

    void setConnection(RefPtr<IPC::Connection>&&);
    void networkProcessCrashed();

    bool isActive() const;

    void didReceiveMessage(IPC::Connection&, IPC::Decoder&);

#if USE(LIBWEBRTC)
    WebRTCMonitor& monitor() { return m_webNetworkMonitor; }
    LibWebRTCSocketFactory& socketFactory() { return m_socketFactory; }

    void disableNonLocalhostConnections() { socketFactory().disableNonLocalhostConnections(); }

    WebRTCSocket socket(WebCore::LibWebRTCSocketIdentifier identifier) { return WebRTCSocket(socketFactory(), identifier); }
    WebRTCResolver resolver(LibWebRTCResolverIdentifier identifier) { return WebRTCResolver(socketFactory(), identifier); }
#endif


#endif

private:
#if USE(LIBWEBRTC)
    void signalReadPacket(WebCore::LibWebRTCSocketIdentifier, const IPC::DataReference&, const RTCNetwork::IPAddress&, uint16_t port, int64_t);
    void signalSentPacket(WebCore::LibWebRTCSocketIdentifier, int, int64_t);
    void signalAddressReady(WebCore::LibWebRTCSocketIdentifier, const RTCNetwork::SocketAddress&);
    void signalConnect(WebCore::LibWebRTCSocketIdentifier);
    void signalClose(WebCore::LibWebRTCSocketIdentifier, int);
    void signalNewConnection(WebCore::LibWebRTCSocketIdentifier socketIdentifier, WebCore::LibWebRTCSocketIdentifier newSocketIdentifier, const WebKit::RTCNetwork::SocketAddress&);
#endif

    // IPC::Connection::ThreadMessageReceiver
    void dispatchToThread(Function<void()>&&) final;

#if USE(LIBWEBRTC)
    LibWebRTCSocketFactory m_socketFactory;
    WebRTCMonitor m_webNetworkMonitor;

#if ENABLE(WEB_RTC)
    WebMDNSRegister m_mdnsRegister;
#endif
    RefPtr<IPC::Connection> m_connection;
};

inline void LibWebRTCNetwork::networkProcessCrashed()
{
#if USE(LIBWEBRTC)
    m_webNetworkMonitor.networkProcessCrashed();
#endif
}

inline bool LibWebRTCNetwork::isActive() const
{
#if USE(LIBWEBRTC)
    return WebCore::LibWebRTCProvider::hasWebRTCThreads();
#else
    return false;
#endif
}

} // namespace WebKit



# Copyright (C) 2017 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.

#if USE(LIBWEBRTC)

messages -> LibWebRTCNetwork NotRefCounted {
    SignalReadPacket(WebCore::LibWebRTCSocketIdentifier socketIdentifier, IPC::DataReference data, WebKit::RTCNetwork::IPAddress address, uint16_t port, int64_t timestamp)
    SignalSentPacket(WebCore::LibWebRTCSocketIdentifier socketIdentifier, int packetSize, int64_t timestamp)
    SignalAddressReady(WebCore::LibWebRTCSocketIdentifier socketIdentifier, WebKit::RTCNetwork::SocketAddress address)
    SignalConnect(WebCore::LibWebRTCSocketIdentifier socketIdentifier)
    SignalClose(WebCore::LibWebRTCSocketIdentifier socketIdentifier, int error)
    SignalNewConnection(WebCore::LibWebRTCSocketIdentifier socketIdentifier, WebCore::LibWebRTCSocketIdentifier newSocketIdentifier, WebKit::RTCNetwork::SocketAddress remoteAddress)
}

#endif // USE(LIBWEBRTC)



    SignalAddressReady(this, m_localAddress);
}

void LibWebRTCSocket::signalReadPacket(const uint8_t* data, size_t size, rtc::SocketAddress&& address, int64_t timestamp)
{
    if (m_isSuspended)
        return;

    m_remoteAddress = WTFMove(address);
    SignalReadPacket(this, reinterpret_cast<const char*>(data), size, m_remoteAddress, timestamp);
}

void LibWebRTCSocket::signalSentPacket(int rtcPacketID, int64_t sendTimeMs)



class Decoder;
}

namespace WebCore {
class SharedBuffer;
}

namespace WebKit {

class LibWebRTCSocketFactory;

private:
    bool willSend(size_t);

    friend class LibWebRTCNetwork;
    void signalReadPacket(const uint8_t*, size_t, rtc::SocketAddress&&, int64_t);
    void signalSentPacket(int, int64_t);
    void signalAddressReady(const rtc::SocketAddress&);
    void signalConnect();

Lines 32-38 a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCSocketFactory.cpp_sec1
- a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCSocketFactory.cpp -1 lines
32	#include "NetworkRTCMonitorMessages.h"	32	#include "NetworkRTCMonitorMessages.h"
33	#include "NetworkRTCProviderMessages.h"	33	#include "NetworkRTCProviderMessages.h"
34	#include "WebProcess.h"	34	#include "WebProcess.h"
35	#include "WebRTCSocket.h"
36	#include <wtf/MainThread.h>	35	#include <wtf/MainThread.h>
37		36
38	namespace WebKit {	37	namespace WebKit {



/*
 * Copyright (C) 2017 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 "WebRTCSocket.h"

#if USE(LIBWEBRTC)

#include "DataReference.h"
#include "LibWebRTCSocket.h"
#include "LibWebRTCSocketFactory.h"
#include "NetworkRTCSocketMessages.h"
#include <WebCore/SharedBuffer.h>
#include <wtf/Function.h>

namespace WebKit {
using namespace WebCore;

void WebRTCSocket::signalOnNetworkThread(LibWebRTCSocketFactory& factory, LibWebRTCSocketIdentifier identifier, Function<void(LibWebRTCSocket&)>&& callback)
{
    // factory is staying valid during the process lifetime.
    WebCore::LibWebRTCProvider::callOnWebRTCNetworkThread([&factory, identifier, callback = WTFMove(callback)]() {
        auto* socket = factory.socket(identifier);
        if (!socket)
            return;
        callback(*socket);
    });
}

WebRTCSocket::WebRTCSocket(LibWebRTCSocketFactory& factory, LibWebRTCSocketIdentifier identifier)
    : m_factory(factory)
    , m_identifier(identifier)
{
}

void WebRTCSocket::signalAddressReady(const RTCNetwork::SocketAddress& address)
{
    signalOnNetworkThread(m_factory, m_identifier, [address](LibWebRTCSocket& socket) {
        socket.signalAddressReady(address.value);
    });
}

void WebRTCSocket::signalReadPacket(const IPC::DataReference& data, const RTCNetwork::IPAddress& address, uint16_t port, int64_t timestamp)
{
    auto buffer = WebCore::SharedBuffer::create(data.data(), data.size());
    signalOnNetworkThread(m_factory, m_identifier, [buffer = WTFMove(buffer), address, port, timestamp](LibWebRTCSocket& socket) {
        socket.signalReadPacket(buffer.get(), rtc::SocketAddress(address.value, port), timestamp);
    });
}

void WebRTCSocket::signalSentPacket(int rtcPacketID, int64_t sendTimeMs)
{
    signalOnNetworkThread(m_factory, m_identifier, [rtcPacketID, sendTimeMs](auto& socket) {
        socket.signalSentPacket(rtcPacketID, sendTimeMs);
    });
}

void WebRTCSocket::signalConnect()
{
    signalOnNetworkThread(m_factory, m_identifier, [](auto& socket) {
        socket.signalConnect();
    });
}

void WebRTCSocket::signalClose(int error)
{
    signalOnNetworkThread(m_factory, m_identifier, [error](auto& socket) {
        socket.signalClose(error);
    });
}

void WebRTCSocket::signalNewConnection(LibWebRTCSocketIdentifier newSocketIdentifier, const RTCNetwork::SocketAddress& remoteAddress)
{
    signalOnNetworkThread(m_factory, m_identifier, [newSocketIdentifier, remoteAddress = RTCNetwork::isolatedCopy(remoteAddress.value)](auto& socket) {
        socket.signalNewConnection(socket.m_factory.createNewConnectionSocket(socket, newSocketIdentifier, remoteAddress));
    });
}

} // namespace WebKit

#endif // USE(LIBWEBRTC)



/*
 * Copyright (C) 2017 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.
 */

#pragma once

#if USE(LIBWEBRTC)

#include "RTCNetwork.h"
#include <WebCore/LibWebRTCSocketIdentifier.h>
#include <wtf/Function.h>

namespace IPC {
class Connection;
class DataReference;
class Decoder;
}

namespace WebKit {

class LibWebRTCSocket;
class LibWebRTCSocketFactory;

class WebRTCSocket {
public:
    WebRTCSocket(LibWebRTCSocketFactory&, WebCore::LibWebRTCSocketIdentifier);

    void didReceiveMessage(IPC::Connection&, IPC::Decoder&);

    static void signalOnNetworkThread(LibWebRTCSocketFactory&, WebCore::LibWebRTCSocketIdentifier, Function<void(LibWebRTCSocket&)>&&);

private:
    void signalReadPacket(const IPC::DataReference&, const RTCNetwork::IPAddress&, uint16_t port, int64_t);
    void signalSentPacket(int, int64_t);
    void signalAddressReady(const RTCNetwork::SocketAddress&);
    void signalConnect();
    void signalClose(int);
    void signalNewConnection(WebCore::LibWebRTCSocketIdentifier newSocketIdentifier, const WebKit::RTCNetwork::SocketAddress&);

    LibWebRTCSocketFactory& m_factory;
    WebCore::LibWebRTCSocketIdentifier m_identifier;
};

} // namespace WebKit

#endif // USE(LIBWEBRTC)



# Copyright (C) 2017 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.

#if USE(LIBWEBRTC)

messages -> WebRTCSocket NotRefCounted {
    SignalReadPacket(IPC::DataReference data, WebKit::RTCNetwork::IPAddress address, uint16_t port, int64_t timestamp)
    SignalSentPacket(int packetSize, int64_t timestamp)
    SignalAddressReady(WebKit::RTCNetwork::SocketAddress address)
    SignalConnect()
    SignalClose(int error)
    SignalNewConnection(WebCore::LibWebRTCSocketIdentifier newSocketIdentifier, WebKit::RTCNetwork::SocketAddress remoteAddress)
}

#endif // USE(LIBWEBRTC)

Return to Bug 211290

Lines 234-243 set(WebKit_MESSAGES_IN_FILES a/Source/WebKit/CMakeLists.txt_sec1
- a/Source/WebKit/CMakeLists.txt -1 / +1 lines
234	WebProcess/Inspector/WebInspectorInterruptDispatcher.messages.in	234	WebProcess/Inspector/WebInspectorInterruptDispatcher.messages.in
235	WebProcess/Inspector/WebInspectorUI.messages.in	235	WebProcess/Inspector/WebInspectorUI.messages.in
236		236
		237	WebProcess/Network/webrtc/LibWebRTCNetwork.messages.in
237	WebProcess/Network/webrtc/WebMDNSRegister.messages.in	238	WebProcess/Network/webrtc/WebMDNSRegister.messages.in
238	WebProcess/Network/webrtc/WebRTCMonitor.messages.in	239	WebProcess/Network/webrtc/WebRTCMonitor.messages.in
239	WebProcess/Network/webrtc/WebRTCResolver.messages.in	240	WebProcess/Network/webrtc/WebRTCResolver.messages.in
240	WebProcess/Network/webrtc/WebRTCSocket.messages.in
241		241
242	WebProcess/Network/NetworkProcessConnection.messages.in	242	WebProcess/Network/NetworkProcessConnection.messages.in
243	WebProcess/Network/WebResourceLoader.messages.in	243	WebProcess/Network/WebResourceLoader.messages.in

Lines 140-149 $(PROJECT_DIR)/WebProcess/Network/NetworkProcessConnection.messages.in a/Source/WebKit/DerivedSources-input.xcfilelist_sec1
- a/Source/WebKit/DerivedSources-input.xcfilelist -1 / +1 lines
140	$(PROJECT_DIR)/WebProcess/Network/WebResourceLoader.messages.in	140	$(PROJECT_DIR)/WebProcess/Network/WebResourceLoader.messages.in
141	$(PROJECT_DIR)/WebProcess/Network/WebSocketChannel.messages.in	141	$(PROJECT_DIR)/WebProcess/Network/WebSocketChannel.messages.in
142	$(PROJECT_DIR)/WebProcess/Network/WebSocketStream.messages.in	142	$(PROJECT_DIR)/WebProcess/Network/WebSocketStream.messages.in
		143	$(PROJECT_DIR)/WebProcess/Network/webrtc/LibWebRTCNetwork.messages.in
143	$(PROJECT_DIR)/WebProcess/Network/webrtc/WebMDNSRegister.messages.in	144	$(PROJECT_DIR)/WebProcess/Network/webrtc/WebMDNSRegister.messages.in
144	$(PROJECT_DIR)/WebProcess/Network/webrtc/WebRTCMonitor.messages.in	145	$(PROJECT_DIR)/WebProcess/Network/webrtc/WebRTCMonitor.messages.in
145	$(PROJECT_DIR)/WebProcess/Network/webrtc/WebRTCResolver.messages.in	146	$(PROJECT_DIR)/WebProcess/Network/webrtc/WebRTCResolver.messages.in
146	$(PROJECT_DIR)/WebProcess/Network/webrtc/WebRTCSocket.messages.in
147	$(PROJECT_DIR)/WebProcess/Notifications/WebNotificationManager.messages.in	147	$(PROJECT_DIR)/WebProcess/Notifications/WebNotificationManager.messages.in
148	$(PROJECT_DIR)/WebProcess/Plugins/PluginProcessConnection.messages.in	148	$(PROJECT_DIR)/WebProcess/Plugins/PluginProcessConnection.messages.in
149	$(PROJECT_DIR)/WebProcess/Plugins/PluginProcessConnectionManager.messages.in	149	$(PROJECT_DIR)/WebProcess/Plugins/PluginProcessConnectionManager.messages.in

Lines 1-3 a/Source/WebKit/ChangeLog_sec1
- a/Source/WebKit/ChangeLog +49 lines
		1	2020-05-01 Youenn Fablet <youenn@apple.com>
		2
		3	Receiving WebRTC network packets should not go through the main thread
		4	https://bugs.webkit.org/show_bug.cgi?id=211290
		5
		6	Reviewed by NOBODY (OOPS!).
		7
		8	Instead of going to main thread before going to rtc network thread, we register a message receiver and dispatch directly to rtc network thread.
		9	This ensures rtc packets are not blocked if main thread is busy.
		10
		11	* DerivedSources-input.xcfilelist:
		12	* DerivedSources-output.xcfilelist:
		13	* DerivedSources.make:
		14	* NetworkProcess/webrtc/LibWebRTCSocketClient.cpp:
		15	(WebKit::LibWebRTCSocketClient::signalReadPacket):
		16	(WebKit::LibWebRTCSocketClient::signalSentPacket):
		17	(WebKit::LibWebRTCSocketClient::signalAddressReady):
		18	(WebKit::LibWebRTCSocketClient::signalConnect):
		19	(WebKit::LibWebRTCSocketClient::signalClose):
		20	* NetworkProcess/webrtc/NetworkRTCProvider.cpp:
		21	(WebKit::NetworkRTCProvider::createSocket):
		22	(WebKit::NetworkRTCProvider::createServerTCPSocket):
		23	(WebKit::NetworkRTCProvider::createClientTCPSocket):
		24	(WebKit::NetworkRTCProvider::newConnection):
		25	(WebKit::NetworkRTCProvider::closeListeningSockets):
		26	* Sources.txt:
		27	* WebKit.xcodeproj/project.pbxproj:
		28	* WebProcess/Network/NetworkProcessConnection.cpp:
		29	(WebKit::NetworkProcessConnection::NetworkProcessConnection):
		30	(WebKit::NetworkProcessConnection::didReceiveMessage):
		31	* WebProcess/Network/webrtc/LibWebRTCNetwork.cpp: Added
		32	* WebProcess/Network/webrtc/LibWebRTCNetwork.h:
		33	(WebKit::LibWebRTCNetwork::connection):
		34	(WebKit::LibWebRTCNetwork::~LibWebRTCNetwork):
		35	(WebKit::LibWebRTCNetwork::networkProcessCrashed):
		36	(WebKit::LibWebRTCNetwork::setConnection):
		37	(WebKit::LibWebRTCNetwork::dispatchToThread):
		38	(WebKit::LibWebRTCNetwork::signalAddressReady):
		39	(WebKit::LibWebRTCNetwork::signalReadPacket):
		40	(WebKit::LibWebRTCNetwork::signalSentPacket):
		41	(WebKit::LibWebRTCNetwork::signalConnect):
		42	(WebKit::LibWebRTCNetwork::signalClose):
		43	(WebKit::LibWebRTCNetwork::signalNewConnection):
		44	* WebProcess/Network/webrtc/LibWebRTCNetwork.messages.in: Added.
		45	* WebProcess/Network/webrtc/LibWebRTCSocket.h:
		46	* WebProcess/Network/webrtc/LibWebRTCSocketFactory.cpp:
		47	* WebProcess/Network/webrtc/WebRTCSocket.cpp: Removed.
		48	* WebProcess/Network/webrtc/WebRTCSocket.h: Removed.
		49
1	2020-05-01 Carlos Garcia Campos <cgarcia@igalia.com>	50	2020-05-01 Carlos Garcia Campos <cgarcia@igalia.com>
2		51
3	[GTK] Move focus out of the web view when tab is pressed and there isn't a next element to focus	52	[GTK] Move focus out of the web view when tab is pressed and there isn't a next element to focus

Lines 57-62 $(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCCodecsMessagesReplies.h a/Source/WebKit/DerivedSources-output.xcfilelist_sec1
- a/Source/WebKit/DerivedSources-output.xcfilelist -3 / +3 lines
57	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCCodecsProxyMessageReceiver.cpp	57	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCCodecsProxyMessageReceiver.cpp
58	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCCodecsProxyMessages.h	58	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCCodecsProxyMessages.h
59	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCCodecsProxyMessagesReplies.h	59	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCCodecsProxyMessagesReplies.h
		60	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCNetworkMessageReceiver.cpp
		61	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCNetworkMessages.h
		62	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCNetworkMessagesReplies.h
60	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCRemoteCodecsMessageReceiver.cpp	63	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCRemoteCodecsMessageReceiver.cpp
61	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCRemoteCodecsMessages.h	64	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCRemoteCodecsMessages.h
62	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCRemoteCodecsMessagesReplies.h	65	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/LibWebRTCRemoteCodecsMessagesReplies.h
Lines 384-392 $(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCMonitorMessagesReplies.h a/Source/WebKit/DerivedSources-output.xcfilelist_sec2
384	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCResolverMessageReceiver.cpp	387	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCResolverMessageReceiver.cpp
385	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCResolverMessages.h	388	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCResolverMessages.h
386	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCResolverMessagesReplies.h	389	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCResolverMessagesReplies.h
387	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCSocketMessageReceiver.cpp
388	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCSocketMessages.h
389	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebRTCSocketMessagesReplies.h
390	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebResourceLoaderMessageReceiver.cpp	390	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebResourceLoaderMessageReceiver.cpp
391	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebResourceLoaderMessages.h	391	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebResourceLoaderMessages.h
392	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebResourceLoaderMessagesReplies.h	392	$(BUILT_PRODUCTS_DIR)/DerivedSources/WebKit2/WebResourceLoaderMessagesReplies.h

Lines 129-134 MESSAGE_RECEIVERS = \ a/Source/WebKit/DerivedSources.make_sec1
- a/Source/WebKit/DerivedSources.make -1 / +1 lines
129	LegacyCustomProtocolManagerProxy \	129	LegacyCustomProtocolManagerProxy \
130	LibWebRTCCodecs \	130	LibWebRTCCodecs \
131	LibWebRTCCodecsProxy \	131	LibWebRTCCodecsProxy \
		132	LibWebRTCNetwork \
132	MediaPlayerPrivateRemote \	133	MediaPlayerPrivateRemote \
133	NPObjectMessageReceiver \	134	NPObjectMessageReceiver \
134	NetworkConnectionToWebProcess \	135	NetworkConnectionToWebProcess \
Lines 228-234 MESSAGE_RECEIVERS = \ a/Source/WebKit/DerivedSources.make_sec2
228	WebProcessProxy \	229	WebProcessProxy \
229	WebRTCMonitor \	230	WebRTCMonitor \
230	WebRTCResolver \	231	WebRTCResolver \
231	WebRTCSocket \
232	WebResourceLoader \	232	WebResourceLoader \
233	WebSWClientConnection \	233	WebSWClientConnection \
234	WebSWContextManagerConnection \	234	WebSWContextManagerConnection \

Lines 30-38 a/Source/WebKit/NetworkProcess/webrtc/LibWebRTCSocketClient.cpp_sec1
- a/Source/WebKit/NetworkProcess/webrtc/LibWebRTCSocketClient.cpp -6 / +6 lines
30		30
31	#include "Connection.h"	31	#include "Connection.h"
32	#include "DataReference.h"	32	#include "DataReference.h"
		33	#include "LibWebRTCNetworkMessages.h"
33	#include "Logging.h"	34	#include "Logging.h"
34	#include "NetworkRTCProvider.h"	35	#include "NetworkRTCProvider.h"
35	#include "WebRTCSocketMessages.h"
36	#include <WebCore/SharedBuffer.h>	36	#include <WebCore/SharedBuffer.h>
37	#include <wtf/Function.h>	37	#include <wtf/Function.h>
38		38
Lines 100-106 void LibWebRTCSocketClient::signalReadPacket(rtc::AsyncPacketSocket* socket, con a/Source/WebKit/NetworkProcess/webrtc/LibWebRTCSocketClient.cpp_sec2
100	auto buffer = WebCore::SharedBuffer::create(value, length);	100	auto buffer = WebCore::SharedBuffer::create(value, length);
101	m_rtcProvider.sendFromMainThread([identifier = m_identifier, buffer = WTFMove(buffer), address = RTCNetwork::isolatedCopy(address), packetTime](IPC::Connection& connection) {	101	m_rtcProvider.sendFromMainThread([identifier = m_identifier, buffer = WTFMove(buffer), address = RTCNetwork::isolatedCopy(address), packetTime](IPC::Connection& connection) {
102	IPC::DataReference data(reinterpret_cast<const uint8_t*>(buffer->data()), buffer->size());	102	IPC::DataReference data(reinterpret_cast<const uint8_t*>(buffer->data()), buffer->size());
103	connection.send(Messages::WebRTCSocket::SignalReadPacket(data, RTCNetwork::IPAddress(address.ipaddr()), address.port(), packetTime), identifier);	103	connection.send(Messages::LibWebRTCNetwork::SignalReadPacket(identifier, data, RTCNetwork::IPAddress(address.ipaddr()), address.port(), packetTime), 0);
104	});	104	});
105	}	105	}
106		106
Lines 108-114 void LibWebRTCSocketClient::signalSentPacket(rtc::AsyncPacketSocket* socket, con a/Source/WebKit/NetworkProcess/webrtc/LibWebRTCSocketClient.cpp_sec3
108	{	108	{
109	ASSERT_UNUSED(socket, m_socket.get() == socket);	109	ASSERT_UNUSED(socket, m_socket.get() == socket);
110	m_rtcProvider.sendFromMainThread([identifier = m_identifier, sentPacket](IPC::Connection& connection) {	110	m_rtcProvider.sendFromMainThread([identifier = m_identifier, sentPacket](IPC::Connection& connection) {
111	connection.send(Messages::WebRTCSocket::SignalSentPacket(sentPacket.packet_id, sentPacket.send_time_ms), identifier);	111	connection.send(Messages::LibWebRTCNetwork::SignalSentPacket(identifier, sentPacket.packet_id, sentPacket.send_time_ms), 0);
112	});	112	});
113	}	113	}
114		114
Lines 122-128 void LibWebRTCSocketClient::signalAddressReady(rtc::AsyncPacketSocket* socket, c a/Source/WebKit/NetworkProcess/webrtc/LibWebRTCSocketClient.cpp_sec4
122	{	122	{
123	ASSERT_UNUSED(socket, m_socket.get() == socket);	123	ASSERT_UNUSED(socket, m_socket.get() == socket);
124	m_rtcProvider.sendFromMainThread([identifier = m_identifier, address = RTCNetwork::isolatedCopy(address)](IPC::Connection& connection) {	124	m_rtcProvider.sendFromMainThread([identifier = m_identifier, address = RTCNetwork::isolatedCopy(address)](IPC::Connection& connection) {
125	connection.send(Messages::WebRTCSocket::SignalAddressReady(RTCNetwork::SocketAddress(address)), identifier);	125	connection.send(Messages::LibWebRTCNetwork::SignalAddressReady(identifier, RTCNetwork::SocketAddress(address)), 0);
126	});	126	});
127	}	127	}
128		128
Lines 135-141 void LibWebRTCSocketClient::signalConnect(rtc::AsyncPacketSocket* socket) a/Source/WebKit/NetworkProcess/webrtc/LibWebRTCSocketClient.cpp_sec5
135	{	135	{
136	ASSERT_UNUSED(socket, m_socket.get() == socket);	136	ASSERT_UNUSED(socket, m_socket.get() == socket);
137	m_rtcProvider.sendFromMainThread([identifier = m_identifier](IPC::Connection& connection) {	137	m_rtcProvider.sendFromMainThread([identifier = m_identifier](IPC::Connection& connection) {
138	connection.send(Messages::WebRTCSocket::SignalConnect(), identifier);	138	connection.send(Messages::LibWebRTCNetwork::SignalConnect(identifier), 0);
139	});	139	});
140	}	140	}
141		141
Lines 143-149 void LibWebRTCSocketClient::signalClose(rtc::AsyncPacketSocket* socket, int erro a/Source/WebKit/NetworkProcess/webrtc/LibWebRTCSocketClient.cpp_sec6
143	{	143	{
144	ASSERT_UNUSED(socket, m_socket.get() == socket);	144	ASSERT_UNUSED(socket, m_socket.get() == socket);
145	m_rtcProvider.sendFromMainThread([identifier = m_identifier, error](IPC::Connection& connection) {	145	m_rtcProvider.sendFromMainThread([identifier = m_identifier, error](IPC::Connection& connection) {
146	connection.send(Messages::WebRTCSocket::SignalClose(error), identifier);	146	connection.send(Messages::LibWebRTCNetwork::SignalClose(identifier, error), 0);
147	});	147	});
148	// We want to remove 'this' from the socket map now but we will destroy it asynchronously	148	// We want to remove 'this' from the socket map now but we will destroy it asynchronously
149	// so that the socket parameter of signalClose remains alive as the caller of signalClose may actually being using it afterwards.	149	// so that the socket parameter of signalClose remains alive as the caller of signalClose may actually being using it afterwards.

Lines 28-33 a/Source/WebKit/NetworkProcess/webrtc/NetworkRTCProvider.cpp_sec1
- a/Source/WebKit/NetworkProcess/webrtc/NetworkRTCProvider.cpp -6 / +6 lines
28		28
29	#if USE(LIBWEBRTC)	29	#if USE(LIBWEBRTC)
30		30
		31	#include "LibWebRTCNetworkMessages.h"
31	#include "LibWebRTCSocketClient.h"	32	#include "LibWebRTCSocketClient.h"
32	#include "Logging.h"	33	#include "Logging.h"
33	#include "NetworkConnectionToWebProcess.h"	34	#include "NetworkConnectionToWebProcess.h"
Lines 35-41 a/Source/WebKit/NetworkProcess/webrtc/NetworkRTCProvider.cpp_sec2
35	#include "NetworkRTCResolver.h"	36	#include "NetworkRTCResolver.h"
36	#include "NetworkRTCSocket.h"	37	#include "NetworkRTCSocket.h"
37	#include "WebRTCResolverMessages.h"	38	#include "WebRTCResolverMessages.h"
38	#include "WebRTCSocketMessages.h"
39	#include <WebCore/LibWebRTCMacros.h>	39	#include <WebCore/LibWebRTCMacros.h>
40	#include <webrtc/rtc_base/async_packet_socket.h>	40	#include <webrtc/rtc_base/async_packet_socket.h>
41	#include <webrtc/rtc_base/logging.h>	41	#include <webrtc/rtc_base/logging.h>
Lines 118-124 void NetworkRTCProvider::createSocket(LibWebRTCSocketIdentifier identifier, std: a/Source/WebKit/NetworkProcess/webrtc/NetworkRTCProvider.cpp_sec3
118	if (!socket) {	118	if (!socket) {
119	sendFromMainThread([this, identifier, size = m_sockets.size()](IPC::Connection& connection) {	119	sendFromMainThread([this, identifier, size = m_sockets.size()](IPC::Connection& connection) {
120	RELEASE_LOG_ERROR_IF_ALLOWED("createSocket with %u sockets is unable to create a new socket", size);	120	RELEASE_LOG_ERROR_IF_ALLOWED("createSocket with %u sockets is unable to create a new socket", size);
121	connection.send(Messages::WebRTCSocket::SignalClose(1), identifier);	121	connection.send(Messages::LibWebRTCNetwork::SignalClose(identifier, 1), 0);
122	});	122	});
123	return;	123	return;
124	}	124	}
Lines 137-143 void NetworkRTCProvider::createServerTCPSocket(LibWebRTCSocketIdentifier identif a/Source/WebKit/NetworkProcess/webrtc/NetworkRTCProvider.cpp_sec4
137	{	137	{
138	if (!m_isListeningSocketAuthorized) {	138	if (!m_isListeningSocketAuthorized) {
139	if (m_connection)	139	if (m_connection)
140	m_connection->connection().send(Messages::WebRTCSocket::SignalClose(1), identifier);	140	m_connection->connection().send(Messages::LibWebRTCNetwork::SignalClose(identifier, 1), 0);
141	return;	141	return;
142	}	142	}
143		143
Lines 158-164 void NetworkRTCProvider::createClientTCPSocket(LibWebRTCSocketIdentifier identif a/Source/WebKit/NetworkProcess/webrtc/NetworkRTCProvider.cpp_sec5
158	{	158	{
159	auto* session = m_connection->networkSession();	159	auto* session = m_connection->networkSession();
160	if (!session) {	160	if (!session) {
161	m_connection->connection().send(Messages::WebRTCSocket::SignalClose(1), identifier);	161	m_connection->connection().send(Messages::LibWebRTCNetwork::SignalClose(identifier, 1), 0);
162	return;	162	return;
163	}	163	}
164	callOnRTCNetworkThread([this, identifier, localAddress = RTCNetwork::isolatedCopy(localAddress.value), remoteAddress = RTCNetwork::isolatedCopy(remoteAddress.value), proxyInfo = proxyInfoFromSession(remoteAddress, *session), userAgent = WTFMove(userAgent).isolatedCopy(), options]() {	164	callOnRTCNetworkThread([this, identifier, localAddress = RTCNetwork::isolatedCopy(localAddress.value), remoteAddress = RTCNetwork::isolatedCopy(remoteAddress.value), proxyInfo = proxyInfoFromSession(remoteAddress, *session), userAgent = WTFMove(userAgent).isolatedCopy(), options]() {
Lines 193-199 void NetworkRTCProvider::newConnection(Socket& serverSocket, std::unique_ptr<rtc a/Source/WebKit/NetworkProcess/webrtc/NetworkRTCProvider.cpp_sec6
193	{	193	{
194	auto incomingSocketIdentifier = LibWebRTCSocketIdentifier::generate();	194	auto incomingSocketIdentifier = LibWebRTCSocketIdentifier::generate();
195	sendFromMainThread([identifier = serverSocket.identifier(), incomingSocketIdentifier, remoteAddress = RTCNetwork::isolatedCopy(newSocket->GetRemoteAddress())](IPC::Connection& connection) {	195	sendFromMainThread([identifier = serverSocket.identifier(), incomingSocketIdentifier, remoteAddress = RTCNetwork::isolatedCopy(newSocket->GetRemoteAddress())](IPC::Connection& connection) {
196	connection.send(Messages::WebRTCSocket::SignalNewConnection(incomingSocketIdentifier, RTCNetwork::SocketAddress(remoteAddress)), identifier);	196	connection.send(Messages::LibWebRTCNetwork::SignalNewConnection(identifier, incomingSocketIdentifier, RTCNetwork::SocketAddress(remoteAddress)), 0);
197	});	197	});
198	m_pendingIncomingSockets.add(incomingSocketIdentifier, WTFMove(newSocket));	198	m_pendingIncomingSockets.add(incomingSocketIdentifier, WTFMove(newSocket));
199	}	199	}
Lines 264-270 void NetworkRTCProvider::closeListeningSockets(Function<void()>&& completionHand a/Source/WebKit/NetworkProcess/webrtc/NetworkRTCProvider.cpp_sec7
264	callOnMainThread([provider = makeRef(*this), listeningSocketIdentifiers = WTFMove(listeningSocketIdentifiers), completionHandler = WTFMove(completionHandler)] {	264	callOnMainThread([provider = makeRef(*this), listeningSocketIdentifiers = WTFMove(listeningSocketIdentifiers), completionHandler = WTFMove(completionHandler)] {
265	if (provider->m_connection) {	265	if (provider->m_connection) {
266	for (auto identifier : listeningSocketIdentifiers)	266	for (auto identifier : listeningSocketIdentifiers)
267	provider->m_connection->connection().send(Messages::WebRTCSocket::SignalClose(ECONNABORTED), identifier);	267	provider->m_connection->connection().send(Messages::LibWebRTCNetwork::SignalClose(identifier, ECONNABORTED), 0);
268	}	268	}
269	completionHandler();	269	completionHandler();
270	});	270	});

Lines 589-594 WebProcess/Network/WebSocketChannelManager.cpp a/Source/WebKit/Sources.txt_sec1
- a/Source/WebKit/Sources.txt -1 / +1 lines
589	WebProcess/Network/WebSocketProvider.cpp	589	WebProcess/Network/WebSocketProvider.cpp
590	WebProcess/Network/WebSocketStream.cpp	590	WebProcess/Network/WebSocketStream.cpp
591		591
		592	WebProcess/Network/webrtc/LibWebRTCNetwork.cpp
592	WebProcess/Network/webrtc/LibWebRTCProvider.cpp	593	WebProcess/Network/webrtc/LibWebRTCProvider.cpp
593	WebProcess/Network/webrtc/LibWebRTCResolver.cpp	594	WebProcess/Network/webrtc/LibWebRTCResolver.cpp
594	WebProcess/Network/webrtc/LibWebRTCSocket.cpp	595	WebProcess/Network/webrtc/LibWebRTCSocket.cpp
Lines 596-602 WebProcess/Network/webrtc/LibWebRTCSocketFactory.cpp a/Source/WebKit/Sources.txt_sec2
596	WebProcess/Network/webrtc/WebMDNSRegister.cpp	597	WebProcess/Network/webrtc/WebMDNSRegister.cpp
597	WebProcess/Network/webrtc/WebRTCMonitor.cpp	598	WebProcess/Network/webrtc/WebRTCMonitor.cpp
598	WebProcess/Network/webrtc/WebRTCResolver.cpp	599	WebProcess/Network/webrtc/WebRTCResolver.cpp
599	WebProcess/Network/webrtc/WebRTCSocket.cpp
600		600
601	WebProcess/Notifications/NotificationPermissionRequestManager.cpp	601	WebProcess/Notifications/NotificationPermissionRequestManager.cpp
602	WebProcess/Notifications/WebNotificationManager.cpp	602	WebProcess/Notifications/WebNotificationManager.cpp

Lines 1074-1080 a/Source/WebKit/WebKit.xcodeproj/project.pbxproj_sec1
- a/Source/WebKit/WebKit.xcodeproj/project.pbxproj -4 / +8 lines
1074	51EFC1CF1524E62500C9A938 /* WKBundleDOMWindowExtension.h in Headers / = {isa = PBXBuildFile; fileRef = 51FA2D541521118600C1BA0B / WKBundleDOMWindowExtension.h */; settings = {ATTRIBUTES = (Private, ); }; };	1074	51EFC1CF1524E62500C9A938 /* WKBundleDOMWindowExtension.h in Headers / = {isa = PBXBuildFile; fileRef = 51FA2D541521118600C1BA0B / WKBundleDOMWindowExtension.h */; settings = {ATTRIBUTES = (Private, ); }; };
1075	51F060E01654317F00F3281B /* WebResourceLoaderMessages.h in Headers / = {isa = PBXBuildFile; fileRef = 51F060DE1654317500F3281B / WebResourceLoaderMessages.h */; };	1075	51F060E01654317F00F3281B /* WebResourceLoaderMessages.h in Headers / = {isa = PBXBuildFile; fileRef = 51F060DE1654317500F3281B / WebResourceLoaderMessages.h */; };
1076	51F060E11654318500F3281B /* WebResourceLoaderMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281B / WebResourceLoaderMessageReceiver.cpp */; };	1076	51F060E11654318500F3281B /* WebResourceLoaderMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281B / WebResourceLoaderMessageReceiver.cpp */; };
1077	51F060E11654318500F3281C /* WebRTCSocketMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281C / WebRTCSocketMessageReceiver.cpp */; };	1077	51F060E11654318500F3281C /* LibWebRTCNetworkMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281C / LibWebRTCNetworkMessageReceiver.cpp */; };
1078	51F060E11654318500F3281D /* NetworkRTCSocketMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281D / NetworkRTCSocketMessageReceiver.cpp */; };	1078	51F060E11654318500F3281D /* NetworkRTCSocketMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281D / NetworkRTCSocketMessageReceiver.cpp */; };
1079	51F060E11654318500F3281E /* NetworkRTCMonitorMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281E / NetworkRTCMonitorMessageReceiver.cpp */; };	1079	51F060E11654318500F3281E /* NetworkRTCMonitorMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281E / NetworkRTCMonitorMessageReceiver.cpp */; };
1080	51F060E11654318500F3281F /* WebRTCMonitorMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281F / WebRTCMonitorMessageReceiver.cpp */; };	1080	51F060E11654318500F3281F /* WebRTCMonitorMessageReceiver.cpp in Sources / = {isa = PBXBuildFile; fileRef = 51F060DD1654317500F3281F / WebRTCMonitorMessageReceiver.cpp */; };
Lines 3429-3434 a/Source/WebKit/WebKit.xcodeproj/project.pbxproj_sec2
3429	4157E4AF20E2EC9800A6C0D7 /* com.google.o1dbrowserplugin.sb */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = text; path = com.google.o1dbrowserplugin.sb; sourceTree = "<group>"; };	3429	4157E4AF20E2EC9800A6C0D7 /* com.google.o1dbrowserplugin.sb */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = text; path = com.google.o1dbrowserplugin.sb; sourceTree = "<group>"; };
3430	4158649A23BE092400A0A61E /* RTCEncoderIdentifier.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = RTCEncoderIdentifier.h; sourceTree = "<group>"; };	3430	4158649A23BE092400A0A61E /* RTCEncoderIdentifier.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = RTCEncoderIdentifier.h; sourceTree = "<group>"; };
3431	416CD74523FB178B00661D99 /* MDNSRegisterIdentifier.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; name = MDNSRegisterIdentifier.h; path = Network/webrtc/MDNSRegisterIdentifier.h; sourceTree = "<group>"; };	3431	416CD74523FB178B00661D99 /* MDNSRegisterIdentifier.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; name = MDNSRegisterIdentifier.h; path = Network/webrtc/MDNSRegisterIdentifier.h; sourceTree = "<group>"; };
		3432	416F8086245B397400B68F02 /* LibWebRTCNetwork.messages.in */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = text; name = LibWebRTCNetwork.messages.in; path = Network/webrtc/LibWebRTCNetwork.messages.in; sourceTree = "<group>"; };
		3433	416F8089245C7FF500B68F02 /* LibWebRTCNetwork.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; name = LibWebRTCNetwork.cpp; path = Network/webrtc/LibWebRTCNetwork.cpp; sourceTree = "<group>"; };
3432	4172198923B6128200AE5686 /* LibWebRTCCodecs.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = LibWebRTCCodecs.h; sourceTree = "<group>"; };	3434	4172198923B6128200AE5686 /* LibWebRTCCodecs.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = LibWebRTCCodecs.h; sourceTree = "<group>"; };
3433	4172198A23B6128200AE5686 /* LibWebRTCCodecs.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; path = LibWebRTCCodecs.cpp; sourceTree = "<group>"; };	3435	4172198A23B6128200AE5686 /* LibWebRTCCodecs.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; path = LibWebRTCCodecs.cpp; sourceTree = "<group>"; };
3434	4172198C23B612E800AE5686 /* RTCDecoderIdentifier.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = RTCDecoderIdentifier.h; sourceTree = "<group>"; };	3436	4172198C23B612E800AE5686 /* RTCDecoderIdentifier.h */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.c.h; path = RTCDecoderIdentifier.h; sourceTree = "<group>"; };
Lines 3811-3817 a/Source/WebKit/WebKit.xcodeproj/project.pbxproj_sec3
3811	51E8B68D1E712873001B7132 /* WebURLSchemeTask.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; path = WebURLSchemeTask.cpp; sourceTree = "<group>"; };	3813	51E8B68D1E712873001B7132 /* WebURLSchemeTask.cpp */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.cpp; path = WebURLSchemeTask.cpp; sourceTree = "<group>"; };
3812	51E949961D761CC700EC9EB9 /* UIGamepadProviderIOS.mm */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.objcpp; path = UIGamepadProviderIOS.mm; sourceTree = "<group>"; };	3814	51E949961D761CC700EC9EB9 /* UIGamepadProviderIOS.mm */ = {isa = PBXFileReference; fileEncoding = 4; lastKnownFileType = sourcecode.cpp.objcpp; path = UIGamepadProviderIOS.mm; sourceTree = "<group>"; };
3813	51F060DD1654317500F3281B /* WebResourceLoaderMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = WebResourceLoaderMessageReceiver.cpp; path = DerivedSources/WebKit2/WebResourceLoaderMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };	3815	51F060DD1654317500F3281B /* WebResourceLoaderMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = WebResourceLoaderMessageReceiver.cpp; path = DerivedSources/WebKit2/WebResourceLoaderMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };
3814	51F060DD1654317500F3281C /* WebRTCSocketMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = WebRTCSocketMessageReceiver.cpp; path = DerivedSources/WebKit2/WebRTCSocketMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };	3816	51F060DD1654317500F3281C /* LibWebRTCNetworkMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = LibWebRTCNetworkMessageReceiver.cpp; path = DerivedSources/WebKit2/LibWebRTCNetworkMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };
3815	51F060DD1654317500F3281D /* NetworkRTCSocketMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = NetworkRTCSocketMessageReceiver.cpp; path = DerivedSources/WebKit2/NetworkRTCSocketMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };	3817	51F060DD1654317500F3281D /* NetworkRTCSocketMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = NetworkRTCSocketMessageReceiver.cpp; path = DerivedSources/WebKit2/NetworkRTCSocketMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };
3816	51F060DD1654317500F3281E /* NetworkRTCMonitorMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = NetworkRTCMonitorMessageReceiver.cpp; path = DerivedSources/WebKit2/NetworkRTCMonitorMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };	3818	51F060DD1654317500F3281E /* NetworkRTCMonitorMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = NetworkRTCMonitorMessageReceiver.cpp; path = DerivedSources/WebKit2/NetworkRTCMonitorMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };
3817	51F060DD1654317500F3281F /* WebRTCMonitorMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = WebRTCMonitorMessageReceiver.cpp; path = DerivedSources/WebKit2/WebRTCMonitorMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };	3819	51F060DD1654317500F3281F /* WebRTCMonitorMessageReceiver.cpp */ = {isa = PBXFileReference; lastKnownFileType = sourcecode.cpp.cpp; name = WebRTCMonitorMessageReceiver.cpp; path = DerivedSources/WebKit2/WebRTCMonitorMessageReceiver.cpp; sourceTree = BUILT_PRODUCTS_DIR; };
Lines 7585-7591 a/Source/WebKit/WebKit.xcodeproj/project.pbxproj_sec4
7585	4130759E1DE85E650039EC69 /* webrtc */ = {	7587	4130759E1DE85E650039EC69 /* webrtc */ = {
7586	isa = PBXGroup;	7588	isa = PBXGroup;
7587	children = (	7589	children = (
		7590	416F8089245C7FF500B68F02 /* LibWebRTCNetwork.cpp */,
7588	411B22621E371244004F7363 /* LibWebRTCNetwork.h */,	7591	411B22621E371244004F7363 /* LibWebRTCNetwork.h */,
		7592	416F8086245B397400B68F02 /* LibWebRTCNetwork.messages.in */,
7589	413075A71DE85EE70039EC69 /* LibWebRTCProvider.cpp */,	7593	413075A71DE85EE70039EC69 /* LibWebRTCProvider.cpp */,
7590	413075A81DE85EE70039EC69 /* LibWebRTCProvider.h */,	7594	413075A81DE85EE70039EC69 /* LibWebRTCProvider.h */,
7591	41FAF5F71E3C0B47001AE678 /* LibWebRTCResolver.cpp */,	7595	41FAF5F71E3C0B47001AE678 /* LibWebRTCResolver.cpp */,
Lines 9983-9988 a/Source/WebKit/WebKit.xcodeproj/project.pbxproj_sec5
9983	2984F587164BA095004BC0C6 /* LegacyCustomProtocolManagerMessages.h */,	9987	2984F587164BA095004BC0C6 /* LegacyCustomProtocolManagerMessages.h */,
9984	2984F57A164B915F004BC0C6 /* LegacyCustomProtocolManagerProxyMessageReceiver.cpp */,	9988	2984F57A164B915F004BC0C6 /* LegacyCustomProtocolManagerProxyMessageReceiver.cpp */,
9985	2984F57B164B915F004BC0C6 /* LegacyCustomProtocolManagerProxyMessages.h */,	9989	2984F57B164B915F004BC0C6 /* LegacyCustomProtocolManagerProxyMessages.h */,
		9990	51F060DD1654317500F3281C /* LibWebRTCNetworkMessageReceiver.cpp */,
9986	07E19EF823D401F00094FFB4 /* MediaPlayerPrivateRemoteMessageReceiver.cpp */,	9991	07E19EF823D401F00094FFB4 /* MediaPlayerPrivateRemoteMessageReceiver.cpp */,
9987	07E19EF923D401F00094FFB4 /* MediaPlayerPrivateRemoteMessages.h */,	9992	07E19EF923D401F00094FFB4 /* MediaPlayerPrivateRemoteMessages.h */,
9988	07E19EFA23D401F00094FFB4 /* MediaPlayerPrivateRemoteMessagesReplies.h */,	9993	07E19EFA23D401F00094FFB4 /* MediaPlayerPrivateRemoteMessagesReplies.h */,
Lines 10184-10190 a/Source/WebKit/WebKit.xcodeproj/project.pbxproj_sec6
10184	51F060DE1654317500F3281B /* WebResourceLoaderMessages.h */,	10189	51F060DE1654317500F3281B /* WebResourceLoaderMessages.h */,
10185	51F060DD1654317500F3281F /* WebRTCMonitorMessageReceiver.cpp */,	10190	51F060DD1654317500F3281F /* WebRTCMonitorMessageReceiver.cpp */,
10186	51F060DD1654317500F3282C /* WebRTCResolverMessageReceiver.cpp */,	10191	51F060DD1654317500F3282C /* WebRTCResolverMessageReceiver.cpp */,
10187	51F060DD1654317500F3281C /* WebRTCSocketMessageReceiver.cpp */,
10188	41F060DD1654317500F3281C /* WebSocketChannelMessageReceiver.cpp */,	10192	41F060DD1654317500F3281C /* WebSocketChannelMessageReceiver.cpp */,
10189	5C0B17761E7C879C00E9123C /* WebSocketStreamMessageReceiver.cpp */,	10193	5C0B17761E7C879C00E9123C /* WebSocketStreamMessageReceiver.cpp */,
10190	5C0B17771E7C879C00E9123C /* WebSocketStreamMessages.h */,	10194	5C0B17771E7C879C00E9123C /* WebSocketStreamMessages.h */,
Lines 12689-12694 a/Source/WebKit/WebKit.xcodeproj/project.pbxproj_sec7
12689	2D913442212CF9F000128AFD /* JSNPObject.cpp in Sources */,	12693	2D913442212CF9F000128AFD /* JSNPObject.cpp in Sources */,
12690	2984F588164BA095004BC0C6 /* LegacyCustomProtocolManagerMessageReceiver.cpp in Sources */,	12694	2984F588164BA095004BC0C6 /* LegacyCustomProtocolManagerMessageReceiver.cpp in Sources */,
12691	2984F57C164B915F004BC0C6 /* LegacyCustomProtocolManagerProxyMessageReceiver.cpp in Sources */,	12695	2984F57C164B915F004BC0C6 /* LegacyCustomProtocolManagerProxyMessageReceiver.cpp in Sources */,
		12696	51F060E11654318500F3281C /* LibWebRTCNetworkMessageReceiver.cpp in Sources */,
12692	449D90DA21FDC30B00F677C0 /* LocalAuthenticationSoftLink.mm in Sources */,	12697	449D90DA21FDC30B00F677C0 /* LocalAuthenticationSoftLink.mm in Sources */,
12693	2D92A779212B6A6100F493FD /* Logging.cpp in Sources */,	12698	2D92A779212B6A6100F493FD /* Logging.cpp in Sources */,
12694	07E19EFB23D401F10094FFB4 /* MediaPlayerPrivateRemoteMessageReceiver.cpp in Sources */,	12699	07E19EFB23D401F10094FFB4 /* MediaPlayerPrivateRemoteMessageReceiver.cpp in Sources */,
Lines 13021-13027 a/Source/WebKit/WebKit.xcodeproj/project.pbxproj_sec8
13021	51F060E11654318500F3281B /* WebResourceLoaderMessageReceiver.cpp in Sources */,	13026	51F060E11654318500F3281B /* WebResourceLoaderMessageReceiver.cpp in Sources */,
13022	51F060E11654318500F3281F /* WebRTCMonitorMessageReceiver.cpp in Sources */,	13027	51F060E11654318500F3281F /* WebRTCMonitorMessageReceiver.cpp in Sources */,
13023	51F060E11654318500F3282C /* WebRTCResolverMessageReceiver.cpp in Sources */,	13028	51F060E11654318500F3282C /* WebRTCResolverMessageReceiver.cpp in Sources */,
13024	51F060E11654318500F3281C /* WebRTCSocketMessageReceiver.cpp in Sources */,
13025	41E0A7CB23B645CD00561060 /* WebSocketChannel.cpp in Sources */,	13029	41E0A7CB23B645CD00561060 /* WebSocketChannel.cpp in Sources */,
13026	41F060E11654318500F3281C /* WebSocketChannelMessageReceiver.cpp in Sources */,	13030	41F060E11654318500F3281C /* WebSocketChannelMessageReceiver.cpp in Sources */,
13027	5C0B17791E7C882100E9123C /* WebSocketStreamMessageReceiver.cpp in Sources */,	13031	5C0B17791E7C882100E9123C /* WebSocketStreamMessageReceiver.cpp in Sources */,

Lines 46-52 a/Source/WebKit/WebProcess/Network/NetworkProcessConnection.cpp_sec1
- a/Source/WebKit/WebProcess/Network/NetworkProcessConnection.cpp -9 / +1 lines
46	#include "WebRTCMonitor.h"	46	#include "WebRTCMonitor.h"
47	#include "WebRTCMonitorMessages.h"	47	#include "WebRTCMonitorMessages.h"
48	#include "WebRTCResolverMessages.h"	48	#include "WebRTCResolverMessages.h"
49	#include "WebRTCSocketMessages.h"
50	#include "WebResourceLoaderMessages.h"	49	#include "WebResourceLoaderMessages.h"
51	#include "WebSWClientConnection.h"	50	#include "WebSWClientConnection.h"
52	#include "WebSWClientConnectionMessages.h"	51	#include "WebSWClientConnectionMessages.h"
Lines 77-82 NetworkProcessConnection::NetworkProcessConnection(IPC::Connection::Identifier c a/Source/WebKit/WebProcess/Network/NetworkProcessConnection.cpp_sec2
77	, m_cookieAcceptPolicy(cookieAcceptPolicy)	76	, m_cookieAcceptPolicy(cookieAcceptPolicy)
78	{	77	{
79	m_connection->open();	78	m_connection->open();
		79	WebProcess::singleton().libWebRTCNetwork().setConnection(m_connection.copyRef());
80	}	80	}
81		81
82	NetworkProcessConnection::~NetworkProcessConnection()	82	NetworkProcessConnection::~NetworkProcessConnection()
Lines 112-125 void NetworkProcessConnection::didReceiveMessage(IPC::Connection& connection, IP a/Source/WebKit/WebProcess/Network/NetworkProcessConnection.cpp_sec3
112	}	112	}
113		113
114	#if USE(LIBWEBRTC)	114	#if USE(LIBWEBRTC)
115	if (decoder.messageReceiverName() == Messages::WebRTCSocket::messageReceiverName()) {
116	auto& network = WebProcess::singleton().libWebRTCNetwork();
117	if (network.isActive())
118	network.socket(makeObjectIdentifier<LibWebRTCSocketIdentifierType>(decoder.destinationID())).didReceiveMessage(connection, decoder);
119	else
120	RELEASE_LOG_ERROR(WebRTC, "Received WebRTCSocket message while libWebRTCNetwork is not active");
121	return;
122	}
123	if (decoder.messageReceiverName() == Messages::WebRTCMonitor::messageReceiverName()) {	115	if (decoder.messageReceiverName() == Messages::WebRTCMonitor::messageReceiverName()) {
124	auto& network = WebProcess::singleton().libWebRTCNetwork();	116	auto& network = WebProcess::singleton().libWebRTCNetwork();
125	if (network.isActive())	117	if (network.isActive())

Line 0 a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCNetwork.cpp_sec1
- a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCNetwork.cpp +124 lines
		1	/*
		2	* Copyright (C) 2020 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 "LibWebRTCNetwork.h"
		28
		29	#include "DataReference.h"
		30	#include "LibWebRTCNetworkMessages.h"
		31	#include "Logging.h"
		32	#include <WebCore/SharedBuffer.h>
		33
		34	namespace WebKit {
		35
		36	LibWebRTCNetwork::~LibWebRTCNetwork()
		37	{
		38	setConnection(nullptr);
		39	}
		40
		41	void LibWebRTCNetwork::networkProcessCrashed()
		42	{
		43	setConnection(nullptr);
		44
		45	#if USE(LIBWEBRTC)
		46	m_webNetworkMonitor.networkProcessCrashed();
		47	#endif
		48	}
		49
		50	void LibWebRTCNetwork::setConnection(RefPtr<IPC::Connection>&& connection)
		51	{
		52	#if USE(LIBWEBRTC)
		53	if (m_connection)
		54	m_connection->removeThreadMessageReceiver(Messages::LibWebRTCNetwork::messageReceiverName());
		55	#endif
		56	m_connection = WTFMove(connection);
		57	#if USE(LIBWEBRTC)
		58	if (m_connection)
		59	m_connection->addThreadMessageReceiver(Messages::LibWebRTCNetwork::messageReceiverName(), this);
		60	#endif
		61	}
		62
		63	bool LibWebRTCNetwork::isActive() const
		64	{
65	#if USE(LIBWEBRTC)
66	return WebCore::LibWebRTCProvider::hasWebRTCThreads();
67	#else
68	return false;
69	#endif
70	}
71
72	void LibWebRTCNetwork::dispatchToThread(Function<void()>&& callback)
73	{
74	if (!isActive()) {
75	RELEASE_LOG_ERROR(WebRTC, "Received WebRTCSocket message while libWebRTCNetwork is not active");
76	return;
77	}
78
79	#if USE(LIBWEBRTC)
80	WebCore::LibWebRTCProvider::callOnWebRTCNetworkThread(WTFMove(callback));
81	#else
82	UNUSED_PARAM(callback);
83	#endif
84	}
85
86	#if USE(LIBWEBRTC)
87	void LibWebRTCNetwork::signalAddressReady(WebCore::LibWebRTCSocketIdentifier identifier, const RTCNetwork::SocketAddress& address)
88	{
89	if (auto* socket = m_socketFactory.socket(identifier))
90	socket->signalAddressReady(address.value);
91	}
92
93	void LibWebRTCNetwork::signalReadPacket(WebCore::LibWebRTCSocketIdentifier identifier, const IPC::DataReference& data, const RTCNetwork::IPAddress& address, uint16_t port, int64_t timestamp)
94	{
95	if (auto* socket = m_socketFactory.socket(identifier))
96	socket->signalReadPacket(data.data(), data.size(), rtc::SocketAddress(address.value, port), timestamp);
97	}
98
99	void LibWebRTCNetwork::signalSentPacket(WebCore::LibWebRTCSocketIdentifier identifier, int rtcPacketID, int64_t sendTimeMs)
100	{
101	if (auto* socket = m_socketFactory.socket(identifier))
102	socket->signalSentPacket(rtcPacketID, sendTimeMs);
103	}
104
105	void LibWebRTCNetwork::signalConnect(WebCore::LibWebRTCSocketIdentifier identifier)
106	{
107	if (auto* socket = m_socketFactory.socket(identifier))
108	socket->signalConnect();
109	}
110
111	void LibWebRTCNetwork::signalClose(WebCore::LibWebRTCSocketIdentifier identifier, int error)
112	{
113	if (auto* socket = m_socketFactory.socket(identifier))
114	socket->signalClose(error);
115	}
116
117	void LibWebRTCNetwork::signalNewConnection(WebCore::LibWebRTCSocketIdentifier identifier, WebCore::LibWebRTCSocketIdentifier newSocketIdentifier, const RTCNetwork::SocketAddress& remoteAddress)
118	{
119	if (auto* socket = m_socketFactory.socket(identifier))
120	socket->signalNewConnection(m_socketFactory.createNewConnectionSocket(*socket, newSocketIdentifier, remoteAddress.value));
121	}
122	#endif
123
124	} // namespace WebKit

Lines 25-59 a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCNetwork.h_sec1
- a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCNetwork.h -23 / +20 lines
25		25
26	#pragma once	26	#pragma once
27		27
28	#if USE(LIBWEBRTC)	28	#include "Connection.h"
29	#include "LibWebRTCProvider.h"	29	#include "LibWebRTCProvider.h"
30	#include "LibWebRTCSocketFactory.h"	30	#include "LibWebRTCSocketFactory.h"
		31	#include "WebMDNSRegister.h"
31	#include "WebRTCMonitor.h"	32	#include "WebRTCMonitor.h"
32	#include "WebRTCResolver.h"	33	#include "WebRTCResolver.h"
33	#include "WebRTCSocket.h"
34	#endif
35
36	#include "WebMDNSRegister.h"
37	#include <WebCore/LibWebRTCSocketIdentifier.h>	34	#include <WebCore/LibWebRTCSocketIdentifier.h>
38		35
39	namespace WebKit {	36	namespace WebKit {
40		37
41	class LibWebRTCNetwork {	38	class LibWebRTCNetwork : public IPC::Connection::ThreadMessageReceiver {
42	WTF_MAKE_FAST_ALLOCATED;	39	WTF_MAKE_FAST_ALLOCATED;
43	public:	40	public:
44	LibWebRTCNetwork() = default;	41	LibWebRTCNetwork() = default;
		42	~LibWebRTCNetwork();
45		43
		44	void setConnection(RefPtr<IPC::Connection>&&);
46	void networkProcessCrashed();	45	void networkProcessCrashed();
47		46
48	bool isActive() const;	47	bool isActive() const;
49		48
		49	void didReceiveMessage(IPC::Connection&, IPC::Decoder&);
		50
50	#if USE(LIBWEBRTC)	51	#if USE(LIBWEBRTC)
51	WebRTCMonitor& monitor() { return m_webNetworkMonitor; }	52	WebRTCMonitor& monitor() { return m_webNetworkMonitor; }
52	LibWebRTCSocketFactory& socketFactory() { return m_socketFactory; }	53	LibWebRTCSocketFactory& socketFactory() { return m_socketFactory; }
53		54
54	void disableNonLocalhostConnections() { socketFactory().disableNonLocalhostConnections(); }	55	void disableNonLocalhostConnections() { socketFactory().disableNonLocalhostConnections(); }
55		56
56	WebRTCSocket socket(WebCore::LibWebRTCSocketIdentifier identifier) { return WebRTCSocket(socketFactory(), identifier); }
57	WebRTCResolver resolver(LibWebRTCResolverIdentifier identifier) { return WebRTCResolver(socketFactory(), identifier); }	57	WebRTCResolver resolver(LibWebRTCResolverIdentifier identifier) { return WebRTCResolver(socketFactory(), identifier); }
58	#endif	58	#endif
59		59
Lines 62-67 public: a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCNetwork.h_sec2
62	#endif	62	#endif
63		63
64	private:	64	private:
		65	#if USE(LIBWEBRTC)
		66	void signalReadPacket(WebCore::LibWebRTCSocketIdentifier, const IPC::DataReference&, const RTCNetwork::IPAddress&, uint16_t port, int64_t);
		67	void signalSentPacket(WebCore::LibWebRTCSocketIdentifier, int, int64_t);
		68	void signalAddressReady(WebCore::LibWebRTCSocketIdentifier, const RTCNetwork::SocketAddress&);
		69	void signalConnect(WebCore::LibWebRTCSocketIdentifier);
		70	void signalClose(WebCore::LibWebRTCSocketIdentifier, int);
		71	void signalNewConnection(WebCore::LibWebRTCSocketIdentifier socketIdentifier, WebCore::LibWebRTCSocketIdentifier newSocketIdentifier, const WebKit::RTCNetwork::SocketAddress&);
		72	#endif
		73
		74	// IPC::Connection::ThreadMessageReceiver
		75	void dispatchToThread(Function<void()>&&) final;
		76
65	#if USE(LIBWEBRTC)	77	#if USE(LIBWEBRTC)
66	LibWebRTCSocketFactory m_socketFactory;	78	LibWebRTCSocketFactory m_socketFactory;
67	WebRTCMonitor m_webNetworkMonitor;	79	WebRTCMonitor m_webNetworkMonitor;
Lines 69-90 private: a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCNetwork.h_sec3
69	#if ENABLE(WEB_RTC)	81	#if ENABLE(WEB_RTC)
70	WebMDNSRegister m_mdnsRegister;	82	WebMDNSRegister m_mdnsRegister;
71	#endif	83	#endif
		84	RefPtr<IPC::Connection> m_connection;
72	};	85	};
73		86
74	inline void LibWebRTCNetwork::networkProcessCrashed()
75	{
76	#if USE(LIBWEBRTC)
77	m_webNetworkMonitor.networkProcessCrashed();
78	#endif
79	}
80
81	inline bool LibWebRTCNetwork::isActive() const
82	{
83	#if USE(LIBWEBRTC)
84	return WebCore::LibWebRTCProvider::hasWebRTCThreads();
85	#else
86	return false;
87	#endif
88	}
89
90	} // namespace WebKit	87	} // namespace WebKit

Line 0 a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCNetwork.messages.in_sec1
- a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCNetwork.messages.in +34 lines
	1	# Copyright (C) 2017 Apple Inc. All rights reserved.
	2	#
	3	# Redistribution and use in source and binary forms, with or without
	4	# modification, are permitted provided that the following conditions
	5	# are met:
	6	# 1. Redistributions of source code must retain the above copyright
	7	# notice, this list of conditions and the following disclaimer.
	8	# 2. Redistributions in binary form must reproduce the above copyright
	9	# notice, this list of conditions and the following disclaimer in the
	10	# documentation and/or other materials provided with the distribution.
	11	#
	12	# THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' AND
	13	# ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
	14	# WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
	15	# DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS BE LIABLE FOR
	16	# ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
	17	# DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
	18	# SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
	19	# CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
	20	# OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
	21	# OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
	22
	23	#if USE(LIBWEBRTC)
	24
	25	messages -> LibWebRTCNetwork NotRefCounted {
	26	SignalReadPacket(WebCore::LibWebRTCSocketIdentifier socketIdentifier, IPC::DataReference data, WebKit::RTCNetwork::IPAddress address, uint16_t port, int64_t timestamp)
	27	SignalSentPacket(WebCore::LibWebRTCSocketIdentifier socketIdentifier, int packetSize, int64_t timestamp)
	28	SignalAddressReady(WebCore::LibWebRTCSocketIdentifier socketIdentifier, WebKit::RTCNetwork::SocketAddress address)
	29	SignalConnect(WebCore::LibWebRTCSocketIdentifier socketIdentifier)
	30	SignalClose(WebCore::LibWebRTCSocketIdentifier socketIdentifier, int error)
	31	SignalNewConnection(WebCore::LibWebRTCSocketIdentifier socketIdentifier, WebCore::LibWebRTCSocketIdentifier newSocketIdentifier, WebKit::RTCNetwork::SocketAddress remoteAddress)
	32	}
	33
	34	#endif // USE(LIBWEBRTC)

Lines 81-93 void LibWebRTCSocket::signalAddressReady(const rtc::SocketAddress& address) a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCSocket.cpp_sec1
- a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCSocket.cpp -2 / +2 lines
81	SignalAddressReady(this, m_localAddress);	81	SignalAddressReady(this, m_localAddress);
82	}	82	}
83		83
84	void LibWebRTCSocket::signalReadPacket(const WebCore::SharedBuffer& buffer, rtc::SocketAddress&& address, int64_t timestamp)	84	void LibWebRTCSocket::signalReadPacket(const uint8_t* data, size_t size, rtc::SocketAddress&& address, int64_t timestamp)
85	{	85	{
86	if (m_isSuspended)	86	if (m_isSuspended)
87	return;	87	return;
88		88
89	m_remoteAddress = WTFMove(address);	89	m_remoteAddress = WTFMove(address);
90	SignalReadPacket(this, buffer.data(), buffer.size(), m_remoteAddress, timestamp);	90	SignalReadPacket(this, reinterpret_cast<const char*>(data), size, m_remoteAddress, timestamp);
91	}	91	}
92		92
93	void LibWebRTCSocket::signalSentPacket(int rtcPacketID, int64_t sendTimeMs)	93	void LibWebRTCSocket::signalSentPacket(int rtcPacketID, int64_t sendTimeMs)

Lines 39-48 class DataReference; a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCSocket.h_sec1
- a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCSocket.h -6 / +2 lines
39	class Decoder;	39	class Decoder;
40	}	40	}
41		41
42	namespace WebCore {
43	class SharedBuffer;
44	}
45
46	namespace WebKit {	42	namespace WebKit {
47		43
48	class LibWebRTCSocketFactory;	44	class LibWebRTCSocketFactory;
Lines 69-76 public: a/Source/WebKit/WebProcess/Network/webrtc/LibWebRTCSocket.h_sec2
69	private:	65	private:
70	bool willSend(size_t);	66	bool willSend(size_t);
71		67
72	friend class WebRTCSocket;	68	friend class LibWebRTCNetwork;
73	void signalReadPacket(const WebCore::SharedBuffer&, rtc::SocketAddress&&, int64_t);	69	void signalReadPacket(const uint8_t*, size_t, rtc::SocketAddress&&, int64_t);
74	void signalSentPacket(int, int64_t);	70	void signalSentPacket(int, int64_t);
75	void signalAddressReady(const rtc::SocketAddress&);	71	void signalAddressReady(const rtc::SocketAddress&);
76	void signalConnect();	72	void signalConnect();

Lines 1-103 a/Source/WebKit/WebProcess/Network/webrtc/WebRTCSocket.cpp_sec1
- a/Source/WebKit/WebProcess/Network/webrtc/WebRTCSocket.cpp -103 lines
1	/*
2	* Copyright (C) 2017 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 "WebRTCSocket.h"
28
29	#if USE(LIBWEBRTC)
30
31	#include "DataReference.h"
32	#include "LibWebRTCSocket.h"
33	#include "LibWebRTCSocketFactory.h"
34	#include "NetworkRTCSocketMessages.h"
35	#include <WebCore/SharedBuffer.h>
36	#include <wtf/Function.h>
37
38	namespace WebKit {
39	using namespace WebCore;
40
41	void WebRTCSocket::signalOnNetworkThread(LibWebRTCSocketFactory& factory, LibWebRTCSocketIdentifier identifier, Function<void(LibWebRTCSocket&)>&& callback)
42	{
43	// factory is staying valid during the process lifetime.
44	WebCore::LibWebRTCProvider::callOnWebRTCNetworkThread([&factory, identifier, callback = WTFMove(callback)]() {
45	auto* socket = factory.socket(identifier);
46	if (!socket)
47	return;
48	callback(*socket);
49	});
50	}
51
52	WebRTCSocket::WebRTCSocket(LibWebRTCSocketFactory& factory, LibWebRTCSocketIdentifier identifier)
53	: m_factory(factory)
54	, m_identifier(identifier)
55	{
56	}
57
58	void WebRTCSocket::signalAddressReady(const RTCNetwork::SocketAddress& address)
59	{
60	signalOnNetworkThread(m_factory, m_identifier, [address](LibWebRTCSocket& socket) {
61	socket.signalAddressReady(address.value);
62	});
63	}
64
65	void WebRTCSocket::signalReadPacket(const IPC::DataReference& data, const RTCNetwork::IPAddress& address, uint16_t port, int64_t timestamp)
66	{
67	auto buffer = WebCore::SharedBuffer::create(data.data(), data.size());
68	signalOnNetworkThread(m_factory, m_identifier, [buffer = WTFMove(buffer), address, port, timestamp](LibWebRTCSocket& socket) {
69	socket.signalReadPacket(buffer.get(), rtc::SocketAddress(address.value, port), timestamp);
70	});
71	}
72
73	void WebRTCSocket::signalSentPacket(int rtcPacketID, int64_t sendTimeMs)
74	{
75	signalOnNetworkThread(m_factory, m_identifier, [rtcPacketID, sendTimeMs](auto& socket) {
76	socket.signalSentPacket(rtcPacketID, sendTimeMs);
77	});
78	}
79
80	void WebRTCSocket::signalConnect()
81	{
82	signalOnNetworkThread(m_factory, m_identifier, [](auto& socket) {
83	socket.signalConnect();
84	});
85	}
86
87	void WebRTCSocket::signalClose(int error)
88	{
89	signalOnNetworkThread(m_factory, m_identifier, [error](auto& socket) {
90	socket.signalClose(error);
91	});
92	}
93
94	void WebRTCSocket::signalNewConnection(LibWebRTCSocketIdentifier newSocketIdentifier, const RTCNetwork::SocketAddress& remoteAddress)
95	{
96	signalOnNetworkThread(m_factory, m_identifier, [newSocketIdentifier, remoteAddress = RTCNetwork::isolatedCopy(remoteAddress.value)](auto& socket) {
97	socket.signalNewConnection(socket.m_factory.createNewConnectionSocket(socket, newSocketIdentifier, remoteAddress));
98	});
99	}
100
101	} // namespace WebKit
102
103	#endif // USE(LIBWEBRTC)