MessageFault.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 / MessageFault.cs / 1 / MessageFault.cs

                            //------------------------------------------------------------ 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//-----------------------------------------------------------

 
namespace System.ServiceModel.Channels
{ 
    using System.Xml; 
    using System.ServiceModel;
    using System.ServiceModel.Description; 
    using System.Text;
    using System.Collections.Generic;
    using System.Runtime.Serialization;
    using System.ServiceModel.Diagnostics; 
    using System.ServiceModel.Dispatcher;
 
    public abstract class MessageFault 
    {
        public static MessageFault CreateFault(FaultCode code, string reason) 
        {
            return CreateFault(code, new FaultReason(reason));
        }
 
        public static MessageFault CreateFault(FaultCode code, FaultReason reason)
        { 
            return CreateFault(code, reason, null, null, "", ""); 
        }
 
        public static MessageFault CreateFault(FaultCode code, FaultReason reason, object detail)
        {
            return CreateFault(code, reason, detail, DataContractSerializerDefaults.CreateSerializer(
                (detail == null ? typeof(object) : detail.GetType()), int.MaxValue/*maxItems*/), "", ""); 
        }
 
        public static MessageFault CreateFault(FaultCode code, FaultReason reason, object detail, XmlObjectSerializer serializer) 
        {
            return CreateFault(code, reason, detail, serializer, "", ""); 
        }

        public static MessageFault CreateFault(FaultCode code, FaultReason reason, object detail, XmlObjectSerializer serializer, string actor)
        { 
            if (serializer == null)
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("serializer")); 
            return CreateFault(code, reason, detail, serializer, actor, actor); 
        }
 
