geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl...@apache.org
Subject [26/51] [abbrv] geode git commit: GEODE-2886 : 1. updated to throw IllegalStateException from WaitUntilFlushedFunction.java and corresponding testcase change.
Date Sat, 19 Aug 2017 00:10:21 GMT
GEODE-2886 : 1. updated to throw IllegalStateException from
WaitUntilFlushedFunction.java and corresponding testcase change.


Project: http://git-wip-us.apache.org/repos/asf/geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/geode/commit/37201519
Tree: http://git-wip-us.apache.org/repos/asf/geode/tree/37201519
Diff: http://git-wip-us.apache.org/repos/asf/geode/diff/37201519

Branch: refs/heads/feature/GEODE-1279
Commit: 37201519de5968ba265e133a92ececf0c3892bb0
Parents: a1c3fc7
Author: Amey Barve <abarve@apache.org>
Authored: Tue Aug 8 18:41:22 2017 +0530
Committer: Amey Barve <abarve@apache.org>
Committed: Thu Aug 17 15:47:30 2017 +0530

----------------------------------------------------------------------
 .../internal/distributed/WaitUntilFlushedFunction.java |  4 +---
 .../cache/lucene/LuceneQueriesIntegrationTest.java     | 13 +++++++++----
 2 files changed, 10 insertions(+), 7 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/geode/blob/37201519/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/WaitUntilFlushedFunction.java
----------------------------------------------------------------------
diff --git a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/WaitUntilFlushedFunction.java
b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/WaitUntilFlushedFunction.java
index ca77873..6c0b8b7 100644
--- a/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/WaitUntilFlushedFunction.java
+++ b/geode-lucene/src/main/java/org/apache/geode/cache/lucene/internal/distributed/WaitUntilFlushedFunction.java
@@ -61,10 +61,8 @@ public class WaitUntilFlushedFunction implements Function, InternalEntity
{
       }
 
     } else {
-      IllegalStateException illegalStateException = new IllegalStateException(
+      throw new IllegalStateException(
           "The AEQ does not exist for the index " + indexName + " region " + region.getFullPath());
-      logger.error(illegalStateException.getMessage());
-      resultSender.lastResult(result);
     }
     resultSender.lastResult(result);
   }

http://git-wip-us.apache.org/repos/asf/geode/blob/37201519/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesIntegrationTest.java
----------------------------------------------------------------------
diff --git a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesIntegrationTest.java
b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesIntegrationTest.java
index 2044c68..2c46b4c 100644
--- a/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesIntegrationTest.java
+++ b/geode-lucene/src/test/java/org/apache/geode/cache/lucene/LuceneQueriesIntegrationTest.java
@@ -342,10 +342,15 @@ public class LuceneQueriesIntegrationTest extends LuceneIntegrationTest
{
 
     // This is to send IllegalStateException from WaitUntilFlushedFunction
     String nonCreatedIndex = "index2";
-
-    boolean b =
-        luceneService.waitUntilFlushed(nonCreatedIndex, REGION_NAME, 60000, TimeUnit.MILLISECONDS);
-    assertFalse(b);
+    boolean result = false;
+    try {
+      result = luceneService.waitUntilFlushed(nonCreatedIndex, REGION_NAME, 60000,
+          TimeUnit.MILLISECONDS);
+    } catch (Exception ex) {
+      assertEquals(ex.getMessage(),
+          "java.lang.IllegalStateException: The AEQ does not exist for the index index2 region
/index");
+      assertFalse(result);
+    }
   }
 
   @Test()


Mime
View raw message