view src/alice/topology/node/IncomingReverseKey.java @ 33:20c67f673224

change name of DataSegmentReceiver
author kazz <kazz@cr.ie.u-ryukyu.ac.jp>
date Wed, 18 Jan 2012 01:34:23 +0900
parents 2bfb796b0fa1
children ca079a730d0b
line wrap: on
line source

package alice.topology.node;

import org.msgpack.type.ValueFactory;

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.val.asRawValue().getString();
		String from = this.reverseKey.from;
		DataSegment.getAccept(from).reverseKey = reverseKey;
		
		int reverseCount = this.reverseCount.val.asIntegerValue().getInt();
		reverseCount++;
		ods.update("local", "reverseCount", ValueFactory.createIntegerValue(reverseCount));
		
		
		IncomingReverseKey cs = new IncomingReverseKey();
		cs.reverseKey.setKey("local", "reverseKey");
		cs.reverseCount.setKey("local", "reverseCount");
	}

}