Mercurial > hg > Database > Alice
annotate src/alice/codesegment/OutputDataSegment.java @ 297:f51ea581b0ff
add quick method
| author | sugi |
|---|---|
| date | Tue, 22 Oct 2013 17:09:04 +0900 |
| parents | 51ccd5480a86 |
| children | a8255a831ade |
| 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 |
| 297 | 17 public void put(String key, Object val) { |
| 264 | 18 DataSegment.getLocal().put(key, val); |
| 185 | 19 } |
| 215 | 20 |
| 297 | 21 public void quickPut(String key, Object val) { |
| 22 put(key, val); | |
| 23 } | |
| 24 | |
| 25 public void update(String key, Object val) { | |
| 264 | 26 DataSegment.getLocal().update(key, val); |
| 185 | 27 } |
| 215 | 28 |
| 297 | 29 public void quickuUpdate(String key, Object val) { |
| 30 update(key, val); | |
| 31 } | |
| 32 | |
| 183 | 33 /** |
| 34 * for remote | |
| 185 | 35 */ |
| 297 | 36 public void put(String managerKey, String key, Object val) { |
| 215 | 37 if (!managerKey.equals("local")){ |
| 297 | 38 DataSegment.get(managerKey).put(key,val); |
| 215 | 39 } else { |
| 40 put(key, val); | |
| 41 } | |
| 42 } | |
| 43 | |
| 297 | 44 public void quickPut(String managerKey, String key, Object val) { |
| 45 if (!managerKey.equals("local")){ | |
| 46 DataSegment.get(managerKey).quickPut(key, val); | |
| 47 } else { | |
| 48 put(key, val); | |
| 49 } | |
| 50 } | |
| 51 | |
| 52 public void update(String managerKey, String key, Object val) { | |
| 53 if (!managerKey.equals("local")){ | |
| 54 DataSegment.get(managerKey).update(key, val); | |
| 55 } else { | |
| 56 update(key, val); | |
| 57 } | |
| 58 } | |
| 59 | |
| 60 public void quickUpdate(String managerKey, String key, Object val) { | |
| 215 | 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 } | |
| 297 | 87 |
| 11 | 88 } |