Author: tomekr
Date: Fri Nov 25 10:18:49 2016
New Revision: 1771274
URL: http://svn.apache.org/viewvc?rev=1771274&view=rev
Log:
OAK-4912: MongoDB: ReadPreferenceIT.testMongoReadPreferencesForLocalChanges()
occasionally fails
Modified:
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/ReadPreferenceIT.java
Modified:
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/ReadPreferenceIT.java
URL:
http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/ReadPreferenceIT.java?rev=1771274&r1=1771273&r2=1771274&view=diff
==============================================================================
---
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/ReadPreferenceIT.java
(original)
+++
jackrabbit/oak/trunk/oak-core/src/test/java/org/apache/jackrabbit/oak/plugins/document/mongo/ReadPreferenceIT.java
Fri Nov 25 10:18:49 2016
@@ -188,12 +188,17 @@ public class ReadPreferenceIT extends Ab
// make the secondary up-to-date
long now = Revision.getCurrentTimestamp();
primary.addRevision(now, 0, 1, false);
+ primary.addRevision(now, 0, 2, false);
secondary.addRevision(now, 0, 1, false);
+ secondary.addRevision(now, 0, 2, false);
replica.updateRevisions();
// local change has been replicated by now, it's fine to use secondary
- assertEquals(testPref,
- mongoDS.getMongoReadPreference(NODES, null, "/x/y",
DocumentReadPreference.PREFER_SECONDARY_IF_OLD_ENOUGH));
+ for (int i = 0; i < 400; i++) {
+ assertEquals(testPref,
+ mongoDS.getMongoReadPreference(NODES, null, "/x/y",
DocumentReadPreference.PREFER_SECONDARY_IF_OLD_ENOUGH));
+ Thread.sleep(5);
+ }
}
@Test
