IndexBuffer.java revision 641e89ef0e15c9edde69f3b8cf82c7dd5f68687a
/*
* CDDL HEADER START
*
* The contents of this file are subject to the terms of the
* Common Development and Distribution License, Version 1.0 only
* (the "License"). You may not use this file except in compliance
* with the License.
*
* You can obtain a copy of the license at legal-notices/CDDLv1_0.txt
* See the License for the specific language governing permissions
* and limitations under the License.
*
* When distributing Covered Code, include this CDDL HEADER in each
* file and include the License file at legal-notices/CDDLv1_0.txt.
* If applicable, add the following below this CDDL HEADER, with the
* fields enclosed by brackets "[]" replaced with your own identifying
* information:
* Portions Copyright [yyyy] [name of copyright owner]
*
* CDDL HEADER END
*
*
* Copyright 2006-2008 Sun Microsystems, Inc.
* Portions Copyright 2014-2015 ForgeRock AS
*/
/**
* A buffered index is used to buffer multiple reads or writes to the
* same index key into a single read or write.
* <p>
* It can only be used to buffer multiple reads and writes under
* the same transaction. The transaction may be null if it is known
* that there are no other concurrent updates to the index.
*/
@SuppressWarnings("javadoc")
class IndexBuffer
{
/** Internal interface for IndexBuffer implementor. */
private interface IndexBufferImplementor
{
}
/**
* A buffered index is used to buffer multiple reads or writes to the same index key into a single read or write.
* <p>
* It can only be used to buffer multiple reads and writes under the same transaction. The transaction may be null if
* it is known that there are no other concurrent updates to the index.
*/
private static final class DefaultIndexBuffer implements IndexBufferImplementor
{
/**
* The buffered records stored as a map from the record key to the buffered value for that key for each index.
* <p>
* The map is sorted by {@link TreeName}s to establish a deterministic iteration order (see {@link AbstractTree}).
* This prevents potential deadlock for db having pessimistic lock strategy (e.g.: JE).
*/
private final SortedMap<Index, SortedMap<ByteString, BufferedIndexValues>> bufferedIndexes = new TreeMap<>();
/**
* The buffered records stored as a set of buffered VLV values for each index.
* <p>
* The map is sorted by {@link TreeName}s to establish a deterministic iteration order (see {@link AbstractTree}).
* This prevents potential deadlock for db having pessimistic lock strategy (e.g.: JE).
*/
/**
* A simple class representing a pair of added and deleted indexed IDs. Initially both addedIDs and deletedIDs are
* {@code null} indicating that that the whole record should be deleted.
*/
private static class BufferedIndexValues
{
private EntryIDSet addedEntryIDs;
private EntryIDSet deletedEntryIDs;
{
{
if (this.addedEntryIDs == null)
{
this.addedEntryIDs = newDefinedSet();
}
}
}
{
{
if (this.deletedEntryIDs == null)
{
this.deletedEntryIDs = newDefinedSet();
}
}
}
{
}
}
/** A simple class representing a pair of added and deleted VLV values. */
private static class BufferedVLVIndexValues
{
{
{
if (addedSortKeys == null)
{
addedSortKeys = new TreeSet<>();
}
}
}
{
{
if (deletedSortKeys == null)
{
deletedSortKeys = new TreeSet<>();
}
}
}
{
}
}
{
if (bufferedValues == null)
{
bufferedValues = new BufferedVLVIndexValues();
}
return bufferedValues;
}
{
{
values = new BufferedIndexValues();
}
return values;
}
{
if (bufferedOperations == null)
{
bufferedOperations = new TreeMap<>();
}
return bufferedOperations;
}
{
// Indexes are stored in sorted map to prevent deadlock during flush with DB using pessimistic lock strategies.
{
}
{
}
}
{
}
{
}
{
}
{
}
{
{
}
}
}
/**
* IndexBuffer used during import which actually doesn't buffer modifications but forward those directly to the
* supplied {@link WriteableTransaction}.
*/
private static final class ImportIndexBuffer implements IndexBufferImplementor
{
private final WriteableTransaction txn;
private final EntryID expectedEntryID;
private final ByteString encodedEntryID;
{
this.expectedEntryID = expectedEntryID;
}
{
}
{
}
{
// Nothing to do
}
{
throw new UnsupportedOperationException();
}
{
throw new UnsupportedOperationException();
}
}
private final IndexBufferImplementor impl;
{
}
public IndexBuffer()
{
this(new DefaultIndexBuffer());
}
{
}
/**
* Flush the buffered index changes to storage.
*
* @param txn
* a non null transaction
* @throws StorageRuntimeException
* If an error occurs in the storage.
* @throws DirectoryException
* If a Directory Server error occurs.
*/
{
}
{
}
{
}
{
}
{
}
}