NetworkSocketStream.cpp [plain text]
#include "config.h"
#include "NetworkSocketStream.h"
#include "DataReference.h"
#include "WebSocketStreamMessages.h"
#include <WebCore/SocketStreamError.h>
#include <WebCore/SocketStreamHandleImpl.h>
using namespace WebCore;
namespace WebKit {
Ref<NetworkSocketStream> NetworkSocketStream::create(WebCore::URL&& url, PAL::SessionID sessionID, const String& credentialPartition, uint64_t identifier, IPC::Connection& connection, SourceApplicationAuditToken&& auditData)
{
return adoptRef(*new NetworkSocketStream(WTFMove(url), sessionID, credentialPartition, identifier, connection, WTFMove(auditData)));
}
NetworkSocketStream::NetworkSocketStream(URL&& url, PAL::SessionID sessionID, const String& credentialPartition, uint64_t identifier, IPC::Connection& connection, SourceApplicationAuditToken&& auditData)
: m_identifier(identifier)
, m_connection(connection)
, m_impl(SocketStreamHandleImpl::create(url, *this, sessionID, credentialPartition, WTFMove(auditData)))
{
}
void NetworkSocketStream::sendData(const IPC::DataReference& data, uint64_t identifier)
{
m_impl->platformSend(reinterpret_cast<const char *>(data.data()), data.size(), [this, protectedThis = makeRef(*this), identifier] (bool success) {
send(Messages::WebSocketStream::DidSendData(identifier, success));
});
}
void NetworkSocketStream::close()
{
m_impl->platformClose();
}
NetworkSocketStream::~NetworkSocketStream()
{
close();
}
void NetworkSocketStream::didOpenSocketStream(SocketStreamHandle& handle)
{
ASSERT_UNUSED(handle, &handle == m_impl.ptr());
send(Messages::WebSocketStream::DidOpenSocketStream());
}
void NetworkSocketStream::didCloseSocketStream(SocketStreamHandle& handle)
{
ASSERT_UNUSED(handle, &handle == m_impl.ptr());
send(Messages::WebSocketStream::DidCloseSocketStream());
}
void NetworkSocketStream::didReceiveSocketStreamData(SocketStreamHandle& handle, const char* data, size_t length)
{
ASSERT_UNUSED(handle, &handle == m_impl.ptr());
send(Messages::WebSocketStream::DidReceiveSocketStreamData(IPC::DataReference(reinterpret_cast<const uint8_t*>(data), length)));
}
void NetworkSocketStream::didFailToReceiveSocketStreamData(WebCore::SocketStreamHandle& handle)
{
ASSERT_UNUSED(handle, &handle == m_impl.ptr());
send(Messages::WebSocketStream::DidFailToReceiveSocketStreamData());
}
void NetworkSocketStream::didUpdateBufferedAmount(SocketStreamHandle& handle, size_t amount)
{
ASSERT_UNUSED(handle, &handle == m_impl.ptr());
send(Messages::WebSocketStream::DidUpdateBufferedAmount(amount));
}
void NetworkSocketStream::didFailSocketStream(SocketStreamHandle& handle, const SocketStreamError& error)
{
ASSERT_UNUSED(handle, &handle == m_impl.ptr());
send(Messages::WebSocketStream::DidFailSocketStream(error));
}
IPC::Connection* NetworkSocketStream::messageSenderConnection()
{
return &m_connection;
}
uint64_t NetworkSocketStream::messageSenderDestinationID()
{
return m_identifier;
}
}