changeset 195:a0be7c83fff8

add connectionList
author akahori
date Sat, 09 Mar 2019 10:19:03 +0900
parents 28c26ea5ef86
children ad49723367c2
files src/main/java/christie/topology/node/CreateConnectionList.java src/main/java/christie/topology/node/IncomingConnectionInfo.java
diffstat 2 files changed, 24 insertions(+), 2 deletions(-) [+]
line wrap: on
line diff
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/main/java/christie/topology/node/CreateConnectionList.java	Sat Mar 09 10:19:03 2019 +0900
@@ -0,0 +1,21 @@
+package christie.topology.node;
+
+
+import christie.annotation.Take;
+import christie.codegear.CodeGear;
+import christie.codegear.CodeGearManager;
+import christie.topology.TopologyDataGear;
+
+class CreateConnectionList extends CodeGear {
+    @Take
+    String cMember;
+
+    @Take
+    TopologyDataGear topoDG;
+
+    @Override
+    protected void run(CodeGearManager cgm) {
+        topoDG.addConnection(cMember);
+        getLocalDGM().put("topoDG", topoDG);
+    }
+}
--- a/src/main/java/christie/topology/node/IncomingConnectionInfo.java	Wed Mar 06 21:40:10 2019 +0900
+++ b/src/main/java/christie/topology/node/IncomingConnectionInfo.java	Sat Mar 09 10:19:03 2019 +0900
@@ -43,9 +43,10 @@
                     remoteNodeInfo.getHostName(),
                     remoteNodeInfo.getPort());
 
-        topoDG.addConnection(connectionName);
-        getLocalDGM().put("topoDG", topoDG);
+
         getDGM(connectionName).put("_CONNECTIONMESSAGE",new Message());
+        cgm.setup(new CreateConnectionList());
+        getLocalDGM().put("cMember", connectionName);
 
         cgm.setup(new IncomingConnectionInfo(count + 1));
     }