Package co.paralleluniverse.galaxy.cluster

Examples of co.paralleluniverse.galaxy.cluster.NodeInfo

27
28
29
30
31
32
33
34
35
public class ChannelAttachedNodeResolver extends ChannelMessageNodeResolver {
    @Override
    protected short getNodeId(ChannelHandlerContext ctx, SocketAddress address) {
        final Channel channel = ctx.getChannel();
        //final SocketAddress address = channel.getRemoteAddress();
        NodeInfo node = ChannelNodeInfo.nodeInfo.get(channel);
        assert node != null;
        return node.getNodeId();
    }
View Full Code Here
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
        @Override
        public boolean add(Channel channel) {
            if (channel instanceof ServerChannel)
                return super.add(channel);
            else {
                final NodeInfo node = ChannelNodeInfo.nodeInfo.get(channel);
                if (node == null) {
                    LOG.warn("Received connection from an unknown address {}.", channel.getRemoteAddress());
                    throw new RuntimeException("Unknown node for address " + channel.getRemoteAddress());
                }
                final short nodeId = node.getNodeId();
                if (channels.containsKey(nodeId)) {
                    LOG.warn("Received connection from address {} of node {}, but this node is already connected.", channel.getRemoteAddress(), nodeId);
                    throw new RuntimeException("Node " + nodeId + " already connected.");
                }
                final boolean added = super.add(channel);
View Full Code Here
77
78
79
80
81
82
83
84
85
86
87
88
    }

    @Override
    protected void start(boolean master) {
        if (master) {
            final NodeInfo serverInfo = getCluster().getMaster(Comm.SERVER);
            if (serverInfo != null) {
                LOG.info("Came online and server found. Connecting.");
                reconnect(serverInfo.getName());
            }
        }
    }
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
                pipeline.addBefore("nodeNameWriter", "nodeInfoSetter", new SimpleChannelUpstreamHandler() {
                    @Override
                    public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) throws Exception {
                        if (nodeName == null)
                            throw new RuntimeException("nodeName not set!");
                        final NodeInfo ni = cluster.getNodeInfoByName(nodeName);
                        ChannelNodeInfo.nodeInfo.set(ctx.getChannel(), ni);
                        super.channelConnected(ctx, e);
                        pipeline.remove(this);
                    }
                });
View Full Code Here
TOP

Related Classes of co.paralleluniverse.galaxy.cluster.NodeInfo

  • co.paralleluniverse.galaxy.core.CacheTest
  • co.paralleluniverse.galaxy.netty.AbstractTcpClient
  • co.paralleluniverse.galaxy.netty.ChannelAttachedNodeResolver
  • co.paralleluniverse.galaxy.netty.TcpServerClientComm
  • co.paralleluniverse.galaxy.netty.TcpServerServerComm$ChannelGroup
  • co.paralleluniverse.galaxy.netty.TcpSlaveClientComm
  • co.paralleluniverse.galaxy.netty.TcpSlaveServerComm$ChannelGroup
  • co.paralleluniverse.galaxy.netty.UDPCommTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.