diff options
Diffstat (limited to 'jrt')
| -rw-r--r-- | jrt/src/com/yahoo/jrt/Connection.java | 4 | ||||
| -rw-r--r-- | jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java | 35 |
2 files changed, 22 insertions, 17 deletions
diff --git a/jrt/src/com/yahoo/jrt/Connection.java b/jrt/src/com/yahoo/jrt/Connection.java index d4938f8ecbb..b8ed1b32eda 100644 --- a/jrt/src/com/yahoo/jrt/Connection.java +++ b/jrt/src/com/yahoo/jrt/Connection.java @@ -18,9 +18,9 @@ class Connection extends Target { private static Logger log = Logger.getLogger(Connection.class.getName()); - private static final int READ_SIZE = 8192; + private static final int READ_SIZE = 16384; private static final int READ_REDO = 10; - private static final int WRITE_SIZE = 8192; + private static final int WRITE_SIZE = 16384; private static final int WRITE_REDO = 10; private static final int INITIAL = 0; diff --git a/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java b/jrt/src/com/yahoo/jrt/slobrok/api/Mirror.java index d957f77c6b3..c632191e31d 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; @@ -22,18 +31,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 @@ -47,9 +56,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; @@ -76,9 +83,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 |