org.corfudb.runtime.view.replication

Class QuorumReplicationProtocol

java.lang.Object

org.corfudb.runtime.view.replication.AbstractReplicationProtocol

org.corfudb.runtime.view.replication.QuorumReplicationProtocol

All Implemented Interfaces:

IReplicationProtocol

public class QuorumReplicationProtocol
extends AbstractReplicationProtocol

Created by kspirov on 4/23/17.

Field Summary

Fields inherited from class org.corfudb.runtime.view.replication.AbstractReplicationProtocol

holeFillPolicy

Constructor Summary

Constructors

Constructor and Description
QuorumReplicationProtocol(IHoleFillPolicy holeFillPolicy)

Method Summary

Modifier and Type	Method and Description
protected void	holeFill(RuntimeLayout runtimeLayout, long globalAddress) Write a special hole filling entry using the given address.
ILogData	peek(RuntimeLayout runtimeLayout, long address) Peek data from a given address.
Map<Long,ILogData>	readAll(RuntimeLayout runtimeLayout, List<Long> addresses, boolean waitForWrite) Read data from all the given addresses.
void	write(RuntimeLayout runtimeLayout, ILogData data) Write data to the log at the given address.

Methods inherited from class org.corfudb.runtime.view.replication.AbstractReplicationProtocol

read

Methods inherited from class java.lang.Object

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

Constructor Detail

QuorumReplicationProtocol

public QuorumReplicationProtocol(IHoleFillPolicy holeFillPolicy)

Method Detail

peek

public ILogData peek(RuntimeLayout runtimeLayout,
                     long address)

Peek data from a given address.

This function -may- return null if there was no entry committed at the given global address, otherwise it returns committed data at the given global address. It does not attempt to hole fill if there was no entry.

Parameters:

runtimeLayout - the RuntimeLayout stamped with layout to use for the peek.

address - the global address to peek from.

Returns:

the data that was committed at the given global address, or NULL, if there was no entry committed.

readAll

@Nonnull
public Map<Long,ILogData> readAll(RuntimeLayout runtimeLayout,
                                           List<Long> addresses,
                                           boolean waitForWrite)

Read data from all the given addresses.

This method functions exactly like a read, except that it returns the result for multiple addresses.

An implementation may optimize for this type of bulk request, but the default implementation just performs multiple reads (possible in parallel).

Parameters:

runtimeLayout - the RuntimeLayout stamped with layout to use for the read.

addresses - a list of addresses to read from.

waitForWrite - flag whether wait for write is required or hole fill directly.

Returns:

a map of addresses to data commit at these address, hole filling if necessary.

holeFill

protected void holeFill(RuntimeLayout runtimeLayout,
                        long globalAddress)

Write a special hole filling entry using the given address. When this call returns, either the hole filling write has been committed or the result of another client's write has committed (you WILL need to -read- the address to find out which write was adopted).

Specified by:

holeFill in class AbstractReplicationProtocol

globalAddress - The address to hole fill.

write

public void write(RuntimeLayout runtimeLayout,
                  ILogData data)
           throws OverwriteException

Write data to the log at the given address.

This function blocks until -a- write at the global address is committed to the log.

If the write which is committed to the log was this write, the function returns normally.

If the write which was committed to the log was not the result of this call, an OverwriteException is thrown.

Parameters:

runtimeLayout - the RuntimeLayout stamped with layout to use for the write.

data - the ILogData to write to the log.

Throws:

OverwriteException - If a write was committed to the log and it was not the result of this call.