org.gridgain.grid.kernal.processors.cache.distributed.dht

Class GridDhtTxFinishRequest<K,V>

java.lang.Object

org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

org.gridgain.grid.kernal.processors.cache.GridCacheMessage<K,V>

org.gridgain.grid.kernal.processors.cache.distributed.GridDistributedBaseMessage<K,V>

org.gridgain.grid.kernal.processors.cache.distributed.GridDistributedTxFinishRequest<K,V>

org.gridgain.grid.kernal.processors.cache.distributed.dht.GridDhtTxFinishRequest<K,V>

All Implemented Interfaces:

Serializable, Cloneable, GridCacheDeployable, GridCacheVersionable

public class GridDhtTxFinishRequest<K,V>
extends GridDistributedTxFinishRequest<K,V>

Near transaction finish request.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.distributed.GridDistributedBaseMessage

ver

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheMessage

CACHE_MSG_INDEX_FIELD_NAME, MAX_CACHE_MSG_LOOKUP_INDEX

Fields inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

BIT_SET_NOT_READ, BOOLEAN_ARR_NOT_READ, BYTE_ARR_LIST_NOT_READ, BYTE_ARR_NOT_READ, CACHE_VER_NOT_READ, CHAR_ARR_NOT_READ, CLOCK_DELTA_VER_NOT_READ, commState, DHT_PART_EXCHANGE_ID_NOT_READ, DOUBLE_ARR_NOT_READ, DR_INT_REQ_ENTRY_NOT_READ, ENUM_NOT_READ, FLOAT_ARR_NOT_READ, GRID_UUID_NOT_READ, INT_ARR_NOT_READ, LONG_ARR_NOT_READ, LONG_LIST_NOT_READ, MSG_NOT_READ, NULL, SHORT_ARR_NOT_READ, STR_NOT_READ, UUID_NOT_READ, VAL_BYTES_NOT_READ

Constructor Summary

Constructors

