org.corfudb.runtime.view.replication

Class ReadWaitHoleFillPolicy

java.lang.Object

org.corfudb.runtime.view.replication.ReadWaitHoleFillPolicy

All Implemented Interfaces:

IHoleFillPolicy

public class ReadWaitHoleFillPolicy
extends Object
implements IHoleFillPolicy

A hole filling policy which reads several times, waiting a static amount of time in between, before requiring a hole fill.

Created by mwei on 4/6/17.

Constructor Summary

Constructors

Constructor and Description
ReadWaitHoleFillPolicy(Duration holeFillThreshold, Duration retryWaitThreshold) Create a ReadWaitHoleFillPolicy with the given wait times and retries.

Method Summary

Modifier and Type	Method and Description
ILogData	peekUntilHoleFillRequired(long address, Function<Long,ILogData> peekFunction) Apply the given peek function until hole filling is required or committed data is returned.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadWaitHoleFillPolicy

public ReadWaitHoleFillPolicy(Duration holeFillThreshold,
                              Duration retryWaitThreshold)

Create a ReadWaitHoleFillPolicy with the given wait times and retries.

Parameters:

holeFillThreshold - The amount of time to wait before retrying.

retryWaitThreshold - The number of retries to apply before requiring a hole fill.

Method Detail

peekUntilHoleFillRequired

@Nonnull
public ILogData peekUntilHoleFillRequired(long address,
                                                   Function<Long,ILogData> peekFunction)
                                            throws HoleFillRequiredException

Apply the given peek function until hole filling is required or committed data is returned. If hole filling is required a HoleFillRequiredException is thrown.

Specified by:

peekUntilHoleFillRequired in interface IHoleFillPolicy

Parameters:

address - The address to apply the function.

peekFunction - The function to use to peek data from the log.

Returns:

The committed data at the given address.

Throws:

HoleFillRequiredException - If hole filling is required.