Mercurial > hg > Database > Alice
annotate src/alice/codesegment/OutputDataSegment.java @ 264:b4690114a0cd
refactor API
author | sugi |
---|---|
date | Tue, 13 Aug 2013 06:02:55 +0900 |
parents | 2ec10cfa8cc3 |
children | 51ccd5480a86 |
rev | line source |
---|---|
11 | 1 package alice.codesegment; |
2 | |
3 import alice.datasegment.DataSegment; | |
209 | 4 import alice.datasegment.Receiver; |
11 | 5 |
6 public class OutputDataSegment { | |
215 | 7 |
185 | 8 /** |
9 * for local | |
10 */ | |
215 | 11 |
12 public void flip(Receiver receiver) { | |
254 | 13 receiver.managerKey=null; |
264 | 14 DataSegment.getLocal().put(receiver.key, receiver.getObj()); |
195 | 15 } |
215 | 16 |
17 public void put(String key, byte[] val) { | |
264 | 18 DataSegment.getLocal().put(key, val); |
183 | 19 } |
215 | 20 |
183 | 21 public <T> void put(String key, T val) { |
264 | 22 DataSegment.getLocal().put(key, val); |
185 | 23 } |
215 | 24 |
185 | 25 public void update(String key, byte[] val) { |
264 | 26 DataSegment.getLocal().update(key, val); |
185 | 27 } |
215 | 28 |
185 | 29 public <T> void update(String key, T val) { |
264 | 30 DataSegment.getLocal().update(key, val); |
185 | 31 } |
215 | 32 |
183 | 33 /** |
34 * for remote | |
185 | 35 */ |
215 | 36 public void put(String managerKey, String key, byte[] val) { |
37 if (!managerKey.equals("local")){ | |
264 | 38 DataSegment.get(managerKey).put(key,val); |
215 | 39 } else { |
40 put(key, val); | |
41 } | |
42 } | |
43 | |
44 public <T> void put(String managerKey, String key, T val) { | |
45 if (!managerKey.equals("local")){ | |
264 | 46 DataSegment.get(managerKey).put(key, val); |
215 | 47 } else { |
48 put(key, val); | |
49 } | |
50 } | |
51 | |
52 public void update(String managerKey, String key, byte[] val) { | |
53 if (!managerKey.equals("local")){ | |
264 | 54 DataSegment.get(managerKey).update(key, val); |
215 | 55 } else { |
56 update(key, val); | |
57 } | |
58 } | |
59 | |
60 public <T> void update(String managerKey, String key, T val) { | |
61 if (!managerKey.equals("local")){ | |
264 | 62 DataSegment.get(managerKey).update(key, val); |
215 | 63 } else { |
64 update(key, val); | |
65 } | |
66 } | |
67 | |
76
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
68 /** |
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
69 * kill the Alice process after send other messages. |
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
70 * |
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
71 * @param managerKey |
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
72 */ |
215 | 73 |
30 | 74 public void finish(String managerKey) { |
75 DataSegment.get(managerKey).finish(); | |
76 } | |
77 | |
76
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
78 /** |
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
79 * close socket for RemoteDataSegment after send other messages. |
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
80 * |
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
81 * @param managerKey |
4a2ecd0a5e8f
refactor test code segments
kazz <kazz@cr.ie.u-ryukyu.ac.jp>
parents:
66
diff
changeset
|
82 */ |
215 | 83 |
41 | 84 public void close(String managerKey) { |
85 DataSegment.get(managerKey).close(); | |
86 } | |
264 | 87 |
11 | 88 } |