You are viewing a plain text version of this content. The canonical link for it is here.
Posted to oak-commits@jackrabbit.apache.org by mr...@apache.org on 2017/12/21 10:42:21 UTC

svn commit: r1818906 - /jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBCacheConsistency2Test.java

Author: mreutegg
Date: Thu Dec 21 10:42:20 2017
New Revision: 1818906

URL: http://svn.apache.org/viewvc?rev=1818906&view=rev
Log:
OAK-7101: Stale documents in RDBDocumentStore cache

Make sure test starts with a fresh set of documents

Modified:
    jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBCacheConsistency2Test.java

Modified: jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBCacheConsistency2Test.java
URL: http://svn.apache.org/viewvc/jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBCacheConsistency2Test.java?rev=1818906&r1=1818905&r2=1818906&view=diff
==============================================================================
--- jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBCacheConsistency2Test.java (original)
+++ jackrabbit/oak/trunk/oak-store-document/src/test/java/org/apache/jackrabbit/oak/plugins/document/rdb/RDBCacheConsistency2Test.java Thu Dec 21 10:42:20 2017
@@ -72,11 +72,17 @@ public class RDBCacheConsistency2Test ex
     @Test
     public void cacheUpdate() throws Exception {
         Revision r = newRevision();
+        List<UpdateOp> ops = Lists.newArrayList();
+        List<String> ids = Lists.newArrayList();
         for (int i = 0; i < NUM_NODES; i++) {
             String id = Utils.getIdFromPath("/node-" + i);
+            ids.add(id);
             UpdateOp op = new UpdateOp(id, true);
             NodeDocument.setLastRev(op, r);
+            ops.add(op);
         }
+        ds.remove(NODES, ids);
+        ds.create(NODES, ops);
 
         for (int i = 0; i < 1000; i++) {
             Thread q = new Thread(new Runnable() {