Mercurial > hg > Members > tatsuki > Alice

changeset 321:7de56e995f09

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
minor change
author one
date Tue, 17 Dec 2013 18:54:47 +0900
parents aafc88985822
children 4b5bf9cf1505
files src/alice/topology/manager/keeparive/TaskExecuter.java
diffstat 1 files changed, 9 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- 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(){