Package org.apache.cassandra.repair.consistent

Class CoordinatorSessions

java.lang.Object

org.apache.cassandra.repair.consistent.CoordinatorSessions

public class CoordinatorSessions
extends Object

Container for all consistent repair sessions a node is coordinating

Constructor Summary

Constructors

Constructor	Description
CoordinatorSessions(SharedContext ctx)

Method Summary

Modifier and Type	Method	Description
protected CoordinatorSession	buildSession(CoordinatorSession.Builder builder)
CoordinatorSession	getSession(TimeUUID sessionId)
void	handleFailSessionMessage(FailSession msg)
void	handleFinalizePromiseMessage(Message<? extends RepairMessage> message)
void	handlePrepareResponse(Message<? extends RepairMessage> msg)
void	onSessionStateUpdate(CoordinatorSession session)
CoordinatorSession	registerSession(TimeUUID sessionId, Set<InetAddressAndPort> participants, boolean isForced)

Methods inherited from class java.lang.Object

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

Constructor Details

CoordinatorSessions

public CoordinatorSessions(SharedContext ctx)

Method Details

buildSession

protected CoordinatorSession buildSession(CoordinatorSession.Builder builder)

registerSession

public CoordinatorSession registerSession(TimeUUID sessionId,
 Set<InetAddressAndPort> participants,
 boolean isForced)
                                   throws NoSuchRepairSessionException

Throws:

NoSuchRepairSessionException

getSession

public CoordinatorSession getSession(TimeUUID sessionId)

onSessionStateUpdate

public void onSessionStateUpdate(CoordinatorSession session)

handlePrepareResponse

public void handlePrepareResponse(Message<? extends RepairMessage> msg)

handleFinalizePromiseMessage

public void handleFinalizePromiseMessage(Message<? extends RepairMessage> message)

handleFailSessionMessage

public void handleFailSessionMessage(FailSession msg)