This is an automated email from the ASF dual-hosted git repository. zhaijia pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/bookkeeper.git
The following commit(s) were added to refs/heads/master by this push: new 8aac2ca ISSUE #239: typo in class name SpeculativeRequestExecutor (#240) 8aac2ca is described below commit 8aac2cab6630de6dee5e1ccef7f15a6f41758b5f Author: Edward Ribeiro <eribe...@users.noreply.github.com> AuthorDate: Thu Jul 13 06:37:13 2017 -0300 ISSUE #239: typo in class name SpeculativeRequestExecutor (#240) --- .../bookkeeper/client/DefaultSpeculativeRequestExecutionPolicy.java | 4 ++-- .../src/main/java/org/apache/bookkeeper/client/PendingReadOp.java | 2 +- .../org/apache/bookkeeper/client/ReadLastConfirmedAndEntryOp.java | 2 +- .../apache/bookkeeper/client/SpeculativeRequestExecutionPolicy.java | 2 +- ...peculativeRequestExectuor.java => SpeculativeRequestExecutor.java} | 2 +- 5 files changed, 6 insertions(+), 6 deletions(-) diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DefaultSpeculativeRequestExecutionPolicy.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DefaultSpeculativeRequestExecutionPolicy.java index d0a3672..614f68e 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DefaultSpeculativeRequestExecutionPolicy.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/DefaultSpeculativeRequestExecutionPolicy.java @@ -59,12 +59,12 @@ public class DefaultSpeculativeRequestExecutionPolicy implements SpeculativeRequ * @param requestExecutor The executor is used to issue the actual speculative requests */ @Override - public void initiateSpeculativeRequest(final ScheduledExecutorService scheduler, final SpeculativeRequestExectuor requestExecutor) { + public void initiateSpeculativeRequest(final ScheduledExecutorService scheduler, final SpeculativeRequestExecutor requestExecutor) { scheduleSpeculativeRead(scheduler, requestExecutor, firstSpeculativeRequestTimeout); } private void scheduleSpeculativeRead(final ScheduledExecutorService scheduler, - final SpeculativeRequestExectuor requestExecutor, + final SpeculativeRequestExecutor requestExecutor, final int speculativeRequestTimeout) { try { scheduler.schedule(new Runnable() { diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingReadOp.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingReadOp.java index c820122..3ca70ed 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingReadOp.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/PendingReadOp.java @@ -77,7 +77,7 @@ class PendingReadOp implements Enumeration<LedgerEntry>, ReadEntryCallback { boolean parallelRead = false; final AtomicBoolean complete = new AtomicBoolean(false); - abstract class LedgerEntryRequest extends LedgerEntry implements SpeculativeRequestExectuor { + abstract class LedgerEntryRequest extends LedgerEntry implements SpeculativeRequestExecutor { final AtomicBoolean complete = new AtomicBoolean(false); diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadLastConfirmedAndEntryOp.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadLastConfirmedAndEntryOp.java index 2fab694..d2de714 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadLastConfirmedAndEntryOp.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/ReadLastConfirmedAndEntryOp.java @@ -39,7 +39,7 @@ import org.apache.bookkeeper.util.MathUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -public class ReadLastConfirmedAndEntryOp implements BookkeeperInternalCallbacks.ReadEntryCallback, SpeculativeRequestExectuor { +public class ReadLastConfirmedAndEntryOp implements BookkeeperInternalCallbacks.ReadEntryCallback, SpeculativeRequestExecutor { static final Logger LOG = LoggerFactory.getLogger(ReadLastConfirmedAndEntryOp.class); final private ScheduledExecutorService scheduler; diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutionPolicy.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutionPolicy.java index 4489d41..a55bf6f 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutionPolicy.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutionPolicy.java @@ -30,5 +30,5 @@ public interface SpeculativeRequestExecutionPolicy { * @param scheduler The scheduler service to issue the speculative request * @param requestExectuor The executor is used to issue the actual speculative requests */ - void initiateSpeculativeRequest(ScheduledExecutorService scheduler, SpeculativeRequestExectuor requestExectuor); + void initiateSpeculativeRequest(ScheduledExecutorService scheduler, SpeculativeRequestExecutor requestExectuor); } diff --git a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExectuor.java b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutor.java similarity index 96% rename from bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExectuor.java rename to bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutor.java index 45e1aeb..450cdb3 100644 --- a/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExectuor.java +++ b/bookkeeper-server/src/main/java/org/apache/bookkeeper/client/SpeculativeRequestExecutor.java @@ -22,7 +22,7 @@ package org.apache.bookkeeper.client; import com.google.common.util.concurrent.ListenableFuture; -public interface SpeculativeRequestExectuor { +public interface SpeculativeRequestExecutor { /** * Issues a speculative request and indicates if more speculative -- To stop receiving notification emails like this one, please contact ['"commits@bookkeeper.apache.org" <commits@bookkeeper.apache.org>'].