Mercurial > hg > Database > Alice
diff src/alice/topology/manager/keeparive/TaskExecuter.java @ 331:8266d7cfba7e
add comment
author | sugi |
---|---|
date | Thu, 03 Apr 2014 20:26:23 +0900 |
parents | d35ff0f588e8 |
children | 6b82dae5d537 |
line wrap: on
line diff
--- a/src/alice/topology/manager/keeparive/TaskExecuter.java Mon Mar 31 22:28:52 2014 +0900 +++ b/src/alice/topology/manager/keeparive/TaskExecuter.java Thu Apr 03 20:26:23 2014 +0900 @@ -66,9 +66,7 @@ private synchronized void execTask(){ // ping or close - System.out.println("aaaa"); if (nowTask.getType() == TaskType.PING) { - System.out.println("bbb"); ods.ping(nowTask.getManagerKey(), nowTask.getReturnKey()); TaskInfo task = new TaskInfo(TaskType.CLOSE); task.setInfo(nowTask.getManagerKey(), 10 * 1000); @@ -76,11 +74,7 @@ new RespondPing(nowTask.getReturnKey()); } else if (nowTask.getType() == TaskType.CLOSE) { // no response from the Remote DataSegment. So close this connection. - //DataSegment.get(nowTask.getManagerKey()).close(); - System.out.println("CLOSE"); - - nowTask.show(); - System.exit(0); + DataSegment.get(nowTask.getManagerKey()).close(); } }