org.corfudb.runtime.view

Class RuntimeLayout

java.lang.Object

org.corfudb.runtime.view.RuntimeLayout

public class RuntimeLayout
extends Object

This is a wrapper over the layout to provide the clients required to communicate with the nodes.

Created by zlokhandwala on 3/8/18.

Constructor Summary

Constructors

Constructor and Description
RuntimeLayout(Layout layout, CorfuRuntime corfuRuntime) Constructor taking a reference of the layout to stamp the clients.

Method Summary

Modifier and Type	Method and Description
BaseClient	getBaseClient(String endpoint)
LayoutClient	getLayoutClient(String endpoint)
LogUnitClient	getLogUnitClient(long address, int index)
LogUnitClient	getLogUnitClient(String endpoint)
ManagementClient	getManagementClient(String endpoint)
SequencerClient	getPrimarySequencerClient()
SequencerClient	getSequencerClient(String endpoint)
void	sealMinServerSet() Attempts to move all servers in the system to the epoch of this layout.

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeLayout

public RuntimeLayout(@Nonnull
                     Layout layout,
                     @Nonnull
                     CorfuRuntime corfuRuntime)

Constructor taking a reference of the layout to stamp the clients.

Method Detail

sealMinServerSet

public void sealMinServerSet()
                      throws WrongEpochException,
                             QuorumUnreachableException

Attempts to move all servers in the system to the epoch of this layout. The seal however waits only for a response from a quorum of layout servers (n/2 + 1), a quorum of log unit servers in every stripe in case of QUORUM_REPLICATION or at least one log unit server in every stripe in case of CHAIN_REPLICATION. The fault detector eventually corrects out of phase epochs by resealing the servers.

Throws:

WrongEpochException - If any server is in a higher epoch.

QuorumUnreachableException - If enough number of servers cannot be sealed.

getBaseClient

public BaseClient getBaseClient(String endpoint)

getLayoutClient

public LayoutClient getLayoutClient(String endpoint)

getPrimarySequencerClient

public SequencerClient getPrimarySequencerClient()

getSequencerClient

public SequencerClient getSequencerClient(String endpoint)

getLogUnitClient

public LogUnitClient getLogUnitClient(long address,
                                      int index)

getLogUnitClient

public LogUnitClient getLogUnitClient(String endpoint)

getManagementClient

public ManagementClient getManagementClient(String endpoint)