org.corfudb.runtime.object.transactions

Class WriteAfterWriteTransactionalContext

java.lang.Object

org.corfudb.runtime.object.transactions.AbstractTransactionalContext

org.corfudb.runtime.object.transactions.OptimisticTransactionalContext

org.corfudb.runtime.object.transactions.WriteAfterWriteTransactionalContext

All Implemented Interfaces:

Comparable<AbstractTransactionalContext>

public class WriteAfterWriteTransactionalContext
extends OptimisticTransactionalContext

A write-after-write transactional context.

A write-after-write transactional context behaves like an optimistic context, except behavior during commit (for writes):

(1) Reads behave the same as in a regular optimistic transaction.

(2) Writes in a write-after-write transaction are guaranteed to commit atomically, if and only if none of the objects written (the "write set") were modified between the first read ("first read timestamp") and the time of commit.

Created by mwei on 11/21/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

Method Summary

Modifier and Type	Method and Description
void	addToReadSet(ICorfuSMRProxyInternal proxy, Object[] conflictObjects) Add the proxy and conflict-params information to our read set.
long	commitTransaction() Commit the transaction.

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

access, addTransaction, getConflictSetAndCommit, getUpcallResult, logUpdate, tryCommitAllProxies, updateAllProxies

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

abortTransaction, compareTo, syncWithRetryUnsafe, toString

Methods inherited from class java.lang.Object

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

Method Detail

commitTransaction

public long commitTransaction()
                       throws TransactionAbortedException

Description copied from class: OptimisticTransactionalContext

Commit the transaction. If it is the last transaction in the stack, append it to the log, otherwise merge it into a nested transaction.

Overrides:

commitTransaction in class OptimisticTransactionalContext

Returns:

The address of the committed transaction.

Throws:

TransactionAbortedException - If the transaction was aborted.

addToReadSet

public void addToReadSet(ICorfuSMRProxyInternal proxy,
                         Object[] conflictObjects)

Description copied from class: AbstractTransactionalContext

Add the proxy and conflict-params information to our read set.

Overrides:

addToReadSet in class AbstractTransactionalContext

Parameters:

proxy - The proxy to add

conflictObjects - The fine-grained conflict information, if available.