You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sa...@apache.org on 2022/10/05 10:43:07 UTC
[ignite-3] branch main updated (098f16b68c -> 9885b6075e)
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 098f16b68c IGNITE-17827 Some API classes moved from "network" to "network-api" (#1164)
add 9885b6075e IGNITE-15081 (#1103) RW transactions implemented
No new revisions were added by this update.
Summary of changes:
.../org/apache/ignite/tx/TransactionException.java | 34 +
.../org/apache/ignite/client/fakes/FakeIgnite.java | 14 +-
.../ignite/client/fakes/FakeInternalTable.java | 6 +
.../internal/cluster/management/MockNode.java | 3 +-
.../management/raft/ItCmgRaftServiceTest.java | 3 +-
.../management/ClusterManagementGroupManager.java | 2 +-
.../management/raft/CmgRaftGroupListener.java | 7 -
.../internal/compute/ComputeComponentImpl.java | 2 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 52 +-
.../server/raft/MetaStorageListener.java | 7 -
.../internal/metastorage/MetaStorageManager.java | 2 +-
.../network/MessageSerializationRegistryImpl.java | 4 +-
.../dotnet/Apache.Ignite.Tests/ErrorGroupTests.cs | 4 +
.../dotnet/Apache.Ignite.Tests/HeartbeatTests.cs | 10 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 2 +-
.../raft/client/service/RaftGroupListener.java | 11 -
.../apache/ignite/internal/raft/ItLozaTest.java | 3 +-
.../internal/raft/ItRaftGroupServiceTest.java | 3 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 80 ++
.../ignite/raft/server/ItJraftHlcServerTest.java | 209 ++++
.../raft/server/counter/CounterListener.java | 8 -
.../server/snasphot/UpdateCountRaftListener.java | 8 -
.../java/org/apache/ignite/internal/raft/Loza.java | 15 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 69 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 6 +
.../ignite/raft/jraft/option/NodeOptions.java | 13 +
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 7 +
.../jraft/rpc/impl/ActionRequestProcessor.java | 32 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 3 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 18 +-
modules/replicator/README.md | 6 +
modules/replicator/pom.xml | 103 ++
.../apache/ignite/internal/replicator/Replica.java | 64 ++
.../ignite/internal/replicator/ReplicaManager.java | 342 +++++++
.../ignite/internal/replicator/ReplicaService.java | 139 +++
.../exception/PrimaryReplicaMissException.java | 67 ++
.../ReplicaIsAlreadyStartedException.java | 51 +
.../exception/ReplicaUnavailableException.java | 51 +
.../replicator/exception/ReplicationException.java | 70 ++
.../exception/ReplicationTimeoutException.java | 49 +
.../UnsupportedReplicaRequestException.java | 52 +
.../replicator/listener/ReplicaListener.java} | 23 +-
.../replicator/message/ErrorReplicaResponse.java} | 20 +-
.../ErrorTimestampAwareReplicaResponse.java} | 15 +-
.../replicator/message/ReplicaMessageGroup.java} | 29 +-
.../replicator/message/ReplicaRequest.java} | 18 +-
.../replicator/message/ReplicaResponse.java} | 13 +-
.../replicator/message/TimestampAware.java} | 33 +-
.../message/TimestampAwareReplicaResponse.java} | 12 +-
.../ItDistributedConfigurationPropertiesTest.java | 3 +-
.../ItDistributedConfigurationStorageTest.java | 3 +-
.../storage/ItRebalanceDistributedTest.java | 90 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 1 +
.../runner/app/ItIgniteNodeRestartTest.java | 28 +-
.../internal/runner/app/ItTablesApiTest.java | 4 +-
.../runner/app/PlatformTestNodeRunner.java | 4 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 2 +-
.../internal/sql/api/ItSqlSynchronousApiTest.java | 8 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 52 +-
.../ignite/internal/schema/SchemaManager.java | 2 +-
.../internal/sql/engine/SqlQueryProcessor.java | 2 +-
.../sql/engine/exec/MockedStructuresTest.java | 7 +-
.../internal/storage/MvPartitionStorage.java | 61 --
.../org/apache/ignite/internal/storage/RowId.java | 3 +-
.../storage/AbstractMvPartitionStorageTest.java | 10 +-
.../storage/AbstractMvTableStorageTest.java | 20 +-
.../storage/impl/TestMvPartitionStorage.java | 11 -
.../mv/AbstractPageMemoryMvPartitionStorage.java | 12 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 19 +-
.../storage/rocksdb/RocksDbTableStorage.java | 2 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 33 +-
modules/table/pom.xml | 24 +-
.../distributed/ItInternalTableScanTest.java | 181 +---
.../ignite/distributed/ItTablePersistenceTest.java | 51 +-
.../distributed/ItTxDistributedTestSingleNode.java | 154 ++-
.../ignite/internal/table/ItColocationTest.java | 78 +-
.../ignite/internal/table/InternalTable.java | 8 +
.../internal/table/distributed/TableManager.java | 176 +++-
.../table/distributed/TableMessageGroup.java | 61 ++
.../table/distributed/TableTxManagerImpl.java | 57 --
.../table/distributed/command/CommandUtils.java | 102 +-
.../distributed/command/DeleteAllCommand.java | 42 -
.../table/distributed/command/DeleteCommand.java | 40 -
.../distributed/command/DeleteExactAllCommand.java | 42 -
.../distributed/command/DeleteExactCommand.java | 40 -
.../table/distributed/command/FinishTxCommand.java | 68 +-
.../table/distributed/command/GetAllCommand.java | 41 -
.../distributed/command/GetAndDeleteCommand.java | 41 -
.../distributed/command/GetAndReplaceCommand.java | 41 -
.../distributed/command/GetAndUpsertCommand.java | 41 -
.../table/distributed/command/GetCommand.java | 40 -
.../distributed/command/InsertAllCommand.java | 41 -
.../table/distributed/command/MultiKeyCommand.java | 83 --
.../{InsertCommand.java => PartitionCommand.java} | 24 +-
.../table/distributed/command/ReplaceCommand.java | 69 --
.../distributed/command/ReplaceIfExistCommand.java | 40 -
.../distributed/command/SingleKeyCommand.java | 81 --
.../distributed/command/TxCleanupCommand.java} | 59 +-
.../distributed/command/UpdateAllCommand.java | 101 ++
.../table/distributed/command/UpdateCommand.java | 88 ++
.../distributed/command/UpsertAllCommand.java | 41 -
.../command/response/MultiRowsResponse.java | 10 +-
.../command/response/SingleRowResponse.java | 9 -
.../distributed/command/scan/ScanCloseCommand.java | 47 -
.../distributed/command/scan/ScanInitCommand.java | 64 --
.../command/scan/ScanRetrieveBatchCommand.java | 74 --
.../{ => distributed}/message/HasDataRequest.java | 3 +-
.../{ => distributed}/message/HasDataResponse.java | 3 +-
.../table/distributed/raft/PartitionListener.java | 743 ++++----------
.../request/MultipleRowReplicaRequest.java} | 23 +-
.../request/ReadOnlyReplicaRequest.java} | 32 +-
.../request/ReadWriteMultiRowReplicaRequest.java} | 12 +-
.../request/ReadWriteReplicaRequest.java} | 33 +-
.../request/ReadWriteScanCloseReplicaRequest.java} | 12 +-
.../ReadWriteScanRetrieveBatchReplicaRequest.java} | 12 +-
.../request/ReadWriteSingleRowReplicaRequest.java} | 12 +-
.../request/ReadWriteSwapRowReplicaRequest.java} | 12 +-
.../request/ScanCloseReplicaRequest.java} | 14 +-
.../request/ScanRetrieveBatchReplicaRequest.java} | 31 +-
.../request/SingleRowReplicaRequest.java} | 34 +-
.../request/SwapRowReplicaRequest.java} | 35 +-
.../replicator/PartitionReplicaListener.java | 1054 ++++++++++++++++++++
.../replicator/action/RequestType.java} | 65 +-
.../distributed/storage/InternalTableImpl.java | 617 +++++++++---
.../distributed/storage/VersionedRowStore.java | 630 ------------
.../org/apache/ignite/internal/table/Example.java | 12 +-
.../internal/table/InteropOperationsTest.java | 24 +-
.../table/KeyValueBinaryViewOperationsTest.java | 26 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 26 +-
.../internal/table/KeyValueViewOperationsTest.java | 23 +-
.../internal/table/MessagingServiceTestUtils.java | 121 ---
.../table/RecordBinaryViewOperationsTest.java | 26 +-
.../internal/table/RecordViewOperationsTest.java | 23 +-
.../internal/table/SchemaValidationTest.java | 20 +-
.../ignite/internal/table/TxAbstractTest.java | 204 +++-
.../apache/ignite/internal/table/TxLocalTest.java | 64 +-
.../table/distributed/TableManagerTest.java | 14 +-
.../PartitionRaftCommandsSerializationTest.java | 279 ++++++
.../raft/PartitionCommandListenerTest.java | 599 ++---------
.../table/impl/DummyInternalTableImpl.java | 229 +++--
modules/transactions/pom.xml | 17 +
.../ignite/internal/tx/InternalTransaction.java | 28 +-
.../tx/{InternalTransaction.java => Lock.java} | 59 +-
.../apache/ignite/internal/tx/LockException.java | 30 +-
.../org/apache/ignite/internal/tx/LockKey.java | 80 ++
.../org/apache/ignite/internal/tx/LockManager.java | 45 +-
.../org/apache/ignite/internal/tx/LockMode.java | 102 ++
.../tx/TransactionInternalCheckedException.java | 127 +++
.../org/apache/ignite/internal/tx/TxManager.java | 95 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 34 +
.../java/org/apache/ignite/internal/tx/Waiter.java | 6 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 342 +++----
.../ignite/internal/tx/impl/TransactionImpl.java | 139 ++-
.../ignite/internal/tx/impl/TxManagerImpl.java | 354 ++-----
...shRequest.java => TxCleanupReplicaRequest.java} | 37 +-
.../tx/message/TxFinishReplicaRequest.java | 80 ++
.../internal/tx/message/TxFinishResponse.java | 3 +-
.../ignite/internal/tx/message/TxMessageGroup.java | 7 +-
.../internal/tx/storage/state/TxStateStorage.java | 66 +-
.../tx/storage/state/TxStateTableStorage.java | 83 ++
.../state/rocksdb/TxStateRocksDbStorage.java | 427 ++++----
.../state/rocksdb/TxStateRocksDbTableStorage.java | 321 ++++++
.../internal/tx/AbstractLockManagerTest.java | 545 ++++++++--
.../ignite/internal/tx/HeapLockManagerTest.java | 2 +
.../apache/ignite/internal/tx/TxManagerTest.java | 62 +-
...geTest.java => TxStateStorageAbstractTest.java} | 90 +-
.../state/rocksdb/TxStateRocksDbStorageTest.java | 67 ++
.../test/TestConcurrentHashMapTxStateStorage.java | 126 +++
.../TestConcurrentHashMapTxStateStorageTest.java} | 16 +-
.../TestConcurrentHashMapTxStateTableStorage.java | 82 ++
parent/pom.xml | 13 +
pom.xml | 1 +
172 files changed, 7722 insertions(+), 5161 deletions(-)
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/ItJraftHlcServerTest.java
create mode 100644 modules/replicator/README.md
create mode 100644 modules/replicator/pom.xml
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/Replica.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaManager.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaService.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/PrimaryReplicaMissException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicaIsAlreadyStartedException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicaUnavailableException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicationException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/ReplicationTimeoutException.java
create mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/exception/UnsupportedReplicaRequestException.java
rename modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/command/TransactionalCommand.java => replicator/src/main/java/org/apache/ignite/internal/replicator/listener/ReplicaListener.java} (64%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishResponse.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ErrorReplicaResponse.java} (58%)
rename modules/{table/src/main/java/org/apache/ignite/internal/table/message/TableMessageGroup.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ErrorTimestampAwareReplicaResponse.java} (67%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxMessageGroup.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaMessageGroup.java} (52%)
copy modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaRequest.java} (72%)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/message/HasDataResponse.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaResponse.java} (74%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishRequest.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/TimestampAware.java} (60%)
copy modules/{table/src/main/java/org/apache/ignite/internal/table/message/HasDataResponse.java => replicator/src/main/java/org/apache/ignite/internal/replicator/message/TimestampAwareReplicaResponse.java} (67%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableMessageGroup.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableTxManagerImpl.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteExactAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/DeleteExactCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAndDeleteCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAndReplaceCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetAndUpsertCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/GetCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/InsertAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/MultiKeyCommand.java
rename modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/{InsertCommand.java => PartitionCommand.java} (70%)
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/ReplaceCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/ReplaceIfExistCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/SingleKeyCommand.java
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TxMeta.java => table/src/main/java/org/apache/ignite/internal/table/distributed/command/TxCleanupCommand.java} (52%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateAllCommand.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpdateCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/UpsertAllCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanCloseCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanInitCommand.java
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/command/scan/ScanRetrieveBatchCommand.java
copy modules/table/src/main/java/org/apache/ignite/internal/table/{ => distributed}/message/HasDataRequest.java (90%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{ => distributed}/message/HasDataResponse.java (89%)
rename modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataRequest.java => distributed/replication/request/MultipleRowReplicaRequest.java} (58%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/Waiter.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/ReadOnlyReplicaRequest.java} (65%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteMultiRowReplicaRequest.java} (70%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/Waiter.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/ReadWriteReplicaRequest.java} (57%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteScanCloseReplicaRequest.java} (70%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteScanRetrieveBatchReplicaRequest.java} (69%)
copy modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteSingleRowReplicaRequest.java} (70%)
rename modules/table/src/main/java/org/apache/ignite/internal/table/{message/HasDataResponse.java => distributed/replication/request/ReadWriteSwapRowReplicaRequest.java} (70%)
copy modules/{transactions/src/test/java/org/apache/ignite/internal/tx/HeapLockManagerTest.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/ScanCloseReplicaRequest.java} (70%)
rename modules/table/src/main/java/org/apache/ignite/internal/table/distributed/{command/UpsertCommand.java => replication/request/ScanRetrieveBatchReplicaRequest.java} (55%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/Waiter.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/SingleRowReplicaRequest.java} (60%)
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/Waiter.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/SwapRowReplicaRequest.java} (58%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
copy modules/{transactions/src/main/java/org/apache/ignite/internal/tx/Waiter.java => table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/action/RequestType.java} (62%)
delete mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/storage/VersionedRowStore.java
delete mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/MessagingServiceTestUtils.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/command/PartitionRaftCommandsSerializationTest.java
copy modules/transactions/src/main/java/org/apache/ignite/internal/tx/{InternalTransaction.java => Lock.java} (53%)
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/LockKey.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/LockMode.java
create mode 100755 modules/transactions/src/main/java/org/apache/ignite/internal/tx/TransactionInternalCheckedException.java
rename modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxFinishRequest.java => TxCleanupReplicaRequest.java} (53%)
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxFinishReplicaRequest.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/storage/state/TxStateTableStorage.java
create mode 100644 modules/transactions/src/main/java/org/apache/ignite/internal/tx/storage/state/rocksdb/TxStateRocksDbTableStorage.java
rename modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/{TxStateStorageTest.java => TxStateStorageAbstractTest.java} (60%)
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/rocksdb/TxStateRocksDbStorageTest.java
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/test/TestConcurrentHashMapTxStateStorage.java
copy modules/transactions/src/test/java/org/apache/ignite/internal/tx/{HeapLockManagerTest.java => storage/state/test/TestConcurrentHashMapTxStateStorageTest.java} (58%)
create mode 100644 modules/transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/test/TestConcurrentHashMapTxStateTableStorage.java