Package org.apache.cassandra.repair

Class RepairCoordinator

java.lang.Object

org.apache.cassandra.repair.RepairCoordinator

All Implemented Interfaces:

Runnable, RepairNotifier, ProgressEventNotifier

public class RepairCoordinator
extends Object
implements Runnable, ProgressEventNotifier, RepairNotifier

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	RepairCoordinator.NeighborsAndRanges

Field Summary

Fields

Modifier and Type	Field	Description
protected final AtomicReference<Throwable>	firstError
final CoordinatorState	state

Constructor Summary

Constructors

Constructor	Description
RepairCoordinator(StorageService storageService, int cmd, RepairOption options, String keyspace)

Method Summary

Modifier and Type	Method	Description
void	addProgressListener(ProgressListener listener)	Register progress listener to this publisher.
protected void	fail(String reason)
protected void	fireProgressEvent(ProgressEvent event)
void	notification(String msg)
void	notifyError(Throwable error)
void	notifyProgress(String message)
void	removeProgressListener(ProgressListener listener)	Remove progress listener from this publisher.
void	run()

Methods inherited from class java.lang.Object

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

Field Details

state

public final CoordinatorState state

firstError

protected final AtomicReference<Throwable> firstError

Constructor Details

RepairCoordinator

public RepairCoordinator(StorageService storageService,
 int cmd,
 RepairOption options,
 String keyspace)

Method Details

addProgressListener

public void addProgressListener(ProgressListener listener)

Description copied from interface: ProgressEventNotifier

Register progress listener to this publisher.

Specified by:

addProgressListener in interface ProgressEventNotifier

Parameters:

listener - listener to register.

removeProgressListener

public void removeProgressListener(ProgressListener listener)

Description copied from interface: ProgressEventNotifier

Remove progress listener from this publisher.

Specified by:

removeProgressListener in interface ProgressEventNotifier

Parameters:

listener - listener to remove

fireProgressEvent

protected void fireProgressEvent(ProgressEvent event)

notification

public void notification(String msg)

Specified by:

notification in interface RepairNotifier

notifyError

public void notifyError(Throwable error)

Specified by:

notifyError in interface RepairNotifier

notifyProgress

public void notifyProgress(String message)

Specified by:

notifyProgress in interface RepairNotifier

fail

protected void fail(String reason)

run

public void run()

Specified by:

run in interface Runnable