blob: ce1eef77fac5cfa73b8b2a249d4f5ca5684ff929 (
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
/* -*- 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 "VRGPUParent.h"
#include "VRPuppetCommandBuffer.h"
#include "mozilla/ipc/Endpoint.h"
#include "mozilla/ipc/ProcessChild.h"
namespace mozilla {
namespace gfx {
using namespace ipc;
VRGPUParent::VRGPUParent(ProcessId aChildProcessId) : mClosed(false) {
MOZ_COUNT_CTOR(VRGPUParent);
MOZ_ASSERT(NS_IsMainThread());
SetOtherProcessId(aChildProcessId);
}
VRGPUParent::~VRGPUParent() { MOZ_COUNT_DTOR(VRGPUParent); }
void VRGPUParent::ActorDestroy(ActorDestroyReason aWhy) {
#if !defined(MOZ_WIDGET_ANDROID)
if (mVRService) {
mVRService->Stop();
mVRService = nullptr;
}
#endif
mClosed = true;
GetCurrentSerialEventTarget()->Dispatch(
NewRunnableMethod("gfx::VRGPUParent::DeferredDestroy", this,
&VRGPUParent::DeferredDestroy));
}
void VRGPUParent::DeferredDestroy() { mSelfRef = nullptr; }
/* static */
RefPtr<VRGPUParent> VRGPUParent::CreateForGPU(
Endpoint<PVRGPUParent>&& aEndpoint) {
RefPtr<VRGPUParent> vcp = new VRGPUParent(aEndpoint.OtherPid());
GetCurrentSerialEventTarget()->Dispatch(
NewRunnableMethod<Endpoint<PVRGPUParent>&&>("gfx::VRGPUParent::Bind", vcp,
&VRGPUParent::Bind,
std::move(aEndpoint)));
return vcp;
}
void VRGPUParent::Bind(Endpoint<PVRGPUParent>&& aEndpoint) {
if (!aEndpoint.Bind(this)) {
return;
}
mSelfRef = this;
}
mozilla::ipc::IPCResult VRGPUParent::RecvStartVRService() {
#if !defined(MOZ_WIDGET_ANDROID)
mVRService = VRService::Create();
MOZ_ASSERT(mVRService);
mVRService->Start();
#endif
return IPC_OK();
}
mozilla::ipc::IPCResult VRGPUParent::RecvStopVRService() {
#if !defined(MOZ_WIDGET_ANDROID)
if (mVRService) {
mVRService->Stop();
mVRService = nullptr;
}
#endif
return IPC_OK();
}
mozilla::ipc::IPCResult VRGPUParent::RecvPuppetReset() {
#if !defined(MOZ_WIDGET_ANDROID)
VRPuppetCommandBuffer::Get().Reset();
#endif
return IPC_OK();
}
mozilla::ipc::IPCResult VRGPUParent::RecvPuppetSubmit(
const nsTArray<uint64_t>& aBuffer) {
#if !defined(MOZ_WIDGET_ANDROID)
VRPuppetCommandBuffer::Get().Submit(aBuffer);
#endif
return IPC_OK();
}
mozilla::ipc::IPCResult VRGPUParent::RecvPuppetCheckForCompletion() {
#if !defined(MOZ_WIDGET_ANDROID)
if (VRPuppetCommandBuffer::Get().HasEnded()) {
Unused << SendNotifyPuppetComplete();
}
#endif
return IPC_OK();
}
bool VRGPUParent::IsClosed() { return mClosed; }
} // namespace gfx
} // namespace mozilla
|
