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>
-
-
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()
-
-
-
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()
-
run
public void run()
-
stopOperations
public void stopOperations() throws InterruptedException
- Throws:
InterruptedException
-
-