org.corfudb.runtime.view

Class SealServersHelper

java.lang.Object

org.corfudb.runtime.view.SealServersHelper

public class SealServersHelper
extends Object

Helper class to seal requested servers.

Created by zlokhandwala on 3/10/17.

Constructor Summary

Constructors

Constructor and Description
SealServersHelper()

Method Summary

Modifier and Type	Method and Description
static Map<String,CompletableFuture<Boolean>>	asyncSealServers(RuntimeLayout runtimeLayout) Asynchronously seal all servers in layout by setting remote epochs.
static void	waitForChainSegmentSeal(Layout.LayoutSegment layoutSegment, Map<String,CompletableFuture<Boolean>> completableFutureMap) Wait for at least one log unit servers in every stripe to be sealed.
static void	waitForLayoutSeal(List<String> layoutServers, Map<String,CompletableFuture<Boolean>> completableFutureMap) Wait for a quorum of layout servers to respond to be sealed.
static void	waitForQuorum(CompletableFuture<Boolean>[] completableFutures) Wait for a quorum of responses from the completable futures.
static void	waitForQuorumSegmentSeal(Layout.LayoutSegment layoutSegment, Map<String,CompletableFuture<Boolean>> completableFutureMap) Wait for a quorum of log unit servers to respond to be sealed.

Methods inherited from class java.lang.Object

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

Constructor Detail

SealServersHelper

public SealServersHelper()

Method Detail

asyncSealServers

public static Map<String,CompletableFuture<Boolean>> asyncSealServers(RuntimeLayout runtimeLayout)

Asynchronously seal all servers in layout by setting remote epochs. Different type of servers can have their own logic of sealing, the base server dispatches sealing logic to each individual server.

Parameters:

runtimeLayout - RuntimeLayout stamped with the layout to be sealed.

Returns:

A map of completableFutures for every remoteSetEpoch call.

waitForLayoutSeal

public static void waitForLayoutSeal(List<String> layoutServers,
                                     Map<String,CompletableFuture<Boolean>> completableFutureMap)
                              throws QuorumUnreachableException

Wait for a quorum of layout servers to respond to be sealed.

Parameters:

layoutServers - List of layout servers.

completableFutureMap - A map of completableFutures for every remoteSetEpoch call.

Throws:

QuorumUnreachableException - Thrown if responses not received from a majority of layout servers.

waitForChainSegmentSeal

public static void waitForChainSegmentSeal(Layout.LayoutSegment layoutSegment,
                                           Map<String,CompletableFuture<Boolean>> completableFutureMap)
                                    throws QuorumUnreachableException

Wait for at least one log unit servers in every stripe to be sealed.

Parameters:

layoutSegment - Layout segment to be sealed.

completableFutureMap - A map of completableFutures for every remoteSetEpoch call.

Throws:

QuorumUnreachableException - Thrown if responses not received from all the log unit servers.

waitForQuorumSegmentSeal

public static void waitForQuorumSegmentSeal(Layout.LayoutSegment layoutSegment,
                                            Map<String,CompletableFuture<Boolean>> completableFutureMap)
                                     throws QuorumUnreachableException

Wait for a quorum of log unit servers to respond to be sealed.

Parameters:

layoutSegment - Layout segment to be sealed.

completableFutureMap - A map of completableFutures for every remoteSetEpoch call.

Throws:

QuorumUnreachableException - Thrown if responses not received from all the log unit servers.

waitForQuorum

public static void waitForQuorum(CompletableFuture<Boolean>[] completableFutures)
                          throws QuorumUnreachableException

Wait for a quorum of responses from the completable futures.

Parameters:

completableFutures - An array of completableFutures of which a quorum is required.

Throws:

QuorumUnreachableException - Thrown if enough responses not received.