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

Refactor
author one
date Tue, 17 Dec 2013 18:00:42 +0900
parents 89dc953fd9e8
children 4b5bf9cf1505
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();
		TaskExecuter.getInstance().setKey();
		for (String manager : list){
			int i = 5;
			TaskInfo task = new TaskInfo(TaskType.PING);
			task.setInfo(manager, "_RESPONCE", i * 1000);
			ods.put("_TASKINFO", task);
			i +=5;
		}
		
	}

}