        public static MessageFault CreateFault(FaultCode code, FaultReason reason, object detail, XmlObjectSerializer serializer, string actor, string node)
        {
            if (code == null)
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("code")); 
            if (reason == null)
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("reason")); 
            if (actor == null) 
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("actor"));
            if (node == null) 
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("node"));
            return new XmlObjectSerializerFault(code, reason, detail, serializer, actor, node);
        }
 
        public static MessageFault CreateFault(Message message, int maxBufferSize)
        { 
            if (message == null) 
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("message"));
            XmlDictionaryReader reader = message.GetReaderAtBodyContents(); 
            using (reader)
            {
                try
                { 
#pragma warning suppress 56506 // [....], Message.Version can never be null
                    EnvelopeVersion envelopeVersion = message.Version.Envelope; 
                    MessageFault fault; 
                    if (envelopeVersion == EnvelopeVersion.Soap12)
                    { 
                        fault = ReceivedFault.CreateFault12(reader, maxBufferSize);
                    }
                    else if (envelopeVersion == EnvelopeVersion.Soap11)
                    { 
                        fault = ReceivedFault.CreateFault11(reader, maxBufferSize);
                    } 
                    else if (envelopeVersion == EnvelopeVersion.None) 
                    {
                        fault = ReceivedFault.CreateFaultNone(reader, maxBufferSize); 
                    }
                    else
                    {
                        throw TraceUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.EnvelopeVersionUnknown, envelopeVersion.ToString())), message); 
                    }
                    message.ReadFromBodyContentsToEnd(reader); 
                    return fault; 
                }
                catch (InvalidOperationException e) 
                {
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new CommunicationException(
                        SR.GetString(SR.SFxErrorDeserializingFault), e));
                } 
                catch (FormatException e)
                { 
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new CommunicationException( 
                        SR.GetString(SR.SFxErrorDeserializingFault), e));
                } 
                catch (XmlException e)
                {
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new CommunicationException(
                        SR.GetString(SR.SFxErrorDeserializingFault), e)); 
                }
            } 
        } 

        public virtual string Actor 
        {
            get
            {
                return ""; 
            }
        } 
 
        public abstract FaultCode Code { get; }
 
        public bool IsMustUnderstandFault
        {
            get
            { 
                FaultCode code = this.Code;
                if (String.Compare(code.Name, MessageStrings.MustUnderstandFault, StringComparison.Ordinal) != 0) 
                { 
                    return false;
                } 

                if ((String.Compare(code.Namespace, EnvelopeVersion.Soap11.Namespace, StringComparison.Ordinal) != 0) &&
                    (String.Compare(code.Namespace, EnvelopeVersion.Soap12.Namespace, StringComparison.Ordinal) != 0))
                { 
                    return false;
                } 
 
                return true;
            } 
        }

        public virtual string Node
        { 
            get
            { 
                return ""; 
            }
        } 

        public abstract bool HasDetail { get; }

        public abstract FaultReason Reason { get; } 

        public T GetDetail() 
        { 
            return GetDetail(DataContractSerializerDefaults.CreateSerializer(typeof(T), int.MaxValue/*maxItems*/));
        } 

        public T GetDetail(XmlObjectSerializer serializer)
        {
            if (serializer == null) 
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("serializer"));
            XmlDictionaryReader reader = GetReaderAtDetailContents(); 
            T value = (T)serializer.ReadObject(reader); 
            if (!reader.EOF)
            { 
                reader.MoveToContent();
                if (reader.NodeType != XmlNodeType.EndElement && !reader.EOF)
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new FormatException(SR.GetString(SR.ExtraContentIsPresentInFaultDetail)));
            } 
            return value;
        } 
 
        public XmlDictionaryReader GetReaderAtDetailContents()
        { 
            if (!HasDetail)
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.FaultDoesNotHaveAnyDetail)));
            return OnGetReaderAtDetailContents();
        } 

        protected virtual void OnWriteDetail(XmlDictionaryWriter writer, EnvelopeVersion version) 
        { 
            OnWriteStartDetail(writer, version);
            OnWriteDetailContents(writer); 
            writer.WriteEndElement();
        }

        protected virtual void OnWriteStartDetail(XmlDictionaryWriter writer, EnvelopeVersion version) 
        {
            if (version == EnvelopeVersion.Soap12) 
                writer.WriteStartElement(XD.Message12Dictionary.FaultDetail, XD.Message12Dictionary.Namespace); 
            else if (version == EnvelopeVersion.Soap11)
                writer.WriteStartElement(XD.Message11Dictionary.FaultDetail, XD.Message11Dictionary.FaultNamespace); 
            else
                writer.WriteStartElement(XD.Message12Dictionary.FaultDetail, XD.MessageDictionary.Namespace);
        }
 
        protected abstract void OnWriteDetailContents(XmlDictionaryWriter writer);
 
        protected virtual XmlDictionaryReader OnGetReaderAtDetailContents() 
        {
            XmlBuffer detailBuffer = new XmlBuffer(int.MaxValue); 
            XmlDictionaryWriter writer = detailBuffer.OpenSection(XmlDictionaryReaderQuotas.Max);
            OnWriteDetail(writer, EnvelopeVersion.Soap12);  // Wrap in soap 1.2 by default
            detailBuffer.CloseSection();
            detailBuffer.Close(); 
            XmlDictionaryReader reader = detailBuffer.GetReader(0);
            reader.Read(); // Skip the detail element 
            return reader; 
        }
 
        public static bool WasHeaderNotUnderstood(MessageHeaders headers, string name, string ns)
        {
            if (headers == null)
            { 
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperArgumentNull("headers");
            } 
 
            for (int i=0; i 0)
                writer.WriteElementString(XD.Message12Dictionary.FaultNode, version.DictionaryNamespace, Node); 
            if (Actor.Length > 0)
                writer.WriteElementString(XD.Message12Dictionary.FaultRole, version.DictionaryNamespace, Actor); 
            if (HasDetail) 
            {
                OnWriteDetail(writer, version); 
            }
            writer.WriteEndElement();
        }
 
        void WriteFaultCode12Driver(XmlDictionaryWriter writer, FaultCode faultCode, EnvelopeVersion version)
        { 
            writer.WriteStartElement(XD.Message12Dictionary.FaultValue, version.DictionaryNamespace); 
            string name;
            if (faultCode.IsSenderFault) 
                name = version.SenderFaultName;
            else if (faultCode.IsReceiverFault)
                name = version.ReceiverFaultName;
            else 
                name = faultCode.Name;
            string ns; 
            if (faultCode.IsPredefinedFault) 
                ns = version.Namespace;
            else 
                ns = faultCode.Namespace;
            string prefix = writer.LookupPrefix(ns);
            if (prefix == null)
                writer.WriteAttributeString("xmlns", "a", XmlUtil.XmlNsNs, ns); 
            writer.WriteQualifiedName(name, ns);
            writer.WriteEndElement(); 
 
            if (faultCode.SubCode != null)
            { 
                writer.WriteStartElement(XD.Message12Dictionary.FaultSubcode, version.DictionaryNamespace);
                WriteFaultCode12Driver(writer, faultCode.SubCode, version);
                writer.WriteEndElement();
            } 
        }
 
        void WriteTo12(XmlDictionaryWriter writer) 
        {
            WriteTo12Driver(writer, EnvelopeVersion.Soap12); 
        }

        void WriteTo11(XmlDictionaryWriter writer)
        { 
            writer.WriteStartElement(XD.MessageDictionary.Fault, XD.Message11Dictionary.Namespace);
            writer.WriteStartElement(XD.Message11Dictionary.FaultCode, XD.Message11Dictionary.FaultNamespace); 
 
            FaultCode faultCode = Code;
            if (faultCode.SubCode != null) 
                faultCode = faultCode.SubCode;

            string name;
            if (faultCode.IsSenderFault) 
                name = "Client";
            else if (faultCode.IsReceiverFault) 
                name = "Server"; 
            else
                name = faultCode.Name; 
            string ns;
            if (faultCode.IsPredefinedFault)
                ns = Message11Strings.Namespace;
            else 
                ns = faultCode.Namespace;
            string prefix = writer.LookupPrefix(ns); 
            if (prefix == null) 
                writer.WriteAttributeString("xmlns", "a", XmlUtil.XmlNsNs, ns);
            writer.WriteQualifiedName(name, ns); 
            writer.WriteEndElement();
            FaultReasonText translation = Reason.Translations[0];
            writer.WriteStartElement(XD.Message11Dictionary.FaultString, XD.Message11Dictionary.FaultNamespace);
            if (translation.XmlLang.Length > 0) 
                writer.WriteAttributeString("xml", "lang", XmlUtil.XmlNs, translation.XmlLang);
            writer.WriteString(translation.Text); 
            writer.WriteEndElement(); 
            if (Actor.Length > 0)
                writer.WriteElementString(XD.Message11Dictionary.FaultActor, XD.Message11Dictionary.FaultNamespace, Actor); 
            if (HasDetail)
            {
                OnWriteDetail(writer, EnvelopeVersion.Soap11);
            } 
            writer.WriteEndElement();
        } 
    } 

    class XmlObjectSerializerFault : MessageFault 
    {
        FaultCode code;
        FaultReason reason;
        string actor; 
        string node;
        object detail; 
        XmlObjectSerializer serializer; 

        public XmlObjectSerializerFault(FaultCode code, FaultReason reason, object detail, XmlObjectSerializer serializer, string actor, string node) 
        {
            this.code = code;
            this.reason = reason;
            this.detail = detail; 
            this.serializer = serializer;
            this.actor = actor; 
            this.node = node; 
        }
 
        public override string Actor
        {
            get
            { 
                return actor;
            } 
        } 

        public override FaultCode Code 
        {
            get
            {
                return code; 
            }
        } 
 
        public override bool HasDetail
        { 
            get
            {
                return serializer != null;
            } 
        }
 
        public override string Node 
        {
            get 
            {
                return node;
            }
        } 

        public override FaultReason Reason 
        { 
            get
            { 
                return reason;
            }
        }
 
        object ThisLock
        { 
            get 
            {
                return code; 
            }
        }

        protected override void OnWriteDetailContents(XmlDictionaryWriter writer) 
        {
            if (serializer != null) 
            { 
                lock (ThisLock)
                { 
                    serializer.WriteObject(writer, detail);
                }
            }
        } 
    }
 
    class ReceivedFault : MessageFault 
    {
        FaultCode code; 
        FaultReason reason;
        string actor;
        string node;
        XmlBuffer detail; 
        bool hasDetail;
 
        ReceivedFault(FaultCode code, FaultReason reason, string actor, string node, XmlBuffer detail) 
        {
            this.code = code; 
            this.reason = reason;
            this.actor = actor;
            this.node = node;
            this.hasDetail = InferHasDetail(detail); 
            this.detail = this.hasDetail ? detail : null;
        } 
 
        public override string Actor
        { 
            get
            {
                return actor;
            } 
        }
 
        public override FaultCode Code 
        {
            get 
            {
                return code;
            }
        } 

        public override bool HasDetail 
        { 
            get
            { 
                return hasDetail;
            }
        }
 
        public override string Node
        { 
            get 
            {
                return node; 
            }
        }

        public override FaultReason Reason 
        {
            get 
            { 
                return reason;
            } 
        }

        bool InferHasDetail(XmlBuffer detail)
        { 
            bool hasDetail = false;
            if (detail != null) 
            { 
                XmlDictionaryReader reader = detail.GetReader(0);
                if (!reader.IsEmptyElement && reader.Read()) // check if the detail element contains data 
                    hasDetail = (reader.MoveToContent() != XmlNodeType.EndElement);
                reader.Close();
            }
            return hasDetail; 
        }
 
        protected override void OnWriteDetail(XmlDictionaryWriter writer, EnvelopeVersion version) 
        {
            using (XmlReader r = detail.GetReader(0)) 
            {
                // Start the element
                base.OnWriteStartDetail(writer, version);
 
                // Copy the attributes
                while(r.MoveToNextAttribute()) 
                    writer.WriteAttributeString(r.Prefix, r.LocalName, r.NamespaceURI, r.Value); 
                r.MoveToElement();
 
                r.Read();

                // Copy the contents
                while (r.NodeType != XmlNodeType.EndElement) 
                    writer.WriteNode(r,false);
 
                // End the element 
                writer.WriteEndElement();
            } 
        }

        protected override void OnWriteStartDetail(XmlDictionaryWriter writer, EnvelopeVersion version)
        { 
            using (XmlReader r = detail.GetReader(0))
            { 
                // Start the element 
                base.OnWriteStartDetail(writer, version);
 
                // Copy the attributes
                while(r.MoveToNextAttribute())
                    writer.WriteAttributeString(r.Prefix, r.LocalName, r.NamespaceURI, r.Value);
            } 
        }
 
        protected override void OnWriteDetailContents(XmlDictionaryWriter writer) 
        {
            using (XmlReader r = detail.GetReader(0)) 
            {
                r.Read();
                while (r.NodeType != XmlNodeType.EndElement)
                    writer.WriteNode(r,false); 
            }
        } 
 
        protected override XmlDictionaryReader OnGetReaderAtDetailContents()
        { 
            XmlDictionaryReader reader = detail.GetReader(0);
            reader.Read(); // Skip the detail element
            return reader;
        } 

        public static ReceivedFault CreateFaultNone(XmlDictionaryReader reader, int maxBufferSize) 
        { 
            return CreateFault12Driver(reader, maxBufferSize, EnvelopeVersion.None);
        } 

        static ReceivedFault CreateFault12Driver(XmlDictionaryReader reader, int maxBufferSize, EnvelopeVersion version)
        {
            reader.ReadStartElement(XD.MessageDictionary.Fault, version.DictionaryNamespace); 
            reader.ReadStartElement(XD.Message12Dictionary.FaultCode, version.DictionaryNamespace);
            FaultCode code = ReadFaultCode12Driver(reader, version); 
            reader.ReadEndElement(); 
            List translations = new List();
            if (reader.IsEmptyElement) 
            {
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new FormatException(SR.GetString(SR.AtLeastOneFaultReasonMustBeSpecified)));
            }
            else 
            {
                reader.ReadStartElement(XD.Message12Dictionary.FaultReason, version.DictionaryNamespace); 
                while (reader.IsStartElement(XD.Message12Dictionary.FaultText, version.DictionaryNamespace)) 
                    translations.Add(ReadTranslation12(reader));
                reader.ReadEndElement(); 
            }

            string actor = "";
            string node = ""; 
            if (reader.IsStartElement(XD.Message12Dictionary.FaultNode, version.DictionaryNamespace))
                node = reader.ReadElementContentAsString(); 
            if (reader.IsStartElement(XD.Message12Dictionary.FaultRole, version.DictionaryNamespace)) 
                actor = reader.ReadElementContentAsString();
            XmlBuffer detail = null; 
            if (reader.IsStartElement(XD.Message12Dictionary.FaultDetail, version.DictionaryNamespace))
            {
                detail = new XmlBuffer(maxBufferSize);
                XmlDictionaryWriter writer = detail.OpenSection(reader.Quotas); 
                writer.WriteNode(reader, false);
                detail.CloseSection(); 
                detail.Close(); 
            }
            reader.ReadEndElement(); 
            FaultReason reason = new FaultReason(translations);
            return new ReceivedFault(code, reason, actor, node, detail);
        }
 
        static FaultCode ReadFaultCode12Driver(XmlDictionaryReader reader, EnvelopeVersion version)
        { 
            string localName; 
            string ns;
            FaultCode subCode = null; 
            reader.ReadStartElement(XD.Message12Dictionary.FaultValue, version.DictionaryNamespace);
            XmlUtil.ReadContentAsQName(reader, out localName, out ns);
            reader.ReadEndElement();
            if (reader.IsStartElement(XD.Message12Dictionary.FaultSubcode, version.DictionaryNamespace)) 
            {
                reader.ReadStartElement(); 
                subCode = ReadFaultCode12Driver(reader, version); 
                reader.ReadEndElement();
                return new FaultCode(localName, ns, subCode); 
            }
            return new FaultCode(localName, ns);
        }
 
        public static ReceivedFault CreateFault12(XmlDictionaryReader reader, int maxBufferSize)
        { 
            return CreateFault12Driver(reader, maxBufferSize, EnvelopeVersion.Soap12); 
        }
 
        static FaultReasonText ReadTranslation12(XmlDictionaryReader reader)
        {
            string xmlLang = XmlUtil.GetXmlLangAttribute(reader);
            string text = reader.ReadElementContentAsString(); 
            return new FaultReasonText(text, xmlLang);
        } 
 
        public static ReceivedFault CreateFault11(XmlDictionaryReader reader, int maxBufferSize)
        { 
            reader.ReadStartElement(XD.MessageDictionary.Fault, XD.Message11Dictionary.Namespace);
            string ns;
            string name;
            reader.ReadStartElement(XD.Message11Dictionary.FaultCode, XD.Message11Dictionary.FaultNamespace); 
            XmlUtil.ReadContentAsQName(reader, out name, out ns);
            FaultCode code = new FaultCode(name, ns); 
            reader.ReadEndElement(); 

            string xmlLang = reader.XmlLang; 
            reader.MoveToContent();  // Don't do IsStartElement.  FaultString is required, so let the reader throw.
            string text = reader.ReadElementContentAsString(XD.Message11Dictionary.FaultString.Value, XD.Message11Dictionary.FaultNamespace.Value);
            FaultReasonText translation = new FaultReasonText(text, xmlLang);
 
            string actor = "";
            if (reader.IsStartElement(XD.Message11Dictionary.FaultActor, XD.Message11Dictionary.FaultNamespace)) 
                actor = reader.ReadElementContentAsString(); 
            XmlBuffer detail = null;
            if (reader.IsStartElement(XD.Message11Dictionary.FaultDetail, XD.Message11Dictionary.FaultNamespace)) 
            {
                detail = new XmlBuffer(maxBufferSize);
                XmlDictionaryWriter writer = detail.OpenSection(reader.Quotas);
                writer.WriteNode(reader, false); 
                detail.CloseSection();
                detail.Close(); 
            } 
            reader.ReadEndElement();
            FaultReason reason = new FaultReason(translation); 
            return new ReceivedFault(code, reason, actor, actor, detail);
        }
    }
} 

// 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