import quincy beta 17.1.0

[ceph.git] / ceph / src / rocksdb / java / src / test / java / org / rocksdb / util / BytewiseComparatorTest.java

diff --git a/ceph/src/rocksdb/java/src/test/java/org/rocksdb/util/BytewiseComparatorTest.java b/ceph/src/rocksdb/java/src/test/java/org/rocksdb/util/BytewiseComparatorTest.java
index 2e2ddc543767acc41a25a1d1f670c3c8ccfdf922..69f2c282b02c8aa65ad06286fc205ab347a81111 100644 (file)
--- a/ceph/src/rocksdb/java/src/test/java/org/rocksdb/util/BytewiseComparatorTest.java
+++ b/ceph/src/rocksdb/java/src/test/java/org/rocksdb/util/BytewiseComparatorTest.java
@@ -263,7 +263,7 @@ public class BytewiseComparatorTest {
       for (int i = 0; i < num_iter_ops; i++) {
         // Random walk and make sure iter and result_iter returns the
         // same key and value
-        final int type = rnd.nextInt(7);
+        final int type = rnd.nextInt(8);
         iter.status();
         switch (type) {
           case 0:
@@ -310,8 +310,15 @@ public class BytewiseComparatorTest {
               continue;
             }
             break;
+          case 6:
+            // Refresh
+            iter.refresh();
+            result_iter.refresh();
+            iter.seekToFirst();
+            result_iter.seekToFirst();
+            break;
           default: {
-            assert (type == 6);
+            assert (type == 7);
             final int key_idx = rnd.nextInt(source_strings.size());
             final String key = source_strings.get(key_idx);
             final byte[] result = db.get(readOptions, bytes(key));
@@ -472,6 +479,11 @@ public class BytewiseComparatorTest {
       }
     }
 
+    @Override
+    public void refresh() throws RocksDBException {
+      offset = -1;
+    }
+
     @Override
     public void status() throws RocksDBException {
       if(offset < 0 || offset >= entries.size()) {