Mercurial > hg > Members > tatsuki > Alice
view src/alice/datasegment/Receiver.java @ 195:b4ca7f75e6b2 working
add put , Update API (no convert to value)
author | e095732 |
---|---|
date | Tue, 12 Mar 2013 00:49:19 +0900 |
parents | a85ff8dc16c1 |
children | f151dea22b2c |
line wrap: on
line source
package alice.datasegment; import java.io.IOException; import org.msgpack.type.ArrayValue; import org.msgpack.type.Value; import org.msgpack.type.ValueFactory; import org.msgpack.type.ValueType; import alice.codesegment.InputDataSegment; import alice.codesegment.SingletonMessage; /** * MessagePack implementation and DataSegment Receiver * @author kazz * */ public class Receiver { public InputDataSegment ids; public int index; public Value val; public Object obj; public String from; public CommandType type; public String managerKey; // for debugging public String key; // for debugging public Receiver(InputDataSegment ids, CommandType type) { this.ids = ids; this.type = type; ids.regist(); } // for same key public void flip(Value val){ DataSegment.getLocal().flip(this.key, val); } public void flip(int val){ DataSegment.getLocal().flip(this.key, ValueFactory.createIntegerValue(val)); } public void flip(String val){ DataSegment.getLocal().flip(this.key, ValueFactory.createRawValue(val)); } public void flip(byte[] val){ DataSegment.getLocal().flip(this.key, ValueFactory.createRawValue(val, true)); } public <T> void flip(T val) { DataSegment.getLocal().flip(key, val); } public void setKey(String managerKey, String key) { this.managerKey = managerKey; setKey(managerKey, key, 0); } public void setKey(String managerKey, String key, int index) { this.key = key; switch (type) { case PEEK: ids.peek(this, managerKey, key, index); break; case TAKE: ids.take(this, managerKey, key, index); break; default: break; } ids.setKey(); } public void setKey(String key) { setKey(key, 0); } public void setKey(String key, int index) { this.key = key; switch (type) { case PEEK: ids.peek(this, key, index); break; case TAKE: ids.take(this, key, index); break; default: break; } ids.setKey(); } public String asString() { if (val.getType() == ValueType.RAW) { return val.asRawValue().getString(); } return null; } public int asInteger() { if (val.getType() == ValueType.INTEGER) { return val.asIntegerValue().getInt(); } return 0; } public Float asFloat() { if (val.getType() == ValueType.FLOAT) { return val.asFloatValue().getFloat(); } return 0.0f; } public ArrayValue asArray(){ if (val.getType() == ValueType.ARRAY){ return val.asArrayValue(); } return null; } public <T> T asClass(Class<T> clazz) { try { return SingletonMessage.getInstance().convert(val, clazz); } catch (IOException e) { e.printStackTrace(); } return null; } }