| | |
| | | * This class publishes some monitoring information below <code> |
| | | * cn=monitor</code>. |
| | | */ |
| | | public class DraftCNDbHandler implements ChangeNumberIndexDB |
| | | public class DraftCNDbHandler implements ChangeNumberIndexDB, Runnable |
| | | { |
| | | /** |
| | | * The tracer object for the debug logger. |
| | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public synchronized void add(int changeNumber, String previousCookie, |
| | | public synchronized void add(long changeNumber, String previousCookie, |
| | | String baseDN, CSN csn) |
| | | { |
| | | db.addEntry(changeNumber, previousCookie, baseDN, csn); |
| | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public int getFirstChangeNumber() |
| | | public long getFirstChangeNumber() |
| | | { |
| | | return db.readFirstChangeNumber(); |
| | | } |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public int getLastChangeNumber() |
| | | public long getLastChangeNumber() |
| | | { |
| | | return db.readLastChangeNumber(); |
| | | } |
| | |
| | | * @throws ChangelogException |
| | | * if a database problem occurs. |
| | | */ |
| | | DraftCNDBCursor getReadCursor(int startChangeNumber) |
| | | DraftCNDBCursor getReadCursor(long startChangeNumber) |
| | | throws ChangelogException |
| | | { |
| | | return db.openReadCursor(startChangeNumber); |
| | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public ChangeNumberIndexDBCursor getCursorFrom(int startChangeNumber) |
| | | public ChangeNumberIndexDBCursor getCursorFrom(long startChangeNumber) |
| | | throws ChangelogException |
| | | { |
| | | return new DraftCNDbIterator(db, startChangeNumber); |
| | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public String getPreviousCookie(int changeNumber) |
| | | public String getPreviousCookie(long changeNumber) |
| | | { |
| | | DraftCNDBCursor cursor = null; |
| | | try |
| | |
| | | |
| | | /** {@inheritDoc} */ |
| | | @Override |
| | | public CSN getCSN(int changeNumber) |
| | | public CSN getCSN(long changeNumber) |
| | | { |
| | | DraftCNDBCursor cursor = null; |
| | | try |
| | |
| | | |
| | | /**{@inheritDoc}*/ |
| | | @Override |
| | | public String getBaseDN(int changeNumber) |
| | | public String getBaseDN(long changeNumber) |
| | | { |
| | | DraftCNDBCursor cursor = null; |
| | | try |
| | |
| | | } |
| | | } |
| | | |
| | | private void debugException(String methodName, int changeNumber, Exception e) |
| | | private void debugException(String methodName, long changeNumber, Exception e) |
| | | { |
| | | if (debugEnabled()) |
| | | TRACER.debugInfo("In DraftCNDbHandler." + methodName + "(), read: " |