Modifier and Type	Class and Description
public static class	TxDecisionMaker.LockDecisionMaker<K, V>
public static class	TxDecisionMaker.PutIfAbsentDecisionMaker<K, V>
public static class	TxDecisionMaker.RepeatableReadLockDecisionMaker<K, V>

Modifier and Type	Field and Description
private Transaction	blockingTransaction
private MVMap.Decision	decision
protected K	key Key for the map entry to decide upon
private long	lastOperationId Id of the last operation, we decided to `org.h2.mvstore.MVMap.Decision#REPEAT`.
private V	lastValue
private final int	mapId Map to decide upon
private final Transaction	transaction Transaction we are operating within
private long	undoKey Id for the undo log entry created for this modification
private V	value Value for the map entry

Access	Constructor and Description
pack-priv	TxDecisionMaker(int mapId, Transaction transaction)

Method Summary

Modifier and Type	Method and Description
pack-priv final boolean	allowNonRepeatableRead()
public MVMap.Decision	decide(VersionedValue<V> value currently exists in the map existingValue, VersionedValue<V> original input value providedValue) Implements abstract org.h2.mvstore.MVMap.DecisionMaker.decide. Makes a decision about how to proceed with the update.
pack-priv final MVMap.Decision	decideToAbort(V lastValue)
pack-priv final Transaction	getBlockingTransaction()
pack-priv final MVMap.Decision	getDecision()
pack-priv final V	getLastValue()
pack-priv V	Returns: the current value. getNewValue(VersionedValue<V> the parameter value existingValue) Get the new value.
pack-priv void	initialize(K key, V value)
pack-priv final boolean	Returns: true if transaction should be considered as committed, false otherwise isCommitted(int to use transactionId) Determine whether specified id corresponds to a logically committed transaction.
pack-priv final boolean	Returns: true if the same as last operation id, false otherwise isRepeatedOperation(long for the operation we decided to `org.h2.mvstore.MVMap.Decision#REPEAT` id) Store operation id provided, but before that, compare it against last stored one.
pack-priv final boolean	Returns: true it it is "current" transaction's id, false otherwise isThisTransaction(int to check transactionId) Check whether specified transaction id belongs to "current" transaction (transaction we are acting within).
pack-priv MVMap.Decision	Returns: `org.h2.mvstore.MVMap.Decision#PUT` logAndDecideToPut(VersionedValue<V> previous value to be logged valueToLog, V last known committed value lastValue) Create undo log entry and record for future references `org.h2.mvstore.MVMap.Decision#PUT` decision along with last known committed value
public final void	reset() Overrides org.h2.mvstore.MVMap.DecisionMaker.reset. Resets internal state (if any) of a this DecisionMaker to it's initial state.
public <T extends VersionedValue<V>> T	selectValue(T value currently exists in the map existingValue, T original input value providedValue) Overrides org.h2.mvstore.MVMap.DecisionMaker.selectValue. Provides revised value for insert/update based on original input value and value currently existing in the map.
pack-priv final MVMap.Decision	Returns: argument provided setDecision(MVMap.Decision made decision) Record for future references specified value as a decision that has been made.
public final String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from org.h2.mvstore.MVMap.DecisionMaker:: decide

Field Detail

blockingTransaction	back to summary
private Transaction blockingTransaction

decision	back to summary
private MVMap.Decision decision

key	back to summary
protected K key Key for the map entry to decide upon

lastOperationId	back to summary
private long lastOperationId Id of the last operation, we decided to `org.h2.mvstore.MVMap.Decision#REPEAT`.

lastValue	back to summary
private V lastValue

mapId	back to summary
private final int mapId Map to decide upon

transaction	back to summary
private final Transaction transaction Transaction we are operating within

undoKey	back to summary
private long undoKey Id for the undo log entry created for this modification

value	back to summary
private V value Value for the map entry

Constructor Detail

TxDecisionMaker	back to summary
pack-priv TxDecisionMaker(int mapId, Transaction transaction)

Method Detail

allowNonRepeatableRead	back to summary
pack-priv final boolean allowNonRepeatableRead()

