gecko-dev/dom/gamepad/ipc/GamepadEventChannelParent.cpp

133 строки
4.0 KiB
C++

/* -*- 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 "GamepadEventChannelParent.h"
#include "GamepadPlatformService.h"
#include "mozilla/dom/GamepadMonitoring.h"
#include "nsThreadUtils.h"
namespace mozilla {
namespace dom {
using namespace mozilla::ipc;
namespace {
class SendGamepadUpdateRunnable final : public Runnable {
private:
~SendGamepadUpdateRunnable() = default;
RefPtr<GamepadEventChannelParent> mParent;
GamepadChangeEvent mEvent;
public:
SendGamepadUpdateRunnable(GamepadEventChannelParent* aParent,
GamepadChangeEvent aEvent)
: Runnable("dom::SendGamepadUpdateRunnable"), mEvent(aEvent) {
MOZ_ASSERT(aParent);
mParent = aParent;
}
NS_IMETHOD Run() override {
AssertIsOnBackgroundThread();
if (mParent->HasGamepadListener()) {
Unused << mParent->SendGamepadUpdate(mEvent);
}
return NS_OK;
}
};
} // namespace
GamepadEventChannelParent::GamepadEventChannelParent()
: mHasGamepadListener(false) {
RefPtr<GamepadPlatformService> service =
GamepadPlatformService::GetParentService();
MOZ_ASSERT(service);
mBackgroundEventTarget = GetCurrentThreadEventTarget();
service->AddChannelParent(this);
}
mozilla::ipc::IPCResult GamepadEventChannelParent::RecvGamepadListenerAdded() {
AssertIsOnBackgroundThread();
MOZ_ASSERT(!mHasGamepadListener);
mHasGamepadListener = true;
StartGamepadMonitoring();
return IPC_OK();
}
mozilla::ipc::IPCResult
GamepadEventChannelParent::RecvGamepadListenerRemoved() {
AssertIsOnBackgroundThread();
MOZ_ASSERT(mHasGamepadListener);
mHasGamepadListener = false;
RefPtr<GamepadPlatformService> service =
GamepadPlatformService::GetParentService();
MOZ_ASSERT(service);
service->RemoveChannelParent(this);
Unused << Send__delete__(this);
return IPC_OK();
}
mozilla::ipc::IPCResult GamepadEventChannelParent::RecvVibrateHaptic(
const uint32_t& aControllerIdx, const uint32_t& aHapticIndex,
const double& aIntensity, const double& aDuration,
const uint32_t& aPromiseID) {
// TODO: Bug 680289, implement for standard gamepads
if (SendReplyGamepadPromise(aPromiseID)) {
return IPC_OK();
}
return IPC_FAIL(this, "SendReplyGamepadPromise fail.");
}
mozilla::ipc::IPCResult GamepadEventChannelParent::RecvStopVibrateHaptic(
const uint32_t& aControllerIdx) {
// TODO: Bug 680289, implement for standard gamepads
return IPC_OK();
}
mozilla::ipc::IPCResult GamepadEventChannelParent::RecvLightIndicatorColor(
const uint32_t& aControllerIdx, const uint32_t& aLightColorIndex,
const uint8_t& aRed, const uint8_t& aGreen, const uint8_t& aBlue,
const uint32_t& aPromiseID) {
// It may be called because IPDL child side crashed, we'll
// not receive RecvGamepadListenerRemoved in that case
if (mHasGamepadListener) {
SetGamepadLightIndicatorColor(aControllerIdx, aLightColorIndex, aRed,
aGreen, aBlue);
}
if (SendReplyGamepadPromise(aPromiseID)) {
return IPC_OK();
}
return IPC_FAIL(this, "SendReplyGamepadPromise fail.");
}
void GamepadEventChannelParent::ActorDestroy(ActorDestroyReason aWhy) {
AssertIsOnBackgroundThread();
// It may be called because IPDL child side crashed, we'll
// not receive RecvGamepadListenerRemoved in that case
if (mHasGamepadListener) {
mHasGamepadListener = false;
RefPtr<GamepadPlatformService> service =
GamepadPlatformService::GetParentService();
MOZ_ASSERT(service);
service->RemoveChannelParent(this);
}
MaybeStopGamepadMonitoring();
}
void GamepadEventChannelParent::DispatchUpdateEvent(
const GamepadChangeEvent& aEvent) {
mBackgroundEventTarget->Dispatch(new SendGamepadUpdateRunnable(this, aEvent),
NS_DISPATCH_NORMAL);
}
} // namespace dom
} // namespace mozilla