- scan(JournalFile[]) - Method in class org.hornetq.core.journal.impl.Reclaimer
-
- scheduleCompactAndBlock(int) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
-
- scheduleCompactAndBlock(int) - Method in class org.hornetq.core.journal.impl.JournalImpl
-
- scheduleCompactAndBlock(int) - Method in interface org.hornetq.core.journal.Journal
-
This method will start compact using the compactorExecutor and block up to timeout seconds
- seqOutOfOrder() - Method in interface org.hornetq.journal.HornetQJournalLogger
-
- sequentialFile - Variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
-
- SequentialFile - Interface in org.hornetq.core.journal
-
A SequentialFile
- SequentialFileFactory - Interface in org.hornetq.core.journal
-
A SequentialFileFactory
- setAutoReclaim(boolean) - Method in class org.hornetq.core.journal.impl.JournalImpl
-
- setAutoReclaim(boolean) - Method in interface org.hornetq.core.journal.TestableJournal
-
- setBufferCallback(BufferCallback) - Method in interface org.hornetq.core.asyncio.AsynchronousFile
-
- setBufferCallback(BufferCallback) - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
-
- setBufferCallback(BufferCallback) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
-
- setCanReclaim(boolean) - Method in interface org.hornetq.core.journal.impl.JournalFile
-
Whether this file's contents can deleted and the file reused.
- setCanReclaim(boolean) - Method in class org.hornetq.core.journal.impl.JournalFileImpl
-
- setCompactCount(short) - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
-
- setCompacting() - Method in class org.hornetq.core.journal.impl.JournalTransaction
-
- setDelegateCompletion(IOAsyncTask) - Method in class org.hornetq.core.journal.impl.TransactionCallback
-
- setExecutor(Executor) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
-
- setFileID(int) - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
-
- setMaxID(long) - Method in class org.hornetq.core.journal.JournalLoadInformation
-
- setNanoSleepInterval(int) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
-
Instead of passing the nanoSeconds through the stack call every time, we set it statically inside the native method
- setNextFileID(long) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
-
Set the {link #nextFileID} value to targetUpdate
if the current value is less than
targetUpdate
.
- setNumberOfRecords(int) - Method in class org.hornetq.core.journal.impl.dataformat.JournalCompleteRecordTX
-
- setNumberOfRecords(int) - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
-
- setNumberOfRecords(int) - Method in class org.hornetq.core.journal.JournalLoadInformation
-
- setObserver(TimedBufferObserver) - Method in class org.hornetq.core.journal.impl.TimedBuffer
-
- setOffset(long) - Method in class org.hornetq.core.journal.impl.JournalFileImpl
-
- setTimedBuffer(TimedBuffer) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
-
- setTimedBuffer(TimedBuffer) - Method in interface org.hornetq.core.journal.SequentialFile
-
- setUpCurrentFile(int) - Method in class org.hornetq.core.journal.impl.JournalImpl
-
- setupFactory() - Method in class org.hornetq.core.journal.impl.SyncSpeedTest
-
- setUseSleep(boolean) - Method in class org.hornetq.core.journal.impl.TimedBuffer
-
- SimpleWaitIOCallback - Class in org.hornetq.core.journal.impl
-
A SimpleWaitIOCallback
- SimpleWaitIOCallback() - Constructor for class org.hornetq.core.journal.impl.SimpleWaitIOCallback
-
- size() - Method in interface org.hornetq.core.asyncio.AsynchronousFile
-
Warning: This function will perform a synchronous IO, probably translating to a fstat call
- size() - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
-
- size() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
-
- size() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
-
- size() - Method in interface org.hornetq.core.journal.SequentialFile
-
- SIZE_ADD_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- SIZE_ADD_RECORD_TX - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- SIZE_COMMIT_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- SIZE_COMPLETE_TRANSACTION_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- SIZE_DELETE_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- SIZE_DELETE_RECORD_TX - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- SIZE_HEADER - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- SIZE_PREPARE_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- SIZE_ROLLBACK_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
-
- sleep(int, int) - Method in class org.hornetq.core.journal.impl.TimedBuffer
-
Sub classes (tests basically) can use this to override how the sleep is being done
- start() - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
-
- start() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
-
- start() - Method in class org.hornetq.core.journal.impl.JournalImpl
-
- start() - Method in class org.hornetq.core.journal.impl.TimedBuffer
-
- start() - Method in interface org.hornetq.core.journal.SequentialFileFactory
-
- startingThread() - Method in interface org.hornetq.journal.HornetQJournalLogger
-
- startSpin() - Method in class org.hornetq.core.journal.impl.TimedBuffer
-
Sub classes (tests basically) can use this to override disabling spinning
- stop() - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
-
- stop() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
-
- stop() - Method in class org.hornetq.core.journal.impl.JournalImpl
-
- stop() - Method in class org.hornetq.core.journal.impl.TimedBuffer
-
- stop() - Method in interface org.hornetq.core.journal.SequentialFileFactory
-
- stopSpin() - Method in class org.hornetq.core.journal.impl.TimedBuffer
-
Sub classes (tests basically) can use this to override disabling spinning
- storeLineUp() - Method in class org.hornetq.core.journal.impl.SimpleWaitIOCallback
-
- storeLineUp() - Method in interface org.hornetq.core.journal.IOCompletion
-
- switchFileIfNecessary(int) - Method in class org.hornetq.core.journal.impl.JournalImpl
-
- sync() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
-
- sync() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
-
- sync() - Method in interface org.hornetq.core.journal.SequentialFile
-
- synchronizationLock() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
-
- synchronizationLock() - Method in class org.hornetq.core.journal.impl.JournalImpl
-
- synchronizationLock() - Method in interface org.hornetq.core.journal.Journal
-
Write lock the Journal and write lock the compacting process.
- synchronizationUnlock() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
-
- synchronizationUnlock() - Method in class org.hornetq.core.journal.impl.JournalImpl
-
- synchronizationUnlock() - Method in interface org.hornetq.core.journal.Journal
-
Unlock the Journal and the compacting process.
- SyncIOCompletion - Class in org.hornetq.core.journal.impl
-
Internal class used to manage explicit syncs on the Journal through callbacks.
- SyncIOCompletion() - Constructor for class org.hornetq.core.journal.impl.SyncIOCompletion
-
- SyncSpeedTest - Class in org.hornetq.core.journal.impl
-
A SyncSpeedTest
This class just provides some diagnostics on how fast your disk can sync
Useful when determining performance issues
- SyncSpeedTest() - Constructor for class org.hornetq.core.journal.impl.SyncSpeedTest
-