blob: 470ff73a27a1e2901bf703cd66bc44a2c17b5b2b (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
/* -*- 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 "VsyncWorkerChild.h"
#include "mozilla/dom/WorkerPrivate.h"
#include "mozilla/dom/WorkerRef.h"
#include "mozilla/dom/WorkerScope.h"
namespace mozilla::dom {
VsyncWorkerChild::VsyncWorkerChild() = default;
VsyncWorkerChild::~VsyncWorkerChild() = default;
bool VsyncWorkerChild::Initialize(WorkerPrivate* aWorkerPrivate) {
MOZ_ASSERT(aWorkerPrivate);
MOZ_ASSERT(!mWorkerRef);
mWorkerRef =
IPCWorkerRef::Create(aWorkerPrivate, "VsyncWorkerChild",
[self = RefPtr{this}]() { self->Destroy(); });
return !!mWorkerRef;
}
void VsyncWorkerChild::Destroy() {
MOZ_ASSERT_IF(!CanSend(), !mWorkerRef);
MOZ_ASSERT_IF(!CanSend(), !mObserving);
Send__delete__(this);
MOZ_ASSERT(!mWorkerRef);
MOZ_ASSERT(!mObserving);
}
void VsyncWorkerChild::TryObserve() {
if (CanSend() && !mObserving) {
mObserving = SendObserve();
}
}
void VsyncWorkerChild::TryUnobserve() {
if (CanSend() && mObserving) {
mObserving = !SendUnobserve();
}
}
mozilla::ipc::IPCResult VsyncWorkerChild::RecvNotify(const VsyncEvent& aVsync,
const float& aVsyncRate) {
// For MOZ_CAN_RUN_SCRIPT_BOUNDARY purposes: We know IPDL is explicitly
// keeping our actor alive until it is done processing the messages. We know
// that the WorkerGlobalScope callee is responsible keeping itself alive
// during the OnVsync callback.
WorkerPrivate* workerPrivate = mWorkerRef->Private();
WorkerGlobalScope* scope = workerPrivate->GlobalScope();
if (scope) {
scope->OnVsync(aVsync);
}
return IPC_OK();
}
void VsyncWorkerChild::ActorDestroy(ActorDestroyReason aActorDestroyReason) {
mWorkerRef = nullptr;
mObserving = false;
}
} // namespace mozilla::dom
|
