HttpStreamMessage.cs source code in C# .NET

                        Code:
                         / WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / NetFx35 / System.ServiceModel.Web / System / ServiceModel / Channels / HttpStreamMessage.cs / 1 / HttpStreamMessage.cs
                        
                        
                            //---------------------------------------------------------------------------- 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//---------------------------------------------------------------------------

#pragma warning disable 1634 // Stops compiler from warning about unknown warnings (for Presharp) 

namespace System.ServiceModel.Channels 
{ 
    using System;
    using System.ServiceModel; 
    using System.ServiceModel.Channels;
    using System.ServiceModel.Description;
    using System.Collections.Generic;
    using System.Xml; 
    using System.Runtime.Serialization;
    using DiagnosticUtility = System.ServiceModel.DiagnosticUtility; 
    using System.IO; 

    class HttpStreamMessage : Message 
    {
        internal const string StreamElementName = "Binary";
        BodyWriter bodyWriter;
        MessageHeaders headers; 
        MessageProperties properties;
 
        public HttpStreamMessage(Stream stream) 
        {
            if (stream == null) 
            {
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("stream");
            }
            this.bodyWriter = new HttpStreamBodyWriter(stream); 
            this.headers = new MessageHeaders(MessageVersion.None, 1);
            this.properties = new MessageProperties(); 
        } 

        public HttpStreamMessage(MessageHeaders headers, MessageProperties properties, BodyWriter bodyWriter) 
        {
            if (bodyWriter == null)
            {
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("bodyWriter"); 
            }
            this.headers = new MessageHeaders(headers); 
            this.properties = new MessageProperties(properties); 
            this.bodyWriter = bodyWriter;
        } 

        public override MessageHeaders Headers
        {
            get 
            {
                if (IsDisposed) 
                { 
#pragma warning suppress 56503
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateDisposedException()); 
                }
                return headers;
            }
        } 

        public override bool IsEmpty 
        { 
            get
            { 
                return false;
            }
        }
 
        public override bool IsFault
        { 
            get { return false; } 
        }
 
