Mercurial > hg > Database > Christie
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)); }