changeset 439:9f6674e503df dispose

change timing putting Connection list
author sugi
date Tue, 23 Sep 2014 16:09:29 +0900
parents c973f7ee7c91
children 2338b1ef29e8
files build.gradle src/main/java/alice/topology/node/IncomingConnectionInfo.java src/main/java/alice/topology/node/StartTopologyNode.java
diffstat 3 files changed, 18 insertions(+), 5 deletions(-) [+]
line wrap: on
line diff
--- a/build.gradle	Wed Aug 20 15:54:20 2014 +0900
+++ b/build.gradle	Tue Sep 23 16:09:29 2014 +0900
@@ -1,9 +1,12 @@
 apply plugin: 'java'
 apply plugin: 'eclipse'
+apply plugin: 'maven'
 
 sourceCompatibility = 1.8
 targetCompatibility = 1.8
 [compileJava, compileTestJava]*.options*.encoding = 'UTF-8'
+
+group = 'cr.ie.u_ryukyu.ac.jp'
 version = '1.0'
 
 dependencies {
@@ -18,3 +21,14 @@
 	archiveName = 'Alice.jar'
 }
 
+ext {
+    mavenRepository = '/Users/YU/workspace/maven'
+}
+
+uploadArchives {
+    repositories {
+        mavenDeployer {
+            repository(url: uri(mavenRepository))
+        }
+    }
+}
--- a/src/main/java/alice/topology/node/IncomingConnectionInfo.java	Wed Aug 20 15:54:20 2014 +0900
+++ b/src/main/java/alice/topology/node/IncomingConnectionInfo.java	Tue Sep 23 16:09:29 2014 +0900
@@ -1,7 +1,5 @@
 package alice.topology.node;
 
-import java.util.ArrayList;
-
 import alice.codesegment.CodeSegment;
 import alice.datasegment.CommandType;
 import alice.datasegment.DataSegment;
@@ -25,9 +23,6 @@
         if (this.hostInfo.getVal() == null) {
             ods.put("local", "configNodeNum", count);
         } else {
-            if (count == 0)
-                ods.put("_CLIST", new ArrayList<String>());
-
             HostMessage hostInfo = this.hostInfo.asClass(HostMessage.class);
             if (DataSegment.contains(hostInfo.connectionName)) {
                 System.out.println("reconnection");
--- a/src/main/java/alice/topology/node/StartTopologyNode.java	Wed Aug 20 15:54:20 2014 +0900
+++ b/src/main/java/alice/topology/node/StartTopologyNode.java	Tue Sep 23 16:09:29 2014 +0900
@@ -2,6 +2,8 @@
 
 import java.net.InetAddress;
 import java.net.UnknownHostException;
+import java.util.ArrayList;
+
 import alice.codesegment.CodeSegment;
 import alice.datasegment.DataSegment;
 import alice.topology.HostMessage;
@@ -31,6 +33,8 @@
         host.cookie = conf.cookie;
         ods.put("manager", "host", host);
 
+        ods.put("_CLIST", new ArrayList<String>());
+        
         IncomingAbstractHostName cs = new IncomingAbstractHostName();
         cs.absName.setKey("local", "host");