Package | Description |
---|---|
org.corfudb.protocols.logprotocol | |
org.corfudb.runtime.exceptions | |
org.corfudb.runtime.object |
This package contains the object layer for Corfu.
|
org.corfudb.runtime.object.transactions |
Modifier and Type | Method and Description |
---|---|
List<SMREntry> |
MultiSMREntry.getSMRUpdates(UUID id)
Deprecated.
|
List<SMREntry> |
SMREntry.getSMRUpdates(UUID id)
Deprecated.
|
List<SMREntry> |
ISMRConsumable.getSMRUpdates(UUID id)
Deprecated.
|
List<SMREntry> |
MultiObjectSMREntry.getSMRUpdates(UUID id)
Deprecated.
Get the list of SMR updates for a particular object.
|
Modifier and Type | Method and Description |
---|---|
void |
MultiSMREntry.addTo(SMREntry entry)
Deprecated.
|
void |
MultiObjectSMREntry.addTo(UUID streamID,
SMREntry updateEntry)
Deprecated.
Add one SMR-update to one object's update-list.
|
Constructor and Description |
---|
MultiSMREntry(List<SMREntry> updates)
Deprecated.
|
Constructor and Description |
---|
NoRollbackException(Optional<SMREntry> entry,
long address,
long rollbackVersion) |
Modifier and Type | Method and Description |
---|---|
List<SMREntry> |
ISMRStream.current()
Deprecated.
|
List<SMREntry> |
StreamViewSMRAdapter.current()
Deprecated.
Returns the list of SMREntries positioned at the current global log.
|
List<SMREntry> |
ISMRStream.previous()
Deprecated.
|
List<SMREntry> |
StreamViewSMRAdapter.previous()
Deprecated.
Returns the list of SMREntries positioned at the previous log position of this stream.
|
List<SMREntry> |
ISMRStream.remainingUpTo(long maxGlobal)
Deprecated.
|
List<SMREntry> |
StreamViewSMRAdapter.remainingUpTo(long maxGlobal)
Deprecated.
Returns all entries remaining upto the specified the global address specified.
|
Stream<SMREntry> |
ISMRStream.stream()
Deprecated.
|
Stream<SMREntry> |
StreamViewSMRAdapter.stream()
Deprecated.
|
Stream<SMREntry> |
ISMRStream.streamUpTo(long maxGlobal)
Deprecated.
|
Stream<SMREntry> |
StreamViewSMRAdapter.streamUpTo(long maxGlobal)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
long |
ISMRStream.append(SMREntry entry,
Function<TokenResponse,Boolean> acquisitionCallback,
Function<TokenResponse,Boolean> deacquisitionCallback)
Deprecated.
Append a SMREntry to the stream, returning the global address
it was written at.
|
long |
StreamViewSMRAdapter.append(SMREntry entry,
Function<TokenResponse,Boolean> acquisitionCallback,
Function<TokenResponse,Boolean> deacquisitionCallback)
Deprecated.
Append a SMREntry to the stream, returning the global address
it was written at.
|
protected void |
VersionLockedObject.applyUndoRecordUnsafe(SMREntry record)
Given a SMR entry with an undo record, undo the update.
|
void |
VersionLockedObject.applyUpdateToStreamUnsafe(SMREntry entry,
long globalAddress)
Apply an SMREntry to the version object, while
doing bookkeeping for the underlying stream.
|
Object |
VersionLockedObject.applyUpdateUnsafe(SMREntry entry)
Apply an SMR update to the object, possibly optimistically.
|
long |
VersionLockedObject.logUpdate(SMREntry entry,
boolean saveUpcall)
Log an update to this object, noting a request to save the
upcall result if necessary.
|
Modifier and Type | Method and Description |
---|---|
List<SMREntry> |
WriteSetSMRStream.current()
Deprecated.
|
List<SMREntry> |
WriteSetSMRStream.previous()
Deprecated.
|
List<SMREntry> |
WriteSetSMRStream.remainingUpTo(long maxGlobal)
Deprecated.
|
Stream<SMREntry> |
WriteSetSMRStream.stream()
Deprecated.
|
Stream<SMREntry> |
WriteSetSMRStream.streamUpTo(long maxGlobal)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
long |
WriteSetInfo.add(ICorfuSMRProxyInternal proxy,
SMREntry updateEntry,
Object[] conflictObjects) |
long |
WriteSetSMRStream.append(SMREntry entry,
Function<TokenResponse,Boolean> acquisitionCallback,
Function<TokenResponse,Boolean> deacquisitionCallback)
Deprecated.
|
<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.
|
Copyright © 2019 CorfuDB. All rights reserved.