view src/alice/topology/manager/keeparive/RespondPing.java @ 320:aafc88985822

Refactor
author one
date Tue, 17 Dec 2013 18:00:42 +0900
parents 32d033a4b3c7
children d746c4486287
line wrap: on
line source

package alice.topology.manager.keeparive;

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

public class RespondPing extends CodeSegment{
	private Receiver respond = ids.create(CommandType.TAKE);
	
	public RespondPing(String key) {
		respond.setKey(key);
	}

	@Override
	public void run() {
		RespondData d = respond.asClass(RespondData.class);
		System.out.print("ping from "+d.from);
		System.out.println(" Recieved time "+d.time);
		TaskInfo task = new TaskInfo(TaskType.PING);
		task.setInfo(d.from, "_RESPONCE", 5 * 1000);
		ods.put("_TASKINFO", task);
		
	}

}