summaryrefslogtreecommitdiffstats
path: root/jrt/src/com/yahoo/jrt/slobrok/server/Slobrok.java
diff options
context:
space:
mode:
Diffstat (limited to 'jrt/src/com/yahoo/jrt/slobrok/server/Slobrok.java')
-rw-r--r--jrt/src/com/yahoo/jrt/slobrok/server/Slobrok.java26
1 files changed, 20 insertions, 6 deletions
diff --git a/jrt/src/com/yahoo/jrt/slobrok/server/Slobrok.java b/jrt/src/com/yahoo/jrt/slobrok/server/Slobrok.java
index 6ce8f3d1227..f19779732ba 100644
--- a/jrt/src/com/yahoo/jrt/slobrok/server/Slobrok.java
+++ b/jrt/src/com/yahoo/jrt/slobrok/server/Slobrok.java
@@ -1,7 +1,21 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.jrt.slobrok.server;
-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.MethodHandler;
+import com.yahoo.jrt.Request;
+import com.yahoo.jrt.RequestWaiter;
+import com.yahoo.jrt.Spec;
+import com.yahoo.jrt.StringArray;
+import com.yahoo.jrt.Supervisor;
+import com.yahoo.jrt.Target;
+import com.yahoo.jrt.TargetWatcher;
+import com.yahoo.jrt.Task;
+import com.yahoo.jrt.Transport;
import java.util.ArrayList;
import java.util.HashMap;
@@ -10,11 +24,11 @@ import java.util.Map;
public class Slobrok {
- Supervisor orb;
- Acceptor listener;
+ Supervisor orb;
+ Acceptor listener;
private Map<String,String> services = new HashMap<>();
List<FetchMirror> pendingFetch = new ArrayList<>();
- Map<String,Target> targets = new HashMap<>();
+ Map<String, Target> targets = new HashMap<>();
TargetMonitor monitor = new TargetMonitor();
int gencnt = 1;
@@ -25,7 +39,7 @@ public class Slobrok {
public Slobrok(int port) throws ListenFailedException {
// NB: rpc must be single-threaded
- orb = new Supervisor(new Transport(1));
+ orb = new Supervisor(new Transport("slobrok-" + port, 1));
registerMethods();
try {
listener = orb.listen(new Spec(port));
@@ -241,7 +255,7 @@ public class Slobrok {
private class FetchMirror implements Runnable {
public final Request req;
- public final Task task;
+ public final Task task;
public FetchMirror(Request req, int timeout) {
req.detach();