You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by dm...@apache.org on 2017/04/11 01:38:47 UTC
[47/50] [abbrv] ignite git commit: Merge remote-tracking branch
'remotes/origin/master' into ignite-1192
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 <dm...@gridgain.com>
Authored: Mon Apr 10 14:26:37 2017 -0700
Committer: Denis Magda <dm...@gridgain.com>
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(-)
----------------------------------------------------------------------