#region Copyright notice and license // Protocol Buffers - Google's data interchange format // Copyright 2008 Google Inc. All rights reserved. // https://developers.google.com/protocol-buffers/ // // Redistribution and use in source and binary forms, with or without // modification, are permitted provided that the following conditions are // met: // // * Redistributions of source code must retain the above copyright // notice, this list of conditions and the following disclaimer. // * Redistributions in binary form must reproduce the above // copyright notice, this list of conditions and the following disclaimer // in the documentation and/or other materials provided with the // distribution. // * Neither the name of Google Inc. nor the names of its // contributors may be used to endorse or promote products derived from // this software without specific prior written permission. // // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. #endregion using LC.Google.Protobuf.Collections; using System; using System.Linq; namespace LC.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(); } internal sealed class ExtensionValue : IExtensionValue { private T field; private FieldCodec codec; internal ExtensionValue(FieldCodec codec) { this.codec = codec; field = codec.DefaultValue; } public int CalculateSize() { return codec.CalculateSizeWithTag(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; 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; 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; } } }