Package org.infinispan.transaction.impl

Class WriteSkewHelper

java.lang.Object

org.infinispan.transaction.impl.WriteSkewHelper

public class WriteSkewHelper
extends Object

Encapsulates write skew logic in maintaining version maps, etc.

Since:

5.1

Author:

Manik Surtani

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	WriteSkewHelper.KeySpecificLogic

Field Summary

Fields

Modifier and Type	Field	Description
static WriteSkewHelper.KeySpecificLogic	ALWAYS_TRUE_LOGIC

Constructor Summary

Constructors

Constructor	Description
WriteSkewHelper()

Method Summary

Modifier and Type	Method	Description
static EntryVersionsMap	performTotalOrderWriteSkewCheckAndReturnNewVersions(org.infinispan.commands.tx.VersionedPrepareCommand prepareCommand, DataContainer dataContainer, PersistenceManager persistenceManager, VersionGenerator versionGenerator, TxInvocationContext context, WriteSkewHelper.KeySpecificLogic ksl, org.infinispan.commons.time.TimeService timeService, KeyPartitioner keyPartitioner)
static EntryVersionsMap	performWriteSkewCheckAndReturnNewVersions(org.infinispan.commands.tx.VersionedPrepareCommand prepareCommand, DataContainer dataContainer, PersistenceManager persistenceManager, VersionGenerator versionGenerator, TxInvocationContext context, WriteSkewHelper.KeySpecificLogic ksl, org.infinispan.commons.time.TimeService timeService, KeyPartitioner keyPartitioner)
static void	readVersionsFromResponse(Response r, CacheTransaction ct)

Methods inherited from class java.lang.Object

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

Field Detail

ALWAYS_TRUE_LOGIC

public static final WriteSkewHelper.KeySpecificLogic ALWAYS_TRUE_LOGIC

Constructor Detail

WriteSkewHelper

public WriteSkewHelper()

Method Detail

readVersionsFromResponse

public static void readVersionsFromResponse(Response r,
                                            CacheTransaction ct)

performWriteSkewCheckAndReturnNewVersions

public static EntryVersionsMap performWriteSkewCheckAndReturnNewVersions(org.infinispan.commands.tx.VersionedPrepareCommand prepareCommand,
                                                                         DataContainer dataContainer,
                                                                         PersistenceManager persistenceManager,
                                                                         VersionGenerator versionGenerator,
                                                                         TxInvocationContext context,
                                                                         WriteSkewHelper.KeySpecificLogic ksl,
                                                                         org.infinispan.commons.time.TimeService timeService,
                                                                         KeyPartitioner keyPartitioner)

performTotalOrderWriteSkewCheckAndReturnNewVersions

public static EntryVersionsMap performTotalOrderWriteSkewCheckAndReturnNewVersions(org.infinispan.commands.tx.VersionedPrepareCommand prepareCommand,
                                                                                   DataContainer dataContainer,
                                                                                   PersistenceManager persistenceManager,
                                                                                   VersionGenerator versionGenerator,
                                                                                   TxInvocationContext context,
                                                                                   WriteSkewHelper.KeySpecificLogic ksl,
                                                                                   org.infinispan.commons.time.TimeService timeService,
                                                                                   KeyPartitioner keyPartitioner)