Mercurial > hg > Database > Alice

comparison src/main/java/alice/codesegment/OutputDataSegment.java @ 345:8f71c3e6f11d

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Change directory structure Maven standard
author sugi
date Wed, 16 Apr 2014 18:26:07 +0900
parents
children 388e7d4b0624
comparison
equal deleted inserted replaced
344:9f97ec18f8c5 345:8f71c3e6f11d
1 package alice.codesegment;
2
3 import alice.datasegment.DataSegment;
4 import alice.datasegment.Receiver;
5
6 public class OutputDataSegment {
7
8 /**
9 * for local
10 */
11
12 public void flip(Receiver receiver) {
13 receiver.managerKey=null;
14 DataSegment.getLocal().put(receiver.key, receiver.getObj());
15 }
16
17 public void put(String key, Object val) {
18 DataSegment.getLocal().put(key, val);
19 }
20
21 public void quickPut(String key, Object val) {
22 put(key, val);
23 }
24
25 public void update(String key, Object val) {
26 DataSegment.getLocal().update(key, val);
27 }
28
29 public void quickuUpdate(String key, Object val) {
30 update(key, val);
31 }
32
33 /**
34 * for remote
35 */
36 public void put(String managerKey, String key, Object val) {
37 if (!managerKey.equals("local")){
38 DataSegment.get(managerKey).put(key,val);
39 } else {
40 put(key, val);
41 }
42 }
43
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) {
61 if (!managerKey.equals("local")){
62 DataSegment.get(managerKey).update(key, val);
63 } else {
64 update(key, val);
65 }
66 }
67
68 /**
69 * kill the Alice process after send other messages.
70 *
71 * @param managerKey
72 */
73
74 public void finish(String managerKey) {
75 DataSegment.get(managerKey).finish();
76 }
77
78 /**
79 * close socket for RemoteDataSegment after send other messages.
80 *
81 * @param managerKey
82 */
83
84 public void close(String managerKey) {
85 DataSegment.get(managerKey).close();
86 }
87
88 /**
89 * "key" is not remote DataSegment's key.
90 * "Ping Response" return in this "key"
91 *
92 * @param managerKey
93 * @param key
94 */
95 public void ping(String managerKey, String returnKey) {
96 DataSegment.get(managerKey).ping(returnKey);
97 }
98
99 }