Mercurial > hg > Database > Alice

comparison src/alice/codesegment/OutputDataSegment.java @ 34:ca079a730d0b

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Thu, 19 Jan 2012 16:01:50 +0900
parents b5a21baf0b07
children 3155337e754e
comparison
equal deleted inserted replaced
33:20c67f673224 34:ca079a730d0b
1 package alice.codesegment; 1 package alice.codesegment;
2 2
3 import java.io.IOException;
4
5 import org.msgpack.MessagePack;
3 import org.msgpack.type.Value; 6 import org.msgpack.type.Value;
4 import org.msgpack.type.ValueFactory; 7 import org.msgpack.type.ValueFactory;
5 8
6 import alice.datasegment.DataSegment; 9 import alice.datasegment.DataSegment;
7 10
29 32
30 public void update(String managerKey, String key, int val) { 33 public void update(String managerKey, String key, int val) {
31 DataSegment.get(managerKey).update(key, ValueFactory.createIntegerValue(val)); 34 DataSegment.get(managerKey).update(key, ValueFactory.createIntegerValue(val));
32 } 35 }
33 36
37 public <T> void put(String managerKey, String key, T val) {
38 MessagePack msgpack = new MessagePack();
39 try {
40 DataSegment.get(managerKey).put(key, msgpack.unconvert(val));
41 } catch (IOException e) {
42 e.printStackTrace();
43 }
44 }
45
46 public <T> void update(String managerKey, String key, T val) {
47 MessagePack msgpack = new MessagePack();
48 try {
49 DataSegment.get(managerKey).update(key, msgpack.unconvert(val));
50 } catch (IOException e) {
51 e.printStackTrace();
52 }
53 }
54
34 public void finish(String managerKey) { 55 public void finish(String managerKey) {
35 DataSegment.get(managerKey).finish(); 56 DataSegment.get(managerKey).finish();
36 } 57 }
37 58
38 59