org.corfudb.runtime.object.transactions

Class ConflictSetInfo

java.lang.Object

org.corfudb.runtime.object.transactions.ConflictSetInfo

Direct Known Subclasses:

WriteSetInfo

public class ConflictSetInfo
extends Object

This class captures information about objects accessed (read) during speculative transaction execution.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ConflictSetInfo()

Method Summary

Modifier and Type	Method and Description
void	add(ICorfuSMRProxyInternal proxy, Object[] conflictObjects) Add an operation into this conflict set.
static byte[]	generateHashFromObject(ICorfuSMRProxyInternal p, Object o) Get a hash for the object, given a proxy.
Map<UUID,Set<byte[]>>	getHashedConflictSet() Get the hashed conflict set.
void	mergeInto(ConflictSetInfo other) Merge a conflict set into this conflict set.

Methods inherited from class java.lang.Object

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

Field Detail

conflicts

protected Map<ICorfuSMRProxyInternal,Set<Object>> conflicts

Set of objects this conflict set conflicts with.

Constructor Detail

ConflictSetInfo

public ConflictSetInfo()

Method Detail

generateHashFromObject

public static byte[] generateHashFromObject(ICorfuSMRProxyInternal p,
                                            Object o)

Get a hash for the object, given a proxy.

getHashedConflictSet

public Map<UUID,Set<byte[]>> getHashedConflictSet()

Get the hashed conflict set.

Returns:

The hashed conflict set.

mergeInto

public void mergeInto(ConflictSetInfo other)

Merge a conflict set into this conflict set.

Parameters:

other - The conflict set to merge.

add

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

Add an operation into this conflict set.