156 lines
3.8 KiB
C++
156 lines
3.8 KiB
C++
/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */
|
|
/* vim: set ts=8 sts=2 et sw=2 tw=80: */
|
|
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
#include "RemoteWorkerParent.h"
|
|
#include "RemoteWorkerController.h"
|
|
#include "RemoteWorkerServiceParent.h"
|
|
#include "mozilla/dom/ContentParent.h"
|
|
#include "mozilla/dom/PFetchEventOpProxyParent.h"
|
|
#include "mozilla/ipc/BackgroundParent.h"
|
|
#include "mozilla/Unused.h"
|
|
|
|
namespace mozilla {
|
|
|
|
using namespace ipc;
|
|
|
|
namespace dom {
|
|
|
|
RemoteWorkerParent::RemoteWorkerParent(
|
|
UniqueThreadsafeContentParentKeepAlive aKeepAlive)
|
|
: mContentParentKeepAlive(std::move(aKeepAlive)) {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
}
|
|
|
|
RemoteWorkerParent::~RemoteWorkerParent() {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
}
|
|
|
|
RemoteWorkerServiceParent* RemoteWorkerParent::Manager() const {
|
|
return static_cast<RemoteWorkerServiceParent*>(
|
|
PRemoteWorkerParent::Manager());
|
|
}
|
|
|
|
already_AddRefed<PFetchEventOpProxyParent>
|
|
RemoteWorkerParent::AllocPFetchEventOpProxyParent(
|
|
const ParentToChildServiceWorkerFetchEventOpArgs& aArgs) {
|
|
MOZ_CRASH("PFetchEventOpProxyParent actors must be manually constructed!");
|
|
return nullptr;
|
|
}
|
|
|
|
void RemoteWorkerParent::ActorDestroy(IProtocol::ActorDestroyReason) {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
|
|
mContentParentKeepAlive = nullptr;
|
|
|
|
if (mController) {
|
|
mController->NoteDeadWorkerActor();
|
|
mController = nullptr;
|
|
}
|
|
}
|
|
|
|
IPCResult RemoteWorkerParent::RecvCreated(const bool& aStatus) {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
|
|
if (!mController) {
|
|
return IPC_OK();
|
|
}
|
|
|
|
if (aStatus) {
|
|
mController->CreationSucceeded();
|
|
} else {
|
|
mController->CreationFailed();
|
|
}
|
|
|
|
return IPC_OK();
|
|
}
|
|
|
|
IPCResult RemoteWorkerParent::RecvError(const ErrorValue& aValue) {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
|
|
if (mController) {
|
|
mController->ErrorPropagation(aValue);
|
|
}
|
|
|
|
return IPC_OK();
|
|
}
|
|
|
|
IPCResult RemoteWorkerParent::RecvNotifyLock(const bool& aCreated) {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
|
|
if (mController) {
|
|
mController->NotifyLock(aCreated);
|
|
}
|
|
|
|
return IPC_OK();
|
|
}
|
|
|
|
IPCResult RemoteWorkerParent::RecvNotifyWebTransport(const bool& aCreated) {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
|
|
if (mController) {
|
|
mController->NotifyWebTransport(aCreated);
|
|
}
|
|
|
|
return IPC_OK();
|
|
}
|
|
|
|
void RemoteWorkerParent::MaybeSendDelete() {
|
|
if (mDeleteSent) {
|
|
return;
|
|
}
|
|
|
|
// For some reason, if the following two lines are swapped, ASan says there's
|
|
// a UAF...
|
|
mDeleteSent = true;
|
|
Unused << Send__delete__(this);
|
|
}
|
|
|
|
IPCResult RemoteWorkerParent::RecvClose() {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
|
|
if (mController) {
|
|
mController->WorkerTerminated();
|
|
}
|
|
|
|
MaybeSendDelete();
|
|
|
|
return IPC_OK();
|
|
}
|
|
|
|
void RemoteWorkerParent::SetController(RemoteWorkerController* aController) {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
|
|
mController = aController;
|
|
}
|
|
|
|
IPCResult RemoteWorkerParent::RecvSetServiceWorkerSkipWaitingFlag(
|
|
SetServiceWorkerSkipWaitingFlagResolver&& aResolve) {
|
|
AssertIsOnBackgroundThread();
|
|
MOZ_ASSERT(XRE_IsParentProcess());
|
|
|
|
if (mController) {
|
|
mController->SetServiceWorkerSkipWaitingFlag()->Then(
|
|
GetCurrentSerialEventTarget(), __func__,
|
|
[resolve = aResolve](bool /* unused */) { resolve(true); },
|
|
[resolve = aResolve](nsresult /* unused */) { resolve(false); });
|
|
} else {
|
|
aResolve(false);
|
|
}
|
|
|
|
return IPC_OK();
|
|
}
|
|
|
|
} // namespace dom
|
|
} // namespace mozilla
|