FixedSchema.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;
using System.Text;
using Newtonsoft.Json.Linq;

namespace Avro
{
    public class FixedSchema : NamedSchema
    {
        public int Size { get; set; }

        internal static FixedSchema NewInstance(JToken jtok, PropertyMap props, SchemaNames names, string encspace)
        {
            SchemaName name = NamedSchema.GetName(jtok, encspace);
            var aliases = NamedSchema.GetAliases(jtok, name.Space, name.EncSpace);

            return new FixedSchema(name, aliases, JsonHelper.GetRequiredInteger(jtok, "size"), props, names);
        }

        private FixedSchema(SchemaName name, IList<SchemaName> aliases, int size, PropertyMap props, SchemaNames names)
                            : base(Type.Fixed, name, aliases, props, names)
        {
            if (null == name.Name) throw new SchemaParseException("name cannot be null for fixed schema.");
            if (size <= 0) throw new ArgumentOutOfRangeException("size", "size must be greater than zero.");
            this.Size = size;
        }

        protected internal override void WriteJsonFields(Newtonsoft.Json.JsonTextWriter writer, SchemaNames names, string encspace)
        {
            base.WriteJsonFields(writer, names, encspace);
            writer.WritePropertyName("size");
            writer.WriteValue(this.Size);
        }

        public override bool Equals(object obj)
        {
            if (obj == this) return true;

            if (obj != null && obj is FixedSchema)
            {
                FixedSchema that = obj as FixedSchema;
                return SchemaName.Equals(that.SchemaName) && Size == that.Size && areEqual(that.Props, this.Props);
            }
            return false;
        }

        public override int GetHashCode()
        {
            return 53 * SchemaName.GetHashCode() + 47 * Size + getHashCode(Props);
        }

        public override bool CanRead(Schema writerSchema)
        {
            if (writerSchema.Tag != Tag) return false;
            FixedSchema that = writerSchema as FixedSchema;
            if (that.Size != Size) return false;
            if (that.SchemaName.Equals(SchemaName))
                return true;
            else
                return InAliases(that.SchemaName);
        }
    }
}