| | |
| | | import java.util.concurrent.BlockingQueue; |
| | | import java.util.concurrent.TimeUnit; |
| | | import java.util.*; |
| | | import org.opends.server.util.*; |
| | | |
| | | import com.sleepycat.je.*; |
| | | |
| | |
| | | */ |
| | | private boolean stopRequested = false; |
| | | |
| | | private Transaction txn = null; |
| | | |
| | | //The substring buffer manager to use. |
| | | private BufferManager bufferMgr; |
| | |
| | | private void |
| | | processIndexesEntryDelete(WorkElement element, Entry existingEntry, |
| | | EntryID entryID) |
| | | throws DatabaseException { |
| | | throws DatabaseException, DirectoryException, JebException { |
| | | DNContext context = element.getContext(); |
| | | Map<AttributeType, AttributeIndex> attrIndexMap = |
| | | context.getAttrIndexMap(); |
| | |
| | | delete(index, existingEntry, entryID); |
| | | } |
| | | } |
| | | for(VLVIndex vlvIdx : context.getEntryContainer().getVLVIndexes()) { |
| | | vlvIdx.removeEntry(txn, entryID, existingEntry); |
| | | } |
| | | } |
| | | } |
| | | |
| | | |
| | | /** |
| | | * Process all indexes using the specified entry ID. |
| | | * |
| | |
| | | */ |
| | | private void |
| | | processIndexesEntry(WorkElement element, EntryID entryID) |
| | | throws DatabaseException { |
| | | throws DatabaseException, DirectoryException, JebException { |
| | | Entry entry = element.getEntry(); |
| | | DNContext context = element.getContext(); |
| | | LDIFImportConfig ldifImportConfig = context.getLDIFImportConfig(); |
| | |
| | | if((index=attributeIndex.getApproximateIndex()) != null) { |
| | | insert(index, entry, entryID); |
| | | } |
| | | for(VLVIndex vlvIdx : context.getEntryContainer().getVLVIndexes()) { |
| | | vlvIdx.addEntry(txn, entryID, entry); |
| | | } |
| | | } |
| | | } |
| | | } |