ActiveXSerializer.cs source code in C# .NET

                        Code:
                         / WCF / WCF / 3.5.30729.1 / untmp / Orcas / SP / ndp / cdf / src / WCF / ServiceModel / System / ServiceModel / MsmqIntegration / ActiveXSerializer.cs / 1 / ActiveXSerializer.cs
                        
                        
                            //---------------------------------------------------------------------------- 
// Copyright (c) Microsoft Corporation.  All rights reserved.
//---------------------------------------------------------------------------
namespace System.ServiceModel.MsmqIntegration
{ 
    using System.Runtime.InteropServices;
    using System.Text; 
    using System.Threading; 
    using System.Runtime.Serialization;
    using System.Diagnostics; 
    using System;
    using System.IO;
    using System.Globalization;
 
    class ActiveXSerializer {
 
        byte[] byteBuffer; 
        char[] charBuffer;
        object bufferLock = new object(); 

        TKind[] TakeLockedBuffer(out bool lockHeld, int size)
        {
            lockHeld = false; 
            try { }
            finally 
            { 
                Monitor.Enter(this.bufferLock);
                lockHeld = true; 
            }
            if (typeof(byte) == typeof(TKind))
            {
                if (null == this.byteBuffer || size > this.byteBuffer.Length) 
                    this.byteBuffer = new byte[size];
                return this.byteBuffer as TKind[]; 
            } 
            else if (typeof(char) == typeof(TKind))
            { 
                if (null == this.charBuffer || size > this.charBuffer.Length)
                    this.charBuffer = new char[size];
                return this.charBuffer as TKind[];
            } 
            else
                return null; 
        } 

        void ReleaseLockedBuffer() 
        {
            Monitor.Exit(this.bufferLock);
        }
 
        public object Deserialize(MemoryStream stream, int bodyType) {
            if (stream == null) 
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("stream")); 

            VarEnum variantType = (VarEnum)bodyType; 

            byte[] bytes;
            byte[] newBytes;
            int size; 
            int count;
            bool lockHeld; 
 
