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 2017/05/22 21:34:56 UTC
geode git commit: Revert "GEODE-269: Removing deprecated API's from
FunctionService."
Repository: geode
Updated Branches:
refs/heads/develop 7da9047a2 -> b47450667
Revert "GEODE-269: Removing deprecated API's from FunctionService."
This reverts commit 7da9047a21f6b677066a107c5d378540b5e8b3fd.
Reverting pull request completely, will wait for a new pull request without conflict
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/b4745066
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/b4745066
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/b4745066
Branch: refs/heads/develop
Commit: b47450667cc608c711e94cfd84f44aef5193345a
Parents: 7da9047
Author: Jason Huynh <hu...@gmail.com>
Authored: Mon May 22 14:34:28 2017 -0700
Committer: Jason Huynh <hu...@gmail.com>
Committed: Mon May 22 14:34:28 2017 -0700
----------------------------------------------------------------------
.../catalina/PeerToPeerSessionCache.java | 2 +-
.../modules/util/BootstrappingFunction.java | 2 +-
.../geode/cache/execute/FunctionService.java | 49 ++++++++++++++++++++
.../management/MemoryThresholdsDUnitTest.java | 32 ++++++-------
.../ClassPathLoaderIntegrationTest.java | 6 ++-
.../geode/internal/cache/CommitFunction.java | 3 +-
.../cache/RemoteTransactionDUnitTest.java | 12 ++---
.../geode/internal/cache/RollbackFunction.java | 3 +-
.../execute/FunctionServiceStatsDUnitTest.java | 2 +-
.../LocalFunctionExecutionDUnitTest.java | 4 +-
.../MemberFunctionExecutionDUnitTest.java | 33 ++++++-------
.../DeployCommandRedeployDUnitTest.java | 3 +-
.../cli/commands/ShowDeadlockDUnitTest.java | 2 +-
13 files changed, 104 insertions(+), 49 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/PeerToPeerSessionCache.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/PeerToPeerSessionCache.java b/extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/PeerToPeerSessionCache.java
index f1afca3..69d6ec0 100644
--- a/extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/PeerToPeerSessionCache.java
+++ b/extensions/geode-modules/src/main/java/org/apache/geode/modules/session/catalina/PeerToPeerSessionCache.java
@@ -90,7 +90,7 @@ public class PeerToPeerSessionCache extends AbstractSessionCache {
collector = execution.execute(TouchPartitionedRegionEntriesFunction.ID, true, false, true);
} else {
// Execute the member touch function on all the server(s)
- Execution execution = FunctionService.onMembers()
+ Execution execution = FunctionService.onMembers(getCache().getDistributedSystem())
.setArguments(new Object[] {this.sessionRegion.getFullPath(), sessionIds});
collector = execution.execute(TouchReplicatedRegionEntriesFunction.ID, true, false, false);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/extensions/geode-modules/src/main/java/org/apache/geode/modules/util/BootstrappingFunction.java
----------------------------------------------------------------------
diff --git a/extensions/geode-modules/src/main/java/org/apache/geode/modules/util/BootstrappingFunction.java b/extensions/geode-modules/src/main/java/org/apache/geode/modules/util/BootstrappingFunction.java
index a0e3e85..64ecef3 100644
--- a/extensions/geode-modules/src/main/java/org/apache/geode/modules/util/BootstrappingFunction.java
+++ b/extensions/geode-modules/src/main/java/org/apache/geode/modules/util/BootstrappingFunction.java
@@ -115,7 +115,7 @@ public class BootstrappingFunction implements Function, MembershipListener {
private void bootstrapMember(InternalDistributedMember member) {
// Create and execute the function
Cache cache = CacheFactory.getAnyInstance();
- Execution execution = FunctionService.onMember(member);
+ Execution execution = FunctionService.onMember(cache.getDistributedSystem(), member);
ResultCollector collector = execution.execute(this);
// Get the result. Nothing is being done with it.
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/main/java/org/apache/geode/cache/execute/FunctionService.java
----------------------------------------------------------------------
diff --git a/geode-core/src/main/java/org/apache/geode/cache/execute/FunctionService.java b/geode-core/src/main/java/org/apache/geode/cache/execute/FunctionService.java
index 8489275..8f64caf 100755
--- a/geode-core/src/main/java/org/apache/geode/cache/execute/FunctionService.java
+++ b/geode-core/src/main/java/org/apache/geode/cache/execute/FunctionService.java
@@ -135,6 +135,55 @@ public class FunctionService {
/**
* Returns an {@link Execution} object that can be used to execute a data independent function on
+ * a {@link DistributedMember} of the {@link DistributedSystem}. If the member is not found in the
+ * system, the function execution will throw an Exception. If the member goes down while
+ * dispatching or executing the function on the member, an Exception will be thrown.
+ *
+ * @param system defines the distributed system
+ * @param distributedMember defines a member in the distributed system
+ * @return Execution
+ * @throws FunctionException if either input parameter is null
+ * @since GemFire 6.0
+ * @deprecated use {@link #onMember(DistributedMember)} instead
+ */
+ public static Execution onMember(DistributedSystem system, DistributedMember distributedMember) {
+ return functionSvcMgr.onMember(system, distributedMember);
+ }
+
+ /**
+ * Returns an {@link Execution} object that can be used to execute a data independent function on
+ * all members of the {@link DistributedSystem}. If one of the members goes down while dispatching
+ * or executing the function on the member, an Exception will be thrown.
+ *
+ * @param system defines the distributed system
+ * @return Execution
+ *
+ * @throws FunctionException if DistributedSystem instance passed is null
+ * @since GemFire 6.0
+ * @deprecated use {@link #onMember(String...)} instead
+ */
+ public static Execution onMembers(DistributedSystem system) {
+ return functionSvcMgr.onMembers(system);
+ }
+
+ /**
+ * Returns an {@link Execution} object that can be used to execute a data independent function on
+ * the set of {@link DistributedMember}s of the {@link DistributedSystem}. If one of the members
+ * goes down while dispatching or executing the function, an Exception will be thrown.
+ *
+ * @param system defines the distributed system
+ * @param distributedMembers set of distributed members on which {@link Function} to be executed
+ * @throws FunctionException if DistributedSystem instance passed is null
+ * @since GemFire 6.0
+ * @deprecated use {@link #onMembers(Set)} instead
+ */
+ public static Execution onMembers(DistributedSystem system,
+ Set<DistributedMember> distributedMembers) {
+ return functionSvcMgr.onMembers(system, distributedMembers);
+ }
+
+ /**
+ * Returns an {@link Execution} object that can be used to execute a data independent function on
* a {@link DistributedMember}. If the member is not found, executing the function will throw an
* Exception. If the member goes down while dispatching or executing the function on the member,
* an Exception will be thrown.
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/cache/management/MemoryThresholdsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/cache/management/MemoryThresholdsDUnitTest.java b/geode-core/src/test/java/org/apache/geode/cache/management/MemoryThresholdsDUnitTest.java
index 9017fc2..8af44eb 100644
--- a/geode-core/src/test/java/org/apache/geode/cache/management/MemoryThresholdsDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/cache/management/MemoryThresholdsDUnitTest.java
@@ -906,8 +906,8 @@ public class MemoryThresholdsDUnitTest extends ClientServerTestCase {
// should not fail
server1.invoke(new SerializableCallable() {
public Object call() throws Exception {
- FunctionService.onMembers().execute(function);
- FunctionService.onMembers().execute(function2);
+ FunctionService.onMembers(getSystem()).execute(function);
+ FunctionService.onMembers(getSystem()).execute(function2);
return null;
}
});
@@ -944,13 +944,13 @@ public class MemoryThresholdsDUnitTest extends ClientServerTestCase {
public Object call() throws Exception {
try {
getCache().getLoggerI18n().fine(addExpectedFunctionExString);
- FunctionService.onMembers().execute(function);
+ FunctionService.onMembers(getSystem()).execute(function);
getCache().getLoggerI18n().fine(removeExpectedFunctionExString);
fail("expected low memory exception was not thrown");
} catch (LowMemoryException e) {
// expected
}
- FunctionService.onMembers().execute(function2);
+ FunctionService.onMembers(getSystem()).execute(function2);
return null;
}
});
@@ -1031,8 +1031,8 @@ public class MemoryThresholdsDUnitTest extends ClientServerTestCase {
// should not fail
accessor.invoke(new SerializableCallable() {
public Object call() throws Exception {
- FunctionService.onMembers().execute(function);
- FunctionService.onMembers().execute(function2);
+ FunctionService.onMembers(getSystem()).execute(function);
+ FunctionService.onMembers(getSystem()).execute(function2);
return null;
}
});
@@ -1067,13 +1067,13 @@ public class MemoryThresholdsDUnitTest extends ClientServerTestCase {
public Object call() throws Exception {
try {
getCache().getLoggerI18n().fine(addExpectedFunctionExString);
- FunctionService.onMembers().execute(function);
+ FunctionService.onMembers(getSystem()).execute(function);
getCache().getLoggerI18n().fine(removeExpectedFunctionExString);
fail("expected low memory exception was not thrown");
} catch (LowMemoryException e) {
// expected
}
- FunctionService.onMembers().execute(function2);
+ FunctionService.onMembers(getSystem()).execute(function2);
return null;
}
});
@@ -1205,10 +1205,10 @@ public class MemoryThresholdsDUnitTest extends ClientServerTestCase {
server2.invoke(new SerializableCallable() {
public Object call() throws Exception {
- FunctionService.onMembers().execute(function);
- FunctionService.onMember(s1).execute(function);
- FunctionService.onMembers().execute(function2);
- FunctionService.onMember(s1).execute(function2);
+ FunctionService.onMembers(getSystem()).execute(function);
+ FunctionService.onMember(getSystem(), s1).execute(function);
+ FunctionService.onMembers(getSystem()).execute(function2);
+ FunctionService.onMember(getSystem(), s1).execute(function2);
return null;
}
});
@@ -1241,19 +1241,19 @@ public class MemoryThresholdsDUnitTest extends ClientServerTestCase {
server2.invoke(new SerializableCallable() {
public Object call() throws Exception {
try {
- FunctionService.onMembers().execute(function);
+ FunctionService.onMembers(getSystem()).execute(function);
fail("expected LowMemoryExcception was not thrown");
} catch (LowMemoryException e) {
// expected
}
try {
- FunctionService.onMember(s1).execute(function);
+ FunctionService.onMember(getSystem(), s1).execute(function);
fail("expected LowMemoryExcception was not thrown");
} catch (LowMemoryException e) {
// expected
}
- FunctionService.onMembers().execute(function2);
- FunctionService.onMember(s1).execute(function2);
+ FunctionService.onMembers(getSystem()).execute(function2);
+ FunctionService.onMember(getSystem(), s1).execute(function2);
return null;
}
});
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/internal/ClassPathLoaderIntegrationTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/ClassPathLoaderIntegrationTest.java b/geode-core/src/test/java/org/apache/geode/internal/ClassPathLoaderIntegrationTest.java
index 721e502..b4776bf 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/ClassPathLoaderIntegrationTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/ClassPathLoaderIntegrationTest.java
@@ -243,7 +243,8 @@ public class ClassPathLoaderIntegrationTest {
GemFireCacheImpl gemFireCache = GemFireCacheImpl.getInstance();
DistributedSystem distributedSystem = gemFireCache.getDistributedSystem();
- Execution execution = FunctionService.onMember(distributedSystem.getDistributedMember());
+ Execution execution =
+ FunctionService.onMember(distributedSystem, distributedSystem.getDistributedMember());
ResultCollector resultCollector = execution.execute("JarDeployerDUnitFunction");
@SuppressWarnings("unchecked")
List<String> result = (List<String>) resultCollector.getResult();
@@ -267,7 +268,8 @@ public class ClassPathLoaderIntegrationTest {
FileUtils.readFileToByteArray(jarVersion1));
assertThatClassCanBeLoaded("jddunit.function.MyFunction");
- Execution execution = FunctionService.onMember(distributedSystem.getDistributedMember());
+ Execution execution =
+ FunctionService.onMember(distributedSystem, distributedSystem.getDistributedMember());
List<String> result = (List<String>) execution.execute("MyFunction").getResult();
assertThat(result.get(0)).isEqualTo("Version1");
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/internal/cache/CommitFunction.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/CommitFunction.java b/geode-core/src/test/java/org/apache/geode/internal/cache/CommitFunction.java
index 4c062cc..c66901a 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/CommitFunction.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/CommitFunction.java
@@ -101,7 +101,8 @@ public class CommitFunction implements Function {
ArrayList args = new ArrayList();
args.add(txId);
args.add(NestedTransactionFunction.COMMIT);
- Execution ex = FunctionService.onMember(member).setArguments(args);
+ Execution ex =
+ FunctionService.onMember(cache.getDistributedSystem(), member).setArguments(args);
if (isDebugEnabled) {
logger.debug(
"CommitFunction: for transaction: {} executing NestedTransactionFunction on member: {}",
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java
index 3c4908c..bc8bfb6 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/RemoteTransactionDUnitTest.java
@@ -2498,7 +2498,7 @@ public class RemoteTransactionDUnitTest extends JUnit4CacheTestCase {
FunctionService.onRegion(custRegion).execute(TXFunction.id).getResult();
break;
case OnMember:
- FunctionService.onMembers().execute(TXFunction.id).getResult();
+ FunctionService.onMembers(basicGetSystem()).execute(TXFunction.id).getResult();
break;
}
fail("Expected exception not thrown");
@@ -2519,7 +2519,7 @@ public class RemoteTransactionDUnitTest extends JUnit4CacheTestCase {
case OnMember:
DistributedMember owner =
custRegion.getOwnerForKey(custRegion.getKeyInfo(expectedCustId));
- FunctionService.onMember(owner).execute(TXFunction.id).getResult();
+ FunctionService.onMember(basicGetSystem(), owner).execute(TXFunction.id).getResult();
break;
}
TXStateProxy tx = mgr.internalSuspend();
@@ -2565,7 +2565,7 @@ public class RemoteTransactionDUnitTest extends JUnit4CacheTestCase {
case OnMember:
DistributedMember owner =
custRegion.getOwnerForKey(custRegion.getKeyInfo(expectedCustId));
- FunctionService.onMember(owner).execute(TXFunction.id).getResult();
+ FunctionService.onMember(basicGetSystem(), owner).execute(TXFunction.id).getResult();
break;
}
TXStateProxy tx = mgr.internalSuspend();
@@ -2833,11 +2833,11 @@ public class RemoteTransactionDUnitTest extends JUnit4CacheTestCase {
members.add(ds1);
members.add(ds2);
try {
- FunctionService.onMembers(members).execute(TXFunction.id).getResult();
+ FunctionService.onMembers(basicGetSystem(), members).execute(TXFunction.id).getResult();
fail("expected exception not thrown");
} catch (TransactionException expected) {
}
- FunctionService.onMember(owner).execute(TXFunction.id).getResult();
+ FunctionService.onMember(basicGetSystem(), owner).execute(TXFunction.id).getResult();
assertEquals(expectedCustomer, pr.get(expectedCustId));
TXStateProxy tx = mgr.internalSuspend();
assertNull(pr.get(expectedCustId));
@@ -2928,7 +2928,7 @@ public class RemoteTransactionDUnitTest extends JUnit4CacheTestCase {
} catch (TransactionDataRebalancedException expected) {
}
try {
- FunctionService.onMember(ds2).execute(TXFunction.id).getResult();
+ FunctionService.onMember(basicGetSystem(), ds2).execute(TXFunction.id).getResult();
fail("expected exception not thrown");
} catch (TransactionDataNotColocatedException expected) {
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/internal/cache/RollbackFunction.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/RollbackFunction.java b/geode-core/src/test/java/org/apache/geode/internal/cache/RollbackFunction.java
index 6d47e56..8ec7d2d 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/RollbackFunction.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/RollbackFunction.java
@@ -100,7 +100,8 @@ public class RollbackFunction implements Function {
ArrayList args = new ArrayList();
args.add(txId);
args.add(NestedTransactionFunction.ROLLBACK);
- Execution ex = FunctionService.onMember(member).setArguments(args);
+ Execution ex =
+ FunctionService.onMember(cache.getDistributedSystem(), member).setArguments(args);
if (isDebugEnabled) {
logger.debug(
"RollbackFunction: for transaction: {} executing NestedTransactionFunction on member: {}",
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/internal/cache/execute/FunctionServiceStatsDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/execute/FunctionServiceStatsDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/execute/FunctionServiceStatsDUnitTest.java
index 1fa523c..a2a6667 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/execute/FunctionServiceStatsDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/execute/FunctionServiceStatsDUnitTest.java
@@ -1057,7 +1057,7 @@ public class FunctionServiceStatsDUnitTest extends PRClientServerTestBase {
assertNotNull(ds);
Execution memberExecution = null;
DistributedMember localmember = ds.getDistributedMember();
- memberExecution = FunctionService.onMember(localmember);
+ memberExecution = FunctionService.onMember(ds, localmember);
memberExecution.setArguments("Key");
try {
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/internal/cache/execute/LocalFunctionExecutionDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/execute/LocalFunctionExecutionDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/execute/LocalFunctionExecutionDUnitTest.java
index 670e751..5b6f065 100644
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/execute/LocalFunctionExecutionDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/execute/LocalFunctionExecutionDUnitTest.java
@@ -156,8 +156,8 @@ public class LocalFunctionExecutionDUnitTest extends JUnit4DistributedTestCase {
Function function1 = new TestFunction(true, TestFunction.TEST_FUNCTION_EXCEPTION);
FunctionService.registerFunction(function1);
DistributedMember localmember = getSystemStatic().getDistributedMember();
- ResultCollector rc = FunctionService.onMember(localmember).setArguments(Boolean.TRUE)
- .execute(function1.getId());
+ ResultCollector rc = FunctionService.onMember(getSystemStatic(), localmember)
+ .setArguments(Boolean.TRUE).execute(function1.getId());
rc.getResult();
Assert.fail("Exception should occur", new Exception("Test Failed"));
} catch (Exception e) {
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutionDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutionDUnitTest.java b/geode-core/src/test/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutionDUnitTest.java
index f997ea2..d14a212 100755
--- a/geode-core/src/test/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutionDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/internal/cache/execute/MemberFunctionExecutionDUnitTest.java
@@ -171,7 +171,8 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Constructor<Function> constructor = clazz.getConstructor();
Function function = (Function) constructor.newInstance();
- Execution execution = FunctionService.onMembers();
+ DistributedSystem distributedSystem = getSystem();
+ Execution execution = FunctionService.onMembers(distributedSystem);
ResultCollector resultCollector = execution.execute(function);
try {
resultCollector.getResult();
@@ -202,7 +203,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
member3.invoke(() -> MemberFunctionExecutionDUnitTest.connectToDistributedSystem(props));
member4.invoke(() -> MemberFunctionExecutionDUnitTest.connectToDistributedSystem(props));
connectToDistributedSystem(props);
- AbstractExecution exe = (AbstractExecution) FunctionService.onMembers();
+ AbstractExecution exe = (AbstractExecution) FunctionService.onMembers(getSystem());
exe.setIgnoreDepartedMembers(true);
ResultCollector rs = exe.execute(new FunctionAdapter() {
@Override
@@ -377,7 +378,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
DistributedMember localmember = ds.getDistributedMember();
Execution memberExcution = null;
- memberExcution = FunctionService.onMember(localmember);
+ memberExcution = FunctionService.onMember(ds, localmember);
Execution executor = memberExcution.setArguments("Key");
try {
ResultCollector rc = executor.execute(new FunctionAdapter() {
@@ -426,12 +427,12 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Map memArgs = new HashMap();
if (noOfMembers.intValue() == 1) { // Local VM
DistributedMember localmember = ds.getDistributedMember();
- memberExcution = (InternalExecution) FunctionService.onMember(localmember);
+ memberExcution = (InternalExecution) FunctionService.onMember(ds, localmember);
memArgs.put(localmember.getId(), localmember.getId());
MemberMappedArgument args = new MemberMappedArgument("Key", memArgs);
executor = memberExcution.withMemberMappedArgument(args);
} else if (noOfMembers.intValue() == 5) {
- memberExcution = (InternalExecution) FunctionService.onMembers();
+ memberExcution = (InternalExecution) FunctionService.onMembers(ds);
Set memberSet = new HashSet(ds.getDistributionManager().getNormalDistributionManagerIds());
Iterator iter = memberSet.iterator();
while (iter.hasNext()) {
@@ -450,7 +451,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
memArgs.put(member.getId(), member.getId());
}
MemberMappedArgument args = new MemberMappedArgument("Key", memArgs);
- memberExcution = (InternalExecution) FunctionService.onMembers(memberSet);
+ memberExcution = (InternalExecution) FunctionService.onMembers(ds, memberSet);
executor = memberExcution.withMemberMappedArgument(args);
}
try {
@@ -477,9 +478,9 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Map memArgs = new HashMap();
if (noOfMembers.intValue() == 1) { // Local VM
DistributedMember localmember = ds.getDistributedMember();
- memberExcution = (InternalExecution) FunctionService.onMember(localmember);
+ memberExcution = (InternalExecution) FunctionService.onMember(ds, localmember);
} else if (noOfMembers.intValue() == 5) {
- memberExcution = (InternalExecution) FunctionService.onMembers();
+ memberExcution = (InternalExecution) FunctionService.onMembers(ds);
} else {
Set memberSet = new HashSet(ds.getDistributionManager().getNormalDistributionManagerIds());
InternalDistributedMember localVM = ds.getDistributionManager().getDistributionManagerId();
@@ -488,7 +489,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
while (iter.hasNext()) {
InternalDistributedMember member = (InternalDistributedMember) iter.next();
}
- memberExcution = (InternalExecution) FunctionService.onMembers(memberSet);
+ memberExcution = (InternalExecution) FunctionService.onMembers(ds, memberSet);
}
try {
ResultCollector rc = memberExcution.setArguments(Boolean.TRUE).execute(function);
@@ -514,12 +515,12 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Map memArgs = new HashMap();
if (noOfMembers.intValue() == 1) { // Local VM
DistributedMember localmember = ds.getDistributedMember();
- memberExcution = (InternalExecution) FunctionService.onMember(localmember);
+ memberExcution = (InternalExecution) FunctionService.onMember(ds, localmember);
memArgs.put(localmember.getId(), localmember.getId());
MemberMappedArgument args = new MemberMappedArgument("Key", memArgs);
executor = memberExcution.withMemberMappedArgument(args);
} else if (noOfMembers.intValue() == 5) {
- memberExcution = (InternalExecution) FunctionService.onMembers();
+ memberExcution = (InternalExecution) FunctionService.onMembers(ds);
Set memberSet = new HashSet(ds.getDistributionManager().getNormalDistributionManagerIds());
Iterator iter = memberSet.iterator();
while (iter.hasNext()) {
@@ -538,7 +539,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
memArgs.put(member.getId(), member.getId());
}
MemberMappedArgument args = new MemberMappedArgument("Key", memArgs);
- memberExcution = (InternalExecution) FunctionService.onMembers(memberSet);
+ memberExcution = (InternalExecution) FunctionService.onMembers(ds, memberSet);
executor = memberExcution.withMemberMappedArgument(args);
}
try {
@@ -559,14 +560,14 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Execution memberExcution = null;
if (noOfMembers.intValue() == 1) { // Local VM
DistributedMember localmember = ds.getDistributedMember();
- memberExcution = FunctionService.onMember(localmember);
+ memberExcution = FunctionService.onMember(ds, localmember);
} else if (noOfMembers.intValue() == 5) {
- memberExcution = FunctionService.onMembers();
+ memberExcution = FunctionService.onMembers(ds);
} else {
Set memberSet = new HashSet(ds.getDistributionManager().getNormalDistributionManagerIds());
InternalDistributedMember localVM = ds.getDistributionManager().getDistributionManagerId();
memberSet.remove(localVM);
- memberExcution = FunctionService.onMembers(memberSet);
+ memberExcution = FunctionService.onMembers(ds, memberSet);
}
Execution executor = memberExcution.setArguments("Key");
try {
@@ -610,7 +611,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
public static void excuteOnMembersNoResult() {
assertNotNull(ds);
Function function = new TestFunction(false, TEST_FUNCTION6);
- Execution memberExcution = FunctionService.onMembers();
+ Execution memberExcution = FunctionService.onMembers(ds);
Execution executor = memberExcution.setArguments("Key");
try {
ResultCollector rc = executor.execute(function.getId());
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DeployCommandRedeployDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DeployCommandRedeployDUnitTest.java b/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DeployCommandRedeployDUnitTest.java
index e494bcd..785915a 100644
--- a/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DeployCommandRedeployDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/DeployCommandRedeployDUnitTest.java
@@ -166,7 +166,8 @@ public class DeployCommandRedeployDUnitTest implements Serializable {
private void assertThatFunctionHasVersion(String functionId, String version) {
GemFireCacheImpl gemFireCache = GemFireCacheImpl.getInstance();
DistributedSystem distributedSystem = gemFireCache.getDistributedSystem();
- Execution execution = FunctionService.onMember(distributedSystem.getDistributedMember());
+ Execution execution =
+ FunctionService.onMember(distributedSystem, distributedSystem.getDistributedMember());
List<String> result = (List<String>) execution.execute(functionId).getResult();
assertThat(result.get(0)).isEqualTo(version);
}
http://git-wip-us.apache.org/repos/asf/geode/blob/b4745066/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ShowDeadlockDUnitTest.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ShowDeadlockDUnitTest.java b/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ShowDeadlockDUnitTest.java
index 62dcf32..b6e7c36 100644
--- a/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ShowDeadlockDUnitTest.java
+++ b/geode-core/src/test/java/org/apache/geode/management/internal/cli/commands/ShowDeadlockDUnitTest.java
@@ -174,7 +174,7 @@ public class ShowDeadlockDUnitTest extends JUnit4CacheTestCase {
lock.lock();
ResultCollector collector =
- FunctionService.onMember(member).execute(new TestFunction());
+ FunctionService.onMember(basicGetSystem(), member).execute(new TestFunction());
// wait the function to lock the lock on member.
collector.getResult();
lock.unlock();