You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by gv...@apache.org on 2020/04/06 18:51:40 UTC
[ignite] 01/02: Merge branch 'ignite-master' into ignite-12248
This is an automated email from the ASF dual-hosted git repository.
gvvinblade pushed a commit to branch ignite-12248
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 10b276845b182040ebf983b5bb3c9ea2e95abe8c
Merge: 4654a3e d580b84
Author: Igor Seliverstov <gv...@gmail.com>
AuthorDate: Mon Apr 6 17:36:16 2020 +0300
Merge branch 'ignite-master' into ignite-12248
examples/pom.xml | 18 +
.../OpenCensusMetricsExporterExample.java | 105 ++
.../OpenCensusMetricsExporterExampleSelfTest.java | 22 +-
.../testsuites/IgniteExamplesSelfTestSuite.java | 4 +
.../internal/jdbc2/JdbcMetadataSelfTest.java | 1 +
.../rest/ChangeStateCommandHandlerTest.java | 13 +-
.../rest/JettyRestProcessorAbstractSelfTest.java | 67 +-
.../rest/JettyRestProcessorCommonSelfTest.java | 25 +-
.../rest/protocols/tcp/TcpRestParserSelfTest.java | 1 +
.../JdbcThinConnectionAdditionalSecurityTest.java | 2 +-
.../jdbc/thin/JdbcThinConnectionSSLTest.java | 2 +-
.../jdbc/thin/JdbcThinLocalQueriesSelfTest.java | 45 +-
.../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 20 +-
...nsactionFinishOnDeactivatedClusterSelfTest.java | 4 +-
modules/clients/src/test/keystore/README.txt | 11 +
modules/clients/src/test/keystore/ca/node01.jks | Bin 3719 -> 0 bytes
modules/clients/src/test/keystore/ca/node02.jks | Bin 4599 -> 0 bytes
modules/clients/src/test/keystore/ca/node02old.jks | Bin 4598 -> 0 bytes
modules/clients/src/test/keystore/ca/node03.jks | Bin 3753 -> 0 bytes
.../clients/src/test/keystore/ca/oneca-index.txt | 3 +
modules/clients/src/test/keystore/ca/oneca-serial | 1 +
modules/clients/src/test/keystore/ca/oneca.cnf | 13 +-
modules/clients/src/test/keystore/ca/oneca.key | 52 +-
modules/clients/src/test/keystore/ca/oneca.pem | 21 +
modules/clients/src/test/keystore/ca/oneindex.txt | 1 -
.../clients/src/test/keystore/ca/oneindex.txt.attr | 1 -
modules/clients/src/test/keystore/ca/oneserial | 1 -
.../clients/src/test/keystore/ca/threeca-index.txt | 2 +
.../test/keystore/ca/{twoserial => threeca-serial} | 0
.../test/keystore/ca/{oneca.cnf => threeca.cnf} | 17 +-
modules/clients/src/test/keystore/ca/threeca.key | 28 +
modules/clients/src/test/keystore/ca/threeca.pem | 21 +
.../clients/src/test/keystore/ca/trust-both.jks | Bin 1718 -> 0 bytes
modules/clients/src/test/keystore/ca/trust-one.jks | Bin 877 -> 0 bytes
modules/clients/src/test/keystore/ca/trust-two.jks | Bin 891 -> 0 bytes
.../clients/src/test/keystore/ca/twoca-index.txt | 5 +
modules/clients/src/test/keystore/ca/twoca-serial | 1 +
modules/clients/src/test/keystore/ca/twoca.cnf | 15 +-
modules/clients/src/test/keystore/ca/twoca.key | 52 +-
modules/clients/src/test/keystore/ca/twoca.pem | 21 +
modules/clients/src/test/keystore/ca/twoindex.txt | 2 -
.../clients/src/test/keystore/ca/twoindex.txt.attr | 1 -
modules/clients/src/test/keystore/client.jks | Bin 3232 -> 2324 bytes
modules/clients/src/test/keystore/client.pem | 69 -
modules/clients/src/test/keystore/client.pfx | Bin 3148 -> 0 bytes
.../clients/src/test/keystore/connectorClient.jks | Bin 0 -> 2353 bytes
.../clients/src/test/keystore/connectorServer.jks | Bin 0 -> 2355 bytes
modules/clients/src/test/keystore/generate-ca.sh | 97 ++
modules/clients/src/test/keystore/generate-keys.sh | 92 ++
modules/clients/src/test/keystore/generate.sh | 99 --
modules/clients/src/test/keystore/node01.jks | Bin 0 -> 2325 bytes
modules/clients/src/test/keystore/node0102.jks | Bin 0 -> 4618 bytes
modules/clients/src/test/keystore/node02.jks | Bin 0 -> 2325 bytes
modules/clients/src/test/keystore/node02old.jks | Bin 0 -> 2331 bytes
modules/clients/src/test/keystore/node03.jks | Bin 0 -> 2327 bytes
modules/clients/src/test/keystore/server.jks | Bin 3230 -> 2324 bytes
modules/clients/src/test/keystore/server.pem | 69 -
modules/clients/src/test/keystore/server.pfx | Bin 3148 -> 0 bytes
modules/clients/src/test/keystore/thinClient.jks | Bin 0 -> 2332 bytes
modules/clients/src/test/keystore/thinServer.jks | Bin 0 -> 2332 bytes
modules/clients/src/test/keystore/trust-both.jks | Bin 0 -> 1888 bytes
modules/clients/src/test/keystore/trust-one.jks | Bin 0 -> 960 bytes
modules/clients/src/test/keystore/trust-three.jks | Bin 0 -> 970 bytes
modules/clients/src/test/keystore/trust-two.jks | Bin 0 -> 960 bytes
modules/clients/src/test/keystore/trust.jks | Bin 2432 -> 0 bytes
.../jetty/rest-jetty-ssl-client-auth.xml} | 20 +-
.../src/test/resources/jetty/rest-jetty-ssl.xml | 2 +-
.../src/test/resources/jetty/rest-jetty.xml | 2 +-
.../src/test/resources/jetty/router-jetty-ssl.xml | 2 +-
.../src/test/resources/jetty/router-jetty.xml | 2 +-
.../src/test/resources/spring-router-ssl.xml | 2 +-
.../src/test/resources/spring-server-ssl-node.xml | 2 +-
.../SystemViewRowAttributeWalkerGenerator.java | 2 +
.../ignite/compatibility/cache/LocalCacheTest.java | 136 ++
.../ignite/compatibility/cache/package-info.java} | 14 +-
.../IgniteCompatibilityBasicTestSuite.java | 4 +-
modules/core/pom.xml | 2 +-
.../src/main/java/org/apache/ignite/Ignite.java | 3 +
.../main/java/org/apache/ignite/IgniteCluster.java | 6 +
.../org/apache/ignite/IgniteSystemProperties.java | 8 +
.../cache/store/jdbc/CacheAbstractJdbcStore.java | 8 +-
.../cache/store/jdbc/dialect/BasicJdbcDialect.java | 14 +-
.../cache/store/jdbc/dialect/MySQLDialect.java | 14 +-
.../org/apache/ignite/cluster/ClusterState.java | 7 +-
.../ignite/configuration/CacheConfiguration.java | 34 +
.../PlatformNearCacheConfiguration.java | 113 ++
.../apache/ignite/internal/ComputeMXBeanImpl.java | 92 ++
.../ignite/internal/GridKernalContextImpl.java | 6 +-
.../org/apache/ignite/internal/IgniteFeatures.java | 8 +
.../ignite/internal/IgniteMessagingImpl.java | 20 +-
.../internal/IgniteTooManyOpenFilesException.java | 66 +
.../apache/ignite/internal/QueryMXBeanImpl.java | 210 +++
...reFilter.java => SecurityAwareBiPredicate.java} | 25 +-
.../apache/ignite/internal/ServiceMXBeanImpl.java | 57 +
.../ignite/internal/TransactionsMXBeanImpl.java | 18 +-
.../internal/client/GridClientClusterState.java | 18 +-
.../client/impl/GridClientClusterStateImpl.java | 33 +-
.../impl/connection/GridClientConnection.java | 22 +-
.../connection/GridClientNioTcpConnection.java | 31 +-
.../internal/client/thin/ReliableChannel.java | 28 +-
.../internal/client/util/GridClientUtils.java | 41 +
.../ignite/internal/cluster/IgniteClusterImpl.java | 10 +-
.../internal/commandline/ActivateCommand.java | 3 +-
.../commandline/ClusterStateChangeCommand.java | 25 +-
.../internal/commandline/CommandHandler.java | 37 +-
.../ignite/internal/commandline/CommandList.java | 6 +-
.../internal/commandline/CommonArgParser.java | 13 +-
.../commandline/ConnectionAndSslParameters.java | 16 +-
.../internal/commandline/DeactivateCommand.java | 28 +-
.../ignite/internal/commandline/TxCommands.java | 32 +-
.../commandline/cache/CacheValidateIndexes.java | 37 +-
.../cache/argument/ValidateIndexesCommandArg.java | 3 +
.../internal/commandline/query/KillCommand.java | 214 +++
.../query/KillSubcommand.java} | 65 +-
.../internal/dto/IgniteDataTransferObject.java | 3 +
.../internal/managers/GridManagerAdapter.java | 18 +
.../internal/managers/IgniteMBeansManager.java | 18 +
.../managers/communication/GridIoManager.java | 94 +-
.../communication/IgniteMessageFactoryImpl.java | 37 +-
.../managers/discovery/CustomMessageWrapper.java | 3 +-
.../managers/discovery/DiscoveryCustomMessage.java | 8 -
.../systemview/walker/ComputeJobViewWalker.java | 77 ++
.../systemview/walker/ComputeTaskViewWalker.java | 50 +-
.../internal/pagemem/wal/record/WALRecord.java | 7 +-
...ageInitRootInlineFlagsCreatedVersionRecord.java | 98 ++
.../wal/record/delta/TrackingPageDeltaRecord.java | 30 +-
.../delta/TrackingPageRepairDeltaRecord.java} | 42 +-
.../authentication/UserAcceptedMessage.java | 5 -
.../authentication/UserProposedMessage.java | 5 -
.../cache/CacheAffinityChangeMessage.java | 5 -
.../cache/CacheStatisticsClearMessage.java | 5 -
.../cache/CacheStatisticsModeChangeMessage.java | 5 -
.../cache/ClientCacheChangeDiscoveryMessage.java | 5 -
.../ClientCacheChangeDummyDiscoveryMessage.java | 5 -
.../processors/cache/DynamicCacheChangeBatch.java | 5 -
.../cache/DynamicCacheChangeFailureMessage.java | 5 -
.../processors/cache/GridCacheAdapter.java | 11 +-
.../processors/cache/GridCacheContext.java | 5 +-
.../processors/cache/GridCacheEntryEx.java | 7 +-
.../processors/cache/GridCacheMapEntry.java | 70 +-
.../cache/GridCachePartitionExchangeManager.java | 17 +
.../processors/cache/GridCacheProcessor.java | 59 +-
.../cache/IgniteCacheOffheapManager.java | 5 +
.../cache/IgniteCacheOffheapManagerImpl.java | 61 +-
.../internal/processors/cache/QueryCursorImpl.java | 40 +-
...TimeoutOnPartitionMapExchangeChangeMessage.java | 5 -
.../processors/cache/WalStateFinishMessage.java | 8 +-
.../internal/processors/cache/WalStateManager.java | 2 +-
.../processors/cache/WalStateProposeMessage.java | 10 +-
.../binary/MetadataUpdateAcceptedMessage.java | 5 -
.../binary/MetadataUpdateProposedMessage.java | 5 -
.../distributed/GridDistributedCacheEntry.java | 7 +-
.../cache/distributed/dht/GridDhtCacheEntry.java | 2 +
.../preloader/GridDhtPartitionsExchangeFuture.java | 16 +-
.../dht/preloader/latch/ExchangeLatchManager.java | 13 +-
.../cache/distributed/near/GridNearCacheEntry.java | 10 +
.../cache/local/GridLocalCacheEntry.java | 8 +-
.../CheckpointWriteProgressSupplier.java | 45 -
.../GridCacheDatabaseSharedManager.java | 786 ++++-------
.../cache/persistence/GridCacheOffheapManager.java | 10 +
.../IgniteCacheDatabaseSharedManager.java | 1 +
.../persistence/checkpoint/CheckpointProgress.java | 106 ++
.../checkpoint/CheckpointProgressImpl.java | 271 ++++
.../checkpoint/PartitionDestroyQueue.java | 77 ++
.../checkpoint/PartitionDestroyRequest.java | 127 ++
.../cache/persistence/metastorage/MetaStorage.java | 2 +-
.../cache/persistence/pagemem/PageMemoryImpl.java | 19 +-
.../pagemem/PagesWriteSpeedBasedThrottle.java | 19 +-
.../persistence/pagemem/PagesWriteThrottle.java | 15 +-
.../cache/persistence/tree/BPlusTree.java | 12 +-
.../cache/persistence/tree/io/BPlusMetaIO.java | 175 ++-
.../cache/persistence/tree/io/TrackingPageIO.java | 18 +-
.../wal/serializer/RecordDataV1Serializer.java | 60 +-
.../wal/serializer/RecordDataV2Serializer.java | 18 +
.../cache/query/GridCacheQueryManager.java | 8 +-
.../query/continuous/SecurityAwareFilter.java | 1 +
.../continuous/SecurityAwareFilterFactory.java | 1 +
.../SecurityAwareTransformerFactory.java | 1 +
.../cache/transactions/IgniteTxStateImpl.java | 2 +-
.../processors/cache/tree/CacheDataTree.java | 2 +
.../processors/cache/verify/IdleVerifyUtility.java | 2 +-
.../cluster/ChangeGlobalStateFinishMessage.java | 5 -
.../cluster/ChangeGlobalStateMessage.java | 19 +-
.../cluster/GridClusterStateProcessor.java | 119 +-
.../cluster/IGridClusterStateProcessor.java | 17 +-
.../continuous/AbstractContinuousMessage.java | 5 -
.../continuous/StopRoutineAckDiscoveryMessage.java | 5 -
.../internal/processors/job/GridJobProcessor.java | 35 +-
.../internal/processors/job/GridJobWorker.java | 28 +-
.../marshaller/MappingAcceptedMessage.java | 5 -
.../marshaller/MappingProposedMessage.java | 5 -
.../DistributedMetaStorageUpdateAckMessage.java | 5 -
.../DistributedMetaStorageUpdateMessage.java | 5 -
.../processors/metric/GridMetricManager.java | 6 +
.../processors/metric/impl/MetricUtils.java | 24 +-
.../ClientListenerAbstractConnectionContext.java | 8 +-
.../odbc/ClientListenerConnectionContext.java | 5 +-
.../processors/odbc/ClientListenerNioListener.java | 10 +-
.../odbc/jdbc/JdbcConnectionContext.java | 14 +-
.../odbc/odbc/OdbcConnectionContext.java | 12 +-
.../processors/platform/PlatformContext.java | 29 +
.../processors/platform/PlatformContextImpl.java | 78 +-
.../processors/platform/PlatformNoopProcessor.java | 16 +
.../processors/platform/PlatformProcessor.java | 22 +
.../processors/platform/PlatformProcessorImpl.java | 63 +-
.../processors/platform/cache/PlatformCache.java | 22 +
.../platform/cache/PlatformCacheEntryFilter.java | 9 +
.../cache/PlatformCacheEntryFilterImpl.java | 67 +-
.../platform/cache/PlatformCacheManager.java | 86 ++
.../platform/cache/affinity/PlatformAffinity.java | 30 +
.../platform/callback/PlatformCallbackGateway.java | 74 ++
.../platform/callback/PlatformCallbackOp.java | 12 +
.../platform/client/ClientConnectionContext.java | 6 +-
.../platform/cluster/PlatformClusterGroup.java | 45 +-
.../platform/utils/PlatformConfigurationUtils.java | 28 +
.../processors/platform/utils/PlatformUtils.java | 4 +-
.../internal/processors/query/GridQueryCancel.java | 7 +-
.../processors/query/GridQueryIndexing.java | 11 +
.../processors/query/GridQueryProcessor.java | 9 +-
.../schema/SchemaIndexCachePartitionWorker.java | 72 +-
.../query/schema/SchemaIndexCacheStat.java | 88 ++
.../query/schema/SchemaIndexCacheVisitorImpl.java | 98 +-
.../message/SchemaFinishDiscoveryMessage.java | 5 -
.../message/SchemaProposeDiscoveryMessage.java | 5 -
.../processors/resource/GridResourceIoc.java | 19 +-
.../processors/resource/GridResourceProcessor.java | 9 +-
.../processors/rest/GridRestProcessor.java | 1 +
.../message/GridClientClusterStateRequest.java | 5 +-
...t.java => GridClientClusterStateRequestV2.java} | 52 +-
.../GridChangeClusterStateCommandHandler.java | 3 +-
.../cluster/GridChangeStateCommandHandler.java | 5 +-
.../rest/protocols/tcp/GridTcpRestNioListener.java | 7 +
.../rest/request/GridRestChangeStateRequest.java | 20 +
.../rest/request/GridRestClusterStateRequest.java | 21 +
.../processors/rest/request/GridRestRequest.java | 18 +
.../AbstractSecurityAwareExternalizable.java | 2 +-
.../service/ServiceChangeBatchRequest.java | 5 -
.../ServiceClusterDeploymentResultBatch.java | 5 -
.../processors/task/GridTaskProcessor.java | 4 +-
.../org/apache/ignite/internal/sql/SqlKeyword.java | 12 +
.../org/apache/ignite/internal/sql/SqlParser.java | 24 +
.../sql/command/SqlKillComputeTaskCommand.java | 66 +
.../sql/command/SqlKillContinuousQueryCommand.java | 81 ++
.../internal/sql/command/SqlKillQueryCommand.java | 51 +-
.../sql/command/SqlKillScanQueryCommand.java | 97 ++
.../sql/command/SqlKillServiceCommand.java | 63 +
.../sql/command/SqlKillTransactionCommand.java | 63 +
.../util/GridConcurrentMultiPairQueue.java | 202 +++
.../internal/util/GridReadOnlyArrayView.java | 80 --
.../apache/ignite/internal/util/IgniteUtils.java | 198 +++
.../internal/util/distributed/FullMessage.java | 5 -
.../internal/util/distributed/InitMessage.java | 5 -
.../ignite/internal/util/nio/GridNioServer.java | 14 -
.../ignite/internal/util/nio/GridNioSession.java | 6 +
.../internal/util/nio/GridNioSessionImpl.java | 20 +
.../internal/util/nio/ssl/GridNioSslFilter.java | 2 +
...ask.java => VisorComputeCancelSessionTask.java} | 37 +-
.../compute/VisorComputeCancelSessionTaskArg.java | 73 ++
.../compute/VisorComputeCancelSessionsTask.java | 4 +-
.../VisorContinuousQueryCancelTask.java} | 38 +-
.../query/VisorContinuousQueryCancelTaskArg.java | 89 ++
.../VisorQueryCancelOnInitiatorTask.java} | 43 +-
.../query/VisorQueryCancelOnInitiatorTaskArg.java | 81 ++
.../VisorScanQueryCancelTask.java} | 35 +-
.../visor/query/VisorScanQueryCancelTaskArg.java | 101 ++
.../visor/service/VisorCancelServiceTask.java | 6 +-
.../visor/verify/VisorValidateIndexesTaskArg.java | 34 +-
.../apache/ignite/lang/IgniteProductVersion.java | 14 +-
.../AbstractNodeNameAwareMarshaller.java | 8 +-
.../org/apache/ignite/marshaller/Marshaller.java | 10 +-
.../ComputeMXBean.java} | 26 +-
.../org/apache/ignite/mxbean/IgniteMXBean.java | 9 +-
.../java/org/apache/ignite/mxbean/QueryMXBean.java | 67 +
.../ServiceMXBean.java} | 16 +-
.../apache/ignite/mxbean/TransactionsMXBean.java | 12 +
.../plugin/security/AuthenticationContext.java | 21 +
.../security/SecurityPermissionSetBuilder.java | 7 +-
.../ignite/plugin/security/SecuritySubject.java | 10 +
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 33 +-
.../org/apache/ignite/spi/IgniteSpiContext.java | 36 +
.../tcp/TcpCommunicationMetricsListener.java | 156 ++-
.../spi/communication/tcp/TcpCommunicationSpi.java | 79 +-
.../spi/discovery/DiscoverySpiCustomMessage.java | 4 +-
.../ignite/spi/discovery/tcp/ClientImpl.java | 10 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 3 +-
.../ignite/spi/discovery/tcp/TcpDiscoverySpi.java | 18 +-
.../ignite/spi/metric/jmx/MetricRegistryMBean.java | 55 +-
.../ignite/spi/systemview/view/ComputeJobView.java | 197 +++
.../spi/systemview/view/ComputeTaskView.java | 60 +-
.../org/apache/ignite/ssl/SslContextFactory.java | 29 +-
.../main/resources/META-INF/classnames.properties | 2 +
modules/core/src/test/config/tests.properties | 26 +-
.../jdbc/CacheJdbcPojoStoreAbstractSelfTest.java | 42 +-
.../failure/FailureHandlerTriggeredTest.java | 4 -
.../DiagnosticLogForPartitionStatesTest.java | 103 +-
.../ThinClientAbstractPartitionAwarenessTest.java | 22 +
...lientPartitionAwarenessResourceReleaseTest.java | 74 ++
.../commandline/CommandHandlerParsingTest.java | 138 +-
.../IgniteMessageFactoryImplTest.java | 47 +-
.../IncompleteDeserializationExceptionTest.java | 5 -
.../ignite/internal/metric/JmxExporterSpiTest.java | 51 +-
.../ignite/internal/metric/MetricsSelfTest.java | 8 +-
.../internal/metric/SystemViewComputeJobTest.java | 517 ++++++++
.../cache/ClusterStateThinClientAbstractTest.java | 2 +-
.../cache/GridCacheAbstractMetricsSelfTest.java | 27 +-
.../processors/cache/GridCacheTestEntryEx.java | 4 +-
.../dht/GridCacheColocatedDebugTest.java | 109 ++
.../preloader/latch/ExchangeLatchManagerTest.java | 75 ++
.../persistence/IgnitePdsCorruptedStoreTest.java | 3 +-
.../IgniteCheckpointDirtyPagesForLowLoadTest.java | 2 +-
.../db/checkpoint/ProgressWatchdog.java | 6 +-
.../pagemem/BPlusTreePageMemoryImplTest.java | 12 +-
.../BPlusTreeReuseListPageMemoryImplTest.java | 12 +-
.../IgnitePageMemReplaceDelayedWriteUnitTest.java | 12 +-
.../pagemem/IgniteThrottlingUnitTest.java | 14 +-
.../pagemem/IndexStoragePageMemoryImplTest.java | 12 +-
.../pagemem/PageMemoryImplNoLoadTest.java | 12 +-
.../persistence/pagemem/PageMemoryImplTest.java | 17 +-
.../pagemem/PagesWriteThrottleSandboxTest.java | 9 +-
.../cache/query/CacheScanQueryFailoverTest.java | 131 ++
.../CacheContinuousQueryLongP2PTest.java | 6 +-
.../continuous/GridEventConsumeSelfTest.java | 91 +-
.../processors/database/BPlusTreeSelfTest.java | 2 +-
.../GridCommandHandlerSslWithSecurityTest.java | 1 +
...eOperationPermissionCreateDestroyCheckTest.java | 164 +++
.../client/AdditionalSecurityCheckTest.java | 3 +-
.../client/ThinClientSslPermissionCheckTest.java | 237 ++++
.../TestCertificateSecurityPluginProvider.java} | 36 +-
....java => TestCertificateSecurityProcessor.java} | 91 +-
.../security/impl/TestSecurityContext.java | 7 +-
.../security/impl/TestSecurityProcessor.java | 1 +
.../security/impl/TestSecuritySubject.java | 19 +
.../MessagingRemoteSecurityContextCheckTest.java | 148 +++
.../util/GridConcurrentMultiPairQueueTest.java | 155 +++
.../ignite/internal/util/IgniteUtilsSelfTest.java | 137 +-
.../util/nio/impl/GridNioFilterChainSelfTest.java | 139 --
.../internal/util/nio/impl}/MockNioSession.java | 8 +-
.../loadtests/hashmap/GridCacheTestContext.java | 3 +-
.../ignite/platform/PlatformDeployServiceTask.java | 48 +-
.../ignite/platform/PlatformThreadUtils.java | 51 +
.../security/SecurityPermissionSetBuilderTest.java | 22 +-
.../TooManyOpenFilesTcpCommunicationSpiTest.java | 130 ++
.../spi/discovery/ClusterRebalancedMetricTest.java | 187 +++
.../FilterDataForClientNodeDiscoveryTest.java | 5 -
.../discovery/tcp/DiscoveryClientSocketTest.java | 184 +++
.../TcpDiscoveryPendingMessageDeliveryTest.java | 5 -
.../tcp/TcpDiscoverySslTrustedUntrustedTest.java | 16 +
.../apache/ignite/ssl/MultipleSSLContextsTest.java | 263 ++++
.../ignite/testframework/GridSpiTestContext.java | 30 +-
.../testframework/junits/IgniteTestResources.java | 16 +-
.../testframework/wal/record/RecordUtils.java | 8 +
.../testsuites/IgniteCacheMvccTestSuite6.java | 2 +
.../ignite/testsuites/IgniteCacheTestSuite6.java | 2 +
.../ignite/testsuites/IgniteCacheTestSuite9.java | 2 +
.../IgniteSpiCommunicationSelfTestSuite.java | 3 +
.../IgniteSpiDiscoverySelfTestSuite.java | 5 +-
.../ignite/testsuites/IgniteUtilSelfTestSuite.java | 4 +
.../ignite/testsuites/SecurityTestSuite.java | 12 +-
.../util/GridCommandHandlerClusterByClassTest.java | 104 +-
.../apache/ignite/util/GridCommandHandlerTest.java | 58 +
...andHandlerClusterByClassTest_cache_help.output} | 3 +-
...idCommandHandlerClusterByClassTest_help.output} | 45 +-
...lerClusterByClassWithSSLTest_cache_help.output} | 3 +-
...ndHandlerClusterByClassWithSSLTest_help.output} | 45 +-
.../resources/org.apache.ignite.util/bigUtf.txt | Bin 0 -> 430138 bytes
.../resources/org.apache.ignite.util/limitUtf.txt | 10 +
.../query/h2/opt/GridH2SpatialIndex.java | 8 +-
modules/hibernate-4.2/pom.xml | 2 +-
modules/hibernate-5.1/pom.xml | 2 +-
modules/hibernate-5.3/pom.xml | 2 +-
.../cache/query/RegisteredQueryCursor.java | 62 +-
.../processors/query/h2/CommandProcessor.java | 73 +-
.../processors/query/h2/ConcurrentStripedPool.java | 177 +++
.../processors/query/h2/ConnectionManager.java | 426 ++----
.../processors/query/h2/H2CachedStatementKey.java | 27 +-
.../internal/processors/query/h2/H2Connection.java | 207 +++
.../processors/query/h2/H2ConnectionWrapper.java | 133 --
.../processors/query/h2/H2FieldsIterator.java | 20 +-
.../processors/query/h2/H2PooledConnection.java | 129 ++
.../processors/query/h2/H2ResultSetIterator.java | 263 +++-
.../processors/query/h2/H2StatementCache.java | 25 +-
.../internal/processors/query/h2/H2Utils.java | 231 +++-
.../processors/query/h2/IgniteH2Indexing.java | 110 +-
.../internal/processors/query/h2/QueryParser.java | 448 +++----
.../processors/query/h2/SchemaManager.java | 54 +-
.../query/h2/database/H2PkHashIndex.java | 3 +-
.../processors/query/h2/database/H2Tree.java | 150 ++-
.../processors/query/h2/database/H2TreeIndex.java | 60 +-
.../query/h2/database/InlineIndexHelper.java | 2 +-
.../processors/query/h2/dml/UpdatePlan.java | 48 +-
.../processors/query/h2/dml/UpdatePlanBuilder.java | 13 +-
.../processors/query/h2/opt/GridH2IndexBase.java | 5 +-
.../processors/query/h2/opt/GridH2Table.java | 22 +-
.../processors/query/h2/opt/QueryContext.java | 46 +
.../query/h2/opt/QueryContextRegistry.java | 34 +-
.../query/h2/opt/join/DistributedLookupBatch.java | 29 +-
.../query/h2/sql/GridSqlQuerySplitter.java | 30 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 64 +-
.../query/h2/twostep/GridReduceQueryExecutor.java | 260 ++--
.../query/h2/twostep/MapQueryResult.java | 23 +-
.../query/h2/twostep/MapQueryResults.java | 9 -
.../query/h2/twostep/ReduceQueryRun.java | 15 -
.../visor/verify/ValidateIndexesClosure.java | 37 +-
.../visor/verify/VisorValidateIndexesTask.java | 7 +-
.../org/apache/ignite/client/ClientTestSuite.java | 4 +-
.../cache/IgniteCacheQueryH2IndexingLeakTest.java | 14 +-
.../cache/index/H2ConnectionLeaksSelfTest.java | 54 +-
.../cache/metric/SqlViewExporterSpiTest.java | 1 +
...xingMultithreadedLoadContinuousRestartTest.java | 2 +-
.../db/LongDestroyDurableBackgroundTaskTest.java | 2 +-
.../processors/database/RebuildIndexTest.java | 232 ++++
.../RebuildIndexWithHistoricalRebalanceTest.java | 2 +-
...actQueryTableLockAndConnectionPoolSelfTest.java | 123 +-
.../query/IgniteSqlGroupConcatCollocatedTest.java | 26 +
.../IgniteSqlGroupConcatNotCollocatedTest.java | 25 +
.../IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 2 +-
.../query/IgniteSqlSplitterSelfTest.java | 3 +-
.../internal/processors/query/KillQueryTest.java | 56 +-
.../processors/query/LocalQueryLazyTest.java | 128 +-
.../query/h2/GridIndexFullRebuildTest.java | 2 +-
.../processors/query/h2/QueryDataPageScanTest.java | 7 +-
.../query/h2/sql/GridQueryParsingTest.java | 60 +-
.../org/apache/ignite/sqltests/BaseSqlTest.java | 39 +
.../IgniteBinaryCacheQueryTestSuite.java | 6 +
.../testsuites/IgnitePdsWithIndexingTestSuite.java | 4 +-
...idCommandHandlerIndexingClusterByClassTest.java | 12 +
.../util/GridCommandHandlerIndexingTest.java | 55 +-
.../ignite/util/KillCommandsCommandShTest.java | 176 +++
.../apache/ignite/util/KillCommandsMXBeanTest.java | 181 +++
.../apache/ignite/util/KillCommandsSQLTest.java | 196 +++
.../org/apache/ignite/util/KillCommandsTests.java | 396 ++++++
.../opencensus/OpenCensusMetricExporterSpi.java | 25 +-
modules/platforms/.gitignore | 7 +-
.../ExpiryCacheHolderTest.cs | 5 +
.../Apache.Ignite.Benchmarks.csproj | 3 +
.../Apache.Ignite.Benchmarks/BenchmarkRunner.cs | 17 +-
.../Apache.Ignite.Benchmarks/Config/benchmark.xml | 23 +
.../Interop/GetNearBenchmark.cs | 64 +
.../Interop/PutNearBenchmark.cs | 59 +
.../Interop/ScanQueryBenchmark.cs | 86 ++
.../Apache.Ignite.Core.Tests.DotNetCore.csproj | 59 +
.../Apache.Ignite.Core.Tests.csproj | 10 +-
.../Binary/BinaryStructureTest.cs | 130 ++
.../Binary/TypeNameParserTest.cs | 22 +-
.../Cache/CacheMetricsTest.cs | 82 ++
.../Cache/CacheNearTest.cs | 200 ---
.../Cache/CacheTestAsyncWrapper.cs | 8 +-
.../Cache/Near/CacheNearCreateDestroy.cs | 348 +++++
.../Cache/Near/CacheNearTest.cs | 1371 ++++++++++++++++++++
.../Cache/Near/CacheNearTopologyChangeTest.cs | 614 +++++++++
.../Cache/Near/FailingCacheStore.cs | 72 +
.../Apache.Ignite.Core.Tests/Cache/Near/Foo.cs | 66 +
.../Cache/Near/ScanQueryNearCacheFilter.cs} | 33 +-
.../Cache/Near/ScanQueryNoNearCacheFilter.cs} | 36 +-
.../Cache/Near/StoreNoNearCacheFilter.cs} | 32 +-
.../Cache/Query/Linq/CacheLinqTest.Misc.cs | 7 +-
.../Cache/Store/CacheStoreTest.cs | 3 +-
.../Client/Cache/ListLogger.cs | 19 +-
.../Config/full-config.xml | 1 +
.../IgniteConfigurationSerializerTest.cs | 11 +
.../Apache.Ignite.Core.Tests/IgniteUtilsTest.cs | 71 +
.../Services/ServicesTest.cs | 47 +
.../Apache.Ignite.Core.Tests/TestUtils.Common.cs | 49 +-
.../Apache.Ignite.Core/Apache.Ignite.Core.csproj | 5 +
.../Apache.Ignite.Core/Cache/CachePeekMode.cs | 9 +-
.../Cache/Configuration/CacheConfiguration.cs | 31 +
.../PlatformNearCacheConfiguration.cs | 72 +
.../Cache/Eviction/FifoEvictionPolicy.cs | 2 +-
.../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 5 +
.../Cache/Store/CacheStoreAdapter.cs | 2 +-
.../Apache.Ignite.Core/Cluster/IClusterGroup.cs | 7 +-
.../Apache.Ignite.Core/Events/DiscoveryEvent.cs | 2 +-
.../platforms/dotnet/Apache.Ignite.Core/IIgnite.cs | 53 +
.../IgniteConfigurationSection.xsd | 22 +
.../Impl/Binary/Structure/BinaryStructure.cs | 135 +-
.../Impl/Binary/Structure/BinaryStructureEntry.cs | 2 +-
.../Impl/Cache/CacheAffinityImpl.cs | 18 +-
.../Impl/Cache/CacheEntryFilterHolder.cs | 40 +-
.../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 480 ++++++-
.../Apache.Ignite.Core/Impl/Cache/CacheOp.cs | 4 +-
.../Impl/Cache/Near/INearCache.cs | 82 ++
.../Impl/Cache/Near/NearCache.cs | 275 ++++
.../Impl/Cache/Near/NearCacheEntry.cs | 85 ++
.../Impl/Cache/Near/NearCacheManager.cs | 198 +++
.../Impl/Cache/Query/QueryCursor.cs | 2 +-
.../Impl/Cache/Query/QueryCursorBase.cs | 2 +-
.../Impl/Client/Cache/ClientCachePartitionMap.cs | 14 +-
.../Impl/Client/ClientFailoverSocket.cs | 8 +-
.../Impl/Client/Cluster/ClientClusterGroup.cs | 3 +-
.../Apache.Ignite.Core/Impl/Client/IgniteClient.cs | 26 +
.../Impl/Cluster/ClusterGroupImpl.cs | 66 +-
.../Impl/Common/CopyOnWriteConcurrentDictionary.cs | 24 +
.../Apache.Ignite.Core/Impl/Common/TaskRunner.cs | 22 +-
.../Apache.Ignite.Core/Impl/IIgniteInternal.cs | 30 +-
.../Impl/IPlatformTargetInternal.cs | 2 +-
.../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 118 +-
.../dotnet/Apache.Ignite.Core/Impl/IgniteUtils.cs | 12 +-
.../Apache.Ignite.Core/Impl/PlatformJniTarget.cs | 10 +-
.../Impl/PlatformTargetAdapter.cs | 53 +-
.../Impl/Services/ServiceProxySerializer.cs | 13 +
.../Impl/Unmanaged/UnmanagedCallbackOp.cs | 6 +-
.../Impl/Unmanaged/UnmanagedCallbacks.cs | 61 +-
.../Apache.Ignite.DotNetCore.sln.DotSettings | 1 +
modules/platforms/dotnet/Apache.Ignite.sln | 1 -
.../platforms/dotnet/Apache.Ignite.sln.DotSettings | 1 +
.../Datagrid/NearCacheExample.cs | 10 +-
.../protocols/http/jetty/GridJettyRestHandler.java | 28 +-
.../IgniteSpringDataCrudSelfExpressionTest.java | 21 +
.../misc/PersonExpressionRepository.java | 2 +-
.../IgniteSpringDataCrudSelfExpressionTest.java | 21 +
.../misc/PersonExpressionRepository.java | 2 +-
modules/spring/pom.xml | 7 +
.../visor/commands/open/VisorOpenCommand.scala | 13 +-
.../src/test/resources/jetty-with-ciphers-0.xml | 2 +-
.../src/test/resources/jetty-with-ciphers-1.xml | 2 +-
.../src/test/resources/jetty-with-ciphers-2.xml | 2 +-
.../src/test/resources/jetty-with-ssl.xml | 2 +-
.../ZkCommunicationErrorResolveFinishMessage.java | 1 +
.../ZkCommunicationErrorResolveStartMessage.java | 1 +
.../zk/internal/ZkForceNodeFailMessage.java | 1 +
.../discovery/zk/internal/ZkNoServersMessage.java | 1 +
.../zk/internal/ZookeeperDiscoveryImpl.java | 33 +-
.../ZookeeperDiscoveryCustomEventsTest.java | 339 -----
parent/pom.xml | 4 +-
524 files changed, 19387 insertions(+), 4825 deletions(-)
diff --cc modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/SchemaManager.java
index 7f22861,826fb2d..424f010
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/SchemaManager.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/SchemaManager.java
@@@ -331,12 -326,8 +330,9 @@@ public class SchemaManager
H2Schema schema = schema(schemaName);
- Connection conn = null;
- try {
- conn = connMgr.connectionForThread().connection(schema.schemaName());
-
+ try(H2PooledConnection conn = connMgr.connection(schema.schemaName())) {
GridH2Table h2tbl = createTable(schema.schemaName(), schema, tblDesc, conn);
+ lsnr.onSqlTypeCreate(schemaName, type, cacheInfo);
schema.add(tblDesc);