+++ /dev/null
-package org.apache.lucene.index;
-
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with this
- * work for additional information regarding copyright ownership. The ASF
- * licenses this file to You under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
- * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
- * License for the specific language governing permissions and limitations under
- * the License.
- */
-
-import java.io.IOException;
-import java.util.Map;
-import java.util.Map.Entry;
-
-import org.apache.lucene.document.Document;
-import org.apache.lucene.index.IndexWriterConfig.OpenMode;
-import org.apache.lucene.store.Directory;
-import org.apache.lucene.store.LockObtainFailedException;
-import org.junit.After;
-import org.junit.Before;
-import org.junit.Test;
-
-public class TestPersistentSnapshotDeletionPolicy extends TestSnapshotDeletionPolicy {
-
- // Keep it a class member so that getDeletionPolicy can use it
- private Directory snapshotDir;
-
- // so we can close it if called by SDP tests
- private PersistentSnapshotDeletionPolicy psdp;
-
- @Before
- @Override
- public void setUp() throws Exception {
- super.setUp();
- snapshotDir = newDirectory();
- }
-
- @After
- @Override
- public void tearDown() throws Exception {
- if (psdp != null) psdp.close();
- snapshotDir.close();
- super.tearDown();
- }
-
- @Override
- protected SnapshotDeletionPolicy getDeletionPolicy() throws IOException {
- if (psdp != null) psdp.close();
- snapshotDir.close();
- snapshotDir = newDirectory();
- return psdp = new PersistentSnapshotDeletionPolicy(
- new KeepOnlyLastCommitDeletionPolicy(), snapshotDir, OpenMode.CREATE,
- TEST_VERSION_CURRENT);
- }
-
- @Override
- protected SnapshotDeletionPolicy getDeletionPolicy(Map<String, String> snapshots) throws IOException {
- SnapshotDeletionPolicy sdp = getDeletionPolicy();
- if (snapshots != null) {
- for (Entry<String, String> e: snapshots.entrySet()) {
- sdp.registerSnapshotInfo(e.getKey(), e.getValue(), null);
- }
- }
- return sdp;
- }
-
- @Override
- @Test
- public void testExistingSnapshots() throws Exception {
- int numSnapshots = 3;
- Directory dir = newDirectory();
- PersistentSnapshotDeletionPolicy psdp = (PersistentSnapshotDeletionPolicy) getDeletionPolicy();
- IndexWriter writer = new IndexWriter(dir, getConfig(random, psdp));
- prepareIndexAndSnapshots(psdp, writer, numSnapshots, "snapshot");
- writer.close();
- psdp.close();
-
- // Re-initialize and verify snapshots were persisted
- psdp = new PersistentSnapshotDeletionPolicy(
- new KeepOnlyLastCommitDeletionPolicy(), snapshotDir, OpenMode.APPEND,
- TEST_VERSION_CURRENT);
- new IndexWriter(dir, getConfig(random, psdp)).close();
-
- assertSnapshotExists(dir, psdp, numSnapshots);
- assertEquals(numSnapshots, psdp.getSnapshots().size());
- psdp.close();
- dir.close();
- }
-
- @Test(expected=IllegalArgumentException.class)
- public void testIllegalSnapshotId() throws Exception {
- getDeletionPolicy().snapshot("$SNAPSHOTS_DOC$");
- }
-
- @Test
- public void testInvalidSnapshotInfos() throws Exception {
- // Add the correct number of documents (1), but without snapshot information
- IndexWriter writer = new IndexWriter(snapshotDir, getConfig(random, null));
- writer.addDocument(new Document());
- writer.close();
- try {
- new PersistentSnapshotDeletionPolicy(
- new KeepOnlyLastCommitDeletionPolicy(), snapshotDir, OpenMode.APPEND,
- TEST_VERSION_CURRENT);
- fail("should not have succeeded to read from an invalid Directory");
- } catch (IllegalStateException e) {
- }
- }
-
- @Test
- public void testNoSnapshotInfos() throws Exception {
- // Initialize an empty index in snapshotDir - PSDP should initialize successfully.
- new IndexWriter(snapshotDir, getConfig(random, null)).close();
- new PersistentSnapshotDeletionPolicy(
- new KeepOnlyLastCommitDeletionPolicy(), snapshotDir, OpenMode.APPEND,
- TEST_VERSION_CURRENT).close();
- }
-
- @Test(expected=IllegalStateException.class)
- public void testTooManySnapshotInfos() throws Exception {
- // Write two documents to the snapshots directory - illegal.
- IndexWriter writer = new IndexWriter(snapshotDir, getConfig(random, null));
- writer.addDocument(new Document());
- writer.addDocument(new Document());
- writer.close();
-
- new PersistentSnapshotDeletionPolicy(
- new KeepOnlyLastCommitDeletionPolicy(), snapshotDir, OpenMode.APPEND,
- TEST_VERSION_CURRENT).close();
- fail("should not have succeeded to open an invalid directory");
- }
-
- @Test
- public void testSnapshotRelease() throws Exception {
- Directory dir = newDirectory();
- PersistentSnapshotDeletionPolicy psdp = (PersistentSnapshotDeletionPolicy) getDeletionPolicy();
- IndexWriter writer = new IndexWriter(dir, getConfig(random, psdp));
- prepareIndexAndSnapshots(psdp, writer, 1, "snapshot");
- writer.close();
-
- psdp.release("snapshot0");
- psdp.close();
-
- psdp = new PersistentSnapshotDeletionPolicy(
- new KeepOnlyLastCommitDeletionPolicy(), snapshotDir, OpenMode.APPEND,
- TEST_VERSION_CURRENT);
- assertEquals("Should have no snapshots !", 0, psdp.getSnapshots().size());
- psdp.close();
- dir.close();
- }
-
- @Test
- public void testStaticRead() throws Exception {
- // While PSDP is open, it keeps a lock on the snapshots directory and thus
- // prevents reading the snapshots information. This test checks that the
- // static read method works.
- int numSnapshots = 1;
- Directory dir = newDirectory();
- PersistentSnapshotDeletionPolicy psdp = (PersistentSnapshotDeletionPolicy) getDeletionPolicy();
- IndexWriter writer = new IndexWriter(dir, getConfig(random, psdp));
- prepareIndexAndSnapshots(psdp, writer, numSnapshots, "snapshot");
- writer.close();
- dir.close();
-
- try {
- // This should fail, since the snapshots directory is locked - we didn't close it !
- new PersistentSnapshotDeletionPolicy(
- new KeepOnlyLastCommitDeletionPolicy(), snapshotDir, OpenMode.APPEND,
- TEST_VERSION_CURRENT);
- fail("should not have reached here - the snapshots directory should be locked!");
- } catch (LockObtainFailedException e) {
- // expected
- } finally {
- psdp.close();
- }
-
- // Reading the snapshots info should succeed though
- Map<String, String> snapshots = PersistentSnapshotDeletionPolicy.readSnapshotsInfo(snapshotDir);
- assertEquals("expected " + numSnapshots + " snapshots, got " + snapshots.size(), numSnapshots, snapshots.size());
- }
-
-}
fnp / pylucene.git / blobdiff