Mercurial > hg > Database > Christie
diff src/main/java/christie/topology/manager/keepalive/CreateTask.java @ 49:fd944876257b
add node and keepalive
author | akahori |
---|---|
date | Thu, 23 Aug 2018 09:29:05 +0900 |
parents | |
children | 2c22b23fa725 |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/src/main/java/christie/topology/manager/keepalive/CreateTask.java Thu Aug 23 09:29:05 2018 +0900 @@ -0,0 +1,32 @@ +package christie.topology.manager.keepalive; + +import christie.annotation.Peek; +import christie.codegear.CodeGear; +import christie.codegear.CodeGearManager; + +import java.util.List; + +public class CreateTask extends CodeGear{ + @Peek + List<String> _CLIST; + @Peek + ListManager _SCHEDULER; + + public static int INTERVAL = 5; + + public CreateTask(){ + } + + @Override + protected void run(CodeGearManager cgm){ + int i = INTERVAL; + for (String manager : _CLIST){ + TaskInfo task = new TaskInfo(TaskType.PING); + task.setInfo(manager, "_FORM_"+manager, i * 1000); + _SCHEDULER.addTask(task); + i +=INTERVAL; + } + getLocalDGM().put("_SCHEDULER", _SCHEDULER); + + } +}