Package | Description |
---|---|
org.corfudb.runtime.view |
Modifier and Type | Method and Description |
---|---|
Layout |
LayoutView.prepare(long epoch,
long rank)
Sends prepare to the current layout and can proceed only if it is accepted by a quorum.
|
Layout |
LayoutView.propose(long epoch,
long rank,
Layout layout)
Proposes new layout to all the servers in the current layout.
|
void |
RuntimeLayout.sealMinServerSet()
Attempts to move all servers in the system to the epoch of this layout.
|
void |
LayoutView.updateLayout(Layout layout,
long rank)
Drives the consensus protocol for persisting the new Layout.
|
abstract void |
Layout.ReplicationMode.validateSegmentSeal(Layout.LayoutSegment layoutSegment,
Map<String,CompletableFuture<Boolean>> completableFutureMap)
Seals the layout segment.
|
static void |
SealServersHelper.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 |
SealServersHelper.waitForLayoutSeal(List<String> layoutServers,
Map<String,CompletableFuture<Boolean>> completableFutureMap)
Wait for a quorum of layout servers to respond to be sealed.
|
static void |
SealServersHelper.waitForQuorum(CompletableFuture<Boolean>[] completableFutures)
Wait for a quorum of responses from the completable futures.
|
static void |
SealServersHelper.waitForQuorumSegmentSeal(Layout.LayoutSegment layoutSegment,
Map<String,CompletableFuture<Boolean>> completableFutureMap)
Wait for a quorum of log unit servers to respond to be sealed.
|
Copyright © 2019 CorfuDB. All rights reserved.