Package org.apache.activemq.artemis.core.paging.impl

Class PageTimedWriter

java.lang.Object

org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

org.apache.activemq.artemis.core.paging.impl.PageTimedWriter

All Implemented Interfaces:

Runnable, ActiveMQComponent

public class PageTimedWriter
extends ActiveMQScheduledComponent

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PageTimedWriter.PageEvent

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<PageTimedWriter.PageEvent>	pageEvents
protected int	pendingTasks
protected final boolean	syncNonTX

Fields inherited from class org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

executor, scheduledExecutorService

Constructor Summary

Constructors

Constructor	Description
PageTimedWriter(int writeCredits, StorageManager storageManager, PagingStoreImpl pagingStore, ScheduledExecutorService scheduledExecutor, Executor executor, boolean syncNonTX, long timeSync)

Method Summary

Modifier and Type	Method	Description
int	addTask(OperationContext context, PagedMessage message, Transaction tx, RouteContextList listCtx, boolean useFlowControl)
void	flowControl(int credits)
int	getAvailablePermits()
int	getMaxCredits()
boolean	hasPendingIO()
void	incrementTask()	We increment task while holding the readLock.
protected void	performSync()
protected void	processMessages()
void	run()
void	stop()

Methods inherited from class org.apache.activemq.artemis.core.server.ActiveMQScheduledComponent

delay, getInitialDelay, getPeriod, getThreadFactory, getTimeUnit, isStarted, setInitialDelay, setInitialDelayAndPeriod, setInitialDelayAndPeriod, setPeriod, setPeriod, setTimeUnit, start

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop

Field Details

pageEvents

protected final List<PageTimedWriter.PageEvent> pageEvents

pendingTasks

protected volatile int pendingTasks

syncNonTX

protected final boolean syncNonTX

Constructor Details

PageTimedWriter

public PageTimedWriter(int writeCredits,
 StorageManager storageManager,
 PagingStoreImpl pagingStore,
 ScheduledExecutorService scheduledExecutor,
 Executor executor,
 boolean syncNonTX,
 long timeSync)

Method Details

hasPendingIO

public boolean hasPendingIO()

getMaxCredits

public int getMaxCredits()

stop

public void stop()

Specified by:

stop in interface ActiveMQComponent

Overrides:

stop in class ActiveMQScheduledComponent

incrementTask

public void incrementTask()

We increment task while holding the readLock. This is because we verify if the system is paging, and we get out of paging when no pending tasks and no pending messages. We allocate a task while holding the read Lock. We cannot call addTask within the lock as if the semaphore gets out of credits we would deadlock in certain cases.

addTask

public int addTask(OperationContext context,
 PagedMessage message,
 Transaction tx,
 RouteContextList listCtx,
 boolean useFlowControl)

flowControl

public void flowControl(int credits)

run

public void run()

processMessages

protected void processMessages()

performSync

protected void performSync()
                    throws Exception

Throws:

Exception

getAvailablePermits

public int getAvailablePermits()