You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ds...@apache.org on 2016/02/18 00:10:48 UTC
[13/33] incubator-geode git commit: GEODE-550 CI failure:
FixedPRSinglehopDUnitTest.test_MetadataContents
GEODE-550 CI failure: FixedPRSinglehopDUnitTest.test_MetadataContents
This test hasn't failed in over 3 months and that was on a private build
with no artifacts. I've changed the test to include details about the
end state of the client's metadata so that if this test fails again we
will know more about why it failed.
I'm closing the ticket so that CI monitors will reopen it and not just
report that it failed again in an email.
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/6f0a3294
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/6f0a3294
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/6f0a3294
Branch: refs/heads/feature/GEODE-831
Commit: 6f0a3294c61cac2129176f3f6eefb9c423be9561
Parents: 5a65498
Author: Bruce Schuchardt <bs...@pivotal.io>
Authored: Thu Feb 11 16:18:01 2016 -0800
Committer: Bruce Schuchardt <bs...@pivotal.io>
Committed: Fri Feb 12 08:09:18 2016 -0800
----------------------------------------------------------------------
.../cache/FixedPRSinglehopDUnitTest.java | 57 ++++++++++----------
1 file changed, 30 insertions(+), 27 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6f0a3294/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/FixedPRSinglehopDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/FixedPRSinglehopDUnitTest.java b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/FixedPRSinglehopDUnitTest.java
index 86376d9..d3c51b1 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/FixedPRSinglehopDUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/internal/cache/FixedPRSinglehopDUnitTest.java
@@ -16,8 +16,14 @@
*/
package com.gemstone.gemfire.internal.cache;
-import com.gemstone.gemfire.DataSerializable;
-import com.gemstone.gemfire.DataSerializer;
+import java.io.File;
+import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+
import com.gemstone.gemfire.cache.AttributesFactory;
import com.gemstone.gemfire.cache.Cache;
import com.gemstone.gemfire.cache.CacheFactory;
@@ -38,27 +44,18 @@ import com.gemstone.gemfire.distributed.internal.DistributionConfig;
import com.gemstone.gemfire.internal.AvailablePort;
import com.gemstone.gemfire.internal.cache.partitioned.fixed.QuarterPartitionResolver;
import com.gemstone.gemfire.internal.cache.partitioned.fixed.SingleHopQuarterPartitionResolver;
-import com.gemstone.gemfire.internal.cache.partitioned.fixed.FixedPartitioningTestBase.Q1_Months;
import com.gemstone.gemfire.internal.cache.tier.sockets.CacheServerTestUtil;
import com.gemstone.gemfire.test.dunit.Assert;
+import com.gemstone.gemfire.test.dunit.DistributedTestCase;
import com.gemstone.gemfire.test.dunit.Host;
import com.gemstone.gemfire.test.dunit.LogWriterUtils;
import com.gemstone.gemfire.test.dunit.NetworkUtils;
+import com.gemstone.gemfire.test.dunit.SerializableCallableIF;
+import com.gemstone.gemfire.test.dunit.SerializableRunnableIF;
import com.gemstone.gemfire.test.dunit.VM;
import com.gemstone.gemfire.test.dunit.Wait;
import com.gemstone.gemfire.test.dunit.WaitCriterion;
-import java.io.DataInput;
-import java.io.DataOutput;
-import java.io.File;
-import java.io.IOException;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
-import java.util.Properties;
-import java.util.Map.Entry;
-
public class FixedPRSinglehopDUnitTest extends CacheTestCase {
private static final long serialVersionUID = 1L;
@@ -98,7 +95,7 @@ public class FixedPRSinglehopDUnitTest extends CacheTestCase {
public FixedPRSinglehopDUnitTest(String name) {
super(name);
}
-
+
public void testNoClientConnected() {
final Host host = Host.getHost(0);
VM accessorServer = host.getVM(0);
@@ -204,6 +201,7 @@ public class FixedPRSinglehopDUnitTest extends CacheTestCase {
verifyEmptyStaticData();
}
+
// 4 servers, 1 client connected to all 4 servers.
// Put data, get data and make the metadata stable.
// Now verify that metadata has all 8 buckets info.
@@ -252,16 +250,18 @@ public class FixedPRSinglehopDUnitTest extends CacheTestCase {
getFromPartitionedRegions();
- server1.invoke(FixedPRSinglehopDUnitTest.class, "printView");
- server2.invoke(FixedPRSinglehopDUnitTest.class, "printView");
- server3.invoke(FixedPRSinglehopDUnitTest.class, "printView");
- server4.invoke(FixedPRSinglehopDUnitTest.class, "printView");
+ SerializableRunnableIF printView = () -> FixedPRSinglehopDUnitTest.printView();
+ server1.invoke(printView);
+ server2.invoke(printView);
+ server3.invoke(printView);
+ server4.invoke(printView);
int totalBucketOnServer = 0;
- totalBucketOnServer += (Integer)server1.invoke(FixedPRSinglehopDUnitTest.class, "totalNumBucketsCreated");
- totalBucketOnServer += (Integer)server2.invoke(FixedPRSinglehopDUnitTest.class, "totalNumBucketsCreated");
- totalBucketOnServer += (Integer)server3.invoke(FixedPRSinglehopDUnitTest.class, "totalNumBucketsCreated");
- totalBucketOnServer += (Integer)server4.invoke(FixedPRSinglehopDUnitTest.class, "totalNumBucketsCreated");
+ SerializableCallableIF<Integer> getBucketCount = () -> FixedPRSinglehopDUnitTest.totalNumBucketsCreated();
+ totalBucketOnServer += server1.invoke(getBucketCount);
+ totalBucketOnServer += server2.invoke(getBucketCount);
+ totalBucketOnServer += server3.invoke(getBucketCount);
+ totalBucketOnServer += server4.invoke(getBucketCount);
verifyMetadata(totalBucketOnServer,2);
updateIntoSinglePR();
@@ -873,13 +873,16 @@ public class FixedPRSinglehopDUnitTest extends CacheTestCase {
}
public String description() {
- return "expected no metadata to be refreshed";
+ return "expected no metadata to be refreshed. Expected " + totalBuckets
+ + " entries but found " + prMetaData.getBucketServerLocationsMap_TEST_ONLY();
}
};
Wait.waitForCriterion(wc, 60000, 1000, true);
- for (Entry entry : prMetaData.getBucketServerLocationsMap_TEST_ONLY()
- .entrySet()) {
- assertEquals(currentRedundancy, ((List)entry.getValue()).size());
+ System.out.println("metadata is " + prMetaData);
+ System.out.println("metadata bucket locations map is " + prMetaData.getBucketServerLocationsMap_TEST_ONLY());
+ for (Map.Entry entry : prMetaData.getBucketServerLocationsMap_TEST_ONLY().entrySet()) {
+ assertEquals("list has wrong contents: " + entry.getValue(),
+ currentRedundancy, ((List)entry.getValue()).size());
}
}