Uses of Interface
org.corfudb.runtime.object.ICorfuSMRProxyInternal

Packages that use ICorfuSMRProxyInternal

Package	Description
org.corfudb.runtime.object	This package contains the object layer for Corfu.
org.corfudb.runtime.object.transactions

Uses of ICorfuSMRProxyInternal in org.corfudb.runtime.object

Classes in org.corfudb.runtime.object that implement ICorfuSMRProxyInternal

Modifier and Type	Class and Description
class	CorfuCompileProxy<T> In the Corfu runtime, on top of a stream, an SMR object layer implements objects whose history of updates are backed by a stream.

Uses of ICorfuSMRProxyInternal in org.corfudb.runtime.object.transactions

Fields in org.corfudb.runtime.object.transactions with type parameters of type ICorfuSMRProxyInternal

Modifier and Type	Field and Description
protected Map<ICorfuSMRProxyInternal,Set<Object>>	ConflictSetInfo.conflicts Set of objects this conflict set conflicts with.

Methods in org.corfudb.runtime.object.transactions with parameters of type ICorfuSMRProxyInternal

Modifier and Type	Method and Description
<R,T> R	SnapshotTransactionalContext.access(ICorfuSMRProxyInternal<T> proxy, ICorfuSMRAccess<R,T> accessFunction, Object[] conflictObject) Access the state of the object.
abstract <R,T> R	AbstractTransactionalContext.access(ICorfuSMRProxyInternal<T> proxy, ICorfuSMRAccess<R,T> accessFunction, Object[] conflictObject) Access the state of the object.
<R,T> R	OptimisticTransactionalContext.access(ICorfuSMRProxyInternal<T> proxy, ICorfuSMRAccess<R,T> accessFunction, Object[] conflictObject) Access within optimistic transactional context is implemented in via proxy.access() as follows:
void	ConflictSetInfo.add(ICorfuSMRProxyInternal proxy, Object[] conflictObjects) Add an operation into this conflict set.
long	WriteSetInfo.add(ICorfuSMRProxyInternal proxy, SMREntry updateEntry, Object[] conflictObjects)
void	WriteAfterWriteTransactionalContext.addToReadSet(ICorfuSMRProxyInternal proxy, Object[] conflictObjects)
void	AbstractTransactionalContext.addToReadSet(ICorfuSMRProxyInternal proxy, Object[] conflictObjects) Add the proxy and conflict-params information to our read set.
static byte[]	ConflictSetInfo.generateHashFromObject(ICorfuSMRProxyInternal p, Object o) Get a hash for the object, given a proxy.
<T> Object	SnapshotTransactionalContext.getUpcallResult(ICorfuSMRProxyInternal<T> proxy, long timestamp, Object[] conflictObject) Get the result of an upcall.
abstract <T> Object	AbstractTransactionalContext.getUpcallResult(ICorfuSMRProxyInternal<T> proxy, long timestamp, Object[] conflictObject) Get the result of an upcall.
<T> Object	OptimisticTransactionalContext.getUpcallResult(ICorfuSMRProxyInternal<T> proxy, long timestamp, Object[] conflictObject) if a Corfu object's method is an Accessor-Mutator, then although the mutation is delayed, it needs to obtain the result by invoking getUpcallResult() on the optimistic stream.
<T> long	SnapshotTransactionalContext.logUpdate(ICorfuSMRProxyInternal<T> proxy, SMREntry updateEntry, Object[] conflictObject) Log an SMR update to the Corfu log.
abstract <T> long	AbstractTransactionalContext.logUpdate(ICorfuSMRProxyInternal<T> proxy, SMREntry updateEntry, Object[] conflictObject) Log an SMR update to the Corfu log.
<T> long	OptimisticTransactionalContext.logUpdate(ICorfuSMRProxyInternal<T> proxy, SMREntry updateEntry, Object[] conflictObjects) Logs an update.
void	AbstractTransactionalContext.syncWithRetryUnsafe(VersionLockedObject vlo, Token snapshotTimestamp, ICorfuSMRProxyInternal proxy, Consumer<VersionLockedObject> optimisticStreamSetter)

Method parameters in org.corfudb.runtime.object.transactions with type arguments of type ICorfuSMRProxyInternal

Modifier and Type	Method and Description
protected void	OptimisticTransactionalContext.updateAllProxies(Consumer<ICorfuSMRProxyInternal> function)