# HG changeset patch # User sugi # Date 1407797867 -32400 # Node ID a9ed8e932a1e259cbb971d65e9048d11079611fa # Parent 41bb86275910464945097b043b4a6baca3b00fd1 pass reconnect test but have many bug diff -r 41bb86275910 -r a9ed8e932a1e src/main/java/alice/topology/manager/CheckComingHost.java --- 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"); } } diff -r 41bb86275910 -r a9ed8e932a1e src/main/java/alice/topology/manager/ComingServiceHosts.java --- 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 parentInfo = info2.asClass(HashMap.class); + @SuppressWarnings("unchecked") + HashMap 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++) {