changeset 436:a9ed8e932a1e dispose

pass reconnect test but have many bug
author sugi
date Tue, 12 Aug 2014 07:57:47 +0900
parents 41bb86275910
children b9fd22d9f6c5
files src/main/java/alice/topology/manager/CheckComingHost.java src/main/java/alice/topology/manager/ComingServiceHosts.java
diffstat 2 files changed, 7 insertions(+), 1 deletions(-) [+]
line wrap: on
line diff
--- a/src/main/java/alice/topology/manager/CheckComingHost.java	Tue Aug 12 07:37:17 2014 +0900
+++ b/src/main/java/alice/topology/manager/CheckComingHost.java	Tue Aug 12 07:57:47 2014 +0900
@@ -27,7 +27,7 @@
             if (absCookieTable.containsKey(host.cookie)){
                 match = true;
                 host.absName = absCookieTable.get(host.cookie);
-                
+                System.out.println("match");
             }
         }
 
--- a/src/main/java/alice/topology/manager/ComingServiceHosts.java	Tue Aug 12 07:37:17 2014 +0900
+++ b/src/main/java/alice/topology/manager/ComingServiceHosts.java	Tue Aug 12 07:57:47 2014 +0900
@@ -16,6 +16,7 @@
     private Receiver info1 = ids.create(CommandType.TAKE);
     private Receiver info2 = ids.create(CommandType.TAKE); // HashMap
     private Receiver info3 = ids.create(CommandType.TAKE); // MD5
+    private Receiver info4 = ids.create(CommandType.TAKE);
 
     private int BINATY_TREE = 2;
 
@@ -24,6 +25,7 @@
         info1.setKey("hostCount");
         info2.setKey("nodeConnectionInfo");
         info3.setKey("MD5");
+        info4.setKey("absCookieTable");
     }
 
     @Override
@@ -34,12 +36,16 @@
         int comingHostCount = info1.asInteger();
         @SuppressWarnings("unchecked")
         HashMap<String, HostMessage> parentInfo = info2.asClass(HashMap.class);
+        @SuppressWarnings("unchecked")
+        HashMap<String, String> absCookieTable = info4.asClass(HashMap.class);
         String nodeName = "node"+comingHostCount;
         // Manager connect to Node
         DataSegment.connect(nodeName, "", host.name, host.port);
         ods.put(nodeName, "host", nodeName);
         ods.put(nodeName, "cookie", cookie);
         
+        absCookieTable.put(cookie, nodeName);
+        ods.put(info4.key, absCookieTable);
         ods.update(info1.key, comingHostCount+1);
         
         for (int i=1;i < BINATY_TREE+1; i++) {