Merge remote-tracking branch 'remotes/origin/master' into ignite-1192
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2ab0999d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2ab0999d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2ab0999d Branch: refs/heads/ignite-1192 Commit: 2ab0999d4f97b5361d094862ebf2115ed3360b3c Parents: 9017ab4 edfa353 Author: Denis Magda <[email protected]> Authored: Mon Apr 10 14:26:37 2017 -0700 Committer: Denis Magda <[email protected]> Committed: Mon Apr 10 14:26:37 2017 -0700 ---------------------------------------------------------------------- DEVNOTES.txt | 3 - assembly/dependencies-fabric-lgpl.xml | 3 - assembly/dependencies-fabric.xml | 3 - assembly/dependencies-schema-import.xml | 57 - assembly/release-base.xml | 2 - assembly/release-fabric-base.xml | 15 +- assembly/release-schema-import.xml | 50 - bin/ignite-schema-import.bat | 110 - bin/ignite-schema-import.sh | 87 - examples/README-LGPL.txt | 4 +- examples/README.txt | 2 - examples/pom-standalone-lgpl.xml | 1 - examples/pom-standalone.xml | 1 - examples/pom.xml | 1 - examples/schema-import/README.txt | 38 - examples/schema-import/bin/db-init.sql | 28 - examples/schema-import/bin/h2-server.bat | 80 - examples/schema-import/bin/h2-server.sh | 66 - .../schema-import/bin/schema-import.properties | 28 - examples/schema-import/pom-standalone.xml | 90 - examples/schema-import/pom.xml | 101 - .../org/apache/ignite/schema/CacheConfig.java | 36 - .../java/org/apache/ignite/schema/Demo.java | 134 -- .../java/org/apache/ignite/schema/DemoNode.java | 38 - .../ignite/schema/H2DataSourceFactory.java | 35 - .../java/org/apache/ignite/schema/Person.java | 44 - .../org/apache/ignite/schema/PersonKey.java | 37 - .../computegrid/ComputeAsyncExample.java | 8 +- .../ComputeFibonacciContinuationExample.java | 13 +- .../examples/datagrid/CacheAsyncApiExample.java | 17 +- .../datastructures/IgniteLockExample.java | 4 +- .../datastructures/IgniteSemaphoreExample.java | 4 +- .../examples/ScalarContinuationExample.scala | 10 +- .../singlesplit/SingleSplitsLoadTest.java | 8 +- .../spi/checkpoint/s3/S3CheckpointSpi.java | 72 +- .../tcp/ipfinder/s3/TcpDiscoveryS3IpFinder.java | 27 +- .../ignite/tests/utils/TestTransaction.java | 11 + .../internal/client/ClientStartNodeTask.java | 10 +- .../internal/jdbc2/JdbcConnectionSelfTest.java | 34 + .../JettyRestProcessorAbstractSelfTest.java | 2 +- .../jdbc/AbstractJdbcPojoQuerySelfTest.java | 169 ++ .../jdbc/JdbcPojoLegacyQuerySelfTest.java | 44 + .../ignite/jdbc/JdbcPojoQuerySelfTest.java | 56 + .../jdbc/suite/IgniteJdbcDriverTestSuite.java | 4 + .../src/test/resources/spring-server-node.xml | 71 +- .../test/resources/spring-server-ssl-node.xml | 69 +- .../cloud/TcpDiscoveryCloudIpFinder.java | 51 +- .../java/org/apache/ignite/IgniteBinary.java | 35 +- .../java/org/apache/ignite/IgniteCache.java | 611 ++++- .../java/org/apache/ignite/IgniteCluster.java | 126 ++ .../java/org/apache/ignite/IgniteCompute.java | 262 ++- .../java/org/apache/ignite/IgniteEvents.java | 128 +- .../org/apache/ignite/IgniteFileSystem.java | 92 +- .../org/apache/ignite/IgniteJdbcDriver.java | 11 +- .../java/org/apache/ignite/IgniteMessaging.java | 27 + .../java/org/apache/ignite/IgniteServices.java | 221 +- .../ignite/binary/BinaryBasicIdMapper.java | 5 +- .../ignite/binary/BinaryBasicNameMapper.java | 5 +- .../ignite/binary/BinaryObjectBuilder.java | 10 - .../ignite/binary/BinaryTypeConfiguration.java | 30 +- .../ignite/cache/CacheKeyConfiguration.java | 10 +- .../ignite/cache/CacheTypeFieldMetadata.java | 149 -- .../apache/ignite/cache/CacheTypeMetadata.java | 379 ---- .../org/apache/ignite/cache/QueryEntity.java | 38 +- .../affinity/fair/FairAffinityFunction.java | 21 +- .../rendezvous/RendezvousAffinityFunction.java | 27 +- .../cache/eviction/AbstractEvictionPolicy.java | 15 +- .../cache/eviction/fifo/FifoEvictionPolicy.java | 74 +- .../eviction/fifo/FifoEvictionPolicyMBean.java | 2 + .../igfs/IgfsPerBlockLruEvictionPolicy.java | 131 +- .../cache/eviction/lru/LruEvictionPolicy.java | 74 +- .../eviction/sorted/SortedEvictionPolicy.java | 74 +- .../store/jdbc/CacheAbstractJdbcStore.java | 79 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 18 +- .../configuration/AtomicConfiguration.java | 15 +- .../configuration/BinaryConfiguration.java | 30 +- .../configuration/CacheConfiguration.java | 98 +- .../configuration/CollectionConfiguration.java | 36 +- .../configuration/ConnectorConfiguration.java | 100 +- .../configuration/FileSystemConfiguration.java | 155 +- .../configuration/HadoopConfiguration.java | 31 +- .../configuration/IgniteConfiguration.java | 34 +- .../configuration/NearCacheConfiguration.java | 6 +- .../configuration/TransactionConfiguration.java | 45 +- .../igfs/IgfsGroupDataBlocksKeyMapper.java | 5 +- .../igfs/IgfsIpcEndpointConfiguration.java | 30 +- .../apache/ignite/internal/GridComponent.java | 5 +- .../ignite/internal/GridJobCancelRequest.java | 2 +- .../ignite/internal/GridJobExecuteRequest.java | 2 +- .../ignite/internal/GridJobExecuteResponse.java | 2 +- .../ignite/internal/GridJobSiblingsRequest.java | 2 +- .../internal/GridJobSiblingsResponse.java | 2 +- .../ignite/internal/GridKernalContext.java | 7 + .../ignite/internal/GridKernalContextImpl.java | 11 + .../ignite/internal/GridTaskCancelRequest.java | 2 +- .../ignite/internal/GridTaskSessionRequest.java | 2 +- .../org/apache/ignite/internal/GridTopic.java | 5 +- .../ignite/internal/IgniteComputeImpl.java | 546 ++++- .../ignite/internal/IgniteEventsImpl.java | 87 +- .../apache/ignite/internal/IgniteKernal.java | 2 + .../ignite/internal/IgniteMessagingImpl.java | 65 +- .../ignite/internal/IgniteServicesImpl.java | 108 + .../org/apache/ignite/internal/IgnitionEx.java | 20 +- .../ignite/internal/MarshallerContextImpl.java | 25 +- .../ignite/internal/MarshallerPlatformIds.java | 3 + .../binary/BinaryCachingMetadataHandler.java | 6 + .../internal/binary/BinaryClassDescriptor.java | 33 +- .../ignite/internal/binary/BinaryContext.java | 29 +- .../internal/binary/BinaryEnumObjectImpl.java | 2 +- .../internal/binary/BinaryFieldMetadata.java | 127 ++ .../ignite/internal/binary/BinaryMetadata.java | 49 +- .../binary/BinaryMetadataCollector.java | 17 +- .../internal/binary/BinaryMetadataHandler.java | 18 +- .../binary/BinaryNoopMetadataHandler.java | 5 + .../internal/binary/BinaryObjectExImpl.java | 4 - .../internal/binary/BinaryObjectImpl.java | 2 +- .../binary/BinaryObjectOffheapImpl.java | 2 +- .../internal/binary/BinaryReaderExImpl.java | 2 +- .../ignite/internal/binary/BinaryUtils.java | 23 +- .../internal/binary/BinaryWriterExImpl.java | 45 +- .../binary/builder/BinaryObjectBuilderImpl.java | 70 +- .../client/GridClientConfiguration.java | 100 +- .../client/GridClientDataConfiguration.java | 15 +- .../client/GridClientPartitionAffinity.java | 15 +- .../balancer/GridClientBalancerAdapter.java | 5 +- .../router/GridTcpRouterConfiguration.java | 50 +- .../internal/cluster/ClusterGroupAdapter.java | 2 +- .../cluster/IgniteClusterAsyncImpl.java | 28 +- .../internal/cluster/IgniteClusterImpl.java | 24 +- .../internal/direct/DirectMessageWriter.java | 4 +- .../stream/v1/DirectByteBufferStreamImplV1.java | 8 +- .../stream/v2/DirectByteBufferStreamImplV2.java | 9 +- .../ignite/internal/jdbc2/JdbcConnection.java | 56 +- .../ignite/internal/jdbc2/JdbcQueryTask.java | 2 +- .../ignite/internal/jdbc2/JdbcQueryTaskV2.java | 2 +- .../internal/jdbc2/JdbcSqlFieldsQuery.java | 57 + .../checkpoint/GridCheckpointRequest.java | 2 +- .../managers/communication/GridIoManager.java | 2 + .../managers/communication/GridIoMessage.java | 2 +- .../communication/GridIoMessageFactory.java | 23 +- .../managers/communication/GridIoPolicy.java | 5 +- .../communication/GridIoUserMessage.java | 2 +- .../communication/IgniteIoTestMessage.java | 2 +- .../deployment/GridDeploymentInfoBean.java | 2 +- .../deployment/GridDeploymentRequest.java | 2 +- .../deployment/GridDeploymentResponse.java | 2 +- .../discovery/DiscoveryCustomMessage.java | 48 + .../discovery/GridDiscoveryManager.java | 38 +- .../eventstorage/GridEventStorageManager.java | 18 +- .../eventstorage/GridEventStorageMessage.java | 2 +- .../affinity/AffinityTopologyVersion.java | 2 +- .../cache/CacheAffinitySharedManager.java | 4 - .../cache/CacheEntryInfoCollection.java | 2 +- .../cache/CacheEntryPredicateAdapter.java | 2 +- .../cache/CacheEntryPredicateContainsValue.java | 2 +- .../cache/CacheEntrySerializablePredicate.java | 2 +- .../processors/cache/CacheEvictionEntry.java | 2 +- .../cache/CacheInvokeDirectResult.java | 2 +- .../cache/CacheObjectByteArrayImpl.java | 2 +- .../processors/cache/CacheObjectImpl.java | 2 +- .../processors/cache/GridCacheAdapter.java | 184 +- .../processors/cache/GridCacheAtomicFuture.java | 2 +- .../processors/cache/GridCacheEntryInfo.java | 2 +- .../cache/GridCacheEvictionRequest.java | 2 +- .../cache/GridCacheEvictionResponse.java | 2 +- .../processors/cache/GridCacheMvccManager.java | 84 +- .../GridCachePartitionExchangeManager.java | 62 +- .../processors/cache/GridCacheProcessor.java | 39 +- .../processors/cache/GridCacheReturn.java | 2 +- .../processors/cache/GridCacheUtils.java | 4 - .../cache/GridDeferredAckMessageSender.java | 11 +- .../processors/cache/IgniteCacheProxy.java | 579 ++++- .../processors/cache/KeyCacheObjectImpl.java | 2 +- .../cache/binary/BinaryMetadataHolder.java | 73 + .../cache/binary/BinaryMetadataTransport.java | 641 ++++++ .../binary/BinaryMetadataUpdatedListener.java | 29 + .../binary/CacheObjectBinaryProcessor.java | 12 +- .../binary/CacheObjectBinaryProcessorImpl.java | 508 ++--- .../binary/ClientMetadataRequestFuture.java | 161 ++ .../cache/binary/MetadataRequestMessage.java | 122 + .../cache/binary/MetadataResponseMessage.java | 195 ++ .../binary/MetadataUpdateAcceptedMessage.java | 96 + .../binary/MetadataUpdateProposedMessage.java | 224 ++ .../cache/binary/MetadataUpdateResult.java | 96 + .../distributed/GridCacheTtlUpdateRequest.java | 2 +- .../distributed/GridCacheTxRecoveryRequest.java | 2 +- .../GridCacheTxRecoveryResponse.java | 2 +- .../distributed/GridDistributedLockRequest.java | 2 +- .../GridDistributedLockResponse.java | 2 +- .../GridDistributedTxFinishRequest.java | 2 +- .../GridDistributedTxFinishResponse.java | 2 +- .../GridDistributedTxPrepareRequest.java | 2 +- .../GridDistributedTxPrepareResponse.java | 2 +- .../GridDistributedUnlockRequest.java | 2 +- .../dht/GridClientPartitionTopology.java | 34 +- .../dht/GridDhtAffinityAssignmentRequest.java | 2 +- .../dht/GridDhtAffinityAssignmentResponse.java | 103 +- .../distributed/dht/GridDhtLockRequest.java | 2 +- .../distributed/dht/GridDhtLockResponse.java | 2 +- .../dht/GridDhtPartitionTopology.java | 6 +- .../dht/GridDhtPartitionTopologyImpl.java | 34 +- .../distributed/dht/GridDhtTxFinishRequest.java | 2 +- .../dht/GridDhtTxFinishResponse.java | 2 +- .../dht/GridDhtTxOnePhaseCommitAckRequest.java | 2 +- .../dht/GridDhtTxPrepareRequest.java | 2 +- .../dht/GridDhtTxPrepareResponse.java | 2 +- .../distributed/dht/GridDhtUnlockRequest.java | 2 +- .../dht/GridPartitionedGetFuture.java | 8 +- .../dht/GridPartitionedSingleGetFuture.java | 53 +- .../GridDhtAtomicAbstractUpdateFuture.java | 4 +- .../GridDhtAtomicDeferredUpdateResponse.java | 2 +- .../dht/atomic/GridDhtAtomicNearResponse.java | 2 +- .../GridDhtAtomicSingleUpdateRequest.java | 2 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 2 +- .../dht/atomic/GridDhtAtomicUpdateResponse.java | 2 +- .../GridNearAtomicAbstractUpdateFuture.java | 2 +- .../GridNearAtomicCheckUpdateRequest.java | 2 +- .../atomic/GridNearAtomicFullUpdateRequest.java | 2 +- ...GridNearAtomicSingleUpdateFilterRequest.java | 2 +- .../GridNearAtomicSingleUpdateFuture.java | 21 +- ...GridNearAtomicSingleUpdateInvokeRequest.java | 2 +- .../GridNearAtomicSingleUpdateRequest.java | 2 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 23 +- .../atomic/GridNearAtomicUpdateResponse.java | 2 +- .../dht/atomic/NearCacheUpdates.java | 2 +- .../distributed/dht/atomic/UpdateErrors.java | 2 +- .../dht/preloader/GridDhtForceKeysRequest.java | 2 +- .../dht/preloader/GridDhtForceKeysResponse.java | 2 +- .../GridDhtPartitionDemandMessage.java | 2 +- .../dht/preloader/GridDhtPartitionDemander.java | 505 +---- .../preloader/GridDhtPartitionExchangeId.java | 2 +- .../dht/preloader/GridDhtPartitionFullMap.java | 45 +- .../dht/preloader/GridDhtPartitionMap.java | 210 +- .../dht/preloader/GridDhtPartitionMap2.java | 329 --- .../GridDhtPartitionSupplyMessage.java | 2 +- .../GridDhtPartitionSupplyMessageV2.java | 2 +- .../GridDhtPartitionsAbstractMessage.java | 4 - .../GridDhtPartitionsExchangeFuture.java | 2 +- .../preloader/GridDhtPartitionsFullMessage.java | 8 +- .../GridDhtPartitionsSingleMessage.java | 12 +- .../GridDhtPartitionsSingleRequest.java | 2 +- .../dht/preloader/GridDhtPreloader.java | 18 +- .../distributed/near/CacheVersionedValue.java | 2 +- .../distributed/near/GridNearGetRequest.java | 2 +- .../distributed/near/GridNearGetResponse.java | 2 +- .../distributed/near/GridNearLockRequest.java | 2 +- .../distributed/near/GridNearLockResponse.java | 2 +- .../near/GridNearSingleGetRequest.java | 2 +- .../near/GridNearSingleGetResponse.java | 2 +- .../near/GridNearTxFinishRequest.java | 2 +- .../near/GridNearTxFinishResponse.java | 2 +- .../near/GridNearTxPrepareRequest.java | 2 +- .../near/GridNearTxPrepareResponse.java | 2 +- .../distributed/near/GridNearUnlockRequest.java | 2 +- .../query/GridCacheDistributedQueryManager.java | 7 +- .../cache/query/GridCacheLocalQueryFuture.java | 3 +- .../cache/query/GridCacheQueryRequest.java | 2 +- .../cache/query/GridCacheQueryResponse.java | 2 +- .../cache/query/GridCacheSqlQuery.java | 2 +- .../CacheContinuousQueryBatchAck.java | 6 +- .../continuous/CacheContinuousQueryEntry.java | 2 +- .../continuous/CacheContinuousQueryHandler.java | 6 +- .../continuous/CacheContinuousQueryManager.java | 87 +- .../query/jdbc/GridCacheQueryJdbcTask.java | 4 +- .../store/GridCacheStoreManagerAdapter.java | 35 +- .../cache/transactions/IgniteTxEntry.java | 2 +- .../cache/transactions/IgniteTxKey.java | 2 +- .../cache/transactions/IgniteTxManager.java | 2 +- .../transactions/TransactionProxyImpl.java | 39 +- .../cache/transactions/TxEntryValueHolder.java | 2 +- .../processors/cache/transactions/TxLock.java | 2 +- .../cache/transactions/TxLockList.java | 2 +- .../cache/transactions/TxLocksRequest.java | 2 +- .../cache/transactions/TxLocksResponse.java | 2 +- .../version/GridCacheRawVersionedEntry.java | 2 +- .../cache/version/GridCacheVersion.java | 2 +- .../cache/version/GridCacheVersionEx.java | 2 +- .../clock/GridClockDeltaSnapshotMessage.java | 2 +- .../processors/clock/GridClockDeltaVersion.java | 2 +- .../closure/GridClosureProcessor.java | 398 +--- .../continuous/GridContinuousMessage.java | 2 +- .../continuous/GridContinuousProcessor.java | 6 +- .../datastreamer/DataStreamerEntry.java | 2 +- .../datastreamer/DataStreamerRequest.java | 2 +- .../datastreamer/DataStreamerResponse.java | 2 +- .../internal/processors/hadoop/HadoopJobId.java | 2 +- .../shuffle/HadoopDirectShuffleMessage.java | 2 +- .../hadoop/shuffle/HadoopShuffleAck.java | 2 +- .../shuffle/HadoopShuffleFinishRequest.java | 2 +- .../shuffle/HadoopShuffleFinishResponse.java | 2 +- .../hadoop/shuffle/HadoopShuffleMessage.java | 2 +- .../processors/igfs/IgfsAckMessage.java | 2 +- .../internal/processors/igfs/IgfsAsyncImpl.java | 45 +- .../internal/processors/igfs/IgfsBlockKey.java | 3 +- .../processors/igfs/IgfsBlocksMessage.java | 2 +- .../processors/igfs/IgfsDeleteMessage.java | 2 +- .../processors/igfs/IgfsFileAffinityRange.java | 2 +- .../igfs/IgfsFragmentizerRequest.java | 2 +- .../igfs/IgfsFragmentizerResponse.java | 2 +- .../internal/processors/igfs/IgfsImpl.java | 76 +- .../processors/igfs/IgfsSyncMessage.java | 2 +- .../GridMarshallerMappingProcessor.java | 7 +- .../MissingMappingRequestMessage.java | 2 +- .../MissingMappingResponseMessage.java | 2 +- .../platform/PlatformAbstractTarget.java | 24 +- .../platform/PlatformAsyncTarget.java | 44 - .../platform/PlatformContextImpl.java | 92 +- .../platform/PlatformTargetProxy.java | 22 - .../platform/PlatformTargetProxyImpl.java | 36 +- .../binary/PlatformBinaryProcessor.java | 40 +- .../platform/cache/PlatformCache.java | 218 +- .../platform/compute/PlatformCompute.java | 14 +- .../dotnet/PlatformDotNetCacheStore.java | 12 +- .../dotnet/PlatformDotNetConfigurationEx.java | 21 +- ...formDotNetEntityFrameworkCacheExtension.java | 8 +- .../platform/events/PlatformEvents.java | 70 +- .../memory/PlatformOutputStreamImpl.java | 8 +- .../platform/messaging/PlatformMessaging.java | 35 +- .../platform/services/PlatformServices.java | 95 +- .../transactions/PlatformTransactions.java | 9 +- .../utils/PlatformConfigurationUtils.java | 38 +- .../internal/processors/pool/PoolProcessor.java | 10 +- .../processors/query/GridQueryProcessor.java | 18 +- .../query/QueryTypeDescriptorImpl.java | 17 - .../internal/processors/query/QueryUtils.java | 328 +-- .../messages/GridQueryCancelRequest.java | 2 +- .../twostep/messages/GridQueryFailResponse.java | 2 +- .../messages/GridQueryNextPageRequest.java | 2 +- .../messages/GridQueryNextPageResponse.java | 2 +- .../h2/twostep/messages/GridQueryRequest.java | 368 --- .../handlers/task/GridTaskResultRequest.java | 2 +- .../handlers/task/GridTaskResultResponse.java | 2 +- .../service/GridServiceProcessor.java | 137 +- .../processors/service/GridServiceProxy.java | 10 + .../processors/task/GridTaskProcessor.java | 9 +- .../task/GridTaskThreadContextKey.java | 7 +- .../processors/task/GridTaskWorker.java | 16 +- .../org/apache/ignite/internal/util/F0.java | 196 +- .../ignite/internal/util/GridByteArrayList.java | 2 +- .../ignite/internal/util/GridLongList.java | 2 +- .../internal/util/GridMessageCollection.java | 2 +- .../ignite/internal/util/IgniteUtils.java | 10 - .../internal/util/UUIDCollectionMessage.java | 2 +- .../ignite/internal/util/lang/GridFunc.java | 620 +---- .../internal/util/nio/GridDirectParser.java | 12 +- .../ignite/internal/visor/cache/VisorCache.java | 84 +- .../cache/VisorCacheAggregatedMetrics.java | 2 +- .../visor/cache/VisorCacheClearTask.java | 14 +- .../visor/cache/VisorCacheConfiguration.java | 22 +- .../internal/visor/cache/VisorCacheMetrics.java | 26 + .../cache/VisorCacheMetricsCollectorTask.java | 18 +- .../visor/cache/VisorCacheMetricsV2.java | 66 - .../cache/VisorCacheQueryConfiguration.java | 11 + .../cache/VisorCacheQueryConfigurationV2.java | 47 - .../cache/VisorCacheStoreConfiguration.java | 12 + .../cache/VisorCacheStoreConfigurationV2.java | 48 - .../cache/VisorCacheTypeFieldMetadata.java | 14 +- .../visor/cache/VisorCacheTypeMetadata.java | 91 +- .../internal/visor/cache/VisorCacheV2.java | 73 - .../internal/visor/cache/VisorCacheV3.java | 52 - .../internal/visor/cache/VisorCacheV4.java | 124 - .../visor/compute/VisorGatewayTask.java | 6 +- .../visor/event/VisorGridDiscoveryEvent.java | 18 +- .../visor/event/VisorGridDiscoveryEventV2.java | 80 - .../visor/igfs/VisorIgfsFormatTask.java | 2 +- .../visor/node/VisorIgfsConfiguration.java | 2 +- .../visor/node/VisorNodeDataCollectorJob.java | 52 +- .../internal/visor/query/VisorQueryArg.java | 39 +- .../internal/visor/query/VisorQueryArgV2.java | 49 - .../internal/visor/query/VisorQueryArgV3.java | 51 - .../internal/visor/query/VisorQueryJob.java | 8 +- .../internal/visor/util/VisorEventMapper.java | 4 +- .../internal/visor/util/VisorTaskUtils.java | 15 - .../apache/ignite/lang/IgniteAsyncSupport.java | 52 +- .../ignite/lang/IgniteAsyncSupported.java | 4 +- .../optimized/OptimizedMarshaller.java | 15 +- .../apache/ignite/mxbean/IgniteMBeanAware.java | 28 + .../dotnet/PlatformDotNetAffinityFunction.java | 10 +- .../PlatformDotNetBinaryConfiguration.java | 31 +- .../PlatformDotNetBinaryTypeConfiguration.java | 35 +- .../dotnet/PlatformDotNetConfiguration.java | 10 +- .../extensions/communication/Message.java | 5 +- .../communication/MessageFactory.java | 2 +- .../extensions/communication/MessageWriter.java | 5 +- .../ignite/services/ServiceConfiguration.java | 35 +- .../org/apache/ignite/spi/IgniteSpiAdapter.java | 52 +- .../ignite/spi/IgniteSpiMBeanAdapter.java | 78 + .../checkpoint/cache/CacheCheckpointSpi.java | 40 +- .../spi/checkpoint/jdbc/JdbcCheckpointSpi.java | 219 +- .../spi/checkpoint/noop/NoopCheckpointSpi.java | 7 + .../sharedfs/SharedFsCheckpointSpi.java | 54 +- .../ignite/spi/collision/CollisionSpi.java | 11 +- .../fifoqueue/FifoQueueCollisionSpi.java | 134 +- .../fifoqueue/FifoQueueCollisionSpiMBean.java | 2 +- .../jobstealing/JobStealingCollisionSpi.java | 281 ++- .../JobStealingCollisionSpiMBean.java | 6 +- .../jobstealing/JobStealingRequest.java | 2 +- .../spi/collision/noop/NoopCollisionSpi.java | 7 + .../PriorityQueueCollisionSpi.java | 278 ++- .../PriorityQueueCollisionSpiMBean.java | 2 +- .../communication/tcp/TcpCommunicationSpi.java | 684 ++++-- .../deployment/local/LocalDeploymentSpi.java | 29 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 109 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 446 +++- .../ipfinder/TcpDiscoveryIpFinderAdapter.java | 5 +- .../ipfinder/jdbc/TcpDiscoveryJdbcIpFinder.java | 17 +- .../TcpDiscoveryMulticastIpFinder.java | 47 +- .../sharedfs/TcpDiscoverySharedFsIpFinder.java | 12 +- .../tcp/ipfinder/vm/TcpDiscoveryVmIpFinder.java | 14 +- .../messages/TcpDiscoveryClientAckResponse.java | 4 - .../spi/eventstorage/NoopEventStorageSpi.java | 53 + .../memory/MemoryEventStorageSpi.java | 98 +- .../spi/failover/always/AlwaysFailoverSpi.java | 53 +- .../jobstealing/JobStealingFailoverSpi.java | 68 +- .../spi/failover/never/NeverFailoverSpi.java | 30 +- .../spi/indexing/noop/NoopIndexingSpi.java | 7 + .../adaptive/AdaptiveLoadBalancingSpi.java | 43 +- .../roundrobin/RoundRobinLoadBalancingSpi.java | 44 +- .../WeightedRandomLoadBalancingSpi.java | 61 +- .../spi/swapspace/file/FileSwapSpaceSpi.java | 112 +- .../spi/swapspace/noop/NoopSwapSpaceSpi.java | 7 + .../apache/ignite/transactions/Transaction.java | 22 + .../resources/META-INF/classnames.properties | 108 +- .../test/config/store/jdbc/ignite-jdbc-type.xml | 279 +++ .../config/store/jdbc/ignite-type-metadata.xml | 276 --- .../IgniteCacheExpiryStoreLoadSelfTest.java | 18 +- ...eJdbcStoreAbstractMultithreadedSelfTest.java | 71 +- .../cache/store/jdbc/model/Organization.java | 2 - .../cache/store/jdbc/model/OrganizationKey.java | 2 - .../ignite/cache/store/jdbc/model/Person.java | 2 - .../store/jdbc/model/PersonComplexKey.java | 4 +- .../cache/store/jdbc/model/PersonKey.java | 2 - .../ignite/custom/DummyEventFilterFactory.java | 47 + .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 2 +- .../igfs/IgfsFragmentizerAbstractSelfTest.java | 2 +- .../ignite/igfs/IgfsFragmentizerSelfTest.java | 2 +- .../internal/ClusterGroupAbstractTest.java | 73 +- .../ComputeJobCancelWithServiceSelfTest.java | 7 +- .../internal/GridAffinityNoCacheSelfTest.java | 2 +- .../internal/GridCancelOnGridStopSelfTest.java | 2 +- .../GridCancelledJobsMetricsSelfTest.java | 11 +- .../internal/GridContinuousTaskSelfTest.java | 21 +- .../GridEventStorageCheckAllEventsSelfTest.java | 12 +- .../GridEventStorageDefaultExceptionTest.java | 94 + .../GridFailoverCustomTopologySelfTest.java | 7 +- .../GridJobMasterLeaveAwareSelfTest.java | 93 +- .../internal/GridMultipleJobsSelfTest.java | 8 +- .../ignite/internal/GridReduceSelfTest.java | 9 +- .../GridTaskCancelSingleNodeSelfTest.java | 7 +- .../internal/GridTaskExecutionSelfTest.java | 58 +- ...xecutionWithoutPeerClassLoadingSelfTest.java | 31 + .../GridTaskFailoverAffinityRunTest.java | 7 +- .../GridTaskInstanceExecutionSelfTest.java | 7 +- .../internal/GridTaskJobRejectSelfTest.java | 7 +- .../IgniteClientReconnectApiExceptionTest.java | 10 +- .../IgniteComputeEmptyClusterGroupTest.java | 26 +- .../binary/BinaryMarshallerSelfTest.java | 4 - .../BinaryObjectBuilderAdditionalSelfTest.java | 9 +- ...naryObjectBuilderDefaultMappersSelfTest.java | 127 +- .../binary/TestCachingMetadataHandler.java | 5 + ...ByteBufferStreamImplV2ByteOrderSelfTest.java | 2 +- ...GridManagerLocalMessageListenerSelfTest.java | 2 +- .../GridCommunicationSendMessageSelfTest.java | 83 +- .../communication/GridIoManagerSelfTest.java | 2 +- .../cache/CacheConcurrentReadThroughTest.java | 8 +- ...CacheExchangeMessageDuplicatedStateTest.java | 12 +- .../cache/CacheFutureExceptionSelfTest.java | 6 +- .../CachePutEventListenerErrorSelfTest.java | 7 +- .../GridCacheAbstractFailoverSelfTest.java | 6 +- ...cheAbstractFullApiMultithreadedSelfTest.java | 105 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 876 +++++++- .../cache/GridCacheAbstractMetricsSelfTest.java | 52 +- .../GridCacheAsyncOperationsLimitSelfTest.java | 9 +- .../GridCacheConcurrentTxMultiNodeTest.java | 10 +- .../GridCacheConditionalDeploymentSelfTest.java | 4 +- .../GridCacheInterceptorAbstractSelfTest.java | 31 +- .../GridCacheMissingCommitVersionSelfTest.java | 6 +- .../cache/GridCachePutAllFailoverSelfTest.java | 16 +- .../GridCacheReferenceCleanupSelfTest.java | 15 +- ...ridCacheStoreManagerDeserializationTest.java | 1 - .../cache/GridCacheUtilsSelfTest.java | 4 - ...calCacheStoreManagerDeserializationTest.java | 2 +- .../IgniteCacheAbstractStopBusySelfTest.java | 7 +- .../IgniteCacheBinaryObjectsScanSelfTest.java | 2 +- .../IgniteCacheConfigVariationsFullApiTest.java | 965 +++++++- .../cache/IgniteCacheInvokeAbstractTest.java | 20 +- .../IgniteCacheManyAsyncOperationsTest.java | 6 +- .../cache/IgniteCachePeekModesAbstractTest.java | 35 +- .../cache/WithKeepBinaryCacheFullApiTest.java | 228 +- .../binary/BinaryMetadataUpdatesFlowTest.java | 592 +++++ .../CacheKeepBinaryWithInterceptorTest.java | 16 +- ...ryDuplicateIndexObjectsAbstractSelfTest.java | 161 -- ...naryObjectMetadataExchangeMultinodeTest.java | 463 ++++ .../GridCacheBinaryObjectsAbstractSelfTest.java | 111 +- ...ateIndexObjectPartitionedAtomicSelfTest.java | 38 - ...xObjectPartitionedTransactionalSelfTest.java | 41 - ...eAbstractDataStructuresFailoverSelfTest.java | 7 +- ...ridCacheQueueJoinedNodeSelfAbstractTest.java | 12 +- .../IgniteCountDownLatchAbstractSelfTest.java | 7 +- .../IgniteLockAbstractSelfTest.java | 7 +- .../IgniteSemaphoreAbstractSelfTest.java | 7 +- ...acheAsyncOperationsFailoverAbstractTest.java | 12 +- .../distributed/CacheAsyncOperationsTest.java | 32 +- .../CachePutAllFailoverAbstractTest.java | 8 +- .../GridCacheAbstractJobExecutionTest.java | 15 +- .../GridCacheBasicOpAbstractTest.java | 38 +- .../distributed/GridCacheEventAbstractTest.java | 82 +- .../GridCacheMultiNodeAbstractTest.java | 25 +- ...yMetadataUpdateChangingTopologySelfTest.java | 13 +- .../IgniteCacheConnectionRecoveryTest.java | 10 +- ...eCacheMessageRecoveryIdleConnectionTest.java | 6 +- ...cOriginatingNodeFailureAbstractSelfTest.java | 6 +- .../dht/GridCacheDhtPreloadDelayedSelfTest.java | 12 +- .../dht/GridCacheDhtPreloadSelfTest.java | 4 +- .../dht/GridCacheGlobalLoadTest.java | 21 +- .../dht/GridCacheTxNodeFailureSelfTest.java | 12 +- .../IgniteCachePutRetryAbstractSelfTest.java | 26 +- .../atomic/IgniteCacheAtomicProtocolTest.java | 34 +- ...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 11 +- .../GridCachePartitionedLoadCacheSelfTest.java | 9 +- .../GridCacheRebalancingSyncSelfTest.java | 7 +- .../GridCacheEmptyEntriesAbstractSelfTest.java | 21 +- .../CacheContinuousQueryVariationsTest.java | 5 + .../ContinuousQueryPeerClassLoadingTest.java | 142 ++ .../GridCacheContinuousQueryConcurrentTest.java | 5 +- .../closure/GridClosureProcessorSelfTest.java | 74 +- ...ComputeJobExecutionErrorToLogManualTest.java | 10 +- ...gniteComputeConfigVariationsFullApiTest.java | 533 ++++- .../continuous/GridEventConsumeSelfTest.java | 196 +- ...faultIgfsSecondaryFileSystemTestAdapter.java | 2 +- .../igfs/IgfsAbstractBaseSelfTest.java | 2 +- .../processors/igfs/IgfsAbstractSelfTest.java | 4 +- ...sCachePerBlockLruEvictionPolicySelfTest.java | 2 +- .../igfs/IgfsMetaManagerSelfTest.java | 2 +- .../processors/igfs/IgfsMetricsSelfTest.java | 2 +- .../internal/processors/igfs/IgfsMock.java | 43 +- .../processors/igfs/IgfsProcessorSelfTest.java | 8 +- .../processors/igfs/IgfsStreamsSelfTest.java | 2 +- .../processors/igfs/IgfsTaskSelfTest.java | 21 +- .../IgfsAbstractRecordResolverSelfTest.java | 2 +- ...niteMessagingConfigVariationFullApiTest.java | 93 +- .../GridServiceProcessorAbstractSelfTest.java | 291 ++- .../GridServiceProcessorMultiNodeSelfTest.java | 18 +- .../GridServiceProcessorStopSelfTest.java | 7 +- .../nio/IgniteExceptionInNioWorkerSelfTest.java | 2 +- .../loadtest/GridSingleExecutionTest.java | 10 +- .../loadtests/colocation/GridTestMain.java | 7 +- .../communication/GridTestMessage.java | 2 +- .../multisplit/GridMultiSplitsLoadTest.java | 7 +- ...ridSingleSplitsNewNodesAbstractLoadTest.java | 8 +- .../ignite/loadtests/dsi/GridDsiClient.java | 12 +- ...GridJobExecutionLoadTestClientSemaphore.java | 9 +- ...JobExecutionSingleNodeSemaphoreLoadTest.java | 10 +- .../loadtests/job/GridJobLoadTestSubmitter.java | 7 +- .../mergesort/GridMergeSortLoadTask.java | 7 +- .../marshaller/MarshallerContextSelfTest.java | 80 +- .../ignite/messaging/GridMessagingSelfTest.java | 73 +- .../messaging/IgniteMessagingSendAsyncTest.java | 83 +- .../ignite/platform/PlatformStopIgniteTask.java | 11 +- .../services/ServiceThreadPoolSelfTest.java | 133 ++ ...idSessionFutureWaitJobAttributeSelfTest.java | 7 +- ...GridSessionSetJobAttributeOrderSelfTest.java | 8 +- ...sionSetJobAttributeWaitListenerSelfTest.java | 7 +- .../GridSessionSetTaskAttributeSelfTest.java | 7 +- ...GridSessionTaskWaitJobAttributeSelfTest.java | 7 +- .../GridSessionWaitAttributeSelfTest.java | 9 +- .../communication/GridCacheMessageSelfTest.java | 20 +- .../spi/communication/GridTestMessage.java | 4 +- .../TcpDiscoverySpiFailureTimeoutSelfTest.java | 60 - .../ignite/testframework/GridTestUtils.java | 57 + .../testframework/junits/GridAbstractTest.java | 56 +- .../junits/GridTestKernalContext.java | 1 + .../cache/GridAbstractCacheStoreSelfTest.java | 11 + .../junits/common/GridCommonAbstractTest.java | 30 +- .../multijvm/IgniteCacheProcessProxy.java | 172 ++ .../multijvm/IgniteClusterProcessProxy.java | 13 + .../multijvm/IgniteEventsProcessProxy.java | 31 + .../IgniteBinaryObjectsTestSuite.java | 4 + .../testsuites/IgniteComputeGridTestSuite.java | 4 + .../testsuites/IgniteKernalSelfTestSuite.java | 2 + .../ignite/util/GridMessageCollectionTest.java | 5 +- .../gce/TcpDiscoveryGoogleStorageIpFinder.java | 33 +- .../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 10 +- .../IgniteHadoopWeightedMapReducePlanner.java | 26 +- .../hadoop/impl/v2/HadoopV2Context.java | 7 +- .../impl/HadoopTaskExecutionSelfTest.java | 2 +- ...opClientProtocolMultipleServersSelfTest.java | 2 +- .../client/HadoopClientProtocolSelfTest.java | 2 +- .../hadoop/impl/igfs/IgfsEventsTestSuite.java | 2 +- .../query/h2/DmlStatementsProcessor.java | 35 - .../processors/query/h2/IgniteH2Indexing.java | 34 +- .../query/h2/opt/GridH2TreeIndex.java | 4 +- .../query/h2/sql/GridSqlOperationType.java | 23 +- .../query/h2/sql/GridSqlQueryParser.java | 19 +- .../query/h2/twostep/GridMapQueryExecutor.java | 39 - .../h2/twostep/GridReduceQueryExecutor.java | 62 +- .../query/h2/twostep/msg/GridH2Array.java | 2 +- .../query/h2/twostep/msg/GridH2Boolean.java | 2 +- .../query/h2/twostep/msg/GridH2Byte.java | 2 +- .../query/h2/twostep/msg/GridH2Bytes.java | 2 +- .../query/h2/twostep/msg/GridH2CacheObject.java | 2 +- .../query/h2/twostep/msg/GridH2Date.java | 2 +- .../query/h2/twostep/msg/GridH2Decimal.java | 2 +- .../query/h2/twostep/msg/GridH2Double.java | 2 +- .../query/h2/twostep/msg/GridH2Float.java | 2 +- .../query/h2/twostep/msg/GridH2Geometry.java | 2 +- .../h2/twostep/msg/GridH2IndexRangeRequest.java | 2 +- .../twostep/msg/GridH2IndexRangeResponse.java | 2 +- .../query/h2/twostep/msg/GridH2Integer.java | 2 +- .../query/h2/twostep/msg/GridH2JavaObject.java | 2 +- .../query/h2/twostep/msg/GridH2Long.java | 2 +- .../query/h2/twostep/msg/GridH2Null.java | 2 +- .../h2/twostep/msg/GridH2QueryRequest.java | 2 +- .../query/h2/twostep/msg/GridH2RowMessage.java | 2 +- .../query/h2/twostep/msg/GridH2RowRange.java | 2 +- .../h2/twostep/msg/GridH2RowRangeBounds.java | 2 +- .../query/h2/twostep/msg/GridH2Short.java | 2 +- .../query/h2/twostep/msg/GridH2String.java | 2 +- .../query/h2/twostep/msg/GridH2Time.java | 2 +- .../query/h2/twostep/msg/GridH2Timestamp.java | 2 +- .../query/h2/twostep/msg/GridH2Uuid.java | 2 +- .../twostep/msg/GridH2ValueMessageFactory.java | 2 +- .../cache/BinarySerializationQuerySelfTest.java | 30 +- ...ryDuplicateIndexObjectsAbstractSelfTest.java | 159 ++ ...niteCacheLockPartitionOnAffinityRunTest.java | 6 +- .../IgniteCacheObjectKeyIndexingSelfTest.java | 124 + .../cache/IgniteCacheQueryLoadSelfTest.java | 20 +- .../cache/IncorrectCacheTypeMetadataTest.java | 72 - .../cache/IncorrectQueryEntityTest.java | 3 + ...ateIndexObjectPartitionedAtomicSelfTest.java | 38 + ...xObjectPartitionedTransactionalSelfTest.java | 41 + .../query/IgniteQueryDedicatedPoolTest.java | 223 ++ .../query/IgniteSqlQueryDedicatedPoolTest.java | 110 - .../query/IgniteSqlSegmentedIndexSelfTest.java | 30 +- .../query/IgniteSqlSplitterSelfTest.java | 43 + .../h2/GridIndexingSpiAbstractSelfTest.java | 2 +- .../query/h2/sql/GridQueryParsingTest.java | 27 +- .../IgniteBinaryCacheQueryTestSuite.java | 4 +- .../IgniteCacheQuerySelfTestSuite.java | 6 +- .../IgniteCacheQuerySelfTestSuite2.java | 2 + .../IgniteCacheQuerySelfTestSuite3.java | 2 + modules/log4j2/pom.xml | 4 +- .../ignite/logger/log4j2/Log4J2Logger.java | 23 +- modules/platforms/cpp/binary/Makefile.am | 2 +- .../platforms/cpp/binary/include/Makefile.am | 1 + .../include/ignite/binary/binary_containers.h | 2 +- .../include/ignite/binary/binary_object.h | 75 +- .../include/ignite/binary/binary_raw_writer.h | 4 +- .../include/ignite/binary/binary_writer.h | 4 +- .../ignite/impl/binary/binary_field_meta.h | 110 + .../ignite/impl/binary/binary_id_resolver.h | 96 +- .../ignite/impl/binary/binary_object_header.h | 13 + .../ignite/impl/binary/binary_object_impl.h | 124 +- .../ignite/impl/binary/binary_reader_impl.h | 6 +- .../include/ignite/impl/binary/binary_schema.h | 10 +- .../ignite/impl/binary/binary_type_handler.h | 47 +- .../ignite/impl/binary/binary_type_impl.h | 2 +- .../ignite/impl/binary/binary_type_manager.h | 48 +- .../ignite/impl/binary/binary_type_snapshot.h | 82 +- .../ignite/impl/binary/binary_type_updater.h | 19 +- .../include/ignite/impl/binary/binary_utils.h | 13 +- .../ignite/impl/binary/binary_writer_impl.h | 21 +- .../cpp/binary/project/vs/binary.vcxproj | 3 +- .../binary/project/vs/binary.vcxproj.filters | 9 +- .../src/impl/binary/binary_field_meta.cpp | 42 + .../src/impl/binary/binary_object_impl.cpp | 139 +- .../src/impl/binary/binary_type_handler.cpp | 45 +- .../src/impl/binary/binary_type_manager.cpp | 187 +- .../src/impl/binary/binary_type_snapshot.cpp | 50 +- .../src/impl/binary/binary_type_updater.cpp | 32 - .../common/include/ignite/common/concurrent.h | 30 + .../cpp/common/include/ignite/reference.h | 14 +- .../cpp/core-test/config/cache-identity.xml | 33 + .../cpp/core-test/config/cache-query.xml | 37 +- .../cpp/core-test/config/cache-test.xml | 2 +- .../core-test/include/ignite/binary_test_defs.h | 5 + .../cpp/core-test/include/ignite/test_utils.h | 11 + .../project/vs/core-test.vcxproj.filters | 3 + .../src/binary_identity_resolver_test.cpp | 91 +- .../cpp/core-test/src/binary_object_test.cpp | 220 +- .../src/binary_reader_writer_raw_test.cpp | 12 +- .../core-test/src/binary_reader_writer_test.cpp | 12 +- .../cpp/core-test/src/cache_invoke_test.cpp | 8 +- .../cpp/core-test/src/cache_query_test.cpp | 225 +- .../platforms/cpp/core-test/src/cache_test.cpp | 229 +- .../cpp/core-test/src/cluster_test.cpp | 7 +- .../cpp/core-test/src/continuous_query_test.cpp | 202 +- .../cpp/core-test/src/ignition_test.cpp | 12 +- .../cpp/core-test/src/reference_test.cpp | 12 +- modules/platforms/cpp/core/Makefile.am | 1 + modules/platforms/cpp/core/include/Makefile.am | 70 +- .../cpp/core/include/ignite/cache/cache.h | 183 +- .../cpp/core/include/ignite/cache/cache_entry.h | 15 + .../ignite/cache/cache_entry_processor.h | 42 +- .../cache/event/cache_entry_event_filter.h | 109 + .../cache/query/continuous/continuous_query.h | 35 +- .../include/ignite/cache/query/query_cursor.h | 28 +- .../platforms/cpp/core/include/ignite/ignite.h | 18 +- .../cpp/core/include/ignite/ignite_binding.h | 39 +- .../include/ignite/ignite_binding_context.h | 2 +- .../cpp/core/include/ignite/ignition.h | 14 +- .../impl/binary/binary_type_updater_impl.h | 6 +- .../cpp/core/include/ignite/impl/bindings.h | 95 + .../impl/cache/cache_entry_processor_holder.h | 15 - .../core/include/ignite/impl/cache/cache_impl.h | 81 +- .../cache/event/cache_entry_event_filter_base.h | 66 + .../event/cache_entry_event_filter_holder.h | 185 ++ .../continuous/continuous_query_handle_impl.h | 10 - .../query/continuous/continuous_query_impl.h | 60 +- .../ignite/impl/cache/query/query_impl.h | 7 + .../cpp/core/include/ignite/impl/helpers.h | 57 + .../include/ignite/impl/ignite_binding_impl.h | 101 +- .../include/ignite/impl/ignite_environment.h | 37 +- .../cpp/core/include/ignite/impl/ignite_impl.h | 21 +- .../ignite/impl/interop/interop_target.h | 2 +- .../cpp/core/include/ignite/impl/operations.h | 138 +- .../platforms/cpp/core/project/vs/core.vcxproj | 6 + .../cpp/core/project/vs/core.vcxproj.filters | 21 + modules/platforms/cpp/core/src/ignition.cpp | 62 +- .../impl/binary/binary_type_updater_impl.cpp | 101 +- .../cpp/core/src/impl/cache/cache_impl.cpp | 90 +- .../continuous/continuous_query_handle_impl.cpp | 5 - .../core/src/impl/cache/query/query_impl.cpp | 39 +- .../cpp/core/src/impl/ignite_binding_impl.cpp | 88 + .../cpp/core/src/impl/ignite_environment.cpp | 128 +- .../platforms/cpp/core/src/impl/ignite_impl.cpp | 2 +- .../core/src/impl/interop/interop_target.cpp | 2 +- .../cpp/jni/include/ignite/jni/exports.h | 2 - .../platforms/cpp/jni/include/ignite/jni/java.h | 4 - modules/platforms/cpp/jni/project/vs/module.def | 2 - modules/platforms/cpp/jni/src/exports.cpp | 8 - modules/platforms/cpp/jni/src/java.cpp | 20 - .../ExpiryCacheHolderTest.cs | 12 +- .../Apache.Ignite.Core.Tests.csproj | 12 +- .../Binary/BinaryBuilderSelfTest.cs | 207 +- .../BinaryBuilderSelfTestArrayIdentity.cs | 34 - .../BinaryBuilderSelfTestDynamicRegistration.cs | 40 + .../Binary/BinaryCompactFooterInteropTest.cs | 2 +- .../Binary/BinaryDynamicRegistrationTest.cs | 483 ++++ .../Binary/BinaryEqualityComparerTest.cs | 7 +- .../Binary/BinarySelfTest.cs | 205 +- .../Binary/BinarySelfTestFullFooter.cs | 5 +- .../Binary/JavaBinaryInteropTest.cs | 182 ++ .../Serializable/AdvancedSerializationTest.cs | 228 ++ .../BasicSerializableObjectsTest.cs | 124 + .../Binary/Serializable/CallbacksTest.cs | 369 +++ .../Binary/Serializable/DelegatesTest.cs | 161 ++ .../Binary/Serializable/ObjectReferenceTests.cs | 131 ++ .../Binary/Serializable/PrimitivesTest.cs | 754 +++++++ .../Binary/Serializable/SqlDmlTest.cs | 277 +++ .../BinaryConfigurationTest.cs | 43 + .../Cache/Affinity/AffinityFunctionTest.cs | 21 - .../Cache/CacheAbstractTest.cs | 74 +- .../Cache/CacheConfigurationTest.cs | 4 +- .../Cache/CacheTestAsyncWrapper.cs | 12 +- .../Cache/Query/CacheDmlQueriesTest.cs | 5 +- .../Cache/Query/CacheLinqTest.cs | 167 +- .../Query/CacheQueriesCodeConfigurationTest.cs | 7 + .../Cache/Query/CacheQueriesTest.cs | 15 +- .../Continuous/ContinuousQueryAbstractTest.cs | 29 +- .../Cache/Store/CacheStoreAdapterTest.cs | 14 +- .../Cache/Store/CacheStoreSessionTest.cs | 2 +- .../Cache/Store/CacheStoreTest.cs | 7 +- .../Cache/Store/CacheTestParallelLoadStore.cs | 16 +- .../Cache/Store/CacheTestStore.cs | 13 +- .../Compute/AbstractTaskTest.cs | 28 +- .../Compute/ComputeApiTest.cs | 28 +- .../Compute/IgniteExceptionTaskSelfTest.cs | 40 +- .../Compute/MixedClusterTest.cs | 33 +- .../Compute/ResourceTaskTest.cs | 13 +- .../Config/cache-query-continuous.xml | 118 +- .../Apache.Ignite.Core.Tests/DeploymentTest.cs | 26 +- .../Apache.Ignite.Core.Tests/EventsTest.cs | 67 +- .../Examples/ExamplesTest.cs | 24 +- .../Apache.Ignite.Core.Tests/ExecutableTest.cs | 33 +- .../IgniteConfigurationSectionTest.cs | 7 +- .../IgniteConfigurationSerializerTest.cs | 19 +- .../IgniteConfigurationTest.cs | 15 +- .../Plugin/PluginTest.cs | 16 +- .../SerializationTest.cs | 240 -- .../Services/ServiceProxyTest.cs | 40 +- .../Apache.Ignite.Core.Tests/TestUtils.cs | 11 + .../Apache.Ignite.Core.csproj | 18 +- .../Binary/BinaryArrayEqualityComparer.cs | 8 + .../Binary/IBinaryObjectBuilder.cs | 10 - .../Cache/Affinity/AffinityFunctionBase.cs | 139 ++ .../Cache/Affinity/Fair/FairAffinityFunction.cs | 1 - .../Rendezvous/RendezvousAffinityFunction.cs | 1 - .../Cache/Configuration/CacheConfiguration.cs | 10 +- .../Cache/Configuration/QueryEntity.cs | 8 + .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 28 +- .../Cache/ICacheEntryProcessorResult.cs | 12 +- .../Cache/Query/Continuous/ContinuousQuery.cs | 59 +- .../Apache.Ignite.Core/Cache/Query/QueryBase.cs | 4 +- .../Cache/Query/SqlFieldsQuery.cs | 6 +- .../Store/CacheParallelLoadStoreAdapter.cs | 38 +- .../Cache/Store/CacheStoreAdapter.cs | 30 +- .../Cache/Store/ICacheStore.cs | 39 +- .../Cache/Store/ICacheStoreSession.cs | 2 +- .../Datastream/IDataStreamer.cs | 2 +- .../Apache.Ignite.Core/Events/CacheEvent.cs | 8 - .../Events/IEventStorageSpi.cs | 33 + .../Events/MemoryEventStorageSpi.cs | 100 + .../Events/NoopEventStorageSpi.cs | 27 + .../Apache.Ignite.Core/IgniteConfiguration.cs | 73 +- .../IgniteConfigurationSection.xsd | 29 + .../dotnet/Apache.Ignite.Core/Ignition.cs | 32 +- .../Impl/Binary/BinarizableSerializer.cs | 5 +- .../Impl/Binary/BinaryFullTypeDescriptor.cs | 49 +- .../Impl/Binary/BinaryObject.cs | 72 +- .../Impl/Binary/BinaryObjectBuilder.cs | 92 +- .../Impl/Binary/BinaryObjectHeader.cs | 13 +- .../Impl/Binary/BinaryObjectSchemaSerializer.cs | 2 + .../Impl/Binary/BinaryProcessor.cs | 41 +- .../Impl/Binary/BinaryReader.cs | 39 +- .../Impl/Binary/BinaryReflectiveActions.cs | 2 +- .../BinaryReflectiveSerializerInternal.cs | 84 +- .../Binary/BinarySurrogateTypeDescriptor.cs | 13 +- .../Impl/Binary/BinarySystemHandlers.cs | 96 +- .../Impl/Binary/BinarySystemTypeSerializer.cs | 2 +- .../Impl/Binary/BinaryUtils.cs | 64 +- .../Impl/Binary/BinaryWriter.cs | 244 +- .../Impl/Binary/DateTimeHolder.cs | 101 - .../Impl/Binary/DateTimeSerializer.cs | 48 - .../Binary/DeserializationCallbackProcessor.cs | 102 + .../Impl/Binary/IBinaryEqualityComparer.cs | 10 + .../Impl/Binary/IBinarySerializerInternal.cs | 4 +- .../Impl/Binary/IBinaryTypeDescriptor.cs | 8 + .../Impl/Binary/Io/BinaryStreamAdapter.cs | 119 - .../Impl/Binary/Io/IBinaryStream.cs | 3 +- .../Impl/Binary/Io/IBinaryStreamProcessor.cs | 5 +- .../Impl/Binary/Marshaller.cs | 281 ++- .../Impl/Binary/Metadata/BinaryField.cs | 72 + .../Impl/Binary/Metadata/BinaryType.cs | 38 +- .../Binary/Metadata/BinaryTypeHashsetHandler.cs | 10 +- .../Impl/Binary/Metadata/BinaryTypeHolder.cs | 9 +- .../Impl/Binary/Metadata/IBinaryTypeHandler.cs | 4 +- .../Impl/Binary/ReflectionUtils.cs | 50 + .../Impl/Binary/SerializableObjectHolder.cs | 96 - .../Impl/Binary/SerializableSerializer.cs | 656 +++++- .../Impl/Binary/TypeResolver.cs | 7 + .../Impl/Binary/UserSerializerProxy.cs | 5 +- .../Impl/Cache/Affinity/AffinityFunctionBase.cs | 140 -- .../Affinity/AffinityFunctionSerializer.cs | 3 - .../Impl/Cache/CacheEntryProcessorResult.cs | 27 +- .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 31 +- .../Impl/Cache/Store/CacheStore.cs | 233 +- .../Impl/Cache/Store/CacheStoreInternal.cs | 285 +++ .../Impl/Cache/Store/ICacheStoreInternal.cs | 43 + .../Impl/Collections/MultiValueDictionary.cs | 2 +- .../Common/CopyOnWriteConcurrentDictionary.cs | 35 + .../Impl/Common/DelegateConverter.cs | 90 +- .../Impl/Common/DelegateTypeDescriptor.cs | 3 +- .../Apache.Ignite.Core/Impl/Common/Future.cs | 3 +- .../Impl/Common/IFutureConverter.cs | 4 +- .../Impl/Common/IFutureInternal.cs | 3 +- .../Impl/Common/IgniteHome.cs | 21 +- .../Impl/Common/LoadedAssembliesResolver.cs | 2 +- .../Impl/Common/SerializableTypeDescriptor.cs | 222 ++ .../Apache.Ignite.Core/Impl/Handle/Handle.cs | 2 +- .../Impl/Handle/HandleRegistry.cs | 2 +- .../Apache.Ignite.Core/Impl/Handle/IHandle.cs | 2 +- .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 13 +- .../Impl/Memory/IPlatformMemory.cs | 5 +- .../Impl/Memory/PlatformMemory.cs | 3 +- .../Impl/Memory/PlatformMemoryManager.cs | 4 +- .../Impl/Memory/PlatformMemoryPool.cs | 3 +- .../Impl/Memory/PlatformMemoryStream.cs | 3 +- .../Impl/Memory/PlatformRawMemory.cs | 96 - .../Apache.Ignite.Core/Impl/PlatformTarget.cs | 17 +- .../Impl/Services/ServiceProxySerializer.cs | 4 +- .../Impl/Unmanaged/UnmanagedCallbacks.cs | 8 +- .../NuGet/LINQPad/ComputeExample.linq | 1 - .../NuGet/LINQPad/PutGetExample.linq | 5 +- .../NuGet/LINQPad/QueryExample.linq | 5 +- .../Plugin/IPluginConfiguration.cs | 4 +- .../Impl/DbCache.cs | 2 +- .../Apache.Ignite.Linq.csproj | 1 - .../dotnet/Apache.Ignite.Linq/CompiledQuery.cs | 112 +- .../dotnet/Apache.Ignite.Linq/CompiledQuery2.cs | 257 --- .../Impl/CacheFieldsQueryProvider.cs | 10 +- .../Impl/CacheQueryExpressionVisitor.cs | 14 +- .../Apache.Ignite.Linq/Impl/CacheQueryParser.cs | 25 +- .../Apache.Ignite.Linq/Impl/MethodVisitor.cs | 72 +- .../NuGet/LINQPad/QueryExample.linq | 5 +- .../dotnet/Apache.Ignite.Linq/QueryOptions.cs | 2 +- .../examples/Apache.Ignite.Examples/App.config | 20 +- .../Datagrid/LinqExample.cs | 2 +- .../Datagrid/MultiTieredCacheExample.cs | 4 +- .../Datagrid/PutGetExample.cs | 13 +- .../Datagrid/StoreExample.cs | 1 + .../Misc/ClientReconnectExample.cs | 38 +- .../Apache.Ignite.ExamplesDll/Binary/Address.cs | 2 - .../Compute/CharacterCountClosure.cs | 1 - .../Datagrid/ContinuousQueryFilter.cs | 2 - .../Datagrid/EmployeeStore.cs | 27 +- .../Datagrid/EmployeeStorePredicate.cs | 2 - .../Messaging/RemoteOrderedListener.cs | 1 - .../Messaging/RemoteUnorderedListener.cs | 1 - .../Services/MapService.cs | 1 - .../scalar/pimps/ScalarProjectionPimp.scala | 24 +- modules/schema-import-db/README.txt | 4 - modules/schema-import-db/pom.xml | 55 - .../apache/ignite/schema/parser/DbColumn.java | 88 - .../ignite/schema/parser/DbMetadataReader.java | 147 -- .../apache/ignite/schema/parser/DbTable.java | 82 - .../parser/dialect/DB2MetadataDialect.java | 33 - .../parser/dialect/DatabaseMetadataDialect.java | 102 - .../parser/dialect/JdbcMetadataDialect.java | 199 -- .../parser/dialect/MySQLMetadataDialect.java | 82 - .../parser/dialect/OracleMetadataDialect.java | 360 --- modules/schema-import/README.txt | 216 -- modules/schema-import/pom.xml | 119 - .../main/java/media/data_connection_48x48.png | Bin 4443 -> 0 bytes .../src/main/java/media/error_48x48.png | Bin 4349 -> 0 bytes .../src/main/java/media/ignite_128x128.png | Bin 4917 -> 0 bytes .../src/main/java/media/ignite_16x16.png | Bin 608 -> 0 bytes .../src/main/java/media/ignite_24x24.png | Bin 930 -> 0 bytes .../src/main/java/media/ignite_32x32.png | Bin 1203 -> 0 bytes .../src/main/java/media/ignite_48x48.png | Bin 1868 -> 0 bytes .../src/main/java/media/ignite_64x64.png | Bin 2453 -> 0 bytes .../src/main/java/media/information_48x48.png | Bin 4102 -> 0 bytes .../src/main/java/media/question_48x48.png | Bin 3857 -> 0 bytes .../src/main/java/media/sign_warning_48x48.png | Bin 2988 -> 0 bytes .../schema-import/src/main/java/media/style.css | 134 -- .../src/main/java/media/text_tree_48x48.png | Bin 2567 -> 0 bytes .../ignite/schema/generator/CodeGenerator.java | 831 ------- .../ignite/schema/generator/GeneratorUtils.java | 70 - .../ignite/schema/generator/XmlGenerator.java | 446 ---- .../ignite/schema/model/PojoDescriptor.java | 497 ---- .../apache/ignite/schema/model/PojoField.java | 461 ---- .../ignite/schema/model/SchemaDescriptor.java | 62 - .../schema/parser/DatabaseMetadataParser.java | 115 - .../ignite/schema/ui/ConfirmCallable.java | 83 - .../org/apache/ignite/schema/ui/Controls.java | 697 ------ .../org/apache/ignite/schema/ui/GridPaneEx.java | 180 -- .../org/apache/ignite/schema/ui/MessageBox.java | 274 --- .../apache/ignite/schema/ui/ModalDialog.java | 50 - .../ignite/schema/ui/SchemaImportApp.java | 2115 ------------------ .../ignite/schema/ui/TextColumnValidator.java | 32 - .../schema/test/AbstractSchemaImportTest.java | 181 -- .../test/generator/CodeGeneratorTest.java | 81 - .../schema/test/generator/XmlGeneratorTest.java | 42 - .../ignite/schema/test/model/CacheConfig.txt | 409 ---- .../apache/ignite/schema/test/model/Objects.txt | 531 ----- .../ignite/schema/test/model/ObjectsKey.txt | 96 - .../ignite/schema/test/model/Primitives.txt | 535 ----- .../ignite/schema/test/model/PrimitivesKey.txt | 96 - .../org/apache/ignite/schema/test/model/Tst.txt | 535 ----- .../apache/ignite/schema/test/model/TstKey.txt | 96 - .../schema/test/model/ignite-type-metadata.xml | 666 ------ .../test/parser/DbMetadataParserTest.java | 134 -- .../testsuites/IgniteSchemaImportTestSuite.java | 42 - modules/spring/pom.xml | 6 + .../apache/ignite/cache/spring/SpringCache.java | 4 +- .../ignite/cache/spring/SpringCacheTest.java | 177 ++ .../ignite/internal/GridFactorySelfTest.java | 3 + .../IgniteExcludeInConfigurationTest.java | 14 +- .../org/apache/ignite/spring/sprint-exclude.xml | 19 +- .../testsuites/IgniteSpringTestSuite.java | 3 + ...gniteProjectionStartStopRestartSelfTest.java | 6 +- .../spi/deployment/uri/UriDeploymentSpi.java | 80 +- .../commands/cache/VisorCacheCommand.scala | 21 +- .../commands/cache/VisorCacheScanCommand.scala | 2 +- .../commands/disco/VisorDiscoveryCommand.scala | 2 +- .../commands/tasks/VisorTasksCommandSpec.scala | 22 +- .../helpers/jade/form/form-field-checkbox.pug | 14 +- .../helpers/jade/form/form-field-datalist.pug | 2 +- .../helpers/jade/form/form-field-dropdown.pug | 3 +- .../app/helpers/jade/form/form-field-number.pug | 3 +- .../helpers/jade/form/form-field-password.pug | 2 +- .../app/helpers/jade/form/form-field-text.pug | 3 +- .../frontend/app/helpers/jade/mixins.pug | 1 + .../modules/configuration/Version.service.js | 2 +- .../states/configuration/clusters/general.pug | 2 +- .../clusters/general/discovery/s3.pug | 2 +- .../frontend/app/primitives/tooltip/index.pug | 25 + .../views/configuration/domains-import.tpl.pug | 6 + modules/web-console/web-agent/README.txt | 2 +- modules/web-console/web-agent/pom.xml | 12 - .../ignite/console/agent/db/DbColumn.java | 88 + .../console/agent/db/DbMetadataReader.java | 142 ++ .../apache/ignite/console/agent/db/DbTable.java | 82 + .../agent/db/dialect/DB2MetadataDialect.java | 33 + .../db/dialect/DatabaseMetadataDialect.java | 102 + .../agent/db/dialect/JdbcMetadataDialect.java | 199 ++ .../agent/db/dialect/MySQLMetadataDialect.java | 82 + .../agent/db/dialect/OracleMetadataDialect.java | 359 +++ .../agent/handlers/DatabaseListener.java | 20 +- .../config/benchmark-atomic.properties | 21 +- .../config/benchmark-cache-load.properties | 7 +- .../config/benchmark-compute.properties | 13 +- .../config/benchmark-failover.properties | 4 +- .../config/benchmark-multicast.properties | 4 +- .../config/benchmark-put-indexed-val.properties | 9 +- .../yardstick/config/benchmark-query.properties | 19 +- .../config/benchmark-remote-sample.properties | 5 +- .../config/benchmark-sample.properties | 5 +- .../config/benchmark-sql-dml.properties | 19 +- .../yardstick/config/benchmark-store.properties | 30 +- .../yardstick/config/benchmark-tx.properties | 19 +- .../test-max-int-values-offheap.properties | 5 +- .../test-max-int-values-onheap.properties | 5 +- .../config/test-max-int-values-swap.properties | 5 +- .../cache/IgniteBinaryIdentityBenchmark.java | 21 - .../IgniteLegacyBinaryIdentityGetBenchmark.java | 30 - .../IgniteLegacyBinaryIdentityPutBenchmark.java | 30 - .../cache/WaitMapExchangeFinishCallable.java | 4 +- .../dml/IgniteSqlDeleteFilteredBenchmark.java | 5 +- .../dml/IgniteSqlUpdateFilteredBenchmark.java | 5 +- .../IgniteAtomicInvokeRetryBenchmark.java | 12 +- .../failover/IgniteAtomicRetriesBenchmark.java | 12 +- .../IgniteFailoverAbstractBenchmark.java | 22 +- ...IgniteTransactionalInvokeRetryBenchmark.java | 10 +- ...IgniteTransactionalWriteInvokeBenchmark.java | 16 +- .../IgniteTransactionalWriteReadBenchmark.java | 12 +- .../IgniteCacheRandomOperationBenchmark.java | 25 +- .../zk/TcpDiscoveryZookeeperIpFinder.java | 37 +- pom.xml | 121 - 1019 files changed, 29608 insertions(+), 26275 deletions(-) ----------------------------------------------------------------------
