You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ja...@apache.org on 2018/03/05 19:07:18 UTC
[geode] branch develop updated: GEODE-4759: Fix typo of
getFunctionExcecutor (#1533)
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 <hu...@gmail.com>
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
jasonhuynh@apache.org.