IGNITE-5267 - Added tx participating node IDs to transaction record.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c6fe26b8 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c6fe26b8 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c6fe26b8 Branch: refs/heads/ignite-5075-pds Commit: c6fe26b8aae298e2645d3ed8e14e24836caef6e1 Parents: 9d75ff8 Author: Alexey Goncharuk <[email protected]> Authored: Thu Jun 1 20:12:10 2017 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Thu Jun 1 20:12:10 2017 +0300 ---------------------------------------------------------------------- .../internal/pagemem/wal/record/TxRecord.java | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/c6fe26b8/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/TxRecord.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/TxRecord.java b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/TxRecord.java index c2877df..6aa899c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/TxRecord.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/TxRecord.java @@ -17,6 +17,7 @@ package org.apache.ignite.internal.pagemem.wal.record; +import java.util.UUID; import org.apache.ignite.internal.processors.cache.version.GridCacheVersion; /** @@ -62,6 +63,9 @@ public class TxRecord extends WALRecord { /** */ private GridCacheVersion dhtVer; + /** */ + private UUID[] participatingNodeIds; + /** {@inheritDoc} */ @Override public RecordType type() { return RecordType.TX_RECORD; @@ -108,4 +112,18 @@ public class TxRecord extends WALRecord { public void action(TxAction action) { this.action = action; } + + /** + * @param participatingNodeIds Participating node IDs. + */ + public void participatingNodeIds(UUID[] participatingNodeIds) { + this.participatingNodeIds = participatingNodeIds; + } + + /** + * @return Participating node IDs. + */ + public UUID[] participatingNodeId() { + return participatingNodeIds; + } }
