Magic-Mirror/gecko-dev
1
0
Fork 0
mirror of https://github.com/mozilla/gecko-dev.git synced 2024-12-01 00:32:11 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Bug 1660555 - Move the runnable into |WorkerSignalFollower|. r=smaug

Browse Source 
Differential Revision: https://phabricator.services.mozilla.com/D93890
This commit is contained in:
Jeff Walden 2020-10-30 20:17:21 +00:00
parent fda30fa995
commit 160ae8c196
1 changed files with 19 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
dom/fetch/Fetch.cpp
View File

@ -108,7 +108,23 @@ NS_INTERFACE_MAP_END
NS_IMPL_CYCLE_COLLECTING_ADDREF(AbortSignalMainThread)
NS_IMPL_CYCLE_COLLECTING_RELEASE(AbortSignalMainThread)
class AbortSignalProxy;
class WorkerSignalFollower final : public nsISupports {
public:
// This runnable propagates changes from the AbortSignalImpl on workers to the
// AbortSignalImpl on main-thread.
class AbortSignalProxyRunnable final : public Runnable {
RefPtr<AbortSignalProxy> mProxy;
public:
explicit AbortSignalProxyRunnable(AbortSignalProxy* aProxy)
: Runnable("dom::WorkerSignalFollower::AbortSignalProxyRunnable"),
mProxy(aProxy) {}
NS_IMETHOD Run() override;
};
public:
NS_DECL_CYCLE_COLLECTING_ISUPPORTS
NS_DECL_CYCLE_COLLECTION_CLASS(WorkerSignalFollower)
@ -147,19 +163,6 @@ class AbortSignalProxy final : public AbortFollower {
// AbortSignal.
const bool mAborted;
// This runnable propagates changes from the AbortSignalImpl on workers to the
// AbortSignalImpl on main-thread.
class AbortSignalProxyRunnable final : public Runnable {
RefPtr<AbortSignalProxy> mProxy;
public:
explicit AbortSignalProxyRunnable(AbortSignalProxy* aProxy)
: Runnable("dom::AbortSignalProxy::AbortSignalProxyRunnable"),
mProxy(aProxy) {}
NS_IMETHOD Run() override;
};
public:
NS_DECL_THREADSAFE_ISUPPORTS
@ -204,7 +207,7 @@ class AbortSignalProxy final : public AbortFollower {
NS_IMPL_ISUPPORTS0(AbortSignalProxy)
NS_IMETHODIMP AbortSignalProxy::AbortSignalProxyRunnable::Run() {
NS_IMETHODIMP WorkerSignalFollower::AbortSignalProxyRunnable::Run() {
MOZ_ASSERT(NS_IsMainThread());
AbortSignalImpl* signalImpl = mProxy->GetOrCreateSignalImplForMainThread();
signalImpl->SignalAbort();
@ -213,6 +216,8 @@ NS_IMETHODIMP AbortSignalProxy::AbortSignalProxyRunnable::Run() {
void AbortSignalProxy::RunAbortAlgorithm() {
MOZ_ASSERT(!NS_IsMainThread());
using AbortSignalProxyRunnable =
WorkerSignalFollower::AbortSignalProxyRunnable;
RefPtr<AbortSignalProxyRunnable> runnable =
new AbortSignalProxyRunnable(this);
MainThreadEventTarget()->Dispatch(runnable.forget(), NS_DISPATCH_NORMAL);