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:31:42 UTC
geode git commit: GEODE-269: Removing deprecated API's from
FunctionService.
Repository: geode
Updated Branches:
refs/heads/develop 4e3a4d762 -> 7da9047a2
GEODE-269: Removing deprecated API's from FunctionService.
This closes #511
Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/7da9047a
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/7da9047a
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/7da9047a
Branch: refs/heads/develop
Commit: 7da9047a21f6b677066a107c5d378540b5e8b3fd
Parents: 4e3a4d7
Author: Jason Huynh <hu...@gmail.com>
Authored: Mon May 22 14:30:54 2017 -0700
Committer: Jason Huynh <hu...@gmail.com>
Committed: Mon May 22 14:30:54 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, 49 insertions(+), 104 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/geode/blob/7da9047a/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 69d6ec0..f1afca3 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(getCache().getDistributedSystem())
+ Execution execution = FunctionService.onMembers()
.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/7da9047a/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 64ecef3..a0e3e85 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(cache.getDistributedSystem(), member);
+ Execution execution = FunctionService.onMember(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/7da9047a/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 8f64caf..8489275 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,55 +135,6 @@ 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/7da9047a/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 8af44eb..9017fc2 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(getSystem()).execute(function);
- FunctionService.onMembers(getSystem()).execute(function2);
+ FunctionService.onMembers().execute(function);
+ FunctionService.onMembers().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(getSystem()).execute(function);
+ FunctionService.onMembers().execute(function);
getCache().getLoggerI18n().fine(removeExpectedFunctionExString);
fail("expected low memory exception was not thrown");
} catch (LowMemoryException e) {
// expected
}
- FunctionService.onMembers(getSystem()).execute(function2);
+ FunctionService.onMembers().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(getSystem()).execute(function);
- FunctionService.onMembers(getSystem()).execute(function2);
+ FunctionService.onMembers().execute(function);
+ FunctionService.onMembers().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(getSystem()).execute(function);
+ FunctionService.onMembers().execute(function);
getCache().getLoggerI18n().fine(removeExpectedFunctionExString);
fail("expected low memory exception was not thrown");
} catch (LowMemoryException e) {
// expected
}
- FunctionService.onMembers(getSystem()).execute(function2);
+ FunctionService.onMembers().execute(function2);
return null;
}
});
@@ -1205,10 +1205,10 @@ public class MemoryThresholdsDUnitTest extends ClientServerTestCase {
server2.invoke(new SerializableCallable() {
public Object call() throws Exception {
- FunctionService.onMembers(getSystem()).execute(function);
- FunctionService.onMember(getSystem(), s1).execute(function);
- FunctionService.onMembers(getSystem()).execute(function2);
- FunctionService.onMember(getSystem(), s1).execute(function2);
+ FunctionService.onMembers().execute(function);
+ FunctionService.onMember(s1).execute(function);
+ FunctionService.onMembers().execute(function2);
+ FunctionService.onMember(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(getSystem()).execute(function);
+ FunctionService.onMembers().execute(function);
fail("expected LowMemoryExcception was not thrown");
} catch (LowMemoryException e) {
// expected
}
try {
- FunctionService.onMember(getSystem(), s1).execute(function);
+ FunctionService.onMember(s1).execute(function);
fail("expected LowMemoryExcception was not thrown");
} catch (LowMemoryException e) {
// expected
}
- FunctionService.onMembers(getSystem()).execute(function2);
- FunctionService.onMember(getSystem(), s1).execute(function2);
+ FunctionService.onMembers().execute(function2);
+ FunctionService.onMember(s1).execute(function2);
return null;
}
});
http://git-wip-us.apache.org/repos/asf/geode/blob/7da9047a/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 b4776bf..721e502 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,8 +243,7 @@ public class ClassPathLoaderIntegrationTest {
GemFireCacheImpl gemFireCache = GemFireCacheImpl.getInstance();
DistributedSystem distributedSystem = gemFireCache.getDistributedSystem();
- Execution execution =
- FunctionService.onMember(distributedSystem, distributedSystem.getDistributedMember());
+ Execution execution = FunctionService.onMember(distributedSystem.getDistributedMember());
ResultCollector resultCollector = execution.execute("JarDeployerDUnitFunction");
@SuppressWarnings("unchecked")
List<String> result = (List<String>) resultCollector.getResult();
@@ -268,8 +267,7 @@ public class ClassPathLoaderIntegrationTest {
FileUtils.readFileToByteArray(jarVersion1));
assertThatClassCanBeLoaded("jddunit.function.MyFunction");
- Execution execution =
- FunctionService.onMember(distributedSystem, distributedSystem.getDistributedMember());
+ Execution execution = FunctionService.onMember(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/7da9047a/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 c66901a..4c062cc 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,8 +101,7 @@ public class CommitFunction implements Function {
ArrayList args = new ArrayList();
args.add(txId);
args.add(NestedTransactionFunction.COMMIT);
- Execution ex =
- FunctionService.onMember(cache.getDistributedSystem(), member).setArguments(args);
+ Execution ex = FunctionService.onMember(member).setArguments(args);
if (isDebugEnabled) {
logger.debug(
"CommitFunction: for transaction: {} executing NestedTransactionFunction on member: {}",
http://git-wip-us.apache.org/repos/asf/geode/blob/7da9047a/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 bc8bfb6..3c4908c 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(basicGetSystem()).execute(TXFunction.id).getResult();
+ FunctionService.onMembers().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(basicGetSystem(), owner).execute(TXFunction.id).getResult();
+ FunctionService.onMember(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(basicGetSystem(), owner).execute(TXFunction.id).getResult();
+ FunctionService.onMember(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(basicGetSystem(), members).execute(TXFunction.id).getResult();
+ FunctionService.onMembers(members).execute(TXFunction.id).getResult();
fail("expected exception not thrown");
} catch (TransactionException expected) {
}
- FunctionService.onMember(basicGetSystem(), owner).execute(TXFunction.id).getResult();
+ FunctionService.onMember(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(basicGetSystem(), ds2).execute(TXFunction.id).getResult();
+ FunctionService.onMember(ds2).execute(TXFunction.id).getResult();
fail("expected exception not thrown");
} catch (TransactionDataNotColocatedException expected) {
}
http://git-wip-us.apache.org/repos/asf/geode/blob/7da9047a/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 8ec7d2d..6d47e56 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,8 +100,7 @@ public class RollbackFunction implements Function {
ArrayList args = new ArrayList();
args.add(txId);
args.add(NestedTransactionFunction.ROLLBACK);
- Execution ex =
- FunctionService.onMember(cache.getDistributedSystem(), member).setArguments(args);
+ Execution ex = FunctionService.onMember(member).setArguments(args);
if (isDebugEnabled) {
logger.debug(
"RollbackFunction: for transaction: {} executing NestedTransactionFunction on member: {}",
http://git-wip-us.apache.org/repos/asf/geode/blob/7da9047a/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 a2a6667..1fa523c 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(ds, localmember);
+ memberExecution = FunctionService.onMember(localmember);
memberExecution.setArguments("Key");
try {
http://git-wip-us.apache.org/repos/asf/geode/blob/7da9047a/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 5b6f065..670e751 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(getSystemStatic(), localmember)
- .setArguments(Boolean.TRUE).execute(function1.getId());
+ ResultCollector rc = FunctionService.onMember(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/7da9047a/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 d14a212..f997ea2 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,8 +171,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Constructor<Function> constructor = clazz.getConstructor();
Function function = (Function) constructor.newInstance();
- DistributedSystem distributedSystem = getSystem();
- Execution execution = FunctionService.onMembers(distributedSystem);
+ Execution execution = FunctionService.onMembers();
ResultCollector resultCollector = execution.execute(function);
try {
resultCollector.getResult();
@@ -203,7 +202,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
member3.invoke(() -> MemberFunctionExecutionDUnitTest.connectToDistributedSystem(props));
member4.invoke(() -> MemberFunctionExecutionDUnitTest.connectToDistributedSystem(props));
connectToDistributedSystem(props);
- AbstractExecution exe = (AbstractExecution) FunctionService.onMembers(getSystem());
+ AbstractExecution exe = (AbstractExecution) FunctionService.onMembers();
exe.setIgnoreDepartedMembers(true);
ResultCollector rs = exe.execute(new FunctionAdapter() {
@Override
@@ -378,7 +377,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
DistributedMember localmember = ds.getDistributedMember();
Execution memberExcution = null;
- memberExcution = FunctionService.onMember(ds, localmember);
+ memberExcution = FunctionService.onMember(localmember);
Execution executor = memberExcution.setArguments("Key");
try {
ResultCollector rc = executor.execute(new FunctionAdapter() {
@@ -427,12 +426,12 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Map memArgs = new HashMap();
if (noOfMembers.intValue() == 1) { // Local VM
DistributedMember localmember = ds.getDistributedMember();
- memberExcution = (InternalExecution) FunctionService.onMember(ds, localmember);
+ memberExcution = (InternalExecution) FunctionService.onMember(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(ds);
+ memberExcution = (InternalExecution) FunctionService.onMembers();
Set memberSet = new HashSet(ds.getDistributionManager().getNormalDistributionManagerIds());
Iterator iter = memberSet.iterator();
while (iter.hasNext()) {
@@ -451,7 +450,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
memArgs.put(member.getId(), member.getId());
}
MemberMappedArgument args = new MemberMappedArgument("Key", memArgs);
- memberExcution = (InternalExecution) FunctionService.onMembers(ds, memberSet);
+ memberExcution = (InternalExecution) FunctionService.onMembers(memberSet);
executor = memberExcution.withMemberMappedArgument(args);
}
try {
@@ -478,9 +477,9 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Map memArgs = new HashMap();
if (noOfMembers.intValue() == 1) { // Local VM
DistributedMember localmember = ds.getDistributedMember();
- memberExcution = (InternalExecution) FunctionService.onMember(ds, localmember);
+ memberExcution = (InternalExecution) FunctionService.onMember(localmember);
} else if (noOfMembers.intValue() == 5) {
- memberExcution = (InternalExecution) FunctionService.onMembers(ds);
+ memberExcution = (InternalExecution) FunctionService.onMembers();
} else {
Set memberSet = new HashSet(ds.getDistributionManager().getNormalDistributionManagerIds());
InternalDistributedMember localVM = ds.getDistributionManager().getDistributionManagerId();
@@ -489,7 +488,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
while (iter.hasNext()) {
InternalDistributedMember member = (InternalDistributedMember) iter.next();
}
- memberExcution = (InternalExecution) FunctionService.onMembers(ds, memberSet);
+ memberExcution = (InternalExecution) FunctionService.onMembers(memberSet);
}
try {
ResultCollector rc = memberExcution.setArguments(Boolean.TRUE).execute(function);
@@ -515,12 +514,12 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Map memArgs = new HashMap();
if (noOfMembers.intValue() == 1) { // Local VM
DistributedMember localmember = ds.getDistributedMember();
- memberExcution = (InternalExecution) FunctionService.onMember(ds, localmember);
+ memberExcution = (InternalExecution) FunctionService.onMember(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(ds);
+ memberExcution = (InternalExecution) FunctionService.onMembers();
Set memberSet = new HashSet(ds.getDistributionManager().getNormalDistributionManagerIds());
Iterator iter = memberSet.iterator();
while (iter.hasNext()) {
@@ -539,7 +538,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
memArgs.put(member.getId(), member.getId());
}
MemberMappedArgument args = new MemberMappedArgument("Key", memArgs);
- memberExcution = (InternalExecution) FunctionService.onMembers(ds, memberSet);
+ memberExcution = (InternalExecution) FunctionService.onMembers(memberSet);
executor = memberExcution.withMemberMappedArgument(args);
}
try {
@@ -560,14 +559,14 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
Execution memberExcution = null;
if (noOfMembers.intValue() == 1) { // Local VM
DistributedMember localmember = ds.getDistributedMember();
- memberExcution = FunctionService.onMember(ds, localmember);
+ memberExcution = FunctionService.onMember(localmember);
} else if (noOfMembers.intValue() == 5) {
- memberExcution = FunctionService.onMembers(ds);
+ memberExcution = FunctionService.onMembers();
} else {
Set memberSet = new HashSet(ds.getDistributionManager().getNormalDistributionManagerIds());
InternalDistributedMember localVM = ds.getDistributionManager().getDistributionManagerId();
memberSet.remove(localVM);
- memberExcution = FunctionService.onMembers(ds, memberSet);
+ memberExcution = FunctionService.onMembers(memberSet);
}
Execution executor = memberExcution.setArguments("Key");
try {
@@ -611,7 +610,7 @@ public class MemberFunctionExecutionDUnitTest extends JUnit4CacheTestCase {
public static void excuteOnMembersNoResult() {
assertNotNull(ds);
Function function = new TestFunction(false, TEST_FUNCTION6);
- Execution memberExcution = FunctionService.onMembers(ds);
+ Execution memberExcution = FunctionService.onMembers();
Execution executor = memberExcution.setArguments("Key");
try {
ResultCollector rc = executor.execute(function.getId());
http://git-wip-us.apache.org/repos/asf/geode/blob/7da9047a/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 785915a..e494bcd 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,8 +166,7 @@ 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, distributedSystem.getDistributedMember());
+ Execution execution = FunctionService.onMember(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/7da9047a/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 b6e7c36..62dcf32 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(basicGetSystem(), member).execute(new TestFunction());
+ FunctionService.onMember(member).execute(new TestFunction());
// wait the function to lock the lock on member.
collector.getResult();
lock.unlock();