view src/alice/topology/manager/keeparive/CreateTask.java @ 315:f9ec5bead150

come back response. but has bug
author sugi
date Tue, 10 Dec 2013 12:32:43 +0900
parents f1f0638861ab
children 89dc953fd9e8
line wrap: on
line source

package alice.topology.manager.keeparive;

import java.util.List;

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

public class CreateTask extends CodeSegment{
	private Receiver info = ids.create(CommandType.PEEK);
	
	public CreateTask(){
		info.setKey("_CLIST");
	}
	
	@Override
	public void run() {
		ods.put("_WAITINGLIST", new ListManager());
		@SuppressWarnings("unchecked")
		List<String> list = info.asClass(List.class);
		
		new CheckExistTask();
		SendPing.getInstance().setKey();
		for (String manager : list){
			int i = 5;
			TaskInfo task = new TaskInfo(manager, "_RESPONCE", i * 1000);
			ods.put("_TASKINFO", task);
			i +=5;
		}
		
	}

}