Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-perftest
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d4006b4b Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d4006b4b Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d4006b4b Branch: refs/heads/ignite-perftest Commit: d4006b4b86c19f4c276a399f3c9efddff665b298 Parents: 311d384 280252e Author: Alexey Goncharuk <[email protected]> Authored: Mon Nov 9 13:14:13 2015 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Mon Nov 9 13:14:13 2015 +0300 ---------------------------------------------------------------------- DEVNOTES.txt | 8 +- assembly/dependencies-fabric-lgpl.xml | 169 + assembly/dependencies-fabric.xml | 3 + assembly/dependencies-hadoop.xml | 1 + assembly/release-fabric-base.xml | 107 + assembly/release-fabric-lgpl.xml | 50 + assembly/release-fabric.xml | 85 +- config/fabric-lgpl/default-config.xml | 29 + examples/README-LGPL.txt | 33 + examples/README.txt | 21 +- .../hibernate/example-hibernate-L2-cache.xml | 30 +- examples/pom-standalone-lgpl.xml | 217 + examples/pom-standalone.xml | 168 +- examples/pom.xml | 153 +- .../hibernate/HibernateL2CacheExample.java | 245 + .../examples/datagrid/hibernate/Post.java | 130 + .../examples/datagrid/hibernate/User.java | 154 + .../datagrid/hibernate/package-info.java | 22 + .../hibernate/CacheHibernatePersonStore.java | 122 + .../hibernate/CacheHibernateStoreExample.java | 151 + .../datagrid/store/hibernate/Person.hbm.xml | 34 + .../datagrid/store/hibernate/hibernate.cfg.xml | 41 + .../datagrid/store/hibernate/package-info.java | 22 + .../misc/schedule/ComputeScheduleExample.java | 82 + .../examples/misc/schedule/package-info.java | 22 + .../hibernate/HibernateL2CacheExample.java | 245 - .../examples/datagrid/hibernate/Post.java | 130 - .../examples/datagrid/hibernate/User.java | 154 - .../datagrid/hibernate/package-info.java | 22 - .../hibernate/CacheHibernatePersonStore.java | 122 - .../hibernate/CacheHibernateStoreExample.java | 151 - .../datagrid/store/hibernate/Person.hbm.xml | 34 - .../datagrid/store/hibernate/hibernate.cfg.xml | 41 - .../datagrid/store/hibernate/package-info.java | 22 - .../misc/schedule/ComputeScheduleExample.java | 82 - .../examples/misc/schedule/package-info.java | 22 - .../java8/messaging/MessagingExample.java | 7 +- .../misc/schedule/ComputeScheduleExample.java | 68 - .../java8/misc/schedule/package-info.java | 22 - .../scalar/examples/ScalarScheduleExample.scala | 66 - ...ibernateL2CacheExampleMultiNodeSelfTest.java | 31 + .../HibernateL2CacheExampleSelfTest.java | 33 + .../IgniteLgplExamplesSelfTestSuite.java | 48 + ...ibernateL2CacheExampleMultiNodeSelfTest.java | 31 - .../HibernateL2CacheExampleSelfTest.java | 33 - .../testsuites/IgniteExamplesSelfTestSuite.java | 4 - ...ibernateL2CacheExampleMultiNodeSelfTest.java | 29 - .../HibernateL2CacheExampleSelfTest.java | 37 - .../tests/examples/ScalarExamplesSelfTest.scala | 5 - modules/apache-license-gen/pom.xml | 3 + .../ClientAbstractMultiThreadedSelfTest.java | 3 +- .../rest/AbstractRestProcessorSelfTest.java | 5 +- .../JettyRestProcessorAbstractSelfTest.java | 146 +- .../src/main/java/org/apache/ignite/Ignite.java | 12 +- .../apache/ignite/IgniteSystemProperties.java | 12 + .../affinity/fair/FairAffinityFunction.java | 497 +- .../rendezvous/RendezvousAffinityFunction.java | 140 +- .../configuration/CacheConfiguration.java | 82 +- .../configuration/ConnectorConfiguration.java | 61 +- .../configuration/IgniteConfiguration.java | 32 +- .../configuration/TransactionConfiguration.java | 6 +- .../internal/GridEventConsumeHandler.java | 19 +- .../apache/ignite/internal/IgniteKernal.java | 137 +- .../ignite/internal/IgniteNodeAttributes.java | 3 + .../org/apache/ignite/internal/IgnitionEx.java | 3 + .../communication/GridIoMessageFactory.java | 10 +- .../deployment/GridDeploymentLocalStore.java | 8 +- .../GridDeploymentPerLoaderStore.java | 8 +- .../GridDeploymentPerVersionStore.java | 8 +- .../discovery/GridDiscoveryManager.java | 5 +- .../internal/portable/PortableContext.java | 103 +- .../internal/portable/PortableWriterExImpl.java | 66 +- .../portable/api/PortableMarshaller.java | 5 + .../affinity/GridAffinityAssignmentCache.java | 13 + .../processors/cache/CacheMetricsImpl.java | 12 +- .../processors/cache/CacheObjectContext.java | 17 +- .../processors/cache/GridCacheAdapter.java | 816 ++-- .../cache/GridCacheAffinityManager.java | 28 +- .../cache/GridCacheClearAllRunnable.java | 18 +- .../cache/GridCacheConcurrentMap.java | 4 +- .../processors/cache/GridCacheContext.java | 10 +- .../processors/cache/GridCacheEntryEx.java | 62 +- .../cache/GridCacheEvictionManager.java | 5 +- .../cache/GridCacheEvictionRequest.java | 18 +- .../cache/GridCacheEvictionResponse.java | 7 +- .../processors/cache/GridCacheIoManager.java | 81 +- .../processors/cache/GridCacheMapEntry.java | 175 +- .../processors/cache/GridCacheMessage.java | 72 +- .../processors/cache/GridCacheMvcc.java | 143 +- .../cache/GridCacheMvccCandidate.java | 26 +- .../GridCachePartitionExchangeManager.java | 188 +- .../processors/cache/GridCachePreloader.java | 60 +- .../cache/GridCachePreloaderAdapter.java | 45 +- .../processors/cache/GridCacheProcessor.java | 177 +- .../processors/cache/GridCacheProxyImpl.java | 14 +- .../cache/GridCacheSharedContext.java | 3 + .../processors/cache/GridCacheUtils.java | 70 +- .../processors/cache/IgniteCacheProxy.java | 2 +- .../processors/cache/IgniteInternalCache.java | 19 +- .../distributed/GridCacheTtlUpdateRequest.java | 7 +- .../distributed/GridCacheTxRecoveryFuture.java | 22 +- .../distributed/GridCacheTxRecoveryRequest.java | 8 +- .../GridCacheTxRecoveryResponse.java | 10 +- .../distributed/GridDistributedBaseMessage.java | 16 +- .../distributed/GridDistributedCacheEntry.java | 12 +- .../distributed/GridDistributedLockRequest.java | 8 +- .../GridDistributedLockResponse.java | 20 +- .../GridDistributedTxFinishRequest.java | 6 +- .../GridDistributedTxFinishResponse.java | 7 +- .../GridDistributedTxPrepareRequest.java | 13 +- .../GridDistributedTxPrepareResponse.java | 12 +- .../GridDistributedTxRemoteAdapter.java | 61 +- .../GridDistributedUnlockRequest.java | 7 +- .../dht/CacheDistributedGetFutureAdapter.java | 158 + .../dht/GridDhtAffinityAssignmentRequest.java | 7 +- .../dht/GridDhtAffinityAssignmentResponse.java | 7 +- .../distributed/dht/GridDhtCacheAdapter.java | 26 +- .../distributed/dht/GridDhtCacheEntry.java | 34 +- .../cache/distributed/dht/GridDhtGetFuture.java | 199 +- .../distributed/dht/GridDhtLocalPartition.java | 71 +- .../distributed/dht/GridDhtLockFuture.java | 10 +- .../distributed/dht/GridDhtLockRequest.java | 7 +- .../distributed/dht/GridDhtLockResponse.java | 14 +- .../dht/GridDhtPartitionsReservation.java | 2 +- .../dht/GridDhtTransactionalCacheAdapter.java | 127 +- .../distributed/dht/GridDhtTxFinishFuture.java | 9 +- .../distributed/dht/GridDhtTxFinishRequest.java | 7 +- .../dht/GridDhtTxFinishResponse.java | 2 +- .../cache/distributed/dht/GridDhtTxLocal.java | 4 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 160 +- .../dht/GridDhtTxPrepareRequest.java | 28 +- .../dht/GridDhtTxPrepareResponse.java | 13 +- .../distributed/dht/GridDhtUnlockRequest.java | 7 +- .../dht/GridPartitionedGetFuture.java | 182 +- .../dht/atomic/GridDhtAtomicCache.java | 28 +- .../GridDhtAtomicDeferredUpdateResponse.java | 12 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 6 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 25 +- .../dht/atomic/GridDhtAtomicUpdateResponse.java | 11 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 12 +- .../dht/atomic/GridNearAtomicUpdateRequest.java | 33 +- .../atomic/GridNearAtomicUpdateResponse.java | 11 +- .../dht/colocated/GridDhtColocatedCache.java | 138 +- .../colocated/GridDhtColocatedLockFuture.java | 9 +- .../dht/preloader/GridDhtForceKeysFuture.java | 19 +- .../dht/preloader/GridDhtForceKeysRequest.java | 35 +- .../dht/preloader/GridDhtForceKeysResponse.java | 11 +- .../GridDhtPartitionDemandMessage.java | 19 +- .../preloader/GridDhtPartitionDemandPool.java | 1192 ----- .../dht/preloader/GridDhtPartitionDemander.java | 1389 ++++++ .../dht/preloader/GridDhtPartitionSupplier.java | 1034 +++++ .../GridDhtPartitionSupplyMessage.java | 9 +- .../GridDhtPartitionSupplyMessageV2.java | 380 ++ .../preloader/GridDhtPartitionSupplyPool.java | 555 --- .../GridDhtPartitionsAbstractMessage.java | 7 +- .../GridDhtPartitionsExchangeFuture.java | 8 + .../dht/preloader/GridDhtPreloader.java | 306 +- .../distributed/near/GridNearAtomicCache.java | 2 - .../distributed/near/GridNearCacheAdapter.java | 53 +- .../near/GridNearCacheClearAllRunnable.java | 9 +- .../distributed/near/GridNearCacheEntry.java | 81 +- .../distributed/near/GridNearGetFuture.java | 345 +- .../distributed/near/GridNearGetRequest.java | 15 +- .../distributed/near/GridNearGetResponse.java | 12 +- .../distributed/near/GridNearLockFuture.java | 3 +- .../distributed/near/GridNearLockRequest.java | 8 +- .../distributed/near/GridNearLockResponse.java | 8 +- ...arOptimisticSerializableTxPrepareFuture.java | 936 ++++ .../near/GridNearOptimisticTxPrepareFuture.java | 255 +- ...ridNearOptimisticTxPrepareFutureAdapter.java | 222 + .../GridNearPessimisticTxPrepareFuture.java | 11 +- .../near/GridNearTransactionalCache.java | 22 +- .../near/GridNearTxFinishFuture.java | 20 +- .../near/GridNearTxFinishRequest.java | 7 +- .../near/GridNearTxFinishResponse.java | 2 +- .../cache/distributed/near/GridNearTxLocal.java | 157 +- .../near/GridNearTxPrepareFutureAdapter.java | 13 +- .../near/GridNearTxPrepareRequest.java | 8 +- .../near/GridNearTxPrepareResponse.java | 8 +- .../distributed/near/GridNearUnlockRequest.java | 7 +- .../cache/local/GridLocalCacheEntry.java | 23 +- .../cache/local/GridLocalLockFuture.java | 2 + .../local/atomic/GridLocalAtomicCache.java | 9 - .../portable/CacheObjectPortableContext.java | 6 +- .../CacheObjectPortableProcessorImpl.java | 14 +- .../query/GridCacheDistributedQueryFuture.java | 5 +- .../query/GridCacheDistributedQueryManager.java | 25 +- .../cache/query/GridCacheQueryRequest.java | 46 +- .../cache/query/GridCacheQueryResponse.java | 29 +- .../continuous/CacheContinuousQueryHandler.java | 8 +- .../continuous/CacheContinuousQueryManager.java | 6 +- .../cache/transactions/IgniteInternalTx.java | 8 +- .../transactions/IgniteTransactionsImpl.java | 6 - .../cache/transactions/IgniteTxAdapter.java | 128 +- .../cache/transactions/IgniteTxEntry.java | 59 +- .../cache/transactions/IgniteTxHandler.java | 20 +- .../transactions/IgniteTxLocalAdapter.java | 843 ++-- .../cache/transactions/IgniteTxLocalEx.java | 27 +- .../cache/transactions/IgniteTxManager.java | 331 +- .../cache/version/GridCacheVersionManager.java | 73 +- .../IgniteCacheObjectProcessorImpl.java | 7 +- .../datastreamer/DataStreamerImpl.java | 2 +- .../datastructures/DataStructuresProcessor.java | 3 + .../processors/igfs/IgfsDataManager.java | 2 - .../processors/igfs/IgfsDeleteWorker.java | 102 +- .../internal/processors/igfs/IgfsImpl.java | 164 +- .../processors/igfs/IgfsMetaManager.java | 901 ++-- .../processors/igfs/IgfsOutputStreamImpl.java | 2 + .../internal/processors/igfs/IgfsUtils.java | 23 + .../processors/job/GridJobProcessor.java | 96 +- .../handlers/cache/GridCacheCommandHandler.java | 128 +- .../handlers/query/QueryCommandHandler.java | 258 +- .../top/GridTopologyCommandHandler.java | 4 - .../service/GridServiceProcessor.java | 31 +- .../processors/task/GridTaskWorker.java | 4 +- .../ignite/internal/util/lang/GridFunc.java | 8 +- .../ignite/internal/util/lang/GridTuple4.java | 2 +- .../util/nio/GridNioRecoveryDescriptor.java | 11 +- .../ignite/internal/util/nio/GridNioServer.java | 2 +- .../ignite/internal/visor/cache/VisorCache.java | 5 +- .../ignite/marshaller/AbstractMarshaller.java | 12 +- .../ignite/marshaller/jdk/JdkMarshaller.java | 7 +- .../optimized/OptimizedMarshaller.java | 14 +- .../optimized/OptimizedMarshallerUtils.java | 35 +- .../communication/tcp/TcpCommunicationSpi.java | 40 +- .../ignite/spi/deployment/DeploymentSpi.java | 8 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 205 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 272 +- .../spi/discovery/tcp/TcpDiscoverySpi.java | 2 +- .../messages/TcpDiscoveryAbstractMessage.java | 11 + .../TcpDiscoveryClientReconnectMessage.java | 1 + .../messages/TcpDiscoveryDiscardMessage.java | 1 + .../messages/TcpDiscoveryNodeAddedMessage.java | 39 + .../apache/ignite/transactions/Transaction.java | 2 +- .../transactions/TransactionIsolation.java | 3 +- modules/core/src/test/config/tests.properties | 3 + .../AbstractAffinityFunctionSelfTest.java | 293 ++ .../affinity/AffinityClientNodeSelfTest.java | 194 + ...ityFunctionBackupFilterAbstractSelfTest.java | 138 + ...unctionExcludeNeighborsAbstractSelfTest.java | 182 + .../affinity/IgniteClientNodeAffinityTest.java | 194 - .../fair/FairAffinityDynamicCacheSelfTest.java | 99 + ...airAffinityFunctionBackupFilterSelfTest.java | 35 + ...ffinityFunctionExcludeNeighborsSelfTest.java | 31 + .../fair/FairAffinityFunctionNodesSelfTest.java | 245 + .../fair/FairAffinityFunctionSelfTest.java | 31 + .../GridFairAffinityFunctionNodesSelfTest.java | 245 - .../fair/GridFairAffinityFunctionSelfTest.java | 270 -- .../IgniteFairAffinityDynamicCacheSelfTest.java | 97 - ...ousAffinityFunctionBackupFilterSelfTest.java | 35 + ...ffinityFunctionExcludeNeighborsSelfTest.java | 32 + .../RendezvousAffinityFunctionSelfTest.java | 50 + .../ignite/igfs/IgfsEventsAbstractSelfTest.java | 6 +- .../GridTaskFailoverAffinityRunTest.java | 3 + .../IgniteClientReconnectCacheTest.java | 33 + .../GridDiscoveryManagerAttributesSelfTest.java | 51 +- .../cache/CacheAffinityCallSelfTest.java | 4 +- .../processors/cache/CacheNamesSelfTest.java | 69 + .../cache/CacheNearReaderUpdateTest.java | 390 ++ .../CacheSerializableTransactionsTest.java | 4392 ++++++++++++++++++ .../cache/CrossCacheTxRandomOperationsTest.java | 10 +- .../GridCacheAbstractFailoverSelfTest.java | 14 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 9 +- .../GridCacheAbstractLocalStoreSelfTest.java | 5 + .../GridCacheAbstractRemoveFailureTest.java | 98 +- ...eAtomicEntryProcessorDeploymentSelfTest.java | 211 + .../cache/GridCacheClearSelfTest.java | 308 ++ .../GridCacheConcurrentTxMultiNodeTest.java | 3 - .../GridCacheConditionalDeploymentSelfTest.java | 190 + ...idCacheConfigurationConsistencySelfTest.java | 17 - .../GridCacheDeploymentOffHeapSelfTest.java | 17 +- .../cache/GridCacheDeploymentSelfTest.java | 26 +- .../cache/GridCacheMvccFlagsTest.java | 6 +- .../cache/GridCacheMvccPartitionedSelfTest.java | 164 + .../processors/cache/GridCacheMvccSelfTest.java | 3 +- .../processors/cache/GridCacheTestEntryEx.java | 53 +- ...ctionalEntryProcessorDeploymentSelfTest.java | 31 + .../cache/IgniteCacheCreateRestartSelfTest.java | 4 +- .../IgniteCacheEntryListenerAbstractTest.java | 50 +- .../IgniteCacheP2pUnmarshallingErrorTest.java | 2 +- .../cache/IgniteCachePutAllRestartTest.java | 3 + .../cache/IgniteCacheTxNearPeekModesTest.java | 7 +- .../cache/IgniteCacheTxPeekModesTest.java | 5 + .../processors/cache/IgniteTxAbstractTest.java | 42 +- .../IgniteTxMultiThreadedAbstractTest.java | 106 +- .../IgniteCountDownLatchAbstractSelfTest.java | 4 +- ...PartitionedQueueCreateMultiNodeSelfTest.java | 5 +- ...IgnitePartitionedCountDownLatchSelfTest.java | 7 +- .../CacheAbstractRestartSelfTest.java | 247 + .../CacheGetFutureHangsSelfTest.java | 11 +- ...NearDisabledAtomicInvokeRestartSelfTest.java | 179 + ...abledTransactionalInvokeRestartSelfTest.java | 173 + ...edTransactionalWriteReadRestartSelfTest.java | 124 + ...dCachePartitionedAffinityFilterSelfTest.java | 143 - ...onedNearDisabledTxMultiThreadedSelfTest.java | 31 + ...niteCacheClientNodeChangingTopologyTest.java | 180 +- .../IgniteCacheClientReconnectTest.java | 2 + .../distributed/IgniteCacheManyClientsTest.java | 14 +- .../dht/GridCacheDhtEntrySelfTest.java | 2 +- .../dht/GridCacheDhtPreloadPutGetSelfTest.java | 3 + .../dht/GridCacheTxNodeFailureSelfTest.java | 23 +- ...gniteAtomicLongChangingTopologySelfTest.java | 4 +- .../IgniteCacheCrossCacheTxFailoverTest.java | 23 +- .../dht/IgniteCacheLockFailoverSelfTest.java | 11 + .../IgniteCachePutRetryAbstractSelfTest.java | 4 +- ...eAtomicInvalidPartitionHandlingSelfTest.java | 6 +- ...unctionExcludeNeighborsAbstractSelfTest.java | 184 - ...omicMultiNodeP2PDisabledFullApiSelfTest.java | 7 +- ...ledFairAffinityMultiNodeFullApiSelfTest.java | 3 +- ...omicNearEnabledMultiNodeFullApiSelfTest.java | 2 +- ...icOffHeapTieredMultiNodeFullApiSelfTest.java | 2 +- .../near/GridCacheNearTxExceptionSelfTest.java | 16 + ...CachePartitionedTxMultiThreadedSelfTest.java | 15 +- ...ffinityFunctionExcludeNeighborsSelfTest.java | 32 - .../GridCacheRebalancingAsyncSelfTest.java | 68 + .../GridCacheRebalancingSyncSelfTest.java | 506 ++ ...eRebalancingUnmarshallingFailedSelfTest.java | 147 + ...xcludeNeighborsMultiNodeFullApiSelfTest.java | 36 + ...tedFairAffinityMultiNodeFullApiSelfTest.java | 35 + ...xcludeNeighborsMultiNodeFullApiSelfTest.java | 36 + ...dezvousAffinityMultiNodeFullApiSelfTest.java | 36 + .../replicated/GridReplicatedTxPreloadTest.java | 7 +- .../GridCacheReplicatedPreloadSelfTest.java | 22 +- .../DataStreamerUpdateAfterLoadTest.java | 184 + .../processors/igfs/IgfsAbstractSelfTest.java | 639 ++- .../igfs/IgfsDataManagerSelfTest.java | 13 +- .../igfs/IgfsMetaManagerSelfTest.java | 170 +- .../processors/igfs/IgfsProcessorSelfTest.java | 12 +- .../GridServiceProcessorStopSelfTest.java | 103 + .../nio/IgniteExceptionInNioWorkerSelfTest.java | 105 + .../loadtests/hashmap/GridHashMapLoadTest.java | 6 +- .../communication/GridCacheMessageSelfTest.java | 17 +- ...gniteClientReconnectMassiveShutdownTest.java | 329 ++ .../tcp/TcpClientDiscoverySpiSelfTest.java | 4 +- .../tcp/TcpDiscoveryMultiThreadedTest.java | 288 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 17 - .../spi/discovery/tcp/TestTcpDiscoverySpi.java | 46 + .../inmemory/GridTestSwapSpaceSpi.java | 8 + .../ignite/testframework/GridTestUtils.java | 23 +- .../testframework/junits/GridAbstractTest.java | 3 +- .../ignite/testframework/junits/IgniteMock.java | 5 + .../junits/common/GridCommonAbstractTest.java | 40 +- .../junits/multijvm/IgniteProcessProxy.java | 7 +- .../ignite/testsuites/IgniteBasicTestSuite.java | 7 +- .../IgniteCacheFullApiSelfTestSuite.java | 16 +- .../IgniteCacheLoadConsistencyTestSuite.java | 42 + .../ignite/testsuites/IgniteCacheTestSuite.java | 40 +- .../testsuites/IgniteCacheTestSuite2.java | 14 +- .../testsuites/IgniteCacheTestSuite3.java | 14 +- .../testsuites/IgniteCacheTestSuite5.java | 40 + .../ignite/testsuites/IgniteIgfsTestSuite.java | 6 + .../testsuites/IgniteKernalSelfTestSuite.java | 2 + .../testsuites/IgniteP2PSelfTestSuite.java | 16 +- .../p2p/CacheDeploymentEntryProcessor.java | 35 + .../CacheDeploymentPortableEntryProcessor.java | 35 + modules/extdata/uri/pom.xml | 14 +- .../hadoop/igfs/HadoopIgfsWrapper.java | 54 +- .../ignite/igfs/Hadoop1DualAbstractTest.java | 5 - .../HadoopIgfs20FileSystemAbstractSelfTest.java | 27 +- .../IgniteHadoopFileSystemAbstractSelfTest.java | 2 +- .../CacheHibernateBlobStoreSelfTest.java | 6 +- .../processors/query/h2/IgniteH2Indexing.java | 2 +- .../cache/IgniteCacheAbstractQuerySelfTest.java | 4 + ...niteCacheP2pUnmarshallingQueryErrorTest.java | 32 +- .../cache/SqlFieldsQuerySelfTest.java | 170 + .../tcp/GridOrderedMessageCancelSelfTest.java | 18 +- .../IgniteCacheQuerySelfTestSuite.java | 2 + modules/jms11/pom.xml | 9 +- .../stream/jms11/IgniteJmsStreamerTest.java | 9 +- .../ignite/logger/log4j2/Log4J2Logger.java~ | 542 --- .../ignite/logger/log4j2/Log4j2FileAware.java~ | 33 - .../ignite/logger/log4j2/Log4jFileAware.java~ | 13 - .../apache/ignite/stream/mqtt/MqttStreamer.java | 386 +- .../stream/mqtt/IgniteMqttStreamerTest.java | 142 +- .../mqtt/IgniteMqttStreamerTestSuite.java | 4 +- .../main/cpp/common/project/vs/common.vcxproj | 4 +- modules/rest-http/pom.xml | 6 + .../http/jetty/GridJettyRestHandler.java | 2 +- .../http/jetty/GridJettyRestProtocol.java | 4 +- modules/spark-2.10/pom.xml | 4 +- modules/spark/pom.xml | 4 +- .../scala/org/apache/ignite/spark/Entity.scala | 2 +- .../org/apache/ignite/spark/IgniteRDDSpec.scala | 249 + .../org/apache/ignite/spark/IgniteRddSpec.scala | 249 - .../org/apache/ignite/IgniteSpringBean.java | 10 +- modules/ssh/pom.xml | 2 +- .../spi/deployment/uri/UriDeploymentSpi.java | 93 +- .../scanners/http/UriDeploymentHttpScanner.java | 10 +- .../http/GridHttpDeploymentSelfTest.java | 132 +- .../visor/commands/open/VisorOpenCommand.scala | 14 +- .../config/benchmark-client-mode.properties | 4 +- .../config/benchmark-failover.properties | 107 + .../config/benchmark-multicast.properties | 68 +- .../yardstick/config/benchmark-store.properties | 4 +- modules/yardstick/config/benchmark.properties | 4 +- .../config/ignite-failover-base-config.xml | 126 + .../config/ignite-failover-localhost-config.xml | 56 + modules/yardstick/pom.xml | 3 +- .../yardstick/IgniteAbstractBenchmark.java | 2 +- .../yardstick/IgniteBenchmarkArguments.java | 69 +- .../IgniteAccountSerializableTxBenchmark.java | 81 + .../cache/IgniteAccountTxAbstractBenchmark.java | 61 + .../cache/IgniteAccountTxBenchmark.java | 74 + .../cache/IgniteCacheAbstractBenchmark.java | 76 +- .../yardstick/cache/IgniteGetBenchmark.java | 4 +- .../cache/IgniteJdbcSqlQueryBenchmark.java | 4 +- .../yardstick/cache/IgnitePutAllBenchmark.java | 4 +- .../IgnitePutAllSerializableTxBenchmark.java | 77 + .../cache/IgnitePutAllTxBenchmark.java | 10 +- .../yardstick/cache/IgnitePutBenchmark.java | 4 +- .../yardstick/cache/IgnitePutGetBenchmark.java | 4 +- .../cache/IgnitePutGetTxBenchmark.java | 4 +- .../cache/IgnitePutIndexedValue1Benchmark.java | 4 +- .../cache/IgnitePutIndexedValue2Benchmark.java | 4 +- .../cache/IgnitePutIndexedValue8Benchmark.java | 4 +- .../yardstick/cache/IgnitePutTxBenchmark.java | 4 +- .../cache/IgniteSqlQueryBenchmark.java | 4 +- .../cache/IgniteSqlQueryJoinBenchmark.java | 4 +- .../cache/IgniteSqlQueryPutBenchmark.java | 4 +- .../IgniteAtomicInvokeRetryBenchmark.java | 214 + ...IgniteAtomicOffHeapInvokeRetryBenchmark.java | 31 + .../IgniteAtomicOffHeapRetriesBenchmark.java | 31 + .../failover/IgniteAtomicRetriesBenchmark.java | 89 + .../IgniteFailoverAbstractBenchmark.java | 320 ++ .../cache/failover/IgniteFailoverNode.java | 60 + ...IgniteTransactionalInvokeRetryBenchmark.java | 212 + ...ransactionalOffHeapInvokeRetryBenchmark.java | 33 + ...ransactionalOffHeapWriteInvokeBenchmark.java | 37 + ...eTransactionalOffHeapWriteReadBenchmark.java | 32 + ...IgniteTransactionalWriteInvokeBenchmark.java | 182 + .../IgniteTransactionalWriteReadBenchmark.java | 141 + .../ignite/yardstick/cache/model/Account.java | 42 + .../ipfinder/zk/ZookeeperIpFinderTestSuite.java | 32 + parent/pom.xml | 1 + pom.xml | 19 +- 435 files changed, 27181 insertions(+), 10378 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d4006b4b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMapEntry.java ----------------------------------------------------------------------
