com.alipay.sofa.jraft.storage.log

Class RocksDBSegmentLogStorage.BarrierWriteContext

java.lang.Object

com.alipay.sofa.jraft.storage.log.RocksDBSegmentLogStorage.BarrierWriteContext

All Implemented Interfaces:

RocksDBLogStorage.WriteContext

Enclosing class:

RocksDBSegmentLogStorage

public static class RocksDBSegmentLogStorage.BarrierWriteContext
extends Object
implements RocksDBLogStorage.WriteContext

Constructor Summary

Constructors

Constructor and Description
BarrierWriteContext()

Method Summary

Modifier and Type	Method and Description
void	addFinishHook(Runnable r) Adds a callback that will be invoked after all sub jobs finish.
void	finishJob() Finish a sub job
void	joinAll() Wait for all sub jobs finish.
void	setError(Exception e) Set an exception to context.
void	startJob() Start a sub job.

Methods inherited from class java.lang.Object

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

Constructor Detail

BarrierWriteContext

public BarrierWriteContext()

Method Detail

startJob

public void startJob()

Description copied from interface: RocksDBLogStorage.WriteContext

Start a sub job.

Specified by:

startJob in interface RocksDBLogStorage.WriteContext

addFinishHook

public void addFinishHook(Runnable r)

Description copied from interface: RocksDBLogStorage.WriteContext

Adds a callback that will be invoked after all sub jobs finish.

Specified by:

addFinishHook in interface RocksDBLogStorage.WriteContext

finishJob

public void finishJob()

Description copied from interface: RocksDBLogStorage.WriteContext

Finish a sub job

Specified by:

finishJob in interface RocksDBLogStorage.WriteContext

setError

public void setError(Exception e)

Description copied from interface: RocksDBLogStorage.WriteContext

Set an exception to context.

Specified by:

setError in interface RocksDBLogStorage.WriteContext

Parameters:

e - exception

joinAll

public void joinAll()
             throws InterruptedException,
                    IOException

Description copied from interface: RocksDBLogStorage.WriteContext

Wait for all sub jobs finish.

Specified by:

joinAll in interface RocksDBLogStorage.WriteContext

Throws:

InterruptedException

IOException