Mercurial > hg > Database > Alice
diff src/alice/topology/manager/keeparive/TaskExecuter.java @ 333:cf9072608fe4
no need TYPE SKIP.
author | sugi |
---|---|
date | Mon, 07 Apr 2014 01:37:59 +0900 |
parents | 6b82dae5d537 |
children |
line wrap: on
line diff
--- a/src/alice/topology/manager/keeparive/TaskExecuter.java Sat Apr 05 18:10:16 2014 +0900 +++ b/src/alice/topology/manager/keeparive/TaskExecuter.java Mon Apr 07 01:37:59 2014 +0900 @@ -28,12 +28,7 @@ public synchronized void run() { ListManager list = info.asClass(ListManager.class); if (list.getTaskList().size() == 0){ - if (remainingTime !=0){ - TaskInfo info = new TaskInfo(TaskType.SKIP); - info.setSleepTime(remainingTime); - remainingTime = 0; - list.addTask(info); - } + remainingTime = 0; ods.update("_WAITINGLIST", list); } else { nowTask = list.getTaskList().poll(); @@ -67,6 +62,7 @@ new RespondPing(nowTask.getReturnKey()); } else if (nowTask.getType() == TaskType.CLOSE) { // no response from the Remote DataSegment. So close this connection. + System.out.println("SHOTDOWN"); DataSegment.get(nowTask.getManagerKey()).close(); } }