TextMessageEncoder.cs source code in C# .NET

Source code for the .NET framework in C#

                        

Code:

/ WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / Channels / TextMessageEncoder.cs / 1 / TextMessageEncoder.cs

                            //------------------------------------------------------------ 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//-----------------------------------------------------------
namespace System.ServiceModel.Channels
{ 
    using System.IO;
    using System.Collections.Generic; 
    using System.Runtime.Serialization; 
    using System.ServiceModel.Diagnostics;
    using System.Text; 
    using System.Xml;
    using System.Globalization;
    using System.Net.Mime;
 
    class TextMessageEncoderFactory : MessageEncoderFactory
    { 
 
        TextMessageEncoder messageEncoder;
        internal static ContentEncoding[] Soap11Content = GetContentEncodingMap(MessageVersion.Soap11WSAddressing10); 
        internal static ContentEncoding[] Soap12Content = GetContentEncodingMap(MessageVersion.Soap12WSAddressing10);
        internal static ContentEncoding[] SoapNoneContent = GetContentEncodingMap(MessageVersion.None);
        internal const string Soap11MediaType = "text/xml";
        internal const string Soap12MediaType = "application/soap+xml"; 
        const string XmlMediaType = "application/xml";
 
        public TextMessageEncoderFactory(MessageVersion version, Encoding writeEncoding, int maxReadPoolSize, int maxWritePoolSize, XmlDictionaryReaderQuotas quotas) 
        {
            messageEncoder = new TextMessageEncoder(version, writeEncoding, maxReadPoolSize, maxWritePoolSize, quotas); 
        }

        public override MessageEncoder Encoder
        { 
            get { return messageEncoder; }
        } 
 
        public override MessageVersion MessageVersion
        { 
            get { return messageEncoder.MessageVersion; }
        }

        public int MaxWritePoolSize 
        {
            get { return messageEncoder.MaxWritePoolSize; } 
        } 

        public int MaxReadPoolSize 
        {
            get { return messageEncoder.MaxReadPoolSize; }
        }
 
        public static Encoding[] GetSupportedEncodings()
        { 
            Encoding[] supported = TextEncoderDefaults.SupportedEncodings; 
            Encoding[] enc = new Encoding[supported.Length];
            Array.Copy(supported, enc, supported.Length); 
            return enc;
        }

        public XmlDictionaryReaderQuotas ReaderQuotas 
        {
            get 
            { 
                return messageEncoder.ReaderQuotas;
            } 
        }

        internal static string GetMediaType(MessageVersion version)
        { 
            string mediaType = null;
            if (version.Envelope == EnvelopeVersion.Soap12) 
            { 
                mediaType = TextMessageEncoderFactory.Soap12MediaType;
            } 
            else if (version.Envelope == EnvelopeVersion.Soap11)
            {
                mediaType = TextMessageEncoderFactory.Soap11MediaType;
            } 
            else if (version.Envelope == EnvelopeVersion.None)
            { 
                mediaType = TextMessageEncoderFactory.XmlMediaType; 
            }
            else 
            {
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(
                    SR.GetString(SR.EnvelopeVersionNotSupported, version.Envelope)));
            } 
            return mediaType;
        } 
 
        internal static string GetContentType(string mediaType, Encoding encoding)
        { 
            return String.Format(CultureInfo.InvariantCulture, "{0}; charset={1}", mediaType, TextEncoderDefaults.EncodingToCharSet(encoding));
        }

        static ContentEncoding[] GetContentEncodingMap(MessageVersion version) 
        {
            Encoding[] readEncodings = TextMessageEncoderFactory.GetSupportedEncodings(); 
            string media = GetMediaType(version); 
            ContentEncoding[] map = new ContentEncoding[readEncodings.Length];
            for (int i = 0; i < readEncodings.Length; i++) 
            {
                ContentEncoding contentEncoding = new ContentEncoding();
                contentEncoding.contentType = GetContentType(media, readEncodings[i]);
                contentEncoding.encoding = readEncodings[i]; 
                map[i] = contentEncoding;
            } 
            return map; 
        }
 
