Mercurial > hg > Database > Alice
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");