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 "SharedWorkerParent.h"
#include "SharedWorkerManager.h"
#include "SharedWorkerService.h"
#include "mozilla/dom/RemoteWorkerTypes.h"
#include "mozilla/ipc/BackgroundParent.h"
#include "mozilla/ipc/BackgroundUtils.h"
#include "mozilla/Unused.h"
namespace mozilla {
using namespace ipc;
namespace dom {
SharedWorkerParent::SharedWorkerParent()
: mBackgroundEventTarget(GetCurrentSerialEventTarget()),
mStatus(eInit),
mSuspended(false),
mFrozen(false) {
AssertIsOnBackgroundThread();
}
SharedWorkerParent::~SharedWorkerParent() = default;
void SharedWorkerParent::ActorDestroy(IProtocol::ActorDestroyReason aReason) {
AssertIsOnBackgroundThread();
if (mWorkerManagerWrapper) {
mWorkerManagerWrapper->Manager()->RemoveActor(this);
mWorkerManagerWrapper = nullptr;
}
}
void SharedWorkerParent::Initialize(
const RemoteWorkerData& aData, uint64_t aWindowID,
const MessagePortIdentifier& aPortIdentifier) {
AssertIsOnBackgroundThread();
MOZ_ASSERT(mStatus == eInit);
mWindowID = aWindowID;
mStatus = ePending;
RefPtr<SharedWorkerService> service = SharedWorkerService::GetOrCreate();
MOZ_ASSERT(service);
service->GetOrCreateWorkerManager(this, aData, aWindowID, aPortIdentifier);
}
IPCResult SharedWorkerParent::RecvClose() {
AssertIsOnBackgroundThread();
MOZ_ASSERT(mStatus == ePending || mStatus == eActive);
mStatus = eClosed;
if (mWorkerManagerWrapper) {
mWorkerManagerWrapper->Manager()->RemoveActor(this);
mWorkerManagerWrapper = nullptr;
}
Unused << Send__delete__(this);
return IPC_OK();
}
IPCResult SharedWorkerParent::RecvSuspend() {
AssertIsOnBackgroundThread();
MOZ_ASSERT(!mSuspended);
MOZ_ASSERT(mStatus == ePending || mStatus == eActive);
mSuspended = true;
if (mStatus == eActive) {
MOZ_ASSERT(mWorkerManagerWrapper);
mWorkerManagerWrapper->Manager()->UpdateSuspend();
}
return IPC_OK();
}
IPCResult SharedWorkerParent::RecvResume() {
AssertIsOnBackgroundThread();
MOZ_ASSERT(mSuspended);
MOZ_ASSERT(mStatus == ePending || mStatus == eActive);
mSuspended = false;
if (mStatus == eActive) {
MOZ_ASSERT(mWorkerManagerWrapper);
mWorkerManagerWrapper->Manager()->UpdateSuspend();
}
return IPC_OK();
}
IPCResult SharedWorkerParent::RecvFreeze() {
AssertIsOnBackgroundThread();
MOZ_ASSERT(!mFrozen);
MOZ_ASSERT(mStatus == ePending || mStatus == eActive);
mFrozen = true;
if (mStatus == eActive) {
MOZ_ASSERT(mWorkerManagerWrapper);
mWorkerManagerWrapper->Manager()->UpdateFrozen();
}
return IPC_OK();
}
IPCResult SharedWorkerParent::RecvThaw() {
AssertIsOnBackgroundThread();
MOZ_ASSERT(mFrozen);
MOZ_ASSERT(mStatus == ePending || mStatus == eActive);
mFrozen = false;
if (mStatus == eActive) {
MOZ_ASSERT(mWorkerManagerWrapper);
mWorkerManagerWrapper->Manager()->UpdateFrozen();
}
return IPC_OK();
}
void SharedWorkerParent::ManagerCreated(
already_AddRefed<SharedWorkerManagerWrapper> aWorkerManagerWrapper) {
AssertIsOnBackgroundThread();
MOZ_ASSERT(!mWorkerManagerWrapper);
MOZ_ASSERT(mStatus == ePending || mStatus == eClosed);
RefPtr<SharedWorkerManagerWrapper> wrapper = aWorkerManagerWrapper;
// Already gone.
if (mStatus == eClosed) {
wrapper->Manager()->RemoveActor(this);
return;
}
mStatus = eActive;
mWorkerManagerWrapper = wrapper;
mWorkerManagerWrapper->Manager()->UpdateFrozen();
mWorkerManagerWrapper->Manager()->UpdateSuspend();
}
void SharedWorkerParent::ErrorPropagation(nsresult aError) {
AssertIsOnBackgroundThread();
MOZ_ASSERT(NS_FAILED(aError));
MOZ_ASSERT(mStatus == ePending || mStatus == eClosed);
// Already gone.
if (mStatus == eClosed) {
return;
}
Unused << SendError(aError);
}
} // namespace dom
} // namespace mozilla