annotate src/alice/datasegment/Receiver.java @ 126:669dba7cbb69 working

Use singleton
author sugi
date Fri, 03 Aug 2012 19:14:46 +0900
parents d5d9ca4cbe87
children ed78890ed8e9
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
3
91057e15065f add DataSegment API and CodeSegment
one
parents:
diff changeset
1 package alice.datasegment;
91057e15065f add DataSegment API and CodeSegment
one
parents:
diff changeset
2
34
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
3 import java.io.IOException;
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
4
126
669dba7cbb69 Use singleton
sugi
parents: 122
diff changeset
5 //import org.msgpack.MessagePack;
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
6 import org.msgpack.type.Value;
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
7 import org.msgpack.type.ValueType;
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
8
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
9 import alice.codesegment.InputDataSegment;
126
669dba7cbb69 Use singleton
sugi
parents: 122
diff changeset
10 import alice.codesegment.SingletonMessage;
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
11
57
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
12 /**
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
13 * MessagePack implementation and DataSegment Receiver
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
14 * @author kazz
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
15 *
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
16 */
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
17 public class Receiver {
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
18 public InputDataSegment ids;
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
19 public int index;
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
20 public Value val;
28
98ab26e09a98 Configuration Manager work and implements reverseKey
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 19
diff changeset
21 public String from;
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
22 public CommandType type;
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
23
57
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
24 public String managerKey; // for debugging
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
25 public String key; // for debugging
44
73158dc54c59 fix peek api
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 34
diff changeset
26
126
669dba7cbb69 Use singleton
sugi
parents: 122
diff changeset
27 //private static MessagePack MSGPACK = new MessagePack();
121
bddb8be357f6 fix memory leak
one
parents: 100
diff changeset
28
33
20c67f673224 change name of DataSegmentReceiver
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 30
diff changeset
29 public Receiver(InputDataSegment ids, CommandType type) {
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
30 this.ids = ids;
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
31 this.type = type;
19
e7867328a2fb change execute() API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
32 ids.regist();
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
33 }
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
34
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
35 public void setKey(String managerKey, String key) {
57
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
36 this.managerKey = managerKey;
7fa9ddb31f64 add comment
one
parents: 44
diff changeset
37 this.key = key;
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
38 setKey(managerKey, key, 0);
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
39 }
3
91057e15065f add DataSegment API and CodeSegment
one
parents:
diff changeset
40
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
41 public void setKey(String managerKey, String key, int index) {
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
42 switch (type) {
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
43 case PEEK:
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
44 ids.peek(this, managerKey, key, index);
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
45 break;
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
46 case TAKE:
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
47 ids.take(this, managerKey, key, index);
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
48 break;
100
b01fb5090e28 add default code to each case statements
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 88
diff changeset
49 default:
b01fb5090e28 add default code to each case statements
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 88
diff changeset
50 break;
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
51 }
19
e7867328a2fb change execute() API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 18
diff changeset
52 ids.setKey();
18
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
53 }
72dd27d952b0 change InputDataSegment API
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 3
diff changeset
54
65
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
55 public void setKey(String key) {
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
56 this.key = key;
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
57 setKey(key, 0);
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
58 }
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
59
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
60 public void setKey(String key, int index) {
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
61 switch (type) {
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
62 case PEEK:
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
63 ids.peek(this, key, index);
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
64 break;
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
65 case TAKE:
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
66 ids.take(this, key, index);
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
67 break;
100
b01fb5090e28 add default code to each case statements
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 88
diff changeset
68 default:
b01fb5090e28 add default code to each case statements
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 88
diff changeset
69 break;
65
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
70 }
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
71 ids.setKey();
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
72 }
ca42a2c8ac22 add local access api
kazz
parents: 57
diff changeset
73
30
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
74 public String asString() {
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
75 if (val.getType() == ValueType.RAW) {
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
76 return val.asRawValue().getString();
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
77 }
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
78 return null;
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
79 }
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
80
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
81 public int asInteger() {
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
82 if (val.getType() == ValueType.INTEGER) {
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
83 return val.asIntegerValue().getInt();
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
84 }
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
85 return 0;
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
86 }
b5a21baf0b07 implements RingTopology
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 28
diff changeset
87
88
33a19ca88e43 Singleton is removed .
sugi
parents: 65
diff changeset
88 public Float asFloat() {
33a19ca88e43 Singleton is removed .
sugi
parents: 65
diff changeset
89 if (val.getType() == ValueType.FLOAT) {
33a19ca88e43 Singleton is removed .
sugi
parents: 65
diff changeset
90 return val.asFloatValue().getFloat();
33a19ca88e43 Singleton is removed .
sugi
parents: 65
diff changeset
91 }
33a19ca88e43 Singleton is removed .
sugi
parents: 65
diff changeset
92 return 0.0f;
33a19ca88e43 Singleton is removed .
sugi
parents: 65
diff changeset
93 }
33a19ca88e43 Singleton is removed .
sugi
parents: 65
diff changeset
94
34
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
95 public <T> T asClass(Class<T> clazz) {
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
96 try {
126
669dba7cbb69 Use singleton
sugi
parents: 122
diff changeset
97 return SingletonMessage.getInstance().convert(val, clazz);
34
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
98 } catch (IOException e) {
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
99 e.printStackTrace();
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
100 }
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
101 return null;
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
102 }
ca079a730d0b added method to OutputDataSegment and Receiver, to convert type from Value to Class<?> without MessagePack
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents: 33
diff changeset
103
3
91057e15065f add DataSegment API and CodeSegment
one
parents:
diff changeset
104 }