# HG changeset patch # User one # Date 1387274087 -32400 # Node ID 7de56e995f09b6d301c627bd85f922eee5d7bdb5 # Parent aafc88985822b7d70162f3c6f8d4d2d438a5a3e5 minor change diff -r aafc88985822 -r 7de56e995f09 src/alice/topology/manager/keeparive/TaskExecuter.java --- a/src/alice/topology/manager/keeparive/TaskExecuter.java Tue Dec 17 18:00:42 2013 +0900 +++ b/src/alice/topology/manager/keeparive/TaskExecuter.java Tue Dec 17 18:54:47 2013 +0900 @@ -2,6 +2,7 @@ import alice.codesegment.CodeSegment; import alice.datasegment.CommandType; +import alice.datasegment.DataSegment; import alice.datasegment.Receiver; public class TaskExecuter extends CodeSegment{ @@ -40,9 +41,15 @@ if (interruptFlag){ interruptFlag = false; } else { - ods.ping(nowTask.getManagerKey(), nowTask.getReturnKey()); - new RespondPing(nowTask.getReturnKey()); + if (nowTask.getType() == TaskType.PING) { + ods.ping(nowTask.getManagerKey(), nowTask.getReturnKey()); + new RespondPing(nowTask.getReturnKey()); + } else { + DataSegment.get(nowTask.getManagerKey()).close(); + } + } + nowTask = null; setKey(); } public synchronized void interrupt(){