Uses of Class
com.continuent.tungsten.replicator.util.AtomicIntervalGuard

Packages that use AtomicIntervalGuard

com.continuent.tungsten.replicator.thl

Uses of AtomicIntervalGuard in com.continuent.tungsten.replicator.thl

Methods in com.continuent.tungsten.replicator.thl that return AtomicIntervalGuard

AtomicIntervalGuard<?>

THLParallelQueue.getIntervalGuard() Returns the interval guard structure that tracks positions of channels.

Constructors in com.continuent.tungsten.replicator.thl with parameters of type AtomicIntervalGuard

THLParallelReadQueue(int taskId, int maxSize, int maxControlEvents, long startingSeqno, int syncInterval, ReplDBMSHeader lastHeader, AtomicIntervalGuard<?> intervalGuard)
Instantiates a new read queue.

THLParallelReadTask(int taskId, THL thl, Partitioner partitioner, AtomicCounter headSeqnoCounter, AtomicIntervalGuard<?> intervalGuard, int maxSize, int maxControlEvents, int syncInterval, com.continuent.tungsten.fsm.event.EventDispatcher dispatcher)
Instantiate a read task.