Mercurial > hg > Database > Christie

changeset 160:3b9be156e280

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
update topologymanager
author akahori
date Mon, 21 Jan 2019 21:40:53 +0900
parents a0391cfdcef6
children 5c5a5da0d13d
files src/main/java/christie/topology/manager/FileParser.java src/main/java/christie/topology/manager/IncomingHosts.java
diffstat 2 files changed, 4 insertions(+), 5 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/christie/topology/manager/FileParser.java	Mon Jan 21 18:02:49 2019 +0900
+++ b/src/main/java/christie/topology/manager/FileParser.java	Mon Jan 21 21:40:53 2019 +0900
@@ -66,12 +66,10 @@
         }
 
         getLocalDGM().put("resultParse", resultParse);
-        getLocalDGM().put("nodeNum", nodeNum);
         getLocalDGM().put("_NODECOUNT", nodeNum);
         getLocalDGM().put("nodeNames", nodeNames);
         getLocalDGM().put("waiterNodeNames", nodeNames.clone());
-
-
+        getLocalDGM().put("_TOTALNODENUM", nodeNum); // use paxos
 
     }
 }
--- a/src/main/java/christie/topology/manager/IncomingHosts.java	Mon Jan 21 18:02:49 2019 +0900
+++ b/src/main/java/christie/topology/manager/IncomingHosts.java	Mon Jan 21 21:40:53 2019 +0900
@@ -24,8 +24,8 @@
     @Take
     String MD5;
 
-    //@Peek
-    //HashMap<String, LinkedList<HostMessage>> topology;
+    @Peek
+    int _TOTALNODENUM;
 
     public IncomingHosts() {
 
@@ -46,6 +46,7 @@
         getLocalDGM().put("absCookieTable", absCookieTable);
 
         getDGM(nodeName).put( "nodeName", nodeName);
+        getDGM(nodeName).put( "_TOTALNODENUM", _TOTALNODENUM);// use paxos
         getDGM(nodeName).put("cookie", MD5);
 
         LinkedList<HostMessage> nodeInfoList = resultParse.get(nodeName);