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/02/06 15:19:19 UTC
[ignite] branch ignite-12248 updated (095804d -> 325987f)
This is an automated email from the ASF dual-hosted git repository.
gvvinblade pushed a change to branch ignite-12248
in repository https://gitbox.apache.org/repos/asf/ignite.git.
from 095804d IGNITE-12448: Calcite integration. Communication protocol. IGNITE-12449: Calcite integration. Execution flow. This closes #7272
add 7af9887 IGNITE-12440 Sensitive data leak in partition release future messages - Fixes #7195.
add 8427f38 IGNITE-12480 Add BinaryFieldExtractionSelfTest to the Binary Objects test suite - Fixes #7179.
add 2a3355f IGNITE-12259 Create new module to support spring-5.2.x and spring-data-2.2.x - Fixes #6978.
add b0e34f0 IGNITE-12259 Fix build.
add 58a4322 IGNITE-12259 Add testsuite after rename.
add c10d8c3 IGNITE-12186: TDE. Phase-2. Master key rotation. (#6937)
add 2b8e14f IGNITE-12193: Add rebalancing metrics for cache groups. (#6960)
add 622c34d IGNITE-11977: Fix metric type for GridDataStreamExecutor (#6695)
add ea92286 IGNITE-12482 Fix query mapping on nodes for REPLICATED caches when there are MOVING partitions - Fixes #7182.
add 02f5358 IGNITE-12385 .NET Thin Client: Introduce ClusterGroup API
add 31d6ad7 IGNITE-12501: Clarify checked exception on node left to the ClusterTopologyCheckedException (#7203)
add 06fe064 IGNITE-12167: Move resetting of BPlusTree.pageHndWrapper to GridAbstractTest. This closes #6962.
add 8d9ffc5 IGNITE-12511: Fix misleading javadoc. This closes #7214.
add 4d6fc4c IGNITE-12512: SQL: Compact logs for cancelled queries. This closes #7215.
add c97b08e IGNITE-12491 Dirty pages count calculation optimized.
add 8d7363d IGNITE-12486 Index calculation in FileWriteAheadLogManager#rollOver fixed.
add 5238ca2 IGNITE-12487 Removed wrong assertion from GridIoManager#sendToGridTopic.
add 8ffb154 IGNITE-12513:SQL: Improve QueryEntity field conflict message. This closes #7218.
add 5ce68bc IGNITE-12458 Rename Affinity Awareness to Partition Awareness
add f550b95 IGNITE-12356 Migrate Flink module to ignite-extensions - Fixes #7222.
add 66593af IGNITE-12479 Make binary metadata be registered only once per type creation - Fixes #7178.
add c402a49 IGNITE-12471 .NET Thin Client: Fix WithExpiryPolicy crash
add 4a31ffb IGNITE-12520: Update a year in copyright in control utility output tests. (#7224)
add c8c21c3 IGNITE-12521: change copyrights to the new 2020 year (#7226)
add 99e037c IGNITE-12515 Fixed flaky GridMultinodeRedeploySharedModeSelfTest.testSharedMode - Fixes #7220.
add 60c4051 IGNITE-12485 Avoid toString when recording DiscoveryEvent message - Fixes #7184.
add 5f0d4a7 IGNITE-12506 Deadlock in WAL archiver fixed - Fixes #7207.
add 2a8ab4a IGNITE-12225 Add enum for cluster state - Fixes #7194.
add 3a08128 IGNITE-12514 Fixed WAL don't flush several last records in LOG-ONLY/FSYNC mode if flush ptr=null
add 25a645e IGNITE-12378 .NET: Fix NuGet package warnings
add 085c247 IGNITE-12524 Partition reserve/release symmetry should be checked on release/destroy (#7236)
add 594061d IGNITE-12523 Added throttling for thread dumps generation on system failure.
add b8b8d68 IGNITE-12528: fix javadoc build with adding package group (#7243)
add 03636e6 IGNITE-11987: Metrics configuration. (#6696)
add 7633a3b IGNITE-12534: [Spark] The spark 2.4 is not found in optional folder (#7248)
add 50f8f8c IGNITE-12403 Throttle output of bytes in PageMemoryTracker/tests - Fixes #7086.
add 1d97529 IGNITE-12108: TCP Communication Metrics migration to a new framework. (#6814)
add 4f986d5 IGNITE-12475: TDE - Phase-2. CLI process management (#7205)
add 5b8f468 IGNITE-12542: Fix of broken tests. (#7261)
add 3085cbc IGNITE-12484: Fix issues related to client cache stop and SQL metadata retrieval.
add c1f8356 IGNITE-12538: GridAffinityAssignmentV2 can return unmodifiable collection in some cases. (#7255)
add b9bab88 IGNITE-12536: Inconsistency between cache data and indexes when cache operation is interrupted.
add 0a8b250 IGNITE-12342 Continuous Queries: Remote filter and transformer have to run with appropriate SecurityContext (#7125)
add dbf7f5d IGNITE-12547 Replace array of AtomicLong with AtomicLongArray in free list - Fixes #7267.
add f1adff9 IGNITE-12539: fix hibernate 5.3 javadoc errors (#7259)
add f0b88f6 IGNITE-12535: Pass custom CipherSuites to JDBC thin client. (#7252)
add 1fbc284 IGNITE-12101 Fixed NullPointerException when IgniteQueue.removeAll is called. - Fixes #7266.
add e31b530 IGNITE-12531 Cluster is unable to change BLT on 2.8 if storage was initially created on 2.7 or less - Fixes #7265.
add 5e95f65 IGNITE-12551 Partition desync if a partition is evicted then owned again and historically rebalanced. - Fixes #7270.
add 07812d4 IGNITE-12505 Improve node start-up and periodic logging - Fixes #7209.
add 72e49ef IGNITE-12227 Fix discovery pending messages logic causing incorrect calculation of baseline auto-adjust flag - Fixes #7150.
add f9a15d9 IGNITE-12463 Align checkpoint progress future state with the checkpoint state - Fixes #7153.
add 223281b IGNITE-12546 Prevent partitions owned by other nodes switch their state to MOVING due to counter difference on node join. - Fixes #7273.
add b677b36c IGNITE-12548 Fixed tx desync during recovery on near node left. - Fixes #7274.
add 5bd3859 IGNITE-12227 Fix failed compilation due to concurrent merge
add f4a42b7 IGNITE-12463 Fix failed compilation after concurrent merge
add 2a9239d IGNITE-12530 Pages list cache limit added to prevent IgniteOOME on checkpoint - Fixes #7245.
add cebc76f IGNITE-12545 Introduce listener interface for components to react to partition map exchange events - Fixes #7263.
add 214044a IGNITE-12459 Searching checkpoint record in WAL doesn't work with segment compaction - Fixes #7148.
add 6668d86 IGNITE-12460 Cluster fails to find the node by consistent ID - Fixes #7151.
add f8239aa IGNITE-12225 Fix wrong license header. - Fixes #7275.
add 891d0af IGNITE-12560 Fix incompatible API usage.
add 826a76a IGNITE-12560 Fix unused import.
add a41c03c IGNITE-12285 Removes boilerplate code in test PluginProvider implementations. (#6969)
add 274c443 IGNITE-12555 .NET: Fix SerializableSerializer performance
add f7c954c IGNITE-12497 PartitionsEvictManager should log all partitions which will be evicted - Fixes #7202.
add 0d8d958 IGNITE-12552: Move ReadOnlyMetricRegistry to public API. (#7269)
add 1f5f07e IGNITE-12540 Update versions of essential dependencies - Fixes #7260.
add de123e2 IGNITE-12474: Support newer boost.test versions.
add ee09a99 IGNITE-8641: Spring data example now uses its own xml config (#7280)
add 3639f92 IGNITE-12439 Warning about possible OOME if cache with too many partitions is created in a limited-size data region
add e89c71d IGNITE-12569 Can't set serialized enum to a BinaryObject's field - Fixes #7292.
add 41ed329 IGNITE-12567 H2Tree goes into illegal state when non-indexed columns are dropped - Fixes #7290.
add 6a87307 IGNITE-12565 Extend test coverage [IGNITE-9279] Support custom default SQL schema name - Fixes #7289.
add ffe7525 IGNITE-12573 Add missed example dependencies to standalone pom files
add 8a1b098 IGNITE-12559 Add @IgniteExperimental annotation - Fixes #7279.
add f7255cb IGNITE-12562 Fixed FreeListCachingTest.testPageListCacheLimit in Disk Page Compressions suite - Fixes #7288.
add 0e6b97e IGNITE-12470 Pme-free switch feature should be deactivatable (#7304)
add f09712e IGNITE-12574 Fix failing IoStatisticsBasicIndexSelfTest - Fixes #7303.
add e7dec60 IGNITE-12571 Statistics of query statement cache (#7299)
add 18dd974 IGNITE-12534 .NET: Disable Scala-related Maven profiles
add e160c8f IGNITE-12557 Fix possible IgniteOOM during cache destroy. - Fixes #7298.
add a1b939a4 IGNITE-12496 Correctly handle checkpoint read lock during index drop - Fixes #7208.
add 54a051b IGNITE-12580: NPE in GridMetricManager. (#7317)
add 3a62a3d IGNITE-11906 Fix test for scala examples - Fixes #7284.
add 21fab11 IGNITE-12583: JdbcThinBulkLoadAbstractSelfTest parametrization (#7319)
new 325987f Merge branch 'ignite-master' into ignite-12248
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
NOTICE | 2 +-
assembly/NOTICE_HADOOP | 2 +-
assembly/NOTICE_IGNITE | 2 +-
examples/config/spring/example-spring-data.xml | 64 +
examples/pom-standalone-lgpl.xml | 12 +
examples/pom-standalone.xml | 12 +
...fg.java => SpringApplicationConfiguration.java} | 22 +-
.../examples/springdata/SpringDataExample.java | 6 +-
.../tests/examples/ScalarExamplesSelfTest.scala | 19 +-
.../benchmarks/jol/GridMetricsJolBenchmark.java | 2 +-
modules/cassandra/store/pom.xml | 2 +-
.../internal/jdbc2/JdbcStreamingSelfTest.java | 91 +-
.../rest/JettyRestProcessorBaselineSelfTest.java | 19 +-
.../ignite/jdbc/JdbcErrorsAbstractSelfTest.java | 9 +-
.../jdbc/suite/IgniteJdbcDriverTestSuite.java | 24 +-
...JdbcThinDriverPartitionAwarenessTestSuite.java} | 22 +-
.../ignite/jdbc/thin/JdbcThinAbstractSelfTest.java | 4 +-
...cThinBulkLoadAtomicPartitionedNearSelfTest.java | 39 -
...SelfTest.java => JdbcThinBulkLoadSelfTest.java} | 84 +-
...inBulkLoadTransactionalPartitionedSelfTest.java | 39 -
...hinBulkLoadTransactionalReplicatedSelfTest.java | 39 -
.../JdbcThinConnectionMultipleAddressesTest.java | 2 +-
.../jdbc/thin/JdbcThinConnectionSSLTest.java | 272 +++-
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 314 ++---
.../jdbc/thin/JdbcThinDataSourceSelfTest.java | 2 +-
.../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 8 +-
...nAwarenessReconnectionAndFailoverSelfTest.java} | 24 +-
...ava => JdbcThinPartitionAwarenessSelfTest.java} | 34 +-
...hinPartitionAwarenessTransactionsSelfTest.java} | 6 +-
.../jdbc/thin/JdbcThinStatementSelfTest.java | 8 +-
.../IgnitePKIndexesMigrationToUnwrapPkTest.java | 1 -
.../persistence/MetaStorageCompatibilityTest.java | 348 +++++
.../IgniteCompatibilityBasicTestSuite.java | 6 +-
.../DiskPageCompressionIntegrationTest.java | 5 +-
modules/core/src/main/java/META-INF/NOTICE | 2 +-
.../src/main/java/org/apache/ignite/Ignite.java | 7 +
.../main/java/org/apache/ignite/IgniteBinary.java | 16 +-
.../main/java/org/apache/ignite/IgniteCache.java | 4 +
.../main/java/org/apache/ignite/IgniteCluster.java | 19 +-
.../java/org/apache/ignite/IgniteEncryption.java | 73 +
.../apache/ignite/IgniteJdbcThinDataSource.java | 20 +
.../org/apache/ignite/IgniteSystemProperties.java | 31 +-
.../java/org/apache/ignite/cache/QueryEntity.java | 11 +-
.../org/apache/ignite/cluster/ClusterState.java | 73 +
.../ignite/configuration/ClientConfiguration.java | 16 +-
.../configuration/DataRegionConfiguration.java | 9 +
.../configuration/DataStorageConfiguration.java | 9 +
.../ignite/configuration/IgniteConfiguration.java | 76 +-
.../configuration/MemoryPolicyConfiguration.java | 9 +
.../PersistentStoreConfiguration.java | 9 +
.../events/CacheConsistencyViolationEvent.java | 4 +
.../ignite/events/ClusterActivationEvent.java | 5 +-
...tionEvent.java => ClusterStateChangeEvent.java} | 66 +-
.../java/org/apache/ignite/events/EventType.java | 12 +
.../apache/ignite/internal/GridKernalContext.java | 6 +
.../ignite/internal/GridKernalContextImpl.java | 12 +
.../java/org/apache/ignite/internal/GridTopic.java | 6 +-
.../org/apache/ignite/internal/IgniteFeatures.java | 14 +-
.../org/apache/ignite/internal/IgniteKernal.java | 354 ++---
.../ignite/internal/IgniteNodeAttributes.java | 3 -
.../internal/binary/BinaryClassDescriptor.java | 68 +-
.../ignite/internal/binary/BinaryContext.java | 321 ++---
.../internal/binary/BinaryEnumObjectImpl.java | 13 +-
.../internal/binary/BinaryFieldAccessor.java | 4 +-
.../ignite/internal/binary/BinaryObjectExImpl.java | 4 +-
.../ignite/internal/binary/BinaryReaderExImpl.java | 8 +-
.../apache/ignite/internal/binary/BinaryUtils.java | 14 +-
.../ignite/internal/binary/BinaryWriterExImpl.java | 29 +-
.../internal/binary/builder/BinaryBuilderEnum.java | 2 +-
.../binary/builder/BinaryBuilderSerializer.java | 37 +-
.../binary/builder/BinaryEnumArrayLazyValue.java | 2 +-
.../binary/builder/BinaryObjectArrayLazyValue.java | 2 +-
.../binary/builder/BinaryObjectBuilderImpl.java | 13 +-
.../apache/ignite/internal/client/GridClient.java | 2 +-
.../internal/client/GridClientClusterState.java | 20 +-
.../ignite/internal/client/GridClientCompute.java | 2 +-
.../ignite/internal/client/GridClientData.java | 2 +-
.../client/impl/GridClientClusterStateImpl.java | 29 +-
.../impl/connection/GridClientConnection.java | 25 +-
.../connection/GridClientNioTcpConnection.java | 57 +-
.../client/thin/ClientCacheAffinityContext.java | 2 +-
.../client/thin/ClientCacheAffinityMapping.java | 10 +-
.../internal/client/thin/ProtocolVersion.java | 2 +-
.../internal/client/thin/ReliableChannel.java | 16 +-
.../internal/cluster/ClusterGroupAdapter.java | 11 +-
.../cluster/DistributedBaselineConfiguration.java | 101 +-
.../internal/cluster/IgniteClusterAsyncImpl.java | 9 +-
.../ignite/internal/cluster/IgniteClusterImpl.java | 23 +-
.../internal/commandline/ActivateCommand.java | 7 +-
.../ClusterReadOnlyModeDisableCommand.java | 72 -
.../ClusterReadOnlyModeEnableCommand.java | 72 -
.../commandline/ClusterStateChangeCommand.java | 105 ++
.../ignite/internal/commandline/Command.java | 73 +-
.../internal/commandline/CommandHandler.java | 1 +
.../ignite/internal/commandline/CommandList.java | 11 +-
.../internal/commandline/DeactivateCommand.java | 7 +-
.../ignite/internal/commandline/StateCommand.java | 26 +-
.../internal/commandline/cache/CacheCommands.java | 45 +-
.../commandline/encryption/EncryptionCommand.java | 125 ++
.../encryption/EncryptionSubcommand.java | 59 +
.../ignite/internal/jdbc/thin/AffinityCache.java | 8 +-
.../internal/jdbc/thin/ConnectionProperties.java | 46 +-
.../jdbc/thin/ConnectionPropertiesImpl.java | 73 +-
.../internal/jdbc/thin/JdbcThinConnection.java | 52 +-
...=> JdbcThinPartitionAwarenessMappingGroup.java} | 16 +-
.../ignite/internal/jdbc/thin/JdbcThinSSLUtil.java | 205 +--
.../ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 4 +-
.../internal/managers/IgniteMBeansManager.java | 32 +-
.../managers/checkpoint/GridCheckpointManager.java | 4 +-
.../managers/communication/GridIoManager.java | 13 +-
.../communication/GridIoMessageFactory.java | 6 +
.../deployment/GridDeploymentPerVersionStore.java | 16 +-
.../managers/discovery/GridDiscoveryManager.java | 27 +-
.../managers/encryption/EncryptionMXBeanImpl.java} | 29 +-
.../encryption/GenerateEncryptionKeyResponse.java | 26 +-
.../managers/encryption/GridEncryptionManager.java | 755 +++++++++--
.../managers/encryption}/package-info.java | 5 +-
.../ignite/internal/metric/IoStatisticsHolder.java | 5 +
.../internal/metric/IoStatisticsHolderCache.java | 21 +-
.../internal/metric/IoStatisticsHolderIndex.java | 25 +-
.../internal/metric/IoStatisticsHolderNoOp.java | 5 +
.../internal/metric/IoStatisticsHolderQuery.java | 5 +
.../ignite/internal/metric/IoStatisticsType.java | 10 +-
.../pagemem/wal/IgniteWriteAheadLogManager.java | 4 +-
.../pagemem/wal/record/MasterKeyChangeRecord.java | 68 +
.../internal/pagemem/wal/record/WALRecord.java | 5 +-
.../affinity/GridAffinityAssignmentV2.java | 8 +-
.../affinity/IdealAffinityAssignment.java | 2 +-
.../cache/CacheAffinitySharedManager.java | 116 ++
.../processors/cache/CacheGroupContext.java | 11 +
.../processors/cache/CacheGroupMetricsImpl.java | 19 +
.../processors/cache/CacheMetricsImpl.java | 12 +-
.../processors/cache/CacheObjectAdapter.java | 2 +-
.../processors/cache/ClusterCachesInfo.java | 31 +-
.../cache/DynamicCacheChangeRequest.java | 13 +
.../internal/processors/cache/ExchangeActions.java | 13 +-
.../internal/processors/cache/ExchangeContext.java | 17 +-
.../processors/cache/GridCacheAdapter.java | 13 +-
.../processors/cache/GridCacheContextInfo.java | 8 +
.../processors/cache/GridCacheMapEntry.java | 4 +-
.../cache/GridCachePartitionExchangeManager.java | 129 +-
.../processors/cache/GridCacheProcessor.java | 108 +-
.../cache/IgniteCacheOffheapManager.java | 2 +-
.../cache/IgniteCacheOffheapManagerImpl.java | 23 +-
.../processors/cache/KeyCacheObjectImpl.java | 2 +-
.../PartitionTxUpdateCounterDebugWrapper.java | 17 +
.../cache/PartitionTxUpdateCounterImpl.java | 2 +
.../processors/cache/StateChangeRequest.java | 34 +-
.../internal/processors/cache/WalStateManager.java | 24 +-
.../cache/binary/BinaryMetadataTransport.java | 2 +-
.../distributed/GridCacheTxRecoveryFuture.java | 15 +-
.../dht/GridDhtTopologyFutureAdapter.java | 3 +-
.../distributed/dht/GridDhtTxFinishFuture.java | 38 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 4 +-
.../dht/IgniteClusterReadOnlyException.java} | 17 +-
.../distributed/dht/atomic/GridDhtAtomicCache.java | 2 +-
.../dht/preloader/GridDhtPartitionDemander.java | 88 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 32 +-
.../dht/preloader/GridDhtPreloader.java | 4 +
.../dht/preloader/PartitionsExchangeAware.java | 69 +
.../dht/topology/GridClientPartitionTopology.java | 20 +-
.../dht/topology/GridDhtLocalPartition.java | 66 +-
.../dht/topology/GridDhtPartitionTopology.java | 8 +-
.../dht/topology/GridDhtPartitionTopologyImpl.java | 71 +-
.../dht/topology/PartitionsEvictManager.java | 131 +-
.../processors/cache/mvcc/txlog/TxLog.java | 3 +-
...eckpointFuture.java => CheckpointProgress.java} | 17 +-
...{CheckpointFuture.java => CheckpointState.java} | 25 +-
.../cache/persistence/DataRegionMetricsImpl.java | 5 +
.../GridCacheDatabaseSharedManager.java | 356 +++--
.../cache/persistence/GridCacheOffheapManager.java | 53 +-
.../IgniteCacheDatabaseSharedManager.java | 28 +-
.../persistence/file/FilePageStoreManager.java | 13 +-
.../persistence/freelist/AbstractFreeList.java | 20 +-
.../cache/persistence/freelist/CacheFreeList.java | 7 +-
.../cache/persistence/freelist/PagesList.java | 52 +-
.../cache/persistence/metastorage/MetaStorage.java | 49 +-
.../pendingtask/DurableBackgroundTask.java | 41 +
.../cache/persistence/pagemem/PageMemoryEx.java | 20 +-
.../cache/persistence/pagemem/PageMemoryImpl.java | 89 +-
.../partstorage/PartitionMetaStorageImpl.java | 6 +-
.../cache/persistence/tree/BPlusTree.java | 296 ++++-
.../persistence/tree/reuse/ReuseListImpl.java | 8 +-
.../wal/AbstractWalRecordsIterator.java | 5 +-
.../persistence/wal/FileWriteAheadLogManager.java | 49 +-
.../wal/filehandle/FileHandleManager.java | 4 +-
.../wal/filehandle/FileHandleManagerFactory.java | 5 -
.../wal/filehandle/FileHandleManagerImpl.java | 33 +-
.../wal/filehandle/FileWriteHandleImpl.java | 2 +-
.../wal/filehandle/FsyncFileHandleManagerImpl.java | 45 +-
.../wal/filehandle/FsyncFileWriteHandle.java | 6 +-
.../wal/reader/StandaloneGridKernalContext.java | 6 +
.../wal/serializer/RecordDataV1Serializer.java | 60 +-
.../cache/query/QueryEntityTypeDescriptor.java | 41 +-
.../AbstractSecurityAwareExternalizable.java} | 55 +-
.../continuous/CacheContinuousQueryManager.java | 69 +-
.../query/continuous/SecurityAwareFilter.java | 62 +
.../continuous/SecurityAwareFilterFactory.java | 52 +
.../SecurityAwareTransformerFactory.java | 67 +
.../cache/store/GridCacheStoreManagerAdapter.java | 2 +-
.../cache/store/GridCacheWriteBehindStore.java | 4 +-
.../cache/transactions/IgniteInternalTx.java | 5 +
.../cache/transactions/IgniteTxAdapter.java | 7 +-
.../cache/transactions/IgniteTxHandler.java | 48 +-
.../processors/cache/transactions/IgniteTxKey.java | 2 +-
.../cache/transactions/IgniteTxLocalAdapter.java | 7 -
.../cache/transactions/IgniteTxManager.java | 20 +-
.../transactions/TransactionMetricsAdapter.java | 6 +-
.../processors/cache/transactions/TxDeadlock.java | 2 +-
.../cache/transactions/TxEntryValueHolder.java | 8 +-
.../processors/cache/verify/IdleVerifyUtility.java | 8 +-
.../cluster/ChangeGlobalStateFinishMessage.java | 26 +-
.../cluster/ChangeGlobalStateMessage.java | 29 +-
.../cluster/DiscoveryDataClusterState.java | 111 +-
.../cluster/GridClusterStateProcessor.java | 540 ++++----
.../cluster/IGridClusterStateProcessor.java | 38 +-
.../baseline/autoadjust/ChangeTopologyWatcher.java | 17 +-
.../distributed/DistributedBooleanProperty.java | 2 +-
...ure.java => DistributedChangeableProperty.java} | 28 +-
.../distributed/DistributedComparableProperty.java | 2 +-
.../DistributedConfigurationLifecycleListener.java | 6 +
.../DistributedConfigurationProcessor.java | 76 +-
.../distributed/DistributedProperty.java | 119 +-
.../distributed/DistributedPropertyDispatcher.java | 21 +-
.../distributed/PropertyUpdateClosure.java | 12 +-
...roperty.java => SimpleDistributedProperty.java} | 92 +-
.../processors/datastreamer/DataStreamerImpl.java | 12 +-
.../datastructures/GridCacheQueueAdapter.java | 4 +-
.../processors/failure/FailureProcessor.java | 63 +-
.../localtask/DurableBackgroundTasksProcessor.java | 265 ++++
.../metastorage/DistributedMetaStorage.java | 10 +
.../persistence/DistributedMetaStorageImpl.java | 5 +
.../persistence/DmsDataWriterWorker.java | 2 +
.../processors/metric/GridMetricManager.java | 255 +++-
.../internal/processors/metric/MetricRegistry.java | 93 +-
.../processors/metric/MetricsMxBeanImpl.java | 75 ++
.../metric/PushMetricsExporterAdapter.java | 9 +-
...stogramMetric.java => HistogramMetricImpl.java} | 14 +-
.../processors/metric/impl/HitRateMetric.java | 18 +-
.../processors/metric/impl/MetricUtils.java | 69 +-
.../internal/processors/odbc/SqlStateCode.java | 4 +-
.../odbc/jdbc/JdbcCachePartitionsResult.java | 14 +-
.../odbc/jdbc/JdbcConnectionContext.java | 2 +-
.../processors/odbc/jdbc/JdbcRequestHandler.java | 16 +-
.../processors/platform/PlatformContext.java | 3 +-
.../processors/platform/PlatformContextImpl.java | 10 +-
.../platform/PlatformNativeException.java | 2 +-
.../platform/binary/PlatformBinaryProcessor.java | 15 +-
.../platform/client/ClientConnectionContext.java | 2 +-
.../platform/client/ClientMessageParser.java | 14 +
...ava => ClientCachePartitionAwarenessGroup.java} | 6 +-
.../client/cache/ClientCachePartitionsRequest.java | 30 +-
.../cache/ClientCachePartitionsResponse.java | 6 +-
.../ClientClusterGroupGetNodeIdsRequest.java | 77 ++
...a => ClientClusterGroupGetNodeIdsResponse.java} | 39 +-
.../ClientClusterGroupGetNodesDetailsRequest.java | 57 +
...ClientClusterGroupGetNodesDetailsResponse.java} | 39 +-
.../cluster/ClientClusterGroupProjection.java | 159 +++
.../ClientClusterWalChangeStateResponse.java | 2 +-
.../processors/query/GridQueryIndexing.java | 7 +
.../processors/query/GridQueryProcessor.java | 2 +-
.../processors/resource/GridResourceIoc.java | 9 +-
.../processors/resource/GridResourceProcessor.java | 2 +
.../GridResourceProxiedIgniteInjector.java | 42 +-
.../resource/GridResourceSupplierInjector.java | 64 +
.../internal/processors/rest/GridRestCommand.java | 19 +-
.../processors/rest/GridRestProcessor.java | 6 +-
...est.java => GridClientClusterStateRequest.java} | 40 +-
.../client/message/GridClientStateRequest.java | 3 +-
...a => GridChangeClusterStateCommandHandler.java} | 32 +-
.../rest/protocols/tcp/GridTcpRestNioListener.java | 21 +-
...quest.java => GridRestClusterStateRequest.java} | 26 +-
.../processors/security/SecurityUtils.java | 2 +-
.../internal/resources/MetricManagerResource.java} | 18 +-
.../sql/optimizer/affinity/PartitionResult.java | 12 +-
.../affinity/PartitionTableAffinityDescriptor.java | 4 +-
.../ignite/internal/util/GridArgumentCheck.java | 13 +
.../ignite/internal/util/GridStringBuilder.java | 13 +
.../apache/ignite/internal/util/IgniteUtils.java | 57 +-
.../ignite/internal/util/StripedExecutor.java | 10 +
.../util/distributed/DistributedProcess.java | 384 ++++++
.../distributed/FullMessage.java} | 96 +-
.../distributed/InitMessage.java} | 87 +-
.../util/distributed/SingleNodeMessage.java | 196 +++
.../ignite/internal/util/ipc/IpcToNioAdapter.java | 33 +-
.../util/nio/GridAbstractCommunicationClient.java | 8 +-
.../ignite/internal/util/nio/GridNioServer.java | 117 +-
.../util/nio/GridSelectorNioSessionImpl.java | 33 +-
.../util/nio/GridShmemCommunicationClient.java | 26 +-
.../util/nio/GridTcpNioCommunicationClient.java | 2 +-
.../util/tostring/GridToStringBuilder.java | 64 +-
.../internal/visor/baseline/VisorBaselineTask.java | 14 +-
...orFindAndDeleteGarbageInPersistenceClosure.java | 8 +-
.../visor/encryption/VisorChangeMasterKeyTask.java | 65 +
.../encryption/VisorGetMasterKeyNameTask.java | 63 +
.../org/apache/ignite/lang/IgniteExperimental.java | 37 +
.../org/apache/ignite/marshaller/Marshaller.java | 2 +
.../ignite/mxbean/DataRegionMetricsMXBean.java | 4 +
.../ignite/mxbean/DataStorageMetricsMXBean.java | 4 +
.../EncryptionMXBean.java} | 28 +-
.../org/apache/ignite/mxbean/IgniteMXBean.java | 49 +-
.../org/apache/ignite/mxbean/MetricsMxBean.java | 64 +
.../org/apache/ignite/plugin/PluginProvider.java | 7 +-
.../tcp/TcpCommunicationMetricsListener.java | 378 +++---
.../spi/communication/tcp/TcpCommunicationSpi.java | 69 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 38 +-
.../ignite/spi/encryption/EncryptionSpi.java | 18 +
.../encryption/keystore/KeystoreEncryptionSpi.java | 94 +-
.../spi/encryption/noop/NoopEncryptionSpi.java | 11 +
.../metric/HistogramMetric.java} | 21 +-
.../ignite/spi/metric/MetricExporterSpi.java | 6 +-
...ricRegistry.java => ReadOnlyMetricManager.java} | 9 +-
.../ignite/spi/metric/ReadOnlyMetricRegistry.java | 20 +-
.../spi/metric/jmx/JmxMetricExporterSpi.java | 75 +-
.../ignite/spi/metric/jmx/MetricRegistryMBean.java | 12 +-
.../spi/metric/noop/NoopMetricExporterSpi.java | 6 +-
.../spi/systemview/ReadOnlySystemViewRegistry.java | 4 +-
.../ignite/ssl/SSLServerSocketFactoryWrapper.java | 3 +-
.../org/apache/ignite/ssl/SslContextFactory.java | 63 +-
.../main/resources/META-INF/classnames.properties | 6 +-
.../cluster/GridClusterStateChangeSelfTest.java | 144 ++
.../ClusterBaselineNodesMetricsSelfTest.java | 22 +-
.../internal/GridNodeMetricsLogPdsSelfTest.java | 51 +-
.../internal/GridNodeMetricsLogSelfTest.java | 89 +-
.../internal/binary/BinaryMarshallerSelfTest.java | 4 +-
.../BinaryObjectBuilderAdditionalSelfTest.java | 139 +-
.../BinarySimpleNameTestPropertySelfTest.java | 3 +-
... ThinClientAbstractPartitionAwarenessTest.java} | 6 +-
...lientPartitionAwarenessStableTopologyTest.java} | 16 +-
...entPartitionAwarenessUnstableTopologyTest.java} | 48 +-
.../commandline/CommandHandlerParsingTest.java | 70 +-
.../encryption/AbstractEncryptionTest.java | 36 +-
.../internal/encryption/EncryptionMXBeanTest.java | 143 ++
.../MasterKeyChangeConsistencyCheckTest.java | 163 +++
.../internal/encryption/MasterKeyChangeTest.java | 426 ++++++
.../internal/metric/IoStatisticsCacheSelfTest.java | 5 +-
...IoStatisticsMetricsLocalMXBeanImplSelfTest.java | 28 +-
.../ignite/internal/metric/JmxExporterSpiTest.java | 18 +-
.../internal/metric/MetricsConfigurationTest.java | 383 ++++++
.../ignite/internal/metric/MetricsSelfTest.java | 20 +-
.../processors/DeadLockOnNodeLeftExchangeTest.java | 3 +-
.../AuthenticationProcessorNodeRestartTest.java | 39 +-
.../cache/ActiveOnStartPropertyTest.java | 149 +++
.../cache/AutoActivationPropertyTest.java | 128 ++
.../cache/CacheDataRegionConfigurationTest.java | 305 +++++
.../processors/cache/CacheGroupMetricsTest.java | 31 +
.../cache/CacheGroupsMetricsRebalanceTest.java | 207 ++-
...ActiveStateChangeWithNodeOutOfBaselineTest.java | 134 ++
.../cache/ClusterReadOnlyModeAbstractTest.java | 3 +-
.../processors/cache/ClusterReadOnlyModeTest.java | 4 +-
.../processors/cache/ClusterStateAbstractTest.java | 395 ++----
.../cache/ClusterStateClientAbstractTest.java | 58 +
.../ClusterStateClientPartitionedSelfTest.java} | 20 +-
.../ClusterStateClientReplicatedSelfTest.java} | 20 +-
.../cache/ClusterStateNoRebalanceAbstractTest.java | 219 +++
.../ClusterStateNoRebalancePartitionedTest.java} | 20 +-
.../ClusterStateNoRebalanceReplicatedTest.java} | 20 +-
.../cache/ClusterStateOnStartPropertyTest.java | 396 ++++++
.../cache/ClusterStatePartitionedSelfTest.java | 14 +-
.../cache/ClusterStateReplicatedSelfTest.java | 15 +-
.../cache/ClusterStateServerAbstractTest.java | 206 +++
.../processors/cache/ClusterStateTestUtils.java | 124 ++
.../cache/ClusterStateThinClientAbstractTest.java | 80 ++
...ClusterStateThinClientPartitionedSelfTest.java} | 20 +-
.../ClusterStateThinClientReplicatedSelfTest.java} | 20 +-
.../cache/GridCacheAbstractMetricsSelfTest.java | 8 +-
...dCacheTransactionalAbstractMetricsSelfTest.java | 6 +-
.../IgniteAbstractDynamicCacheStartFailTest.java | 22 +-
.../cache/IgniteClusterActivateDeactivateTest.java | 1388 ++++++++++++--------
...usterActivateDeactivateTestWithPersistence.java | 274 ++--
...teDynamicCacheStartFailWithPersistenceTest.java | 6 -
.../binary/BinaryMetadataRegistrationTest.java | 230 ++++
.../GridCacheBinaryObjectsAbstractSelfTest.java | 2 +-
.../distributed/CacheBaselineTopologyTest.java | 21 +-
.../CacheDataLossOnPartitionMoveTest.java | 6 +-
.../CachePartitionLostWhileClearingTest.java | 8 +-
.../distributed/CacheRentingStateRepairTest.java | 7 +-
.../distributed/GridExchangeFreeSwitchTest.java | 208 ++-
.../distributed/PartitionsExchangeAwareTest.java | 272 ++++
.../dht/topology/EvictPartitionInLogTest.java | 274 ++++
.../PartitionsEvictManagerAbstractTest.java | 2 +-
.../GridCacheRebalancingWithAsyncClearingTest.java | 7 +-
.../processors/cache/mvcc/CacheMvccVacuumTest.java | 19 +-
.../persistence/CleanupRestoredCachesSlowTest.java | 5 +-
...niteBaselineAffinityTopologyActivationTest.java | 24 +-
.../persistence/IgnitePdsCorruptedIndexTest.java | 7 +-
.../IgnitePdsDestroyCacheAbstractTest.java | 45 +-
.../persistence/IgnitePdsDestroyCacheTest.java | 101 ++
.../IgnitePdsPartitionFilesDestroyTest.java | 54 +-
...IgnitePdsSpuriousRebalancingOnNodeJoinTest.java | 170 +++
...gniteRebalanceScheduleResendPartitionsTest.java | 16 +-
...ocalWalModeChangeDuringRebalancingSelfTest.java | 11 +-
.../ClientAffinityAssignmentWithBaselineTest.java | 19 +-
.../baseline/ClusterActivationEventTest.java | 296 +++--
.../ClusterActivationEventWithPersistenceTest.java | 50 +
.../IgniteAbsentEvictionNodeOutOfBaselineTest.java | 7 +-
...hangingBaselineDownCachePutAllFailoverTest.java | 7 +-
...hangingBaselineDownCacheRemoveFailoverTest.java | 6 +-
...eChangingBaselineUpCachePutAllFailoverTest.java | 7 +-
...eChangingBaselineUpCacheRemoveFailoverTest.java | 7 +-
.../persistence/db/IgniteLogicalRecoveryTest.java | 9 +-
...IgnitePdsCacheWalDisabledOnRebalancingTest.java | 18 +-
.../db/IgnitePdsDataRegionMetricsTest.java | 6 +-
.../cache/persistence/db/IgnitePdsWithTtlTest.java | 15 +-
.../SlowHistoricalRebalanceSmallHistoryTest.java | 7 +-
.../db/checkpoint/CheckpointFreeListTest.java | 35 +
...CheckpointSimulationWithRealCpDisabledTest.java | 16 -
...eWalFlushMultiNodeFailoverAbstractSelfTest.java | 6 +-
.../persistence/db/wal/WalCompactionTest.java | 85 +-
.../db/wal/WalRecoveryTxLogicalRecordsTest.java | 18 +-
.../persistence/freelist/FreeListCachingTest.java | 109 +-
.../metastorage/IgniteMetaStorageBasicTest.java | 4 +-
.../cache/persistence/pagemem/NoOpWALManager.java | 4 +-
.../standbycluster/AbstractNodeJoinTemplate.java | 8 +-
.../standbycluster/IgniteStandByClusterTest.java | 76 +-
.../wal/memtracker/PageMemoryTracker.java | 15 +
.../PageMemoryTrackerPluginProvider.java | 52 +-
.../transactions/PartitionUpdateCounterTest.java | 8 +-
...ionIntegrityWithPrimaryIndexCorruptionTest.java | 4 +-
.../TxCrossCachePartitionConsistencyTest.java | 3 -
...acheRemoteMultiplePartitionReservationTest.java | 2 -
.../TxPartitionCounterStateAbstractTest.java | 46 +-
...ounterStateConsistencyHistoryRebalanceTest.java | 98 ++
.../TxPartitionCounterStateConsistencyTest.java | 28 +-
...unterStateConsistencyVolatileRebalanceTest.java | 10 +
...ounterStateOnePrimaryTwoBackupsFailAllTest.java | 7 +-
.../TxRecoveryWithConcurrentRollbackTest.java | 340 +++++
.../processors/cluster/BaselineAutoAdjustTest.java | 35 +-
.../cluster/ClusterReadOnlyModeNodeJoinTest.java | 8 +-
.../cluster/ClusterReadOnlyModeSelfTest.java | 86 +-
.../cluster/ClusterStateChangeEventTest.java | 159 +++
...ClusterStateChangeEventWithPersistenceTest.java | 36 +
.../DistributedConfigurationAbstractTest.java | 132 +-
.../DistributedConfigurationPersistentTest.java | 128 ++
.../TestDistibutedConfigurationPlugin.java | 68 +-
.../database/BPlusTreeReuseSelfTest.java | 2 +-
.../processors/database/CacheFreeListSelfTest.java | 3 +-
.../GridCacheReplicatedQueueRemoveSelfTest.java | 144 ++
.../FailureProcessorThreadDumpThrottlingTest.java | 203 +++
.../internal/processors/igfs/IgfsIgniteMock.java | 19 +-
.../DistributedMetaStoragePersistentTest.java | 6 +-
.../metastorage/DistributedMetaStorageTest.java | 34 +-
.../processors/query/DummyQueryIndexing.java | 5 +
.../rest/RestProcessorInitializationTest.java | 74 +-
...cheOperationRemoteSecurityContextCheckTest.java | 21 +-
.../AbstractRemoteSecurityContextCheckTest.java | 122 +-
.../AbstractTestSecurityPluginProvider.java | 73 +-
.../cache/ContinuousQueryPermissionCheckTest.java | 143 ++
...tinuousQueryRemoteSecurityContextCheckTest.java | 125 ++
...tinuousQueryRemoteSecurityContextCheckTest.java | 106 ++
...hTransformerRemoteSecurityContextCheckTest.java | 118 ++
...tryProcessorRemoteSecurityContextCheckTest.java | 2 +-
.../ScanQueryRemoteSecurityContextCheckTest.java | 2 +-
...teTaskCancelRemoteSecurityContextCheckTest.java | 1 -
...DataStreamerRemoteSecurityContextCheckTest.java | 2 +-
.../service/IgniteServiceReassignmentTest.java | 6 -
.../ServiceDeploymentOutsideBaselineTest.java | 30 +-
.../util/tostring/GridToStringBuilderSelfTest.java | 4 +-
.../tostring/TransactionSensitiveDataTest.java | 343 +++++
.../ignite/plugin/AbstractTestPluginProvider.java} | 59 +-
.../plugin/NodeValidationPluginProvider.java | 54 +-
.../tcp/TcpCommunicationStatisticsTest.java | 41 +
.../spi/discovery/ClusterMetricsSelfTest.java | 6 +-
.../IgniteDiscoveryCacheReuseSelfTest.java | 6 +-
.../encryption/KeystoreEncryptionSpiSelfTest.java | 41 +-
.../apache/ignite/testframework/GridTestUtils.java | 60 +-
.../ignite/testframework/ListeningTestLogger.java | 25 +
.../testframework/junits/GridAbstractTest.java | 70 +-
.../junits/GridTestKernalContext.java | 11 +
.../ignite/testframework/junits/IgniteMock.java | 6 +
.../testframework/junits/IgniteTestResources.java | 18 +-
.../junits/multijvm/IgniteClusterProcessProxy.java | 5 +-
.../junits/multijvm/IgniteProcessProxy.java | 6 +
.../ignite/testsuites/IgniteBasicTestSuite.java | 4 +
.../IgniteBasicWithPersistenceTestSuite.java | 14 +-
.../testsuites/IgniteBinaryObjectsTestSuite.java | 5 +-
.../IgniteCacheDataStructuresSelfTestSuite.java | 2 +
.../testsuites/IgniteCacheMvccTestSuite5.java | 12 +
.../testsuites/IgniteCacheMvccTestSuite6.java | 4 +
.../ignite/testsuites/IgniteCacheTestSuite5.java | 12 +
.../ignite/testsuites/IgniteCacheTestSuite6.java | 3 +
.../ignite/testsuites/IgniteCacheTestSuite7.java | 3 +
.../ignite/testsuites/IgniteCacheTestSuite9.java | 6 +-
.../testsuites/IgniteKernalSelfTestSuite.java | 4 +-
.../ignite/testsuites/IgnitePdsTestSuite.java | 7 +
.../ignite/testsuites/IgnitePdsTestSuite2.java | 6 +
.../ignite/testsuites/IgnitePdsTestSuite4.java | 2 +
.../testsuites/IgniteStandByClusterSuite.java | 4 +-
.../ignite/testsuites/IgniteUtilSelfTestSuite.java | 2 +
.../ignite/testsuites/SecurityTestSuite.java | 6 +
.../util/GridCommandHandlerAbstractTest.java | 40 +-
...idCommandHandlerClusterByClassAbstractTest.java | 3 +
.../util/GridCommandHandlerClusterByClassTest.java | 14 +
...idCommandHandlerClusterByClassWithSSLTest.java} | 16 +-
.../ignite/util/GridCommandHandlerSslTest.java | 7 +-
.../apache/ignite/util/GridCommandHandlerTest.java | 240 +++-
.../ignite/util/GridCommandHandlerTestUtils.java | 37 +
.../GridCommandHandlerWithSSLTest.java} | 16 +-
.../control.sh_cache_help.output | 2 +-
.../org.apache.ignite.util/control.sh_help.output | 23 +-
modules/core/src/test/resources/tde.jks | Bin 347 -> 813 bytes
modules/extdata/platform/pom.xml | 8 +
.../plugin/PlatformTestPluginProvider.java | 51 +-
modules/flink/pom.xml | 194 ---
.../org/apache/ignite/sink/flink/IgniteSink.java | 197 ---
.../apache/ignite/source/flink/IgniteSource.java | 223 ----
.../ignite/source/flink/TaskRemoteFilter.java | 60 -
.../ignite/sink/flink/FlinkIgniteSinkSelfTest.java | 84 --
.../source/flink/FlinkIgniteSourceSelfTest.java | 154 ---
.../flink/src/test/resources/example-ignite.xml | 73 -
.../hibernate/IgniteCollectionDataAccess.java | 32 +-
.../cache/hibernate/IgniteDomainDataRegion.java | 22 +-
.../cache/hibernate/IgniteEntityDataAccess.java | 30 +-
.../cache/hibernate/IgniteNaturalIdDataAccess.java | 30 +-
.../h2/DurableBackgroundCleanupIndexTreeTask.java | 179 +++
.../internal/processors/query/h2/H2Utils.java | 3 +
.../processors/query/h2/IgniteH2Indexing.java | 16 +-
.../internal/processors/query/h2/QueryParser.java | 13 +-
.../query/h2/QueryParserMetricsHolder.java | 62 +
.../processors/query/h2/database/H2Tree.java | 30 +-
.../query/h2/database/H2TreeClientIndex.java | 2 +-
.../processors/query/h2/database/H2TreeIndex.java | 131 +-
.../query/h2/database/H2TreeIndexBase.java | 16 +-
.../processors/query/h2/dml/DmlBatchSender.java | 4 +-
.../processors/query/h2/dml/UpdatePlanBuilder.java | 4 +-
.../processors/query/h2/opt/GridH2IndexBase.java | 9 +
.../processors/query/h2/opt/GridH2Table.java | 29 +-
.../processors/query/h2/opt/H2CacheRow.java | 4 +-
.../query/h2/sql/GridSqlQueryParser.java | 16 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 12 +-
.../metric/sql/MetricRegistryLocalSystemView.java | 14 +-
.../spi/metric/sql/SqlViewMetricExporterSpi.java | 10 +-
.../org/apache/ignite/client/ClientTestSuite.java | 8 +-
...finityKeyNameAndValueFieldNameConflictTest.java | 2 +-
...usterReadOnlyModeDoesNotBreakSqlSelectTest.java | 121 ++
.../processors/cache/SqlCacheStartStopTest.java | 330 +++++
.../H2DynamicColumnsAbstractBasicSelfTest.java | 37 +
.../index/H2TreeCorruptedTreeExceptionTest.java | 98 +-
.../index/IoStatisticsBasicIndexSelfTest.java | 47 +-
.../index/StopNodeOnRebuildIndexFailureTest.java | 10 +-
.../persistence/RebuildIndexLogMessageTest.java | 3 -
.../db/LongDestroyDurableBackgroundTaskTest.java | 676 ++++++++++
.../persistence/db/wal/IgniteWalRecoveryTest.java | 3 +-
.../cache/ttl/CacheTtlReadOnlyModeSelfTest.java | 15 +-
...ngingBaselineCacheQueryNodeRestartSelfTest.java | 7 +-
.../processors/query/AbstractCustomSchemaTest.java | 197 +++
.../query/AbstractDefaultSchemaTest.java | 133 ++
.../query/IgniteSqlCustomSchemaTest.java | 51 +
.../query/IgniteSqlCustomSchemaWithPdsEnabled.java | 148 +++
.../query/IgniteSqlDefaultSchemaTest.java} | 15 +-
.../IgniteSqlSchemasDiffConfigurationsTest.java | 90 ++
.../processors/query/JdbcSqlCustomSchemaTest.java | 85 ++
.../processors/query/JdbcSqlDefaultSchemaTest.java | 85 ++
...encyAfterInterruptAtomicCacheOperationTest.java | 153 +++
...istencyAfterInterruptTxCacheOperationTest.java} | 15 +-
.../query/SqlQueriesTopologyMappingTest.java | 185 +++
.../SqlTwoCachesInGroupWithSameEntryTest.java | 145 ++
.../query/h2/QueryParserMetricsHolderSelfTest.java | 109 ++
.../IgniteBinaryCacheQueryTestSuite.java | 16 +
.../IgniteBinaryCacheQueryTestSuite2.java | 15 +-
...teCacheWithIndexingAndPersistenceTestSuite.java | 8 +-
.../IgniteCacheWithIndexingTestSuite.java | 3 +
.../testsuites/IgnitePdsWithIndexingTestSuite.java | 4 +-
...dHandlerIndexingClusterByClassWithSSLTest.java} | 16 +-
.../GridCommandHandlerIndexingWithSSLTest.java} | 16 +-
.../opencensus/OpenCensusMetricExporterSpi.java | 6 +-
.../OpenCensusMetricExporterSpiTest.java | 4 +-
.../platforms/cpp/core-test/src/teamcity_boost.cpp | 120 +-
.../cpp/core-test/src/teamcity_messages.cpp | 9 +-
.../cpp/odbc-test/src/teamcity/teamcity_boost.cpp | 120 +-
.../odbc-test/src/teamcity/teamcity_messages.cpp | 9 +-
.../cpp/thin-client-test/src/cache_client_test.cpp | 18 +-
.../src/teamcity/teamcity_boost.cpp | 120 +-
.../src/teamcity/teamcity_messages.cpp | 9 +-
.../ignite/thin/ignite_client_configuration.h | 24 +-
.../cpp/thin-client/project/vs/thin-client.vcxproj | 2 +-
.../project/vs/thin-client.vcxproj.filters | 6 +-
.../src/impl/affinity/affinity_manager.cpp | 4 +-
.../src/impl/affinity/affinity_manager.h | 6 +-
...areness_group.h => partition_awareness_group.h} | 12 +-
.../src/impl/cache/cache_client_impl.cpp | 2 +-
.../cpp/thin-client/src/impl/data_channel.h | 2 +-
.../cpp/thin-client/src/impl/data_router.cpp | 2 +-
.../cpp/thin-client/src/impl/data_router.h | 10 +-
.../platforms/cpp/thin-client/src/impl/message.cpp | 2 +-
.../platforms/cpp/thin-client/src/impl/message.h | 16 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.AspNet.nuspec | 17 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.Benchmarks.DotNetCore.csproj | 18 +
.../Apache.Ignite.Benchmarks.csproj | 2 +
.../Apache.Ignite.Benchmarks/BenchmarkRunner.cs | 26 +-
...GetBenchmark.cs => GetAllEmployeesBenchmark.cs} | 38 +-
.../Interop/GetBenchmark.cs | 8 +
.../Apache.Ignite.Benchmarks/Model/Employee.cs | 18 +
.../Properties/AssemblyInfo.cs | 4 +-
...rk.cs => ThinClientGetAllEmployeesBenchmark.cs} | 39 +-
.../ThinClient/ThinClientGetBenchmark.cs | 8 +
.../Apache.Ignite.Core.Tests.DotNetCore.csproj | 31 +-
.../Properties/AssemblyInfo.cs | 2 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Properties/AssemblyInfo.cs | 2 +-
.../Apache.Ignite.Core.Tests.csproj | 9 +-
.../ApiParity/ClusterParityTest.cs | 6 +-
.../Apache.Ignite.Core.Tests/AssertExtensions.cs | 35 +-
.../Serializable/DynamicFieldSetSerializable.cs | 81 ++
.../Binary/Serializable/DynamicFieldSetTest.cs | 120 ++
.../Client/Cache/CacheTest.cs | 21 +-
.../Client/Cache/CacheTestNoMeta.cs | 6 -
.../Client/Cache/CreateCacheTest.cs | 4 +-
.../Client/Cache/DynamicFieldSetTest.cs | 141 ++
...yAwarenessTest.cs => PartitionAwarenessTest.cs} | 95 +-
.../Client/Cache/SerializableObjectsTest.cs | 136 ++
.../Client/ClientConnectionTest.cs | 23 +
.../Client/ClientProtocolCompatibilityTest.cs | 14 +-
.../Client/ClientReconnectCompatibilityTest.cs | 10 +-
.../Client/ClientServerCacheAdapter.cs | 302 +++++
.../Client/ClientServerCacheAdapterExtensions.cs} | 47 +-
.../Client/ClientServerCompatibilityTest.cs | 166 ++-
.../Client/ClientTestBase.cs | 80 +-
.../Client/Cluster/ClientClusterGroupTests.cs | 313 +++++
.../Client/IgniteClientConfigurationTest.cs | 6 +-
.../Compute/ComputeApiTest.cs | 84 +-
.../Config/Client/IgniteClientConfiguration.xml | 2 +-
.../dotnet/Apache.Ignite.Core.Tests/JavaServer.cs | 53 +-
.../Apache.Ignite.Core.Tests/JavaServer/pom.xml | 2 +-
.../JavaServer/src/main/java/Runner.java | 20 +-
.../Apache.Ignite.Core.Tests/ProcessExtensions.cs | 1 +
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.Core.Schema.nuspec | 13 +-
.../Apache.Ignite.Core/Apache.Ignite.Core.csproj | 13 +-
.../Apache.Ignite.Core/Apache.Ignite.Core.nuspec | 23 +-
.../Apache.Ignite.Core/Client/IClientCluster.cs | 2 +-
.../Client/IClientClusterGroup.cs | 96 ++
.../Client/IClientClusterNode.cs | 98 ++
.../Client/IgniteClientConfiguration.cs | 10 +-
.../Common/IgniteExperimentalAttribute.cs} | 35 +-
.../platforms/dotnet/Apache.Ignite.Core/IIgnite.cs | 2 +-
.../IgniteClientConfigurationSection.xsd | 2 +-
.../Impl/Binary/BinaryObjectSchemaSerializer.cs | 61 +-
.../Impl/Binary/BinaryProcessor.cs | 21 +-
.../Impl/Binary/BinaryProcessorClient.cs | 37 +-
.../Apache.Ignite.Core/Impl/Binary/BinaryReader.cs | 10 +-
.../Impl/Binary/IBinaryProcessor.cs | 5 -
.../Apache.Ignite.Core/Impl/Binary/Marshaller.cs | 97 +-
.../Impl/Binary/Metadata/BinaryType.cs | 9 +-
.../Impl/Binary/Metadata/BinaryTypeHolder.cs | 69 +-
.../Impl/Binary/SerializableSerializer.cs | 35 +-
.../Impl/Client/Cache/CacheClient.cs | 250 ++--
...up.cs => ClientCachePartitionAwarenessGroup.cs} | 4 +-
.../Client/Cache/Query/ClientQueryCursorBase.cs | 5 +-
.../Impl/Client/ClientContextBase.cs | 79 ++
.../Impl/Client/ClientFailoverSocket.cs | 73 +-
.../Apache.Ignite.Core/Impl/Client/ClientOp.cs | 6 +-
.../{IClientSocket.cs => ClientRequestContext.cs} | 51 +-
.../Impl/Client/ClientResponseContext.cs | 51 +
.../Apache.Ignite.Core/Impl/Client/ClientSocket.cs | 62 +-
.../Apache.Ignite.Core/Impl/Client/ClientUtils.cs | 58 +
.../Impl/Client/Cluster/ClientCluster.cs | 73 +-
.../Impl/Client/Cluster/ClientClusterGroup.cs | 313 +++++
.../Client/Cluster/ClientClusterGroupProjection.cs | 166 +++
.../Impl/Client/Cluster/ClientClusterNode.cs | 171 +++
.../Apache.Ignite.Core/Impl/Client/IgniteClient.cs | 71 +-
.../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 2 +-
.../Apache.Ignite.Core/Properties/AssemblyInfo.cs | 2 +-
.../platforms/dotnet/Apache.Ignite.DotNetCore.sln | 6 +
.../Apache.Ignite.EntityFramework.nuspec | 19 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.Linq.DotNetCore.csproj | 2 +-
.../Apache.Ignite.Linq/Apache.Ignite.Linq.nuspec | 27 +-
.../Apache.Ignite.Linq/Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.Log4Net.nuspec | 26 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.NLog/Apache.Ignite.NLog.nuspec | 26 +-
.../Apache.Ignite.NLog/Properties/AssemblyInfo.cs | 2 +-
.../Apache.Ignite/Properties/AssemblyInfo.cs | 4 +-
modules/platforms/dotnet/DEVNOTES.txt | 3 +-
modules/platforms/dotnet/README.md | 6 +-
modules/platforms/dotnet/build.ps1 | 6 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../dotnet}/logo_ignite_128x128.png | Bin
modules/platforms/dotnet/release/Program.cs | 31 +-
modules/platforms/dotnet/release/verify-nuget.ps1 | 5 +-
.../protocols/http/jetty/GridJettyRestHandler.java | 58 +-
.../http/jetty/GridJettyRestProtocol.java | 39 +-
modules/scalar-2.10/pom.xml | 2 +-
modules/scalar/pom.xml | 2 +-
modules/{flink => spring-data-2.2}/README.txt | 21 +-
.../licenses/apache-2.0.txt | 0
modules/spring-data-2.2/pom.xml | 141 ++
.../springdata22/repository/IgniteRepository.java | 58 +
.../config/EnableIgniteRepositories.java | 119 ++
.../config/IgniteRepositoriesRegistar.java} | 27 +-
.../IgniteRepositoryConfigurationExtension.java | 49 +
.../springdata22/repository/config/Query.java} | 24 +-
.../repository/config/RepositoryConfig.java} | 26 +-
.../repository/config/package-info.java} | 13 +-
.../springdata22/repository}/package-info.java | 5 +-
.../springdata22/repository/query/IgniteQuery.java | 82 ++
.../repository/query/IgniteQueryGenerator.java | 252 ++++
.../repository/query/IgniteRepositoryQuery.java | 312 +++++
.../repository/query/package-info.java} | 14 +-
.../repository/support/ConditionFalse.java} | 24 +-
.../support/IgniteRepositoryFactory.java | 168 +++
.../support/IgniteRepositoryFactoryBean.java | 91 ++
.../repository/support/IgniteRepositoryImpl.java | 164 +++
.../repository/support}/package-info.java | 4 +-
.../springdata/IgniteSpringDataCrudSelfTest.java | 353 +++++
.../IgniteSpringDataQueriesSelfTest.java | 317 +++++
.../springdata/misc/ApplicationConfiguration.java} | 41 +-
.../org/apache/ignite/springdata/misc/Person.java | 0
.../ignite/springdata/misc/PersonRepository.java | 119 ++
.../springdata/misc/PersonSecondRepository.java | 40 +
.../testsuites/IgniteSpringData22TestSuite.java} | 13 +-
.../java/org/apache/ignite/IgniteSpringBean.java | 7 +
.../src/test/config/state/cluster-state.xml} | 36 +-
.../cluster/ClusterStateXmlPropertiesTest.java | 90 ++
.../ignite/testsuites/IgniteSpringTestSuite.java | 5 +-
.../app/modules/branding/branding.service.js | 4 +-
parent/pom.xml | 45 +-
pom.xml | 7 +-
722 files changed, 28676 insertions(+), 9019 deletions(-)
create mode 100644 examples/config/spring/example-spring-data.xml
rename examples/src/main/java/org/apache/ignite/examples/springdata/{SpringAppCfg.java => SpringApplicationConfiguration.java} (75%)
rename modules/clients/src/test/java/org/apache/ignite/jdbc/suite/{IgniteJdbcThinDriverAffinityAwarenessTestSuite.java => IgniteJdbcThinDriverPartitionAwarenessTestSuite.java} (68%)
delete mode 100644 modules/clients/src/test/java/org/apache/ignite/jdbc/thin/JdbcThinBulkLoadAtomicPartitionedNearSelfTest.java
rename modules/clients/src/test/java/org/apache/ignite/jdbc/thin/{JdbcThinBulkLoadAbstractSelfTest.java => JdbcThinBulkLoadSelfTest.java} (94%)
delete mode 100644 modules/clients/src/test/java/org/apache/ignite/jdbc/thin/JdbcThinBulkLoadTransactionalPartitionedSelfTest.java
delete mode 100644 modules/clients/src/test/java/org/apache/ignite/jdbc/thin/JdbcThinBulkLoadTransactionalReplicatedSelfTest.java
rename modules/clients/src/test/java/org/apache/ignite/jdbc/thin/{JdbcThinAffinityAwarenessReconnectionAndFailoverSelfTest.java => JdbcThinPartitionAwarenessReconnectionAndFailoverSelfTest.java} (97%)
rename modules/clients/src/test/java/org/apache/ignite/jdbc/thin/{JdbcThinAffinityAwarenessSelfTest.java => JdbcThinPartitionAwarenessSelfTest.java} (95%)
rename modules/clients/src/test/java/org/apache/ignite/jdbc/thin/{JdbcThinAffinityAwarenessTransactionsSelfTest.java => JdbcThinPartitionAwarenessTransactionsSelfTest.java} (98%)
create mode 100644 modules/compatibility/src/test/java/org/apache/ignite/compatibility/persistence/MetaStorageCompatibilityTest.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/IgniteEncryption.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/cluster/ClusterState.java
copy modules/core/src/main/java/org/apache/ignite/events/{ClusterActivationEvent.java => ClusterStateChangeEvent.java} (63%)
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/ClusterReadOnlyModeDisableCommand.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/ClusterReadOnlyModeEnableCommand.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/ClusterStateChangeCommand.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/encryption/EncryptionCommand.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/commandline/encryption/EncryptionSubcommand.java
rename modules/core/src/main/java/org/apache/ignite/internal/jdbc/thin/{JdbcThinAffinityAwarenessMappingGroup.java => JdbcThinPartitionAwarenessMappingGroup.java} (88%)
rename modules/{clients/src/test/java/org/apache/ignite/jdbc/thin/JdbcThinBulkLoadAtomicPartitionedSelfTest.java => core/src/main/java/org/apache/ignite/internal/managers/encryption/EncryptionMXBeanImpl.java} (55%)
copy modules/{flink/src/main/java/org/apache/ignite/sink/flink => core/src/main/java/org/apache/ignite/internal/managers/encryption}/package-info.java (88%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/MasterKeyChangeRecord.java
rename modules/core/src/main/java/org/apache/ignite/internal/{cluster/ClusterReadOnlyModeCheckedException.java => processors/cache/distributed/dht/IgniteClusterReadOnlyException.java} (75%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/PartitionsExchangeAware.java
copy modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/{CheckpointFuture.java => CheckpointProgress.java} (76%)
copy modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/{CheckpointFuture.java => CheckpointState.java} (64%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/metastorage/pendingtask/DurableBackgroundTask.java
copy modules/core/src/main/java/org/apache/ignite/internal/processors/{platform/PlatformNativeException.java => cache/query/continuous/AbstractSecurityAwareExternalizable.java} (54%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/SecurityAwareFilter.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/SecurityAwareFilterFactory.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/SecurityAwareTransformerFactory.java
copy modules/core/src/main/java/org/apache/ignite/internal/processors/configuration/distributed/{PropertyUpdateClosure.java => DistributedChangeableProperty.java} (59%)
copy modules/core/src/main/java/org/apache/ignite/internal/processors/configuration/distributed/{DistributedProperty.java => SimpleDistributedProperty.java} (55%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/localtask/DurableBackgroundTasksProcessor.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/metric/MetricsMxBeanImpl.java
rename modules/core/src/main/java/org/apache/ignite/internal/processors/metric/impl/{HistogramMetric.java => HistogramMetricImpl.java} (84%)
rename modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cache/{ClientCacheAffinityAwarenessGroup.java => ClientCachePartitionAwarenessGroup.java} (94%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cluster/ClientClusterGroupGetNodeIdsRequest.java
copy modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cluster/{ClientClusterWalChangeStateResponse.java => ClientClusterGroupGetNodeIdsResponse.java} (54%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cluster/ClientClusterGroupGetNodesDetailsRequest.java
copy modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cluster/{ClientClusterWalChangeStateResponse.java => ClientClusterGroupGetNodesDetailsResponse.java} (52%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/platform/client/cluster/ClientClusterGroupProjection.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/processors/resource/GridResourceSupplierInjector.java
rename modules/core/src/main/java/org/apache/ignite/internal/processors/rest/client/message/{GridClientReadOnlyModeRequest.java => GridClientClusterStateRequest.java} (66%)
rename modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cluster/{GridChangeReadOnlyModeCommandHandler.java => GridChangeClusterStateCommandHandler.java} (70%)
copy modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/{GridRestReadOnlyChangeModeRequest.java => GridRestClusterStateRequest.java} (67%)
copy modules/core/src/{test/java/org/apache/ignite/internal/processors/configuration/distributed/DistributedConfigurationPersistentTest.java => main/java/org/apache/ignite/internal/resources/MetricManagerResource.java} (66%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/distributed/DistributedProcess.java
copy modules/core/src/main/java/org/apache/ignite/internal/{processors/cluster/ChangeGlobalStateFinishMessage.java => util/distributed/FullMessage.java} (55%)
copy modules/core/src/main/java/org/apache/ignite/internal/{processors/cluster/ChangeGlobalStateFinishMessage.java => util/distributed/InitMessage.java} (59%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/distributed/SingleNodeMessage.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/encryption/VisorChangeMasterKeyTask.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/visor/encryption/VisorGetMasterKeyNameTask.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/lang/IgniteExperimental.java
copy modules/core/src/main/java/org/apache/ignite/{spi/metric/ReadOnlyMetricRegistry.java => mxbean/EncryptionMXBean.java} (52%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/mxbean/MetricsMxBean.java
copy modules/core/src/main/java/org/apache/ignite/{internal/util/nio/GridNioMetricsListener.java => spi/metric/HistogramMetric.java} (64%)
copy modules/core/src/main/java/org/apache/ignite/spi/metric/{ReadOnlyMetricRegistry.java => ReadOnlyMetricManager.java} (76%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/cluster/GridClusterStateChangeSelfTest.java
rename modules/core/src/test/java/org/apache/ignite/internal/client/thin/{ThinClientAbstractAffinityAwarenessTest.java => ThinClientAbstractPartitionAwarenessTest.java} (98%)
rename modules/core/src/test/java/org/apache/ignite/internal/client/thin/{ThinClientAffinityAwarenessStableTopologyTest.java => ThinClientPartitionAwarenessStableTopologyTest.java} (88%)
rename modules/core/src/test/java/org/apache/ignite/internal/client/thin/{ThinClientAffinityAwarenessUnstableTopologyTest.java => ThinClientPartitionAwarenessUnstableTopologyTest.java} (80%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/encryption/EncryptionMXBeanTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/encryption/MasterKeyChangeConsistencyCheckTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/encryption/MasterKeyChangeTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/metric/MetricsConfigurationTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ActiveOnStartPropertyTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/AutoActivationPropertyTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterActiveStateChangeWithNodeOutOfBaselineTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterStateClientAbstractTest.java
copy modules/core/src/test/java/org/apache/ignite/internal/processors/{configuration/distributed/DistributedConfigurationPersistentTest.java => cache/ClusterStateClientPartitionedSelfTest.java} (54%)
copy modules/core/src/test/java/org/apache/ignite/internal/processors/{configuration/distributed/DistributedConfigurationPersistentTest.java => cache/ClusterStateClientReplicatedSelfTest.java} (55%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterStateNoRebalanceAbstractTest.java
copy modules/core/src/test/java/org/apache/ignite/internal/processors/{configuration/distributed/DistributedConfigurationPersistentTest.java => cache/ClusterStateNoRebalancePartitionedTest.java} (54%)
copy modules/core/src/test/java/org/apache/ignite/internal/processors/{configuration/distributed/DistributedConfigurationPersistentTest.java => cache/ClusterStateNoRebalanceReplicatedTest.java} (54%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterStateOnStartPropertyTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterStateServerAbstractTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterStateTestUtils.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/ClusterStateThinClientAbstractTest.java
copy modules/core/src/test/java/org/apache/ignite/internal/processors/{configuration/distributed/DistributedConfigurationPersistentTest.java => cache/ClusterStateThinClientPartitionedSelfTest.java} (54%)
copy modules/core/src/test/java/org/apache/ignite/internal/processors/{configuration/distributed/DistributedConfigurationPersistentTest.java => cache/ClusterStateThinClientReplicatedSelfTest.java} (54%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/binary/BinaryMetadataRegistrationTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/PartitionsExchangeAwareTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/EvictPartitionInLogTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/IgnitePdsSpuriousRebalancingOnNodeJoinTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/baseline/ClusterActivationEventWithPersistenceTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxRecoveryWithConcurrentRollbackTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/ClusterStateChangeEventTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/cluster/ClusterStateChangeEventWithPersistenceTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/datastructures/GridCacheReplicatedQueueRemoveSelfTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/failure/FailureProcessorThreadDumpThrottlingTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/cache/ContinuousQueryPermissionCheckTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/cache/closure/AbstractContinuousQueryRemoteSecurityContextCheckTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/cache/closure/ContinuousQueryRemoteSecurityContextCheckTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/processors/security/cache/closure/ContinuousQueryWithTransformerRemoteSecurityContextCheckTest.java
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/tostring/TransactionSensitiveDataTest.java
copy modules/{extdata/platform/src/test/java/org/apache/ignite/platform/plugin/PlatformTestPluginProvider.java => core/src/test/java/org/apache/ignite/plugin/AbstractTestPluginProvider.java} (74%)
copy modules/core/src/test/java/org/apache/ignite/{internal/processors/configuration/distributed/DistributedConfigurationPersistentTest.java => util/GridCommandHandlerClusterByClassWithSSLTest.java} (62%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/util/GridCommandHandlerTestUtils.java
copy modules/core/src/test/java/org/apache/ignite/{internal/processors/configuration/distributed/DistributedConfigurationPersistentTest.java => util/GridCommandHandlerWithSSLTest.java} (62%)
delete mode 100644 modules/flink/pom.xml
delete mode 100644 modules/flink/src/main/java/org/apache/ignite/sink/flink/IgniteSink.java
delete mode 100644 modules/flink/src/main/java/org/apache/ignite/source/flink/IgniteSource.java
delete mode 100644 modules/flink/src/main/java/org/apache/ignite/source/flink/TaskRemoteFilter.java
delete mode 100644 modules/flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTest.java
delete mode 100644 modules/flink/src/test/java/org/apache/ignite/source/flink/FlinkIgniteSourceSelfTest.java
delete mode 100644 modules/flink/src/test/resources/example-ignite.xml
create mode 100644 modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/DurableBackgroundCleanupIndexTreeTask.java
create mode 100644 modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParserMetricsHolder.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/ClusterReadOnlyModeDoesNotBreakSqlSelectTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/SqlCacheStartStopTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/LongDestroyDurableBackgroundTaskTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/AbstractCustomSchemaTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/AbstractDefaultSchemaTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlCustomSchemaTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlCustomSchemaWithPdsEnabled.java
copy modules/{core/src/test/java/org/apache/ignite/internal/processors/configuration/distributed/DistributedConfigurationPersistentTest.java => indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlDefaultSchemaTest.java} (64%)
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSchemasDiffConfigurationsTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/JdbcSqlCustomSchemaTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/JdbcSqlDefaultSchemaTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/SqlIndexConsistencyAfterInterruptAtomicCacheOperationTest.java
copy modules/{core/src/main/java/org/apache/ignite/internal/processors/configuration/distributed/DistributedConfigurationLifecycleListener.java => indexing/src/test/java/org/apache/ignite/internal/processors/query/SqlIndexConsistencyAfterInterruptTxCacheOperationTest.java} (70%)
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/SqlQueriesTopologyMappingTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/SqlTwoCachesInGroupWithSameEntryTest.java
create mode 100644 modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/QueryParserMetricsHolderSelfTest.java
copy modules/{core/src/test/java/org/apache/ignite/internal/processors/configuration/distributed/DistributedConfigurationPersistentTest.java => indexing/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingClusterByClassWithSSLTest.java} (62%)
copy modules/{core/src/test/java/org/apache/ignite/internal/processors/configuration/distributed/DistributedConfigurationPersistentTest.java => indexing/src/test/java/org/apache/ignite/util/GridCommandHandlerIndexingWithSSLTest.java} (62%)
rename modules/platforms/cpp/thin-client/src/impl/affinity/{affinity_awareness_group.h => partition_awareness_group.h} (92%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Benchmarks/Apache.Ignite.Benchmarks.DotNetCore.csproj
copy modules/platforms/dotnet/Apache.Ignite.Benchmarks/Interop/{GetBenchmark.cs => GetAllEmployeesBenchmark.cs} (57%)
copy modules/platforms/dotnet/Apache.Ignite.Benchmarks/ThinClient/{ThinClientGetBenchmark.cs => ThinClientGetAllEmployeesBenchmark.cs} (55%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/Binary/Serializable/DynamicFieldSetSerializable.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/Binary/Serializable/DynamicFieldSetTest.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/Client/Cache/DynamicFieldSetTest.cs
rename modules/platforms/dotnet/Apache.Ignite.Core.Tests/Client/Cache/{AffinityAwarenessTest.cs => PartitionAwarenessTest.cs} (86%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/Client/Cache/SerializableObjectsTest.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/Client/ClientServerCacheAdapter.cs
rename modules/{core/src/main/java/org/apache/ignite/internal/processors/rest/request/GridRestReadOnlyChangeModeRequest.java => platforms/dotnet/Apache.Ignite.Core.Tests/Client/ClientServerCacheAdapterExtensions.cs} (56%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core.Tests/Client/Cluster/ClientClusterGroupTests.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Client/IClientClusterGroup.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Client/IClientClusterNode.cs
rename modules/{clients/src/test/java/org/apache/ignite/jdbc/thin/JdbcThinBulkLoadTransactionalPartitionedNearSelfTest.java => platforms/dotnet/Apache.Ignite.Core/Common/IgniteExperimentalAttribute.cs} (50%)
rename modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/Cache/{ClientCacheAffinityAwarenessGroup.cs => ClientCachePartitionAwarenessGroup.cs} (96%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/ClientContextBase.cs
rename modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/{IClientSocket.cs => ClientRequestContext.cs} (50%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/ClientResponseContext.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/ClientUtils.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/Cluster/ClientClusterGroup.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/Cluster/ClientClusterGroupProjection.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Core/Impl/Client/Cluster/ClientClusterNode.cs
copy modules/{core/src/main/java/org/apache/ignite/startup/cmdline => platforms/dotnet}/logo_ignite_128x128.png (100%)
rename modules/{flink => spring-data-2.2}/README.txt (52%)
rename modules/{flink => spring-data-2.2}/licenses/apache-2.0.txt (100%)
create mode 100644 modules/spring-data-2.2/pom.xml
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/IgniteRepository.java
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/config/EnableIgniteRepositories.java
rename modules/{clients/src/test/java/org/apache/ignite/jdbc/thin/JdbcThinBulkLoadAtomicReplicatedSelfTest.java => spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/config/IgniteRepositoriesRegistar.java} (54%)
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/config/IgniteRepositoryConfigurationExtension.java
copy modules/{core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMetricsListener.java => spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/config/Query.java} (63%)
rename modules/{core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/CheckpointFuture.java => spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/config/RepositoryConfig.java} (56%)
copy modules/{flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTestSuite.java => spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/config/package-info.java} (76%)
rename modules/{flink/src/main/java/org/apache/ignite/source/flink => spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository}/package-info.java (85%)
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/IgniteQuery.java
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/IgniteQueryGenerator.java
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/IgniteRepositoryQuery.java
rename modules/{flink/src/test/java/org/apache/ignite/source/flink/FlinkIgniteSourceSelfTestSuite.java => spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/query/package-info.java} (75%)
rename modules/{core/src/main/java/org/apache/ignite/internal/util/nio/GridNioMetricsListener.java => spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/support/ConditionFalse.java} (60%)
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/support/IgniteRepositoryFactory.java
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/support/IgniteRepositoryFactoryBean.java
create mode 100644 modules/spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/support/IgniteRepositoryImpl.java
rename modules/{flink/src/main/java/org/apache/ignite/sink/flink => spring-data-2.2/src/main/java/org/apache/ignite/springdata22/repository/support}/package-info.java (86%)
create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/IgniteSpringDataCrudSelfTest.java
create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/IgniteSpringDataQueriesSelfTest.java
copy modules/{platforms/dotnet/Apache.Ignite.Core.Tests/JavaServer/src/main/java/Runner.java => spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/ApplicationConfiguration.java} (52%)
copy modules/{spring-data-2.0 => spring-data-2.2}/src/test/java/org/apache/ignite/springdata/misc/Person.java (100%)
create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/PersonRepository.java
create mode 100644 modules/spring-data-2.2/src/test/java/org/apache/ignite/springdata/misc/PersonSecondRepository.java
rename modules/{flink/src/test/java/org/apache/ignite/sink/flink/FlinkIgniteSinkSelfTestSuite.java => spring-data-2.2/src/test/java/org/apache/ignite/testsuites/IgniteSpringData22TestSuite.java} (71%)
copy modules/{platforms/dotnet/Apache.Ignite.Core.Tests/JavaServer/pom.xml => spring/src/test/config/state/cluster-state.xml} (52%)
create mode 100644 modules/spring/src/test/java/org/apache/ignite/cluster/ClusterStateXmlPropertiesTest.java
[ignite] 01/01: Merge branch 'ignite-master' into ignite-12248
Posted by gv...@apache.org.
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 325987f1558f82f85c1d6eaeac05c58644a670b6
Merge: 095804d 21fab11
Author: Igor Seliverstov <gv...@gmail.com>
AuthorDate: Wed Jan 29 16:58:19 2020 +0300
Merge branch 'ignite-master' into ignite-12248
# Conflicts:
# modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
NOTICE | 2 +-
assembly/NOTICE_HADOOP | 2 +-
assembly/NOTICE_IGNITE | 2 +-
examples/config/spring/example-spring-data.xml | 64 +
examples/pom-standalone-lgpl.xml | 12 +
examples/pom-standalone.xml | 12 +
...fg.java => SpringApplicationConfiguration.java} | 22 +-
.../examples/springdata/SpringDataExample.java | 6 +-
.../tests/examples/ScalarExamplesSelfTest.scala | 19 +-
.../benchmarks/jol/GridMetricsJolBenchmark.java | 2 +-
modules/cassandra/store/pom.xml | 2 +-
.../internal/jdbc2/JdbcStreamingSelfTest.java | 91 +-
.../rest/JettyRestProcessorBaselineSelfTest.java | 19 +-
.../ignite/jdbc/JdbcErrorsAbstractSelfTest.java | 9 +-
.../jdbc/suite/IgniteJdbcDriverTestSuite.java | 24 +-
...JdbcThinDriverPartitionAwarenessTestSuite.java} | 22 +-
.../ignite/jdbc/thin/JdbcThinAbstractSelfTest.java | 4 +-
...cThinBulkLoadAtomicPartitionedNearSelfTest.java | 39 -
...SelfTest.java => JdbcThinBulkLoadSelfTest.java} | 84 +-
...inBulkLoadTransactionalPartitionedSelfTest.java | 39 -
...hinBulkLoadTransactionalReplicatedSelfTest.java | 39 -
.../JdbcThinConnectionMultipleAddressesTest.java | 2 +-
.../jdbc/thin/JdbcThinConnectionSSLTest.java | 272 +++-
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 314 ++---
.../jdbc/thin/JdbcThinDataSourceSelfTest.java | 2 +-
.../ignite/jdbc/thin/JdbcThinMetadataSelfTest.java | 8 +-
...nAwarenessReconnectionAndFailoverSelfTest.java} | 24 +-
...ava => JdbcThinPartitionAwarenessSelfTest.java} | 34 +-
...hinPartitionAwarenessTransactionsSelfTest.java} | 6 +-
.../jdbc/thin/JdbcThinStatementSelfTest.java | 8 +-
.../IgnitePKIndexesMigrationToUnwrapPkTest.java | 1 -
.../persistence/MetaStorageCompatibilityTest.java | 348 +++++
.../IgniteCompatibilityBasicTestSuite.java | 6 +-
.../DiskPageCompressionIntegrationTest.java | 5 +-
modules/core/src/main/java/META-INF/NOTICE | 2 +-
.../src/main/java/org/apache/ignite/Ignite.java | 7 +
.../main/java/org/apache/ignite/IgniteBinary.java | 16 +-
.../main/java/org/apache/ignite/IgniteCache.java | 4 +
.../main/java/org/apache/ignite/IgniteCluster.java | 19 +-
.../java/org/apache/ignite/IgniteEncryption.java | 73 +
.../apache/ignite/IgniteJdbcThinDataSource.java | 20 +
.../org/apache/ignite/IgniteSystemProperties.java | 31 +-
.../java/org/apache/ignite/cache/QueryEntity.java | 11 +-
.../org/apache/ignite/cluster/ClusterState.java | 73 +
.../ignite/configuration/ClientConfiguration.java | 16 +-
.../configuration/DataRegionConfiguration.java | 9 +
.../configuration/DataStorageConfiguration.java | 9 +
.../ignite/configuration/IgniteConfiguration.java | 76 +-
.../configuration/MemoryPolicyConfiguration.java | 9 +
.../PersistentStoreConfiguration.java | 9 +
.../events/CacheConsistencyViolationEvent.java | 4 +
.../ignite/events/ClusterActivationEvent.java | 5 +-
...tionEvent.java => ClusterStateChangeEvent.java} | 66 +-
.../java/org/apache/ignite/events/EventType.java | 12 +
.../apache/ignite/internal/GridKernalContext.java | 6 +
.../ignite/internal/GridKernalContextImpl.java | 12 +
.../java/org/apache/ignite/internal/GridTopic.java | 6 +-
.../org/apache/ignite/internal/IgniteFeatures.java | 14 +-
.../org/apache/ignite/internal/IgniteKernal.java | 354 ++---
.../ignite/internal/IgniteNodeAttributes.java | 3 -
.../internal/binary/BinaryClassDescriptor.java | 68 +-
.../ignite/internal/binary/BinaryContext.java | 321 ++---
.../internal/binary/BinaryEnumObjectImpl.java | 13 +-
.../internal/binary/BinaryFieldAccessor.java | 4 +-
.../ignite/internal/binary/BinaryObjectExImpl.java | 4 +-
.../ignite/internal/binary/BinaryReaderExImpl.java | 8 +-
.../apache/ignite/internal/binary/BinaryUtils.java | 14 +-
.../ignite/internal/binary/BinaryWriterExImpl.java | 29 +-
.../internal/binary/builder/BinaryBuilderEnum.java | 2 +-
.../binary/builder/BinaryBuilderSerializer.java | 37 +-
.../binary/builder/BinaryEnumArrayLazyValue.java | 2 +-
.../binary/builder/BinaryObjectArrayLazyValue.java | 2 +-
.../binary/builder/BinaryObjectBuilderImpl.java | 13 +-
.../apache/ignite/internal/client/GridClient.java | 2 +-
.../internal/client/GridClientClusterState.java | 20 +-
.../ignite/internal/client/GridClientCompute.java | 2 +-
.../ignite/internal/client/GridClientData.java | 2 +-
.../client/impl/GridClientClusterStateImpl.java | 29 +-
.../impl/connection/GridClientConnection.java | 25 +-
.../connection/GridClientNioTcpConnection.java | 57 +-
.../client/thin/ClientCacheAffinityContext.java | 2 +-
.../client/thin/ClientCacheAffinityMapping.java | 10 +-
.../internal/client/thin/ProtocolVersion.java | 2 +-
.../internal/client/thin/ReliableChannel.java | 16 +-
.../internal/cluster/ClusterGroupAdapter.java | 11 +-
.../cluster/DistributedBaselineConfiguration.java | 101 +-
.../internal/cluster/IgniteClusterAsyncImpl.java | 9 +-
.../ignite/internal/cluster/IgniteClusterImpl.java | 23 +-
.../internal/commandline/ActivateCommand.java | 7 +-
.../ClusterReadOnlyModeDisableCommand.java | 72 -
.../ClusterReadOnlyModeEnableCommand.java | 72 -
.../commandline/ClusterStateChangeCommand.java | 105 ++
.../ignite/internal/commandline/Command.java | 73 +-
.../internal/commandline/CommandHandler.java | 1 +
.../ignite/internal/commandline/CommandList.java | 11 +-
.../internal/commandline/DeactivateCommand.java | 7 +-
.../ignite/internal/commandline/StateCommand.java | 26 +-
.../internal/commandline/cache/CacheCommands.java | 45 +-
.../commandline/encryption/EncryptionCommand.java | 125 ++
.../encryption/EncryptionSubcommand.java | 59 +
.../ignite/internal/jdbc/thin/AffinityCache.java | 8 +-
.../internal/jdbc/thin/ConnectionProperties.java | 46 +-
.../jdbc/thin/ConnectionPropertiesImpl.java | 73 +-
.../internal/jdbc/thin/JdbcThinConnection.java | 52 +-
...=> JdbcThinPartitionAwarenessMappingGroup.java} | 16 +-
.../ignite/internal/jdbc/thin/JdbcThinSSLUtil.java | 205 +--
.../ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 4 +-
.../internal/managers/IgniteMBeansManager.java | 32 +-
.../managers/checkpoint/GridCheckpointManager.java | 4 +-
.../managers/communication/GridIoManager.java | 13 +-
.../communication/GridIoMessageFactory.java | 6 +
.../deployment/GridDeploymentPerVersionStore.java | 16 +-
.../managers/discovery/GridDiscoveryManager.java | 27 +-
.../managers/encryption/EncryptionMXBeanImpl.java} | 29 +-
.../encryption/GenerateEncryptionKeyResponse.java | 26 +-
.../managers/encryption/GridEncryptionManager.java | 755 +++++++++--
.../managers/encryption}/package-info.java | 5 +-
.../ignite/internal/metric/IoStatisticsHolder.java | 5 +
.../internal/metric/IoStatisticsHolderCache.java | 21 +-
.../internal/metric/IoStatisticsHolderIndex.java | 25 +-
.../internal/metric/IoStatisticsHolderNoOp.java | 5 +
.../internal/metric/IoStatisticsHolderQuery.java | 5 +
.../ignite/internal/metric/IoStatisticsType.java | 10 +-
.../pagemem/wal/IgniteWriteAheadLogManager.java | 4 +-
.../pagemem/wal/record/MasterKeyChangeRecord.java | 68 +
.../internal/pagemem/wal/record/WALRecord.java | 5 +-
.../affinity/GridAffinityAssignmentV2.java | 8 +-
.../affinity/IdealAffinityAssignment.java | 2 +-
.../cache/CacheAffinitySharedManager.java | 116 ++
.../processors/cache/CacheGroupContext.java | 11 +
.../processors/cache/CacheGroupMetricsImpl.java | 19 +
.../processors/cache/CacheMetricsImpl.java | 12 +-
.../processors/cache/CacheObjectAdapter.java | 2 +-
.../processors/cache/ClusterCachesInfo.java | 31 +-
.../cache/DynamicCacheChangeRequest.java | 13 +
.../internal/processors/cache/ExchangeActions.java | 13 +-
.../internal/processors/cache/ExchangeContext.java | 17 +-
.../processors/cache/GridCacheAdapter.java | 13 +-
.../processors/cache/GridCacheContextInfo.java | 8 +
.../processors/cache/GridCacheMapEntry.java | 4 +-
.../cache/GridCachePartitionExchangeManager.java | 129 +-
.../processors/cache/GridCacheProcessor.java | 108 +-
.../cache/IgniteCacheOffheapManager.java | 2 +-
.../cache/IgniteCacheOffheapManagerImpl.java | 23 +-
.../processors/cache/KeyCacheObjectImpl.java | 2 +-
.../PartitionTxUpdateCounterDebugWrapper.java | 17 +
.../cache/PartitionTxUpdateCounterImpl.java | 2 +
.../processors/cache/StateChangeRequest.java | 34 +-
.../internal/processors/cache/WalStateManager.java | 24 +-
.../cache/binary/BinaryMetadataTransport.java | 2 +-
.../distributed/GridCacheTxRecoveryFuture.java | 15 +-
.../dht/GridDhtTopologyFutureAdapter.java | 3 +-
.../distributed/dht/GridDhtTxFinishFuture.java | 38 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 4 +-
.../dht/IgniteClusterReadOnlyException.java} | 17 +-
.../distributed/dht/atomic/GridDhtAtomicCache.java | 2 +-
.../dht/preloader/GridDhtPartitionDemander.java | 88 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 32 +-
.../dht/preloader/GridDhtPreloader.java | 4 +
.../dht/preloader/PartitionsExchangeAware.java | 69 +
.../dht/topology/GridClientPartitionTopology.java | 20 +-
.../dht/topology/GridDhtLocalPartition.java | 66 +-
.../dht/topology/GridDhtPartitionTopology.java | 8 +-
.../dht/topology/GridDhtPartitionTopologyImpl.java | 71 +-
.../dht/topology/PartitionsEvictManager.java | 131 +-
.../processors/cache/mvcc/txlog/TxLog.java | 3 +-
...eckpointFuture.java => CheckpointProgress.java} | 17 +-
...{CheckpointFuture.java => CheckpointState.java} | 25 +-
.../cache/persistence/DataRegionMetricsImpl.java | 5 +
.../GridCacheDatabaseSharedManager.java | 356 +++--
.../cache/persistence/GridCacheOffheapManager.java | 53 +-
.../IgniteCacheDatabaseSharedManager.java | 28 +-
.../persistence/file/FilePageStoreManager.java | 13 +-
.../persistence/freelist/AbstractFreeList.java | 20 +-
.../cache/persistence/freelist/CacheFreeList.java | 7 +-
.../cache/persistence/freelist/PagesList.java | 52 +-
.../cache/persistence/metastorage/MetaStorage.java | 49 +-
.../pendingtask/DurableBackgroundTask.java | 41 +
.../cache/persistence/pagemem/PageMemoryEx.java | 20 +-
.../cache/persistence/pagemem/PageMemoryImpl.java | 89 +-
.../partstorage/PartitionMetaStorageImpl.java | 6 +-
.../cache/persistence/tree/BPlusTree.java | 296 ++++-
.../persistence/tree/reuse/ReuseListImpl.java | 8 +-
.../wal/AbstractWalRecordsIterator.java | 5 +-
.../persistence/wal/FileWriteAheadLogManager.java | 49 +-
.../wal/filehandle/FileHandleManager.java | 4 +-
.../wal/filehandle/FileHandleManagerFactory.java | 5 -
.../wal/filehandle/FileHandleManagerImpl.java | 33 +-
.../wal/filehandle/FileWriteHandleImpl.java | 2 +-
.../wal/filehandle/FsyncFileHandleManagerImpl.java | 45 +-
.../wal/filehandle/FsyncFileWriteHandle.java | 6 +-
.../wal/reader/StandaloneGridKernalContext.java | 6 +
.../wal/serializer/RecordDataV1Serializer.java | 60 +-
.../cache/query/QueryEntityTypeDescriptor.java | 41 +-
.../AbstractSecurityAwareExternalizable.java} | 55 +-
.../continuous/CacheContinuousQueryManager.java | 69 +-
.../query/continuous/SecurityAwareFilter.java | 62 +
.../continuous/SecurityAwareFilterFactory.java | 52 +
.../SecurityAwareTransformerFactory.java | 67 +
.../cache/store/GridCacheStoreManagerAdapter.java | 2 +-
.../cache/store/GridCacheWriteBehindStore.java | 4 +-
.../cache/transactions/IgniteInternalTx.java | 5 +
.../cache/transactions/IgniteTxAdapter.java | 7 +-
.../cache/transactions/IgniteTxHandler.java | 48 +-
.../processors/cache/transactions/IgniteTxKey.java | 2 +-
.../cache/transactions/IgniteTxLocalAdapter.java | 7 -
.../cache/transactions/IgniteTxManager.java | 20 +-
.../transactions/TransactionMetricsAdapter.java | 6 +-
.../processors/cache/transactions/TxDeadlock.java | 2 +-
.../cache/transactions/TxEntryValueHolder.java | 8 +-
.../processors/cache/verify/IdleVerifyUtility.java | 8 +-
.../cluster/ChangeGlobalStateFinishMessage.java | 26 +-
.../cluster/ChangeGlobalStateMessage.java | 29 +-
.../cluster/DiscoveryDataClusterState.java | 111 +-
.../cluster/GridClusterStateProcessor.java | 540 ++++----
.../cluster/IGridClusterStateProcessor.java | 38 +-
.../baseline/autoadjust/ChangeTopologyWatcher.java | 17 +-
.../distributed/DistributedBooleanProperty.java | 2 +-
...ure.java => DistributedChangeableProperty.java} | 28 +-
.../distributed/DistributedComparableProperty.java | 2 +-
.../DistributedConfigurationLifecycleListener.java | 6 +
.../DistributedConfigurationProcessor.java | 76 +-
.../distributed/DistributedProperty.java | 119 +-
.../distributed/DistributedPropertyDispatcher.java | 21 +-
.../distributed/PropertyUpdateClosure.java | 12 +-
...roperty.java => SimpleDistributedProperty.java} | 92 +-
.../processors/datastreamer/DataStreamerImpl.java | 12 +-
.../datastructures/GridCacheQueueAdapter.java | 4 +-
.../processors/failure/FailureProcessor.java | 63 +-
.../localtask/DurableBackgroundTasksProcessor.java | 265 ++++
.../metastorage/DistributedMetaStorage.java | 10 +
.../persistence/DistributedMetaStorageImpl.java | 5 +
.../persistence/DmsDataWriterWorker.java | 2 +
.../processors/metric/GridMetricManager.java | 255 +++-
.../internal/processors/metric/MetricRegistry.java | 93 +-
.../processors/metric/MetricsMxBeanImpl.java | 75 ++
.../metric/PushMetricsExporterAdapter.java | 9 +-
...stogramMetric.java => HistogramMetricImpl.java} | 14 +-
.../processors/metric/impl/HitRateMetric.java | 18 +-
.../processors/metric/impl/MetricUtils.java | 69 +-
.../internal/processors/odbc/SqlStateCode.java | 4 +-
.../odbc/jdbc/JdbcCachePartitionsResult.java | 14 +-
.../odbc/jdbc/JdbcConnectionContext.java | 2 +-
.../processors/odbc/jdbc/JdbcRequestHandler.java | 16 +-
.../processors/platform/PlatformContext.java | 3 +-
.../processors/platform/PlatformContextImpl.java | 10 +-
.../platform/PlatformNativeException.java | 2 +-
.../platform/binary/PlatformBinaryProcessor.java | 15 +-
.../platform/client/ClientConnectionContext.java | 2 +-
.../platform/client/ClientMessageParser.java | 14 +
...ava => ClientCachePartitionAwarenessGroup.java} | 6 +-
.../client/cache/ClientCachePartitionsRequest.java | 30 +-
.../cache/ClientCachePartitionsResponse.java | 6 +-
.../ClientClusterGroupGetNodeIdsRequest.java | 77 ++
...a => ClientClusterGroupGetNodeIdsResponse.java} | 39 +-
.../ClientClusterGroupGetNodesDetailsRequest.java | 57 +
...ClientClusterGroupGetNodesDetailsResponse.java} | 39 +-
.../cluster/ClientClusterGroupProjection.java | 159 +++
.../ClientClusterWalChangeStateResponse.java | 2 +-
.../processors/query/GridQueryIndexing.java | 7 +
.../processors/query/GridQueryProcessor.java | 2 +-
.../processors/resource/GridResourceIoc.java | 9 +-
.../processors/resource/GridResourceProcessor.java | 2 +
.../GridResourceProxiedIgniteInjector.java | 42 +-
.../resource/GridResourceSupplierInjector.java | 64 +
.../internal/processors/rest/GridRestCommand.java | 19 +-
.../processors/rest/GridRestProcessor.java | 6 +-
...est.java => GridClientClusterStateRequest.java} | 40 +-
.../client/message/GridClientStateRequest.java | 3 +-
...a => GridChangeClusterStateCommandHandler.java} | 32 +-
.../rest/protocols/tcp/GridTcpRestNioListener.java | 21 +-
...quest.java => GridRestClusterStateRequest.java} | 26 +-
.../processors/security/SecurityUtils.java | 2 +-
.../internal/resources/MetricManagerResource.java} | 18 +-
.../sql/optimizer/affinity/PartitionResult.java | 12 +-
.../affinity/PartitionTableAffinityDescriptor.java | 4 +-
.../ignite/internal/util/GridArgumentCheck.java | 13 +
.../ignite/internal/util/GridStringBuilder.java | 13 +
.../apache/ignite/internal/util/IgniteUtils.java | 57 +-
.../ignite/internal/util/StripedExecutor.java | 10 +
.../util/distributed/DistributedProcess.java | 384 ++++++
.../distributed/FullMessage.java} | 96 +-
.../distributed/InitMessage.java} | 87 +-
.../util/distributed/SingleNodeMessage.java | 196 +++
.../ignite/internal/util/ipc/IpcToNioAdapter.java | 33 +-
.../util/nio/GridAbstractCommunicationClient.java | 8 +-
.../ignite/internal/util/nio/GridNioServer.java | 117 +-
.../util/nio/GridSelectorNioSessionImpl.java | 33 +-
.../util/nio/GridShmemCommunicationClient.java | 26 +-
.../util/nio/GridTcpNioCommunicationClient.java | 2 +-
.../util/tostring/GridToStringBuilder.java | 64 +-
.../internal/visor/baseline/VisorBaselineTask.java | 14 +-
...orFindAndDeleteGarbageInPersistenceClosure.java | 8 +-
.../visor/encryption/VisorChangeMasterKeyTask.java | 65 +
.../encryption/VisorGetMasterKeyNameTask.java | 63 +
.../org/apache/ignite/lang/IgniteExperimental.java | 37 +
.../org/apache/ignite/marshaller/Marshaller.java | 2 +
.../ignite/mxbean/DataRegionMetricsMXBean.java | 4 +
.../ignite/mxbean/DataStorageMetricsMXBean.java | 4 +
.../EncryptionMXBean.java} | 28 +-
.../org/apache/ignite/mxbean/IgniteMXBean.java | 49 +-
.../org/apache/ignite/mxbean/MetricsMxBean.java | 64 +
.../org/apache/ignite/plugin/PluginProvider.java | 7 +-
.../tcp/TcpCommunicationMetricsListener.java | 378 +++---
.../spi/communication/tcp/TcpCommunicationSpi.java | 69 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 38 +-
.../ignite/spi/encryption/EncryptionSpi.java | 18 +
.../encryption/keystore/KeystoreEncryptionSpi.java | 94 +-
.../spi/encryption/noop/NoopEncryptionSpi.java | 11 +
.../metric/HistogramMetric.java} | 21 +-
.../ignite/spi/metric/MetricExporterSpi.java | 6 +-
...ricRegistry.java => ReadOnlyMetricManager.java} | 9 +-
.../ignite/spi/metric/ReadOnlyMetricRegistry.java | 20 +-
.../spi/metric/jmx/JmxMetricExporterSpi.java | 75 +-
.../ignite/spi/metric/jmx/MetricRegistryMBean.java | 12 +-
.../spi/metric/noop/NoopMetricExporterSpi.java | 6 +-
.../spi/systemview/ReadOnlySystemViewRegistry.java | 4 +-
.../ignite/ssl/SSLServerSocketFactoryWrapper.java | 3 +-
.../org/apache/ignite/ssl/SslContextFactory.java | 63 +-
.../main/resources/META-INF/classnames.properties | 6 +-
.../cluster/GridClusterStateChangeSelfTest.java | 144 ++
.../ClusterBaselineNodesMetricsSelfTest.java | 22 +-
.../internal/GridNodeMetricsLogPdsSelfTest.java | 51 +-
.../internal/GridNodeMetricsLogSelfTest.java | 89 +-
.../internal/binary/BinaryMarshallerSelfTest.java | 4 +-
.../BinaryObjectBuilderAdditionalSelfTest.java | 139 +-
.../BinarySimpleNameTestPropertySelfTest.java | 3 +-
... ThinClientAbstractPartitionAwarenessTest.java} | 6 +-
...lientPartitionAwarenessStableTopologyTest.java} | 16 +-
...entPartitionAwarenessUnstableTopologyTest.java} | 48 +-
.../commandline/CommandHandlerParsingTest.java | 70 +-
.../encryption/AbstractEncryptionTest.java | 36 +-
.../internal/encryption/EncryptionMXBeanTest.java | 143 ++
.../MasterKeyChangeConsistencyCheckTest.java | 163 +++
.../internal/encryption/MasterKeyChangeTest.java | 426 ++++++
.../internal/metric/IoStatisticsCacheSelfTest.java | 5 +-
...IoStatisticsMetricsLocalMXBeanImplSelfTest.java | 28 +-
.../ignite/internal/metric/JmxExporterSpiTest.java | 18 +-
.../internal/metric/MetricsConfigurationTest.java | 383 ++++++
.../ignite/internal/metric/MetricsSelfTest.java | 20 +-
.../processors/DeadLockOnNodeLeftExchangeTest.java | 3 +-
.../AuthenticationProcessorNodeRestartTest.java | 39 +-
.../cache/ActiveOnStartPropertyTest.java | 149 +++
.../cache/AutoActivationPropertyTest.java | 128 ++
.../cache/CacheDataRegionConfigurationTest.java | 305 +++++
.../processors/cache/CacheGroupMetricsTest.java | 31 +
.../cache/CacheGroupsMetricsRebalanceTest.java | 207 ++-
...ActiveStateChangeWithNodeOutOfBaselineTest.java | 134 ++
.../cache/ClusterReadOnlyModeAbstractTest.java | 3 +-
.../processors/cache/ClusterReadOnlyModeTest.java | 4 +-
.../processors/cache/ClusterStateAbstractTest.java | 395 ++----
.../cache/ClusterStateClientAbstractTest.java | 58 +
.../ClusterStateClientPartitionedSelfTest.java} | 20 +-
.../ClusterStateClientReplicatedSelfTest.java} | 20 +-
.../cache/ClusterStateNoRebalanceAbstractTest.java | 219 +++
.../ClusterStateNoRebalancePartitionedTest.java} | 20 +-
.../ClusterStateNoRebalanceReplicatedTest.java} | 20 +-
.../cache/ClusterStateOnStartPropertyTest.java | 396 ++++++
.../cache/ClusterStatePartitionedSelfTest.java | 14 +-
.../cache/ClusterStateReplicatedSelfTest.java | 15 +-
.../cache/ClusterStateServerAbstractTest.java | 206 +++
.../processors/cache/ClusterStateTestUtils.java | 124 ++
.../cache/ClusterStateThinClientAbstractTest.java | 80 ++
...ClusterStateThinClientPartitionedSelfTest.java} | 20 +-
.../ClusterStateThinClientReplicatedSelfTest.java} | 20 +-
.../cache/GridCacheAbstractMetricsSelfTest.java | 8 +-
...dCacheTransactionalAbstractMetricsSelfTest.java | 6 +-
.../IgniteAbstractDynamicCacheStartFailTest.java | 22 +-
.../cache/IgniteClusterActivateDeactivateTest.java | 1388 ++++++++++++--------
...usterActivateDeactivateTestWithPersistence.java | 274 ++--
...teDynamicCacheStartFailWithPersistenceTest.java | 6 -
.../binary/BinaryMetadataRegistrationTest.java | 230 ++++
.../GridCacheBinaryObjectsAbstractSelfTest.java | 2 +-
.../distributed/CacheBaselineTopologyTest.java | 21 +-
.../CacheDataLossOnPartitionMoveTest.java | 6 +-
.../CachePartitionLostWhileClearingTest.java | 8 +-
.../distributed/CacheRentingStateRepairTest.java | 7 +-
.../distributed/GridExchangeFreeSwitchTest.java | 208 ++-
.../distributed/PartitionsExchangeAwareTest.java | 272 ++++
.../dht/topology/EvictPartitionInLogTest.java | 274 ++++
.../PartitionsEvictManagerAbstractTest.java | 2 +-
.../GridCacheRebalancingWithAsyncClearingTest.java | 7 +-
.../processors/cache/mvcc/CacheMvccVacuumTest.java | 19 +-
.../persistence/CleanupRestoredCachesSlowTest.java | 5 +-
...niteBaselineAffinityTopologyActivationTest.java | 24 +-
.../persistence/IgnitePdsCorruptedIndexTest.java | 7 +-
.../IgnitePdsDestroyCacheAbstractTest.java | 45 +-
.../persistence/IgnitePdsDestroyCacheTest.java | 101 ++
.../IgnitePdsPartitionFilesDestroyTest.java | 54 +-
...IgnitePdsSpuriousRebalancingOnNodeJoinTest.java | 170 +++
...gniteRebalanceScheduleResendPartitionsTest.java | 16 +-
...ocalWalModeChangeDuringRebalancingSelfTest.java | 11 +-
.../ClientAffinityAssignmentWithBaselineTest.java | 19 +-
.../baseline/ClusterActivationEventTest.java | 296 +++--
.../ClusterActivationEventWithPersistenceTest.java | 50 +
.../IgniteAbsentEvictionNodeOutOfBaselineTest.java | 7 +-
...hangingBaselineDownCachePutAllFailoverTest.java | 7 +-
...hangingBaselineDownCacheRemoveFailoverTest.java | 6 +-
...eChangingBaselineUpCachePutAllFailoverTest.java | 7 +-
...eChangingBaselineUpCacheRemoveFailoverTest.java | 7 +-
.../persistence/db/IgniteLogicalRecoveryTest.java | 9 +-
...IgnitePdsCacheWalDisabledOnRebalancingTest.java | 18 +-
.../db/IgnitePdsDataRegionMetricsTest.java | 6 +-
.../cache/persistence/db/IgnitePdsWithTtlTest.java | 15 +-
.../SlowHistoricalRebalanceSmallHistoryTest.java | 7 +-
.../db/checkpoint/CheckpointFreeListTest.java | 35 +
...CheckpointSimulationWithRealCpDisabledTest.java | 16 -
...eWalFlushMultiNodeFailoverAbstractSelfTest.java | 6 +-
.../persistence/db/wal/WalCompactionTest.java | 85 +-
.../db/wal/WalRecoveryTxLogicalRecordsTest.java | 18 +-
.../persistence/freelist/FreeListCachingTest.java | 109 +-
.../metastorage/IgniteMetaStorageBasicTest.java | 4 +-
.../cache/persistence/pagemem/NoOpWALManager.java | 4 +-
.../standbycluster/AbstractNodeJoinTemplate.java | 8 +-
.../standbycluster/IgniteStandByClusterTest.java | 76 +-
.../wal/memtracker/PageMemoryTracker.java | 15 +
.../PageMemoryTrackerPluginProvider.java | 52 +-
.../transactions/PartitionUpdateCounterTest.java | 8 +-
...ionIntegrityWithPrimaryIndexCorruptionTest.java | 4 +-
.../TxCrossCachePartitionConsistencyTest.java | 3 -
...acheRemoteMultiplePartitionReservationTest.java | 2 -
.../TxPartitionCounterStateAbstractTest.java | 46 +-
...ounterStateConsistencyHistoryRebalanceTest.java | 98 ++
.../TxPartitionCounterStateConsistencyTest.java | 28 +-
...unterStateConsistencyVolatileRebalanceTest.java | 10 +
...ounterStateOnePrimaryTwoBackupsFailAllTest.java | 7 +-
.../TxRecoveryWithConcurrentRollbackTest.java | 340 +++++
.../processors/cluster/BaselineAutoAdjustTest.java | 35 +-
.../cluster/ClusterReadOnlyModeNodeJoinTest.java | 8 +-
.../cluster/ClusterReadOnlyModeSelfTest.java | 86 +-
.../cluster/ClusterStateChangeEventTest.java | 159 +++
...ClusterStateChangeEventWithPersistenceTest.java | 36 +
.../DistributedConfigurationAbstractTest.java | 132 +-
.../DistributedConfigurationPersistentTest.java | 128 ++
.../TestDistibutedConfigurationPlugin.java | 68 +-
.../database/BPlusTreeReuseSelfTest.java | 2 +-
.../processors/database/CacheFreeListSelfTest.java | 3 +-
.../GridCacheReplicatedQueueRemoveSelfTest.java | 144 ++
.../FailureProcessorThreadDumpThrottlingTest.java | 203 +++
.../internal/processors/igfs/IgfsIgniteMock.java | 19 +-
.../DistributedMetaStoragePersistentTest.java | 6 +-
.../metastorage/DistributedMetaStorageTest.java | 34 +-
.../processors/query/DummyQueryIndexing.java | 5 +
.../rest/RestProcessorInitializationTest.java | 74 +-
...cheOperationRemoteSecurityContextCheckTest.java | 21 +-
.../AbstractRemoteSecurityContextCheckTest.java | 122 +-
.../AbstractTestSecurityPluginProvider.java | 73 +-
.../cache/ContinuousQueryPermissionCheckTest.java | 143 ++
...tinuousQueryRemoteSecurityContextCheckTest.java | 125 ++
...tinuousQueryRemoteSecurityContextCheckTest.java | 106 ++
...hTransformerRemoteSecurityContextCheckTest.java | 118 ++
...tryProcessorRemoteSecurityContextCheckTest.java | 2 +-
.../ScanQueryRemoteSecurityContextCheckTest.java | 2 +-
...teTaskCancelRemoteSecurityContextCheckTest.java | 1 -
...DataStreamerRemoteSecurityContextCheckTest.java | 2 +-
.../service/IgniteServiceReassignmentTest.java | 6 -
.../ServiceDeploymentOutsideBaselineTest.java | 30 +-
.../util/tostring/GridToStringBuilderSelfTest.java | 4 +-
.../tostring/TransactionSensitiveDataTest.java | 343 +++++
.../ignite/plugin/AbstractTestPluginProvider.java} | 59 +-
.../plugin/NodeValidationPluginProvider.java | 54 +-
.../tcp/TcpCommunicationStatisticsTest.java | 41 +
.../spi/discovery/ClusterMetricsSelfTest.java | 6 +-
.../IgniteDiscoveryCacheReuseSelfTest.java | 6 +-
.../encryption/KeystoreEncryptionSpiSelfTest.java | 41 +-
.../apache/ignite/testframework/GridTestUtils.java | 60 +-
.../ignite/testframework/ListeningTestLogger.java | 25 +
.../testframework/junits/GridAbstractTest.java | 70 +-
.../junits/GridTestKernalContext.java | 11 +
.../ignite/testframework/junits/IgniteMock.java | 6 +
.../testframework/junits/IgniteTestResources.java | 18 +-
.../junits/multijvm/IgniteClusterProcessProxy.java | 5 +-
.../junits/multijvm/IgniteProcessProxy.java | 6 +
.../ignite/testsuites/IgniteBasicTestSuite.java | 4 +
.../IgniteBasicWithPersistenceTestSuite.java | 14 +-
.../testsuites/IgniteBinaryObjectsTestSuite.java | 5 +-
.../IgniteCacheDataStructuresSelfTestSuite.java | 2 +
.../testsuites/IgniteCacheMvccTestSuite5.java | 12 +
.../testsuites/IgniteCacheMvccTestSuite6.java | 4 +
.../ignite/testsuites/IgniteCacheTestSuite5.java | 12 +
.../ignite/testsuites/IgniteCacheTestSuite6.java | 3 +
.../ignite/testsuites/IgniteCacheTestSuite7.java | 3 +
.../ignite/testsuites/IgniteCacheTestSuite9.java | 6 +-
.../testsuites/IgniteKernalSelfTestSuite.java | 4 +-
.../ignite/testsuites/IgnitePdsTestSuite.java | 7 +
.../ignite/testsuites/IgnitePdsTestSuite2.java | 6 +
.../ignite/testsuites/IgnitePdsTestSuite4.java | 2 +
.../testsuites/IgniteStandByClusterSuite.java | 4 +-
.../ignite/testsuites/IgniteUtilSelfTestSuite.java | 2 +
.../ignite/testsuites/SecurityTestSuite.java | 6 +
.../util/GridCommandHandlerAbstractTest.java | 40 +-
...idCommandHandlerClusterByClassAbstractTest.java | 3 +
.../util/GridCommandHandlerClusterByClassTest.java | 14 +
...idCommandHandlerClusterByClassWithSSLTest.java} | 16 +-
.../ignite/util/GridCommandHandlerSslTest.java | 7 +-
.../apache/ignite/util/GridCommandHandlerTest.java | 240 +++-
.../ignite/util/GridCommandHandlerTestUtils.java | 37 +
.../GridCommandHandlerWithSSLTest.java} | 16 +-
.../control.sh_cache_help.output | 2 +-
.../org.apache.ignite.util/control.sh_help.output | 23 +-
modules/core/src/test/resources/tde.jks | Bin 347 -> 813 bytes
modules/extdata/platform/pom.xml | 8 +
.../plugin/PlatformTestPluginProvider.java | 51 +-
modules/flink/pom.xml | 194 ---
.../org/apache/ignite/sink/flink/IgniteSink.java | 197 ---
.../apache/ignite/source/flink/IgniteSource.java | 223 ----
.../ignite/source/flink/TaskRemoteFilter.java | 60 -
.../ignite/sink/flink/FlinkIgniteSinkSelfTest.java | 84 --
.../source/flink/FlinkIgniteSourceSelfTest.java | 154 ---
.../flink/src/test/resources/example-ignite.xml | 73 -
.../hibernate/IgniteCollectionDataAccess.java | 32 +-
.../cache/hibernate/IgniteDomainDataRegion.java | 22 +-
.../cache/hibernate/IgniteEntityDataAccess.java | 30 +-
.../cache/hibernate/IgniteNaturalIdDataAccess.java | 30 +-
.../h2/DurableBackgroundCleanupIndexTreeTask.java | 179 +++
.../internal/processors/query/h2/H2Utils.java | 3 +
.../processors/query/h2/IgniteH2Indexing.java | 16 +-
.../internal/processors/query/h2/QueryParser.java | 13 +-
.../query/h2/QueryParserMetricsHolder.java | 62 +
.../processors/query/h2/database/H2Tree.java | 30 +-
.../query/h2/database/H2TreeClientIndex.java | 2 +-
.../processors/query/h2/database/H2TreeIndex.java | 131 +-
.../query/h2/database/H2TreeIndexBase.java | 16 +-
.../processors/query/h2/dml/DmlBatchSender.java | 4 +-
.../processors/query/h2/dml/UpdatePlanBuilder.java | 4 +-
.../processors/query/h2/opt/GridH2IndexBase.java | 9 +
.../processors/query/h2/opt/GridH2Table.java | 29 +-
.../processors/query/h2/opt/H2CacheRow.java | 4 +-
.../query/h2/sql/GridSqlQueryParser.java | 16 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 12 +-
.../metric/sql/MetricRegistryLocalSystemView.java | 14 +-
.../spi/metric/sql/SqlViewMetricExporterSpi.java | 10 +-
.../org/apache/ignite/client/ClientTestSuite.java | 8 +-
...finityKeyNameAndValueFieldNameConflictTest.java | 2 +-
...usterReadOnlyModeDoesNotBreakSqlSelectTest.java | 121 ++
.../processors/cache/SqlCacheStartStopTest.java | 330 +++++
.../H2DynamicColumnsAbstractBasicSelfTest.java | 37 +
.../index/H2TreeCorruptedTreeExceptionTest.java | 98 +-
.../index/IoStatisticsBasicIndexSelfTest.java | 47 +-
.../index/StopNodeOnRebuildIndexFailureTest.java | 10 +-
.../persistence/RebuildIndexLogMessageTest.java | 3 -
.../db/LongDestroyDurableBackgroundTaskTest.java | 676 ++++++++++
.../persistence/db/wal/IgniteWalRecoveryTest.java | 3 +-
.../cache/ttl/CacheTtlReadOnlyModeSelfTest.java | 15 +-
...ngingBaselineCacheQueryNodeRestartSelfTest.java | 7 +-
.../processors/query/AbstractCustomSchemaTest.java | 197 +++
.../query/AbstractDefaultSchemaTest.java | 133 ++
.../query/IgniteSqlCustomSchemaTest.java | 51 +
.../query/IgniteSqlCustomSchemaWithPdsEnabled.java | 148 +++
.../query/IgniteSqlDefaultSchemaTest.java} | 15 +-
.../IgniteSqlSchemasDiffConfigurationsTest.java | 90 ++
.../processors/query/JdbcSqlCustomSchemaTest.java | 85 ++
.../processors/query/JdbcSqlDefaultSchemaTest.java | 85 ++
...encyAfterInterruptAtomicCacheOperationTest.java | 153 +++
...istencyAfterInterruptTxCacheOperationTest.java} | 15 +-
.../query/SqlQueriesTopologyMappingTest.java | 185 +++
.../SqlTwoCachesInGroupWithSameEntryTest.java | 145 ++
.../query/h2/QueryParserMetricsHolderSelfTest.java | 109 ++
.../IgniteBinaryCacheQueryTestSuite.java | 16 +
.../IgniteBinaryCacheQueryTestSuite2.java | 15 +-
...teCacheWithIndexingAndPersistenceTestSuite.java | 8 +-
.../IgniteCacheWithIndexingTestSuite.java | 3 +
.../testsuites/IgnitePdsWithIndexingTestSuite.java | 4 +-
...dHandlerIndexingClusterByClassWithSSLTest.java} | 16 +-
.../GridCommandHandlerIndexingWithSSLTest.java} | 16 +-
.../opencensus/OpenCensusMetricExporterSpi.java | 6 +-
.../OpenCensusMetricExporterSpiTest.java | 4 +-
.../platforms/cpp/core-test/src/teamcity_boost.cpp | 120 +-
.../cpp/core-test/src/teamcity_messages.cpp | 9 +-
.../cpp/odbc-test/src/teamcity/teamcity_boost.cpp | 120 +-
.../odbc-test/src/teamcity/teamcity_messages.cpp | 9 +-
.../cpp/thin-client-test/src/cache_client_test.cpp | 18 +-
.../src/teamcity/teamcity_boost.cpp | 120 +-
.../src/teamcity/teamcity_messages.cpp | 9 +-
.../ignite/thin/ignite_client_configuration.h | 24 +-
.../cpp/thin-client/project/vs/thin-client.vcxproj | 2 +-
.../project/vs/thin-client.vcxproj.filters | 6 +-
.../src/impl/affinity/affinity_manager.cpp | 4 +-
.../src/impl/affinity/affinity_manager.h | 6 +-
...areness_group.h => partition_awareness_group.h} | 12 +-
.../src/impl/cache/cache_client_impl.cpp | 2 +-
.../cpp/thin-client/src/impl/data_channel.h | 2 +-
.../cpp/thin-client/src/impl/data_router.cpp | 2 +-
.../cpp/thin-client/src/impl/data_router.h | 10 +-
.../platforms/cpp/thin-client/src/impl/message.cpp | 2 +-
.../platforms/cpp/thin-client/src/impl/message.h | 16 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.AspNet.nuspec | 17 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.Benchmarks.DotNetCore.csproj | 18 +
.../Apache.Ignite.Benchmarks.csproj | 2 +
.../Apache.Ignite.Benchmarks/BenchmarkRunner.cs | 26 +-
...GetBenchmark.cs => GetAllEmployeesBenchmark.cs} | 38 +-
.../Interop/GetBenchmark.cs | 8 +
.../Apache.Ignite.Benchmarks/Model/Employee.cs | 18 +
.../Properties/AssemblyInfo.cs | 4 +-
...rk.cs => ThinClientGetAllEmployeesBenchmark.cs} | 39 +-
.../ThinClient/ThinClientGetBenchmark.cs | 8 +
.../Apache.Ignite.Core.Tests.DotNetCore.csproj | 31 +-
.../Properties/AssemblyInfo.cs | 2 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Properties/AssemblyInfo.cs | 2 +-
.../Apache.Ignite.Core.Tests.csproj | 9 +-
.../ApiParity/ClusterParityTest.cs | 6 +-
.../Apache.Ignite.Core.Tests/AssertExtensions.cs | 35 +-
.../Serializable/DynamicFieldSetSerializable.cs | 81 ++
.../Binary/Serializable/DynamicFieldSetTest.cs | 120 ++
.../Client/Cache/CacheTest.cs | 21 +-
.../Client/Cache/CacheTestNoMeta.cs | 6 -
.../Client/Cache/CreateCacheTest.cs | 4 +-
.../Client/Cache/DynamicFieldSetTest.cs | 141 ++
...yAwarenessTest.cs => PartitionAwarenessTest.cs} | 95 +-
.../Client/Cache/SerializableObjectsTest.cs | 136 ++
.../Client/ClientConnectionTest.cs | 23 +
.../Client/ClientProtocolCompatibilityTest.cs | 14 +-
.../Client/ClientReconnectCompatibilityTest.cs | 10 +-
.../Client/ClientServerCacheAdapter.cs | 302 +++++
.../Client/ClientServerCacheAdapterExtensions.cs} | 47 +-
.../Client/ClientServerCompatibilityTest.cs | 166 ++-
.../Client/ClientTestBase.cs | 80 +-
.../Client/Cluster/ClientClusterGroupTests.cs | 313 +++++
.../Client/IgniteClientConfigurationTest.cs | 6 +-
.../Compute/ComputeApiTest.cs | 84 +-
.../Config/Client/IgniteClientConfiguration.xml | 2 +-
.../dotnet/Apache.Ignite.Core.Tests/JavaServer.cs | 53 +-
.../Apache.Ignite.Core.Tests/JavaServer/pom.xml | 2 +-
.../JavaServer/src/main/java/Runner.java | 20 +-
.../Apache.Ignite.Core.Tests/ProcessExtensions.cs | 1 +
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.Core.Schema.nuspec | 13 +-
.../Apache.Ignite.Core/Apache.Ignite.Core.csproj | 13 +-
.../Apache.Ignite.Core/Apache.Ignite.Core.nuspec | 23 +-
.../Apache.Ignite.Core/Client/IClientCluster.cs | 2 +-
.../Client/IClientClusterGroup.cs | 96 ++
.../Client/IClientClusterNode.cs | 98 ++
.../Client/IgniteClientConfiguration.cs | 10 +-
.../Common/IgniteExperimentalAttribute.cs} | 35 +-
.../platforms/dotnet/Apache.Ignite.Core/IIgnite.cs | 2 +-
.../IgniteClientConfigurationSection.xsd | 2 +-
.../Impl/Binary/BinaryObjectSchemaSerializer.cs | 61 +-
.../Impl/Binary/BinaryProcessor.cs | 21 +-
.../Impl/Binary/BinaryProcessorClient.cs | 37 +-
.../Apache.Ignite.Core/Impl/Binary/BinaryReader.cs | 10 +-
.../Impl/Binary/IBinaryProcessor.cs | 5 -
.../Apache.Ignite.Core/Impl/Binary/Marshaller.cs | 97 +-
.../Impl/Binary/Metadata/BinaryType.cs | 9 +-
.../Impl/Binary/Metadata/BinaryTypeHolder.cs | 69 +-
.../Impl/Binary/SerializableSerializer.cs | 35 +-
.../Impl/Client/Cache/CacheClient.cs | 250 ++--
...up.cs => ClientCachePartitionAwarenessGroup.cs} | 4 +-
.../Client/Cache/Query/ClientQueryCursorBase.cs | 5 +-
.../Impl/Client/ClientContextBase.cs | 79 ++
.../Impl/Client/ClientFailoverSocket.cs | 73 +-
.../Apache.Ignite.Core/Impl/Client/ClientOp.cs | 6 +-
.../{IClientSocket.cs => ClientRequestContext.cs} | 51 +-
.../Impl/Client/ClientResponseContext.cs | 51 +
.../Apache.Ignite.Core/Impl/Client/ClientSocket.cs | 62 +-
.../Apache.Ignite.Core/Impl/Client/ClientUtils.cs | 58 +
.../Impl/Client/Cluster/ClientCluster.cs | 73 +-
.../Impl/Client/Cluster/ClientClusterGroup.cs | 313 +++++
.../Client/Cluster/ClientClusterGroupProjection.cs | 166 +++
.../Impl/Client/Cluster/ClientClusterNode.cs | 171 +++
.../Apache.Ignite.Core/Impl/Client/IgniteClient.cs | 71 +-
.../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 2 +-
.../Apache.Ignite.Core/Properties/AssemblyInfo.cs | 2 +-
.../platforms/dotnet/Apache.Ignite.DotNetCore.sln | 6 +
.../Apache.Ignite.EntityFramework.nuspec | 19 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.Linq.DotNetCore.csproj | 2 +-
.../Apache.Ignite.Linq/Apache.Ignite.Linq.nuspec | 27 +-
.../Apache.Ignite.Linq/Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.Log4Net.nuspec | 26 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Apache.Ignite.NLog/Apache.Ignite.NLog.nuspec | 26 +-
.../Apache.Ignite.NLog/Properties/AssemblyInfo.cs | 2 +-
.../Apache.Ignite/Properties/AssemblyInfo.cs | 4 +-
modules/platforms/dotnet/DEVNOTES.txt | 3 +-
modules/platforms/dotnet/README.md | 6 +-
modules/platforms/dotnet/build.ps1 | 6 +-
.../Properties/AssemblyInfo.cs | 4 +-
.../Properties/AssemblyInfo.cs | 4 +-
modules/platforms/dotnet/logo_ignite_128x128.png | Bin 0 -> 18667 bytes
modules/platforms/dotnet/release/Program.cs | 31 +-
modules/platforms/dotnet/release/verify-nuget.ps1 | 5 +-
.../protocols/http/jetty/GridJettyRestHandler.java | 58 +-
.../http/jetty/GridJettyRestProtocol.java | 39 +-
modules/scalar-2.10/pom.xml | 2 +-
modules/scalar/pom.xml | 2 +-
modules/{flink => spring-data-2.2}/README.txt | 21 +-
.../licenses/apache-2.0.txt | 0
modules/spring-data-2.2/pom.xml | 141 ++
.../springdata22/repository/IgniteRepository.java | 58 +
.../config/EnableIgniteRepositories.java | 119 ++
.../config/IgniteRepositoriesRegistar.java} | 27 +-
.../IgniteRepositoryConfigurationExtension.java | 49 +
.../springdata22/repository/config/Query.java} | 24 +-
.../repository/config/RepositoryConfig.java} | 26 +-
.../repository/config/package-info.java} | 13 +-
.../springdata22/repository}/package-info.java | 5 +-
.../springdata22/repository/query/IgniteQuery.java | 82 ++
.../repository/query/IgniteQueryGenerator.java | 252 ++++
.../repository/query/IgniteRepositoryQuery.java | 312 +++++
.../repository/query/package-info.java} | 14 +-
.../repository/support/ConditionFalse.java} | 24 +-
.../support/IgniteRepositoryFactory.java | 168 +++
.../support/IgniteRepositoryFactoryBean.java | 91 ++
.../repository/support/IgniteRepositoryImpl.java | 164 +++
.../repository/support}/package-info.java | 4 +-
.../springdata/IgniteSpringDataCrudSelfTest.java | 353 +++++
.../IgniteSpringDataQueriesSelfTest.java | 317 +++++
.../springdata/misc/ApplicationConfiguration.java} | 41 +-
.../org/apache/ignite/springdata/misc/Person.java | 98 ++
.../ignite/springdata/misc/PersonRepository.java | 119 ++
.../springdata/misc/PersonSecondRepository.java | 40 +
.../testsuites/IgniteSpringData22TestSuite.java} | 13 +-
.../java/org/apache/ignite/IgniteSpringBean.java | 7 +
.../src/test/config/state/cluster-state.xml} | 36 +-
.../cluster/ClusterStateXmlPropertiesTest.java | 90 ++
.../ignite/testsuites/IgniteSpringTestSuite.java | 5 +-
.../app/modules/branding/branding.service.js | 4 +-
parent/pom.xml | 45 +-
pom.xml | 7 +-
722 files changed, 28774 insertions(+), 9019 deletions(-)
diff --cc modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
index d0e9556,4bd3aa9..e01f33d
--- a/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/GridKernalContextImpl.java
@@@ -703,9 -707,10 +708,11 @@@ public class GridKernalContextImpl impl
compressProc = (CompressionProcessor)comp;
else if (comp instanceof DiagnosticProcessor)
diagnosticProcessor = (DiagnosticProcessor)comp;
+ else if (comp instanceof DurableBackgroundTasksProcessor)
+ durableBackgroundTasksProcessor = (DurableBackgroundTasksProcessor)comp;
else if (!(comp instanceof DiscoveryNodeValidationProcessor
- || comp instanceof PlatformPluginProcessor))
+ || comp instanceof PlatformPluginProcessor
+ || comp instanceof QueryEngine))
assert (comp instanceof GridPluginComponent) : "Unknown manager class: " + comp.getClass();
if (addToList)
diff --cc modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
index 42d0e2f,1840451..31116d8
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java
@@@ -37,6 -40,6 +37,7 @@@ import java.nio.file.Path
import java.nio.file.Paths;
import java.text.DateFormat;
import java.text.DecimalFormat;
++import java.text.DecimalFormatSymbols;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;