Package org.apache.cassandra.gms

Class EndpointState

java.lang.Object

org.apache.cassandra.gms.EndpointState

public class EndpointState
extends Object

This abstraction represents both the HeartBeatState and the ApplicationState in an EndpointState instance. Any state for a given endpoint can be retrieved from this instance.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	logger
static final IVersionedSerializer<EndpointState>	nullableSerializer
static final IVersionedSerializer<EndpointState>	serializer

Constructor Summary

Constructors

Constructor	Description
EndpointState(EndpointState other)
EndpointState(HeartBeatState initialHbState)
EndpointState(HeartBeatState initialHbState, Map<ApplicationState,VersionedValue> states)

Method Summary

Modifier and Type	Method	Description
void	addApplicationState(ApplicationState key, VersionedValue value)
void	addApplicationStates(Map<ApplicationState,VersionedValue> values)
void	addApplicationStates(Set<Map.Entry<ApplicationState,VersionedValue>> values)
void	addApplicationStates(Set<Map.Entry<ApplicationState,VersionedValue>> values, HeartBeatState hbState)
boolean	containsApplicationState(ApplicationState key)
void	forceHighestPossibleVersionUnsafe()
void	forceNewerGenerationUnsafe()
VersionedValue	getApplicationState(ApplicationState key)
HeartBeatState	getHeartBeatState()
CassandraVersion	getReleaseVersion()
UUID	getSchemaVersion()
String	getStatus()
long	getUpdateTimestamp()
boolean	isAlive()
boolean	isEmptyWithoutStatus()
boolean	isNormalState()
boolean	isRpcReady()
boolean	isStateEmpty()
boolean	isSupersededBy(EndpointState that)
void	markAlive()
void	markDead()
Set<Map.Entry<ApplicationState,VersionedValue>>	states()
String	toString()
void	unsafeSetUpdateTimestamp(long value)
void	updateHeartBeat()

Methods inherited from class java.lang.Object

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

Field Details

logger

protected static final org.slf4j.Logger logger

serializer

public static final IVersionedSerializer<EndpointState> serializer

nullableSerializer

public static final IVersionedSerializer<EndpointState> nullableSerializer

Constructor Details

EndpointState

public EndpointState(HeartBeatState initialHbState)

EndpointState

public EndpointState(EndpointState other)

EndpointState

public EndpointState(HeartBeatState initialHbState,
 Map<ApplicationState,VersionedValue> states)

Method Details

getHeartBeatState

public HeartBeatState getHeartBeatState()

updateHeartBeat

public void updateHeartBeat()

forceNewerGenerationUnsafe

public void forceNewerGenerationUnsafe()

forceHighestPossibleVersionUnsafe

public void forceHighestPossibleVersionUnsafe()

getApplicationState

public VersionedValue getApplicationState(ApplicationState key)

containsApplicationState

public boolean containsApplicationState(ApplicationState key)

states

public Set<Map.Entry<ApplicationState,VersionedValue>> states()

addApplicationState

public void addApplicationState(ApplicationState key,
 VersionedValue value)

addApplicationStates

public void addApplicationStates(Map<ApplicationState,VersionedValue> values)

addApplicationStates

public void addApplicationStates(Set<Map.Entry<ApplicationState,VersionedValue>> values)

addApplicationStates

public void addApplicationStates(Set<Map.Entry<ApplicationState,VersionedValue>> values,
 @Nullable
 HeartBeatState hbState)

getUpdateTimestamp

public long getUpdateTimestamp()

Returns:

System.nanoTime() when state was updated last time.

unsafeSetUpdateTimestamp

public void unsafeSetUpdateTimestamp(long value)

isAlive

public boolean isAlive()

markAlive

public void markAlive()

markDead

public void markDead()

isStateEmpty

public boolean isStateEmpty()

isEmptyWithoutStatus

public boolean isEmptyWithoutStatus()

Returns:

true if HeartBeatState.isEmpty() is true and no STATUS application state exists

isRpcReady

public boolean isRpcReady()

isNormalState

public boolean isNormalState()

getStatus

public String getStatus()

getSchemaVersion

@Nullable
public UUID getSchemaVersion()

getReleaseVersion

@Nullable
public CassandraVersion getReleaseVersion()

toString

public String toString()

Overrides:

toString in class Object

isSupersededBy

public boolean isSupersededBy(EndpointState that)