fabric.worker.transaction

Class Log

java.lang.Object

fabric.worker.transaction.Log

public final class Log
extends java.lang.Object

Stores per-transaction information. Records the objects that are created, read, and written during a single nested transaction.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Log.CommitState

Field Summary

Fields

Modifier and Type	Field and Description
Log.CommitState	commitState Indicates the state of commit for the top-level transaction.
protected java.util.List<Object._Impl>	creates A collection of all objects created in this transaction or completed sub-transactions.
protected WeakReferenceArrayList<Object._Impl>	localStoreCreates Tracks objects created on local store.
protected WeakReferenceArrayList<Object._Impl>	localStoreWrites Tracks objects on local store that have been modified.
static Log	NO_READER
protected OidKeyHashMap<ReadMap.Entry>	reads Maps OIDs to readMap entries for objects read in this transaction or completed sub-transactions.
protected java.util.List<ReadMap.Entry>	readsReadByParent Reads on objects that have been read by an ancestor transaction.
AbstractSecurityCache	securityCache
long	startTime The time at which this subtransaction was started.
java.util.List<RemoteWorker>	workersCalled The set of workers called by this transaction and completed sub-transactions.
protected java.util.List<Object._Impl>	writes A collection of all objects modified in this transaction or completed sub-transactions.

Constructor Summary

Constructors

Constructor and Description
Log(TransactionID tid) Creates a log with the given transaction ID.

Method Summary

Modifier and Type	Method and Description
void	clearWaitsFor() Empties the waitsFor set.
void	flagRetry() Sets the retry flag on this and the logs of all sub-transactions.
Log	getChild()
TransactionID	getTid()
java.util.Set<Log>	getWaitsFor() Returns a copy of the waitsFor set.
boolean	isReadOnly()
void	renumberObject(Store store, long onum, long newOnum) Deprecated.
void	setWaitsFor(Log waitsFor) Changes the waitsFor set to a singleton set containing the given log.
void	setWaitsFor(java.util.Set<Log> waitsFor) Changes the waitsFor set to contain exactly the elements of the given set.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

NO_READER

public static final Log NO_READER

reads

protected final OidKeyHashMap<ReadMap.Entry> reads

Maps OIDs to readMap entries for objects read in this transaction or completed sub-transactions. Reads from running or aborted sub-transactions don't count here.

readsReadByParent

protected final java.util.List<ReadMap.Entry> readsReadByParent

Reads on objects that have been read by an ancestor transaction.

creates

protected final java.util.List<Object._Impl> creates

A collection of all objects created in this transaction or completed sub-transactions. Objects created in running or aborted sub-transactions don't count here. To keep them from being pinned, objects on local store are not tracked here.

localStoreCreates

protected final WeakReferenceArrayList<Object._Impl> localStoreCreates

Tracks objects created on local store. See creates.

writes

protected final java.util.List<Object._Impl> writes

A collection of all objects modified in this transaction or completed sub-transactions. Objects modified in running or aborted sub-transactions don't count here. To keep them from being pinned, objects on local store are not tracked here.

localStoreWrites

protected final WeakReferenceArrayList<Object._Impl> localStoreWrites

Tracks objects on local store that have been modified. See writes.

workersCalled

public final java.util.List<RemoteWorker> workersCalled

The set of workers called by this transaction and completed sub-transactions.

commitState

public final Log.CommitState commitState

Indicates the state of commit for the top-level transaction.

securityCache

public final AbstractSecurityCache securityCache

startTime

public final long startTime

The time at which this subtransaction was started.

Constructor Detail

Log

public Log(TransactionID tid)

Creates a log with the given transaction ID.

Method Detail

isReadOnly

public boolean isReadOnly()

Returns:

true if the transaction is not distributed and neither creates nor modifies objects on remote stores.

flagRetry

public void flagRetry()

Sets the retry flag on this and the logs of all sub-transactions.

getTid

public TransactionID getTid()

getChild

public Log getChild()

setWaitsFor

public void setWaitsFor(Log waitsFor)

Changes the waitsFor set to a singleton set containing the given log.

setWaitsFor

public void setWaitsFor(java.util.Set<Log> waitsFor)

Changes the waitsFor set to contain exactly the elements of the given set.

clearWaitsFor

public void clearWaitsFor()

Empties the waitsFor set.

getWaitsFor

public java.util.Set<Log> getWaitsFor()

Returns a copy of the waitsFor set.

renumberObject

@Deprecated
public void renumberObject(Store store,
                                       long onum,
                                       long newOnum)

Deprecated.

Goes through this transaction log and performs an onum renumbering. This is used by fabric.worker.TransactionRegistery.renumberObject. Do not call this unless if you really know what you are doing.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object