| | |
| | | import org.opends.server.loggers.debug.DebugTracer; |
| | | import org.opends.server.replication.common.ChangeNumber; |
| | | import org.opends.server.replication.common.ServerState; |
| | | import org.opends.server.replication.server.DraftCNDB.*; |
| | | import org.opends.server.replication.server.DraftCNDB.DraftCNDBCursor; |
| | | import org.opends.server.types.Attribute; |
| | | import org.opends.server.types.Attributes; |
| | | import org.opends.server.types.InitializationException; |
| | |
| | | private boolean shutdown = false; |
| | | private boolean trimDone = false; |
| | | private DirectoryThread thread = null; |
| | | private final Object flushLock = new Object(); |
| | | private ReplicationServer replicationServer; |
| | | |
| | | // The maximum number of retries in case of DatabaseDeadlock Exception. |
| | |
| | | db.addEntry(key, value, serviceID, cn); |
| | | |
| | | if (debugEnabled()) |
| | | TRACER.debugInfo("In DraftCNDbhandler.add, added: " |
| | | TRACER.debugInfo( |
| | | "In DraftCNDbhandler.add, added: " |
| | | + " key=" + key |
| | | + " value=" + value |
| | | + " serviceID=" + serviceID |