        internal static Encoding GetEncodingFromContentType(string contentType, ContentEncoding[] contentMap)
        {
            if (contentType == null)
            { 
                return null;
            } 
 
            // Check for known/expected content types
            for (int i = 0; i < contentMap.Length; i++) 
            {
                if (contentMap[i].contentType == contentType)
                {
                    return contentMap[i].encoding; 
                }
            } 
 
            // then some heuristic matches (since System.Mime.ContentType is a performance hit)
            // start by looking for a parameter. 

            // If none exists, we don't have an encoding
            int semiColonIndex = contentType.IndexOf(';');
            if (semiColonIndex == -1) 
            {
                return null; 
            } 

            // optimize for charset being the first parameter 
            int charsetValueIndex = -1;

            // for Indigo scenarios, we'll have "; charset=", so check for the c
            if ((contentType.Length > semiColonIndex + 11) // need room for parameter + charset + '=' 
                && contentType[semiColonIndex + 2] == 'c'
                && string.Compare("charset=", 0, contentType, semiColonIndex + 2, 8, StringComparison.OrdinalIgnoreCase) == 0) 
            { 
                charsetValueIndex = semiColonIndex + 10;
            } 
            else
            {
                // look for charset= somewhere else in the message
                int paramIndex = contentType.IndexOf("charset=", semiColonIndex + 1, StringComparison.OrdinalIgnoreCase); 
                if (paramIndex != -1)
                { 
                    // validate there's only whitespace or semi-colons beforehand 
                    for (int i = paramIndex - 1; i >= semiColonIndex; i--)
                    { 
                        if (contentType[i] == ';')
                        {
                            charsetValueIndex = paramIndex + 8;
                            break; 
                        }
 
                        if (contentType[i] == '\n') 
                        {
                            if (i == semiColonIndex || contentType[i - 1] != '\r') 
                            {
                                break;
                            }
 
                            i--;
                            continue; 
                        } 

                        if (contentType[i] != ' ' 
                            && contentType[i] != '\t')
                        {
                            break;
                        } 
                    }
                } 
            } 

            string charSet; 
            Encoding enc;

            // we have a possible charset value. If it's easy to parse, do so
            if (charsetValueIndex != -1) 
            {
                // get the next semicolon 
                semiColonIndex = contentType.IndexOf(';', charsetValueIndex); 
                if (semiColonIndex == -1)
                { 
                    charSet = contentType.Substring(charsetValueIndex);
                }
                else
                { 
                    charSet = contentType.Substring(charsetValueIndex, semiColonIndex - charsetValueIndex);
                } 
 
                // and some minimal quote stripping
                if (charSet.Length > 2 && charSet[0] == '"' && charSet[charSet.Length - 1] == '"') 
                {
                    charSet = charSet.Substring(1, charSet.Length - 2);
                }
 
                DiagnosticUtility.DebugAssert(charSet == (new ContentType(contentType)).CharSet,
                        "CharSet parsing failed to correctly parse the ContentType header."); 
 
                if (TryGetEncodingFromCharSet(charSet, out enc))
                { 
                    return enc;
                }
            }
 
            // our quick heuristics failed. fall back to System.Net
            try 
            { 
                ContentType parsedContentType = new ContentType(contentType);
                charSet = parsedContentType.CharSet; 
            }
            catch (FormatException e)
            {
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ProtocolException(SR.GetString(SR.EncoderBadContentType), e)); 
            }
 
            if (TryGetEncodingFromCharSet(charSet, out enc)) 
                return enc;
 
            throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ProtocolException(SR.GetString(SR.EncoderUnrecognizedCharSet, charSet)));
        }

        internal static bool TryGetEncodingFromCharSet(string charSet, out Encoding encoding) 
        {
            encoding = null; 
            if (charSet == null || charSet.Length == 0) 
                return true;
 
            return TextEncoderDefaults.TryGetEncoding(charSet, out encoding);
        }

        internal class ContentEncoding 
        {
            internal string contentType; 
            internal Encoding encoding; 
        }
 
        class TextMessageEncoder : MessageEncoder
        {
            int maxReadPoolSize;
            int maxWritePoolSize; 
            SynchronizedPool streamedWriterPool;
            SynchronizedPool streamedReaderPool; 
            SynchronizedPool bufferedReaderPool; 
            SynchronizedPool bufferedWriterPool;
            SynchronizedPool recycledStatePool; 
            object thisLock;
            string contentType;
            string mediaType;
            Encoding writeEncoding; 
            MessageVersion version;
            bool optimizeWriteForUTF8; 
            const int maxPooledXmlReadersPerMessage = 2; 
            XmlDictionaryReaderQuotas readerQuotas;
            OnXmlDictionaryReaderClose onStreamedReaderClose; 
            ContentEncoding[] contentEncodingMap;

            public TextMessageEncoder(MessageVersion version, Encoding writeEncoding, int maxReadPoolSize, int maxWritePoolSize, XmlDictionaryReaderQuotas quotas)
            { 
                if (version == null)
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("version"); 
                if (writeEncoding == null) 
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("writeEncoding");
 
                TextEncoderDefaults.ValidateEncoding(writeEncoding);
                this.writeEncoding = writeEncoding;
                optimizeWriteForUTF8 = IsUTF8Encoding(writeEncoding);
 
                thisLock = new object();
 
                this.version = version; 
                this.maxReadPoolSize = maxReadPoolSize;
                this.maxWritePoolSize = maxWritePoolSize; 
                this.readerQuotas = new XmlDictionaryReaderQuotas();
                quotas.CopyTo(this.readerQuotas);
                this.onStreamedReaderClose = new OnXmlDictionaryReaderClose(ReturnStreamedReader);
 
                this.mediaType = TextMessageEncoderFactory.GetMediaType(version);
                this.contentType = TextMessageEncoderFactory.GetContentType(mediaType, writeEncoding); 
                if (version.Envelope == EnvelopeVersion.Soap12) 
                {
                    contentEncodingMap = TextMessageEncoderFactory.Soap12Content; 
                }
                else if (version.Envelope == EnvelopeVersion.Soap11)
                {
                    contentEncodingMap = TextMessageEncoderFactory.Soap11Content; 
                }
                else if (version.Envelope == EnvelopeVersion.None) 
                { 
                    contentEncodingMap = TextMessageEncoderFactory.SoapNoneContent;
                } 
                else
                {
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(
                        SR.GetString(SR.EnvelopeVersionNotSupported, version.Envelope))); 
                }
            } 
 
            static bool IsUTF8Encoding(Encoding encoding)
            { 
                return encoding.WebName == "utf-8";
            }

            public override string ContentType 
            {
                get { return contentType; } 
            } 

            public int MaxWritePoolSize 
            {
                get { return maxWritePoolSize; }
            }
 
            public int MaxReadPoolSize
            { 
                get { return maxReadPoolSize; } 
            }
 
            public XmlDictionaryReaderQuotas ReaderQuotas
            {
                get
                { 
                    return readerQuotas;
                } 
            } 

            public override string MediaType 
            {
                get { return mediaType; }
            }
 
            public override MessageVersion MessageVersion
            { 
                get { return version; } 
            }
 
            object ThisLock
            {
                get { return thisLock; }
            } 

 
            internal override bool IsCharSetSupported(string charSet) 
            {
                Encoding tmp; 
                return TextEncoderDefaults.TryGetEncoding(charSet, out tmp);
            }

            public override bool IsContentTypeSupported(string contentType) 
            {
                if (contentType == null) 
                { 
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("contentType");
                } 

                if (base.IsContentTypeSupported(contentType))
                {
                    return true; 
                }
 
                // we support a few extra content types for "none" 
                if (MessageVersion == MessageVersion.None)
                { 
                    const string rss1MediaType = "text/xml";
                    const string rss2MediaType = "application/rss+xml";
                    const string atomMediaType = "application/atom+xml";
                    const string htmlMediaType = "text/html"; 

                    if (IsContentTypeSupported(contentType, rss1MediaType, rss1MediaType)) 
                    { 
                        return true;
                    } 
                    if (IsContentTypeSupported(contentType, rss2MediaType, rss2MediaType))
                    {
                        return true;
                    } 
                    if (IsContentTypeSupported(contentType, htmlMediaType, atomMediaType))
                    { 
                        return true; 
                    }
                    if (IsContentTypeSupported(contentType, atomMediaType, atomMediaType)) 
                    {
                        return true;
                    }
                    // application/xml checked by base method 
                }
 
                return false; 
            }
 
            public override Message ReadMessage(ArraySegment buffer, BufferManager bufferManager, string contentType)
            {
                if (bufferManager == null)
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("bufferManager")); 

                Message message; 
 
                UTF8BufferedMessageData messageData = TakeBufferedReader();
                messageData.Encoding = GetEncodingFromContentType(contentType, this.contentEncodingMap); 
                messageData.Open(buffer, bufferManager);
                RecycledMessageState messageState = messageData.TakeMessageState();
                if (messageState == null)
                    messageState = new RecycledMessageState(); 
                message = new BufferedMessage(messageData, messageState);
 
                message.Properties.Encoder = this; 
                if (MessageLogger.LogMessagesAtTransportLevel)
                    MessageLogger.LogMessage(ref message, MessageLoggingSource.TransportReceive); 
                return message;
            }

            public override Message ReadMessage(Stream stream, int maxSizeOfHeaders, string contentType) 
            {
                if (stream == null) 
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("stream")); 

                XmlReader reader = TakeStreamedReader(stream, GetEncodingFromContentType(contentType, this.contentEncodingMap)); 
                Message message = Message.CreateMessage(reader, maxSizeOfHeaders, version);
                message.Properties.Encoder = this;
                if (MessageLogger.LogMessagesAtTransportLevel)
                    MessageLogger.LogMessage(ref message, MessageLoggingSource.TransportReceive); 
                return message;
            } 
 
            public override ArraySegment WriteMessage(Message message, int maxMessageSize, BufferManager bufferManager, int messageOffset)
            { 
                if (message == null)
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("message"));
                if (bufferManager == null)
                    throw TraceUtility.ThrowHelperError(new ArgumentNullException("bufferManager"), message); 
                if (maxMessageSize < 0)
                    throw TraceUtility.ThrowHelperError(new ArgumentOutOfRangeException("maxMessageSize", maxMessageSize, 
                                                                SR.GetString(SR.ValueMustBeNonNegative)), message); 
                if (messageOffset < 0 || messageOffset > maxMessageSize)
                    throw TraceUtility.ThrowHelperError(new ArgumentOutOfRangeException("messageOffset", messageOffset, 
                                                    SR.GetString(SR.ValueMustBeInRange, 0, maxMessageSize)), message);

                ThrowIfMismatchedMessageVersion(message);
                message.Properties.Encoder = this; 
                TextBufferedMessageWriter messageWriter = TakeBufferedWriter();
                ArraySegment messageData = messageWriter.WriteMessage(message, bufferManager, messageOffset, maxMessageSize); 
                ReturnMessageWriter(messageWriter); 
                if (MessageLogger.LogMessagesAtTransportLevel)
                { 
                    XmlDictionaryReader xmlDictionaryReader = XmlDictionaryReader.CreateTextReader(messageData.Array, messageData.Offset, messageData.Count, null, XmlDictionaryReaderQuotas.Max, null);
                    MessageLogger.LogMessage(ref message, xmlDictionaryReader, MessageLoggingSource.TransportSend);
                }
                return messageData; 
            }
 
            public override void WriteMessage(Message message, Stream stream) 
            {
                if (message == null) 
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("message"));
                if (stream == null)
                    throw TraceUtility.ThrowHelperError(new ArgumentNullException("stream"), message);
                ThrowIfMismatchedMessageVersion(message); 
                message.Properties.Encoder = this;
                XmlDictionaryWriter xmlWriter = TakeStreamedWriter(stream); 
                if (optimizeWriteForUTF8) 
                {
                    message.WriteMessage(xmlWriter); 
                }
                else
                {
                    xmlWriter.WriteStartDocument(); 
                    message.WriteMessage(xmlWriter);
                    xmlWriter.WriteEndDocument(); 
                } 
                xmlWriter.Flush();
                ReturnStreamedWriter(xmlWriter); 
                if (MessageLogger.LogMessagesAtTransportLevel)
                    MessageLogger.LogMessage(ref message, MessageLoggingSource.TransportSend);
            }
 
            XmlDictionaryWriter TakeStreamedWriter(Stream stream)
            { 
                if (streamedWriterPool == null) 
                {
                    lock (ThisLock) 
                    {
                        if (streamedWriterPool == null)
                        {
                            streamedWriterPool = new SynchronizedPool(maxWritePoolSize); 
                        }
                    } 
                } 
                XmlDictionaryWriter xmlWriter = streamedWriterPool.Take();
                if (xmlWriter == null) 
                    xmlWriter = XmlDictionaryWriter.CreateTextWriter(stream, this.writeEncoding, false);
                else
                    ((IXmlTextWriterInitializer)xmlWriter).SetOutput(stream, this.writeEncoding, false);
                return xmlWriter; 
            }
 
            void ReturnStreamedWriter(XmlWriter xmlWriter) 
            {
                xmlWriter.Close(); 
                streamedWriterPool.Return((XmlDictionaryWriter)xmlWriter);
            }

            TextBufferedMessageWriter TakeBufferedWriter() 
            {
                if (bufferedWriterPool == null) 
                { 
                    lock (ThisLock)
                    { 
                        if (bufferedWriterPool == null)
                        {
                            bufferedWriterPool = new SynchronizedPool(maxWritePoolSize);
                        } 
                    }
                } 
 
                TextBufferedMessageWriter messageWriter = bufferedWriterPool.Take();
                if (messageWriter == null) 
                    messageWriter = new TextBufferedMessageWriter(this);
                return messageWriter;
            }
 
            void ReturnMessageWriter(TextBufferedMessageWriter messageWriter)
            { 
                bufferedWriterPool.Return(messageWriter); 
            }
 
            XmlReader TakeStreamedReader(Stream stream, Encoding enc)
            {
                if (streamedReaderPool == null)
                { 
                    lock (ThisLock)
                    { 
                        if (streamedReaderPool == null) 
                        {
                            streamedReaderPool = new SynchronizedPool(maxReadPoolSize); 
                        }
                    }
                }
                XmlDictionaryReader xmlReader = streamedReaderPool.Take(); 
                if (xmlReader == null)
                    xmlReader = XmlDictionaryReader.CreateTextReader(stream, enc, this.readerQuotas, null); 
                else 
                    ((IXmlTextReaderInitializer)xmlReader).SetInput(stream, enc, this.readerQuotas, onStreamedReaderClose);
                return xmlReader; 
            }

            void ReturnStreamedReader(XmlDictionaryReader xmlReader)
            { 
                streamedReaderPool.Return(xmlReader);
            } 
 
            XmlDictionaryWriter CreateWriter(Stream stream)
            { 
                return XmlDictionaryWriter.CreateTextWriter(stream, writeEncoding, false);
            }

            UTF8BufferedMessageData TakeBufferedReader() 
            {
                if (bufferedReaderPool == null) 
                { 
                    lock (ThisLock)
                    { 
                        if (bufferedReaderPool == null)
                        {
                            bufferedReaderPool = new SynchronizedPool(maxReadPoolSize);
                        } 
                    }
                } 
                UTF8BufferedMessageData messageData = bufferedReaderPool.Take(); 
                if (messageData == null)
                    messageData = new UTF8BufferedMessageData(this, maxPooledXmlReadersPerMessage); 
                return messageData;
            }

            void ReturnBufferedData(UTF8BufferedMessageData messageData) 
            {
                bufferedReaderPool.Return(messageData); 
            } 

            SynchronizedPool RecycledStatePool 
            {
                get
                {
                    if (recycledStatePool == null) 
                    {
                        lock (ThisLock) 
                        { 
                            if (recycledStatePool == null)
                            { 
                                recycledStatePool = new SynchronizedPool(maxReadPoolSize);
                            }
                        }
                    } 
                    return recycledStatePool;
                } 
            } 

            static readonly byte[] xmlDeclarationStartText = { (byte)'<', (byte)'?', (byte)'x', (byte)'m', (byte)'l' }; 
            static readonly byte[] version10Text = { (byte)'v', (byte)'e', (byte)'r', (byte)'s', (byte)'i', (byte)'o', (byte)'n', (byte)'=', (byte)'"', (byte)'1', (byte)'.', (byte)'0', (byte)'"' };
            static readonly byte[] encodingText = { (byte)'e', (byte)'n', (byte)'c', (byte)'o', (byte)'d', (byte)'i', (byte)'n', (byte)'g', (byte)'=' };

            class UTF8BufferedMessageData : BufferedMessageData 
            {
                TextMessageEncoder messageEncoder; 
                Pool readerPool; 
                OnXmlDictionaryReaderClose onClose;
                Encoding encoding; 

                const int additionalNodeSpace = 1024;

                public UTF8BufferedMessageData(TextMessageEncoder messageEncoder, int maxReaderPoolSize) 
                    : base(messageEncoder.RecycledStatePool)
                { 
                    this.messageEncoder = messageEncoder; 
                    readerPool = new Pool(maxReaderPoolSize);
                    onClose = new OnXmlDictionaryReaderClose(OnXmlReaderClosed); 
                }

                internal Encoding Encoding
                { 
                    set
                    { 
                        this.encoding = value; 
                    }
                } 

                public override MessageEncoder MessageEncoder
                {
                    get { return messageEncoder; } 
                }
 
                public override XmlDictionaryReaderQuotas Quotas 
                {
                    get { return messageEncoder.readerQuotas; } 
                }

                protected override void OnClosed()
                { 
                    messageEncoder.ReturnBufferedData(this);
                } 
 
                protected override XmlDictionaryReader TakeXmlReader()
                { 
                    ArraySegment buffer = this.Buffer;

                    XmlDictionaryReader xmlReader = readerPool.Take();
                    if (xmlReader == null) 
                        xmlReader = XmlDictionaryReader.CreateTextReader(buffer.Array, buffer.Offset, buffer.Count, this.encoding, messageEncoder.readerQuotas, onClose);
                    else 
                        ((IXmlTextReaderInitializer)xmlReader).SetInput(buffer.Array, buffer.Offset, buffer.Count, this.encoding, messageEncoder.readerQuotas, onClose); 

                    return xmlReader; 
                }

                protected override void ReturnXmlReader(XmlDictionaryReader xmlReader)
                { 
                    if (xmlReader != null)
                    { 
                        readerPool.Return(xmlReader); 
                    }
                } 
            }

            class TextBufferedMessageWriter : BufferedMessageWriter
            { 
                TextMessageEncoder messageEncoder;
                XmlDictionaryWriter writer; 
 
                public TextBufferedMessageWriter(TextMessageEncoder messageEncoder)
                { 
                    this.messageEncoder = messageEncoder;
                }

                protected override void OnWriteStartMessage(XmlDictionaryWriter writer) 
                {
                    if (!messageEncoder.optimizeWriteForUTF8) 
                        writer.WriteStartDocument(); 
                }
 
                protected override void OnWriteEndMessage(XmlDictionaryWriter writer)
                {
                    if (!messageEncoder.optimizeWriteForUTF8)
                        writer.WriteEndDocument(); 
                }
 
                protected override XmlDictionaryWriter TakeXmlWriter(Stream stream) 
                {
                    if (messageEncoder.optimizeWriteForUTF8) 
                    {
                        XmlDictionaryWriter returnedWriter = writer;
                        if (returnedWriter == null)
                        { 
                            returnedWriter = XmlDictionaryWriter.CreateTextWriter(stream, messageEncoder.writeEncoding, false);
                        } 
                        else 
                        {
                            writer = null; 
                            ((IXmlTextWriterInitializer)returnedWriter).SetOutput(stream, messageEncoder.writeEncoding, false);
                        }
                        return returnedWriter;
                    } 
                    else
                    { 
                        return messageEncoder.CreateWriter(stream); 
                    }
                } 

                protected override void ReturnXmlWriter(XmlDictionaryWriter writer)
                {
                    writer.Close(); 

                    if (messageEncoder.optimizeWriteForUTF8) 
                    { 
                        if (this.writer == null)
                            this.writer = writer; 
                    }
                }
            }
        } 
    }
} 

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


                        

Link Menu

Network programming in C#, Network Programming in VB.NET, Network Programming in .NET
This book is available now!
Buy at Amazon US or
Buy at Amazon UK