MimePart.cs source code in C# .NET

                        
Code:
                         / 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Net / System / Net / Mail / MimePart.cs / 1305376 / MimePart.cs
                        

                        
                            using System; 
using System.IO;
using System.Text;
using System.Collections;
using System.Globalization; 
using System.Net.Mail;
 
namespace System.Net.Mime 
{
    /// 
 
    /// Summary description for MimePart.
    /// 
    internal class MimePart: MimeBasePart,IDisposable
    { 
        Stream stream = null;
        bool streamSet = false; 
        bool streamUsedOnce = false; 
        AsyncCallback readCallback;
        AsyncCallback writeCallback; 
        const int maxBufferSize = 0x4400;  //seems optimal for send based on perf analysis

        internal MimePart()
        { 
        }
 
        public void Dispose(){ 
            if (stream != null) {
                stream.Close(); 
            }
        }

        internal Stream Stream { 
            get {
                return stream; 
            } 
        }
 

        internal ContentDisposition ContentDisposition{
            get{
                return contentDisposition; 
            }
            set{ 
                contentDisposition = value; 
                if(value == null){
                    ((HeaderCollection)Headers).InternalRemove(MailHeaderInfo.GetString(MailHeaderID.ContentDisposition)); 
                }
                else{
                    contentDisposition.PersistIfNeeded((HeaderCollection)Headers,true);
                } 
            }
        } 
 
