Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / ndp / fx / src / Net / System / Net / _FtpDataStream.cs / 1 / _FtpDataStream.cs
// ------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // // ----------------------------------------------------------------------------- // namespace System.Net { using System.IO; using System.Net.Sockets; using System.Security.Permissions; ////// internal class FtpDataStream : Stream, ICloseEx { private FtpWebRequest m_Request; private NetworkStream m_NetworkStream; private bool m_Writeable; private bool m_Readable; private bool m_IsFullyRead = false; bool m_Closing = false; internal FtpDataStream(NetworkStream networkStream, FtpWebRequest request, TriState writeOnly) { GlobalLog.Print("FtpDataStream#" + ValidationHelper.HashString(this) + "::FtpDataStream"); m_Readable = true; m_Writeable = true; if (writeOnly == TriState.True) { m_Readable = false; } else if (writeOnly == TriState.False) { m_Writeable = false; } m_NetworkStream = networkStream; m_Request = request; } protected override void Dispose(bool disposing) { try { if (disposing) ((ICloseEx)this).CloseEx(CloseExState.Normal); else ((ICloseEx)this).CloseEx(CloseExState.Abort | CloseExState.Silent); } finally { base.Dispose(disposing); } } void ICloseEx.CloseEx(CloseExState closeState) { GlobalLog.Print("FtpDataStream#" + ValidationHelper.HashString(this) + "::CloseEx, state = " + closeState.ToString()); lock (this) { if (m_Closing == true) return; m_Closing = true; m_Writeable = false; m_Readable = false; } try { try { if ((closeState & CloseExState.Abort) == 0) m_NetworkStream.Close(Socket.DefaultCloseTimeout); else m_NetworkStream.Close(0); } finally { m_Request.DataStreamClosed(closeState); } } catch (Exception exception) { bool doThrow = true; WebException webException = exception as WebException; if (webException != null) { FtpWebResponse response = webException.Response as FtpWebResponse; if (response != null) { if (!m_IsFullyRead && response.StatusCode == FtpStatusCode.ConnectionClosed) doThrow = false; } } if (doThrow) if ((closeState & CloseExState.Silent) == 0) throw; } } ////// The FtpDataStream class implements a data FTP connection, /// ////// private void CheckError() { if (m_Request.Aborted) { throw new WebException( NetRes.GetWebStatusString( "net_requestaborted", WebExceptionStatus.RequestCanceled), WebExceptionStatus.RequestCanceled); } } ///Rethrows the exception ////// public override bool CanRead { get { return m_Readable; } } ///Indicates that data can be read from the stream. /// /// public override bool CanSeek { get { return m_NetworkStream.CanSeek; } } ///Indicates that the stream is seekable ////// public override bool CanWrite { get { return m_Writeable; } } ///Indicates that the stream is writeable ////// public override long Length { get { return m_NetworkStream.Length; } } ///Indicates that the stream is writeable ////// public override long Position { get { return m_NetworkStream.Position; } set { m_NetworkStream.Position = value; } } ///Gets or sets the position in the stream. Always throws ///. /// public override long Seek(long offset, SeekOrigin origin) { CheckError(); try { return m_NetworkStream.Seek(offset, origin); } catch { CheckError(); throw; } } ///Seeks a specific position in the stream. ////// public override int Read(byte[] buffer, int offset, int size) { CheckError(); int readBytes; try { readBytes = m_NetworkStream.Read(buffer, offset, size); } catch { CheckError(); throw; } if (readBytes == 0) { m_IsFullyRead = true; Close(); } return readBytes; } ///Reads data from the stream. ////// public override void Write(byte[] buffer, int offset, int size) { CheckError(); try { m_NetworkStream.Write(buffer, offset, size); } catch { CheckError(); throw; } } private void AsyncReadCallback(IAsyncResult ar) { LazyAsyncResult userResult = (LazyAsyncResult) ar.AsyncState; try { try { int readBytes = m_NetworkStream.EndRead(ar); if (readBytes == 0) { m_IsFullyRead = true; Close(); // This should block for pipeline completion } userResult.InvokeCallback(readBytes); } catch (Exception exception) { // Complete with error. If already completed rethrow on the worker thread if (!userResult.IsCompleted) userResult.InvokeCallback(exception); } } catch {} } ///Writes data to the stream. ////// [HostProtection(ExternalThreading=true)] public override IAsyncResult BeginRead(byte[] buffer, int offset, int size, AsyncCallback callback, Object state) { CheckError(); LazyAsyncResult userResult = new LazyAsyncResult(this, state, callback); try { m_NetworkStream.BeginRead(buffer, offset, size, new AsyncCallback(AsyncReadCallback), userResult); } catch { CheckError(); throw; } return userResult; } ////// Begins an asychronous read from a stream. /// ////// public override int EndRead(IAsyncResult ar) { try { object result = ((LazyAsyncResult)ar).InternalWaitForCompletion(); if (result is Exception) throw (Exception) result; return (int)result; } finally { CheckError(); } } ////// Handle the end of an asynchronous read. /// ////// [HostProtection(ExternalThreading=true)] public override IAsyncResult BeginWrite(byte[] buffer, int offset, int size, AsyncCallback callback, Object state) { CheckError(); try { return m_NetworkStream.BeginWrite(buffer, offset, size, callback, state); } catch { CheckError(); throw; } } ////// Begins an asynchronous write to a stream. /// ////// public override void EndWrite(IAsyncResult asyncResult) { try { m_NetworkStream.EndWrite(asyncResult); } finally { CheckError(); } } ////// Handle the end of an asynchronous write. /// ////// public override void Flush() { m_NetworkStream.Flush(); } ////// Flushes data from the stream. /// ////// public override void SetLength(long value) { m_NetworkStream.SetLength(value); } ////// Sets the length of the stream. Always throws ////// . /// /// public override bool CanTimeout { get { return m_NetworkStream.CanTimeout; } } ///Indicates whether we can timeout ////// public override int ReadTimeout { get { return m_NetworkStream.ReadTimeout; } set { m_NetworkStream.ReadTimeout = value; } } ///Set/Get ReadTimeout ////// public override int WriteTimeout { get { return m_NetworkStream.WriteTimeout; } set { m_NetworkStream.WriteTimeout = value; } } internal void SetSocketTimeoutOption(SocketShutdown mode, int timeout, bool silent) { m_NetworkStream.SetSocketTimeoutOption(mode, timeout, silent); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. // ------------------------------------------------------------------------------ //Set/Get WriteTimeout ///// Copyright (c) Microsoft Corporation. All rights reserved. // // ----------------------------------------------------------------------------- // namespace System.Net { using System.IO; using System.Net.Sockets; using System.Security.Permissions; ////// internal class FtpDataStream : Stream, ICloseEx { private FtpWebRequest m_Request; private NetworkStream m_NetworkStream; private bool m_Writeable; private bool m_Readable; private bool m_IsFullyRead = false; bool m_Closing = false; internal FtpDataStream(NetworkStream networkStream, FtpWebRequest request, TriState writeOnly) { GlobalLog.Print("FtpDataStream#" + ValidationHelper.HashString(this) + "::FtpDataStream"); m_Readable = true; m_Writeable = true; if (writeOnly == TriState.True) { m_Readable = false; } else if (writeOnly == TriState.False) { m_Writeable = false; } m_NetworkStream = networkStream; m_Request = request; } protected override void Dispose(bool disposing) { try { if (disposing) ((ICloseEx)this).CloseEx(CloseExState.Normal); else ((ICloseEx)this).CloseEx(CloseExState.Abort | CloseExState.Silent); } finally { base.Dispose(disposing); } } void ICloseEx.CloseEx(CloseExState closeState) { GlobalLog.Print("FtpDataStream#" + ValidationHelper.HashString(this) + "::CloseEx, state = " + closeState.ToString()); lock (this) { if (m_Closing == true) return; m_Closing = true; m_Writeable = false; m_Readable = false; } try { try { if ((closeState & CloseExState.Abort) == 0) m_NetworkStream.Close(Socket.DefaultCloseTimeout); else m_NetworkStream.Close(0); } finally { m_Request.DataStreamClosed(closeState); } } catch (Exception exception) { bool doThrow = true; WebException webException = exception as WebException; if (webException != null) { FtpWebResponse response = webException.Response as FtpWebResponse; if (response != null) { if (!m_IsFullyRead && response.StatusCode == FtpStatusCode.ConnectionClosed) doThrow = false; } } if (doThrow) if ((closeState & CloseExState.Silent) == 0) throw; } } ////// The FtpDataStream class implements a data FTP connection, /// ////// private void CheckError() { if (m_Request.Aborted) { throw new WebException( NetRes.GetWebStatusString( "net_requestaborted", WebExceptionStatus.RequestCanceled), WebExceptionStatus.RequestCanceled); } } ///Rethrows the exception ////// public override bool CanRead { get { return m_Readable; } } ///Indicates that data can be read from the stream. /// /// public override bool CanSeek { get { return m_NetworkStream.CanSeek; } } ///Indicates that the stream is seekable ////// public override bool CanWrite { get { return m_Writeable; } } ///Indicates that the stream is writeable ////// public override long Length { get { return m_NetworkStream.Length; } } ///Indicates that the stream is writeable ////// public override long Position { get { return m_NetworkStream.Position; } set { m_NetworkStream.Position = value; } } ///Gets or sets the position in the stream. Always throws ///. /// public override long Seek(long offset, SeekOrigin origin) { CheckError(); try { return m_NetworkStream.Seek(offset, origin); } catch { CheckError(); throw; } } ///Seeks a specific position in the stream. ////// public override int Read(byte[] buffer, int offset, int size) { CheckError(); int readBytes; try { readBytes = m_NetworkStream.Read(buffer, offset, size); } catch { CheckError(); throw; } if (readBytes == 0) { m_IsFullyRead = true; Close(); } return readBytes; } ///Reads data from the stream. ////// public override void Write(byte[] buffer, int offset, int size) { CheckError(); try { m_NetworkStream.Write(buffer, offset, size); } catch { CheckError(); throw; } } private void AsyncReadCallback(IAsyncResult ar) { LazyAsyncResult userResult = (LazyAsyncResult) ar.AsyncState; try { try { int readBytes = m_NetworkStream.EndRead(ar); if (readBytes == 0) { m_IsFullyRead = true; Close(); // This should block for pipeline completion } userResult.InvokeCallback(readBytes); } catch (Exception exception) { // Complete with error. If already completed rethrow on the worker thread if (!userResult.IsCompleted) userResult.InvokeCallback(exception); } } catch {} } ///Writes data to the stream. ////// [HostProtection(ExternalThreading=true)] public override IAsyncResult BeginRead(byte[] buffer, int offset, int size, AsyncCallback callback, Object state) { CheckError(); LazyAsyncResult userResult = new LazyAsyncResult(this, state, callback); try { m_NetworkStream.BeginRead(buffer, offset, size, new AsyncCallback(AsyncReadCallback), userResult); } catch { CheckError(); throw; } return userResult; } ////// Begins an asychronous read from a stream. /// ////// public override int EndRead(IAsyncResult ar) { try { object result = ((LazyAsyncResult)ar).InternalWaitForCompletion(); if (result is Exception) throw (Exception) result; return (int)result; } finally { CheckError(); } } ////// Handle the end of an asynchronous read. /// ////// [HostProtection(ExternalThreading=true)] public override IAsyncResult BeginWrite(byte[] buffer, int offset, int size, AsyncCallback callback, Object state) { CheckError(); try { return m_NetworkStream.BeginWrite(buffer, offset, size, callback, state); } catch { CheckError(); throw; } } ////// Begins an asynchronous write to a stream. /// ////// public override void EndWrite(IAsyncResult asyncResult) { try { m_NetworkStream.EndWrite(asyncResult); } finally { CheckError(); } } ////// Handle the end of an asynchronous write. /// ////// public override void Flush() { m_NetworkStream.Flush(); } ////// Flushes data from the stream. /// ////// public override void SetLength(long value) { m_NetworkStream.SetLength(value); } ////// Sets the length of the stream. Always throws ////// . /// /// public override bool CanTimeout { get { return m_NetworkStream.CanTimeout; } } ///Indicates whether we can timeout ////// public override int ReadTimeout { get { return m_NetworkStream.ReadTimeout; } set { m_NetworkStream.ReadTimeout = value; } } ///Set/Get ReadTimeout ////// public override int WriteTimeout { get { return m_NetworkStream.WriteTimeout; } set { m_NetworkStream.WriteTimeout = value; } } internal void SetSocketTimeoutOption(SocketShutdown mode, int timeout, bool silent) { m_NetworkStream.SetSocketTimeoutOption(mode, timeout, silent); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.Set/Get WriteTimeout ///
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- FixedDocument.cs
- Run.cs
- SecurityCredentialsManager.cs
- CorruptStoreException.cs
- TimeManager.cs
- MediaScriptCommandRoutedEventArgs.cs
- ParameterEditorUserControl.cs
- SmiEventSink_Default.cs
- Privilege.cs
- RemotingSurrogateSelector.cs
- UnionCqlBlock.cs
- CodePropertyReferenceExpression.cs
- KeyGestureValueSerializer.cs
- Renderer.cs
- IntegerValidatorAttribute.cs
- EventMappingSettingsCollection.cs
- HttpListenerResponse.cs
- ProjectionQueryOptionExpression.cs
- MediaElementAutomationPeer.cs
- XmlValidatingReader.cs
- RectangleF.cs
- autovalidator.cs
- SessionEndingEventArgs.cs
- Delegate.cs
- UnionExpr.cs
- XPathNodeIterator.cs
- KeyConverter.cs
- MailDefinition.cs
- PasswordBox.cs
- XpsS0ValidatingLoader.cs
- EventSetter.cs
- MethodBuilder.cs
- HebrewCalendar.cs
- SelectionProviderWrapper.cs
- TextTreeTextElementNode.cs
- SerializationEventsCache.cs
- DataServiceBuildProvider.cs
- UnauthorizedWebPart.cs
- MatchSingleFxEngineOpcode.cs
- HTMLTagNameToTypeMapper.cs
- WebPartCancelEventArgs.cs
- WebPartConnectionsConfigureVerb.cs
- Timer.cs
- Pair.cs
- SoapServerMethod.cs
- ExclusiveTcpTransportManager.cs
- SapiGrammar.cs
- SafeFileMapViewHandle.cs
- WebPartEditorOkVerb.cs
- Int16AnimationUsingKeyFrames.cs
- Run.cs
- DataTableClearEvent.cs
- PathFigure.cs
- SoapMessage.cs
- ReplacementText.cs
- Compiler.cs
- SchemaInfo.cs
- OwnerDrawPropertyBag.cs
- GraphicsPath.cs
- CodeMethodReturnStatement.cs
- DataGridViewCell.cs
- EventLogPropertySelector.cs
- HtmlEncodedRawTextWriter.cs
- DispatchWrapper.cs
- AccessControlEntry.cs
- TokenBasedSet.cs
- webeventbuffer.cs
- RectangleHotSpot.cs
- KeyPressEvent.cs
- WrappedIUnknown.cs
- TraceSwitch.cs
- DetailsViewUpdatedEventArgs.cs
- LocationSectionRecord.cs
- StandardTransformFactory.cs
- LOSFormatter.cs
- Config.cs
- CqlQuery.cs
- ReadOnlyHierarchicalDataSourceView.cs
- VoiceInfo.cs
- Binding.cs
- BindingContext.cs
- DateTimeOffsetConverter.cs
- MultipartContentParser.cs
- TaiwanCalendar.cs
- mediaeventargs.cs
- DataGridRow.cs
- RemotingConfigParser.cs
- PassportAuthentication.cs
- Path.cs
- MissingFieldException.cs
- SecurityContext.cs
- TextBoxAutoCompleteSourceConverter.cs
- ParameterToken.cs
- InheritanceAttribute.cs
- ToolTip.cs
- MethodBuilder.cs
- FlowLayoutSettings.cs
- ObjectContextServiceProvider.cs
- SspiSecurityTokenProvider.cs
- CodeExporter.cs