Mercurial > hg > Database > Alice

changeset 504:ece6a109b64c dispose

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
DataSegment.remove API need only call in DeleteConnectoin
author sugi
date Thu, 18 Dec 2014 17:54:42 +0900
parents 79d5b317b2b6
children 63b18091374c
files src/main/java/alice/datasegment/RemoteDataSegmentManager.java src/main/java/alice/topology/manager/keeparive/TaskExecuter.java
diffstat 2 files changed, 1 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/datasegment/RemoteDataSegmentManager.java	Thu Dec 18 17:28:45 2014 +0900
+++ b/src/main/java/alice/datasegment/RemoteDataSegmentManager.java	Thu Dec 18 17:54:42 2014 +0900
@@ -151,8 +151,6 @@
         connection.close();
         LinkedBlockingQueue<Command> queue = connection.sendQueue;
         if (!queue.isEmpty()) queue.clear();
-        if (DataSegment.contains(connection.name))
-            DataSegment.remove(connection.name);
     }
 
     @Override
--- a/src/main/java/alice/topology/manager/keeparive/TaskExecuter.java	Thu Dec 18 17:28:45 2014 +0900
+++ b/src/main/java/alice/topology/manager/keeparive/TaskExecuter.java	Thu Dec 18 17:54:42 2014 +0900
@@ -29,7 +29,7 @@
         ListManager list = info.asClass(ListManager.class);
         if (list.getTaskList().size() == 0){
             TaskInfo task = new TaskInfo(TaskType.CREATE);
-            task.setSleepTime(3000 + remainingTime);
+            task.setSleepTime(3000);
             list.addTask(task);
             ods.update("_WAITINGLIST", list);
             remainingTime = 0;