mikemccand commented on a change in pull request #1331: LUCENE-9268: Add some
random tests to IndexWriter
URL: https://github.com/apache/lucene-solr/pull/1331#discussion_r389389331
##########
File path: lucene/core/src/test/org/apache/lucene/index/TestIndexWriter.java
##########
@@ -3775,4 +3777,120 @@ public void testRefreshAndRollbackConcurrently()
throws Exception {
IOUtils.close(sm, dir);
}
}
+
+ public void testRandomOperations() throws Exception {
+ IndexWriterConfig iwc = newIndexWriterConfig();
+ iwc.setMergePolicy(new FilterMergePolicy(newMergePolicy()) {
+ boolean keepFullyDeletedSegment = random().nextBoolean();
+
+ @Override
+ public boolean keepFullyDeletedSegment(IOSupplier<CodecReader>
readerIOSupplier) {
+ return keepFullyDeletedSegment;
+ }
+ });
+ try (Directory dir = newDirectory();
+ IndexWriter writer = new IndexWriter(dir, iwc);
+ SearcherManager sm = new SearcherManager(writer, new
SearcherFactory())) {
+ Semaphore permits = new Semaphore(10 + random().nextInt(1000));
+ boolean singleDoc = random().nextBoolean();
+ Thread[] threads = new Thread[1 + random().nextInt(4)];
+ CountDownLatch latch = new CountDownLatch(threads.length);
+ for (int i = 0; i < threads.length; i++) {
+ threads[i] = new Thread(() -> {
+ latch.countDown();
+ try {
+ latch.await();
+ while (permits.tryAcquire()) {
+ String id = singleDoc ? "1" :
Integer.toString(random().nextInt(10));
+ Document doc = new Document();
+ doc.add(new StringField("id", id, Field.Store.YES));
+ if (random().nextInt(10) <= 2) {
+ writer.updateDocument(new Term("id", id), doc);
+ } else if (random().nextInt(10) <= 2) {
+ writer.deleteDocuments(new Term("id", id));
+ } else {
+ writer.addDocument(doc);
+ }
+ if (random().nextInt(100) < 10) {
+ sm.maybeRefreshBlocking();
+ }
+ if (random().nextInt(100) < 5) {
+ writer.commit();
+ }
+ if (random().nextInt(100) < 1) {
+ writer.forceMerge(1 + random().nextInt(10),
random().nextBoolean());
+ }
+ }
+ } catch (Exception e) {
+ throw new AssertionError(e);
+ }
+ });
+ threads[i].start();
+ }
+ for (Thread thread : threads) {
+ thread.join();
+ }
+ }
+ }
+
+ public void testRandomOperationsWithSoftDeletes() throws Exception {
+ IndexWriterConfig iwc = newIndexWriterConfig();
+ AtomicInteger seqNo = new AtomicInteger(-1);
+ AtomicInteger retainingSeqNo = new AtomicInteger();
+ iwc.setSoftDeletesField("soft_deletes");
+ iwc.setMergePolicy(new SoftDeletesRetentionMergePolicy("soft_deletes",
+ () -> LongPoint.newRangeQuery("seq_no", retainingSeqNo.longValue(),
Long.MAX_VALUE), newMergePolicy()));
+ try (Directory dir = newDirectory();
+ IndexWriter writer = new IndexWriter(dir, iwc);
+ SearcherManager sm = new SearcherManager(writer, new
SearcherFactory())) {
+ Semaphore permits = new Semaphore(10 + random().nextInt(1000));
Review comment:
Also here?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@lucene.apache.org
For additional commands, e-mail: issues-h...@lucene.apache.org
