This is an automated email from the ASF dual-hosted git repository. av pushed a commit to branch ignite-ducktape in repository https://gitbox.apache.org/repos/asf/ignite.git
commit db85d67aedd4f2ae22d580657750e4bb393cfe54 Merge: 47d1311 513afe4 Author: Anton Vinogradov <a...@apache.org> AuthorDate: Tue Sep 15 10:41:56 2020 +0300 Merge remote-tracking branch 'remotes/origin/master' into ignite-ducktape checkstyle/checkstyle.xml | 7 +- .../jmh/misc/JmhTracingContextBenchmark.java | 112 ++++ .../internal/jdbc2/JdbcMetadataSelfTest.java | 19 +- .../apache/ignite/jdbc/JdbcMetadataSelfTest.java | 16 + .../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 30 +- .../SystemViewRowAttributeWalkerGenerator.java | 4 + .../jdbc/JdbcThinCompatibilityTest.java | 197 +++++++ .../ignite/compatibility/jdbc/package-info.java} | 11 +- .../junits/IgniteCompatibilityAbstractTest.java | 87 ++-- .../IgniteCompatibilityBasicTestSuite.java | 4 +- .../ignite/internal/commandline/Command.java | 31 ++ .../ignite/internal/commandline/CommandList.java | 5 +- .../ignite/internal/commandline/WarmUpCommand.java | 121 +++++ .../commandline/encryption/EncryptionCommand.java | 6 +- .../commandline/CommandHandlerParsingTest.java | 36 +- .../apache/ignite/util/GridCommandHandlerTest.java | 68 ++- .../org/apache/ignite/IgniteSystemProperties.java | 571 +++++++++++++++++++++ ...ateCounterMvccImpl.java => SystemProperty.java} | 37 +- .../java/org/apache/ignite/cache/CacheManager.java | 6 +- .../java/org/apache/ignite/cache/CacheMetrics.java | 2 +- .../configuration/DataStorageConfiguration.java | 6 +- .../ignite/configuration/IgniteConfiguration.java | 2 +- .../ignite/internal/GridEventConsumeHandler.java | 5 - .../ignite/internal/GridKernalGatewayImpl.java | 7 +- .../ignite/internal/GridMessageListenHandler.java | 5 - .../org/apache/ignite/internal/IgniteKernal.java | 20 +- .../ignite/internal/LongJVMPauseDetector.java | 15 +- .../binary/streams/BinaryMemoryAllocatorChunk.java | 6 +- .../internal/client/GridClientBeforeNodeStart.java | 66 +++ .../ignite/internal/client/GridClientFactory.java | 33 +- .../client/GridClientNodeStateBeforeStart.java} | 16 +- .../internal/client/impl/GridClientImpl.java | 190 +++++-- .../impl/GridClientNodeStateBeforeStartImpl.java | 49 ++ .../impl/connection/GridClientConnection.java | 9 + .../connection/GridClientConnectionManager.java | 12 + .../GridClientConnectionManagerAdapter.java | 156 ++++-- .../GridClientConnectionManagerOsImpl.java | 7 +- .../connection/GridClientNioTcpConnection.java | 8 + .../client/router/impl/GridRouterClientImpl.java | 2 +- .../client/thin/ClientCacheAffinityMapping.java | 2 +- .../client/thin/ClientClusterGroupImpl.java | 23 +- .../internal/client/thin/ClientClusterImpl.java | 5 +- .../ignite/internal/client/thin/ClientUtils.java | 21 +- .../internal/client/thin/TcpClientChannel.java | 4 +- .../internal/client/thin/TcpIgniteClient.java | 2 +- .../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 8 +- .../jdbc/thin/JdbcThinDatabaseMetadata.java | 6 +- .../ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 21 +- .../internal/jdbc2/JdbcDatabaseMetadata.java | 8 +- .../managers/discovery/GridDiscoveryManager.java | 7 +- .../walker/BinaryMetadataViewWalker.java | 56 ++ .../systemview/walker/MetastorageViewWalker.java} | 30 +- .../processors/affinity/AffinityAssignment.java | 5 +- .../affinity/GridAffinityAssignmentCache.java | 11 +- .../cache/CacheAffinitySharedManager.java | 6 +- .../processors/cache/CacheGroupContext.java | 12 +- .../processors/cache/CacheMetricsImpl.java | 37 +- .../internal/processors/cache/ExchangeContext.java | 4 +- .../processors/cache/GridCacheAdapter.java | 18 +- .../processors/cache/GridCacheConcurrentMap.java | 5 +- .../cache/GridCacheConcurrentMapImpl.java | 37 +- .../processors/cache/GridCacheContext.java | 6 +- .../cache/GridCacheDeploymentManager.java | 3 +- .../processors/cache/GridCacheMapEntry.java | 12 +- .../processors/cache/GridCacheMvccManager.java | 7 +- .../cache/GridCachePartitionExchangeManager.java | 18 +- .../processors/cache/GridCacheProcessor.java | 11 +- .../cache/GridCacheSharedTtlCleanupManager.java | 11 + .../processors/cache/GridCacheTtlManager.java | 5 +- .../internal/processors/cache/GridCacheUtils.java | 5 +- .../processors/cache/GridNoStorageCacheMap.java | 6 +- .../cache/PartitionUpdateCounterMvccImpl.java | 5 + .../cache/PartitionUpdateCounterTrackingImpl.java | 7 +- .../internal/processors/cache/WalStateManager.java | 19 +- .../binary/CacheObjectBinaryProcessorImpl.java | 17 +- .../distributed/GridDistributedCacheEntry.java | 3 +- .../dht/GridCachePartitionedConcurrentMap.java | 8 +- .../dht/GridDhtTransactionalCacheAdapter.java | 3 +- .../dht/GridPartitionedSingleGetFuture.java | 4 +- .../distributed/dht/atomic/GridDhtAtomicCache.java | 11 +- .../CachePartitionPartialCountersMap.java | 11 + .../dht/preloader/GridDhtPartitionDemander.java | 360 ++++++------- .../preloader/GridDhtPartitionsExchangeFuture.java | 29 +- .../dht/preloader/GridDhtPreloader.java | 46 +- .../dht/preloader/GridDhtPreloaderAssignments.java | 16 + .../IgniteHistoricalIteratorException.java | 9 + .../dht/topology/GridClientPartitionTopology.java | 10 +- .../dht/topology/GridDhtLocalPartition.java | 530 +++++-------------- .../dht/topology/GridDhtPartitionTopology.java | 4 +- .../dht/topology/GridDhtPartitionTopologyImpl.java | 148 +++--- .../dht/topology/GridDhtPartitionsReservation.java | 20 +- .../dht/topology/PartitionsEvictManager.java | 503 ++++++------------ .../distributed/near/GridNearTxEnlistFuture.java | 5 + .../cache/distributed/near/GridNearTxLocal.java | 57 +- .../GridNearReadRepairAbstractFuture.java | 4 +- .../processors/cache/mvcc/MvccCachingManager.java | 5 +- .../GridCacheDatabaseSharedManager.java | 57 +- .../cache/persistence/GridCacheOffheapManager.java | 55 +- .../IgniteCacheDatabaseSharedManager.java | 9 + .../persistence/checkpoint/CheckpointHistory.java | 137 ++++- .../cache/persistence/checkpoint/Checkpointer.java | 5 +- .../pagelocktracker/LockTrackerFactory.java | 31 +- .../pagelocktracker/SharedPageLockTracker.java | 58 +-- .../cache/persistence/file/FilePageStore.java | 2 +- .../cache/persistence/freelist/PagesList.java | 53 +- .../cache/persistence/metastorage/MetaStorage.java | 5 + .../cache/persistence/pagemem/FullPageIdTable.java | 7 +- .../cache/persistence/pagemem/PageMemoryImpl.java | 13 +- .../pagemem/PagesWriteThrottlePolicy.java | 5 +- .../pagemem/RobinHoodBackwardShiftHashMap.java | 4 +- .../cache/persistence/tree/BPlusTree.java | 2 +- .../persistence/wal/FileWriteAheadLogManager.java | 29 +- .../wal/filehandle/FileHandleManagerImpl.java | 2 +- .../continuous/CacheContinuousQueryEntry.java | 35 +- .../CacheContinuousQueryEventBuffer.java | 226 +++----- .../continuous/CacheContinuousQueryHandler.java | 115 ++--- .../continuous/CacheContinuousQueryListener.java | 4 +- .../continuous/CacheContinuousQueryManager.java | 6 +- .../CacheContinuousQueryPartitionRecovery.java | 2 +- .../cache/transactions/IgniteTransactionsImpl.java | 16 +- .../cache/transactions/IgniteTxManager.java | 41 +- .../cache/transactions/IgniteTxStateImpl.java | 1 - .../cache/transactions/TransactionProxyImpl.java | 31 +- .../TransactionProxyRollbackOnlyImpl.java | 2 +- .../cache/transactions/TxDeadlockDetection.java | 7 +- .../processors/cluster/ClusterProcessor.java | 10 +- .../autoadjust/BaselineAutoAdjustScheduler.java | 3 +- .../baseline/autoadjust/ChangeTopologyWatcher.java | 4 + .../continuous/GridContinuousHandler.java | 4 +- .../continuous/GridContinuousProcessor.java | 7 +- .../datastructures/GridAtomicCacheQueueImpl.java | 7 +- .../processors/diagnostic/DiagnosticProcessor.java | 7 +- .../processors/failure/FailureProcessor.java | 9 +- .../internal/processors/job/GridJobProcessor.java | 6 +- .../jobmetrics/GridJobMetricsProcessor.java | 7 +- .../persistence/DistributedMetaStorageImpl.java | 42 +- .../odbc/jdbc/JdbcConnectionContext.java | 12 +- .../processors/odbc/jdbc/JdbcRequestHandler.java | 4 +- .../transactions/PlatformTransactions.java | 8 + .../internal/processors/query/QueryUtils.java | 9 +- .../internal/processors/rest/GridRestCommand.java | 8 +- .../processors/rest/GridRestProcessor.java | 15 +- .../internal/processors/rest/GridRestProtocol.java | 5 + .../GridClientNodeStateBeforeStartRequest.java} | 25 +- .../client/message/GridClientWarmUpRequest.java | 90 ++++ .../NodeStateBeforeStartCommandHandler.java | 75 +++ .../rest/handlers/task/GridTaskCommandHandler.java | 2 +- .../rest/protocols/GridRestProtocolAdapter.java | 5 + .../rest/protocols/tcp/GridTcpRestNioListener.java | 22 + .../rest/protocols/tcp/GridTcpRestProtocol.java | 6 +- .../GridRestNodeStateBeforeStartRequest.java} | 13 +- .../request/GridRestWarmUpRequest.java} | 36 +- .../ignite/internal/processors/tracing/MTC.java | 30 +- .../ignite/internal/util/GridLogThrottle.java | 6 +- .../ignite/internal/util/GridReflectionCache.java | 6 +- .../apache/ignite/internal/util/GridUnsafe.java | 7 +- .../apache/ignite/internal/util/IgniteUtils.java | 5 +- .../ignite/internal/util/OffheapReadWriteLock.java | 19 +- .../ignite/internal/util/StripedExecutor.java | 8 +- .../internal/util/io/GridUnsafeDataInput.java | 3 +- .../internal/util/io/GridUnsafeDataOutput.java | 3 +- .../util/nio/GridNioRecoveryDescriptor.java | 8 +- .../ignite/internal/util/nio/GridNioServer.java | 24 +- .../util/portscanner/GridJmxPortFinder.java | 2 + .../util/tostring/GridToStringBuilder.java | 14 +- .../internal/util/tostring/SBLengthLimit.java | 4 +- .../visor/node/VisorBasicConfiguration.java | 3 +- .../tcp/internal/GridNioServerWrapper.java | 27 +- .../tcp/internal/InboundConnectionHandler.java | 7 +- .../internal/TcpCommunicationConfiguration.java | 11 +- .../spi/deployment/local/LocalDeploymentSpi.java | 2 + .../ignite/spi/discovery/tcp/ClientImpl.java | 6 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 8 +- .../ignite/spi/discovery/tcp/TcpDiscoveryImpl.java | 3 +- .../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 16 + .../spi/systemview/view/BinaryMetadataView.java | 85 +++ .../systemview/view/MetastorageView.java} | 36 +- .../apache/ignite/spi/tracing/NoopTracingSpi.java | 2 + .../ignite/startup/cmdline/CommandLineStartup.java | 116 ++++- .../main/resources/META-INF/classnames.properties | 2 + modules/core/src/test/config/log4j-test.xml | 9 + .../ignite/cache/ResetLostPartitionTest.java | 8 +- .../client/ClientCacheConfigurationTest.java | 56 +- .../org/apache/ignite/client/IgniteBinaryTest.java | 25 + .../ignite/internal/metric/JmxExporterSpiTest.java | 120 +++++ .../ignite/internal/metric/SystemViewSelfTest.java | 116 +++++ .../cache/CacheGroupsMetricsRebalanceTest.java | 110 ++-- .../cache/WalModeChangeAdvancedSelfTest.java | 4 +- ...iteExchangeLatchManagerCoordinatorFailTest.java | 45 +- ...CachePartitionLostAfterSupplierHasLeftTest.java | 18 +- .../distributed/CacheRentingStateRepairTest.java | 21 +- .../IgniteCacheClientNodeChangingTopologyTest.java | 2 + ...eScheduleResendPartitionsAfterEvictionTest.java | 135 ----- .../dht/topology/BlockedEvictionsTest.java | 483 +++++++++++++++++ .../DropCacheContextDuringEvictionTest.java | 103 ---- .../dht/topology/EvictPartitionInLogTest.java | 38 +- .../EvictionWhilePartitionGroupIsReservedTest.java | 168 ++++++ .../GridDhtLocalPartitionSyncEviction.java | 125 +++++ ...MovingPartitionIsEvictedDuringClearingTest.java | 173 +++++++ .../PartitionsEvictManagerAbstractTest.java | 212 -------- .../PartitionsEvictionTaskFailureHandlerTest.java | 49 -- ...reloadingRestartWhileClearingPartitionTest.java | 166 ++++++ .../RentingPartitionIsOwnedDuringEvictionTest.java | 94 +++- ...yPartitionHistoricallyWithReorderedUpdates.java | 223 ++++++++ .../processors/cache/persistence/EagerTtlTest.java | 203 ++++++++ .../IgnitePdsCacheEntriesExpirationTest.java | 4 +- .../IgnitePdsPartitionFilesDestroyTest.java | 2 +- .../db/wal/WalRecoveryTxLogicalRecordsTest.java | 31 ++ .../CacheContinuousQueryEventBufferTest.java | 12 +- ...acheRemoteMultiplePartitionReservationTest.java | 6 +- .../TxRollbackOnMapOnInvalidTopologyTest.java | 4 +- .../cache/warmup/BlockedWarmUpConfiguration.java | 4 +- ...ockedWarmUp.java => BlockedWarmUpStrategy.java} | 6 +- .../SimpleObservableWarmUpConfiguration.java | 2 +- ...Up.java => SimpleObservableWarmUpStrategy.java} | 2 +- .../processors/cache/warmup/WarmUpSelfTest.java | 10 +- .../cache/warmup/WarmUpTestPluginProvider.java | 8 +- .../tcp/TcpClientDiscoverySpiSelfTest.java | 2 + .../cmdline/CommandLinePrintPropertiesTest.java | 113 ++++ .../junits/common/GridAbstractExamplesTest.java | 5 + .../junits/common/GridCommonAbstractTest.java | 2 +- .../ignite/testsuites/IgniteBasicTestSuite.java | 4 - .../ignite/testsuites/IgniteCacheTestSuite7.java | 10 +- .../ignite/testsuites/IgnitePdsMvccTestSuite3.java | 24 +- .../ignite/testsuites/IgnitePdsTestSuite3.java | 2 + .../ignite/testsuites/IgnitePdsTestSuite4.java | 2 + .../ignite/testsuites/IgniteStartUpTestSuite.java | 6 +- ...ridCommandHandlerClusterByClassTest_help.output | 3 + ...andHandlerClusterByClassWithSSLTest_help.output | 3 + .../processors/query/h2/database/H2Tree.java | 9 +- .../cache/metric/SqlViewExporterSpiTest.java | 111 +++- .../Apache.Ignite.Core.Tests.csproj | 2 + .../Cache/CacheLocalActiveTransactionsTest.cs | 208 ++++++++ .../Cache/CacheTransactionGridStopTest.cs | 48 ++ .../Cache/OptimisticTransactionTest.cs | 9 +- .../Cache/PartitionLossTest.cs | 12 +- .../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 2 +- .../IgniteStartStopTest.cs | 2 +- .../Apache.Ignite.Core/Apache.Ignite.Core.csproj | 2 + .../Common/IgniteIllegalStateException.cs | 69 +++ .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 1 + .../Impl/Transactions/TransactionImpl.cs | 12 +- .../Transactions/TransactionRollbackOnlyProxy.cs | 261 ++++++++++ .../Impl/Transactions/TransactionsImpl.cs | 55 +- .../Transactions/ITransactions.cs | 19 +- .../OverrideAnnotationOnTheSameLineCheck.java | 100 ---- .../ipfinder/zk/TcpDiscoveryZookeeperIpFinder.java | 5 +- .../zk/internal/ZookeeperDiscoveryImpl.java | 41 +- parent/pom.xml | 11 +- 249 files changed, 7248 insertions(+), 2798 deletions(-)