This is an automated email from the ASF dual-hosted git repository.
sanpwc pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from c41a26f2d8 IGNITE-21761 Within commitPartition mark txnState with
cleanup finished timestamp (#3496)
add e394902598 IGNITE-21572 Fix one phase transaction protocol
inconsistency in case of primary replica expirations (#3467)
No new revisions were added by this update.
Summary of changes:
.../apache/ignite/internal/replicator/Replica.java | 31 ++-
.../exception/PrimaryReplicaMissException.java | 14 ++
.../message/PrimaryReplicaChangeCommand.java} | 22 +--
.../replicator/message/ReplicaMessageGroup.java | 3 +
.../replicator/PlacementDriverReplicaSideTest.java | 2 +
.../org/apache/ignite/internal/TestWrappers.java | 10 +
.../apache/ignite/internal/table/NodeUtils.java | 28 ++-
.../table/ItTransactionPrimaryChangeTest.java | 219 +++++++++++++++++++++
.../internal/table/ItTransactionRecoveryTest.java | 4 +-
.../distributed/command/UpdateAllCommand.java | 5 +
.../table/distributed/command/UpdateCommand.java | 3 +
.../table/distributed/raft/PartitionListener.java | 52 ++++-
.../replicator/PartitionReplicaListener.java | 200 ++++++++++++-------
.../distributed/storage/InternalTableImpl.java | 24 +--
.../raft/PartitionCommandListenerTest.java | 35 +++-
.../replication/PartitionReplicaListenerTest.java | 10 +-
.../ignite/internal/tx/UpdateCommandResult.java | 100 ++++++++++
.../state/ThreadAssertingTxStateStorage.java | 14 ++
.../internal/tx/storage/state/TxStateStorage.java | 16 ++
.../state/rocksdb/TxStateRocksDbStorage.java | 110 +++++++++--
.../storage/state/AbstractTxStateStorageTest.java | 24 +++
.../tx/storage/state/test/TestTxStateStorage.java | 24 +++
22 files changed, 802 insertions(+), 148 deletions(-)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxStateCoordinatorRequest.java
=>
replicator/src/main/java/org/apache/ignite/internal/replicator/message/PrimaryReplicaChangeCommand.java}
(63%)
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItTransactionPrimaryChangeTest.java
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/UpdateCommandResult.java
