|
Packit |
f0b94e |
/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
|
|
Packit |
f0b94e |
/* vim: set ts=8 sts=2 et sw=2 tw=80: */
|
|
Packit |
f0b94e |
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
Packit |
f0b94e |
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
Packit |
f0b94e |
* You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
#include "TCPSocketParent.h"
|
|
Packit |
f0b94e |
#include "jsapi.h"
|
|
Packit |
f0b94e |
#include "jsfriendapi.h"
|
|
Packit |
f0b94e |
#include "nsJSUtils.h"
|
|
Packit |
f0b94e |
#include "mozilla/Unused.h"
|
|
Packit |
f0b94e |
#include "mozilla/net/NeckoCommon.h"
|
|
Packit |
f0b94e |
#include "mozilla/net/PNeckoParent.h"
|
|
Packit |
f0b94e |
#include "mozilla/dom/ContentParent.h"
|
|
Packit |
f0b94e |
#include "mozilla/dom/ScriptSettings.h"
|
|
Packit |
f0b94e |
#include "mozilla/dom/TabParent.h"
|
|
Packit |
f0b94e |
#include "mozilla/HoldDropJSObjects.h"
|
|
Packit |
f0b94e |
#include "nsISocketTransportService.h"
|
|
Packit |
f0b94e |
#include "nsISocketTransport.h"
|
|
Packit |
f0b94e |
#include "nsIScriptSecurityManager.h"
|
|
Packit |
f0b94e |
#include "nsNetUtil.h"
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
namespace IPC {
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
// Defined in TCPSocketChild.cpp
|
|
Packit |
f0b94e |
extern bool DeserializeArrayBuffer(JSContext* aCx,
|
|
Packit |
f0b94e |
const InfallibleTArray<uint8_t>& aBuffer,
|
|
Packit |
f0b94e |
JS::MutableHandle<JS::Value> aVal);
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
} // namespace IPC
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
namespace mozilla {
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
namespace net {
|
|
Packit |
f0b94e |
//
|
|
Packit |
f0b94e |
// set MOZ_LOG=TCPSocket:5
|
|
Packit |
f0b94e |
//
|
|
Packit |
f0b94e |
extern LazyLogModule gTCPSocketLog;
|
|
Packit |
f0b94e |
#define TCPSOCKET_LOG(args) MOZ_LOG(gTCPSocketLog, LogLevel::Debug, args)
|
|
Packit |
f0b94e |
#define TCPSOCKET_LOG_ENABLED() MOZ_LOG_TEST(gTCPSocketLog, LogLevel::Debug)
|
|
Packit |
f0b94e |
} // namespace net
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
namespace dom {
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
static void FireInteralError(mozilla::net::PTCPSocketParent* aActor,
|
|
Packit |
f0b94e |
uint32_t aLineNo) {
|
|
Packit |
f0b94e |
mozilla::Unused << aActor->SendCallback(
|
|
Packit |
f0b94e |
NS_LITERAL_STRING("onerror"),
|
|
Packit |
f0b94e |
TCPError(NS_LITERAL_STRING("InvalidStateError"),
|
|
Packit |
f0b94e |
NS_LITERAL_STRING("Internal error")),
|
|
Packit |
f0b94e |
static_cast<uint32_t>(TCPReadyState::Connecting));
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
NS_INTERFACE_MAP_BEGIN_CYCLE_COLLECTION(TCPSocketParentBase)
|
|
Packit |
f0b94e |
NS_INTERFACE_MAP_ENTRY(nsISupports)
|
|
Packit |
f0b94e |
NS_INTERFACE_MAP_END
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
NS_IMPL_CYCLE_COLLECTION(TCPSocketParentBase, mSocket)
|
|
Packit |
f0b94e |
NS_IMPL_CYCLE_COLLECTING_ADDREF(TCPSocketParentBase)
|
|
Packit |
f0b94e |
NS_IMPL_CYCLE_COLLECTING_RELEASE(TCPSocketParentBase)
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
TCPSocketParentBase::TCPSocketParentBase() : mIPCOpen(false) {}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
TCPSocketParentBase::~TCPSocketParentBase() {}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParentBase::ReleaseIPDLReference() {
|
|
Packit |
f0b94e |
MOZ_ASSERT(mIPCOpen);
|
|
Packit |
f0b94e |
mIPCOpen = false;
|
|
Packit |
f0b94e |
this->Release();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParentBase::AddIPDLReference() {
|
|
Packit |
f0b94e |
MOZ_ASSERT(!mIPCOpen);
|
|
Packit |
f0b94e |
mIPCOpen = true;
|
|
Packit |
f0b94e |
this->AddRef();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
NS_IMETHODIMP_(MozExternalRefCountType) TCPSocketParent::Release(void) {
|
|
Packit |
f0b94e |
nsrefcnt refcnt = TCPSocketParentBase::Release();
|
|
Packit |
f0b94e |
if (refcnt == 1 && mIPCOpen) {
|
|
Packit |
f0b94e |
mozilla::Unused << PTCPSocketParent::SendRequestDelete();
|
|
Packit |
f0b94e |
return 1;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
return refcnt;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::ipc::IPCResult TCPSocketParent::RecvOpen(
|
|
Packit |
f0b94e |
const nsString& aHost, const uint16_t& aPort, const bool& aUseSSL,
|
|
Packit |
f0b94e |
const bool& aUseArrayBuffers) {
|
|
Packit |
f0b94e |
mSocket = new TCPSocket(nullptr, aHost, aPort, aUseSSL, aUseArrayBuffers);
|
|
Packit |
f0b94e |
mSocket->SetSocketBridgeParent(this);
|
|
Packit |
f0b94e |
NS_ENSURE_SUCCESS(mSocket->Init(), IPC_OK());
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::ipc::IPCResult TCPSocketParent::RecvOpenBind(
|
|
Packit |
f0b94e |
const nsCString& aRemoteHost, const uint16_t& aRemotePort,
|
|
Packit |
f0b94e |
const nsCString& aLocalAddr, const uint16_t& aLocalPort,
|
|
Packit |
f0b94e |
const bool& aUseSSL, const bool& aReuseAddrPort,
|
|
Packit |
f0b94e |
const bool& aUseArrayBuffers, const nsCString& aFilter) {
|
|
Packit |
f0b94e |
nsresult rv;
|
|
Packit |
f0b94e |
nsCOMPtr<nsISocketTransportService> sts =
|
|
Packit |
f0b94e |
do_GetService("@mozilla.org/network/socket-transport-service;1", &rv;;
|
|
Packit |
f0b94e |
if (NS_FAILED(rv)) {
|
|
Packit |
f0b94e |
FireInteralError(this, __LINE__);
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
nsCOMPtr<nsISocketTransport> socketTransport;
|
|
Packit |
f0b94e |
if (aUseSSL) {
|
|
Packit |
f0b94e |
const char* socketTypes[1];
|
|
Packit |
f0b94e |
socketTypes[0] = "ssl";
|
|
Packit |
f0b94e |
rv = sts->CreateTransport(socketTypes, 1, aRemoteHost, aRemotePort, nullptr,
|
|
Packit |
f0b94e |
getter_AddRefs(socketTransport));
|
|
Packit |
f0b94e |
} else {
|
|
Packit |
f0b94e |
rv = sts->CreateTransport(nullptr, 0, aRemoteHost, aRemotePort, nullptr,
|
|
Packit |
f0b94e |
getter_AddRefs(socketTransport));
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
if (NS_FAILED(rv)) {
|
|
Packit |
f0b94e |
FireInteralError(this, __LINE__);
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
// in most cases aReuseAddrPort is false, but ICE TCP needs
|
|
Packit |
f0b94e |
// sockets options set that allow addr/port reuse
|
|
Packit |
f0b94e |
socketTransport->SetReuseAddrPort(aReuseAddrPort);
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
PRNetAddr prAddr;
|
|
Packit |
f0b94e |
if (PR_SUCCESS != PR_InitializeNetAddr(PR_IpAddrAny, aLocalPort, &prAddr)) {
|
|
Packit |
f0b94e |
FireInteralError(this, __LINE__);
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
if (PR_SUCCESS != PR_StringToNetAddr(aLocalAddr.BeginReading(), &prAddr)) {
|
|
Packit |
f0b94e |
FireInteralError(this, __LINE__);
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::net::NetAddr addr;
|
|
Packit |
f0b94e |
PRNetAddrToNetAddr(&prAddr, &addr);
|
|
Packit |
f0b94e |
rv = socketTransport->Bind(&addr);
|
|
Packit |
f0b94e |
if (NS_FAILED(rv)) {
|
|
Packit |
f0b94e |
FireInteralError(this, __LINE__);
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
if (!aFilter.IsEmpty()) {
|
|
Packit |
f0b94e |
nsAutoCString contractId(NS_NETWORK_TCP_SOCKET_FILTER_HANDLER_PREFIX);
|
|
Packit |
f0b94e |
contractId.Append(aFilter);
|
|
Packit |
f0b94e |
nsCOMPtr<nsISocketFilterHandler> filterHandler =
|
|
Packit |
f0b94e |
do_GetService(contractId.get());
|
|
Packit |
f0b94e |
if (!filterHandler) {
|
|
Packit |
f0b94e |
NS_ERROR("Content doesn't have a valid filter");
|
|
Packit |
f0b94e |
FireInteralError(this, __LINE__);
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
rv = filterHandler->NewFilter(getter_AddRefs(mFilter));
|
|
Packit |
f0b94e |
if (NS_FAILED(rv)) {
|
|
Packit |
f0b94e |
NS_ERROR("Cannot create filter that content specified");
|
|
Packit |
f0b94e |
FireInteralError(this, __LINE__);
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mSocket = new TCPSocket(nullptr, NS_ConvertUTF8toUTF16(aRemoteHost),
|
|
Packit |
f0b94e |
aRemotePort, aUseSSL, aUseArrayBuffers);
|
|
Packit |
f0b94e |
mSocket->SetSocketBridgeParent(this);
|
|
Packit |
f0b94e |
rv = mSocket->InitWithUnconnectedTransport(socketTransport);
|
|
Packit |
f0b94e |
NS_ENSURE_SUCCESS(rv, IPC_OK());
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::ipc::IPCResult TCPSocketParent::RecvStartTLS() {
|
|
Packit |
f0b94e |
NS_ENSURE_TRUE(mSocket, IPC_OK());
|
|
Packit |
f0b94e |
ErrorResult rv;
|
|
Packit |
f0b94e |
mSocket->UpgradeToSecure(rv);
|
|
Packit |
f0b94e |
if (NS_WARN_IF(rv.Failed())) {
|
|
Packit |
f0b94e |
rv.SuppressException();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::ipc::IPCResult TCPSocketParent::RecvSuspend() {
|
|
Packit |
f0b94e |
NS_ENSURE_TRUE(mSocket, IPC_OK());
|
|
Packit |
f0b94e |
mSocket->Suspend();
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::ipc::IPCResult TCPSocketParent::RecvResume() {
|
|
Packit |
f0b94e |
NS_ENSURE_TRUE(mSocket, IPC_OK());
|
|
Packit |
f0b94e |
ErrorResult rv;
|
|
Packit |
f0b94e |
mSocket->Resume(rv);
|
|
Packit |
f0b94e |
if (NS_WARN_IF(rv.Failed())) {
|
|
Packit |
f0b94e |
rv.SuppressException();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::ipc::IPCResult TCPSocketParent::RecvData(
|
|
Packit |
f0b94e |
const SendableData& aData, const uint32_t& aTrackingNumber) {
|
|
Packit |
f0b94e |
ErrorResult rv;
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
if (mFilter) {
|
|
Packit |
f0b94e |
mozilla::net::NetAddr addr; // dummy value
|
|
Packit |
f0b94e |
bool allowed;
|
|
Packit |
f0b94e |
MOZ_ASSERT(aData.type() == SendableData::TArrayOfuint8_t,
|
|
Packit |
f0b94e |
"Unsupported data type for filtering");
|
|
Packit |
f0b94e |
const InfallibleTArray<uint8_t>& data(aData.get_ArrayOfuint8_t());
|
|
Packit |
f0b94e |
nsresult nsrv =
|
|
Packit |
f0b94e |
mFilter->FilterPacket(&addr, data.Elements(), data.Length(),
|
|
Packit |
f0b94e |
nsISocketFilter::SF_OUTGOING, &allowed);
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
// Reject sending of unallowed data
|
|
Packit |
f0b94e |
if (NS_WARN_IF(NS_FAILED(nsrv)) || !allowed) {
|
|
Packit |
f0b94e |
TCPSOCKET_LOG(("%s: Dropping outgoing TCP packet", __FUNCTION__));
|
|
Packit |
f0b94e |
return IPC_FAIL_NO_REASON(this);
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
switch (aData.type()) {
|
|
Packit |
f0b94e |
case SendableData::TArrayOfuint8_t: {
|
|
Packit |
f0b94e |
AutoSafeJSContext autoCx;
|
|
Packit |
f0b94e |
JS::Rooted<JS::Value> val(autoCx);
|
|
Packit |
f0b94e |
const nsTArray<uint8_t>& buffer = aData.get_ArrayOfuint8_t();
|
|
Packit |
f0b94e |
bool ok = IPC::DeserializeArrayBuffer(autoCx, buffer, &val;;
|
|
Packit |
f0b94e |
NS_ENSURE_TRUE(ok, IPC_OK());
|
|
Packit |
f0b94e |
RootedSpiderMonkeyInterface<ArrayBuffer> data(autoCx);
|
|
Packit |
f0b94e |
data.Init(&val.toObject());
|
|
Packit |
f0b94e |
Optional<uint32_t> byteLength(buffer.Length());
|
|
Packit |
f0b94e |
mSocket->SendWithTrackingNumber(autoCx, data, 0, byteLength,
|
|
Packit |
f0b94e |
aTrackingNumber, rv);
|
|
Packit |
f0b94e |
break;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
case SendableData::TnsCString: {
|
|
Packit |
f0b94e |
const nsCString& strData = aData.get_nsCString();
|
|
Packit |
f0b94e |
mSocket->SendWithTrackingNumber(strData, aTrackingNumber, rv);
|
|
Packit |
f0b94e |
break;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
default:
|
|
Packit |
f0b94e |
MOZ_CRASH("unexpected SendableData type");
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
NS_ENSURE_SUCCESS(rv.StealNSResult(), IPC_OK());
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::ipc::IPCResult TCPSocketParent::RecvClose() {
|
|
Packit |
f0b94e |
NS_ENSURE_TRUE(mSocket, IPC_OK());
|
|
Packit |
f0b94e |
mSocket->Close();
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParent::FireErrorEvent(const nsAString& aName,
|
|
Packit |
f0b94e |
const nsAString& aType,
|
|
Packit |
f0b94e |
TCPReadyState aReadyState) {
|
|
Packit |
f0b94e |
SendEvent(NS_LITERAL_STRING("error"),
|
|
Packit |
f0b94e |
TCPError(nsString(aName), nsString(aType)), aReadyState);
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParent::FireEvent(const nsAString& aType,
|
|
Packit |
f0b94e |
TCPReadyState aReadyState) {
|
|
Packit |
f0b94e |
return SendEvent(aType, mozilla::void_t(), aReadyState);
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParent::FireArrayBufferDataEvent(nsTArray<uint8_t>& aBuffer,
|
|
Packit |
f0b94e |
TCPReadyState aReadyState) {
|
|
Packit |
f0b94e |
InfallibleTArray<uint8_t> arr;
|
|
Packit |
f0b94e |
arr.SwapElements(aBuffer);
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
if (mFilter) {
|
|
Packit |
f0b94e |
bool allowed;
|
|
Packit |
f0b94e |
mozilla::net::NetAddr addr;
|
|
Packit |
f0b94e |
nsresult nsrv =
|
|
Packit |
f0b94e |
mFilter->FilterPacket(&addr, arr.Elements(), arr.Length(),
|
|
Packit |
f0b94e |
nsISocketFilter::SF_INCOMING, &allowed);
|
|
Packit |
f0b94e |
// receiving unallowed data, drop it.
|
|
Packit |
f0b94e |
if (NS_WARN_IF(NS_FAILED(nsrv)) || !allowed) {
|
|
Packit |
f0b94e |
TCPSOCKET_LOG(("%s: Dropping incoming TCP packet", __FUNCTION__));
|
|
Packit |
f0b94e |
return;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
SendableData data(arr);
|
|
Packit |
f0b94e |
SendEvent(NS_LITERAL_STRING("data"), data, aReadyState);
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParent::FireStringDataEvent(const nsACString& aData,
|
|
Packit |
f0b94e |
TCPReadyState aReadyState) {
|
|
Packit |
f0b94e |
SendableData data((nsCString(aData)));
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
MOZ_ASSERT(!mFilter, "Socket filtering doesn't support nsCString");
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
SendEvent(NS_LITERAL_STRING("data"), data, aReadyState);
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParent::SendEvent(const nsAString& aType, CallbackData aData,
|
|
Packit |
f0b94e |
TCPReadyState aReadyState) {
|
|
Packit |
f0b94e |
if (mIPCOpen) {
|
|
Packit |
f0b94e |
mozilla::Unused << PTCPSocketParent::SendCallback(
|
|
Packit |
f0b94e |
nsString(aType), aData, static_cast<uint32_t>(aReadyState));
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParent::SetSocket(TCPSocket* socket) { mSocket = socket; }
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
nsresult TCPSocketParent::GetHost(nsAString& aHost) {
|
|
Packit |
f0b94e |
if (!mSocket) {
|
|
Packit |
f0b94e |
NS_ERROR("No internal socket instance mSocket!");
|
|
Packit |
f0b94e |
return NS_ERROR_FAILURE;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
mSocket->GetHost(aHost);
|
|
Packit |
f0b94e |
return NS_OK;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
nsresult TCPSocketParent::GetPort(uint16_t* aPort) {
|
|
Packit |
f0b94e |
if (!mSocket) {
|
|
Packit |
f0b94e |
NS_ERROR("No internal socket instance mSocket!");
|
|
Packit |
f0b94e |
return NS_ERROR_FAILURE;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
*aPort = mSocket->Port();
|
|
Packit |
f0b94e |
return NS_OK;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
void TCPSocketParent::ActorDestroy(ActorDestroyReason why) {
|
|
Packit |
f0b94e |
if (mSocket) {
|
|
Packit |
f0b94e |
mSocket->Close();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
mSocket = nullptr;
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
mozilla::ipc::IPCResult TCPSocketParent::RecvRequestDelete() {
|
|
Packit |
f0b94e |
mozilla::Unused << Send__delete__(this);
|
|
Packit |
f0b94e |
return IPC_OK();
|
|
Packit |
f0b94e |
}
|
|
Packit |
f0b94e |
|
|
Packit |
f0b94e |
} // namespace dom
|
|
Packit |
f0b94e |
} // namespace mozilla
|