            switch (variantType) {
                case VarEnum.VT_LPSTR: 
                    bytes = stream.ToArray();
                    size = bytes.Length;

                    lockHeld = false; 
                    try
                    { 
                        char[] buffer = TakeLockedBuffer(out lockHeld, size); 
                        System.Text.Encoding.ASCII.GetChars(bytes, 0, size, buffer, 0);
                        return new String(buffer, 0, size); 
                    }
                    finally
                    {
                        if (lockHeld) 
                        {
                            ReleaseLockedBuffer(); 
                        } 
                    }
                case VarEnum.VT_BSTR: 
                case VarEnum.VT_LPWSTR:
                    bytes = stream.ToArray();
                    size = bytes.Length / 2;
 
                    lockHeld = false;
                    try 
                    { 
                        char[] buffer = TakeLockedBuffer(out lockHeld, size);
                        System.Text.Encoding.Unicode.GetChars(bytes, 0, size * 2, buffer, 0); 
                        return new String(buffer, 0, size);
                    }
                    finally
                    { 
                        if (lockHeld)
                        { 
                            ReleaseLockedBuffer(); 
                        }
                    } 
                case VarEnum.VT_VECTOR | VarEnum.VT_UI1:
                    bytes = stream.ToArray();
                    newBytes = new byte[bytes.Length];
                    Array.Copy(bytes, newBytes, bytes.Length); 

                    return newBytes; 
 
                case VarEnum.VT_BOOL:
                    bytes = new byte[1]; 
                    count = stream.Read(bytes, 0, 1);

                    if (count != 1)
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage))); 

                    return (bytes[0] != 0); 
 
                case VarEnum.VT_CLSID:
                    bytes = new byte[16]; 
                    count = stream.Read(bytes, 0, 16);

                    if (count != 16)
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage))); 

                    return new Guid(bytes); 
 
                case VarEnum.VT_CY:
 
                    bytes = new byte[8];
                    count = stream.Read(bytes, 0, 8);

                    if (count != 8) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return Decimal.FromOACurrency(BitConverter.ToInt64(bytes, 0)); 

                case VarEnum.VT_DATE: 

                    bytes = new byte[8];
                    count = stream.Read(bytes, 0, 8);
 
                    if (count != 8)
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage))); 
 
                    return new DateTime(BitConverter.ToInt64(bytes, 0));
 
                case VarEnum.VT_I1:
                case VarEnum.VT_UI1:

                    bytes = new byte[1]; 
                    count = stream.Read(bytes, 0, 1);
 
                    if (count != 1) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return bytes[0];

                case VarEnum.VT_I2:
                    bytes = new byte[2]; 
                    count = stream.Read(bytes, 0, 2);
 
                    if (count != 2) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return BitConverter.ToInt16(bytes, 0);

                case VarEnum.VT_UI2:
                    bytes = new byte[2]; 
                    count = stream.Read(bytes, 0, 2);
 
                    if (count != 2) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return BitConverter.ToUInt16(bytes, 0);

                case VarEnum.VT_I4:
                    bytes = new byte[4]; 
                    count = stream.Read(bytes, 0, 4);
 
                    if (count != 4) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return BitConverter.ToInt32(bytes, 0);

                case VarEnum.VT_UI4:
                    bytes = new byte[4]; 
                    count = stream.Read(bytes, 0, 4);
 
                    if (count != 4) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return BitConverter.ToUInt32(bytes, 0);

                case VarEnum.VT_I8:
                    bytes = new byte[8]; 
                    count = stream.Read(bytes, 0, 8);
 
                    if (count != 8) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return BitConverter.ToInt64(bytes, 0);

                case VarEnum.VT_UI8:
                    bytes = new byte[8]; 
                    count = stream.Read(bytes, 0, 8);
 
                    if (count != 8) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return BitConverter.ToUInt64(bytes, 0);

                case VarEnum.VT_R4:
                    bytes = new byte[4]; 
                    count = stream.Read(bytes, 0, 4);
 
                    if (count != 4) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return BitConverter.ToSingle(bytes, 0);

                case VarEnum.VT_R8:
                    bytes = new byte[8]; 
                    count = stream.Read(bytes, 0, 8);
 
                    if (count != 8) 
                        throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqCannotDeserializeActiveXMessage)));
 
                    return BitConverter.ToDouble(bytes, 0);

                case VarEnum.VT_NULL:
                    return null; 

 
                default: 
                    throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new SerializationException(SR.GetString(SR.MsmqInvalidTypeDeserialization)));
            } 
        }


        public void Serialize(Stream stream, object obj, ref int bodyType) { 
            if (stream == null)
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new ArgumentNullException("stream")); 
 
            VarEnum variantType;
            if (obj is string) { 
                int size = ((string)obj).Length * 2;

                bool lockHeld = false;
                try 
                {
                    byte[] buffer = TakeLockedBuffer(out lockHeld, size); 
                    System.Text.Encoding.Unicode.GetBytes(((string)obj).ToCharArray(), 0, size /2, buffer, 0); 
                    stream.Write(buffer, 0, size);
                } 
                finally
                {
                    if (lockHeld)
                    { 
                        ReleaseLockedBuffer();
                    } 
                } 
                variantType =  VarEnum.VT_LPWSTR;
            } 
            else if (obj is byte[]) {
                byte[] bytes = (byte[])obj;
                stream.Write(bytes, 0, bytes.Length);
                variantType = VarEnum.VT_UI1 | VarEnum.VT_VECTOR; 
            }
            else if (obj is char[]) { 
                char[] chars = (char[])obj; 
                int size = chars.Length * 2;
 
                bool lockHeld = false;
                try
                {
                    byte[] buffer = TakeLockedBuffer(out lockHeld, size); 
                    System.Text.Encoding.Unicode.GetBytes(chars, 0, size /2, buffer, 0);
                    stream.Write(buffer, 0, size); 
                } 
                finally
                { 
                    if (lockHeld)
                    {
                        ReleaseLockedBuffer();
                    } 
                }
                variantType = VarEnum.VT_LPWSTR; 
            } 
            else if (obj is byte) {
                stream.Write(new byte[]{(byte)obj}, 0, 1); 
                variantType = VarEnum.VT_UI1;
            }
            else if (obj is bool) {
                if ((bool)obj) 
                    stream.Write(new byte[]{0xff}, 0, 1);
                else 
                    stream.Write(new byte[]{0x00}, 0, 1); 
                variantType = VarEnum.VT_BOOL;
            } 
            else if (obj is char) {
                byte[] bytes = BitConverter.GetBytes((Char)obj);
                stream.Write(bytes, 0, 2);
                variantType = VarEnum.VT_UI2; 
            }
            else if (obj is Decimal) { 
                byte[] bytes = BitConverter.GetBytes(Decimal.ToOACurrency((Decimal)obj)); 
                stream.Write(bytes, 0, 8);
                variantType = VarEnum.VT_CY; 
            }
            else if (obj is DateTime) {
                byte[] bytes = BitConverter.GetBytes(((DateTime)obj).Ticks);
                stream.Write(bytes, 0, 8); 
                variantType = VarEnum.VT_DATE;
            } 
            else if (obj is Double) { 
                byte[] bytes = BitConverter.GetBytes((Double)obj);
                stream.Write(bytes, 0, 8); 
                variantType = VarEnum.VT_R8;
            }
            else if (obj is Guid) {
                byte[] bytes = ((Guid)obj).ToByteArray(); 
                stream.Write(bytes, 0, 16);
                variantType = VarEnum.VT_CLSID; 
            } 
            else if (obj is Int16) {
                byte[] bytes = BitConverter.GetBytes((short)obj); 
                stream.Write(bytes, 0, 2);
                variantType = VarEnum.VT_I2;
            }
            else if (obj is UInt16) { 
                byte[] bytes = BitConverter.GetBytes((UInt16)obj);
                stream.Write(bytes, 0, 2); 
                variantType = VarEnum.VT_UI2; 
            }
            else if (obj is Int32) { 
               ;
                byte[] bytes = BitConverter.GetBytes((int)obj);
                stream.Write(bytes, 0, 4);
                variantType = VarEnum.VT_I4; 
            }
            else if (obj is UInt32) { 
 
                byte[] bytes = BitConverter.GetBytes((UInt32)obj);
                stream.Write(bytes, 0, 4); 
                variantType = VarEnum.VT_UI4;
            }
            else if (obj is Int64) {
 
                byte[] bytes = BitConverter.GetBytes((Int64)obj);
                stream.Write(bytes, 0, 8); 
                variantType = VarEnum.VT_I8; 
            }
            else if (obj is UInt64) { 

                byte[] bytes = BitConverter.GetBytes((UInt64)obj);
                stream.Write(bytes, 0, 8);
                variantType = VarEnum.VT_UI8; 
            }
            else if (obj is Single) { 
 
                byte[] bytes = BitConverter.GetBytes((float)obj);
                stream.Write(bytes, 0, 4); 
                variantType = VarEnum.VT_R4;
            }
            else {
                throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new InvalidOperationException(SR.GetString(SR.MsmqInvalidTypeSerialization))); 
            }
 
            bodyType = (int)variantType; 
        }
 
   }
}

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

Source code for the .NET framework in C#

Code:

Link Menu
