//-----------------------------------------------------------------------
// <copyright file="BinaryDataWriter.cs" company="Sirenix IVS">
// Copyright (c) 2018 Sirenix IVS
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
// </copyright>
//-----------------------------------------------------------------------

namespace VRC.Udon.Serialization.OdinSerializer
{
    using VRC.Udon.Serialization.OdinSerializer.Utilities;
    using VRC.Udon.Serialization.OdinSerializer.Utilities.Unsafe;
    using System;
    using System.Collections.Generic;
    using System.IO;
    using System.Runtime.CompilerServices;
    using System.Runtime.InteropServices;

    /// <summary>
    /// Writes data to a stream that can be read by a <see cref="BinaryDataReader"/>.
    /// </summary>
    /// <seealso cref="BaseDataWriter" />
    public unsafe class BinaryDataWriter : BaseDataWriter
    {
        private static readonly Dictionary<Type, Delegate> PrimitiveGetBytesMethods = new Dictionary<Type, Delegate>(FastTypeComparer.Instance)
        {
            { typeof(char),     (Action<byte[], int, char>)     ((byte[] b, int i, char v) => { ProperBitConverter.GetBytes(b, i, (ushort)v); }) },
            { typeof(byte),     (Action<byte[], int, byte>)     ((b, i, v) => { b[i] = v; }) },
            { typeof(sbyte),    (Action<byte[], int, sbyte>)    ((b, i, v) => { b[i] = (byte)v; }) },
            { typeof(bool),     (Action<byte[], int, bool>)     ((b, i, v) => { b[i] = v ? (byte)1 : (byte)0; }) },
            { typeof(short),    (Action<byte[], int, short>)    ProperBitConverter.GetBytes },
            { typeof(int),      (Action<byte[], int, int>)      ProperBitConverter.GetBytes },
            { typeof(long),     (Action<byte[], int, long>)     ProperBitConverter.GetBytes },
            { typeof(ushort),   (Action<byte[], int, ushort>)   ProperBitConverter.GetBytes },
            { typeof(uint),     (Action<byte[], int, uint>)     ProperBitConverter.GetBytes },
            { typeof(ulong),    (Action<byte[], int, ulong>)    ProperBitConverter.GetBytes },
            { typeof(decimal),  (Action<byte[], int, decimal>)  ProperBitConverter.GetBytes },
            { typeof(float),    (Action<byte[], int, float>)    ProperBitConverter.GetBytes },
            { typeof(double),   (Action<byte[], int, double>)   ProperBitConverter.GetBytes },
            { typeof(Guid),     (Action<byte[], int, Guid>)     ProperBitConverter.GetBytes }
        };

        private static readonly Dictionary<Type, int> PrimitiveSizes = new Dictionary<Type, int>(FastTypeComparer.Instance)
        {
            { typeof(char),    2  },
            { typeof(byte),    1  },
            { typeof(sbyte),   1  },
            { typeof(bool),    1  },
            { typeof(short),   2  },
            { typeof(int),     4  },
            { typeof(long),    8  },
            { typeof(ushort),  2  },
            { typeof(uint),    4  },
            { typeof(ulong),   8  },
            { typeof(decimal), 16 },
            { typeof(float),   4  },
            { typeof(double),  8  },
            { typeof(Guid),    16 }
        };

        // For byte caching while writing values up to sizeof(decimal) using the old ProperBitConverter method
        // (still occasionally used) and to provide a permanent buffer to read into.
        private readonly byte[] small_buffer = new byte[16];
        private readonly byte[] buffer = new byte[1024 * 100]; // 100 Kb buffer should be enough for most things, and enough to prevent flushing to stream too often
        private int bufferIndex = 0;

        // A dictionary over all seen types, so short type ids can be written after a type's full name has already been written to the stream once
        private readonly Dictionary<Type, int> types = new Dictionary<Type, int>(16, FastTypeComparer.Instance);

        public bool CompressStringsTo8BitWhenPossible = false;

        public BinaryDataWriter() : base(null, null)
        {
        }

        /// <summary>
        /// Initializes a new instance of the <see cref="BinaryDataWriter" /> class.
        /// </summary>
        /// <param name="stream">The base stream of the writer.</param>
        /// <param name="context">The serialization context to use.</param>
        public BinaryDataWriter(Stream stream, SerializationContext context) : base(stream, context)
        {
        }

        /// <summary>
        /// Begins an array node of the given length.
        /// </summary>
        /// <param name="length">The length of the array to come.</param>
        public override void BeginArrayNode(long length)
        {
            this.EnsureBufferSpace(9);
            this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.StartOfArray;
            this.UNSAFE_WriteToBuffer_8_Int64(length);
            this.PushArray();
        }

        /// <summary>
        /// Writes the beginning of a reference node.
        /// <para />
        /// This call MUST eventually be followed by a corresponding call to <see cref="IDataWriter.EndNode(string)" />, with the same name.
        /// </summary>
        /// <param name="name">The name of the reference node.</param>
        /// <param name="type">The type of the reference node. If null, no type metadata will be written.</param>
        /// <param name="id">The id of the reference node. This id is acquired by calling <see cref="SerializationContext.TryRegisterInternalReference(object, out int)" />.</param>
        public override void BeginReferenceNode(string name, Type type, int id)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedStartOfReferenceNode;
                this.WriteStringFast(name);
            }
            else
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedStartOfReferenceNode;
            }

            this.WriteType(type);
            this.EnsureBufferSpace(4);
            this.UNSAFE_WriteToBuffer_4_Int32(id);
            this.PushNode(name, id, type);
        }

        /// <summary>
        /// Begins a struct/value type node. This is essentially the same as a reference node, except it has no internal reference id.
        /// <para />
        /// This call MUST eventually be followed by a corresponding call to <see cref="IDataWriter.EndNode(string)" />, with the same name.
        /// </summary>
        /// <param name="name">The name of the struct node.</param>
        /// <param name="type">The type of the struct node. If null, no type metadata will be written.</param>
        public override void BeginStructNode(string name, Type type)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedStartOfStructNode;
                this.WriteStringFast(name);
            }
            else
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedStartOfStructNode;
            }

            this.WriteType(type);
            this.PushNode(name, -1, type);
        }

        /// <summary>
        /// Disposes all resources kept by the data writer, except the stream, which can be reused later.
        /// </summary>
        public override void Dispose()
        {
            //this.Stream.Dispose();
            this.FlushToStream();
        }

        /// <summary>
        /// Ends the current array node, if the current node is an array node.
        /// </summary>
        public override void EndArrayNode()
        {
            this.PopArray();

            this.EnsureBufferSpace(1);
            this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.EndOfArray;
        }

        /// <summary>
        /// Ends the current node with the given name. If the current node has another name, an <see cref="InvalidOperationException" /> is thrown.
        /// </summary>
        /// <param name="name">The name of the node to end. This has to be the name of the current node.</param>
        public override void EndNode(string name)
        {
            this.PopNode(name);

            this.EnsureBufferSpace(1);
            this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.EndOfNode;
        }

        private static readonly Dictionary<Type, Action<BinaryDataWriter, object>> PrimitiveArrayWriters = new Dictionary<Type, Action<BinaryDataWriter, object>>(FastTypeComparer.Instance)
        {
            { typeof(char),    WritePrimitiveArray_char     },
            { typeof(sbyte),   WritePrimitiveArray_sbyte    },
            { typeof(short),   WritePrimitiveArray_short    },
            { typeof(int),     WritePrimitiveArray_int      },
            { typeof(long),    WritePrimitiveArray_long     },
            { typeof(byte),    WritePrimitiveArray_byte     },
            { typeof(ushort),  WritePrimitiveArray_ushort   },
            { typeof(uint),    WritePrimitiveArray_uint     },
            { typeof(ulong),   WritePrimitiveArray_ulong    },
            { typeof(decimal), WritePrimitiveArray_decimal  },
            { typeof(bool),    WritePrimitiveArray_bool     },
            { typeof(float),   WritePrimitiveArray_float    },
            { typeof(double),  WritePrimitiveArray_double   },
            { typeof(Guid),    WritePrimitiveArray_Guid     },
        };

        private static void WritePrimitiveArray_byte(BinaryDataWriter writer, object o)
        {
            byte[] array = o as byte[];

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(1);

            // We can include a special case for byte arrays, as there's no need to copy that to a buffer
            // First we ensure that the stream is up to date with the buffer, then we write directly to
            // the stream.
            writer.FlushToStream();
            writer.Stream.Write(array, 0, array.Length);
        }

        private static void WritePrimitiveArray_sbyte(BinaryDataWriter writer, object o)
        {
            sbyte[] array = o as sbyte[];
            int bytesPerElement = sizeof(sbyte);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                fixed (byte* toBase = writer.buffer)
                fixed (void* from = array)
                {
                    void* to = toBase + writer.bufferIndex;

                    UnsafeUtilities.MemoryCopy(from, to, byteCount);
                }

                writer.bufferIndex += byteCount;
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    // No need to check endianness, since sbyte has a size of 1
                    UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_bool(BinaryDataWriter writer, object o)
        {
            bool[] array = o as bool[];
            int bytesPerElement = sizeof(bool);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                fixed (byte* toBase = writer.buffer)
                fixed (void* from = array)
                {
                    void* to = toBase + writer.bufferIndex;

                    UnsafeUtilities.MemoryCopy(from, to, byteCount);
                }

                writer.bufferIndex += byteCount;
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    // No need to check endianness, since bool has a size of 1
                    UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_char(BinaryDataWriter writer, object o)
        {
            char[] array = o as char[];
            int bytesPerElement = sizeof(char);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_2_Char(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_short(BinaryDataWriter writer, object o)
        {
            short[] array = o as short[];
            int bytesPerElement = sizeof(short);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_2_Int16(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_int(BinaryDataWriter writer, object o)
        {
            int[] array = o as int[];
            int bytesPerElement = sizeof(int);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_4_Int32(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_long(BinaryDataWriter writer, object o)
        {
            long[] array = o as long[];
            int bytesPerElement = sizeof(long);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_8_Int64(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_ushort(BinaryDataWriter writer, object o)
        {
            ushort[] array = o as ushort[];
            int bytesPerElement = sizeof(ushort);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_2_UInt16(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_uint(BinaryDataWriter writer, object o)
        {
            uint[] array = o as uint[];
            int bytesPerElement = sizeof(uint);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_4_UInt32(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_ulong(BinaryDataWriter writer, object o)
        {
            ulong[] array = o as ulong[];
            int bytesPerElement = sizeof(ulong);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_8_UInt64(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_decimal(BinaryDataWriter writer, object o)
        {
            decimal[] array = o as decimal[];
            int bytesPerElement = sizeof(decimal);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_16_Decimal(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_float(BinaryDataWriter writer, object o)
        {
            float[] array = o as float[];
            int bytesPerElement = sizeof(float);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_4_Float32(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_double(BinaryDataWriter writer, object o)
        {
            double[] array = o as double[];
            int bytesPerElement = sizeof(double);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_8_Float64(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        private static void WritePrimitiveArray_Guid(BinaryDataWriter writer, object o)
        {
            Guid[] array = o as Guid[];
            int bytesPerElement = sizeof(Guid);
            int byteCount = array.Length * bytesPerElement;

            writer.EnsureBufferSpace(9);

            // Write entry flag
            writer.buffer[writer.bufferIndex++] = (byte)BinaryEntryType.PrimitiveArray;

            writer.UNSAFE_WriteToBuffer_4_Int32(array.Length);
            writer.UNSAFE_WriteToBuffer_4_Int32(bytesPerElement);

            // We copy to a buffer in order to write the entire array into the stream with one call
            // We use our internal buffer if there's space in it, otherwise we claim a buffer from a cache.
            if (writer.TryEnsureBufferSpace(byteCount))
            {
                if (BitConverter.IsLittleEndian)
                {
                    fixed (byte* toBase = writer.buffer)
                    fixed (void* from = array)
                    {
                        void* to = toBase + writer.bufferIndex;

                        UnsafeUtilities.MemoryCopy(from, to, byteCount);
                    }

                    writer.bufferIndex += byteCount;
                }
                else
                {
                    for (int i = 0; i < array.Length; i++)
                    {
                        writer.UNSAFE_WriteToBuffer_16_Guid(array[i]);
                    }
                }
            }
            else
            {
                // Ensure stream is up to date with the buffer before we write directly to it
                writer.FlushToStream();

                using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                {
                    if (BitConverter.IsLittleEndian)
                    {
                        // We always store in little endian, so we can do a direct memory mapping, which is a lot faster
                        UnsafeUtilities.MemoryCopy(array, tempBuffer.Array, byteCount, 0, 0);
                    }
                    else
                    {
                        // We have to convert each individual element to bytes, since the byte order has to be reversed
                        var b = tempBuffer.Array;

                        for (int i = 0; i < array.Length; i++)
                        {
                            ProperBitConverter.GetBytes(b, i * bytesPerElement, array[i]);
                        }
                    }

                    writer.Stream.Write(tempBuffer.Array, 0, byteCount);
                }
            }
        }

        /// <summary>
        /// Writes a primitive array to the stream.
        /// </summary>
        /// <typeparam name="T">The element type of the primitive array. Valid element types can be determined using <see cref="FormatterUtilities.IsPrimitiveArrayType(Type)" />.</typeparam>
        /// <param name="array">The primitive array to write.</param>
        /// <exception cref="System.ArgumentException">Type  + typeof(T).Name +  is not a valid primitive array type.</exception>
        public override void WritePrimitiveArray<T>(T[] array)
        {
            Action<BinaryDataWriter, object> writer;

            if (!PrimitiveArrayWriters.TryGetValue(typeof(T), out writer))
            {
                throw new ArgumentException("Type " + typeof(T).Name + " is not a valid primitive array type.");
            }

            writer(this, array);
        }

        /// <summary>
        /// Writes a <see cref="bool" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteBoolean(string name, bool value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedBoolean;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = value ? (byte)1 : (byte)0;
            }
            else
            {
                this.EnsureBufferSpace(2);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedBoolean;
                this.buffer[this.bufferIndex++] = value ? (byte)1 : (byte)0;
            }

        }

        /// <summary>
        /// Writes a <see cref="byte" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteByte(string name, byte value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedByte;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = value;
            }
            else
            {
                this.EnsureBufferSpace(2);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedByte;
                this.buffer[this.bufferIndex++] = value;
            }
        }

        /// <summary>
        /// Writes a <see cref="char" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteChar(string name, char value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedChar;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(2);
                this.UNSAFE_WriteToBuffer_2_Char(value);
            }
            else
            {
                this.EnsureBufferSpace(3);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedChar;
                this.UNSAFE_WriteToBuffer_2_Char(value);
            }

        }

        /// <summary>
        /// Writes a <see cref="decimal" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteDecimal(string name, decimal value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedDecimal;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(16);
                this.UNSAFE_WriteToBuffer_16_Decimal(value);
            }
            else
            {
                this.EnsureBufferSpace(17);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedDecimal;
                this.UNSAFE_WriteToBuffer_16_Decimal(value);
            }
        }

        /// <summary>
        /// Writes a <see cref="double" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteDouble(string name, double value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedDouble;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(8);
                this.UNSAFE_WriteToBuffer_8_Float64(value);
            }
            else
            {
                this.EnsureBufferSpace(9);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedDouble;
                this.UNSAFE_WriteToBuffer_8_Float64(value);
            }

        }

        /// <summary>
        /// Writes a <see cref="Guid" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteGuid(string name, Guid value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedGuid;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(16);
                this.UNSAFE_WriteToBuffer_16_Guid(value);
            }
            else
            {
                this.EnsureBufferSpace(17);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedGuid;
                this.UNSAFE_WriteToBuffer_16_Guid(value);
            }

        }

        /// <summary>
        /// Writes an external guid reference to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="guid">The value to write.</param>
        public override void WriteExternalReference(string name, Guid guid)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedExternalReferenceByGuid;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(16);
                this.UNSAFE_WriteToBuffer_16_Guid(guid);
            }
            else
            {
                this.EnsureBufferSpace(17);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedExternalReferenceByGuid;
                this.UNSAFE_WriteToBuffer_16_Guid(guid);
            }
        }

        /// <summary>
        /// Writes an external index reference to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="index">The value to write.</param>
        public override void WriteExternalReference(string name, int index)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedExternalReferenceByIndex;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(4);
                this.UNSAFE_WriteToBuffer_4_Int32(index);
            }
            else
            {
                this.EnsureBufferSpace(5);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedExternalReferenceByIndex;
                this.UNSAFE_WriteToBuffer_4_Int32(index);
            }
        }

        /// <summary>
        /// Writes an external string reference to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="id">The value to write.</param>
        public override void WriteExternalReference(string name, string id)
        {
            if (id == null)
            {
                throw new ArgumentNullException("id");
            }

            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedExternalReferenceByString;
                this.WriteStringFast(name);
            }
            else
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedExternalReferenceByString;
            }

            this.WriteStringFast(id);
        }

        /// <summary>
        /// Writes an <see cref="int" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteInt32(string name, int value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedInt;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(4);
                this.UNSAFE_WriteToBuffer_4_Int32(value);
            }
            else
            {
                this.EnsureBufferSpace(5);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedInt;
                this.UNSAFE_WriteToBuffer_4_Int32(value);
            }
        }

        /// <summary>
        /// Writes a <see cref="long" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteInt64(string name, long value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedLong;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(8);
                this.UNSAFE_WriteToBuffer_8_Int64(value);
            }
            else
            {
                this.EnsureBufferSpace(9);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedLong;
                this.UNSAFE_WriteToBuffer_8_Int64(value);
            }
        }

        /// <summary>
        /// Writes a null value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        public override void WriteNull(string name)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedNull;
                this.WriteStringFast(name);
            }
            else
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedNull;
            }
        }

        /// <summary>
        /// Writes an internal reference to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="id">The value to write.</param>
        public override void WriteInternalReference(string name, int id)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedInternalReference;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(4);
                this.UNSAFE_WriteToBuffer_4_Int32(id);
            }
            else
            {
                this.EnsureBufferSpace(5);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedInternalReference;
                this.UNSAFE_WriteToBuffer_4_Int32(id);
            }
        }

        /// <summary>
        /// Writes an <see cref="sbyte" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteSByte(string name, sbyte value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedSByte;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(1);

                unchecked
                {
                    this.buffer[this.bufferIndex++] = (byte)value;
                }
            }
            else
            {
                this.EnsureBufferSpace(2);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedSByte;

                unchecked
                {
                    this.buffer[this.bufferIndex++] = (byte)value;
                }
            }
        }

        /// <summary>
        /// Writes a <see cref="short" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteInt16(string name, short value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedShort;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(2);
                this.UNSAFE_WriteToBuffer_2_Int16(value);
            }
            else
            {
                this.EnsureBufferSpace(3);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedShort;
                this.UNSAFE_WriteToBuffer_2_Int16(value);
            }
        }

        /// <summary>
        /// Writes a <see cref="float" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteSingle(string name, float value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedFloat;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(4);
                this.UNSAFE_WriteToBuffer_4_Float32(value);
            }
            else
            {
                this.EnsureBufferSpace(5);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedFloat;
                this.UNSAFE_WriteToBuffer_4_Float32(value);
            }
        }

        /// <summary>
        /// Writes a <see cref="string" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteString(string name, string value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedString;

                this.WriteStringFast(name);
            }
            else
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedString;
            }

            this.WriteStringFast(value);
        }

        /// <summary>
        /// Writes an <see cref="uint" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteUInt32(string name, uint value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedUInt;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(4);
                this.UNSAFE_WriteToBuffer_4_UInt32(value);
            }
            else
            {
                this.EnsureBufferSpace(5);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedUInt;
                this.UNSAFE_WriteToBuffer_4_UInt32(value);
            }
        }

        /// <summary>
        /// Writes an <see cref="ulong" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteUInt64(string name, ulong value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedULong;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(8);
                this.UNSAFE_WriteToBuffer_8_UInt64(value);
            }
            else
            {
                this.EnsureBufferSpace(9);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedULong;
                this.UNSAFE_WriteToBuffer_8_UInt64(value);
            }
        }

        /// <summary>
        /// Writes an <see cref="ushort" /> value to the stream.
        /// </summary>
        /// <param name="name">The name of the value. If this is null, no name will be written.</param>
        /// <param name="value">The value to write.</param>
        public override void WriteUInt16(string name, ushort value)
        {
            if (name != null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.NamedUShort;

                this.WriteStringFast(name);

                this.EnsureBufferSpace(2);
                this.UNSAFE_WriteToBuffer_2_UInt16(value);
            }
            else
            {
                this.EnsureBufferSpace(3);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedUShort;
                this.UNSAFE_WriteToBuffer_2_UInt16(value);
            }
        }

        /// <summary>
        /// Tells the writer that a new serialization session is about to begin, and that it should clear all cached values left over from any prior serialization sessions.
        /// This method is only relevant when the same writer is used to serialize several different, unrelated values.
        /// </summary>
        public override void PrepareNewSerializationSession()
        {
            base.PrepareNewSerializationSession();
            this.types.Clear();
            this.bufferIndex = 0;
        }

        public override string GetDataDump()
        {
            if (!this.Stream.CanRead)
            {
                return "Binary data stream for writing cannot be read; cannot dump data.";
            }

            if (!this.Stream.CanSeek)
            {
                return "Binary data stream cannot seek; cannot dump data.";
            }

            this.FlushToStream();

            var oldPosition = this.Stream.Position;

            var bytes = new byte[oldPosition];

            this.Stream.Position = 0;
            this.Stream.Read(bytes, 0, (int)oldPosition);

            this.Stream.Position = oldPosition;

            return "Binary hex dump: " + ProperBitConverter.BytesToHexString(bytes);
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void WriteType(Type type)
        {
            if (type == null)
            {
                this.EnsureBufferSpace(1);
                this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.UnnamedNull;
            }
            else
            {
                int id;

                if (this.types.TryGetValue(type, out id))
                {
                    this.EnsureBufferSpace(5);
                    this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.TypeID;
                    this.UNSAFE_WriteToBuffer_4_Int32(id);
                }
                else
                {
                    id = this.types.Count;
                    this.types.Add(type, id);

                    this.EnsureBufferSpace(5);
                    this.buffer[this.bufferIndex++] = (byte)BinaryEntryType.TypeName;
                    this.UNSAFE_WriteToBuffer_4_Int32(id);
                    this.WriteStringFast(this.Context.Binder.BindToName(type, this.Context.Config.DebugContext));
                }
            }
        }

        private struct Struct256Bit
        {
            public decimal d1;
            public decimal d2;
        }

        private void WriteStringFast(string value)
        {
            bool needs16BitsPerChar = true;
            int byteCount;

            if (this.CompressStringsTo8BitWhenPossible)
            {
                needs16BitsPerChar = false;

                // Check if the string requires 16 bit support
                for (int i = 0; i < value.Length; i++)
                {
                    if (value[i] > 255)
                    {
                        needs16BitsPerChar = true;
                        break;
                    }
                }
            }

            if (needs16BitsPerChar)
            {
                byteCount = value.Length * 2;

                if (this.TryEnsureBufferSpace(byteCount + 5))
                {
                    this.buffer[this.bufferIndex++] = 1; // Write 16 bit flag
                    this.UNSAFE_WriteToBuffer_4_Int32(value.Length);

                    if (BitConverter.IsLittleEndian)
                    {
                        fixed (byte* baseToPtr = this.buffer)
                        fixed (char* baseFromPtr = value)
                        {
                            Struct256Bit* toPtr = (Struct256Bit*)(baseToPtr + this.bufferIndex);
                            Struct256Bit* fromPtr = (Struct256Bit*)baseFromPtr;

                            byte* toEnd = (byte*)toPtr + byteCount;

                            while ((toPtr + 1) <= toEnd)
                            {
                                *toPtr++ = *fromPtr++;
                            }

                            char* toPtrRest = (char*)toPtr;
                            char* fromPtrRest = (char*)fromPtr;

                            while (toPtrRest < toEnd)
                            {
                                *toPtrRest++ = *fromPtrRest++;
                            }
                        }
                    }
                    else
                    {
                        fixed (byte* baseToPtr = this.buffer)
                        fixed (char* baseFromPtr = value)
                        {
                            byte* toPtr = baseToPtr + this.bufferIndex;
                            byte* fromPtr = (byte*)baseFromPtr;

                            for (int i = 0; i < byteCount; i += 2)
                            {
                                *toPtr = *(fromPtr + 1);
                                *(toPtr + 1) = *fromPtr;

                                fromPtr += 2;
                                toPtr += 2;
                            }
                        }
                    }

                    this.bufferIndex += byteCount;
                }
                else
                {
                    // Our internal buffer doesn't have space for this string - use the stream directly
                    this.FlushToStream(); // Ensure stream is up to date with buffer before we write directly to it
                    this.Stream.WriteByte(1); // Write 16 bit flag

                    ProperBitConverter.GetBytes(this.small_buffer, 0, value.Length);
                    this.Stream.Write(this.small_buffer, 0, 4);

                    using (var tempBuffer = Buffer<byte>.Claim(byteCount))
                    {
                        var array = tempBuffer.Array;
                        UnsafeUtilities.StringToBytes(array, value, true);
                        this.Stream.Write(array, 0, byteCount);
                    }
                }
            }
            else
            {
                byteCount = value.Length;

                if (this.TryEnsureBufferSpace(byteCount + 5))
                {
                    this.buffer[this.bufferIndex++] = 0; // Write 8 bit flag
                    this.UNSAFE_WriteToBuffer_4_Int32(value.Length);

                    for (int i = 0; i < byteCount; i++)
                    {
                        this.buffer[this.bufferIndex++] = (byte)value[i];
                    }
                }
                else
                {
                    // Our internal buffer doesn't have space for this string - use the stream directly
                    this.FlushToStream(); // Ensure stream is up to date with buffer before we write directly to it
                    this.Stream.WriteByte(0); // Write 8 bit flag

                    ProperBitConverter.GetBytes(this.small_buffer, 0, value.Length);
                    this.Stream.Write(this.small_buffer, 0, 4);

                    using (var tempBuffer = Buffer<byte>.Claim(value.Length))
                    {
                        var array = tempBuffer.Array;

                        for (int i = 0; i < value.Length; i++)
                        {
                            array[i] = (byte)value[i];
                        }

                        this.Stream.Write(array, 0, value.Length);
                    }
                }
            }
        }

        public override void FlushToStream()
        {
            if (this.bufferIndex > 0)
            {
                this.Stream.Write(this.buffer, 0, this.bufferIndex);
                this.bufferIndex = 0;
            }

            base.FlushToStream();
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_2_Char(char value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    *(char*)(basePtr + this.bufferIndex) = value;
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 1;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 2;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_2_Int16(short value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    *(short*)(basePtr + this.bufferIndex) = value;
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 1;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 2;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_2_UInt16(ushort value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    *(ushort*)(basePtr + this.bufferIndex) = value;
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 1;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 2;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_4_Int32(int value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    *(int*)(basePtr + this.bufferIndex) = value;
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 3;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 4;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_4_UInt32(uint value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    *(uint*)(basePtr + this.bufferIndex) = value;
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 3;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 4;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_4_Float32(float value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    if (ArchitectureInfo.Architecture_Supports_All_Unaligned_ReadWrites)
                    {
                        // We can write directly to the buffer, safe in the knowledge that any potential unaligned writes will work
                        *(float*)(basePtr + this.bufferIndex) = value;
                    }
                    else
                    {
                        // We do a slower but safer byte-by-byte write instead.
                        // Apparently doing this bit through an int pointer alias can also crash sometimes.
                        // Hence, we just do a byte-by-byte write to be safe.
                        byte* from = (byte*)&value;
                        byte* to = basePtr + this.bufferIndex;

                        *to++ = *from++;
                        *to++ = *from++;
                        *to++ = *from++;
                        *to = *from;
                    }
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 3;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 4;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_8_Int64(long value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    if (ArchitectureInfo.Architecture_Supports_All_Unaligned_ReadWrites)
                    {
                        // We can write directly to the buffer, safe in the knowledge that any potential unaligned writes will work
                        *(long*)(basePtr + this.bufferIndex) = value;
                    }
                    else
                    {
                        // We do a slower but safer int-by-int write instead
                        int* fromPtr = (int*)&value;
                        int* toPtr = (int*)(basePtr + this.bufferIndex);

                        *toPtr++ = *fromPtr++;
                        *toPtr = *fromPtr;
                    }
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 7;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 8;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_8_UInt64(ulong value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    if (ArchitectureInfo.Architecture_Supports_All_Unaligned_ReadWrites)
                    {
                        // We can write directly to the buffer, safe in the knowledge that any potential unaligned writes will work
                        *(ulong*)(basePtr + this.bufferIndex) = value;
                    }
                    else
                    {
                        // We do a slower but safer int-by-int write instead
                        int* fromPtr = (int*)&value;
                        int* toPtr = (int*)(basePtr + this.bufferIndex);

                        *toPtr++ = *fromPtr++;
                        *toPtr = *fromPtr;
                    }
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 7;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 8;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_8_Float64(double value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    if (ArchitectureInfo.Architecture_Supports_All_Unaligned_ReadWrites)
                    {
                        // We can write directly to the buffer, safe in the knowledge that any potential unaligned writes will work
                        *(double*)(basePtr + this.bufferIndex) = value;
                    }
                    else
                    {
                        // We do a slower but safer int-by-int write instead
                        int* fromPtr = (int*)&value;
                        int* toPtr = (int*)(basePtr + this.bufferIndex);

                        *toPtr++ = *fromPtr++;
                        *toPtr = *fromPtr;
                    }
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 7;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 8;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_16_Decimal(decimal value)
        {
            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    if (ArchitectureInfo.Architecture_Supports_All_Unaligned_ReadWrites)
                    {
                        // We can write directly to the buffer, safe in the knowledge that any potential unaligned writes will work
                        *(decimal*)(basePtr + this.bufferIndex) = value;
                    }
                    else
                    {
                        // We do a slower but safer int-by-int write instead
                        int* fromPtr = (int*)&value;
                        int* toPtr = (int*)(basePtr + this.bufferIndex);

                        *toPtr++ = *fromPtr++;
                        *toPtr++ = *fromPtr++;
                        *toPtr++ = *fromPtr++;
                        *toPtr = *fromPtr;
                    }
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value + 15;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 16;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void UNSAFE_WriteToBuffer_16_Guid(Guid value)
        {
            // First 10 bytes of a guid are always little endian
            // Last 6 bytes depend on architecture endianness
            // See http://stackoverflow.com/questions/10190817/guid-byte-order-in-net

            // TODO: Test if this actually works on big-endian architecture. Where the hell do we find that?

            fixed (byte* basePtr = this.buffer)
            {
                if (BitConverter.IsLittleEndian)
                {
                    if (ArchitectureInfo.Architecture_Supports_All_Unaligned_ReadWrites)
                    {
                        // We can write directly to the buffer, safe in the knowledge that any potential unaligned writes will work
                        *(Guid*)(basePtr + this.bufferIndex) = value;
                    }
                    else
                    {
                        // We do a slower but safer int-by-int write instead
                        int* fromPtr = (int*)&value;
                        int* toPtr = (int*)(basePtr + this.bufferIndex);

                        *toPtr++ = *fromPtr++;
                        *toPtr++ = *fromPtr++;
                        *toPtr++ = *fromPtr++;
                        *toPtr = *fromPtr;
                    }
                }
                else
                {
                    byte* ptrTo = basePtr + this.bufferIndex;
                    byte* ptrFrom = (byte*)&value;

                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom++;
                    *ptrTo++ = *ptrFrom;

                    ptrFrom += 6;

                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo++ = *ptrFrom--;
                    *ptrTo = *ptrFrom;
                }
            }

            this.bufferIndex += 16;
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private void EnsureBufferSpace(int space)
        {
            var length = this.buffer.Length;

            if (space > length)
            {
                throw new Exception("Insufficient buffer capacity");
            }

            if (this.bufferIndex + space > length)
            {
                this.FlushToStream();
            }
        }

        [MethodImpl((MethodImplOptions)0x100)]  // Set aggressive inlining flag, for the runtimes that understand that
        private bool TryEnsureBufferSpace(int space)
        {
            var length = this.buffer.Length;

            if (space > length)
            {
                return false;
            }

            if (this.bufferIndex + space > length)
            {
                this.FlushToStream();
            }

            return true;
        }
    }
}