Mercurial > hg > Database > Alice

comparison src/main/java/alice/topology/manager/keeparive/CreateTask.java @ 419:aefbe41fcf12 dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
change tab to space
author sugi
date Tue, 15 Jul 2014 16:00:22 +0900
parents 8f71c3e6f11d
children 27079619f5fd
comparison
equal deleted inserted replaced
418:a269a019f5f8 419:aefbe41fcf12
5 import alice.codesegment.CodeSegment; 5 import alice.codesegment.CodeSegment;
6 import alice.datasegment.CommandType; 6 import alice.datasegment.CommandType;
7 import alice.datasegment.Receiver; 7 import alice.datasegment.Receiver;
8 8
9 public class CreateTask extends CodeSegment{ 9 public class CreateTask extends CodeSegment{
10 private Receiver info = ids.create(CommandType.PEEK); 10 private Receiver info = ids.create(CommandType.PEEK);
11 11
12 public CreateTask(){ 12 public CreateTask(){
13 info.setKey("_CLIST"); 13 info.setKey("_CLIST");
14 } 14 }
15 15
16 @Override 16 @Override
17 public void run(){ 17 public void run(){
18 ods.put("_WAITINGLIST", new ListManager()); 18 ods.put("_WAITINGLIST", new ListManager());
19 @SuppressWarnings("unchecked") 19 @SuppressWarnings("unchecked")
20 List<String> list = info.asClass(List.class); 20 List<String> list = info.asClass(List.class);
21 21
22 new CheckExistTask(); 22 new CheckExistTask();
23 TaskExecuter.getInstance().setKey(); 23 TaskExecuter.getInstance().setKey();
24 for (String manager : list){ 24 for (String manager : list){
25 int i = 5; 25 int i = 5;
26 TaskInfo task = new TaskInfo(TaskType.PING); 26 TaskInfo task = new TaskInfo(TaskType.PING);
27 task.setInfo(manager, "_FORM_"+manager, i * 1000); 27 task.setInfo(manager, "_FORM_"+manager, i * 1000);
28 ods.put("_TASKINFO", task); 28 ods.put("_TASKINFO", task);
29 i +=5; 29 i +=5;
30 } 30 }
31 31
32 } 32 }
33 33
34 } 34 }