decide	back to summary
public MVMap.Decision decide(VersionedValue<V> existingValue, VersionedValue<V> providedValue) Implements abstract org.h2.mvstore.MVMap.DecisionMaker.decide. Doc from org.h2.mvstore.MVMap.DecisionMaker.decide. Makes a decision about how to proceed with the update. Parameters existingValue:VersionedValue<V> value currently exists in the map providedValue:VersionedValue<V> original input value Returns:MVMap.Decision PUT if a new value need to replace existing one or a new value to be inserted if there is none REMOVE if existing value should be deleted ABORT if update operation should be aborted or repeated later REPEAT if update operation should be repeated immediately Annotations @Override

decide

back to summary

public MVMap.Decision decide(VersionedValue<V> existingValue, VersionedValue<V> providedValue)

Implements abstract org.h2.mvstore.MVMap.DecisionMaker.decide.

Doc from org.h2.mvstore.MVMap.DecisionMaker.decide.

Makes a decision about how to proceed with the update.

Parameters

existingValue:VersionedValue<V>: value currently exists in the map
providedValue:VersionedValue<V>: original input value

Returns:MVMap.Decision

PUT if a new value need to replace existing one or a new value to be inserted if there is none REMOVE if existing value should be deleted ABORT if update operation should be aborted or repeated later REPEAT if update operation should be repeated immediately

Annotations

@Override

decideToAbort	back to summary
pack-priv final MVMap.Decision decideToAbort(V lastValue)

getBlockingTransaction	back to summary
pack-priv final Transaction getBlockingTransaction()

getDecision	back to summary
pack-priv final MVMap.Decision getDecision()

getLastValue	back to summary
pack-priv final V getLastValue()

getNewValue	back to summary
pack-priv V getNewValue(VersionedValue<V> existingValue) Get the new value. This implementation always return the current value (ignores the parameter). Parameters existingValue:VersionedValue<V> the parameter value Returns:V the current value.

getNewValue

back to summary

pack-priv V getNewValue(VersionedValue<V> existingValue)

Get the new value. This implementation always return the current value (ignores the parameter).

Parameters

existingValue:VersionedValue<V>: the parameter value

Returns:V

the current value.

initialize	back to summary
pack-priv void initialize(K key, V value)

isCommitted	back to summary
pack-priv final boolean isCommitted(int transactionId) Determine whether specified id corresponds to a logically committed transaction. In case of pending transaction, reference to actual Transaction object (if any) is preserved for future use. Parameters transactionId:int to use Returns:boolean true if transaction should be considered as committed, false otherwise

isCommitted

back to summary

pack-priv final boolean isCommitted(int transactionId)

Determine whether specified id corresponds to a logically committed transaction. In case of pending transaction, reference to actual Transaction object (if any) is preserved for future use.

Parameters

transactionId:int: to use

Returns:boolean

true if transaction should be considered as committed, false otherwise

isRepeatedOperation back to summary

isRepeatedOperation	back to summary
pack-priv final boolean isRepeatedOperation(long id) Store operation id provided, but before that, compare it against last stored one. This is to prevent an infinite loop in case of uncommitted "leftover" entry (one without a corresponding undo log entry, most likely as a result of unclean shutdown). Parameters id:long for the operation we decided to `org.h2.mvstore.MVMap.Decision#REPEAT` Returns:boolean true if the same as last operation id, false otherwise

pack-priv final boolean isRepeatedOperation(long id)

Store operation id provided, but before that, compare it against last stored one. This is to prevent an infinite loop in case of uncommitted "leftover" entry (one without a corresponding undo log entry, most likely as a result of unclean shutdown).

Parameters

id:long: for the operation we decided to org.h2.mvstore.MVMap.Decision#REPEAT

Returns:boolean

true if the same as last operation id, false otherwise

isThisTransaction	back to summary
pack-priv final boolean isThisTransaction(int transactionId) Check whether specified transaction id belongs to "current" transaction (transaction we are acting within). Parameters transactionId:int to check Returns:boolean true it it is "current" transaction's id, false otherwise

isThisTransaction

back to summary

pack-priv final boolean isThisTransaction(int transactionId)

Check whether specified transaction id belongs to "current" transaction (transaction we are acting within).

Parameters

transactionId:int: to check

Returns:boolean

true it it is "current" transaction's id, false otherwise

logAndDecideToPut back to summary

logAndDecideToPut	back to summary
pack-priv MVMap.Decision logAndDecideToPut(VersionedValue<V> valueToLog, V lastValue) Create undo log entry and record for future references `org.h2.mvstore.MVMap.Decision#PUT` decision along with last known committed value Parameters valueToLog:VersionedValue<V> previous value to be logged lastValue:V last known committed value Returns:MVMap.Decision `org.h2.mvstore.MVMap.Decision#PUT`