        public override MessageProperties Properties
        {
            get
            { 
                if (IsDisposed)
                { 
#pragma warning suppress 56503 
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateDisposedException());
                } 
                return properties;
            }
        }
 
        public override MessageVersion Version
        { 
            get 
            {
                if (IsDisposed) 
                {
#pragma warning suppress 56503
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateDisposedException());
                } 
                return MessageVersion.None;
            } 
        } 

        protected override void OnBodyToString(XmlDictionaryWriter writer) 
        {
            if (this.bodyWriter.IsBuffered)
            {
                bodyWriter.WriteBodyContents(writer); 
            }
            else 
            { 
                writer.WriteString(SR2.GetString(SR2.MessageBodyIsStream));
            } 
        }

        protected override void OnClose()
        { 
            Exception ex = null;
            try 
            { 
                base.OnClose();
            } 
            catch (Exception e)
            {
                if (DiagnosticUtility.IsFatal(e))
                { 
                    throw;
                } 
                ex = e; 
            }
 
            try
            {
                if (properties != null)
                { 
                    properties.Dispose();
                } 
            } 
            catch (Exception e)
            { 
                if (DiagnosticUtility.IsFatal(e))
                {
                    throw;
                } 
                if (ex == null)
                { 
                    ex = e; 
                }
            } 

            if (ex != null)
            {
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(ex); 
            }
 
            this.bodyWriter = null; 
        }
 
        protected override MessageBuffer OnCreateBufferedCopy(int maxBufferSize)
        {
            BodyWriter bufferedBodyWriter;
            if (this.bodyWriter.IsBuffered) 
            {
                bufferedBodyWriter = this.bodyWriter; 
            } 
            else
            { 
                bufferedBodyWriter = this.bodyWriter.CreateBufferedCopy(maxBufferSize);
            }
            return new HttpStreamMessageBuffer(this.Headers, new MessageProperties(this.Properties), bufferedBodyWriter);
        } 

        protected override void OnWriteBodyContents(XmlDictionaryWriter writer) 
        { 
            this.bodyWriter.WriteBodyContents(writer);
        } 

        Exception CreateDisposedException()
        {
            return new ObjectDisposedException("", SR2.GetString(SR2.MessageClosed)); 
        }
 
        class HttpStreamBodyWriter : BodyWriter 
        {
            Stream stream; 
            Object thisLock;

            public HttpStreamBodyWriter(Stream stream)
                : base(false) 
            {
                if (stream == null) 
                { 
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("stream");
                } 
                this.stream = stream;
                thisLock = new Object();
            }
 
            object ThisLock
            { 
                get { return thisLock; } 
            }
 
            protected override BodyWriter OnCreateBufferedCopy(int maxBufferSize)
            {
                using (BufferedOutputStream bufferedStream = new BufferedOutputStream(SR2.MaxReceivedMessageSizeExceeded, maxBufferSize))
                { 
                    using (HttpStreamXmlDictionaryWriter writer = new HttpStreamXmlDictionaryWriter(bufferedStream))
                    { 
                        OnWriteBodyContents(writer); 
                        writer.Flush();
                        int size; 
                        byte[] bytesArray = bufferedStream.ToArray(out size);
                        return new BufferedBytesBodyWriter(bytesArray, size);
                    }
                } 
            }
 
            protected override void OnWriteBodyContents(XmlDictionaryWriter writer) 
            {
                lock (ThisLock) 
                {
                    writer.WriteStartElement(StreamElementName, string.Empty);
                    writer.WriteValue(new HttpStreamProvider(this.stream));
                    writer.WriteEndElement(); 
                }
            } 
 
            class BufferedBytesBodyWriter : BodyWriter
            { 
                byte[] array;
                int size;

                public BufferedBytesBodyWriter(byte[] array, int size) 
                    : base(true)
                { 
                    this.array = array; 
                    this.size = size;
                } 

                protected override void OnWriteBodyContents(XmlDictionaryWriter writer)
                {
                    writer.WriteStartElement(StreamElementName, string.Empty); 
                    writer.WriteBase64(this.array, 0, size);
                    writer.WriteEndElement(); 
                } 
            }
 
            class HttpStreamProvider : IStreamProvider
            {
                Stream stream;
 
                internal HttpStreamProvider(Stream stream)
                { 
                    this.stream = stream; 
                }
 
                public Stream GetStream()
                {
                    return stream;
                } 

                public void ReleaseStream(Stream stream) 
                { 
                    //Noop
                } 
            }
        }

        class HttpStreamMessageBuffer : MessageBuffer 
        {
            BodyWriter bodyWriter; 
            bool closed; 
            MessageHeaders headers;
            MessageProperties properties; 
            object thisLock = new object();

            public HttpStreamMessageBuffer(MessageHeaders headers,
                MessageProperties properties, BodyWriter bodyWriter) 
                : base()
            { 
                this.bodyWriter = bodyWriter; 
                this.headers = headers;
                this.properties = properties; 
            }

            public override int BufferSize
            { 
                get { return 0; }
            } 
 
            object ThisLock
            { 
                get { return thisLock; }
            }

            public override void Close() 
            {
                lock (ThisLock) 
                { 
                    if (!closed)
                    { 
                        closed = true;
                        bodyWriter = null;
                        headers = null;
                        properties = null; 
                    }
                } 
            } 

            public override Message CreateMessage() 
            {
                lock (ThisLock)
                {
                    if (closed) 
                    {
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(CreateDisposedException()); 
                    } 
                    return new HttpStreamMessage(this.headers, this.properties, this.bodyWriter);
                } 
            }

            Exception CreateDisposedException()
            { 
                return new ObjectDisposedException("", SR2.GetString(SR2.MessageBufferIsClosed));
            } 
        } 
    }
} 

// 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
HttpStreamMessage.cs source code in C# .NET

Source code for the .NET framework in C#

Code:

Link Menu
