Package | Description |
---|---|
de.zib.scalaris |
This package contains means to communicate with the erlang scalaris ring from Java.
|
Modifier and Type | Method and Description |
---|---|
PeerNode |
Connection.getRemote()
Gets the remote node connected to.
|
PeerNode |
ConnectionPolicy.selectNode()
Selects the node to connect with when establishing a connection (no
failed node, no exception that has already been thrown).
|
<E extends Exception> |
DefaultConnectionPolicy.selectNode(int retry,
PeerNode failedNode,
E e)
Selects the node to (re-)connect with until the maximal number of
DefaultConnectionPolicy.maxRetries has been reached. |
abstract <E extends Exception> |
ConnectionPolicy.selectNode(int retry,
PeerNode failedNode,
E e)
Selects the node to (re-)connect with.
|
<E extends Exception> |
FixedNodeConnectionPolicy.selectNode(int retry,
PeerNode failedNode,
E e) |
Modifier and Type | Method and Description |
---|---|
List<PeerNode> |
DefaultConnectionPolicy.getBadNodes()
Gets a copy of the list of good nodes (contains references to the
PeerNode objects). |
List<PeerNode> |
DefaultConnectionPolicy.getGoodNodes()
Gets a copy of the list of good nodes (contains references to the
PeerNode objects). |
List<PeerNode> |
ConnectionFactory.getNodes()
Gets a copy of the list of nodes available for connections.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectionFactory.addNode(PeerNode node)
Adds a node to the set of nodes available for connections.
|
void |
DefaultConnectionPolicy.availableNodeAdded(PeerNode newNode)
Adds the given node to the
DefaultConnectionPolicy.goodNodes list if it has no failures,
otherwise it will be added to DefaultConnectionPolicy.badNodes . |
void |
ConnectionPolicy.availableNodeAdded(PeerNode newNode)
Signals the connection policy that the given node has been added to the
list of available nodes.
|
void |
DefaultConnectionPolicy.availableNodeRemoved(PeerNode removedNode)
Removes the node from the
DefaultConnectionPolicy.goodNodes and DefaultConnectionPolicy.badNodes lists. |
void |
ConnectionPolicy.availableNodeRemoved(PeerNode removedNode)
Signals the connection policy that the given node has been removed from
the list of available nodes.
|
void |
DefaultConnectionPolicy.nodeConnectSuccess(PeerNode node)
Sets the node's last successful connect time stamp, resets its failure
statistics and moves it to the
DefaultConnectionPolicy.goodNodes list. |
void |
ConnectionPolicy.nodeConnectSuccess(PeerNode node)
Acts upon a successful connect attempt of the given node.
|
void |
DefaultConnectionPolicy.nodeFailed(PeerNode node)
Sets the given node's last failed connect time stamp and moves it to the
DefaultConnectionPolicy.badNodes list. |
void |
ConnectionPolicy.nodeFailed(PeerNode node)
Acts upon a failure of the given node.
|
void |
DefaultConnectionPolicy.nodeFailReset(PeerNode node)
Acts upon a failure reset of the given node.
|
void |
ConnectionPolicy.nodeFailReset(PeerNode node)
Acts upon a failure reset of the given node.
|
void |
ConnectionFactory.removeNode(PeerNode node)
Removes a node from the set of nodes available for connections.
|
<E extends Exception> |
DefaultConnectionPolicy.selectNode(int retry,
PeerNode failedNode,
E e)
Selects the node to (re-)connect with until the maximal number of
DefaultConnectionPolicy.maxRetries has been reached. |
abstract <E extends Exception> |
ConnectionPolicy.selectNode(int retry,
PeerNode failedNode,
E e)
Selects the node to (re-)connect with.
|
<E extends Exception> |
FixedNodeConnectionPolicy.selectNode(int retry,
PeerNode failedNode,
E e) |
void |
ConnectionFactory.setNode(PeerNode node)
Sets the name of the node to connect to.
|
Modifier and Type | Method and Description |
---|---|
void |
ConnectionPool.closeAllBut(Collection<PeerNode> remainingNodes)
Closes all available pooled connections to any node not in the given
collection.
|
Constructor and Description |
---|
Connection(OtpSelf self,
PeerNode remote)
Creates a new connection using the given nodes and a default connection
policy.
|
ConnectionPolicy(PeerNode remoteNode)
Creates a connection policy with one available node to connect to.
|
DefaultConnectionPolicy(PeerNode remoteNode)
Creates a new connection policy working with the given remote node.
|
FixedNodeConnectionPolicy(PeerNode remoteNode)
Creates a new connection policy working with the given remote node.
|
RoundRobinConnectionPolicy(PeerNode remoteNode)
Creates a new connection policy working with the given remote node.
|
ScalarisVM(PeerNode node)
Creates a connection to the erlang VM of the given Scalaris node.
|
Constructor and Description |
---|
ConnectionPolicy(List<PeerNode> availableRemoteNodes)
Creates a connection policy with the given set of nodes available for
connections.
|
DefaultConnectionPolicy(List<PeerNode> availableRemoteNodes)
Creates a new connection policy with the given remote nodes.
|
RoundRobinConnectionPolicy(List<PeerNode> availableRemoteNodes)
Creates a new connection policy with the given remote nodes.
|