pack-priv MVMap.Decision logAndDecideToPut(VersionedValue<V> valueToLog, V lastValue)

Create undo log entry and record for future references org.h2.mvstore.MVMap.Decision#PUT decision along with last known committed value

Parameters

valueToLog:VersionedValue<V>: previous value to be logged
lastValue:V: last known committed value

Returns:MVMap.Decision

org.h2.mvstore.MVMap.Decision#PUT

reset	back to summary
public final void reset() Overrides org.h2.mvstore.MVMap.DecisionMaker.reset. Doc from org.h2.mvstore.MVMap.DecisionMaker.reset. Resets internal state (if any) of a this DecisionMaker to it's initial state. This method is invoked whenever concurrent update failure is encountered, so we can re-start update process. Annotations @Override

reset

back to summary

public final void reset()

Overrides org.h2.mvstore.MVMap.DecisionMaker.reset.

Doc from org.h2.mvstore.MVMap.DecisionMaker.reset.

Resets internal state (if any) of a this DecisionMaker to it's initial state. This method is invoked whenever concurrent update failure is encountered, so we can re-start update process.

Annotations

@Override

selectValue	back to summary
public <T extends VersionedValue<V>> T selectValue(T existingValue, T providedValue) Overrides org.h2.mvstore.MVMap.DecisionMaker.selectValue. Doc from org.h2.mvstore.MVMap.DecisionMaker.selectValue. Provides revised value for insert/update based on original input value and value currently existing in the map. This method is only invoked after call to decide(), if it returns PUT. Parameters <T> value type existingValue:T value currently exists in the map providedValue:T original input value Returns:T value to be used by insert/update Annotations @SuppressWarnings:unchecked @Override

selectValue

back to summary

public <T extends VersionedValue<V>> T selectValue(T existingValue, T providedValue)

Overrides org.h2.mvstore.MVMap.DecisionMaker.selectValue.

Doc from org.h2.mvstore.MVMap.DecisionMaker.selectValue.

Provides revised value for insert/update based on original input value and value currently existing in the map. This method is only invoked after call to decide(), if it returns PUT.

Parameters

<T>: value type
existingValue:T: value currently exists in the map
providedValue:T: original input value

Returns:T

value to be used by insert/update

Annotations

@SuppressWarnings:unchecked
@Override

setDecision	back to summary
pack-priv final MVMap.Decision setDecision(MVMap.Decision decision) Record for future references specified value as a decision that has been made. Parameters decision:MVMap.Decision made Returns:MVMap.Decision argument provided

setDecision

back to summary

pack-priv final MVMap.Decision setDecision(MVMap.Decision decision)

Record for future references specified value as a decision that has been made.

Parameters

decision:MVMap.Decision: made

Returns:MVMap.Decision

argument provided

toString back to summary

toString	back to summary
public final String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Returns:String a string representation of the object Annotations @Override

public final String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

org.h2.mvstore.tx back to summary

public Class TxDecisionMaker.LockDecisionMaker<K, V>

Class Inheritance

extends TxDecisionMaker<K, V>

java.lang.Object
org.h2.mvstore.MVMap.DecisionMaker
org.h2.mvstore.tx.TxDecisionMaker
org.h2.mvstore.tx.TxDecisionMaker.LockDecisionMaker

Known Direct Subclasses

org.h2.mvstore.tx.TxDecisionMaker.RepeatableReadLockDecisionMaker

Field Summary

Inherited from org.h2.mvstore.tx.TxDecisionMaker:: key

Constructor Summary

Access	Constructor and Description
pack-priv	LockDecisionMaker(int mapId, Transaction transaction)

Method Summary

Modifier and Type	Method and Description
public MVMap.Decision	decide(VersionedValue<V> value currently exists in the map existingValue, VersionedValue<V> original input value providedValue) Overrides org.h2.mvstore.tx.TxDecisionMaker.decide. Makes a decision about how to proceed with the update.
pack-priv V	getNewValue(VersionedValue<V> the parameter value existingValue) Overrides org.h2.mvstore.tx.TxDecisionMaker.getNewValue. Get the new value.

Inherited from org.h2.mvstore.tx.TxDecisionMaker:: allowNonRepeatableRead decideToAbort getBlockingTransaction getDecision getLastValue initialize isCommitted isRepeatedOperation isThisTransaction logAndDecideToPut reset selectValue setDecision toString

