view src/main/java/alice/topology/node/IncomingReverseKey.java @ 639:8d9f35701fdb

fix RecordTopology
author suruga
date Sat, 30 Dec 2017 20:25:19 +0900
parents 145c425db88d
children 0832af83583f 767d93626b88 3284428f525e e321c5ec9b58
line wrap: on
line source

package alice.topology.node;

import alice.codesegment.CodeSegment;
import alice.datasegment.CommandType;
import alice.datasegment.DataSegment;
import alice.datasegment.Receiver;

public class IncomingReverseKey extends CodeSegment {

    public Receiver reverseKey = ids.create(CommandType.TAKE);
    public Receiver reverseCount = ids.create(CommandType.PEEK);

    @Override
    public void run() {
        String reverseKey = this.reverseKey.asString();
        String from = this.reverseKey.from;
        DataSegment.getAccept(from).setReverseKey(reverseKey);

        int reverseCount = this.reverseCount.asInteger();
        reverseCount++;
        ods.update("local", "reverseCount", reverseCount);

        IncomingReverseKey cs = new IncomingReverseKey();
        cs.reverseKey.setKey("local", "reverseKey");
        cs.reverseCount.setKey("local", "reverseCount");
    }

}