# HG changeset patch # User akahori # Date 1552094343 -32400 # Node ID a0be7c83fff8c44903f0aa4f561fcf485972a222 # Parent 28c26ea5ef86bc54102d43bad36696c0e2674df7 add connectionList diff -r 28c26ea5ef86 -r a0be7c83fff8 src/main/java/christie/topology/node/CreateConnectionList.java --- /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); + } +} diff -r 28c26ea5ef86 -r a0be7c83fff8 src/main/java/christie/topology/node/IncomingConnectionInfo.java --- 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)); }