Mercurial > hg > Database > Alice
view 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 |
line wrap: on
line source
package alice.codesegment; import alice.datasegment.DataSegment; import alice.datasegment.Receiver; public class OutputDataSegment { /** * for local */ public void flip(Receiver receiver) { receiver.managerKey=null; DataSegment.getLocal().put(receiver.key, receiver.getObj()); } public void put(String key, Object val) { DataSegment.getLocal().put(key, val); } public void quickPut(String key, Object val) { put(key, val); } public void update(String key, Object val) { DataSegment.getLocal().update(key, val); } public void quickuUpdate(String key, Object val) { update(key, val); } /** * for remote */ public void put(String managerKey, String key, Object val) { if (!managerKey.equals("local")){ DataSegment.get(managerKey).put(key,val); } else { put(key, val); } } public void quickPut(String managerKey, String key, Object val) { if (!managerKey.equals("local")){ DataSegment.get(managerKey).quickPut(key, val); } else { put(key, val); } } public void update(String managerKey, String key, Object val) { if (!managerKey.equals("local")){ DataSegment.get(managerKey).update(key, val); } else { update(key, val); } } public void quickUpdate(String managerKey, String key, Object val) { if (!managerKey.equals("local")){ DataSegment.get(managerKey).update(key, val); } else { update(key, val); } } /** * kill the Alice process after send other messages. * * @param managerKey */ public void finish(String managerKey) { DataSegment.get(managerKey).finish(); } /** * close socket for RemoteDataSegment after send other messages. * * @param managerKey */ public void close(String managerKey) { DataSegment.get(managerKey).close(); } }