summaryrefslogtreecommitdiffstats
path: root/jrt
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-21 00:58:52 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-22 11:25:50 +0200
commitc716e862cbbfc37c8b37cfbdfee9b53d453f6035 (patch)
tree13e4b29a08d673d6a58133ea4a5b72c1774aa897 /jrt
parent6a61110fef80bebfdd7fe7725005a6560974b22d (diff)
Avoid '*' imports.
Diffstat (limited to 'jrt')
-rw-r--r--jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java35
1 files changed, 20 insertions, 15 deletions
diff --git a/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java b/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java
index e131ad1b143..127aa3d0d4f 100644
--- a/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java
+++ b/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java
@@ -1,7 +1,16 @@
// 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.api;
-import com.yahoo.jrt.*;
+
+import com.yahoo.jrt.ErrorCode;
+import com.yahoo.jrt.Int32Value;
+import com.yahoo.jrt.Request;
+import com.yahoo.jrt.RequestWaiter;
+import com.yahoo.jrt.Spec;
+import com.yahoo.jrt.Supervisor;
+import com.yahoo.jrt.Target;
+import com.yahoo.jrt.Task;
+import com.yahoo.jrt.Values;
import java.util.ArrayList;
import java.util.HashMap;
@@ -21,18 +30,18 @@ public class Mirror implements IMirror {
private static Logger log = Logger.getLogger(Mirror.class.getName());
- private Supervisor orb;
- private SlobrokList slobroks;
+ private final Supervisor orb;
+ private final SlobrokList slobroks;
private String currSlobrok;
- private BackOffPolicy backOff;
+ private final BackOffPolicy backOff;
private volatile int updates = 0;
private boolean requestDone = false;
- private volatile Entry[] specs = new Entry[0];
+ private volatile Entry[] specs = new Entry[0];
private int specsGeneration = 0;
- private Task updateTask = null;
- private RequestWaiter reqWait = null;
- private Target target = null;
- private Request req = null;
+ private final Task updateTask;
+ private final RequestWaiter reqWait;
+ private Target target = null;
+ private Request req = null;
/**
* Create a new MirrorAPI using the given Supervisor and slobrok
@@ -46,9 +55,7 @@ public class Mirror implements IMirror {
this.orb = orb;
this.slobroks = slobroks;
this.backOff = bop;
- updateTask = orb.transport().createTask(new Runnable() {
- public void run() { checkForUpdate(); }
- });
+ updateTask = orb.transport().createTask(this::checkForUpdate);
reqWait = new RequestWaiter() {
public void handleRequestDone(Request req) {
requestDone = true;
@@ -75,9 +82,7 @@ public class Mirror implements IMirror {
*/
public void shutdown() {
updateTask.kill();
- orb.transport().perform(new Runnable() {
- public void run() { handleShutdown(); }
- });
+ orb.transport().perform(this::handleShutdown);
}
@Override