Package org.apache.cassandra.repair
Class LocalSyncTask
- java.lang.Object
-
- com.google.common.util.concurrent.internal.InternalFutureFailureAccess
-
- com.google.common.util.concurrent.AbstractFuture<SyncStat>
-
- org.apache.cassandra.repair.SyncTask
-
- org.apache.cassandra.repair.LocalSyncTask
-
- All Implemented Interfaces:
com.google.common.util.concurrent.FutureCallback<StreamState>
,com.google.common.util.concurrent.ListenableFuture<SyncStat>
,java.lang.Runnable
,java.util.concurrent.Future<SyncStat>
,StreamEventHandler
public class LocalSyncTask extends SyncTask implements StreamEventHandler
LocalSyncTask performs streaming between local(coordinator) node and remote replica.
-
-
Field Summary
Fields Modifier and Type Field Description boolean
requestRanges
boolean
transferRanges
-
Fields inherited from class org.apache.cassandra.repair.SyncTask
desc, nodePair, previewKind, rangesToSync, startTime, stat
-
-
Constructor Summary
Constructors Constructor Description LocalSyncTask(RepairJobDesc desc, InetAddressAndPort local, InetAddressAndPort remote, java.util.List<Range<Token>> diff, java.util.UUID pendingRepair, boolean requestRanges, boolean transferRanges, PreviewKind previewKind)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
abort()
void
handleStreamEvent(StreamEvent event)
Callback for various streaming events.boolean
isLocal()
void
onFailure(java.lang.Throwable t)
void
onSuccess(StreamState result)
protected void
startSync()
Starts sending/receiving our list of differences to/from the remote endpoint: creates a callback that will be called out of band once the streams complete.java.lang.String
toString()
-
-
-
Constructor Detail
-
LocalSyncTask
public LocalSyncTask(RepairJobDesc desc, InetAddressAndPort local, InetAddressAndPort remote, java.util.List<Range<Token>> diff, java.util.UUID pendingRepair, boolean requestRanges, boolean transferRanges, PreviewKind previewKind)
-
-
Method Detail
-
startSync
protected void startSync()
Starts sending/receiving our list of differences to/from the remote endpoint: creates a callback that will be called out of band once the streams complete.
-
handleStreamEvent
public void handleStreamEvent(StreamEvent event)
Description copied from interface:StreamEventHandler
Callback for various streaming events.- Specified by:
handleStreamEvent
in interfaceStreamEventHandler
- Parameters:
event
- Stream event.- See Also:
StreamEvent.Type
-
onSuccess
public void onSuccess(StreamState result)
- Specified by:
onSuccess
in interfacecom.google.common.util.concurrent.FutureCallback<StreamState>
-
onFailure
public void onFailure(java.lang.Throwable t)
- Specified by:
onFailure
in interfacecom.google.common.util.concurrent.FutureCallback<StreamState>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classcom.google.common.util.concurrent.AbstractFuture<SyncStat>
-
-