com.splicemachine.si.impl

Class ManualKeepAliveScheduler

java.lang.Object

com.splicemachine.si.impl.ManualKeepAliveScheduler

All Implemented Interfaces:

KeepAliveScheduler

public class ManualKeepAliveScheduler
extends java.lang.Object
implements KeepAliveScheduler

Specific Keep-Alive Scheduler to allow us to timeout and/or keep Alive transactions at our leisure, for testing purposes.

Constructor Summary

Constructors

Constructor and Description
ManualKeepAliveScheduler(TxnStore store)

Method Summary

Modifier and Type	Method and Description
void	keepAlive(long txnId)
void	keepAliveAll()
void	scheduleKeepAlive(Txn txn) Schedule the transaction for keep alive.
void	start() Start the scheduler, including any resources associated with it.
void	stop() Stop the scheduler.

Methods inherited from class java.lang.Object

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

Constructor Detail

ManualKeepAliveScheduler

public ManualKeepAliveScheduler(TxnStore store)

Method Detail

scheduleKeepAlive

public void scheduleKeepAlive(Txn txn)

Description copied from interface: KeepAliveScheduler

Schedule the transaction for keep alive. If the transaction is in a known terminal state (e.g. if you schedule a committed or rolled back transaction) at submission time, then this will not schedule it further. If the scheduler is shut down, then this method will perform no action.

Specified by:

scheduleKeepAlive in interface KeepAliveScheduler

Parameters:

txn - the transaction to keep alive.

keepAlive

public void keepAlive(long txnId)
               throws java.io.IOException

Throws:

java.io.IOException

start

public void start()

Description copied from interface: KeepAliveScheduler

Start the scheduler, including any resources associated with it.

Specified by:

start in interface KeepAliveScheduler

stop

public void stop()

Description copied from interface: KeepAliveScheduler

Stop the scheduler. Future keep-alive scheduling requests will be ignored.

Specified by:

stop in interface KeepAliveScheduler

keepAliveAll

public void keepAliveAll()
                  throws java.io.IOException

Throws:

java.io.IOException