This is an automated email from the ASF dual-hosted git repository.
jchen21 pushed a commit to branch feature/GEODE-6511
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-6511 by this
push:
new 8e4db99 Fix failed test
8e4db99 is described below
commit 8e4db995a9616397286f00a9a7ea7a13871d9dff
Author: Ben Ross <[email protected]>
AuthorDate: Wed Mar 13 09:57:07 2019 -0700
Fix failed test
Co-authored-by: Ben Ross <[email protected]>
Co-authored-by: Jianxia Chen <[email protected]>
---
.../cli/functions/DestroyJndiBindingFunctionTest.java | 2 +-
.../java/org/apache/geode/internal/jndi/JNDIInvoker.java | 13 ++++++-------
.../internal/cli/functions/DestroyJndiBindingFunction.java | 6 +++---
3 files changed, 10 insertions(+), 11 deletions(-)
diff --git
a/geode-core/src/integrationTest/java/org/apache/geode/management/internal/cli/functions/DestroyJndiBindingFunctionTest.java
b/geode-core/src/integrationTest/java/org/apache/geode/management/internal/cli/functions/DestroyJndiBindingFunctionTest.java
index 3717fdc..87758b4 100644
---
a/geode-core/src/integrationTest/java/org/apache/geode/management/internal/cli/functions/DestroyJndiBindingFunctionTest.java
+++
b/geode-core/src/integrationTest/java/org/apache/geode/management/internal/cli/functions/DestroyJndiBindingFunctionTest.java
@@ -134,7 +134,7 @@ public class DestroyJndiBindingFunctionTest {
when(context.getArguments()).thenReturn(new Object[] {"jndi1", true});
when(context.getResultSender()).thenReturn(resultSender);
DestroyJndiBindingFunction destroyFunctionSpy =
spy(destroyJndiBindingFunction);
- doReturn(true).when(destroyFunctionSpy).checkForInvalidDataSource(any());
+ doReturn(false).when(destroyFunctionSpy).isValidDataSource(any());
destroyFunctionSpy.execute(context);
verify(resultSender).lastResult(resultCaptor.capture());
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/jndi/JNDIInvoker.java
b/geode-core/src/main/java/org/apache/geode/internal/jndi/JNDIInvoker.java
index 944673e..8380539 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/jndi/JNDIInvoker.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/jndi/JNDIInvoker.java
@@ -405,16 +405,15 @@ public class JNDIInvoker {
}
}
- public static boolean checkForInvalidDataSource(String name) {
+ public static boolean isValidDataSource(String name) {
Object dataSource = dataSourceMap.get(name);
- if (dataSource != null) {
- if (dataSource instanceof DataSource
- && !(dataSource instanceof GemFireTransactionDataSource)) {
- return false;
- }
+ if (dataSource == null || (dataSource != null && dataSource instanceof
DataSource
+ && !(dataSource instanceof GemFireTransactionDataSource))) {
+ return true;
}
- return true;
+
+ return false;
}
/**
diff --git
a/geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/DestroyJndiBindingFunction.java
b/geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/DestroyJndiBindingFunction.java
index a31d8bd..eba763e 100644
---
a/geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/DestroyJndiBindingFunction.java
+++
b/geode-core/src/main/java/org/apache/geode/management/internal/cli/functions/DestroyJndiBindingFunction.java
@@ -32,7 +32,7 @@ public class DestroyJndiBindingFunction extends
CliFunction<Object[]> {
if (destroyingDataSource) {
typeName = "Data source";
- if (checkForInvalidDataSource(jndiName)) {
+ if (!isValidDataSource(jndiName)) {
return new CliFunctionResult(context.getMemberName(),
CliFunctionResult.StatusState.ERROR,
CliStrings.format(
"Data Source {0} has invalid type for destroy data-source,
destroy jndi-binding command should be used.",
@@ -53,7 +53,7 @@ public class DestroyJndiBindingFunction extends
CliFunction<Object[]> {
}
}
- boolean checkForInvalidDataSource(String jndiName) {
- return JNDIInvoker.checkForInvalidDataSource(jndiName);
+ boolean isValidDataSource(String jndiName) {
+ return JNDIInvoker.isValidDataSource(jndiName);
}
}