From 2aa4a82499d4becd2284cdb482213d541b8804dd Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 28 Apr 2024 16:29:10 +0200 Subject: Adding upstream version 86.0.1. Signed-off-by: Daniel Baumann --- dom/presentation/PresentationTCPSessionTransport.h | 104 +++++++++++++++++++++ 1 file changed, 104 insertions(+) create mode 100644 dom/presentation/PresentationTCPSessionTransport.h (limited to 'dom/presentation/PresentationTCPSessionTransport.h') diff --git a/dom/presentation/PresentationTCPSessionTransport.h b/dom/presentation/PresentationTCPSessionTransport.h new file mode 100644 index 0000000000..c8662d4852 --- /dev/null +++ b/dom/presentation/PresentationTCPSessionTransport.h @@ -0,0 +1,104 @@ +/* -*- 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/. */ + +#ifndef mozilla_dom_PresentationSessionTransport_h +#define mozilla_dom_PresentationSessionTransport_h + +#include "mozilla/RefPtr.h" +#include "nsCOMPtr.h" +#include "nsCycleCollectionParticipant.h" +#include "nsIAsyncInputStream.h" +#include "nsIPresentationSessionTransport.h" +#include "nsIPresentationSessionTransportBuilder.h" +#include "nsIStreamListener.h" +#include "nsISupportsImpl.h" +#include "nsITransport.h" + +class nsISocketTransport; +class nsIInputStreamPump; +class nsIScriptableInputStream; +class nsIMultiplexInputStream; +class nsIAsyncStreamCopier; +class nsIInputStream; + +namespace mozilla { +namespace dom { + +/* + * App-to-App transport channel for the presentation session. It's usually + * initialized with an |InitWithSocketTransport| call if at the presenting + * sender side; whereas it's initialized with an |InitWithChannelDescription| if + * at the presenting receiver side. The lifetime is managed in either + * |PresentationControllingInfo| (sender side) or |PresentationPresentingInfo| + * (receiver side) in PresentationSessionInfo.cpp. + */ +class PresentationTCPSessionTransport final + : public nsIPresentationSessionTransport, + public nsIPresentationTCPSessionTransportBuilder, + public nsITransportEventSink, + public nsIInputStreamCallback, + public nsIStreamListener { + public: + NS_DECL_CYCLE_COLLECTING_ISUPPORTS + NS_DECL_CYCLE_COLLECTION_CLASS_AMBIGUOUS(PresentationTCPSessionTransport, + nsIPresentationSessionTransport) + + NS_DECL_NSIPRESENTATIONSESSIONTRANSPORT + NS_DECL_NSIPRESENTATIONSESSIONTRANSPORTBUILDER + NS_DECL_NSIPRESENTATIONTCPSESSIONTRANSPORTBUILDER + NS_DECL_NSITRANSPORTEVENTSINK + NS_DECL_NSIINPUTSTREAMCALLBACK + NS_DECL_NSIREQUESTOBSERVER + NS_DECL_NSISTREAMLISTENER + + PresentationTCPSessionTransport(); + + void NotifyCopyComplete(nsresult aStatus); + + private: + ~PresentationTCPSessionTransport(); + + nsresult CreateStream(); + + nsresult CreateInputStreamPump(); + + nsresult EnsureCopying(); + + enum class ReadyState { CONNECTING, OPEN, CLOSING, CLOSED }; + + void SetReadyState(ReadyState aReadyState); + + bool IsReadyToNotifyData() { + return mDataNotificationEnabled && mReadyState == ReadyState::OPEN; + } + + ReadyState mReadyState; + bool mAsyncCopierActive; + nsresult mCloseStatus; + bool mDataNotificationEnabled; + + uint8_t mRole = 0; + + // Raw socket streams + nsCOMPtr mTransport; + nsCOMPtr mSocketInputStream; + nsCOMPtr mSocketOutputStream; + + // Input stream machinery + nsCOMPtr mInputStreamPump; + nsCOMPtr mInputStreamScriptable; + + nsCOMPtr mCallback; + nsCOMPtr mListener; + + // The data to be sent. + nsTArray> mPendingData; +}; + +} // namespace dom +} // namespace mozilla + +#endif // mozilla_dom_PresentationSessionTransport_h -- cgit v1.2.3