You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@bookkeeper.apache.org by zh...@apache.org on 2017/07/13 09:37:15 UTC
[bookkeeper] branch master updated: ISSUE #239: typo in class name
SpeculativeRequestExecutor (#240)
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 <er...@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" <co...@bookkeeper.apache.org>'].