System.Net.CommandStream Class Reference

Inheritance diagram for System.Net.CommandStream:

Classes
class	PipelineEntry

Public Member Functions
override long	Seek (long offset, SeekOrigin origin)
override int	Read (byte[] buffer, int offset, int size)
virtual int	Read (Span< byte > buffer)
override void	Write (byte[] buffer, int offset, int size)
virtual void	Write (ReadOnlySpan< byte > buffer)
void	Dispose ()
void	Close (int timeout)
virtual void	Close ()
override IAsyncResult	BeginRead (byte[] buffer, int offset, int size, AsyncCallback callback, object state)
override int	EndRead (IAsyncResult asyncResult)
override Task< int >	ReadAsync (byte[] buffer, int offset, int count, CancellationToken cancellationToken)
Task< int >	ReadAsync (byte[] buffer, int offset, int count)
virtual ValueTask< int >	ReadAsync (Memory< byte > buffer, [Optional] CancellationToken cancellationToken)
override IAsyncResult	BeginWrite (byte[] buffer, int offset, int size, AsyncCallback callback, object state)
override void	EndWrite (IAsyncResult asyncResult)
override Task	WriteAsync (byte[] buffer, int offset, int count, CancellationToken cancellationToken)
Task	WriteAsync (byte[] buffer, int offset, int count)
virtual ValueTask	WriteAsync (ReadOnlyMemory< byte > buffer, [Optional] CancellationToken cancellationToken)
override void	Flush ()
override Task	FlushAsync (CancellationToken cancellationToken)
override void	SetLength (long value)
void	CopyTo (Stream destination)
virtual void	CopyTo (Stream destination, int bufferSize)
virtual int	ReadByte ()
virtual void	WriteByte (byte value)
virtual ObjRef	CreateObjRef (Type requestedType)
virtual object	InitializeLifetimeService ()

Static Public Attributes
static readonly Stream	Null

Protected Member Functions
override void	Dispose (bool disposing)
void	InvokeRequestCallback (object obj)
void	MarkAsRecoverableFailure ()
virtual void	ClearState ()
virtual CommandStream.PipelineEntry[]	BuildCommandsList (WebRequest request)
Exception	GenerateException (string message, WebExceptionStatus status, Exception innerException)
Exception	GenerateException (FtpStatusCode code, string statusDescription, Exception innerException)
void	InitCommandPipeline (WebRequest request, CommandStream.PipelineEntry[] commands, bool isAsync)
Stream	ContinueCommandPipeline ()
virtual CommandStream.PipelineInstruction	PipelineCallback (CommandStream.PipelineEntry entry, ResponseDescription response, bool timeout, Stream stream)
virtual bool	CheckValid (ResponseDescription response, int validThrough, int completeLength)

Protected Attributes
WebRequest	_request
bool	_isAsync
CommandStream.PipelineEntry[]	_commands
int	_index
string	_abortReason

Package Types
enum	PipelineInstruction {   Abort , Advance , Pause , Reread ,   GiveStream }
enum	PipelineEntryFlags { UserCommand = 1 , GiveDataStream = 2 , CreateDataConnection = 4 , DontLogParameter = 8 }

Package Functions
	CommandStream (global::System.Net.Sockets.TcpClient client)
virtual void	Abort (Exception e)
Stream	SubmitRequest (WebRequest request, bool isAsync, bool readInitalResponseOnConnect)
void	CheckContinuePipeline ()
void	CloseSocket ()
void	SetSocketTimeoutOption (int timeout)
SemaphoreSlim	EnsureAsyncActiveSemaphoreInitialized ()
IAsyncResult	BeginReadInternal (byte[] buffer, int offset, int count, AsyncCallback callback, object state, bool serializeAsynchronously, bool apm)
IAsyncResult	BeginWriteInternal (byte[] buffer, int offset, int count, AsyncCallback callback, object state, bool serializeAsynchronously, bool apm)
IAsyncResult	BlockingBeginRead (byte[] buffer, int offset, int count, AsyncCallback callback, object state)
IAsyncResult	BlockingBeginWrite (byte[] buffer, int offset, int count, AsyncCallback callback, object state)

Static Package Functions
static int	BlockingEndRead (IAsyncResult asyncResult)
static void	BlockingEndWrite (IAsyncResult asyncResult)
static ValueTask< int >< ReadAsync >	g__FinishReadAsync (Task< int > readTask, byte[] localBuffer, Memory< byte > localDestination)

Properties
bool	RecoverableFailure [get]
Encoding	Encoding [get, set]
bool	UsingSecureStream [get]
IPAddress	ServerAddress [get]
global::System.Net.Sockets.Socket	Socket [get]
global::System.Net.Sockets.NetworkStream	NetworkStream [get, set]
override bool	CanRead [get]
override bool	CanSeek [get]
override bool	CanWrite [get]
override bool	CanTimeout [get]
override int	ReadTimeout [get, set]
override int	WriteTimeout [get, set]
override long	Length [get]
override long	Position [get, set]
ServerIdentity	ObjectIdentity [get, set]

Private Member Functions
bool	PostSendCommandProcessing (Stream stream)
bool	PostReadCommandProcessing (Stream stream)
ResponseDescription	ReceiveCommandResponse ()
void	ReceiveCommandResponseCallback (ReceiveState state, int bytesRead)
int	GetCopyBufferSize ()
Task< int >	BeginEndReadAsync (byte[] buffer, int offset, int count)
void	RunReadWriteTaskWhenReady (Task asyncWaiter, Stream.ReadWriteTask readWriteTask)
void	RunReadWriteTask (Stream.ReadWriteTask readWriteTask)
void	FinishTrackingAsyncOperation ()
Task	FinishWriteAsync (Task writeTask, byte[] localBuffer)
Task	BeginEndWriteAsync (byte[] buffer, int offset, int count)
bool	HasOverriddenBeginEndRead ()
bool	HasOverriddenBeginEndWrite ()

Static Private Member Functions
static void	ReadCallback (IAsyncResult asyncResult)
static void	WriteCallback (IAsyncResult asyncResult)
static	CommandStream ()

Private Attributes
bool	_recoverableFailure
bool	_aborted
bool	_doRead
bool	_doSend
ResponseDescription	_currentResponseDescription
string	_buffer
Encoding	_encoding
Decoder	_decoder
global::System.Net.Sockets.TcpClient	_client
global::System.Net.Sockets.NetworkStream	_networkStream
Stream.ReadWriteTask	_activeReadWriteTask
SemaphoreSlim	_asyncActiveSemaphore
object	_identity

Static Private Attributes
static readonly AsyncCallback	s_writeCallbackDelegate
static readonly AsyncCallback	s_readCallbackDelegate
const int	WaitingForPipeline = 1
const int	CompletedPipeline = 2

Detailed Description

Definition at line 12 of file CommandStream.cs.

---

The documentation for this class was generated from the following file:

• source/System/Net/CommandStream.cs