Package org.infinispan.persistence.sifs
Class LogAppender
- java.lang.Object
-
- java.lang.Thread
-
- org.infinispan.persistence.sifs.LogAppender
-
- All Implemented Interfaces:
Runnable
public class LogAppender extends Thread
This component has the only thread that polls the queue with requests to write some entry into the cache store. It writes the records to append-only log files, inserts the entry position into TemporaryTable and queues the position to be persisted in Index.- Author:
- Radim Vansa <rvansa@redhat.com>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class java.lang.Thread
Thread.State, Thread.UncaughtExceptionHandler
-
-
Field Summary
-
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
clearAndPause()
void
pause()
void
resumeAfterPause()
void
run()
void
setSeqId(long seqId)
void
stopOperations()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Method Detail
-
setSeqId
public void setSeqId(long seqId)
-
pause
public void pause() throws InterruptedException
- Throws:
InterruptedException
-
clearAndPause
public void clearAndPause() throws InterruptedException
- Throws:
InterruptedException
-
resumeAfterPause
public void resumeAfterPause()
-
stopOperations
public void stopOperations() throws InterruptedException
- Throws:
InterruptedException
-
-