Name the transport threads to understand how things are interconnected.

4 files changed, 5 insertions, 4 deletions

diff --git a/config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java b/config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java
index 2c1d00f295e..9aeb1c9da0f 100644
--- a/config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java
+++ b/config/src/main/java/com/yahoo/vespa/config/JRTConnectionPool.java
@@ -29,7 +29,7 @@ public class JRTConnectionPool implements ConnectionPool {
 
     private static final Logger log = Logger.getLogger(JRTConnectionPool.class.getName());
 
-    private final Supervisor supervisor = new Supervisor(new Transport());
+    private final Supervisor supervisor;
     private final Map<String, JRTConnection> connections = new LinkedHashMap<>();
 
     // The config sources used by this connection pool.
@@ -39,6 +39,7 @@ public class JRTConnectionPool implements ConnectionPool {
     private volatile JRTConnection currentConnection;
 
     public JRTConnectionPool(ConfigSourceSet sourceSet) {
+        supervisor = new Supervisor(new Transport("config-jrtpool-" + sourceSet.hashCode()));
         addSources(sourceSet);
     }
 
diff --git a/config/src/main/java/com/yahoo/vespa/config/UrlDownloader.java b/config/src/main/java/com/yahoo/vespa/config/UrlDownloader.java
index 2356b400343..5cc03c7deea 100644
--- a/config/src/main/java/com/yahoo/vespa/config/UrlDownloader.java
+++ b/config/src/main/java/com/yahoo/vespa/config/UrlDownloader.java
@@ -28,7 +28,7 @@ public class UrlDownloader {
     public  static final int INTERNAL_ERROR = BASE_ERROR_CODE + 2;
     public  static final int HTTP_ERROR = BASE_ERROR_CODE + 3;
 
-    private final Supervisor supervisor = new Supervisor(new Transport());
+    private final Supervisor supervisor = new Supervisor(new Transport("url-downloader"));
     private final Spec spec;
     private Target target;
 
diff --git a/config/src/main/java/com/yahoo/vespa/config/benchmark/LoadTester.java b/config/src/main/java/com/yahoo/vespa/config/benchmark/LoadTester.java
index f20371d203c..8a0f24bcd48 100644
--- a/config/src/main/java/com/yahoo/vespa/config/benchmark/LoadTester.java
+++ b/config/src/main/java/com/yahoo/vespa/config/benchmark/LoadTester.java
@@ -43,7 +43,7 @@ import java.util.concurrent.ThreadLocalRandom;
 public class LoadTester {
 
     private static boolean debug = false;
-    private Transport transport = new Transport();
+    private Transport transport = new Transport("rpc-client");
     protected Supervisor supervisor = new Supervisor(transport);
     private List<ConfigKey<?>> configs = new ArrayList<>();
     private Map<ConfigDefinitionKey, Tuple2<String, String[]>> defs = new HashMap<>();
diff --git a/config/src/main/java/com/yahoo/vespa/config/benchmark/StressTester.java b/config/src/main/java/com/yahoo/vespa/config/benchmark/StressTester.java
index 0152c0bc3ff..6964e35abf6 100644
--- a/config/src/main/java/com/yahoo/vespa/config/benchmark/StressTester.java
+++ b/config/src/main/java/com/yahoo/vespa/config/benchmark/StressTester.java
@@ -168,7 +168,7 @@ public class StressTester {
     }
 
     public static class RpcServer implements Runnable {
-        private Transport transport = new Transport();
+        private Transport transport = new Transport("rpc-server");
         protected Supervisor supervisor = new Supervisor(transport);
         private final Spec spec;
         private final StressTester tester;