view src/main/java/christie/topology/node/TopologyNode.java @ 77:c73f4ff18cfc

refactor TopologyNode
author akahori
date Wed, 05 Sep 2018 10:26:10 +0900 (2018-09-05)
parents 36c5c050394d
children 33afa0fa8bc5
line wrap: on
line source
package christie.topology.node;

import christie.annotation.Peek;
import christie.codegear.CodeGear;
import christie.codegear.CodeGearManager;
import christie.topology.HostMessage;
import christie.topology.manager.IncomingHosts;

import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.ArrayList;

public class TopologyNode extends CodeGear{

    @Peek
    TopologyNodeConfig topologyNodeConfig;

    public TopologyNode() {
    }

    @Override
    protected void run(CodeGearManager cgm) {

        cgm.createRemoteDGM(topologyNodeConfig.getManagerKey(),
                            topologyNodeConfig.getManagerHostName(),
                            topologyNodeConfig.getManagerPort());


        String localHostName = null;
        try {
            localHostName = InetAddress.getLocalHost().getHostAddress();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        }

        HostMessage host = new HostMessage(localHostName, cgm.localPort);
        host.cookie = topologyNodeConfig.cookie;

        getDGM(topologyNodeConfig.getManagerKey()).put("hostMessage", host);

        getLocalDGM().put("_CLIST", new ArrayList<String>());
        getLocalDGM().put("reverseCount", 0);

        cgm.setup(new SaveCookie());
        cgm.setup(new IncomingConnectionInfo());
        cgm.setup(new IncomingReverseKey());
        cgm.setup(new ConfigurationFinish());

    }
}