Constructor Detail

LockDecisionMaker	back to summary
pack-priv LockDecisionMaker(int mapId, Transaction transaction)

Method Detail

decide	back to summary
public MVMap.Decision decide(VersionedValue<V> existingValue, VersionedValue<V> providedValue) Overrides org.h2.mvstore.tx.TxDecisionMaker.decide. Doc from org.h2.mvstore.MVMap.DecisionMaker.decide. Makes a decision about how to proceed with the update. Parameters existingValue:VersionedValue<V> value currently exists in the map providedValue:VersionedValue<V> original input value Returns:MVMap.Decision PUT if a new value need to replace existing one or a new value to be inserted if there is none REMOVE if existing value should be deleted ABORT if update operation should be aborted or repeated later REPEAT if update operation should be repeated immediately Annotations @Override

decide

back to summary

public MVMap.Decision decide(VersionedValue<V> existingValue, VersionedValue<V> providedValue)

Overrides org.h2.mvstore.tx.TxDecisionMaker.decide.

Doc from org.h2.mvstore.MVMap.DecisionMaker.decide.

Makes a decision about how to proceed with the update.

Parameters

existingValue:VersionedValue<V>: value currently exists in the map
providedValue:VersionedValue<V>: original input value

Returns:MVMap.Decision

Annotations

@Override

getNewValue	back to summary
pack-priv V getNewValue(VersionedValue<V> existingValue) Overrides org.h2.mvstore.tx.TxDecisionMaker.getNewValue. Doc from org.h2.mvstore.tx.TxDecisionMaker.getNewValue. Get the new value. This implementation always return the current value (ignores the parameter). Parameters existingValue:VersionedValue<V> the parameter value Returns:V the current value. Annotations @Override

getNewValue

back to summary

pack-priv V getNewValue(VersionedValue<V> existingValue)

Overrides org.h2.mvstore.tx.TxDecisionMaker.getNewValue.

Doc from org.h2.mvstore.tx.TxDecisionMaker.getNewValue.

Get the new value. This implementation always return the current value (ignores the parameter).

Parameters

existingValue:VersionedValue<V>: the parameter value

Returns:V

the current value.

Annotations

@Override

org.h2.mvstore.tx back to summary

public final Class TxDecisionMaker.PutIfAbsentDecisionMaker<K, V>

Class Inheritance

extends TxDecisionMaker<K, V>

java.lang.Object
org.h2.mvstore.MVMap.DecisionMaker
org.h2.mvstore.tx.TxDecisionMaker
org.h2.mvstore.tx.TxDecisionMaker.PutIfAbsentDecisionMaker

Field Summary

Modifier and Type	Field and Description
private final Function<K, V>	oldValueSupplier

Inherited from org.h2.mvstore.tx.TxDecisionMaker:: key

Constructor Summary

Access	Constructor and Description
pack-priv	PutIfAbsentDecisionMaker(int mapId, Transaction transaction, Function<K, V> oldValueSupplier)

Method Summary

Modifier and Type	Method and Description
public MVMap.Decision	decide(VersionedValue<V> value currently exists in the map existingValue, VersionedValue<V> original input value providedValue) Overrides org.h2.mvstore.tx.TxDecisionMaker.decide. Makes a decision about how to proceed with the update.
private V	getValueInSnapshot()

Inherited from org.h2.mvstore.tx.TxDecisionMaker:: allowNonRepeatableRead decideToAbort getBlockingTransaction getDecision getLastValue getNewValue initialize isCommitted isRepeatedOperation isThisTransaction logAndDecideToPut reset selectValue setDecision toString

Field Detail

oldValueSupplier	back to summary
private final Function<K, V> oldValueSupplier

Constructor Detail

PutIfAbsentDecisionMaker	back to summary
pack-priv PutIfAbsentDecisionMaker(int mapId, Transaction transaction, Function<K, V> oldValueSupplier)

Method Detail

decide	back to summary
public MVMap.Decision decide(VersionedValue<V> existingValue, VersionedValue<V> providedValue) Overrides org.h2.mvstore.tx.TxDecisionMaker.decide. Doc from org.h2.mvstore.MVMap.DecisionMaker.decide. Makes a decision about how to proceed with the update. Parameters existingValue:VersionedValue<V> value currently exists in the map providedValue:VersionedValue<V> original input value Returns:MVMap.Decision PUT if a new value need to replace existing one or a new value to be inserted if there is none REMOVE if existing value should be deleted ABORT if update operation should be aborted or repeated later REPEAT if update operation should be repeated immediately Annotations @Override

