This is an automated email from the ASF dual-hosted git repository.
jasonhuynh pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/develop by this push:
new c64b34829 GEODE-4759: Fix typo of getFunctionExcecutor (#1533)
c64b34829 is described below
commit c64b348292ae7553fd7e779293cd710859122302
Author: Jason Huynh <[email protected]>
AuthorDate: Mon Mar 5 11:07:15 2018 -0800
GEODE-4759: Fix typo of getFunctionExcecutor (#1533)
---
.../apache/geode/distributed/internal/ClusterDistributionManager.java | 4 ++--
.../org/apache/geode/distributed/internal/DistributionManager.java | 2 +-
.../apache/geode/distributed/internal/LonerDistributionManager.java | 2 +-
.../org/apache/geode/internal/cache/execute/AbstractExecution.java | 4 ++--
.../geode/internal/cache/tier/sockets/command/ExecuteFunction66.java | 2 +-
5 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
b/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
index 9b9089c..f190e72 100644
---
a/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
+++
b/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
@@ -3128,7 +3128,7 @@ public class ClusterDistributionManager implements
DistributionManager {
case PARTITIONED_REGION_EXECUTOR:
return getPartitionedRegionExcecutor();
case REGION_FUNCTION_EXECUTION_EXECUTOR:
- return getFunctionExcecutor();
+ return getFunctionExecutor();
default:
throw new
InternalGemFireError(LocalizedStrings.DistributionManager_UNKNOWN_PROCESSOR_TYPE
.toLocalizedString(processorType));
@@ -3526,7 +3526,7 @@ public class ClusterDistributionManager implements
DistributionManager {
@Override
- public Executor getFunctionExcecutor() {
+ public Executor getFunctionExecutor() {
if (this.functionExecutionThread != null) {
return this.functionExecutionThread;
} else {
diff --git
a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
index d05d248..6290a9b 100644
---
a/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
+++
b/geode-core/src/main/java/org/apache/geode/distributed/internal/DistributionManager.java
@@ -264,7 +264,7 @@ public interface DistributionManager extends ReplySender {
/**
* Return the executor used for function processing
*/
- Executor getFunctionExcecutor();
+ Executor getFunctionExecutor();
/**
* gets this distribution manager's message-processing executor for ordered
(i.e. serialized)
diff --git
a/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
b/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
index c5b2f41..6d1bbe4 100644
---
a/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
+++
b/geode-core/src/main/java/org/apache/geode/distributed/internal/LonerDistributionManager.java
@@ -293,7 +293,7 @@ public class LonerDistributionManager implements
DistributionManager {
}
@Override
- public Executor getFunctionExcecutor() {
+ public Executor getFunctionExecutor() {
return executor;
}
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/AbstractExecution.java
b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/AbstractExecution.java
index 41ab8eb..3db0475 100755
---
a/geode-core/src/main/java/org/apache/geode/internal/cache/execute/AbstractExecution.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/cache/execute/AbstractExecution.java
@@ -269,7 +269,7 @@ public abstract class AbstractExecution implements
InternalExecution {
} else {
final ClusterDistributionManager newDM = (ClusterDistributionManager)
dm;
- newDM.getFunctionExcecutor().execute(new Runnable() {
+ newDM.getFunctionExecutor().execute(new Runnable() {
public void run() {
executeFunctionLocally(fn, cx, sender, newDM);
if (!sender.isLastResultReceived() && fn.hasResult()) {
@@ -297,7 +297,7 @@ public abstract class AbstractExecution implements
InternalExecution {
final ResultSender sender, DistributionManager dm, final boolean isTx) {
if (dm instanceof ClusterDistributionManager && !isTx) {
final ClusterDistributionManager newDM = (ClusterDistributionManager) dm;
- newDM.getFunctionExcecutor().execute(new Runnable() {
+ newDM.getFunctionExecutor().execute(new Runnable() {
public void run() {
executeFunctionLocally(fn, cx, sender, newDM);
if (!((InternalResultSender) sender).isLastResultReceived() &&
fn.hasResult()) {
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java
b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java
index bd10268..16a487d 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/cache/tier/sockets/command/ExecuteFunction66.java
@@ -397,7 +397,7 @@ public class ExecuteFunction66 extends BaseCommand {
execService.execute(functionExecution);
} else {
final ClusterDistributionManager newDM = (ClusterDistributionManager)
dm;
- newDM.getFunctionExcecutor().execute(functionExecution);
+ newDM.getFunctionExecutor().execute(functionExecution);
}
}
stats.endFunctionExecution(startExecution, fn.hasResult());
--
To stop receiving notification emails like this one, please contact
[email protected].
