forked from msgpack/msgpack-cli
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathCollectionMessagePackSerializer`2.cs
More file actions
163 lines (149 loc) · 6.5 KB
/
CollectionMessagePackSerializer`2.cs
File metadata and controls
163 lines (149 loc) · 6.5 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
#region -- License Terms --
//
// MessagePack for CLI
//
// Copyright (C) 2015-2018 FUJIWARA, Yusuke
//
// 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.
//
#endregion -- License Terms --
#if UNITY_5 || UNITY_STANDALONE || UNITY_WEBPLAYER || UNITY_WII || UNITY_IPHONE || UNITY_ANDROID || UNITY_PS3 || UNITY_XBOX360 || UNITY_FLASH || UNITY_BKACKBERRY || UNITY_WINRT
#define UNITY
#endif
using System;
using System.Collections.Generic;
#if UNITY
using System.Collections;
using System.Reflection;
#endif // UNITY
namespace MsgPack.Serialization.CollectionSerializers
{
/// <summary>
/// Provides common implementation of <see cref="CollectionMessagePackSerializerBase{TCollection, TItem}"/>
/// for collection types which implement <see cref="ICollection{T}"/>.
/// </summary>
/// <typeparam name="TCollection">The type of the collection.</typeparam>
/// <typeparam name="TItem">The type of the item of collection.</typeparam>
public abstract class CollectionMessagePackSerializer<TCollection, TItem> : CollectionMessagePackSerializerBase<TCollection, TItem>
where TCollection : ICollection<TItem>
{
/// <summary>
/// Initializes a new instance of the <see cref="CollectionMessagePackSerializer{TCollection, TItem}"/> class.
/// </summary>
/// <param name="ownerContext">A <see cref="SerializationContext"/> which owns this serializer.</param>
/// <param name="schema">
/// The schema for collection itself or its items for the member this instance will be used to.
/// <c>null</c> will be considered as <see cref="PolymorphismSchema.Default"/>.
/// </param>
/// <exception cref="ArgumentNullException">
/// <paramref name="ownerContext"/> is <c>null</c>.
/// </exception>
protected CollectionMessagePackSerializer( SerializationContext ownerContext, PolymorphismSchema schema )
: base( ownerContext, schema ) { }
/// <summary>
/// Initializes a new instance of the <see cref="CollectionMessagePackSerializer{TCollection, TItem}"/> class.
/// </summary>
/// <param name="ownerContext">A <see cref="SerializationContext"/> which owns this serializer.</param>
/// <param name="schema">
/// The schema for collection itself or its items for the member this instance will be used to.
/// <c>null</c> will be considered as <see cref="PolymorphismSchema.Default"/>.
/// </param>
/// <param name="capabilities">A serializer calability flags represents capabilities of this instance.</param>
/// <exception cref="ArgumentNullException">
/// <paramref name="ownerContext"/> is <c>null</c>.
/// </exception>
protected CollectionMessagePackSerializer( SerializationContext ownerContext, PolymorphismSchema schema, SerializerCapabilities capabilities )
: base( ownerContext, schema, capabilities ) { }
/// <summary>
/// Returns count of the collection.
/// </summary>
/// <param name="collection">A collection. This value will not be <c>null</c>.</param>
/// <returns>The count of the <paramref name="collection"/>.</returns>
protected override int GetCount( TCollection collection )
{
#if ( !UNITY && !AOT ) || AOT_CHECK
return collection.Count;
#else
// .constraind call for TCollection.get_Count/TCollection.GetEnumerator() causes AOT error.
// So use cast and invoke as normal call (it might cause boxing, but most collection should be reference type).
return ( collection as ICollection<TItem> ).Count;
#endif // ( !UNITY ) || AOT_CHECK
}
/// <summary>
/// Adds the deserialized item to the collection on <typeparamref name="TCollection"/> specific manner
/// to implement <see cref="MessagePackSerializer{TCollection}.UnpackToCore(Unpacker,TCollection)"/>.
/// </summary>
/// <param name="collection">The collection to be added.</param>
/// <param name="item">The item to be added.</param>
[System.Diagnostics.CodeAnalysis.SuppressMessage( "Microsoft.Design", "CA1062:ValidateArgumentsOfPublicMethods", MessageId = "0", Justification = "Validated by caller in base class" )]
protected override void AddItem( TCollection collection, TItem item )
{
#if ( !UNITY && !AOT ) || AOT_CHECK
collection.Add( item );
#else
// .constraind call for TCollection.Add causes AOT error.
// So use cast and invoke as normal call (it might cause boxing, but most collection should be reference type).
( collection as ICollection<TItem> ).Add( item );
#endif // ( !UNITY ) || AOT_CHECK
}
}
#if UNITY
#warning TODO: Remove if possible for maintenancibility.
internal abstract class UnityCollectionMessagePackSerializer : UnityEnumerableMessagePackSerializerBase
{
private readonly MethodInfo _getCount;
private readonly MethodInfo _add;
protected UnityCollectionMessagePackSerializer(
SerializationContext ownerContext,
Type targetType,
CollectionTraits traits,
PolymorphismSchema schema,
SerializerCapabilities capabilities
)
: base( ownerContext, targetType, traits.ElementType, schema, capabilities )
{
this._getCount = traits.CountPropertyGetter;
this._add = traits.AddMethod;
}
protected internal override void PackToCore( Packer packer, object objectTree )
{
packer.PackArrayHeader( ( int )this._getCount.InvokePreservingExceptionType( objectTree ) );
var itemSerializer = this.ItemSerializer;
// ReSharper disable once PossibleNullReferenceException
foreach ( var item in objectTree as IEnumerable )
{
itemSerializer.PackTo( packer, item );
}
}
protected internal override object UnpackFromCore( Unpacker unpacker )
{
if ( !unpacker.IsArrayHeader )
{
SerializationExceptions.ThrowIsNotArrayHeader( unpacker );
}
return this.InternalUnpackFromCore( unpacker );
}
internal virtual object InternalUnpackFromCore( Unpacker unpacker )
{
var itemsCount = UnpackHelpers.GetItemsCount( unpacker );
var collection = this.CreateInstance( itemsCount );
this.UnpackToCore( unpacker, collection, itemsCount );
return collection;
}
protected override void AddItem( object collection, object item )
{
this._add.InvokePreservingExceptionType( collection, item );
}
}
#endif // UNITY
}