Mercurial > hg > Database > jungle-sharp

annotate Main/jungle-main/persistent/msgpack/src/ObjectPacker.cs @ 20:1f99e150f336

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
fix folder and add Object Mapper.
author Kazuma Takeda
date Thu, 15 Dec 2016 22:52:48 +0900
parents
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
20
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
1 //
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
2 // Copyright 2011 Kazuki Oikawa
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
3 //
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
4 // Licensed under the Apache License, Version 2.0 (the "License");
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
5 // you may not use this file except in compliance with the License.
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
6 // You may obtain a copy of the License at
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
7 //
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
8 // http://www.apache.org/licenses/LICENSE-2.0
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
9 //
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
10 // Unless required by applicable law or agreed to in writing, software
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
11 // distributed under the License is distributed on an "AS IS" BASIS,
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
12 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
13 // See the License for the specific language governing permissions and
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
14 // limitations under the License.
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
15 //
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
16
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
17 using System;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
18 using System.Collections.Generic;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
19 using System.IO;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
20 using System.Reflection;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
21 using System.Runtime.Serialization;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
22 using System.Text;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
23
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
24 namespace MsgPack
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
25 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
26 public class ObjectPacker
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
27 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
28 byte[] _buf = new byte[64];
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
29 //Encoding _encoding = Encoding.UTF8;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
30 static Dictionary<Type, PackDelegate> PackerMapping;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
31 static Dictionary<Type, UnpackDelegate> UnpackerMapping;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
32
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
33 delegate void PackDelegate (ObjectPacker packer, MsgPackWriter writer, object o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
34 delegate object UnpackDelegate (ObjectPacker packer, MsgPackReader reader);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
35
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
36 static ObjectPacker ()
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
37 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
38 PackerMapping = new Dictionary<Type, PackDelegate> ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
39 UnpackerMapping = new Dictionary<Type, UnpackDelegate> ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
40
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
41 PackerMapping.Add (typeof (string), StringPacker);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
42 UnpackerMapping.Add (typeof (string), StringUnpacker);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
43 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
44
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
45 public byte[] Pack (object o)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
46 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
47 using (MemoryStream ms = new MemoryStream ()) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
48 Pack (ms, o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
49 return ms.ToArray ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
50 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
51 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
52
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
53 public void Pack (Stream strm, object o)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
54 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
55 if (o != null && o.GetType ().IsPrimitive)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
56 throw new NotSupportedException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
57 MsgPackWriter writer = new MsgPackWriter (strm);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
58 Pack (writer, o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
59 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
60
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
61 void Pack (MsgPackWriter writer, object o)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
62 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
63 if (o == null) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
64 writer.WriteNil ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
65 return;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
66 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
67
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
68 Type t = o.GetType ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
69 if (t.IsPrimitive) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
70 if (t.Equals (typeof (int))) writer.Write ((int)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
71 else if (t.Equals (typeof (uint))) writer.Write ((uint)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
72 else if (t.Equals (typeof (float))) writer.Write ((float)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
73 else if (t.Equals (typeof (double))) writer.Write ((double)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
74 else if (t.Equals (typeof (long))) writer.Write ((long)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
75 else if (t.Equals (typeof (ulong))) writer.Write ((ulong)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
76 else if (t.Equals (typeof (bool))) writer.Write ((bool)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
77 else if (t.Equals (typeof (byte))) writer.Write ((byte)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
78 else if (t.Equals (typeof (sbyte))) writer.Write ((sbyte)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
79 else if (t.Equals (typeof (short))) writer.Write ((short)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
80 else if (t.Equals (typeof (ushort))) writer.Write ((ushort)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
81 else if (t.Equals (typeof (char))) writer.Write ((ushort)(char)o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
82 else throw new NotSupportedException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
83 return;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
84 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
85
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
86 PackDelegate packer;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
87 if (PackerMapping.TryGetValue (t, out packer)) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
88 packer (this, writer, o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
89 return;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
90 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
91
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
92 if (t.IsArray) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
93 Array ary = (Array)o;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
94 writer.WriteArrayHeader (ary.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
95 for (int i = 0; i < ary.Length; i ++)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
96 Pack (writer, ary.GetValue (i));
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
97 return;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
98 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
99
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
100 ReflectionCacheEntry entry = ReflectionCache.Lookup (t);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
101 writer.WriteMapHeader (entry.FieldMap.Count);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
102 foreach (KeyValuePair<string, FieldInfo> pair in entry.FieldMap) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
103 writer.Write (pair.Key, _buf);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
104 object v = pair.Value.GetValue (o);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
105 if (pair.Value.FieldType.IsInterface && v != null) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
106 writer.WriteArrayHeader (2);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
107 writer.Write (v.GetType().FullName);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
108 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
109 Pack (writer, v);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
110 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
111 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
112
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
113 public T Unpack<T> (byte[] buf)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
114 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
115 return Unpack<T> (buf, 0, buf.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
116 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
117
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
118 public T Unpack<T> (byte[] buf, int offset, int size)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
119 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
120 using (MemoryStream ms = new MemoryStream (buf, offset, size)) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
121 return Unpack<T> (ms);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
122 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
123 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
124
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
125 public T Unpack<T> (Stream strm)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
126 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
127 if (typeof (T).IsPrimitive)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
128 throw new NotSupportedException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
129 MsgPackReader reader = new MsgPackReader (strm);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
130 return (T)Unpack (reader, typeof (T));
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
131 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
132
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
133 public object Unpack (Type type, byte[] buf)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
134 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
135 return Unpack (type, buf, 0, buf.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
136 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
137
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
138 public object Unpack (Type type, byte[] buf, int offset, int size)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
139 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
140 using (MemoryStream ms = new MemoryStream (buf, offset, size)) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
141 return Unpack (type, ms);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
142 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
143 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
144
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
145 public object Unpack (Type type, Stream strm)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
146 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
147 if (type.IsPrimitive)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
148 throw new NotSupportedException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
149 MsgPackReader reader = new MsgPackReader (strm);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
150 return Unpack (reader, type);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
151 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
152
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
153 object Unpack (MsgPackReader reader, Type t)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
154 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
155 if (t.IsPrimitive) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
156 if (!reader.Read ()) throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
157 if (t.Equals (typeof (int)) && reader.IsSigned ()) return reader.ValueSigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
158 else if (t.Equals (typeof (uint)) && reader.IsUnsigned ()) return reader.ValueUnsigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
159 else if (t.Equals (typeof (float)) && reader.Type == TypePrefixes.Float) return reader.ValueFloat;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
160 else if (t.Equals (typeof (double)) && reader.Type == TypePrefixes.Double) return reader.ValueDouble;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
161 else if (t.Equals (typeof (long))) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
162 if (reader.IsSigned64 ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
163 return reader.ValueSigned64;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
164 if (reader.IsSigned ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
165 return (long)reader.ValueSigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
166 } else if (t.Equals (typeof (ulong))) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
167 if (reader.IsUnsigned64 ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
168 return reader.ValueUnsigned64;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
169 if (reader.IsUnsigned ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
170 return (ulong)reader.ValueUnsigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
171 } else if (t.Equals (typeof (bool)) && reader.IsBoolean ()) return (reader.Type == TypePrefixes.True);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
172 else if (t.Equals (typeof (byte)) && reader.IsUnsigned ()) return (byte)reader.ValueUnsigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
173 else if (t.Equals (typeof (sbyte)) && reader.IsSigned ()) return (sbyte)reader.ValueSigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
174 else if (t.Equals (typeof (short)) && reader.IsSigned ()) return (short)reader.ValueSigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
175 else if (t.Equals (typeof (ushort)) && reader.IsUnsigned ()) return (ushort)reader.ValueUnsigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
176 else if (t.Equals (typeof (char)) && reader.IsUnsigned ()) return (char)reader.ValueUnsigned;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
177 else throw new NotSupportedException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
178 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
179
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
180 UnpackDelegate unpacker;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
181 if (UnpackerMapping.TryGetValue (t, out unpacker))
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
182 return unpacker (this, reader);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
183
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
184 if (t.IsArray) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
185 if (!reader.Read () || (!reader.IsArray () && reader.Type != TypePrefixes.Nil))
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
186 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
187 if (reader.Type == TypePrefixes.Nil)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
188 return null;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
189 Type et = t.GetElementType ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
190 Array ary = Array.CreateInstance (et, (int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
191 for (int i = 0; i < ary.Length; i ++)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
192 ary.SetValue (Unpack (reader, et), i);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
193 return ary;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
194 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
195
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
196 if (!reader.Read ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
197 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
198 if (reader.Type == TypePrefixes.Nil)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
199 return null;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
200 if (t.IsInterface) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
201 if (reader.Type != TypePrefixes.FixArray && reader.Length != 2)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
202 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
203 if (!reader.Read () || !reader.IsRaw ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
204 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
205 CheckBufferSize ((int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
206 reader.ReadValueRaw (_buf, 0, (int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
207 t = Type.GetType (Encoding.UTF8.GetString (_buf, 0, (int)reader.Length));
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
208 if (!reader.Read () || reader.Type == TypePrefixes.Nil)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
209 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
210 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
211 if (!reader.IsMap ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
212 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
213
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
214 object o = FormatterServices.GetUninitializedObject (t);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
215 ReflectionCacheEntry entry = ReflectionCache.Lookup (t);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
216 int members = (int)reader.Length;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
217 for (int i = 0; i < members; i ++) {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
218 if (!reader.Read () || !reader.IsRaw ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
219 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
220 CheckBufferSize ((int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
221 reader.ReadValueRaw (_buf, 0, (int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
222 string name = Encoding.UTF8.GetString (_buf, 0, (int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
223 FieldInfo f;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
224 if (!entry.FieldMap.TryGetValue (name, out f))
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
225 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
226 f.SetValue (o, Unpack (reader, f.FieldType));
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
227 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
228
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
229 IDeserializationCallback callback = o as IDeserializationCallback;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
230 if (callback != null)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
231 callback.OnDeserialization (this);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
232 return o;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
233 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
234
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
235 void CheckBufferSize (int size)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
236 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
237 if (_buf.Length < size)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
238 Array.Resize<byte> (ref _buf, size);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
239 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
240
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
241 static void StringPacker (ObjectPacker packer, MsgPackWriter writer, object o)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
242 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
243 writer.Write (Encoding.UTF8.GetBytes ((string)o));
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
244 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
245
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
246 static object StringUnpacker (ObjectPacker packer, MsgPackReader reader)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
247 {
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
248 if (!reader.Read ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
249 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
250 if (reader.Type == TypePrefixes.Nil)
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
251 return null;
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
252 if (!reader.IsRaw ())
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
253 throw new FormatException ();
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
254 packer.CheckBufferSize ((int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
255 reader.ReadValueRaw (packer._buf, 0, (int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
256 return Encoding.UTF8.GetString (packer._buf, 0, (int)reader.Length);
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
257 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
258 }
1f99e150f336 fix folder and add Object Mapper.
Kazuma Takeda
parents:
diff changeset
259 }