decide

back to summary

public MVMap.Decision decide(VersionedValue<V> existingValue, VersionedValue<V> providedValue)

Overrides org.h2.mvstore.tx.TxDecisionMaker.decide.

Doc from org.h2.mvstore.MVMap.DecisionMaker.decide.

Makes a decision about how to proceed with the update.

Parameters

existingValue:VersionedValue<V>: value currently exists in the map
providedValue:VersionedValue<V>: original input value

Returns:MVMap.Decision

Annotations

@Override

getValueInSnapshot	back to summary
private V getValueInSnapshot()

org.h2.mvstore.tx back to summary

public final Class TxDecisionMaker.RepeatableReadLockDecisionMaker<K, V>

Class Inheritance

extends TxDecisionMaker.LockDecisionMaker<K, V>

java.lang.Object
org.h2.mvstore.MVMap.DecisionMaker
org.h2.mvstore.tx.TxDecisionMaker
org.h2.mvstore.tx.TxDecisionMaker.LockDecisionMaker
org.h2.mvstore.tx.TxDecisionMaker.RepeatableReadLockDecisionMaker

Field Summary

Modifier and Type	Field and Description
private final Function<K, V>	snapshotValueSupplier
private final DataType<VersionedValue<V>>	valueType

Constructor Summary

Access	Constructor and Description
pack-priv	RepeatableReadLockDecisionMaker(int mapId, Transaction transaction, DataType<VersionedValue<V>> valueType, Function<K, V> snapshotValueSupplier)

Method Summary

Modifier and Type	Method and Description
pack-priv MVMap.Decision	logAndDecideToPut(VersionedValue<V> previous value to be logged valueToLog, V last known committed value value) Overrides org.h2.mvstore.tx.TxDecisionMaker.logAndDecideToPut. Create undo log entry and record for future references `org.h2.mvstore.MVMap.Decision#PUT` decision along with last known committed value

Inherited from org.h2.mvstore.tx.TxDecisionMaker.LockDecisionMaker:: decide getNewValue

Field Detail

snapshotValueSupplier	back to summary
private final Function<K, V> snapshotValueSupplier

valueType	back to summary
private final DataType<VersionedValue<V>> valueType

Constructor Detail

RepeatableReadLockDecisionMaker	back to summary
pack-priv RepeatableReadLockDecisionMaker(int mapId, Transaction transaction, DataType<VersionedValue<V>> valueType, Function<K, V> snapshotValueSupplier)

Method Detail

logAndDecideToPut back to summary

logAndDecideToPut	back to summary
pack-priv MVMap.Decision logAndDecideToPut(VersionedValue<V> valueToLog, V value) Overrides org.h2.mvstore.tx.TxDecisionMaker.logAndDecideToPut. Doc from org.h2.mvstore.tx.TxDecisionMaker.logAndDecideToPut. Create undo log entry and record for future references `org.h2.mvstore.MVMap.Decision#PUT` decision along with last known committed value Parameters valueToLog:VersionedValue<V> previous value to be logged value:V last known committed value Returns:MVMap.Decision `org.h2.mvstore.MVMap.Decision#PUT` Annotations @Override

pack-priv MVMap.Decision logAndDecideToPut(VersionedValue<V> valueToLog, V value)

Overrides org.h2.mvstore.tx.TxDecisionMaker.logAndDecideToPut.

Doc from org.h2.mvstore.tx.TxDecisionMaker.logAndDecideToPut.

Create undo log entry and record for future references org.h2.mvstore.MVMap.Decision#PUT decision along with last known committed value

Parameters

valueToLog:VersionedValue<V>: previous value to be logged
value:V: last known committed value

Returns:MVMap.Decision

org.h2.mvstore.MVMap.Decision#PUT

Annotations

@Override

pack-priv Class TxDecisionMaker<K, V>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public Class TxDecisionMaker.LockDecisionMaker<K, V>

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail

public final Class TxDecisionMaker.PutIfAbsentDecisionMaker<K, V>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

public final Class TxDecisionMaker.RepeatableReadLockDecisionMaker<K, V>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail