This is an automated email from the ASF dual-hosted git repository.
vpyatkov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 64b518e676 IGNITE-18983 Sql. Jdbc. Migrate JDBC handler on new
internal API (#1831)
add af4e428cc4 Implement primary replica side leaseGrant handler (#1765)
No new revisions were added by this update.
Summary of changes:
.../ignite/internal/hlc/HybridTimestamp.java | 42 ++
.../apache/ignite/internal/util/IgniteUtils.java | 50 ++
.../build.gradle | 8 +-
.../message/LeaseGrantedMessage.java} | 16 +-
.../message/LeaseGrantedMessageResponse.java} | 11 +-
.../message/PlacementDriverMessageGroup.java} | 28 +-
.../message/PlacementDriverReplicaMessage.java} | 6 +-
modules/placement-driver/build.gradle | 2 +
.../internal/placementdriver/ActiveActorTest.java | 592 ++++++++++++++++++++-
.../PlacementDriverManagerTest.java | 35 +-
.../internal/placementdriver/LeaseUpdater.java | 25 +-
.../placementdriver/PlacementDriverManager.java | 74 +--
.../apache/ignite/internal/raft/RaftManager.java | 33 ++
.../ignite/internal/raft/RaftServiceFactory.java | 45 ++
.../internal/raft/service/RaftGroupService.java | 7 +
.../java/org/apache/ignite/internal/raft/Loza.java | 83 ++-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 13 +
.../ignite/internal/raft/RaftGroupServiceTest.java | 36 ++
modules/replicator/build.gradle | 14 +-
.../raft/client/TopologyAwareRaftGroupService.java | 22 +-
.../TopologyAwareRaftGroupServiceFactory.java | 84 +++
.../apache/ignite/internal/replicator/Replica.java | 174 +++++-
.../ignite/internal/replicator/ReplicaManager.java | 181 ++++---
.../client/TopologyAwareRaftGroupServiceTest.java | 101 +---
.../replicator/PlacementDriverReplicaSideTest.java | 340 ++++++++++++
modules/rest-api/openapi/openapi.yaml | 4 +-
modules/runner/build.gradle | 1 +
.../storage/ItRebalanceDistributedTest.java | 14 +-
.../runner/app/ItIgniteNodeRestartTest.java | 12 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 28 +-
modules/sql-engine/build.gradle | 1 +
.../sql/engine/exec/MockedStructuresTest.java | 4 +-
.../ignite/distributed/ItTablePersistenceTest.java | 3 +-
.../distributed/ItTxDistributedTestSingleNode.java | 61 ++-
.../ignite/distributed/ReplicaUnavailableTest.java | 9 +-
.../internal/table/distributed/TableManager.java | 29 +-
.../table/distributed/raft/PartitionListener.java | 10 +-
.../replicator/PartitionReplicaListener.java | 13 +-
.../TableManagerDistributionZonesTest.java | 4 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../raft/PartitionCommandListenerTest.java | 6 +-
.../table/impl/DummyInternalTableImpl.java | 3 +-
settings.gradle | 2 +
43 files changed, 1859 insertions(+), 373 deletions(-)
copy modules/{baseline => placement-driver-api}/build.gradle (88%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxStateReplicaRequest.java
=>
placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/message/LeaseGrantedMessage.java}
(75%)
copy
modules/{replicator/src/main/java/org/apache/ignite/internal/replicator/message/ErrorTimestampAwareReplicaResponse.java
=>
placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/message/LeaseGrantedMessageResponse.java}
(74%)
copy
modules/{compute/src/main/java/org/apache/ignite/internal/compute/ComputeMessageTypes.java
=>
placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/message/PlacementDriverMessageGroup.java}
(57%)
copy
modules/{replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaRequest.java
=>
placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/message/PlacementDriverReplicaMessage.java}
(86%)
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/RaftServiceFactory.java
rename modules/{placement-driver =>
replicator}/src/main/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupService.java
(97%)
create mode 100644
modules/replicator/src/main/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupServiceFactory.java
rename modules/{placement-driver/src/integrationTest =>
replicator/src/test}/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupServiceTest.java
(84%)
create mode 100644
modules/replicator/src/test/java/org/apache/ignite/internal/replicator/PlacementDriverReplicaSideTest.java