This is an automated email from the ASF dual-hosted git repository.
ptupitsyn pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 3f80b7e066 IGNITE-20863 Selecting indexes when performing update
operations for partition (#2859)
add 2304733e14 IGNITE-20701 Use primary replica for client partition
awareness (#2825)
No new revisions were added by this update.
Summary of changes:
modules/client-handler/build.gradle | 9 +
.../apache/ignite/client/handler/TestServer.java | 4 +-
.../ignite/client/handler/ClientHandlerModule.java | 14 +-
.../handler/ClientInboundMessageHandler.java | 47 +--
.../handler/ClientPrimaryReplicaTracker.java | 333 +++++++++++++++++++++
...ntTablePartitionPrimaryReplicasGetRequest.java} | 34 ++-
.../handler/ClientInboundMessageHandlerTest.java | 3 +-
.../handler/ClientPrimaryReplicaTrackerTest.java | 148 +++++++++
.../ignite/client/handler/FakeCatalogService.java | 161 ++++++++++
.../ignite/client/handler/FakePlacementDriver.java | 123 ++++++++
modules/client/build.gradle | 2 +
.../ignite/internal/client/ClientChannel.java | 2 +-
.../ignite/internal/client/ReliableChannel.java | 42 +--
.../ignite/internal/client/TcpClientChannel.java | 9 +-
...ctClientStreamerPartitionAwarenessProvider.java | 4 +-
.../ignite/internal/client/table/ClientTable.java | 55 ++--
.../apache/ignite/client/ClientMetricsTest.java | 2 +-
.../ignite/client/PartitionAwarenessTest.java | 63 ++--
.../ignite/client/TestClientHandlerModule.java | 19 +-
.../java/org/apache/ignite/client/TestServer.java | 37 ++-
.../ignite/client/fakes/FakeIgniteTables.java | 42 ---
.../ignite/client/fakes/FakeInternalTable.java | 4 +-
.../RepeatedFinishClientTransactionTest.java | 2 +-
.../internal/streamer/StreamerSubscriber.java | 1 +
.../internal/index/IndexBuildControllerTest.java | 2 +-
.../event/PrimaryReplicaEventParameters.java | 12 +-
.../placementdriver/leases/LeaseTracker.java | 4 +-
.../cpp/ignite/client/detail/node_connection.cpp | 7 +-
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 7 +-
modules/platforms/cpp/ignite/protocol/messages.h | 21 ++
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 13 +-
.../dotnet/Apache.Ignite.Tests/HeartbeatTests.cs | 3 +-
.../dotnet/Apache.Ignite.Tests/ListLogger.cs | 4 +-
.../Table/SchemaSynchronizationTest.cs | 2 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 2 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 2 +
.../Apache.Ignite/Internal/Proto/PreferredNode.cs | 4 +-
.../Apache.Ignite/Internal/Table/DataStreamer.cs | 4 +-
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 23 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 3 +-
.../internal/table/IgniteTablesInternal.java | 27 --
.../internal/table/distributed/TableManager.java | 41 +--
.../PartitionReplicaListenerDurableUnlockTest.java | 6 +-
43 files changed, 1051 insertions(+), 296 deletions(-)
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/ClientPrimaryReplicaTracker.java
rename
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/{ClientTablePartitionAssignmentGetRequest.java
=> ClientTablePartitionPrimaryReplicasGetRequest.java} (62%)
create mode 100644
modules/client-handler/src/test/java/org/apache/ignite/client/handler/ClientPrimaryReplicaTrackerTest.java
create mode 100644
modules/client-handler/src/testFixtures/java/org/apache/ignite/client/handler/FakeCatalogService.java
create mode 100644
modules/client-handler/src/testFixtures/java/org/apache/ignite/client/handler/FakePlacementDriver.java
