/* -*- 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/. */
class nsISocketTransport; class nsIInputStreamPump; class nsIScriptableInputStream; class nsIBinaryInputStream; class nsIMultiplexInputStream; class nsIAsyncStreamCopier; class nsIInputStream; class nsINetworkInfo;
namespace mozilla { class ErrorResult; namespace dom {
struct ServerSocketOptions; class TCPServerSocket; class TCPSocketChild; class TCPSocketParent;
// This interface is only used for legacy navigator.mozTCPSocket API // compatibility. class LegacyMozTCPSocket : public nsISupports { public:
NS_DECL_CYCLE_COLLECTING_ISUPPORTS
NS_DECL_CYCLE_COLLECTION_CLASS(LegacyMozTCPSocket)
class TCPSocket final : public DOMEventTargetHelper, public nsIStreamListener, public nsITransportEventSink, public nsIInputStreamCallback, public nsIObserver, public nsSupportsWeakReference, public nsITCPSocketCallback, public nsIProtocolProxyCallback { public:
TCPSocket(nsIGlobalObject* aGlobal, const nsAString& aHost, uint16_t aPort, bool aSsl, bool aUseArrayBuffers);
// Create a TCPSocket object from an existing low-level socket connection. // Used by the TCPServerSocket implementation when a new connection is // accepted. static already_AddRefed<TCPSocket> CreateAcceptedSocket(
nsIGlobalObject* aGlobal, nsISocketTransport* aTransport, bool aUseArrayBuffers); // Create a TCPSocket object from an existing child-side IPC actor. // Used by the TCPServerSocketChild implementation when a new connection is // accepted. static already_AddRefed<TCPSocket> CreateAcceptedSocket(
nsIGlobalObject* aGlobal, TCPSocketChild* aBridge, bool aUseArrayBuffers);
// Initialize this socket's associated IPC actor in the parent process. void SetSocketBridgeParent(TCPSocketParent* aBridgeParent);
// Inform this socket that a buffered send() has completed sending. void NotifyCopyComplete(nsresult aStatus);
// Initialize this socket from a low-level connection that hasn't connected // yet (called from RecvOpenBind() in TCPSocketParent).
nsresult InitWithUnconnectedTransport(nsISocketTransport* aTransport);
private:
~TCPSocket();
// Initialize this socket with an existing IPC actor. void InitWithSocketChild(TCPSocketChild* aSocketBridge); // Initialize this socket from an existing low-level connection.
nsresult InitWithTransport(nsISocketTransport* aTransport); // Initialize the input/output streams for this socket object.
nsresult CreateStream(); // Initialize the asynchronous read operation from this socket's input stream.
nsresult CreateInputStreamPump(); // Send the contents of the provided input stream, which is assumed to be the // given length for reporting and buffering purposes. bool Send(nsIInputStream* aStream, uint32_t aByteLength); // Begin an asynchronous copy operation if one is not already in progress.
nsresult EnsureCopying(); // Re-calculate buffered amount. void CalculateBufferedAmount(); // Helper function, should be called by ActivateTLS(), only. void ActivateTLSHelper(); // Enable TLS on this socket, dispatch to STSThread if necessary. void ActivateTLS(); // Dispatch an error event if necessary, then dispatch a "close" event.
nsresult MaybeReportErrorAndCloseIfOpen(nsresult status);
// Helper for FireDataStringEvent/FireDataArrayEvent.
nsresult FireDataEvent(JSContext* aCx, const nsAString& aType,
JS::Handle<JS::Value> aData); // Helper for Close/CloseImmediately void CloseHelper(bool waitForUnsentData);
nsresult ResolveProxy();
TCPReadyState mReadyState; // Whether to use strings or array buffers for the "data" event. bool mUseArrayBuffers;
nsString mHost;
uint16_t mPort; // Whether this socket is using a secure transport. bool mSsl;
// The associated IPC actor in a child process.
RefPtr<TCPSocketChild> mSocketBridgeChild; // The associated IPC actor in a parent process.
RefPtr<TCPSocketParent> mSocketBridgeParent;
// Raw socket streams
nsCOMPtr<nsISocketTransport> mTransport;
nsCOMPtr<nsIInputStream> mSocketInputStream;
nsCOMPtr<nsIOutputStream> mSocketOutputStream;
// Is there an async copy operation in progress? bool mAsyncCopierActive; // True if the buffer is full and a "drain" event is expected by the client. bool mWaitingForDrain;
// The id of the window that created this socket.
uint64_t mInnerWindowID;
// The current number of buffered bytes. Only used in content processes when // IPC is enabled.
uint64_t mBufferedAmount;
// The number of times this socket has had `Suspend` called without a // corresponding `Resume`.
uint32_t mSuspendCount;
// The current sequence number (ie. number of send operations) that have been // processed. This is used in the IPC scenario by the child process to filter // out outdated notifications about the amount of buffered data present in the // parent process.
uint32_t mTrackingNumber;
// True if this socket has been upgraded to secure after the initial // connection, but the actual upgrade is waiting for an in-progress copy // operation to complete. bool mWaitingForStartTLS; // The buffered data awaiting the TLS upgrade to finish.
nsTArray<nsCOMPtr<nsIInputStream>> mPendingDataAfterStartTLS;
// The data to be sent.
nsTArray<nsCOMPtr<nsIInputStream>> mPendingData;
bool mObserversActive;
};
} // namespace dom
} // namespace mozilla
#endif// mozilla_dom_TCPSocket_h
¤ Dauer der Verarbeitung: 0.16 Sekunden
(vorverarbeitet)
¤
Die Informationen auf dieser Webseite wurden
nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit,
noch Qualität der bereit gestellten Informationen zugesichert.
Bemerkung:
Die farbliche Syntaxdarstellung ist noch experimentell.
