Uses of Interface
org.apache.cassandra.repair.SharedContext

Packages that use SharedContext

Package	Description
org.apache.cassandra.db.repair
org.apache.cassandra.repair
org.apache.cassandra.repair.consistent
org.apache.cassandra.repair.messages
org.apache.cassandra.service
org.apache.cassandra.service.paxos
org.apache.cassandra.service.paxos.cleanup

Uses of SharedContext in org.apache.cassandra.db.repair

Methods in org.apache.cassandra.db.repair with parameters of type SharedContext

Modifier and Type	Method	Description
static Refs<SSTableReader>	CassandraValidationIterator.getSSTablesToValidate(ColumnFamilyStore cfs, SharedContext ctx, Collection<Range<Token>> ranges, TimeUUID parentId, boolean isIncremental)

Constructors in org.apache.cassandra.db.repair with parameters of type SharedContext

Modifier	Constructor	Description
	CassandraTableRepairManager(ColumnFamilyStore cfs, SharedContext ctx)
	CassandraValidationIterator(ColumnFamilyStore cfs, SharedContext ctx, Collection<Range<Token>> ranges, TimeUUID parentId, TimeUUID sessionID, boolean isIncremental, long nowInSec, TopPartitionTracker.Collector topPartitionCollector)

Uses of SharedContext in org.apache.cassandra.repair

Classes in org.apache.cassandra.repair that implement SharedContext

Modifier and Type	Class	Description
static class	SharedContext.ForwardingSharedContext
static class	SharedContext.Global

Fields in org.apache.cassandra.repair declared as SharedContext

Modifier and Type	Field	Description
final SharedContext	RepairSession.ctx
protected final SharedContext	SyncTask.ctx
final SharedContext	Validator.ctx

Methods in org.apache.cassandra.repair that return SharedContext

Modifier and Type	Method	Description
protected SharedContext	SharedContext.ForwardingSharedContext.delegate()
default SharedContext	SharedContext.withMessaging(MessageDelivery messaging)

Methods in org.apache.cassandra.repair with parameters of type SharedContext

Modifier and Type	Method	Description
protected ExecutorPlus	RepairSession.createExecutor(SharedContext ctx)

Constructors in org.apache.cassandra.repair with parameters of type SharedContext

Modifier	Constructor	Description
	AsymmetricRemoteSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort to, InetAddressAndPort from, List<Range<Token>> differences, PreviewKind previewKind)
	ForwardingSharedContext(SharedContext delegate)
	LocalSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort local, InetAddressAndPort remote, List<Range<Token>> diff, TimeUUID pendingRepair, boolean requestRanges, boolean transferRanges, PreviewKind previewKind)
	RepairMessageVerbHandler(SharedContext ctx)
	RepairSession(SharedContext ctx, Scheduler validationScheduler, TimeUUID parentRepairSession, CommonRange commonRange, String keyspace, RepairParallelism parallelismDegree, boolean isIncremental, boolean pullRepair, PreviewKind previewKind, boolean optimiseStreams, boolean repairPaxos, boolean paxosOnly, String... cfnames)	Create new repair session.
	StreamingRepairTask(SharedContext ctx, SyncState state, RepairJobDesc desc, InetAddressAndPort initiator, InetAddressAndPort src, InetAddressAndPort dst, Collection<Range<Token>> ranges, TimeUUID pendingRepair, PreviewKind previewKind, boolean asymmetric)
	SymmetricRemoteSyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort r1, InetAddressAndPort r2, List<Range<Token>> differences, PreviewKind previewKind)
protected	SyncTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort primaryEndpoint, InetAddressAndPort peer, List<Range<Token>> rangesToSync, PreviewKind previewKind)
	ValidationTask(SharedContext ctx, RepairJobDesc desc, InetAddressAndPort endpoint, long nowInSec, PreviewKind previewKind)
	Validator(SharedContext ctx, ValidationState state, long nowInSec, boolean evenTreeDistribution, boolean isIncremental, PreviewKind previewKind)
	Validator(SharedContext ctx, ValidationState state, long nowInSec, boolean isIncremental, PreviewKind previewKind)

Uses of SharedContext in org.apache.cassandra.repair.consistent

Fields in org.apache.cassandra.repair.consistent declared as SharedContext

Modifier and Type	Field	Description
final SharedContext	ConsistentSession.ctx

Methods in org.apache.cassandra.repair.consistent with parameters of type SharedContext

