# HG changeset patch # User sugi # Date 1405998252 -32400 # Node ID 3fff2edc8d335129e54feec86938a20f807da468 # Parent faae3e976cc1230d7d4bcb71d901980bbb2b795c remove no need DataSegment diff -r faae3e976cc1 -r 3fff2edc8d33 src/main/java/alice/datasegment/LocalDataSegmentManager.java --- 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)); diff -r faae3e976cc1 -r 3fff2edc8d33 src/main/java/alice/topology/node/ConfigurationFinish.java --- 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; } diff -r faae3e976cc1 -r 3fff2edc8d33 src/main/java/alice/topology/node/Start.java --- 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(); }