org.corfudb.runtime.view.replication

Class NeverHoleFillPolicy

java.lang.Object

org.corfudb.runtime.view.replication.NeverHoleFillPolicy

All Implemented Interfaces:

IHoleFillPolicy

public class NeverHoleFillPolicy
extends Object
implements IHoleFillPolicy

This hole fill policy keeps retrying and never requires a hole fill. It waits a static amount of time before retrying.

Created by mwei on 4/6/17.

Constructor Summary

Constructors

Constructor and Description
NeverHoleFillPolicy(int waitMs) Create a new neverHoleFillPolicy with the given wait time.

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

NeverHoleFillPolicy

public NeverHoleFillPolicy(int waitMs)

Create a new neverHoleFillPolicy with the given wait time.

Parameters:

waitMs - The time to wait, in milliseconds.

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.