Mercurial > hg > Database > Alice

comparison src/main/java/alice/topology/manager/keeparive/CreateTask.java @ 498:e5d2141af6c2 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
keep alive Scheduler has bug
author sugi
date Mon, 15 Dec 2014 19:16:20 +0900
parents 27079619f5fd
children d3442b23e3df
comparison
equal deleted inserted replaced
497:5adb0f530e3d 498:e5d2141af6c2
15 @Override 15 @Override
16 public void run(){ 16 public void run(){
17 @SuppressWarnings("unchecked") 17 @SuppressWarnings("unchecked")
18 List<String> list = info.asClass(List.class); 18 List<String> list = info.asClass(List.class);
19 19
20 if (list.size()==0) { 20 int i = 5;
21 TaskInfo task = new TaskInfo(TaskType.CREATE); 21 for (String manager : list){
22 task.setSleepTime(3000); 22 TaskInfo task = new TaskInfo(TaskType.PING);
23 task.setInfo(manager, "_FORM_"+manager, i * 1000);
23 ods.put("_TASKINFO", task); 24 ods.put("_TASKINFO", task);
24 } else { 25 i +=5;
25 for (String manager : list){ 26 }
26 int i = 5;
27 TaskInfo task = new TaskInfo(TaskType.PING);
28 task.setInfo(manager, "_FORM_"+manager, i * 1000);
29 ods.put("_TASKINFO", task);
30 i +=5;
31 }
32 27
33 TaskInfo task = new TaskInfo(TaskType.CREATE); 28 TaskInfo task = new TaskInfo(TaskType.CREATE);
34 task.setSleepTime(10 * 1000); 29 task.setSleepTime((i + 15) * 1000);
35 ods.put("_TASKINFO", task); 30 ods.put("_TASKINFO", task);
36 } 31
37 } 32 }
38 } 33 }