        internal TransferEncoding TransferEncoding {
            get { 
                if (Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)].Equals("base64", StringComparison.OrdinalIgnoreCase))
                    return TransferEncoding.Base64;
                else if(Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)].Equals("quoted-printable", StringComparison.OrdinalIgnoreCase))
                    return TransferEncoding.QuotedPrintable; 
                else if(Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)].Equals("7bit", StringComparison.OrdinalIgnoreCase))
                    return TransferEncoding.SevenBit; 
                else 
                    return TransferEncoding.Unknown;
            } 
            set {
                //QFE 4554
                if (value == TransferEncoding.Base64) {
                    Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)] = "base64"; 
                }
                else if (value == TransferEncoding.QuotedPrintable) { 
                    Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)] = "quoted-printable"; 
                }
                else if (value == TransferEncoding.SevenBit) { 
                    Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)] = "7bit";
                }
                else {
                    throw new NotSupportedException(SR.GetString(SR.MimeTransferEncodingNotSupported, value)); 
                }
            } 
        } 

        internal void SetContent(Stream stream){ 
            if (stream == null) {
                throw new ArgumentNullException("stream");
            }
 
            if (streamSet) {
                this.stream.Close(); 
                this.stream = null; 
                streamSet = false;
            } 

            this.stream = stream;
            streamSet = true;
            streamUsedOnce = false; 
            TransferEncoding = TransferEncoding.Base64;
        } 
 
        internal void SetContent(Stream stream, string name, string mimeType) {
            if (stream == null) { 
                throw new ArgumentNullException("stream");
            }

            if (mimeType != null && mimeType != string.Empty) { 
                contentType = new ContentType(mimeType);
            } 
            if (name != null && name != string.Empty) { 
                ContentType.Name = name;
            } 
            SetContent(stream);
        }

 
        internal void SetContent(Stream stream, ContentType contentType) {
            if (stream == null) { 
                throw new ArgumentNullException("stream"); 
            }
            this.contentType = contentType; 
            SetContent(stream);
        }

 
        internal void Complete(IAsyncResult result, Exception e){
            //if we already completed and we got called again, 
            //it mean's that there was an exception in the callback and we 
            //should just rethrow it.
 
            MimePartContext context = (MimePartContext)result.AsyncState;
            if (context.completed) {
                throw e;
            } 

            try{ 
                if(context.outputStream != null){ 
                    context.outputStream.Close();
                } 
            }
            catch(Exception ex){
                if (e == null) {
                    e = ex; 
                }
            } 
            context.completed = true; 
            context.result.InvokeCallback(e);
        } 


        internal void ReadCallback(IAsyncResult result)
        { 
            if (result.CompletedSynchronously ) {
                return; 
            } 

            ((MimePartContext)result.AsyncState).completedSynchronously = false; 

            try {
                ReadCallbackHandler(result);
            } 
            catch(Exception e){
                Complete(result,e); 
            } 
        }
 

        internal void ReadCallbackHandler(IAsyncResult result){
            MimePartContext context = (MimePartContext)result.AsyncState;
            context.bytesLeft = Stream.EndRead(result); 
            if (context.bytesLeft > 0) {
                IAsyncResult writeResult = context.outputStream.BeginWrite(context.buffer, 0, context.bytesLeft, writeCallback, context); 
                if (writeResult.CompletedSynchronously) { 
                    WriteCallbackHandler(writeResult);
                } 
            }
            else {
                Complete(result,null);
            } 
        }
 
 
        internal void WriteCallback(IAsyncResult result)
        { 
            if (result.CompletedSynchronously ) {
                return;
            }
 
            ((MimePartContext)result.AsyncState).completedSynchronously = false;
 
            try { 
                WriteCallbackHandler(result);
            } 
            catch (Exception e) {
                Complete(result,e);
            }
        } 

 
 
        internal void WriteCallbackHandler(IAsyncResult result){
            MimePartContext context = (MimePartContext)result.AsyncState; 
            context.outputStream.EndWrite(result);
            IAsyncResult readResult = Stream.BeginRead(context.buffer, 0, context.buffer.Length, readCallback, context);
            if (readResult.CompletedSynchronously) {
                ReadCallbackHandler(readResult); 
            }
        } 
 

        internal Stream GetEncodedStream(Stream stream){ 
            Stream outputStream = stream;

            if (TransferEncoding == TransferEncoding.Base64) {
                outputStream = new Base64Stream(outputStream, new Base64WriteStateInfo()); 
            }
            else if (TransferEncoding == TransferEncoding.QuotedPrintable) { 
                outputStream = new QuotedPrintableStream(outputStream,true); 
            }
            else if (TransferEncoding == TransferEncoding.SevenBit) { 
                outputStream = new SevenBitStream(outputStream);
            }

            return outputStream; 
        }
 
        internal void ContentStreamCallbackHandler(IAsyncResult result){ 

            MimePartContext context = (MimePartContext)result.AsyncState; 
            Stream outputStream = context.writer.EndGetContentStream(result);
            context.outputStream = GetEncodedStream(outputStream);

            readCallback = new AsyncCallback(ReadCallback); 
            writeCallback = new AsyncCallback(WriteCallback);
            IAsyncResult readResult = Stream.BeginRead(context.buffer, 0, context.buffer.Length,readCallback, context); 
            if (readResult.CompletedSynchronously) { 
                ReadCallbackHandler(readResult);
            } 
        }


        internal void ContentStreamCallback(IAsyncResult result) 
        {
            if (result.CompletedSynchronously ) { 
                return; 
            }
 
            ((MimePartContext)result.AsyncState).completedSynchronously = false;

            try{
                ContentStreamCallbackHandler(result); 
            }
            catch (Exception e) { 
                Complete(result,e); 
            }
        } 


        internal class MimePartContext
        { 
            internal MimePartContext(BaseWriter writer, LazyAsyncResult result)
            { 
                this.writer = writer; 
                this.result = result;
                buffer = new byte[maxBufferSize]; 
            }

            internal Stream outputStream;
            internal LazyAsyncResult result; 
            internal int bytesLeft;
            internal BaseWriter writer; 
            internal byte[] buffer; 
            internal bool completed;
            internal bool completedSynchronously = true; 
        }


        internal override IAsyncResult BeginSend(BaseWriter writer, AsyncCallback callback, object state) 
        {
            writer.WriteHeaders(Headers); 
            MimePartAsyncResult result = new MimePartAsyncResult(this, state, callback); 
            MimePartContext context = new MimePartContext(writer, result);
 
            ResetStream();
            streamUsedOnce = true;
            IAsyncResult contentResult = writer.BeginGetContentStream(new AsyncCallback(ContentStreamCallback),context);
            if (contentResult.CompletedSynchronously) { 
                ContentStreamCallbackHandler(contentResult);
            } 
            return result; 
        }
 

        internal override void Send(BaseWriter writer) {
            if (Stream != null) {
                byte[] buffer = new byte[maxBufferSize]; 

                writer.WriteHeaders(Headers); 
 
                Stream outputStream = writer.GetContentStream();
                outputStream = GetEncodedStream(outputStream); 

                int read;

                ResetStream(); 
                streamUsedOnce = true;
 
                while ((read = Stream.Read(buffer, 0, maxBufferSize)) > 0) { 
                    outputStream.Write(buffer, 0, read);
                } 
                outputStream.Close();
            }
        }
 

        //Ensures that if we've used the stream once, we will either reset it to the origin, or throw. 
        internal void ResetStream(){ 
            if (streamUsedOnce) {
                if (Stream.CanSeek) { 
                    Stream.Seek(0,SeekOrigin.Begin);
                    streamUsedOnce = false;
                }
                else{ 
                    throw new InvalidOperationException(SR.GetString(SR.MimePartCantResetStream));
                } 
            } 
        }
    } 
}

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
using System; 
using System.IO;
using System.Text;
using System.Collections;
using System.Globalization; 
using System.Net.Mail;
 
