changeset 425:3fff2edc8d33 dispose

remove no need DataSegment
author sugi
date Tue, 22 Jul 2014 12:04:12 +0900
parents faae3e976cc1
children b4a9cf8c00b6
files src/main/java/alice/datasegment/LocalDataSegmentManager.java src/main/java/alice/topology/node/ConfigurationFinish.java src/main/java/alice/topology/node/Start.java
diffstat 3 files changed, 5 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/datasegment/LocalDataSegmentManager.java	Mon Jul 21 21:38:43 2014 +0900
+++ b/src/main/java/alice/datasegment/LocalDataSegmentManager.java	Tue Jul 22 12:04:12 2014 +0900
@@ -45,6 +45,11 @@
         }
 
     }
+    
+    public void deleteDataSegmentKey(String key){
+        if (dataSegments.containsKey(key))
+            dataSegments.remove(key);
+    }
 
     public void submitCommand(DataSegmentKey key, Command cmd) {
         dataSegmentExecutor.execute(new RunCommand(key, cmd));
--- a/src/main/java/alice/topology/node/ConfigurationFinish.java	Mon Jul 21 21:38:43 2014 +0900
+++ b/src/main/java/alice/topology/node/ConfigurationFinish.java	Tue Jul 22 12:04:12 2014 +0900
@@ -22,7 +22,6 @@
 
             ods.put("manager", "done", ValueFactory.createNilValue());
             Start cs = new Start(startCS);
-            cs.runningFlag.setKey("local", "running");
             cs.done.setKey("manager", "start");
             return;
         }
--- a/src/main/java/alice/topology/node/Start.java	Mon Jul 21 21:38:43 2014 +0900
+++ b/src/main/java/alice/topology/node/Start.java	Tue Jul 22 12:04:12 2014 +0900
@@ -9,7 +9,6 @@
 public class Start extends CodeSegment {
 
     public Receiver done = ids.create(CommandType.PEEK);
-    public Receiver runningFlag = ids.create(CommandType.TAKE);
 
     private Logger logger = Logger.getLogger(Start.class);
     private CodeSegment startCS;
@@ -25,7 +24,6 @@
 
         if (startCS == null)
             return;
-        ods.update(runningFlag.key, true);
         startCS.execute();
 
     }