Package | Description |
---|---|
org.corfudb.runtime.object |
This package contains the object layer for Corfu.
|
org.corfudb.runtime.object.transactions |
Modifier and Type | Method and Description |
---|---|
VersionLockedObject<T> |
ICorfuSMRProxyInternal.getUnderlyingObject()
Deprecated.
Directly get the state of the object the proxy is managing,
without causing a sync.
|
Modifier and Type | Method and Description |
---|---|
<R> R |
VersionLockedObject.access(Function<VersionLockedObject<T>,Boolean> directAccessCheckFunction,
Consumer<VersionLockedObject<T>> updateFunction,
Function<T,R> accessFunction)
Access the internal state of the object, trying first to optimistically access
the object, then obtaining a write lock the optimistic access fails.
|
<R> R |
VersionLockedObject.access(Function<VersionLockedObject<T>,Boolean> directAccessCheckFunction,
Consumer<VersionLockedObject<T>> updateFunction,
Function<T,R> accessFunction)
Access the internal state of the object, trying first to optimistically access
the object, then obtaining a write lock the optimistic access fails.
|
<R> R |
VersionLockedObject.update(Function<VersionLockedObject<T>,R> updateFunction)
Update the object under a write lock.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractTransactionalContext.syncWithRetryUnsafe(VersionLockedObject vlo,
Token snapshotTimestamp,
ICorfuSMRProxyInternal proxy,
Consumer<VersionLockedObject> optimisticStreamSetter) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractTransactionalContext.syncWithRetryUnsafe(VersionLockedObject vlo,
Token snapshotTimestamp,
ICorfuSMRProxyInternal proxy,
Consumer<VersionLockedObject> optimisticStreamSetter) |
Copyright © 2019 CorfuDB. All rights reserved.