Modifier and Type	Method	Description
static CoordinatorSession.Builder	CoordinatorSession.builder(SharedContext ctx)
static LocalSession.Builder	LocalSession.builder(SharedContext ctx)
CoordinatorSession.Builder	CoordinatorSession.Builder.withContext(SharedContext ctx)

Constructors in org.apache.cassandra.repair.consistent with parameters of type SharedContext

Modifier	Constructor	Description
	Builder(SharedContext ctx)
	Builder(SharedContext ctx)
	CoordinatorSessions(SharedContext ctx)
	LocalSessions(SharedContext ctx)

Uses of SharedContext in org.apache.cassandra.repair.messages

Methods in org.apache.cassandra.repair.messages with parameters of type SharedContext

Modifier and Type	Method	Description
static void	RepairMessage.sendAck(SharedContext ctx, Message<? extends RepairMessage> message)
static void	RepairMessage.sendFailureResponse(SharedContext ctx, Message<?> respondTo)
static void	RepairMessage.sendMessageWithFailureCB(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RepairMessage.RepairFailureCallback failureCallback)
static void	RepairMessage.sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint)
static <T> void	RepairMessage.sendMessageWithRetries(SharedContext ctx, Supplier<Boolean> allowRetry, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback)
static void	RepairMessage.sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint)
static <T> void	RepairMessage.sendMessageWithRetries(SharedContext ctx, RepairMessage request, Verb verb, InetAddressAndPort endpoint, RequestCallback<T> finalCallback)

Uses of SharedContext in org.apache.cassandra.service

Fields in org.apache.cassandra.service declared as SharedContext

Modifier and Type	Field	Description
final SharedContext	ActiveRepairService.ctx

Constructors in org.apache.cassandra.service with parameters of type SharedContext

Modifier	Constructor	Description
	ActiveRepairService(SharedContext ctx)
	ConsistentSessions(SharedContext ctx)

Uses of SharedContext in org.apache.cassandra.service.paxos

Methods in org.apache.cassandra.service.paxos with parameters of type SharedContext

Modifier and Type	Method	Description
static boolean	PaxosRepair.validatePeerCompatibility(SharedContext ctx, TableMetadata table, Collection<Range<Token>> ranges)

Uses of SharedContext in org.apache.cassandra.service.paxos.cleanup

Methods in org.apache.cassandra.service.paxos.cleanup with parameters of type SharedContext

Modifier and Type	Method	Description
static PaxosCleanup	PaxosCleanup.cleanup(SharedContext ctx, Collection<InetAddressAndPort> endpoints, TableMetadata table, Collection<Range<Token>> ranges, boolean skippedReplicas, Executor executor)
static PaxosCleanupLocalCoordinator	PaxosCleanupLocalCoordinator.create(SharedContext ctx, PaxosCleanupRequest request)
static PaxosCleanupLocalCoordinator	PaxosCleanupLocalCoordinator.createForAutoRepair(SharedContext ctx, TableId tableId, Collection<Range<Token>> ranges)
static IVerbHandler<PaxosCleanupComplete.Request>	PaxosCleanupComplete.createVerbHandler(SharedContext ctx)
static IVerbHandler<PaxosCleanupRequest>	PaxosCleanupRequest.createVerbHandler(SharedContext ctx)
static IVerbHandler<PaxosCleanupResponse>	PaxosCleanupResponse.createVerbHandler(SharedContext ctx)
static IVerbHandler<PaxosCleanupHistory>	PaxosFinishPrepareCleanup.createVerbHandler(SharedContext ctx)
static IVerbHandler<PaxosStartPrepareCleanup.Request>	PaxosStartPrepareCleanup.createVerbHandler(SharedContext ctx)
static PaxosFinishPrepareCleanup	PaxosFinishPrepareCleanup.finish(SharedContext ctx, Collection<InetAddressAndPort> endpoints, PaxosCleanupHistory result)
static PaxosStartPrepareCleanup	PaxosStartPrepareCleanup.prepare(SharedContext ctx, TableId tableId, Collection<InetAddressAndPort> endpoints, EndpointState localEpState, Collection<Range<Token>> ranges)	We run paxos repair as part of topology changes, so we include the local endpoint state in the paxos repair prepare message to prevent racing with gossip dissemination and guarantee that every repair participant is aware of the pending ring change during repair.

Constructors in org.apache.cassandra.service.paxos.cleanup with parameters of type SharedContext

Modifier	Constructor	Description
	PaxosCleanup(SharedContext ctx, Collection<InetAddressAndPort> endpoints, TableMetadata table, Collection<Range<Token>> ranges, boolean skippedReplicas, Executor executor)
	PaxosRepairState(SharedContext ctx)