123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855 |
- #if !NO_RUNTIME
- using System;
- using ProtoBuf.Serializers;
- using System.Globalization;
- using System.Collections.Generic;
- #if PROFILE259
- using System.Reflection;
- using System.Linq;
- #else
- using System.Reflection;
- #endif
- namespace ProtoBuf.Meta
- {
- /// <summary>
- /// Represents a member (property/field) that is mapped to a protobuf field
- /// </summary>
- public class ValueMember
- {
- private int _fieldNumber;
- /// <summary>
- /// The number that identifies this member in a protobuf stream
- /// </summary>
- public int FieldNumber
- {
- get => _fieldNumber;
- internal set
- {
- if (_fieldNumber != value)
- {
- MetaType.AssertValidFieldNumber(value);
- ThrowIfFrozen();
- _fieldNumber = value;
- }
- }
- }
- private readonly MemberInfo originalMember;
- private MemberInfo backingMember;
- /// <summary>
- /// Gets the member (field/property) which this member relates to.
- /// </summary>
- public MemberInfo Member { get { return originalMember; } }
- /// <summary>
- /// Gets the backing member (field/property) which this member relates to
- /// </summary>
- public MemberInfo BackingMember
- {
- get { return backingMember; }
- set
- {
- if (backingMember != value)
- {
- ThrowIfFrozen();
- backingMember = value;
- }
- }
- }
- private readonly Type parentType, itemType, defaultType, memberType;
- private object defaultValue;
- /// <summary>
- /// Within a list / array / etc, the type of object for each item in the list (especially useful with ArrayList)
- /// </summary>
- public Type ItemType => itemType;
- /// <summary>
- /// The underlying type of the member
- /// </summary>
- public Type MemberType => memberType;
- /// <summary>
- /// For abstract types (IList etc), the type of concrete object to create (if required)
- /// </summary>
- public Type DefaultType => defaultType;
- /// <summary>
- /// The type the defines the member
- /// </summary>
- public Type ParentType => parentType;
- /// <summary>
- /// The default value of the item (members with this value will not be serialized)
- /// </summary>
- public object DefaultValue
- {
- get { return defaultValue; }
- set
- {
- if (defaultValue != value)
- {
- ThrowIfFrozen();
- defaultValue = value;
- }
- }
- }
- private readonly RuntimeTypeModel model;
- /// <summary>
- /// Creates a new ValueMember instance
- /// </summary>
- public ValueMember(RuntimeTypeModel model, Type parentType, int fieldNumber, MemberInfo member, Type memberType, Type itemType, Type defaultType, DataFormat dataFormat, object defaultValue)
- : this(model, fieldNumber, memberType, itemType, defaultType, dataFormat)
- {
- if (parentType == null) throw new ArgumentNullException("parentType");
- if (fieldNumber < 1 && !Helpers.IsEnum(parentType)) throw new ArgumentOutOfRangeException("fieldNumber");
- this.originalMember = member ?? throw new ArgumentNullException("member");
- this.parentType = parentType;
- if (fieldNumber < 1 && !Helpers.IsEnum(parentType)) throw new ArgumentOutOfRangeException("fieldNumber");
- //#if WINRT
- if (defaultValue != null && model.MapType(defaultValue.GetType()) != memberType)
- //#else
- // if (defaultValue != null && !memberType.IsInstanceOfType(defaultValue))
- //#endif
- {
- defaultValue = ParseDefaultValue(memberType, defaultValue);
- }
- this.defaultValue = defaultValue;
- MetaType type = model.FindWithoutAdd(memberType);
- if (type != null)
- {
- AsReference = type.AsReferenceDefault;
- }
- else
- { // we need to scan the hard way; can't risk recursion by fully walking it
- AsReference = MetaType.GetAsReferenceDefault(model, memberType);
- }
- }
- /// <summary>
- /// Creates a new ValueMember instance
- /// </summary>
- internal ValueMember(RuntimeTypeModel model, int fieldNumber, Type memberType, Type itemType, Type defaultType, DataFormat dataFormat)
- {
- _fieldNumber = fieldNumber;
- this.memberType = memberType ?? throw new ArgumentNullException(nameof(memberType));
- this.itemType = itemType;
- this.defaultType = defaultType;
- this.model = model ?? throw new ArgumentNullException(nameof(model));
- this.dataFormat = dataFormat;
- }
- internal object GetRawEnumValue()
- {
- #if PORTABLE || CF || COREFX || PROFILE259
- object value = ((FieldInfo)originalMember).GetValue(null);
- switch(Helpers.GetTypeCode(Enum.GetUnderlyingType(((FieldInfo)originalMember).FieldType)))
- {
- case ProtoTypeCode.SByte: return (sbyte)value;
- case ProtoTypeCode.Byte: return (byte)value;
- case ProtoTypeCode.Int16: return (short)value;
- case ProtoTypeCode.UInt16: return (ushort)value;
- case ProtoTypeCode.Int32: return (int)value;
- case ProtoTypeCode.UInt32: return (uint)value;
- case ProtoTypeCode.Int64: return (long)value;
- case ProtoTypeCode.UInt64: return (ulong)value;
- default:
- throw new InvalidOperationException();
- }
- #else
- return ((FieldInfo)originalMember).GetRawConstantValue();
- #endif
- }
- private static object ParseDefaultValue(Type type, object value)
- {
- {
- Type tmp = Helpers.GetUnderlyingType(type);
- if (tmp != null) type = tmp;
- }
- if (value is string s)
- {
- if (Helpers.IsEnum(type)) return Helpers.ParseEnum(type, s);
- switch (Helpers.GetTypeCode(type))
- {
- case ProtoTypeCode.Boolean: return bool.Parse(s);
- case ProtoTypeCode.Byte: return byte.Parse(s, NumberStyles.Integer, CultureInfo.InvariantCulture);
- case ProtoTypeCode.Char: // char.Parse missing on CF/phone7
- if (s.Length == 1) return s[0];
- throw new FormatException("Single character expected: \"" + s + "\"");
- case ProtoTypeCode.DateTime: return DateTime.Parse(s, CultureInfo.InvariantCulture);
- case ProtoTypeCode.Decimal: return decimal.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.Double: return double.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.Int16: return short.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.Int32: return int.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.Int64: return long.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.SByte: return sbyte.Parse(s, NumberStyles.Integer, CultureInfo.InvariantCulture);
- case ProtoTypeCode.Single: return float.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.String: return s;
- case ProtoTypeCode.UInt16: return ushort.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.UInt32: return uint.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.UInt64: return ulong.Parse(s, NumberStyles.Any, CultureInfo.InvariantCulture);
- case ProtoTypeCode.TimeSpan: return TimeSpan.Parse(s);
- case ProtoTypeCode.Uri: return s; // Uri is decorated as string
- case ProtoTypeCode.Guid: return new Guid(s);
- }
- }
- if (Helpers.IsEnum(type)) return Enum.ToObject(type, value);
- return Convert.ChangeType(value, type, CultureInfo.InvariantCulture);
- }
- private IProtoSerializer serializer;
- internal IProtoSerializer Serializer
- {
- get
- {
- return serializer ?? (serializer = BuildSerializer());
- }
- }
- private DataFormat dataFormat;
- /// <summary>
- /// Specifies the rules used to process the field; this is used to determine the most appropriate
- /// wite-type, but also to describe subtypes <i>within</i> that wire-type (such as SignedVariant)
- /// </summary>
- public DataFormat DataFormat
- {
- get { return dataFormat; }
- set
- {
- if (value != dataFormat)
- {
- ThrowIfFrozen();
- this.dataFormat = value;
- }
- }
- }
- /// <summary>
- /// Indicates whether this field should follow strict encoding rules; this means (for example) that if a "fixed32"
- /// is encountered when "variant" is defined, then it will fail (throw an exception) when parsing. Note that
- /// when serializing the defined type is always used.
- /// </summary>
- public bool IsStrict
- {
- get { return HasFlag(OPTIONS_IsStrict); }
- set { SetFlag(OPTIONS_IsStrict, value, true); }
- }
- /// <summary>
- /// Indicates whether this field should use packed encoding (which can save lots of space for repeated primitive values).
- /// This option only applies to list/array data of primitive types (int, double, etc).
- /// </summary>
- public bool IsPacked
- {
- get { return HasFlag(OPTIONS_IsPacked); }
- set { SetFlag(OPTIONS_IsPacked, value, true); }
- }
- /// <summary>
- /// Indicates whether this field should *repace* existing values (the default is false, meaning *append*).
- /// This option only applies to list/array data.
- /// </summary>
- public bool OverwriteList
- {
- get { return HasFlag(OPTIONS_OverwriteList); }
- set { SetFlag(OPTIONS_OverwriteList, value, true); }
- }
- /// <summary>
- /// Indicates whether this field is mandatory.
- /// </summary>
- public bool IsRequired
- {
- get { return HasFlag(OPTIONS_IsRequired); }
- set { SetFlag(OPTIONS_IsRequired, value, true); }
- }
- /// <summary>
- /// Enables full object-tracking/full-graph support.
- /// </summary>
- public bool AsReference
- {
- get { return HasFlag(OPTIONS_AsReference); }
- set { SetFlag(OPTIONS_AsReference, value, true); }
- }
- /// <summary>
- /// Embeds the type information into the stream, allowing usage with types not known in advance.
- /// </summary>
- public bool DynamicType
- {
- get { return HasFlag(OPTIONS_DynamicType); }
- set { SetFlag(OPTIONS_DynamicType, value, true); }
- }
- /// <summary>
- /// Indicates that the member should be treated as a protobuf Map
- /// </summary>
- public bool IsMap
- {
- get { return HasFlag(OPTIONS_IsMap); }
- set { SetFlag(OPTIONS_IsMap, value, true); }
- }
- private DataFormat mapKeyFormat, mapValueFormat;
- /// <summary>
- /// Specifies the data-format that should be used for the key, when IsMap is enabled
- /// </summary>
- public DataFormat MapKeyFormat
- {
- get { return mapKeyFormat; }
- set
- {
- if (mapKeyFormat != value)
- {
- ThrowIfFrozen();
- mapKeyFormat = value;
- }
- }
- }
- /// <summary>
- /// Specifies the data-format that should be used for the value, when IsMap is enabled
- /// </summary>
- public DataFormat MapValueFormat
- {
- get { return mapValueFormat; }
- set
- {
- if (mapValueFormat != value)
- {
- ThrowIfFrozen();
- mapValueFormat = value;
- }
- }
- }
- private MethodInfo getSpecified, setSpecified;
- /// <summary>
- /// Specifies methods for working with optional data members.
- /// </summary>
- /// <param name="getSpecified">Provides a method (null for none) to query whether this member should
- /// be serialized; it must be of the form "bool {Method}()". The member is only serialized if the
- /// method returns true.</param>
- /// <param name="setSpecified">Provides a method (null for none) to indicate that a member was
- /// deserialized; it must be of the form "void {Method}(bool)", and will be called with "true"
- /// when data is found.</param>
- public void SetSpecified(MethodInfo getSpecified, MethodInfo setSpecified)
- {
- if (this.getSpecified != getSpecified || this.setSpecified != setSpecified)
- {
- if (getSpecified != null)
- {
- if (getSpecified.ReturnType != model.MapType(typeof(bool))
- || getSpecified.IsStatic
- || getSpecified.GetParameters().Length != 0)
- {
- throw new ArgumentException("Invalid pattern for checking member-specified", "getSpecified");
- }
- }
- if (setSpecified != null)
- {
- ParameterInfo[] args;
- if (setSpecified.ReturnType != model.MapType(typeof(void))
- || setSpecified.IsStatic
- || (args = setSpecified.GetParameters()).Length != 1
- || args[0].ParameterType != model.MapType(typeof(bool)))
- {
- throw new ArgumentException("Invalid pattern for setting member-specified", "setSpecified");
- }
- }
- ThrowIfFrozen();
- this.getSpecified = getSpecified;
- this.setSpecified = setSpecified;
- }
- }
- private void ThrowIfFrozen()
- {
- if (serializer != null) throw new InvalidOperationException("The type cannot be changed once a serializer has been generated");
- }
- internal bool ResolveMapTypes(out Type dictionaryType, out Type keyType, out Type valueType)
- {
- dictionaryType = keyType = valueType = null;
- try
- {
- #if COREFX || PROFILE259
- var info = memberType.GetTypeInfo();
- #else
- var info = memberType;
- #endif
- if (ImmutableCollectionDecorator.IdentifyImmutable(model, MemberType, out _, out _, out _, out _, out _, out _))
- {
- return false;
- }
- if (info.IsInterface && info.IsGenericType && info.GetGenericTypeDefinition() == typeof(IDictionary<,>))
- {
- #if PROFILE259
- var typeArgs = memberType.GetGenericTypeDefinition().GenericTypeArguments;
- #else
- var typeArgs = memberType.GetGenericArguments();
- #endif
- if (IsValidMapKeyType(typeArgs[0]))
- {
- keyType = typeArgs[0];
- valueType = typeArgs[1];
- dictionaryType = memberType;
- }
- return false;
- }
- #if PROFILE259
- foreach (var iType in memberType.GetTypeInfo().ImplementedInterfaces)
- #else
- foreach (var iType in memberType.GetInterfaces())
- #endif
- {
- #if COREFX || PROFILE259
- info = iType.GetTypeInfo();
- #else
- info = iType;
- #endif
- if (info.IsGenericType && info.GetGenericTypeDefinition() == typeof(IDictionary<,>))
- {
- if (dictionaryType != null) throw new InvalidOperationException("Multiple dictionary interfaces implemented by type: " + memberType.FullName);
- #if PROFILE259
- var typeArgs = iType.GetGenericTypeDefinition().GenericTypeArguments;
- #else
- var typeArgs = iType.GetGenericArguments();
- #endif
- if (IsValidMapKeyType(typeArgs[0]))
- {
- keyType = typeArgs[0];
- valueType = typeArgs[1];
- dictionaryType = memberType;
- }
- }
- }
- if (dictionaryType == null) return false;
- // (note we checked the key type already)
- // not a map if value is repeated
- Type itemType = null, defaultType = null;
- model.ResolveListTypes(valueType, ref itemType, ref defaultType);
- if (itemType != null) return false;
- return dictionaryType != null;
- }
- catch
- {
- // if it isn't a good fit; don't use "map"
- return false;
- }
- }
- static bool IsValidMapKeyType(Type type)
- {
- if (type == null || Helpers.IsEnum(type)) return false;
- switch (Helpers.GetTypeCode(type))
- {
- case ProtoTypeCode.Boolean:
- case ProtoTypeCode.Byte:
- case ProtoTypeCode.Char:
- case ProtoTypeCode.Int16:
- case ProtoTypeCode.Int32:
- case ProtoTypeCode.Int64:
- case ProtoTypeCode.String:
- case ProtoTypeCode.SByte:
- case ProtoTypeCode.UInt16:
- case ProtoTypeCode.UInt32:
- case ProtoTypeCode.UInt64:
- return true;
- }
- return false;
- }
- private IProtoSerializer BuildSerializer()
- {
- int opaqueToken = 0;
- try
- {
- model.TakeLock(ref opaqueToken);// check nobody is still adding this type
- var member = backingMember ?? originalMember;
- IProtoSerializer ser;
- if (IsMap)
- {
- ResolveMapTypes(out var dictionaryType, out var keyType, out var valueType);
- if (dictionaryType == null)
- {
- throw new InvalidOperationException("Unable to resolve map type for type: " + memberType.FullName);
- }
- var concreteType = defaultType;
- if (concreteType == null && Helpers.IsClass(memberType))
- {
- concreteType = memberType;
- }
- var keySer = TryGetCoreSerializer(model, MapKeyFormat, keyType, out var keyWireType, false, false, false, false);
- if (!AsReference)
- {
- AsReference = MetaType.GetAsReferenceDefault(model, valueType);
- }
- var valueSer = TryGetCoreSerializer(model, MapValueFormat, valueType, out var valueWireType, AsReference, DynamicType, false, true);
- #if PROFILE259
- IEnumerable<ConstructorInfo> ctors = typeof(MapDecorator<,,>).MakeGenericType(new Type[] { dictionaryType, keyType, valueType }).GetTypeInfo().DeclaredConstructors;
- if (ctors.Count() != 1)
- {
- throw new InvalidOperationException("Unable to resolve MapDecorator constructor");
- }
- ser = (IProtoSerializer)ctors.First().Invoke(new object[] {model, concreteType, keySer, valueSer, _fieldNumber,
- DataFormat == DataFormat.Group ? WireType.StartGroup : WireType.String, keyWireType, valueWireType, OverwriteList });
- #else
- var ctors = typeof(MapDecorator<,,>).MakeGenericType(new Type[] { dictionaryType, keyType, valueType }).GetConstructors(
- BindingFlags.NonPublic | BindingFlags.Public | BindingFlags.Instance);
- if (ctors.Length != 1) throw new InvalidOperationException("Unable to resolve MapDecorator constructor");
- ser = (IProtoSerializer)ctors[0].Invoke(new object[] {model, concreteType, keySer, valueSer, _fieldNumber,
- DataFormat == DataFormat.Group ? WireType.StartGroup : WireType.String, keyWireType, valueWireType, OverwriteList });
- #endif
- }
- else
- {
- Type finalType = itemType ?? memberType;
- ser = TryGetCoreSerializer(model, dataFormat, finalType, out WireType wireType, AsReference, DynamicType, OverwriteList, true);
- if (ser == null)
- {
- throw new InvalidOperationException("No serializer defined for type: " + finalType.FullName);
- }
- // apply tags
- if (itemType != null && SupportNull)
- {
- if (IsPacked)
- {
- throw new NotSupportedException("Packed encodings cannot support null values");
- }
- ser = new TagDecorator(NullDecorator.Tag, wireType, IsStrict, ser);
- ser = new NullDecorator(model, ser);
- ser = new TagDecorator(_fieldNumber, WireType.StartGroup, false, ser);
- }
- else
- {
- ser = new TagDecorator(_fieldNumber, wireType, IsStrict, ser);
- }
- // apply lists if appropriate
- if (itemType != null)
- {
- Type underlyingItemType = SupportNull ? itemType : Helpers.GetUnderlyingType(itemType) ?? itemType;
- Helpers.DebugAssert(underlyingItemType == ser.ExpectedType
- || (ser.ExpectedType == model.MapType(typeof(object)) && !Helpers.IsValueType(underlyingItemType))
- , "Wrong type in the tail; expected {0}, received {1}", ser.ExpectedType, underlyingItemType);
- if (memberType.IsArray)
- {
- ser = new ArrayDecorator(model, ser, _fieldNumber, IsPacked, wireType, memberType, OverwriteList, SupportNull);
- }
- else
- {
- ser = ListDecorator.Create(model, memberType, defaultType, ser, _fieldNumber, IsPacked, wireType, member != null && PropertyDecorator.CanWrite(model, member), OverwriteList, SupportNull);
- }
- }
- else if (defaultValue != null && !IsRequired && getSpecified == null)
- { // note: "ShouldSerialize*" / "*Specified" / etc ^^^^ take precedence over defaultValue,
- // as does "IsRequired"
- ser = new DefaultValueDecorator(model, defaultValue, ser);
- }
- if (memberType == model.MapType(typeof(Uri)))
- {
- ser = new UriDecorator(model, ser);
- }
- #if PORTABLE
- else if(memberType.FullName == typeof(Uri).FullName)
- {
- // In PCLs, the Uri type may not match (WinRT uses Internal/Uri, .Net uses System/Uri)
- ser = new ReflectedUriDecorator(memberType, model, ser);
- }
- #endif
- }
- if (member != null)
- {
- if (member is PropertyInfo prop)
- {
- ser = new PropertyDecorator(model, parentType, prop, ser);
- }
- else if (member is FieldInfo fld)
- {
- ser = new FieldDecorator(parentType, fld, ser);
- }
- else
- {
- throw new InvalidOperationException();
- }
-
- if (getSpecified != null || setSpecified != null)
- {
- ser = new MemberSpecifiedDecorator(getSpecified, setSpecified, ser);
- }
- }
- return ser;
- }
- finally
- {
- model.ReleaseLock(opaqueToken);
- }
- }
- private static WireType GetIntWireType(DataFormat format, int width)
- {
- switch (format)
- {
- case DataFormat.ZigZag: return WireType.SignedVariant;
- case DataFormat.FixedSize: return width == 32 ? WireType.Fixed32 : WireType.Fixed64;
- case DataFormat.TwosComplement:
- case DataFormat.Default: return WireType.Variant;
- default: throw new InvalidOperationException();
- }
- }
- private static WireType GetDateTimeWireType(DataFormat format)
- {
- switch (format)
- {
- case DataFormat.Group: return WireType.StartGroup;
- case DataFormat.FixedSize: return WireType.Fixed64;
- case DataFormat.WellKnown:
- case DataFormat.Default:
- return WireType.String;
- default: throw new InvalidOperationException();
- }
- }
- internal static IProtoSerializer TryGetCoreSerializer(RuntimeTypeModel model, DataFormat dataFormat, Type type, out WireType defaultWireType,
- bool asReference, bool dynamicType, bool overwriteList, bool allowComplexTypes)
- {
- {
- Type tmp = Helpers.GetUnderlyingType(type);
- if (tmp != null) type = tmp;
- }
- if (Helpers.IsEnum(type))
- {
- if (allowComplexTypes && model != null)
- {
- // need to do this before checking the typecode; an int enum will report Int32 etc
- defaultWireType = WireType.Variant;
- return new EnumSerializer(type, model.GetEnumMap(type));
- }
- else
- { // enum is fine for adding as a meta-type
- defaultWireType = WireType.None;
- return null;
- }
- }
- ProtoTypeCode code = Helpers.GetTypeCode(type);
- switch (code)
- {
- case ProtoTypeCode.Int32:
- defaultWireType = GetIntWireType(dataFormat, 32);
- return new Int32Serializer(model);
- case ProtoTypeCode.UInt32:
- defaultWireType = GetIntWireType(dataFormat, 32);
- return new UInt32Serializer(model);
- case ProtoTypeCode.Int64:
- defaultWireType = GetIntWireType(dataFormat, 64);
- return new Int64Serializer(model);
- case ProtoTypeCode.UInt64:
- defaultWireType = GetIntWireType(dataFormat, 64);
- return new UInt64Serializer(model);
- case ProtoTypeCode.String:
- defaultWireType = WireType.String;
- if (asReference)
- {
- return new NetObjectSerializer(model, model.MapType(typeof(string)), 0, BclHelpers.NetObjectOptions.AsReference);
- }
- return new StringSerializer(model);
- case ProtoTypeCode.Single:
- defaultWireType = WireType.Fixed32;
- return new SingleSerializer(model);
- case ProtoTypeCode.Double:
- defaultWireType = WireType.Fixed64;
- return new DoubleSerializer(model);
- case ProtoTypeCode.Boolean:
- defaultWireType = WireType.Variant;
- return new BooleanSerializer(model);
- case ProtoTypeCode.DateTime:
- defaultWireType = GetDateTimeWireType(dataFormat);
- return new DateTimeSerializer(dataFormat, model);
- case ProtoTypeCode.Decimal:
- defaultWireType = WireType.String;
- return new DecimalSerializer(model);
- case ProtoTypeCode.Byte:
- defaultWireType = GetIntWireType(dataFormat, 32);
- return new ByteSerializer(model);
- case ProtoTypeCode.SByte:
- defaultWireType = GetIntWireType(dataFormat, 32);
- return new SByteSerializer(model);
- case ProtoTypeCode.Char:
- defaultWireType = WireType.Variant;
- return new CharSerializer(model);
- case ProtoTypeCode.Int16:
- defaultWireType = GetIntWireType(dataFormat, 32);
- return new Int16Serializer(model);
- case ProtoTypeCode.UInt16:
- defaultWireType = GetIntWireType(dataFormat, 32);
- return new UInt16Serializer(model);
- case ProtoTypeCode.TimeSpan:
- defaultWireType = GetDateTimeWireType(dataFormat);
- return new TimeSpanSerializer(dataFormat, model);
- case ProtoTypeCode.Guid:
- defaultWireType = dataFormat == DataFormat.Group ? WireType.StartGroup : WireType.String;
- return new GuidSerializer(model);
- case ProtoTypeCode.Uri:
- defaultWireType = WireType.String;
- return new StringSerializer(model);
- case ProtoTypeCode.ByteArray:
- defaultWireType = WireType.String;
- return new BlobSerializer(model, overwriteList);
- case ProtoTypeCode.Type:
- defaultWireType = WireType.String;
- return new SystemTypeSerializer(model);
- }
- IProtoSerializer parseable = model.AllowParseableTypes ? ParseableSerializer.TryCreate(type, model) : null;
- if (parseable != null)
- {
- defaultWireType = WireType.String;
- return parseable;
- }
- if (allowComplexTypes && model != null)
- {
- int key = model.GetKey(type, false, true);
- MetaType meta = null;
- if (key >= 0)
- {
- meta = model[type];
- if (dataFormat == DataFormat.Default && meta.IsGroup)
- {
- dataFormat = DataFormat.Group;
- }
- }
- if (asReference || dynamicType)
- {
- BclHelpers.NetObjectOptions options = BclHelpers.NetObjectOptions.None;
- if (asReference) options |= BclHelpers.NetObjectOptions.AsReference;
- if (dynamicType) options |= BclHelpers.NetObjectOptions.DynamicType;
- if (meta != null)
- { // exists
- if (asReference && Helpers.IsValueType(type))
- {
- string message = "AsReference cannot be used with value-types";
- if (type.Name == "KeyValuePair`2")
- {
- message += "; please see https://stackoverflow.com/q/14436606/23354";
- }
- else
- {
- message += ": " + type.FullName;
- }
- throw new InvalidOperationException(message);
- }
- if (asReference && meta.IsAutoTuple) options |= BclHelpers.NetObjectOptions.LateSet;
- if (meta.UseConstructor) options |= BclHelpers.NetObjectOptions.UseConstructor;
- }
- defaultWireType = dataFormat == DataFormat.Group ? WireType.StartGroup : WireType.String;
- return new NetObjectSerializer(model, type, key, options);
- }
- if (key >= 0)
- {
- defaultWireType = dataFormat == DataFormat.Group ? WireType.StartGroup : WireType.String;
- return new SubItemSerializer(type, key, meta, true);
- }
- }
- defaultWireType = WireType.None;
- return null;
- }
- private string name;
- internal void SetName(string name)
- {
- if (name != this.name)
- {
- ThrowIfFrozen();
- this.name = name;
- }
- }
- /// <summary>
- /// Gets the logical name for this member in the schema (this is not critical for binary serialization, but may be used
- /// when inferring a schema).
- /// </summary>
- public string Name
- {
- get { return string.IsNullOrEmpty(name) ? originalMember.Name : name; }
- set { SetName(value); }
- }
- private const byte
- OPTIONS_IsStrict = 1,
- OPTIONS_IsPacked = 2,
- OPTIONS_IsRequired = 4,
- OPTIONS_OverwriteList = 8,
- OPTIONS_SupportNull = 16,
- OPTIONS_AsReference = 32,
- OPTIONS_IsMap = 64,
- OPTIONS_DynamicType = 128;
- private byte flags;
- private bool HasFlag(byte flag) { return (flags & flag) == flag; }
- private void SetFlag(byte flag, bool value, bool throwIfFrozen)
- {
- if (throwIfFrozen && HasFlag(flag) != value)
- {
- ThrowIfFrozen();
- }
- if (value)
- flags |= flag;
- else
- flags = (byte)(flags & ~flag);
- }
- /// <summary>
- /// Should lists have extended support for null values? Note this makes the serialization less efficient.
- /// </summary>
- public bool SupportNull
- {
- get { return HasFlag(OPTIONS_SupportNull); }
- set { SetFlag(OPTIONS_SupportNull, value, true); }
- }
- internal string GetSchemaTypeName(bool applyNetObjectProxy, ref RuntimeTypeModel.CommonImports imports)
- {
- Type effectiveType = ItemType;
- if (effectiveType == null) effectiveType = MemberType;
- return model.GetSchemaTypeName(effectiveType, DataFormat, applyNetObjectProxy && AsReference, applyNetObjectProxy && DynamicType, ref imports);
- }
- internal sealed class Comparer : System.Collections.IComparer, IComparer<ValueMember>
- {
- public static readonly Comparer Default = new Comparer();
- public int Compare(object x, object y)
- {
- return Compare(x as ValueMember, y as ValueMember);
- }
- public int Compare(ValueMember x, ValueMember y)
- {
- if (ReferenceEquals(x, y)) return 0;
- if (x == null) return -1;
- if (y == null) return 1;
- return x.FieldNumber.CompareTo(y.FieldNumber);
- }
- }
- }
- }
- #endif
|