| Method Summary |
|
| public void | deleteCheckpointTable()
Delete all entries from the CheckpointTable. |
| public void | deleteLogEntriesAndCheckpointBetween(long commonCheckpointId, long nowCheckpointId)
Delete all log entries that have an id strictly between the 2 given
boundaries (commonCheckpointId |
| public void | deleteLogEntriesBeforeId(long oldId)
Delete all LogEntries with an identifier lower than oldId (inclusive). |
| public PreparedStatement | getLogPreparedStatement()
|
| public synchronized boolean | getLogQueueIsEmpty()
|
| public Trace | getLogger()
Returns the logger value. |
| public long | getNumberOfLogEntries(long lowerLogId, long upperLogId)
Return the real number of log entries between 2 log ids (usually matching
checkpoint indices). |
| public RecoveryLog | getRecoveryLog()
Returns the recoveryLog value. |
| public PreparedStatement | getUpdatePreparedStatement()
|
| public synchronized boolean | hasLogEntryForTransaction(long tid)
Returns true if there is any log event in the queue that belongs to the
given transaction. |
| public void | invalidateLogStatements()
Invalidate both logStmt and unlogStmt so that they can be renewed from a
fresh connection. |
| public synchronized void | log(LogEvent logObject)
Log a write-query into the recovery log. |
| public synchronized void | putBackAtHeadOfQueue(LogEvent event, Exception e)
Put back a log entry at the head of the queue in case a problem happened
with this entry and we need to retry it right away. |
| public void | removeCheckpoint(String checkpointName)
Remove a checkpoint in the recovery log.
In case of error, additionely close and invalidates log and unlog
statements (internal) before calling
RecoveryLog#invalidateInternalConnection(). |
| public boolean | removeEmptyTransaction(long transactionId)
Remove a possibly empty transaction from the recovery log. |
| public synchronized void | removeQueriesOfTransactionFromQueue(long tid)
Remove all queries that have not been logged yet and belonging to the
specified transaction. |
| public void | run()
Log the requests from queue until the thread is explicetly killed. |
| public void | shiftLogEntriesAfterId(long fromId, long shiftValue)
Shift LogEntries identifiers from the specified shiftValue (value is added
to existing identifiers) starting with identifier with a value strictly
greater than the given id. |
| public void | shiftLogEntriesIds(long shiftValue)
Shift LogEntries identifiers from the specified value (value is added to
existing identifiers). |
| public synchronized void | shutdown()
Shutdown the current thread. |
| public void | storeCheckpointWithLogId(String checkpointName, long checkpointLogId)
Store a checkpoint in the recovery log using the provided local log id.
Moreover, in case of error, additionally closes and invalidates log and
unlog statements (internal) before calling
RecoveryLog#invalidateInternalConnection(). |
