// // Automatically generated by ipdlc. // Edit at your own risk // #include "mozilla/PRemoteDecoderParent.h" #include "gfxipc/ShadowLayerUtils.h" #include "mozilla/GfxMessageUtils.h" #include "mozilla/ProfilerLabels.h" #include "mozilla/RemoteDecoderParent.h" #include "mozilla/RemoteMediaData.h" #include "mozilla/dom/MediaIPCUtils.h" #include "mozilla/ipc/IPCCore.h" #include "mozilla/layers/LayersMessageUtils.h" #include "mozilla/layers/WebRenderMessageUtils.h" #include "mozilla/PRemoteMediaManagerParent.h" #include "ipc/IPCMessageUtils.h" #include "ipc/IPCMessageUtilsSpecializations.h" #include "nsIFile.h" #include "mozilla/ipc/Endpoint.h" #include "mozilla/ipc/ProtocolMessageUtils.h" #include "mozilla/ipc/ProtocolUtils.h" #include "mozilla/ipc/ShmemMessageUtils.h" #include "mozilla/ipc/TaintingIPCUtils.h" namespace mozilla { auto PRemoteDecoderParent::Recv__delete__() -> mozilla::ipc::IPCResult { return IPC_OK(); } MOZ_IMPLICIT PRemoteDecoderParent::PRemoteDecoderParent() : mozilla::ipc::IRefCountedProtocol(kProtocolId, mozilla::ipc::ParentSide) { MOZ_COUNT_CTOR(PRemoteDecoderParent); } PRemoteDecoderParent::~PRemoteDecoderParent() { MOZ_COUNT_DTOR(PRemoteDecoderParent); } auto PRemoteDecoderParent::ActorAlloc() -> void { AddRef(); } auto PRemoteDecoderParent::ActorDealloc() -> void { Release(); } auto PRemoteDecoderParent::OtherPid() const -> ::base::ProcessId { ::base::ProcessId pid = ::mozilla::ipc::IProtocol::ToplevelProtocol()->OtherPidMaybeInvalid(); MOZ_RELEASE_ASSERT(pid != ::base::kInvalidProcessId); return pid; } auto PRemoteDecoderParent::OtherChildID() const -> ::GeckoChildID { ::GeckoChildID childID = ::mozilla::ipc::IProtocol::ToplevelProtocol()->OtherChildIDMaybeInvalid(); MOZ_RELEASE_ASSERT(childID != -1); return childID; } auto PRemoteDecoderParent::OtherEndpointProcInfo() const -> ::mozilla::ipc::EndpointProcInfo { return ::mozilla::ipc::EndpointProcInfo{OtherPid(), OtherChildID()}; } auto PRemoteDecoderParent::Manager() const -> PRemoteMediaManagerParent* { return static_cast(IProtocol::Manager()); } auto PRemoteDecoderParent::ManagedProtocolIds() const -> mozilla::Span { return {}; } auto PRemoteDecoderParent::GetManagedActors(mozilla::ipc::ProtocolId aProtocol) -> UntypedManagedContainer* { switch (aProtocol) { default: return nullptr; } } auto PRemoteDecoderParent::RejectPendingResponses(ResponseRejectReason aReason) -> void { mAsyncCallbacks.RejectPendingResponses(aReason); } auto PRemoteDecoderParent::DeallocManagee( mozilla::ipc::ProtocolId aProtocolId, IProtocol* aListener) -> void { FatalError("unreached"); return; } auto PRemoteDecoderParent::OnMessageReceived(const Message& msg__) -> PRemoteDecoderParent::Result { if (!CanSend()) { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Ignored message for dead actor", (&(msg__))->type(), mozilla::ipc::MessageDirection::eSending); } return MsgProcessed; } switch (msg__.type()) { case MANAGED_ENDPOINT_BOUND_MESSAGE_TYPE: { if (!mAwaitingManagedEndpointBind) { NS_WARNING("Unexpected managed endpoint lifecycle message after actor bound!"); return MsgNotAllowed; } mAwaitingManagedEndpointBind = false; return MsgProcessed; } case MANAGED_ENDPOINT_DROPPED_MESSAGE_TYPE: { if (!mAwaitingManagedEndpointBind) { NS_WARNING("Unexpected managed endpoint lifecycle message after actor bound!"); return MsgNotAllowed; } mAwaitingManagedEndpointBind = false; this->ActorDisconnected(ManagedEndpointDropped); return MsgProcessed; } case PRemoteDecoder::Msg_Construct__ID: { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PRemoteDecoder::Msg_Construct", OTHER); mozilla::ipc::ActorId id__ = Id(); UniquePtr reply__(PRemoteDecoder::Reply_Construct(id__)); reply__->set_seqno(msg__.seqno()); RefPtr resolver__ = new mozilla::ipc::IPDLResolverInner(std::move(reply__), this); ConstructResolver resolver = [resolver__ = std::move(resolver__)](const MediaResult& aParam) { resolver__->Resolve([&] (IPC::Message* reply__, IProtocol* self__) { IPC::MessageWriter writer__(*reply__, self__); IPC::WriteParam((&(writer__)), aParam); // Sentinel = 'result' ((&(writer__)))->WriteSentinel(153223840); if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", self__->ToplevelProtocol()->OtherPidMaybeInvalid(), "Sending reply ", reply__->type(), mozilla::ipc::MessageDirection::eSending); } }); }; mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::RemoteDecoderParent*>(this))->RecvConstruct(std::move(resolver)); if ((!(__ok))) { mozilla::ipc::ProtocolErrorBreakpoint("Handler returned error code!"); // Error handled in mozilla::ipc::IPCResult return MsgProcessingError; } return MsgProcessed; } case PRemoteDecoder::Msg_Init__ID: { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PRemoteDecoder::Msg_Init", OTHER); mozilla::ipc::ActorId id__ = Id(); UniquePtr reply__(PRemoteDecoder::Reply_Init(id__)); reply__->set_seqno(msg__.seqno()); RefPtr resolver__ = new mozilla::ipc::IPDLResolverInner(std::move(reply__), this); InitResolver resolver = [resolver__ = std::move(resolver__)](const InitResultIPDL& aParam) { resolver__->Resolve([&] (IPC::Message* reply__, IProtocol* self__) { IPC::MessageWriter writer__(*reply__, self__); IPC::WriteParam((&(writer__)), aParam); // Sentinel = 'result' ((&(writer__)))->WriteSentinel(153223840); if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", self__->ToplevelProtocol()->OtherPidMaybeInvalid(), "Sending reply ", reply__->type(), mozilla::ipc::MessageDirection::eSending); } }); }; mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::RemoteDecoderParent*>(this))->RecvInit(std::move(resolver)); if ((!(__ok))) { mozilla::ipc::ProtocolErrorBreakpoint("Handler returned error code!"); // Error handled in mozilla::ipc::IPCResult return MsgProcessingError; } return MsgProcessed; } case PRemoteDecoder::Msg_Decode__ID: { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PRemoteDecoder::Msg_Decode", OTHER); IPC::MessageReader reader__{ msg__, this}; auto maybe__data = IPC::ReadParam>((&(reader__))); if (!maybe__data) { FatalError("Error deserializing 'ArrayOfRemoteMediaRawData'"); return MsgValueError; } auto& data = *maybe__data; // Sentinel = 'data' if ((!(((&(reader__)))->ReadSentinel(67109275)))) { mozilla::ipc::SentinelReadError("Error deserializing 'ArrayOfRemoteMediaRawData'"); return MsgValueError; } reader__.EndRead(); mozilla::ipc::ActorId id__ = Id(); UniquePtr reply__(PRemoteDecoder::Reply_Decode(id__)); reply__->set_seqno(msg__.seqno()); RefPtr resolver__ = new mozilla::ipc::IPDLResolverInner(std::move(reply__), this); DecodeResolver resolver = [resolver__ = std::move(resolver__)](const DecodeResultIPDL& aParam) { resolver__->Resolve([&] (IPC::Message* reply__, IProtocol* self__) { IPC::MessageWriter writer__(*reply__, self__); IPC::WriteParam((&(writer__)), aParam); // Sentinel = 'result' ((&(writer__)))->WriteSentinel(153223840); if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", self__->ToplevelProtocol()->OtherPidMaybeInvalid(), "Sending reply ", reply__->type(), mozilla::ipc::MessageDirection::eSending); } }); }; mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::RemoteDecoderParent*>(this))->RecvDecode(data, std::move(resolver)); if ((!(__ok))) { mozilla::ipc::ProtocolErrorBreakpoint("Handler returned error code!"); // Error handled in mozilla::ipc::IPCResult return MsgProcessingError; } return MsgProcessed; } case PRemoteDecoder::Msg_Flush__ID: { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PRemoteDecoder::Msg_Flush", OTHER); mozilla::ipc::ActorId id__ = Id(); UniquePtr reply__(PRemoteDecoder::Reply_Flush(id__)); reply__->set_seqno(msg__.seqno()); RefPtr resolver__ = new mozilla::ipc::IPDLResolverInner(std::move(reply__), this); FlushResolver resolver = [resolver__ = std::move(resolver__)](const MediaResult& aParam) { resolver__->Resolve([&] (IPC::Message* reply__, IProtocol* self__) { IPC::MessageWriter writer__(*reply__, self__); IPC::WriteParam((&(writer__)), aParam); // Sentinel = 'error' ((&(writer__)))->WriteSentinel(107741739); if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", self__->ToplevelProtocol()->OtherPidMaybeInvalid(), "Sending reply ", reply__->type(), mozilla::ipc::MessageDirection::eSending); } }); }; mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::RemoteDecoderParent*>(this))->RecvFlush(std::move(resolver)); if ((!(__ok))) { mozilla::ipc::ProtocolErrorBreakpoint("Handler returned error code!"); // Error handled in mozilla::ipc::IPCResult return MsgProcessingError; } return MsgProcessed; } case PRemoteDecoder::Msg_Drain__ID: { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PRemoteDecoder::Msg_Drain", OTHER); mozilla::ipc::ActorId id__ = Id(); UniquePtr reply__(PRemoteDecoder::Reply_Drain(id__)); reply__->set_seqno(msg__.seqno()); RefPtr resolver__ = new mozilla::ipc::IPDLResolverInner(std::move(reply__), this); DrainResolver resolver = [resolver__ = std::move(resolver__)](const DecodeResultIPDL& aParam) { resolver__->Resolve([&] (IPC::Message* reply__, IProtocol* self__) { IPC::MessageWriter writer__(*reply__, self__); IPC::WriteParam((&(writer__)), aParam); // Sentinel = 'result' ((&(writer__)))->WriteSentinel(153223840); if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", self__->ToplevelProtocol()->OtherPidMaybeInvalid(), "Sending reply ", reply__->type(), mozilla::ipc::MessageDirection::eSending); } }); }; mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::RemoteDecoderParent*>(this))->RecvDrain(std::move(resolver)); if ((!(__ok))) { mozilla::ipc::ProtocolErrorBreakpoint("Handler returned error code!"); // Error handled in mozilla::ipc::IPCResult return MsgProcessingError; } return MsgProcessed; } case PRemoteDecoder::Msg_Shutdown__ID: { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PRemoteDecoder::Msg_Shutdown", OTHER); mozilla::ipc::ActorId id__ = Id(); UniquePtr reply__(PRemoteDecoder::Reply_Shutdown(id__)); reply__->set_seqno(msg__.seqno()); RefPtr resolver__ = new mozilla::ipc::IPDLResolverInner(std::move(reply__), this); ShutdownResolver resolver = [resolver__ = std::move(resolver__)](const bool& aParam) { resolver__->Resolve([&] (IPC::Message* reply__, IProtocol* self__) { IPC::MessageWriter writer__(*reply__, self__); IPC::WriteParam((&(writer__)), aParam); // Sentinel = 'unused' ((&(writer__)))->WriteSentinel(155517589); if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", self__->ToplevelProtocol()->OtherPidMaybeInvalid(), "Sending reply ", reply__->type(), mozilla::ipc::MessageDirection::eSending); } }); }; mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::RemoteDecoderParent*>(this))->RecvShutdown(std::move(resolver)); if ((!(__ok))) { mozilla::ipc::ProtocolErrorBreakpoint("Handler returned error code!"); // Error handled in mozilla::ipc::IPCResult return MsgProcessingError; } return MsgProcessed; } case PRemoteDecoder::Msg_SetSeekThreshold__ID: { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PRemoteDecoder::Msg_SetSeekThreshold", OTHER); IPC::MessageReader reader__{ msg__, this}; auto maybe__time = IPC::ReadParam((&(reader__))); if (!maybe__time) { FatalError("Error deserializing 'TimeUnit'"); return MsgValueError; } auto& time = *maybe__time; // Sentinel = 'time' if ((!(((&(reader__)))->ReadSentinel(72221104)))) { mozilla::ipc::SentinelReadError("Error deserializing 'TimeUnit'"); return MsgValueError; } reader__.EndRead(); mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::RemoteDecoderParent*>(this))->RecvSetSeekThreshold(std::move(time)); if ((!(__ok))) { mozilla::ipc::ProtocolErrorBreakpoint("Handler returned error code!"); // Error handled in mozilla::ipc::IPCResult return MsgProcessingError; } return MsgProcessed; } case PRemoteDecoder::Msg___delete____ID: { if (mozilla::ipc::LoggingEnabledFor("PRemoteDecoder", mozilla::ipc::ParentSide)) { mozilla::ipc::LogMessageForProtocol( "PRemoteDecoderParent", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PRemoteDecoder::Msg___delete__", OTHER); DoomSubtree(); mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::RemoteDecoderParent*>(this))->Recv__delete__(); if ((!(__ok))) { mozilla::ipc::ProtocolErrorBreakpoint("Handler returned error code!"); // Error handled in mozilla::ipc::IPCResult return MsgProcessingError; } this->ActorDisconnected(Deletion); return MsgProcessed; } default: return MsgNotKnown; } } auto PRemoteDecoderParent::OnMessageReceived( const Message& msg__, UniquePtr& reply__) -> PRemoteDecoderParent::Result { if (!CanSend()) { return MsgDropped; } return MsgNotKnown; } } // namespace mozilla