org.corfudb.protocols.wireprotocol.failuredetector

Class NodeConnectivity

java.lang.Object

org.corfudb.protocols.wireprotocol.failuredetector.NodeConnectivity

All Implemented Interfaces:

Comparable<NodeConnectivity>, ICorfuPayload<NodeConnectivity>

public class NodeConnectivity
extends Object
implements ICorfuPayload<NodeConnectivity>, Comparable<NodeConnectivity>

Represents a degree of a node (the number of connections it has to other nodes) https://en.wikipedia.org/wiki/Degree_distribution

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NodeConnectivity.ConnectionStatus Node connection status
static class	NodeConnectivity.NodeConnectivityType

Nested classes/interfaces inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

ICorfuPayload.PayloadConstructor<T>

Field Summary

Fields inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

constructorMap, lookup

Constructor Summary

Constructors

Constructor and Description
NodeConnectivity(io.netty.buffer.ByteBuf buf)

Method Summary

Modifier and Type	Method and Description
int	compareTo(NodeConnectivity other) Compare node connectivity's according to their endpoints
static NodeConnectivity	connectivity(String endpoint, com.google.common.collect.ImmutableMap<String,NodeConnectivity.ConnectionStatus> connectivity) Factory method to build a node connectivity
void	doSerialize(io.netty.buffer.ByteBuf buf)
int	getConnected() Get number of nodes this node is connected to
Set<String>	getConnectedNodes() Contains list of servers successfully connected with current node.
NodeConnectivity.ConnectionStatus	getConnectionStatus(String node) Returns node status: connected, disconnected
Set<String>	getFailedNodes() Contains list of servers disconnected from this node.
static NodeConnectivity	notReady(String endpoint) Builds a new connectivity with NOT_READY state
static NodeConnectivity	unavailable(String endpoint) Builds a new connectivity with unavailable state

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.corfudb.protocols.wireprotocol.ICorfuPayload

enumMapFromBuffer, fromBuffer, fromBuffer, listFromBuffer, mapFromBuffer, rangeFromBuffer, rangeSetFromBuffer, serialize, setFromBuffer

Constructor Detail

NodeConnectivity

public NodeConnectivity(io.netty.buffer.ByteBuf buf)

Method Detail

doSerialize

public void doSerialize(io.netty.buffer.ByteBuf buf)

Specified by:

doSerialize in interface ICorfuPayload<NodeConnectivity>

getConnectedNodes

public Set<String> getConnectedNodes()

Contains list of servers successfully connected with current node.

getFailedNodes

public Set<String> getFailedNodes()

Contains list of servers disconnected from this node. If the node A can't ping node B then node B will be added to failedNodes list.

getConnectionStatus

public NodeConnectivity.ConnectionStatus getConnectionStatus(String node)

Returns node status: connected, disconnected

Parameters:

node - node name

Returns:

node status

getConnected

public int getConnected()

Get number of nodes this node is connected to

Returns:

number of connected nodes

compareTo

public int compareTo(NodeConnectivity other)

Compare node connectivity's according to their endpoints

Specified by:

compareTo in interface Comparable<NodeConnectivity>

Parameters:

other - another node connectivity

Returns:

a negative integer, zero, or a positive integer as this object is less than, equal to, or greater than the specified object.

connectivity

public static NodeConnectivity connectivity(String endpoint,
                                            com.google.common.collect.ImmutableMap<String,NodeConnectivity.ConnectionStatus> connectivity)

Factory method to build a node connectivity

Parameters:

endpoint - node name

connectivity - connectivity matrix

Returns:

NodeConnectivity

unavailable

public static NodeConnectivity unavailable(String endpoint)

Builds a new connectivity with unavailable state

Parameters:

endpoint - node name

Returns:

NodeConnectivity

notReady

public static NodeConnectivity notReady(String endpoint)

Builds a new connectivity with NOT_READY state

Parameters:

endpoint - node name

Returns:

NodeConnectivity