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 <[email protected]>
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
['"[email protected]" <[email protected]>'].
