Source code
Revision control
Copy as Markdown
Other Tools
/* -*- 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
#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