namespace System.Net.Mime 
{
    /// 
 
    /// Summary description for MimePart.
    /// 
    internal class MimePart: MimeBasePart,IDisposable
    { 
        Stream stream = null;
        bool streamSet = false; 
        bool streamUsedOnce = false; 
        AsyncCallback readCallback;
        AsyncCallback writeCallback; 
        const int maxBufferSize = 0x4400;  //seems optimal for send based on perf analysis

        internal MimePart()
        { 
        }
 
        public void Dispose(){ 
            if (stream != null) {
                stream.Close(); 
            }
        }

        internal Stream Stream { 
            get {
                return stream; 
            } 
        }
 

        internal ContentDisposition ContentDisposition{
            get{
                return contentDisposition; 
            }
            set{ 
                contentDisposition = value; 
                if(value == null){
                    ((HeaderCollection)Headers).InternalRemove(MailHeaderInfo.GetString(MailHeaderID.ContentDisposition)); 
                }
                else{
                    contentDisposition.PersistIfNeeded((HeaderCollection)Headers,true);
                } 
            }
        } 
 
        internal TransferEncoding TransferEncoding {
            get { 
                if (Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)].Equals("base64", StringComparison.OrdinalIgnoreCase))
                    return TransferEncoding.Base64;
                else if(Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)].Equals("quoted-printable", StringComparison.OrdinalIgnoreCase))
                    return TransferEncoding.QuotedPrintable; 
                else if(Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)].Equals("7bit", StringComparison.OrdinalIgnoreCase))
                    return TransferEncoding.SevenBit; 
                else 
                    return TransferEncoding.Unknown;
            } 
            set {
                //QFE 4554
                if (value == TransferEncoding.Base64) {
                    Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)] = "base64"; 
                }
                else if (value == TransferEncoding.QuotedPrintable) { 
                    Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)] = "quoted-printable"; 
                }
                else if (value == TransferEncoding.SevenBit) { 
                    Headers[MailHeaderInfo.GetString(MailHeaderID.ContentTransferEncoding)] = "7bit";
                }
                else {
                    throw new NotSupportedException(SR.GetString(SR.MimeTransferEncodingNotSupported, value)); 
                }
            } 
        } 

        internal void SetContent(Stream stream){ 
            if (stream == null) {
                throw new ArgumentNullException("stream");
            }
 
            if (streamSet) {
                this.stream.Close(); 
                this.stream = null; 
                streamSet = false;
            } 

            this.stream = stream;
            streamSet = true;
            streamUsedOnce = false; 
            TransferEncoding = TransferEncoding.Base64;
        } 
 
        internal void SetContent(Stream stream, string name, string mimeType) {
            if (stream == null) { 
                throw new ArgumentNullException("stream");
            }

            if (mimeType != null && mimeType != string.Empty) { 
                contentType = new ContentType(mimeType);
            } 
            if (name != null && name != string.Empty) { 
                ContentType.Name = name;
            } 
            SetContent(stream);
        }

 
        internal void SetContent(Stream stream, ContentType contentType) {
            if (stream == null) { 
                throw new ArgumentNullException("stream"); 
            }
            this.contentType = contentType; 
            SetContent(stream);
        }

 
        internal void Complete(IAsyncResult result, Exception e){
            //if we already completed and we got called again, 
            //it mean's that there was an exception in the callback and we 
            //should just rethrow it.
 
            MimePartContext context = (MimePartContext)result.AsyncState;
            if (context.completed) {
                throw e;
            } 

            try{ 
                if(context.outputStream != null){ 
                    context.outputStream.Close();
                } 
            }
            catch(Exception ex){
                if (e == null) {
                    e = ex; 
                }
            } 
            context.completed = true; 
            context.result.InvokeCallback(e);
        } 


        internal void ReadCallback(IAsyncResult result)
        { 
            if (result.CompletedSynchronously ) {
                return; 
            } 

            ((MimePartContext)result.AsyncState).completedSynchronously = false; 

            try {
                ReadCallbackHandler(result);
            } 
            catch(Exception e){
                Complete(result,e); 
            } 
        }
 

        internal void ReadCallbackHandler(IAsyncResult result){
            MimePartContext context = (MimePartContext)result.AsyncState;
            context.bytesLeft = Stream.EndRead(result); 
            if (context.bytesLeft > 0) {
                IAsyncResult writeResult = context.outputStream.BeginWrite(context.buffer, 0, context.bytesLeft, writeCallback, context); 
                if (writeResult.CompletedSynchronously) { 
                    WriteCallbackHandler(writeResult);
                } 
            }
            else {
                Complete(result,null);
            } 
        }
 
 
        internal void WriteCallback(IAsyncResult result)
        { 
            if (result.CompletedSynchronously ) {
                return;
            }
 
            ((MimePartContext)result.AsyncState).completedSynchronously = false;
 
            try { 
                WriteCallbackHandler(result);
            } 
            catch (Exception e) {
                Complete(result,e);
            }
        } 

 
 
        internal void WriteCallbackHandler(IAsyncResult result){
            MimePartContext context = (MimePartContext)result.AsyncState; 
            context.outputStream.EndWrite(result);
            IAsyncResult readResult = Stream.BeginRead(context.buffer, 0, context.buffer.Length, readCallback, context);
            if (readResult.CompletedSynchronously) {
                ReadCallbackHandler(readResult); 
            }
        } 
 

        internal Stream GetEncodedStream(Stream stream){ 
            Stream outputStream = stream;

            if (TransferEncoding == TransferEncoding.Base64) {
                outputStream = new Base64Stream(outputStream, new Base64WriteStateInfo()); 
            }
            else if (TransferEncoding == TransferEncoding.QuotedPrintable) { 
                outputStream = new QuotedPrintableStream(outputStream,true); 
            }
            else if (TransferEncoding == TransferEncoding.SevenBit) { 
                outputStream = new SevenBitStream(outputStream);
            }

            return outputStream; 
        }
 
        internal void ContentStreamCallbackHandler(IAsyncResult result){ 

            MimePartContext context = (MimePartContext)result.AsyncState; 
            Stream outputStream = context.writer.EndGetContentStream(result);
            context.outputStream = GetEncodedStream(outputStream);

            readCallback = new AsyncCallback(ReadCallback); 
            writeCallback = new AsyncCallback(WriteCallback);
            IAsyncResult readResult = Stream.BeginRead(context.buffer, 0, context.buffer.Length,readCallback, context); 
            if (readResult.CompletedSynchronously) { 
                ReadCallbackHandler(readResult);
            } 
        }


        internal void ContentStreamCallback(IAsyncResult result) 
        {
            if (result.CompletedSynchronously ) { 
                return; 
            }
 
            ((MimePartContext)result.AsyncState).completedSynchronously = false;

            try{
                ContentStreamCallbackHandler(result); 
            }
            catch (Exception e) { 
                Complete(result,e); 
            }
        } 


        internal class MimePartContext
        { 
            internal MimePartContext(BaseWriter writer, LazyAsyncResult result)
            { 
                this.writer = writer; 
                this.result = result;
                buffer = new byte[maxBufferSize]; 
            }

            internal Stream outputStream;
            internal LazyAsyncResult result; 
            internal int bytesLeft;
            internal BaseWriter writer; 
            internal byte[] buffer; 
            internal bool completed;
            internal bool completedSynchronously = true; 
        }


        internal override IAsyncResult BeginSend(BaseWriter writer, AsyncCallback callback, object state) 
        {
            writer.WriteHeaders(Headers); 
            MimePartAsyncResult result = new MimePartAsyncResult(this, state, callback); 
            MimePartContext context = new MimePartContext(writer, result);
 
            ResetStream();
            streamUsedOnce = true;
            IAsyncResult contentResult = writer.BeginGetContentStream(new AsyncCallback(ContentStreamCallback),context);
            if (contentResult.CompletedSynchronously) { 
                ContentStreamCallbackHandler(contentResult);
            } 
            return result; 
        }
 

        internal override void Send(BaseWriter writer) {
            if (Stream != null) {
                byte[] buffer = new byte[maxBufferSize]; 

                writer.WriteHeaders(Headers); 
 
                Stream outputStream = writer.GetContentStream();
                outputStream = GetEncodedStream(outputStream); 

                int read;

                ResetStream(); 
                streamUsedOnce = true;
 
                while ((read = Stream.Read(buffer, 0, maxBufferSize)) > 0) { 
                    outputStream.Write(buffer, 0, read);
                } 
                outputStream.Close();
            }
        }
 

        //Ensures that if we've used the stream once, we will either reset it to the origin, or throw. 
        internal void ResetStream(){ 
            if (streamUsedOnce) {
                if (Stream.CanSeek) { 
                    Stream.Seek(0,SeekOrigin.Begin);
                    streamUsedOnce = false;
                }
                else{ 
                    throw new InvalidOperationException(SR.GetString(SR.MimePartCantResetStream));
                } 
            } 
        }
    } 
}

