annotate src/main/java/org/msgpack/template/MapTemplate.java @ 0:cb825acd883a

first commit
author sugi
date Sat, 18 Oct 2014 15:06:15 +0900
parents
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
cb825acd883a first commit
sugi
parents:
diff changeset
1 //
cb825acd883a first commit
sugi
parents:
diff changeset
2 // MessagePack for Java
cb825acd883a first commit
sugi
parents:
diff changeset
3 //
cb825acd883a first commit
sugi
parents:
diff changeset
4 // Copyright (C) 2009 - 2013 FURUHASHI Sadayuki
cb825acd883a first commit
sugi
parents:
diff changeset
5 //
cb825acd883a first commit
sugi
parents:
diff changeset
6 // Licensed under the Apache License, Version 2.0 (the "License");
cb825acd883a first commit
sugi
parents:
diff changeset
7 // you may not use this file except in compliance with the License.
cb825acd883a first commit
sugi
parents:
diff changeset
8 // You may obtain a copy of the License at
cb825acd883a first commit
sugi
parents:
diff changeset
9 //
cb825acd883a first commit
sugi
parents:
diff changeset
10 // http://www.apache.org/licenses/LICENSE-2.0
cb825acd883a first commit
sugi
parents:
diff changeset
11 //
cb825acd883a first commit
sugi
parents:
diff changeset
12 // Unless required by applicable law or agreed to in writing, software
cb825acd883a first commit
sugi
parents:
diff changeset
13 // distributed under the License is distributed on an "AS IS" BASIS,
cb825acd883a first commit
sugi
parents:
diff changeset
14 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
cb825acd883a first commit
sugi
parents:
diff changeset
15 // See the License for the specific language governing permissions and
cb825acd883a first commit
sugi
parents:
diff changeset
16 // limitations under the License.
cb825acd883a first commit
sugi
parents:
diff changeset
17 //
cb825acd883a first commit
sugi
parents:
diff changeset
18 package org.msgpack.template;
cb825acd883a first commit
sugi
parents:
diff changeset
19
cb825acd883a first commit
sugi
parents:
diff changeset
20 import java.io.IOException;
cb825acd883a first commit
sugi
parents:
diff changeset
21 import java.util.Map;
cb825acd883a first commit
sugi
parents:
diff changeset
22 import java.util.HashMap;
cb825acd883a first commit
sugi
parents:
diff changeset
23 import org.msgpack.packer.Packer;
cb825acd883a first commit
sugi
parents:
diff changeset
24 import org.msgpack.unpacker.Unpacker;
cb825acd883a first commit
sugi
parents:
diff changeset
25 import org.msgpack.MessageTypeException;
cb825acd883a first commit
sugi
parents:
diff changeset
26
cb825acd883a first commit
sugi
parents:
diff changeset
27 public class MapTemplate<K, V> extends AbstractTemplate<Map<K, V>> {
cb825acd883a first commit
sugi
parents:
diff changeset
28 private Template<K> keyTemplate;
cb825acd883a first commit
sugi
parents:
diff changeset
29 private Template<V> valueTemplate;
cb825acd883a first commit
sugi
parents:
diff changeset
30
cb825acd883a first commit
sugi
parents:
diff changeset
31 public MapTemplate(Template<K> keyTemplate, Template<V> valueTemplate) {
cb825acd883a first commit
sugi
parents:
diff changeset
32 this.keyTemplate = keyTemplate;
cb825acd883a first commit
sugi
parents:
diff changeset
33 this.valueTemplate = valueTemplate;
cb825acd883a first commit
sugi
parents:
diff changeset
34 }
cb825acd883a first commit
sugi
parents:
diff changeset
35
cb825acd883a first commit
sugi
parents:
diff changeset
36 public void write(Packer pk, Map<K, V> target, boolean required)
cb825acd883a first commit
sugi
parents:
diff changeset
37 throws IOException {
cb825acd883a first commit
sugi
parents:
diff changeset
38 if (!(target instanceof Map)) {
cb825acd883a first commit
sugi
parents:
diff changeset
39 if (target == null) {
cb825acd883a first commit
sugi
parents:
diff changeset
40 if (required) {
cb825acd883a first commit
sugi
parents:
diff changeset
41 throw new MessageTypeException("Attempted to write null");
cb825acd883a first commit
sugi
parents:
diff changeset
42 }
cb825acd883a first commit
sugi
parents:
diff changeset
43 pk.writeNil();
cb825acd883a first commit
sugi
parents:
diff changeset
44 return;
cb825acd883a first commit
sugi
parents:
diff changeset
45 }
cb825acd883a first commit
sugi
parents:
diff changeset
46 throw new MessageTypeException("Target is not a Map but " + target.getClass());
cb825acd883a first commit
sugi
parents:
diff changeset
47 }
cb825acd883a first commit
sugi
parents:
diff changeset
48 Map<K, V> map = (Map<K, V>) target;
cb825acd883a first commit
sugi
parents:
diff changeset
49 pk.writeMapBegin(map.size());
cb825acd883a first commit
sugi
parents:
diff changeset
50 for (Map.Entry<K, V> pair : map.entrySet()) {
cb825acd883a first commit
sugi
parents:
diff changeset
51 keyTemplate.write(pk, pair.getKey());
cb825acd883a first commit
sugi
parents:
diff changeset
52 valueTemplate.write(pk, pair.getValue());
cb825acd883a first commit
sugi
parents:
diff changeset
53 }
cb825acd883a first commit
sugi
parents:
diff changeset
54 pk.writeMapEnd();
cb825acd883a first commit
sugi
parents:
diff changeset
55 }
cb825acd883a first commit
sugi
parents:
diff changeset
56
cb825acd883a first commit
sugi
parents:
diff changeset
57 public Map<K, V> read(Unpacker u, Map<K, V> to, boolean required)
cb825acd883a first commit
sugi
parents:
diff changeset
58 throws IOException {
cb825acd883a first commit
sugi
parents:
diff changeset
59 if (!required && u.trySkipNil()) {
cb825acd883a first commit
sugi
parents:
diff changeset
60 return null;
cb825acd883a first commit
sugi
parents:
diff changeset
61 }
cb825acd883a first commit
sugi
parents:
diff changeset
62 int n = u.readMapBegin();
cb825acd883a first commit
sugi
parents:
diff changeset
63 Map<K, V> map;
cb825acd883a first commit
sugi
parents:
diff changeset
64 if (to != null) {
cb825acd883a first commit
sugi
parents:
diff changeset
65 map = (Map<K, V>) to;
cb825acd883a first commit
sugi
parents:
diff changeset
66 map.clear();
cb825acd883a first commit
sugi
parents:
diff changeset
67 } else {
cb825acd883a first commit
sugi
parents:
diff changeset
68 map = new HashMap<K, V>(n);
cb825acd883a first commit
sugi
parents:
diff changeset
69 }
cb825acd883a first commit
sugi
parents:
diff changeset
70 for (int i = 0; i < n; i++) {
cb825acd883a first commit
sugi
parents:
diff changeset
71 K key = keyTemplate.read(u, null);
cb825acd883a first commit
sugi
parents:
diff changeset
72 V value = valueTemplate.read(u, null);
cb825acd883a first commit
sugi
parents:
diff changeset
73 map.put(key, value);
cb825acd883a first commit
sugi
parents:
diff changeset
74 }
cb825acd883a first commit
sugi
parents:
diff changeset
75 u.readMapEnd();
cb825acd883a first commit
sugi
parents:
diff changeset
76 return map;
cb825acd883a first commit
sugi
parents:
diff changeset
77 }
cb825acd883a first commit
sugi
parents:
diff changeset
78 }