Mercurial > hg > Database > Alice
diff src/alice/codesegment/OutputDataSegment.java @ 264:b4690114a0cd
refactor API
author | sugi |
---|---|
date | Tue, 13 Aug 2013 06:02:55 +0900 |
parents | 2ec10cfa8cc3 |
children | 51ccd5480a86 |
line wrap: on
line diff
--- a/src/alice/codesegment/OutputDataSegment.java Tue Aug 06 02:14:40 2013 +0900 +++ b/src/alice/codesegment/OutputDataSegment.java Tue Aug 13 06:02:55 2013 +0900 @@ -1,11 +1,5 @@ package alice.codesegment; -import java.io.IOException; - - -import org.msgpack.type.Value; -import org.msgpack.type.ValueFactory; - import alice.datasegment.DataSegment; import alice.datasegment.Receiver; @@ -17,70 +11,31 @@ public void flip(Receiver receiver) { receiver.managerKey=null; - DataSegment.getLocal().putObject(receiver.key, receiver.getObj()); - } - - public void put(String key, String val) { - DataSegment.getLocal().putObject(key, val); + DataSegment.getLocal().put(receiver.key, receiver.getObj()); } public void put(String key, byte[] val) { - DataSegment.getLocal().putObject(key, val); - } - - public void put(String key, int val) { - DataSegment.getLocal().putObject(key, val); + DataSegment.getLocal().put(key, val); } public <T> void put(String key, T val) { - DataSegment.getLocal().putObject(key, val); - } - - public void update(String key, String val) { - DataSegment.getLocal().updateObject(key, val); + DataSegment.getLocal().put(key, val); } public void update(String key, byte[] val) { - DataSegment.getLocal().updateObject(key, val); - } - - public void update(String key, int val) { - DataSegment.getLocal().updateObject(key, val); + DataSegment.getLocal().update(key, val); } public <T> void update(String key, T val) { - DataSegment.getLocal().updateObject(key, val); + DataSegment.getLocal().update(key, val); } - /** * for remote */ - - public void put(String managerKey, String key, Value val) { - DataSegment.get(managerKey).put(key, val); - } - - public void put(String managerKey, String key, String val) { - if (!managerKey.equals("local")){ - DataSegment.get(managerKey).put(key, ValueFactory.createRawValue(val)); - } else { - put(key, val); - } - - } - public void put(String managerKey, String key, byte[] val) { if (!managerKey.equals("local")){ - DataSegment.get(managerKey).put(key, ValueFactory.createRawValue(val, true)); - } else { - put(key, val); - } - } - - public void put(String managerKey, String key, int val) { - if (!managerKey.equals("local")){ - DataSegment.get(managerKey).put(key, ValueFactory.createIntegerValue(val)); + DataSegment.get(managerKey).put(key,val); } else { put(key, val); } @@ -88,39 +43,15 @@ public <T> void put(String managerKey, String key, T val) { if (!managerKey.equals("local")){ - try { - DataSegment.get(managerKey).put(key, SingletonMessage.getInstance().unconvert(val)); - } catch (IOException e) { - e.printStackTrace(); - } + DataSegment.get(managerKey).put(key, val); } else { put(key, val); } } - public void update(String managerKey, String key, Value val) { - DataSegment.get(managerKey).update(key, val); - } - - public void update(String managerKey, String key, String val) { - if (!managerKey.equals("local")){ - DataSegment.get(managerKey).update(key, ValueFactory.createRawValue(val)); - } else { - update(key, val); - } - } - public void update(String managerKey, String key, byte[] val) { if (!managerKey.equals("local")){ - DataSegment.get(managerKey).update(key, ValueFactory.createRawValue(val, true)); - } else { - update(key, val); - } - } - - public void update(String managerKey, String key, int val) { - if (!managerKey.equals("local")){ - DataSegment.get(managerKey).update(key, ValueFactory.createIntegerValue(val)); + DataSegment.get(managerKey).update(key, val); } else { update(key, val); } @@ -128,11 +59,7 @@ public <T> void update(String managerKey, String key, T val) { if (!managerKey.equals("local")){ - try { - DataSegment.get(managerKey).update(key, SingletonMessage.getInstance().unconvert(val)); - } catch (IOException e) { - e.printStackTrace(); - } + DataSegment.get(managerKey).update(key, val); } else { update(key, val); } @@ -157,9 +84,5 @@ public void close(String managerKey) { DataSegment.get(managerKey).close(); } - - - - - + }