LibWebRTCResolver.cpp [plain text]
#include "config.h"
#include "LibWebRTCResolver.h"
#if USE(LIBWEBRTC)
#include "LibWebRTCNetwork.h"
#include "NetworkProcessConnection.h"
#include "NetworkRTCProviderMessages.h"
#include "WebProcess.h"
#include <wtf/MainThread.h>
namespace WebKit {
static inline void sendOnMainThread(Function<void(IPC::Connection&)>&& callback)
{
callOnMainThread([callback = WTFMove(callback)]() {
callback(WebProcess::singleton().ensureNetworkProcessConnection().connection());
});
}
void LibWebRTCResolver::Start(const rtc::SocketAddress& address)
{
m_isResolving = true;
m_addressToResolve = address;
m_port = address.port();
auto identifier = m_identifier;
sendOnMainThread([identifier, address](IPC::Connection& connection) {
auto addressString = address.HostAsURIString();
connection.send(Messages::NetworkRTCProvider::CreateResolver(identifier, String(addressString.data(), addressString.length())), 0);
});
}
bool LibWebRTCResolver::GetResolvedAddress(int family, rtc::SocketAddress* address) const
{
ASSERT(address);
if (m_error || !m_addresses.size())
return false;
*address = m_addressToResolve;
for (auto& ipAddress : m_addresses) {
if (family == ipAddress.family()) {
address->SetResolvedIP(ipAddress);
address->SetPort(m_port);
return true;
}
}
return false;
}
void LibWebRTCResolver::Destroy(bool)
{
if (!isResolving())
return;
auto identifier = m_identifier;
sendOnMainThread([identifier](IPC::Connection& connection) {
connection.send(Messages::NetworkRTCProvider::StopResolver(identifier), 0);
});
auto resolver = WebProcess::singleton().libWebRTCNetwork().socketFactory().takeResolver(m_identifier);
ASSERT(resolver);
}
void LibWebRTCResolver::setResolvedAddress(const Vector<rtc::IPAddress>& addresses)
{
m_addresses = addresses;
SignalDone(this);
}
void LibWebRTCResolver::setError(int error)
{
m_error = error;
SignalDone(this);
}
}
#endif // USE(LIBWEBRTC)