diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-21 00:58:52 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-22 11:25:50 +0200 |
commit | c716e862cbbfc37c8b37cfbdfee9b53d453f6035 (patch) | |
tree | 13e4b29a08d673d6a58133ea4a5b72c1774aa897 /jrt/src/com | |
parent | 6a61110fef80bebfdd7fe7725005a6560974b22d (diff) |
Avoid '*' imports.
Diffstat (limited to 'jrt/src/com')
-rw-r--r-- | jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java | 35 |
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 |