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

Class GridNearTxPrepareRequest<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.GridDistributedTxPrepareRequest<K,V>

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

All Implemented Interfaces:

Serializable, Cloneable, GridCacheDeployable, GridCacheVersionable

public class GridNearTxPrepareRequest<K,V>
extends GridDistributedTxPrepareRequest<K,V>

Near transaction prepare 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
GridNearTxPrepareRequest() Empty constructor required for Externalizable.
GridNearTxPrepareRequest(GridUuid futId, long topVer, GridCacheTxEx<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Object grpLockKey, boolean partLock, boolean syncCommit, boolean syncRollback, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, UUID subjId)

Method Summary

Methods

Modifier and Type	Method and Description
GridTcpCommunicationMessageAdapter	clone()
protected void	clone0(GridTcpCommunicationMessageAdapter _msg) Clones all fields of the provided message to this.
byte	directType()
GridUuid	futureId()
boolean	last()
Collection<UUID>	lastBackups()
GridUuid	miniId()
void	miniId(GridUuid miniId)
boolean	readFrom(ByteBuffer buf)
UUID	subjectId()
boolean	syncCommit()
boolean	syncRollback()
long	topologyVersion() Gets topology version or -1 in case of topology version is not required for this message.
String	toString()
boolean	writeTo(ByteBuffer buf)

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

addDhtVersion, commitVersion, concurrency, dhtVersions, finishUnmarshal, groupLockKey, isInvalidate, isolation, partitionLock, prepareMarshal, reads, reads, threadId, timeout, transactionNodes, txSize, writes, 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

allowForStartup, 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

GridNearTxPrepareRequest

public GridNearTxPrepareRequest()

Empty constructor required for Externalizable.

GridNearTxPrepareRequest

public GridNearTxPrepareRequest(GridUuid futId,
                        long topVer,
                        GridCacheTxEx<K,V> tx,
                        Collection<GridCacheTxEntry<K,V>> reads,
                        Collection<GridCacheTxEntry<K,V>> writes,
                        Object grpLockKey,
                        boolean partLock,
                        boolean syncCommit,
                        boolean syncRollback,
                        Map<UUID,Collection<UUID>> txNodes,
                        boolean last,
                        Collection<UUID> lastBackups,
                        @Nullable
                        UUID subjId)

Parameters:

futId - Future ID.

topVer - Topology version.

tx - Transaction.

reads - Read entries.

writes - Write entries.

grpLockKey - Group lock key if preparing group-lock transaction.

partLock - True if preparing group-lock transaction with partition lock.

syncCommit - Synchronous commit.

syncRollback - Synchronous rollback.

txNodes - Transaction nodes mapping.

last - True if this last prepare request for node.

lastBackups - IDs of backup nodes receiving last prepare request during this prepare.

Method Detail

lastBackups

public Collection<UUID> lastBackups()

Returns:

IDs of backup nodes receiving last prepare request during this prepare.

last

public boolean last()

Returns:

True if this last prepare request for node.

futureId

public GridUuid futureId()

Returns:

Future ID.

miniId

public GridUuid miniId()

Returns:

Mini future ID.

miniId

public void miniId(GridUuid miniId)

Parameters:

miniId - Mini future ID.

subjectId

@Nullable
public UUID subjectId()

Returns:

Subject ID.

syncCommit

public boolean syncCommit()

Returns:

Synchronous commit.

syncRollback

public boolean syncRollback()

Returns:

Synchronous rollback.

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.

clone

public GridTcpCommunicationMessageAdapter clone()

Overrides:

clone in class GridDistributedTxPrepareRequest<K,V>

clone0

protected void clone0(GridTcpCommunicationMessageAdapter _msg)

Clones all fields of the provided message to this.

Overrides:

clone0 in class GridDistributedTxPrepareRequest<K,V>

Parameters:

_msg - Message to clone from.

writeTo

public boolean writeTo(ByteBuffer buf)

Overrides:

writeTo in class GridDistributedTxPrepareRequest<K,V>

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully written.

readFrom

public boolean readFrom(ByteBuffer buf)

Overrides:

readFrom in class GridDistributedTxPrepareRequest<K,V>

Parameters:

buf - Byte buffer.

Returns:

Whether message was fully read.

directType

public byte directType()

Overrides:

directType in class GridDistributedTxPrepareRequest<K,V>

Returns:

Message type.

toString

public String toString()

Overrides:

toString in class GridDistributedTxPrepareRequest<K,V>