diff options
author | Håkon Hallingstad <hakon@yahoo-inc.com> | 2017-02-20 17:13:18 +0100 |
---|---|---|
committer | Håkon Hallingstad <hakon@yahoo-inc.com> | 2017-02-20 17:13:18 +0100 |
commit | d27e86bcd396d64a92d4742083235ee6768dc6b9 (patch) | |
tree | f2daf9230f2575792e58f8abe76aeeeb8f8a0d86 /clustercontroller-core/src/main | |
parent | 24eab4fe4b661526f327fcb32a045dfbc7f3c998 (diff) |
Makes clustercontroller-core work on WiFi
Diffstat (limited to 'clustercontroller-core/src/main')
-rw-r--r-- | clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java | 45 |
1 files changed, 30 insertions, 15 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java index 9619a15de3c..d846bba1ad1 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/rpc/RpcServer.java @@ -1,25 +1,41 @@ // Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.vespa.clustercontroller.core.rpc; -import com.yahoo.jrt.*; +import com.yahoo.jrt.Acceptor; +import com.yahoo.jrt.ErrorCode; +import com.yahoo.jrt.Int32Value; +import com.yahoo.jrt.ListenFailedException; +import com.yahoo.jrt.Method; +import com.yahoo.jrt.Request; +import com.yahoo.jrt.Spec; +import com.yahoo.jrt.StringArray; +import com.yahoo.jrt.StringValue; +import com.yahoo.jrt.Supervisor; +import com.yahoo.jrt.Transport; +import com.yahoo.jrt.slobrok.api.BackOffPolicy; import com.yahoo.jrt.slobrok.api.Register; import com.yahoo.jrt.slobrok.api.SlobrokList; -import com.yahoo.jrt.slobrok.api.BackOffPolicy; import com.yahoo.log.LogLevel; -import com.yahoo.vdslib.state.*; +import com.yahoo.vdslib.state.ClusterState; +import com.yahoo.vdslib.state.Node; +import com.yahoo.vdslib.state.NodeState; +import com.yahoo.vdslib.state.NodeType; +import com.yahoo.vdslib.state.State; +import com.yahoo.vespa.clustercontroller.core.ContentCluster; import com.yahoo.vespa.clustercontroller.core.MasterElectionHandler; import com.yahoo.vespa.clustercontroller.core.NodeInfo; -import com.yahoo.vespa.clustercontroller.core.ContentCluster; +import com.yahoo.vespa.clustercontroller.core.Timer; import com.yahoo.vespa.clustercontroller.core.listeners.NodeAddedOrRemovedListener; import com.yahoo.vespa.clustercontroller.core.listeners.NodeStateOrHostInfoChangeHandler; -import com.yahoo.vespa.clustercontroller.core.Timer; -import java.util.logging.Logger; -import java.util.*; -import java.net.UnknownHostException; -import java.net.InetAddress; -import java.io.StringWriter; import java.io.PrintWriter; +import java.io.StringWriter; +import java.net.UnknownHostException; +import java.util.ArrayList; +import java.util.Iterator; +import java.util.LinkedList; +import java.util.List; +import java.util.logging.Logger; public class RpcServer { @@ -94,13 +110,12 @@ public class RpcServer { slobroks.append(" )"); SlobrokList slist = new SlobrokList(); slist.setup(slobrokConnectionSpecs); - log.log(LogLevel.DEBUG, "Trying to connect to slobrok using local address " + InetAddress.getLocalHost().getHostName() - + ", port " + acceptor.port() + " using slobrok connection spec " + slobroks); + Spec spec = Spec.fromLocalHostName(acceptor.port()); + log.log(LogLevel.INFO, "Connecting to slobrok at " + spec + " using connection spec " + slobroks); if (slobrokBackOffPolicy != null) { - register = new Register(supervisor, slist, - new Spec(InetAddress.getLocalHost().getHostName(), acceptor.port()), slobrokBackOffPolicy); + register = new Register(supervisor, slist, spec, slobrokBackOffPolicy); } else { - register = new Register(supervisor, slist, InetAddress.getLocalHost().getHostName(), acceptor.port()); + register = new Register(supervisor, slist, spec); } register.registerName(getSlobrokName()); } |