org.corfudb.runtime.object.transactions

Class SnapshotTransactionalContext

java.lang.Object

org.corfudb.runtime.object.transactions.AbstractTransactionalContext

org.corfudb.runtime.object.transactions.SnapshotTransactionalContext

All Implemented Interfaces:

Comparable<AbstractTransactionalContext>

public class SnapshotTransactionalContext
extends AbstractTransactionalContext

A snapshot transactional context.

Given the snapshot (log address) given by the TransactionBuilder, access all objects within the same snapshot during the course of this transactional context.

Created by mwei on 11/22/16.

Field Summary

Fields inherited from class org.corfudb.runtime.object.transactions.AbstractTransactionalContext

ABORTED_ADDRESS, commitAddress, completionFuture, FOLDED_ADDRESS, NOWRITE_ADDRESS, startTime, transaction, transactionID, UNCOMMITTED_ADDRESS

Constructor Summary

Constructors

Constructor and Description
SnapshotTransactionalContext(Transaction transaction)

Method Summary

Modifier and Type	Method and Description
<R,T> R	access(ICorfuSMRProxyInternal<T> proxy, ICorfuSMRAccess<R,T> accessFunction, Object[] conflictObject) Access the state of the object.
void	addTransaction(AbstractTransactionalContext tc) Add a given transaction to this transactional context, merging the read and write sets.
<T> Object	getUpcallResult(ICorfuSMRProxyInternal<T> proxy, long timestamp, Object[] conflictObject) Get the result of an upcall.
<T> long	logUpdate(ICorfuSMRProxyInternal<T> proxy, SMREntry updateEntry, Object[] conflictObject) Log an SMR update to the Corfu log.

Methods inherited from class org.corfudb.runtime.object.transactions.AbstractTransactionalContext

abortTransaction, addToReadSet, commitTransaction, compareTo, syncWithRetryUnsafe, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotTransactionalContext

public SnapshotTransactionalContext(Transaction transaction)

Method Detail

access

public <R,T> R access(ICorfuSMRProxyInternal<T> proxy,
                      ICorfuSMRAccess<R,T> accessFunction,
                      Object[] conflictObject)

Access the state of the object.

Specified by:

access in class AbstractTransactionalContext

Type Parameters:

R - The return type of the access function.

T - The type of the proxy's underlying object.

Parameters:

proxy - The proxy to access the state for.

accessFunction - The function to execute, which will be provided with the state of the object.

conflictObject - Fine-grained conflict information, if available.

Returns:

The return value of the access function.

getUpcallResult

public <T> Object getUpcallResult(ICorfuSMRProxyInternal<T> proxy,
                                  long timestamp,
                                  Object[] conflictObject)

Get the result of an upcall.

Specified by:

getUpcallResult in class AbstractTransactionalContext

Type Parameters:

T - The type of the proxy's underlying object.

Parameters:

proxy - The proxy to retrieve the upcall for.

timestamp - The timestamp to return the upcall for.

conflictObject - Fine-grained conflict information, if available.

Returns:

The result of the upcall.

logUpdate

public <T> long logUpdate(ICorfuSMRProxyInternal<T> proxy,
                          SMREntry updateEntry,
                          Object[] conflictObject)

Log an SMR update to the Corfu log.

Specified by:

logUpdate in class AbstractTransactionalContext

Type Parameters:

T - The type of the proxy's underlying object.

Parameters:

proxy - The proxy which generated the update.

updateEntry - The entry which we are writing to the log.

conflictObject - Fine-grained conflict information, if available.

Returns:

The address the update was written at.

addTransaction

public void addTransaction(AbstractTransactionalContext tc)

Description copied from class: AbstractTransactionalContext

Add a given transaction to this transactional context, merging the read and write sets.

Specified by:

addTransaction in class AbstractTransactionalContext

Parameters:

tc - The transactional context to merge.