| | |
| | | import org.opends.server.backends.jeb.*; |
| | | |
| | | import com.sleepycat.je.DatabaseException; |
| | | import com.sleepycat.je.Transaction; |
| | | import com.sleepycat.je.LockMode; |
| | | |
| | | import java.util.concurrent.BlockingQueue; |
| | |
| | | |
| | | //Used to synchronize the parent ID map, since multiple worker threads |
| | | //can be accessing it. |
| | | private Object synchObject = new Object(); |
| | | private final Object synchObject = new Object(); |
| | | |
| | | /** |
| | | * The number of LDAP entries added to the database, used to update the |
| | |
| | | * Get the Entry ID of the parent entry. |
| | | * @param parentDN The parent DN. |
| | | * @param dn2id The DN2ID DB. |
| | | * @param txn A database transaction, |
| | | * @return The entry ID of the parent entry. |
| | | * @throws DatabaseException If a DB error occurs. |
| | | */ |
| | | public |
| | | EntryID getParentID(DN parentDN, DN2ID dn2id, Transaction txn) |
| | | EntryID getParentID(DN parentDN, DN2ID dn2id) |
| | | throws DatabaseException { |
| | | EntryID parentID; |
| | | synchronized(synchObject) { |
| | |
| | | return null; |
| | | } |
| | | } |
| | | parentID = dn2id.get(txn, parentDN, LockMode.DEFAULT); |
| | | parentID = dn2id.get(null, parentDN, LockMode.DEFAULT); |
| | | //If the parent is in dn2id, add it to the cache. |
| | | if (parentID != null) { |
| | | synchronized(synchObject) { |