aboutsummaryrefslogtreecommitdiffstats
path: root/metrics-proxy
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-08-04 18:34:18 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-08-04 18:34:18 +0000
commitaf72753359ee72003d10d92e3c7355a156d3e6d7 (patch)
treedf01de4919739a944082c72a2d805482a625e9e9 /metrics-proxy
parentbd3399a2677b32888ef2588adf1c976ed4cdb5cb (diff)
Name the transport threads to understand how things are interconnected.
Diffstat (limited to 'metrics-proxy')
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java3
-rw-r--r--metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java2
2 files changed, 3 insertions, 2 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java
index c09dc44d3fd..c9d4ad2a5ac 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/rpc/RpcConnector.java
@@ -23,10 +23,11 @@ import static java.util.logging.Level.INFO;
public class RpcConnector extends AbstractComponent {
private static final Logger log = Logger.getLogger(RpcConnector.class.getName());
- private final Supervisor supervisor = new Supervisor(new Transport());
+ private final Supervisor supervisor;
private final Acceptor acceptor;
public RpcConnector(RpcConnectorConfig config) {
+ supervisor = new Supervisor(new Transport("rpc-" + config.port()));
Spec spec = new Spec(config.port());
try {
acceptor = supervisor.listen(spec);
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java
index c0e3e636aa6..1fd444332d6 100644
--- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java
+++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/ConfigSentinelClient.java
@@ -24,7 +24,7 @@ import java.util.logging.Logger;
public class ConfigSentinelClient extends AbstractComponent {
private final static Logger log = Logger.getLogger(ConfigSentinelClient.class.getName());
- private final Supervisor supervisor = new Supervisor(new Transport());
+ private final Supervisor supervisor = new Supervisor(new Transport("sentinel-client"));
@Inject
public ConfigSentinelClient() {