// // Automatically generated by ipdlc. // Edit at your own risk // #include "mozilla/net/PInputChannelThrottleQueueChild.h" #include "mozilla/ProfilerLabels.h" #include "mozilla/net/InputChannelThrottleQueueChild.h" #include "mozilla/net/PSocketProcessChild.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 { namespace net { auto PInputChannelThrottleQueueChild::Recv__delete__() -> mozilla::ipc::IPCResult { return IPC_OK(); } MOZ_IMPLICIT PInputChannelThrottleQueueChild::PInputChannelThrottleQueueChild() : mozilla::ipc::IRefCountedProtocol(kProtocolId, mozilla::ipc::ChildSide) { MOZ_COUNT_CTOR(PInputChannelThrottleQueueChild); } PInputChannelThrottleQueueChild::~PInputChannelThrottleQueueChild() { MOZ_COUNT_DTOR(PInputChannelThrottleQueueChild); } auto PInputChannelThrottleQueueChild::ActorAlloc() -> void { AddRef(); } auto PInputChannelThrottleQueueChild::ActorDealloc() -> void { Release(); } auto PInputChannelThrottleQueueChild::OtherPid() const -> ::base::ProcessId { ::base::ProcessId pid = ::mozilla::ipc::IProtocol::ToplevelProtocol()->OtherPidMaybeInvalid(); MOZ_RELEASE_ASSERT(pid != ::base::kInvalidProcessId); return pid; } auto PInputChannelThrottleQueueChild::OtherChildID() const -> ::GeckoChildID { ::GeckoChildID childID = ::mozilla::ipc::IProtocol::ToplevelProtocol()->OtherChildIDMaybeInvalid(); MOZ_RELEASE_ASSERT(childID != -1); return childID; } auto PInputChannelThrottleQueueChild::OtherEndpointProcInfo() const -> ::mozilla::ipc::EndpointProcInfo { return ::mozilla::ipc::EndpointProcInfo{OtherPid(), OtherChildID()}; } auto PInputChannelThrottleQueueChild::Manager() const -> PSocketProcessChild* { return static_cast(IProtocol::Manager()); } auto PInputChannelThrottleQueueChild::ManagedProtocolIds() const -> mozilla::Span { return {}; } auto PInputChannelThrottleQueueChild::GetManagedActors(mozilla::ipc::ProtocolId aProtocol) -> UntypedManagedContainer* { switch (aProtocol) { default: return nullptr; } } auto PInputChannelThrottleQueueChild::SendRecordRead(const uint32_t& aBytesRead) -> bool { UniquePtr msg__ = PInputChannelThrottleQueue::Msg_RecordRead(Id()); IPC::MessageWriter writer__{ (*(msg__)), this}; IPC::WriteParam((&(writer__)), aBytesRead); // Sentinel = 'aBytesRead' ((&(writer__)))->WriteSentinel(357827557); if (mozilla::ipc::LoggingEnabledFor("PInputChannelThrottleQueue", mozilla::ipc::ChildSide)) { mozilla::ipc::LogMessageForProtocol( "PInputChannelThrottleQueueChild", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Sending ", msg__->type(), mozilla::ipc::MessageDirection::eSending); } AUTO_PROFILER_LABEL("PInputChannelThrottleQueue::Msg_RecordRead", OTHER); bool sendok__ = ChannelSend(std::move(msg__)); return sendok__; } auto PInputChannelThrottleQueueChild::DeallocManagee( mozilla::ipc::ProtocolId aProtocolId, IProtocol* aListener) -> void { FatalError("unreached"); return; } auto PInputChannelThrottleQueueChild::OnMessageReceived(const Message& msg__) -> PInputChannelThrottleQueueChild::Result { if (!CanSend()) { if (mozilla::ipc::LoggingEnabledFor("PInputChannelThrottleQueue", mozilla::ipc::ChildSide)) { mozilla::ipc::LogMessageForProtocol( "PInputChannelThrottleQueueChild", 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 PInputChannelThrottleQueue::Msg___delete____ID: { if (mozilla::ipc::LoggingEnabledFor("PInputChannelThrottleQueue", mozilla::ipc::ChildSide)) { mozilla::ipc::LogMessageForProtocol( "PInputChannelThrottleQueueChild", this->ToplevelProtocol()->OtherPidMaybeInvalid(), "Received ", (&(msg__))->type(), mozilla::ipc::MessageDirection::eReceiving); } AUTO_PROFILER_LABEL("PInputChannelThrottleQueue::Msg___delete__", OTHER); DoomSubtree(); mozilla::ipc::IPCResult __ok = (static_cast<::mozilla::net::InputChannelThrottleQueueChild*>(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 PInputChannelThrottleQueueChild::OnMessageReceived( const Message& msg__, UniquePtr& reply__) -> PInputChannelThrottleQueueChild::Result { if (!CanSend()) { return MsgDropped; } return MsgNotKnown; } } // namespace net } // namespace mozilla