// File provided for Reference Use Only by Microsoft Corporation (c) 2007.
// Copyright (c) Microsoft Corporation. All rights reserved.
                        

                        

                        
                        

Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK

• ZipIOModeEnforcingStream.cs
• WebHttpDispatchOperationSelector.cs
• CommandBinding.cs
• XmlEnumAttribute.cs
• Random.cs
• SqlAggregateChecker.cs
• CodeExporter.cs
• SqlClientPermission.cs
• BasicExpressionVisitor.cs
• newitemfactory.cs
• Journal.cs
• AstTree.cs
• ConnectionManagementElementCollection.cs
• GroupQuery.cs
• Rectangle.cs
• ProcessModuleCollection.cs
• XslNumber.cs
• _AutoWebProxyScriptEngine.cs
• DictionaryBase.cs
• HtmlFormParameterReader.cs
• QilStrConcatenator.cs
• FlowDocumentPage.cs
• GraphicsState.cs
• ViewBase.cs
• TreeViewImageKeyConverter.cs
• MarkupObject.cs
• AssemblyResourceLoader.cs
• ToolBarTray.cs
• DemultiplexingDispatchMessageFormatter.cs
• SimpleTypeResolver.cs
• XmlSerializationGeneratedCode.cs
• SecurityContextSecurityTokenAuthenticator.cs
• LinqDataSource.cs
• StatusBarPanelClickEvent.cs
• CaseInsensitiveHashCodeProvider.cs
• FolderLevelBuildProvider.cs
• InputReport.cs
• SlipBehavior.cs
• Permission.cs
• ConcurrentBag.cs
• initElementDictionary.cs
• MouseOverProperty.cs
• SynchronizedPool.cs
• DbProviderManifest.cs
• ToolStripDropDownClosingEventArgs.cs
• TextSpan.cs
• RichTextBoxConstants.cs
• Geometry.cs
• DataGridHeaderBorder.cs
• xmlfixedPageInfo.cs
• Delegate.cs
• SQLRoleProvider.cs
• FrameworkPropertyMetadata.cs
• DeflateEmulationStream.cs
• SharedDp.cs
• TextBoxAutomationPeer.cs
• ComboBoxRenderer.cs
• TextSearch.cs
• Dump.cs
• safesecurityhelperavalon.cs
• ErrorLog.cs
• EncoderExceptionFallback.cs
• OleDbTransaction.cs
• NamedElement.cs
• RenderCapability.cs
• XamlSerializationHelper.cs
• DrawingAttributesDefaultValueFactory.cs
• SiteMapPathDesigner.cs
• DrawingVisualDrawingContext.cs
• XamlBrushSerializer.cs
• Soap.cs
• LongValidatorAttribute.cs
• MemberListBinding.cs
• SqlFacetAttribute.cs
• WebEncodingValidator.cs
• ItemDragEvent.cs
• ChangeNode.cs
• ToolboxItem.cs
• SystemIPv6InterfaceProperties.cs
• AudioFormatConverter.cs
• AutoScrollHelper.cs
• IndependentlyAnimatedPropertyMetadata.cs
• MatrixAnimationUsingKeyFrames.cs
• MergeFailedEvent.cs
• TraceContext.cs
• MsmqIntegrationBinding.cs
• MouseButton.cs
• SchemaEntity.cs
• shaperfactoryquerycacheentry.cs
• MessageQueueCriteria.cs
• CaseInsensitiveHashCodeProvider.cs
• ObjectAnimationUsingKeyFrames.cs
• FileClassifier.cs
• Odbc32.cs
• PeerCustomResolverSettings.cs
• PaintEvent.cs
• UInt16Storage.cs
• DescendentsWalker.cs
• SQLString.cs
• MethodInfo.cs