# HG changeset patch # User one # Date 1387277189 -32400 # Node ID 4b5bf9cf15058723f7394dd4613e68db2efe2191 # Parent 7de56e995f09b6d301c627bd85f922eee5d7bdb5 minor change diff -r 7de56e995f09 -r 4b5bf9cf1505 src/alice/topology/manager/keeparive/CreateTask.java --- a/src/alice/topology/manager/keeparive/CreateTask.java Tue Dec 17 18:54:47 2013 +0900 +++ b/src/alice/topology/manager/keeparive/CreateTask.java Tue Dec 17 19:46:29 2013 +0900 @@ -14,7 +14,7 @@ } @Override - public void run() { + public void run(){ ods.put("_WAITINGLIST", new ListManager()); @SuppressWarnings("unchecked") List list = info.asClass(List.class); diff -r 7de56e995f09 -r 4b5bf9cf1505 src/alice/topology/manager/keeparive/TaskExecuter.java --- a/src/alice/topology/manager/keeparive/TaskExecuter.java Tue Dec 17 18:54:47 2013 +0900 +++ b/src/alice/topology/manager/keeparive/TaskExecuter.java Tue Dec 17 19:46:29 2013 +0900 @@ -13,7 +13,7 @@ private static TaskExecuter instance = new TaskExecuter(); private TaskExecuter(){} - public static TaskExecuter getInstance() { + public static TaskExecuter getInstance(){ return instance; } @@ -23,7 +23,7 @@ } @Override - public synchronized void run() { + public synchronized void run(){ ListManager list = info.asClass(ListManager.class); if (list.getTaskList().size() == 0){ ods.update("_WAITINGLIST", list); @@ -36,13 +36,16 @@ if (nowTask.getSleepTime()!=0){ try { this.wait(nowTask.getSleepTime()); - } catch (InterruptedException e) {} + } catch (InterruptedException e){} } if (interruptFlag){ interruptFlag = false; } else { - if (nowTask.getType() == TaskType.PING) { + if (nowTask.getType() == TaskType.PING){ ods.ping(nowTask.getManagerKey(), nowTask.getReturnKey()); + TaskInfo task = new TaskInfo(TaskType.CLOSE); + task.setInfo(nowTask.getManagerKey(), 60 * 1000); + ods.put("_TASKINFO", task); new RespondPing(nowTask.getReturnKey()); } else { DataSegment.get(nowTask.getManagerKey()).close(); @@ -57,7 +60,7 @@ notify(); } - public TaskInfo getNowTask() { + public TaskInfo getNowTask(){ return nowTask; } diff -r 7de56e995f09 -r 4b5bf9cf1505 src/alice/topology/manager/keeparive/TaskInfo.java --- a/src/alice/topology/manager/keeparive/TaskInfo.java Tue Dec 17 18:54:47 2013 +0900 +++ b/src/alice/topology/manager/keeparive/TaskInfo.java Tue Dec 17 19:46:29 2013 +0900 @@ -10,13 +10,18 @@ type = t; } + public void setInfo(String managerKey, long time){ + this.managerKey = managerKey; + sleepTime = time; + } + public void setInfo(String managerKey, String returnKey, long time){ this.managerKey = managerKey; this.returnKey = returnKey; sleepTime = time; } - public TaskType getType() { + public TaskType getType(){ return type; } @@ -28,11 +33,11 @@ sleepTime = time; } - public String getManagerKey() { + public String getManagerKey(){ return managerKey; } - public String getReturnKey() { + public String getReturnKey(){ return returnKey; } }