Constructor and Description
GridDhtTxFinishRequest() Empty constructor required for Externalizable.
GridDhtTxFinishRequest(UUID nearNodeId, GridUuid futId, GridUuid miniId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, long threadId, GridCacheTxIsolation isolation, boolean commit, boolean invalidate, boolean sysInvalidate, GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers, int txSize, Collection<GridCacheTxEntry<K,V>> writes, Collection<GridCacheTxEntry<K,V>> nearWrites, Collection<GridCacheTxEntry<K,V>> recoverWrites, boolean reply, boolean onePhaseCommit, Object grpLockKey, UUID subjId)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	allowForStartup()
GridTcpCommunicationMessageAdapter	clone()
protected void	clone0(GridTcpCommunicationMessageAdapter _msg) Clones all fields of the provided message to this.
byte	directType()
void	finishUnmarshal(GridCacheContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheContext) method.
GridCacheTxIsolation	isolation()
boolean	isSystemInvalidate()
GridUuid	miniId()
UUID	nearNodeId()
Collection<GridCacheTxEntry<K,V>>	nearWrites()
boolean	onePhaseCommit()
Collection<GridCacheVersion>	pendingVersions() Gets versions of not acquired locks with version less then one of transaction being committed.
void	prepareMarshal(GridCacheContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
boolean	readFrom(ByteBuffer buf)
UUID	subjectId()
long	topologyVersion() Gets topology version or -1 in case of topology version is not required for this message.
String	toString()
boolean	writeTo(ByteBuffer buf)
GridCacheVersion	writeVersion()
void	writeVersion(GridCacheVersion writeVer)

Methods inherited from class org.gridgain.grid.kernal.processors.cache.distributed.GridDistributedTxFinishRequest

baseVersion, commit, commitVersion, futureId, groupLock, groupLockKey, isInvalidate, recoveryWrites, replyRequired, threadId, txSize, writes

Methods inherited from class org.gridgain.grid.kernal.processors.cache.distributed.GridDistributedBaseMessage

candidatesByIndex, candidatesByIndex, candidatesByKey, candidatesByKey, candidatesByKey, committedVersions, completedVersions, keysCount, rolledbackVersions, version, version

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheMessage

classError, deployInfo, ignoreClassErrors, lookupIndex, marshalBooleanLinkedMap, marshalCollection, marshalFilter, marshalInfo, marshalInfos, marshalTx, marshalValuesCollection, messageId, nextIndexId, onClassError, prepare, prepareFilter, prepareObject, prepareObjects, unmarshalBooleanLinkedMap, unmarshalCollection, unmarshalFilter, unmarshalInfo, unmarshalInfos, unmarshalTx, unmarshalValueBytesCollection

Methods inherited from class org.gridgain.grid.util.direct.GridTcpCommunicationMessageAdapter

arrayIterator, messageReader, messageWriter

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheDeployable

deployInfo, prepare

Constructor Detail

GridDhtTxFinishRequest

public GridDhtTxFinishRequest()

Empty constructor required for Externalizable.

GridDhtTxFinishRequest

public GridDhtTxFinishRequest(UUID nearNodeId,
                      GridUuid futId,
                      GridUuid miniId,
                      long topVer,
                      GridCacheVersion xidVer,
                      GridCacheVersion commitVer,
                      long threadId,
                      GridCacheTxIsolation isolation,
                      boolean commit,
                      boolean invalidate,
                      boolean sysInvalidate,
                      GridCacheVersion baseVer,
                      Collection<GridCacheVersion> committedVers,
                      Collection<GridCacheVersion> rolledbackVers,
                      Collection<GridCacheVersion> pendingVers,
                      int txSize,
                      Collection<GridCacheTxEntry<K,V>> writes,
                      Collection<GridCacheTxEntry<K,V>> nearWrites,
                      Collection<GridCacheTxEntry<K,V>> recoverWrites,
                      boolean reply,
                      boolean onePhaseCommit,
                      @Nullable
                      Object grpLockKey,
                      @Nullable
                      UUID subjId)

Parameters:

nearNodeId - Near node ID.

futId - Future ID.

miniId - Mini future ID.

topVer - Topology version.

xidVer - Transaction ID.

threadId - Thread ID.

commitVer - Commit version.

isolation - Transaction isolation.

commit - Commit flag.

invalidate - Invalidate flag.

sysInvalidate - System invalidation flag.

baseVer - Base version.

committedVers - Committed versions.

rolledbackVers - Rolled back versions.

pendingVers - Pending versions.

txSize - Expected transaction size.

writes - Write entries.

nearWrites - Near cache writes.

recoverWrites - Recovery write entries.

reply - Reply flag.

onePhaseCommit - One phase commit flag.

grpLockKey - Group lock key.

Method Detail

allowForStartup

public boolean allowForStartup()

Overrides:

allowForStartup in class GridCacheMessage<K,V>

Returns:

True if this message is preloader message.

nearWrites

public Collection<GridCacheTxEntry<K,V>> nearWrites()

Returns:

Near writes.

miniId

public GridUuid miniId()

Returns:

Mini ID.

subjectId

@Nullable
public UUID subjectId()

Returns:

Subject ID.

isolation

public GridCacheTxIsolation isolation()

Returns:

Transaction isolation.

nearNodeId

public UUID nearNodeId()

Returns:

Near node ID.

isSystemInvalidate

public boolean isSystemInvalidate()

Returns:

System invalidate flag.

onePhaseCommit

public boolean onePhaseCommit()

Returns:

One phase commit flag.

writeVersion

public GridCacheVersion writeVersion()

Returns:

Write version for one-phase commit transactions.

writeVersion

public void writeVersion(GridCacheVersion writeVer)

Parameters:

writeVer - Write version for one-phase commit transactions.

topologyVersion

public long topologyVersion()

Description copied from class: GridCacheMessage

Gets topology version or -1 in case of topology version is not required for this message.

Overrides:

topologyVersion in class GridCacheMessage<K,V>

Returns:

Topology version.

pendingVersions

public Collection<GridCacheVersion> pendingVersions()

Gets versions of not acquired locks with version less then one of transaction being committed.

Returns:

Versions of locks for entries participating in transaction that have not been acquired yet have version less then one of transaction being committed.

prepareMarshal

public void prepareMarshal(GridCacheContext<K,V> ctx)
                    throws GridException

This method is called before the whole message is serialized and is responsible for pre-marshalling state.

Overrides:

prepareMarshal in class GridDistributedTxFinishRequest<K,V>

Parameters:

ctx - Cache context.

Throws:

GridException - If failed.

finishUnmarshal

public void finishUnmarshal(GridCacheContext<K,V> ctx,
                   ClassLoader ldr)
                     throws GridException

This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheContext) method.

Overrides:

finishUnmarshal in class GridDistributedTxFinishRequest<K,V>

Parameters:

ctx - Context.

ldr - Class loader.

Throws:

GridException - If failed.

toString

public String toString()

Overrides:

toString in class GridDistributedTxFinishRequest<K,V>

clone

public GridTcpCommunicationMessageAdapter clone()

Overrides:

clone in class GridDistributedTxFinishRequest<K,V>

clone0

protected void clone0(GridTcpCommunicationMessageAdapter _msg)

Clones all fields of the provided message to this.

Overrides:

clone0 in class GridDistributedTxFinishRequest<K,V>

Parameters:

_msg - Message to clone from.

writeTo

public boolean writeTo(ByteBuffer buf)

Overrides:

writeTo in class GridDistributedTxFinishRequest<K,V>

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf)

Overrides:

readFrom in class GridDistributedTxFinishRequest<K,V>

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

directType

public byte directType()

Overrides:

directType in class GridDistributedTxFinishRequest<K,V>

Returns:

Message type.