#region Copyright notice and license // Protocol Buffers - Google's data interchange format // Copyright 2008 Google Inc. All rights reserved. // // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file or at // https://developers.google.com/open-source/licenses/bsd #endregion using Google.Protobuf.Collections; using System; namespace Google.Protobuf { internal interface IExtensionValue : IEquatable, IDeepCloneable { void MergeFrom(ref ParseContext ctx); void MergeFrom(IExtensionValue value); void WriteTo(ref WriteContext ctx); int CalculateSize(); bool IsInitialized(); object GetValue(); } internal sealed class ExtensionValue : IExtensionValue { private T field; private readonly FieldCodec codec; internal ExtensionValue(FieldCodec codec) { this.codec = codec; field = codec.DefaultValue; } public int CalculateSize() { return codec.CalculateUnconditionalSizeWithTag(field); } public IExtensionValue Clone() { return new ExtensionValue(codec) { field = field is IDeepCloneable ? (field as IDeepCloneable).Clone() : field }; } public bool Equals(IExtensionValue other) { if (ReferenceEquals(this, other)) return true; return other is ExtensionValue && codec.Equals((other as ExtensionValue).codec) && Equals(field, (other as ExtensionValue).field); // we check for equality in the codec since we could have equal field values however the values could be written in different ways } public override int GetHashCode() { unchecked { int hash = 17; hash = hash * 31 + field.GetHashCode(); hash = hash * 31 + codec.GetHashCode(); return hash; } } public void MergeFrom(ref ParseContext ctx) { codec.ValueMerger(ref ctx, ref field); } public void MergeFrom(IExtensionValue value) { if (value is ExtensionValue) { var extensionValue = value as ExtensionValue; codec.FieldMerger(ref field, extensionValue.field); } } public void WriteTo(ref WriteContext ctx) { ctx.WriteTag(codec.Tag); codec.ValueWriter(ref ctx, field); if (codec.EndTag != 0) { ctx.WriteTag(codec.EndTag); } } public T GetValue() => field; object IExtensionValue.GetValue() => field; public void SetValue(T value) { field = value; } public bool IsInitialized() { if (field is IMessage) { return (field as IMessage).IsInitialized(); } else { return true; } } } internal sealed class RepeatedExtensionValue : IExtensionValue { private RepeatedField field; private readonly FieldCodec codec; internal RepeatedExtensionValue(FieldCodec codec) { this.codec = codec; field = new RepeatedField(); } public int CalculateSize() { return field.CalculateSize(codec); } public IExtensionValue Clone() { return new RepeatedExtensionValue(codec) { field = field.Clone() }; } public bool Equals(IExtensionValue other) { if (ReferenceEquals(this, other)) return true; return other is RepeatedExtensionValue && field.Equals((other as RepeatedExtensionValue).field) && codec.Equals((other as RepeatedExtensionValue).codec); } public override int GetHashCode() { unchecked { int hash = 17; hash = hash * 31 + field.GetHashCode(); hash = hash * 31 + codec.GetHashCode(); return hash; } } public void MergeFrom(ref ParseContext ctx) { field.AddEntriesFrom(ref ctx, codec); } public void MergeFrom(IExtensionValue value) { if (value is RepeatedExtensionValue) { field.Add((value as RepeatedExtensionValue).field); } } public void WriteTo(ref WriteContext ctx) { field.WriteTo(ref ctx, codec); } public RepeatedField GetValue() => field; object IExtensionValue.GetValue() => field; public bool IsInitialized() { for (int i = 0; i < field.Count; i++) { var element = field[i]; if (element is IMessage) { if (!(element as IMessage).IsInitialized()) { return false; } } else { break; } } return true; } } }