Package org.apache.cassandra.db.commitlog

Class AbstractCommitLogService

java.lang.Object

org.apache.cassandra.db.commitlog.AbstractCommitLogService

Direct Known Subclasses:

GroupCommitLogService

public abstract class AbstractCommitLogService
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Semaphore	haveWork
protected long	lastSyncedAt
protected final AtomicLong	pending
protected final WaitQueue	syncComplete

Method Summary

Modifier and Type	Method	Description
void	awaitTermination()
void	finishWriteFor(CommitLogSegment.Allocation alloc)	Block for @param alloc to be sync'd as necessary, and handle bookkeeping
long	getCompletedTasks()
long	getPendingTasks()
protected abstract void	maybeWaitForSync(CommitLogSegment.Allocation alloc)
void	shutdown()
void	syncBlocking()	Request sync and wait until the current state is synced.

Methods inherited from class java.lang.Object

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

Field Details

lastSyncedAt

protected volatile long lastSyncedAt

pending

protected final AtomicLong pending

syncComplete

protected final WaitQueue syncComplete

haveWork

protected final Semaphore haveWork

Method Details

finishWriteFor

public void finishWriteFor(CommitLogSegment.Allocation alloc)

Block for @param alloc to be sync'd as necessary, and handle bookkeeping

maybeWaitForSync

protected abstract void maybeWaitForSync(CommitLogSegment.Allocation alloc)

shutdown

public void shutdown()

syncBlocking

public void syncBlocking()

Request sync and wait until the current state is synced. Note: If a sync is in progress at the time of this request, the call will return after both it and a cycle initiated immediately afterwards complete.

awaitTermination

public void awaitTermination()
                      throws InterruptedException

Throws:

InterruptedException

getCompletedTasks

public long getCompletedTasks()

getPendingTasks

public long getPendingTasks()