Merge branch 'ignite-1.5'
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0db011d4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0db011d4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0db011d4 Branch: refs/heads/ignite-2265 Commit: 0db011d4a8ad9ecaa7bfa2bc1c603077ed4a36d1 Parents: 49a0e6d 1dbf20e Author: ashutak <ashu...@gridgain.com> Authored: Fri Dec 11 12:45:21 2015 +0300 Committer: ashutak <ashu...@gridgain.com> Committed: Fri Dec 11 12:45:21 2015 +0300 ---------------------------------------------------------------------- assembly/docfiles/ignite_logo.png | Bin 0 -> 24315 bytes assembly/release-fabric-base.xml | 25 +- bin/ignite.bat | 7 +- bin/include/parseargs.bat | 4 +- .../java/org/apache/ignite/schema/Demo.java | 6 +- ...ComputeClientBinaryTaskExecutionExample.java | 4 +- .../CacheClientBinaryPutGetExample.java | 2 +- .../datagrid/CacheClientBinaryQueryExample.java | 8 +- .../store/auto/CacheBinaryAutoStoreExample.java | 38 +- .../examples/datagrid/CacheQueryExample.java | 6 + .../datagrid/CacheTransactionExample.java | 4 +- .../store/auto/CacheAutoStoreExample.java | 81 +- .../messaging/MessagingPingPongExample.java | 4 - .../ignite/examples/model/Organization.java | 16 +- .../apache/ignite/examples/model/Person.java | 40 +- .../ignite/examples/util/DbH2ServerStartup.java | 31 +- .../examples/MessagingExamplesSelfTest.java | 2 - .../ignite/codegen/MessageCodeGenerator.java | 6 +- modules/core/pom.xml | 4 +- .../java/org/apache/ignite/IgniteBinary.java | 2 +- .../java/org/apache/ignite/IgniteCache.java | 2 +- .../main/java/org/apache/ignite/Ignition.java | 18 +- .../ignite/binary/BinaryCollectionFactory.java | 33 + .../apache/ignite/binary/BinaryMapFactory.java | 33 + .../apache/ignite/binary/BinaryRawReader.java | 8 +- .../org/apache/ignite/binary/BinaryReader.java | 9 +- .../store/jdbc/CacheAbstractJdbcStore.java | 5 +- .../cache/store/jdbc/CacheJdbcPojoStore.java | 2 +- .../configuration/CacheConfiguration.java | 5 +- .../configuration/IgniteConfiguration.java | 4 +- .../configuration/TransactionConfiguration.java | 47 +- .../apache/ignite/internal/GridComponent.java | 3 +- .../ignite/internal/GridKernalContextImpl.java | 2 +- .../ignite/internal/GridPluginComponent.java | 4 +- .../apache/ignite/internal/IgniteKernal.java | 26 +- .../org/apache/ignite/internal/IgnitionEx.java | 65 +- .../ignite/internal/MarshallerContextImpl.java | 23 +- .../binary/BinaryCachingMetadataHandler.java | 70 + .../ignite/internal/binary/BinaryEnumCache.java | 69 + .../internal/binary/BinaryEnumObjectImpl.java | 311 ++ .../internal/binary/BinaryFieldAccessor.java | 856 ++++ .../ignite/internal/binary/BinaryFieldImpl.java | 116 + .../internal/binary/BinaryInternalIdMapper.java | 161 + .../internal/binary/BinaryMarshaller.java | 142 + .../ignite/internal/binary/BinaryMetadata.java | 180 + .../binary/BinaryMetadataCollector.java | 277 ++ .../internal/binary/BinaryMetadataHandler.java | 44 + .../binary/BinaryNoopMetadataHandler.java | 53 + .../ignite/internal/binary/BinaryObjectEx.java | 30 + .../internal/binary/BinaryObjectExImpl.java | 251 ++ .../internal/binary/BinaryObjectImpl.java | 570 +++ .../binary/BinaryObjectOffheapImpl.java | 430 ++ .../internal/binary/BinaryRawReaderEx.java | 33 + .../internal/binary/BinaryRawWriterEx.java | 60 + .../internal/binary/BinaryReaderExImpl.java | 2028 +++++++++ .../internal/binary/BinaryReaderHandles.java | 108 + .../binary/BinaryReaderHandlesHolder.java | 46 + .../binary/BinaryReaderHandlesHolderImpl.java | 44 + .../binary/BinaryThreadLocalContext.java | 70 + .../ignite/internal/binary/BinaryTypeImpl.java | 93 + .../ignite/internal/binary/BinaryWriteMode.java | 178 + .../internal/binary/BinaryWriterExImpl.java | 1808 ++++++++ .../internal/binary/BinaryWriterHandles.java | 101 + .../binary/BinaryWriterSchemaHolder.java | 149 + .../internal/binary/GridPortableMarshaller.java | 289 ++ .../binary/PortableClassDescriptor.java | 813 ++++ .../ignite/internal/binary/PortableContext.java | 1102 +++++ .../binary/PortablePositionReadable.java | 47 + .../internal/binary/PortablePrimitives.java | 382 ++ .../ignite/internal/binary/PortableSchema.java | 466 ++ .../internal/binary/PortableSchemaRegistry.java | 172 + .../ignite/internal/binary/PortableUtils.java | 1909 ++++++++ .../binary/builder/BinaryObjectBuilderImpl.java | 587 +++ .../builder/PortableAbstractLazyValue.java | 57 + .../binary/builder/PortableBuilderEnum.java | 116 + .../binary/builder/PortableBuilderReader.java | 856 ++++ .../PortableBuilderSerializationAware.java | 31 + .../builder/PortableBuilderSerializer.java | 217 + .../builder/PortableEnumArrayLazyValue.java | 116 + .../binary/builder/PortableLazyArrayList.java | 167 + .../binary/builder/PortableLazyLinkedList.java | 218 + .../binary/builder/PortableLazyMap.java | 221 + .../binary/builder/PortableLazySet.java | 94 + .../binary/builder/PortableLazyValue.java | 28 + .../builder/PortableModifiableLazyValue.java | 52 + .../builder/PortableObjectArrayLazyValue.java | 91 + .../binary/builder/PortablePlainLazyValue.java | 49 + .../builder/PortablePlainPortableObject.java | 56 + .../binary/builder/PortableValueWithType.java | 77 + .../internal/binary/builder/package-info.java | 22 + .../ignite/internal/binary/package-info.java | 22 + .../streams/PortableAbstractInputStream.java | 379 ++ .../streams/PortableAbstractOutputStream.java | 347 ++ .../binary/streams/PortableAbstractStream.java | 80 + .../binary/streams/PortableHeapInputStream.java | 166 + .../streams/PortableHeapOutputStream.java | 176 + .../binary/streams/PortableInputStream.java | 163 + .../binary/streams/PortableMemoryAllocator.java | 57 + .../streams/PortableMemoryAllocatorChunk.java | 117 + .../streams/PortableOffheapInputStream.java | 144 + .../streams/PortableOffheapOutputStream.java | 222 + .../binary/streams/PortableOutputStream.java | 259 ++ .../internal/binary/streams/PortableStream.java | 53 + .../internal/binary/streams/package-info.java | 22 + .../internal/managers/GridManagerAdapter.java | 5 +- .../managers/communication/GridIoManager.java | 3 +- .../communication/GridIoMessageFactory.java | 12 +- .../deployment/GridDeploymentManager.java | 5 +- .../portable/BinaryCachingMetadataHandler.java | 70 - .../internal/portable/BinaryEnumCache.java | 69 - .../internal/portable/BinaryEnumObjectImpl.java | 311 -- .../internal/portable/BinaryFieldAccessor.java | 866 ---- .../internal/portable/BinaryFieldImpl.java | 116 - .../portable/BinaryInternalIdMapper.java | 161 - .../internal/portable/BinaryMarshaller.java | 142 - .../internal/portable/BinaryMetadata.java | 180 - .../portable/BinaryMetadataCollector.java | 277 -- .../portable/BinaryMetadataHandler.java | 44 - .../portable/BinaryNoopMetadataHandler.java | 53 - .../internal/portable/BinaryObjectEx.java | 30 - .../internal/portable/BinaryObjectExImpl.java | 251 -- .../internal/portable/BinaryObjectImpl.java | 580 --- .../portable/BinaryObjectOffheapImpl.java | 429 -- .../internal/portable/BinaryRawReaderEx.java | 33 - .../internal/portable/BinaryRawWriterEx.java | 60 - .../internal/portable/BinaryReaderExImpl.java | 2020 --------- .../internal/portable/BinaryReaderHandles.java | 108 - .../portable/BinaryReaderHandlesHolder.java | 46 - .../portable/BinaryReaderHandlesHolderImpl.java | 44 - .../portable/BinaryThreadLocalContext.java | 69 - .../internal/portable/BinaryTypeImpl.java | 93 - .../internal/portable/BinaryWriteMode.java | 181 - .../internal/portable/BinaryWriterExImpl.java | 1833 -------- .../internal/portable/BinaryWriterHandles.java | 101 - .../portable/BinaryWriterSchemaHolder.java | 148 - .../portable/GridPortableMarshaller.java | 307 -- .../portable/PortableClassDescriptor.java | 814 ---- .../internal/portable/PortableContext.java | 1112 ----- .../portable/PortablePositionReadable.java | 47 - .../internal/portable/PortablePrimitives.java | 382 -- .../internal/portable/PortableSchema.java | 466 -- .../portable/PortableSchemaRegistry.java | 172 - .../ignite/internal/portable/PortableUtils.java | 1979 -------- .../builder/BinaryObjectBuilderImpl.java | 580 --- .../builder/PortableAbstractLazyValue.java | 57 - .../portable/builder/PortableBuilderEnum.java | 116 - .../portable/builder/PortableBuilderReader.java | 859 ---- .../PortableBuilderSerializationAware.java | 31 - .../builder/PortableBuilderSerializer.java | 222 - .../builder/PortableEnumArrayLazyValue.java | 114 - .../portable/builder/PortableLazyArrayList.java | 166 - .../builder/PortableLazyLinkedList.java | 217 - .../portable/builder/PortableLazyMap.java | 220 - .../portable/builder/PortableLazyMapEntry.java | 68 - .../portable/builder/PortableLazySet.java | 92 - .../portable/builder/PortableLazyValue.java | 28 - .../builder/PortableModifiableLazyValue.java | 52 - .../builder/PortableObjectArrayLazyValue.java | 91 - .../builder/PortablePlainLazyValue.java | 49 - .../builder/PortablePlainPortableObject.java | 53 - .../portable/builder/PortableValueWithType.java | 76 - .../internal/portable/builder/package-info.java | 22 - .../ignite/internal/portable/package-info.java | 22 - .../streams/PortableAbstractInputStream.java | 379 -- .../streams/PortableAbstractOutputStream.java | 347 -- .../streams/PortableAbstractStream.java | 80 - .../streams/PortableHeapInputStream.java | 166 - .../streams/PortableHeapOutputStream.java | 176 - .../portable/streams/PortableInputStream.java | 162 - .../streams/PortableMemoryAllocator.java | 57 - .../streams/PortableMemoryAllocatorChunk.java | 117 - .../streams/PortableOffheapInputStream.java | 144 - .../streams/PortableOffheapOutputStream.java | 222 - .../portable/streams/PortableOutputStream.java | 259 -- .../portable/streams/PortableStream.java | 53 - .../internal/portable/streams/package-info.java | 22 - .../processors/GridProcessorAdapter.java | 5 +- .../CacheDefaultBinaryAffinityKeyMapper.java | 6 +- .../processors/cache/CacheLazyEntry.java | 12 +- .../processors/cache/CacheObjectContext.java | 2 +- .../processors/cache/GridCacheAdapter.java | 65 +- .../cache/GridCacheConcurrentMap.java | 734 +-- .../processors/cache/GridCacheContext.java | 8 +- .../processors/cache/GridCacheIoManager.java | 5 +- .../processors/cache/GridCacheMapEntry.java | 44 +- .../cache/GridCacheMapEntryFactory.java | 13 +- .../processors/cache/GridCacheProcessor.java | 45 +- .../CacheDefaultPortableAffinityKeyMapper.java | 51 + .../binary/CacheObjectBinaryProcessor.java | 106 + .../binary/CacheObjectBinaryProcessorImpl.java | 895 ++++ .../binary/CacheObjectPortableContext.java | 56 + .../cache/binary/IgniteBinaryImpl.java | 178 + .../cache/binary/PortableMetadataKey.java | 82 + .../processors/cache/binary/package-info.java | 22 + .../distributed/GridDistributedCacheEntry.java | 14 +- .../dht/GridDhtAffinityAssignmentResponse.java | 2 +- .../distributed/dht/GridDhtCacheAdapter.java | 13 +- .../distributed/dht/GridDhtCacheEntry.java | 14 +- .../dht/GridDhtOffHeapCacheEntry.java | 15 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 2 +- .../distributed/dht/GridNoStorageCacheMap.java | 4 +- .../dht/atomic/GridDhtAtomicCache.java | 23 +- .../dht/atomic/GridDhtAtomicCacheEntry.java | 16 +- .../atomic/GridDhtAtomicOffHeapCacheEntry.java | 15 +- .../dht/colocated/GridDhtColocatedCache.java | 13 +- .../colocated/GridDhtColocatedCacheEntry.java | 14 +- .../GridDhtColocatedOffHeapCacheEntry.java | 15 +- .../colocated/GridDhtDetachedCacheEntry.java | 4 +- .../GridDhtPartitionsExchangeFuture.java | 4 +- .../preloader/GridDhtPartitionsFullMessage.java | 8 +- .../distributed/near/GridNearCacheAdapter.java | 8 +- .../distributed/near/GridNearCacheEntry.java | 16 +- .../near/GridNearOffHeapCacheEntry.java | 15 +- .../cache/jta/CacheJtaManagerAdapter.java | 4 +- .../processors/cache/local/GridLocalCache.java | 8 +- .../cache/local/GridLocalCacheEntry.java | 15 +- .../local/atomic/GridLocalAtomicCache.java | 8 +- .../CacheDefaultPortableAffinityKeyMapper.java | 51 - .../portable/CacheObjectBinaryProcessor.java | 106 - .../CacheObjectBinaryProcessorImpl.java | 896 ---- .../portable/CacheObjectPortableContext.java | 56 - .../cache/portable/IgniteBinaryImpl.java | 178 - .../cache/portable/PortableMetadataKey.java | 82 - .../processors/cache/portable/package-info.java | 22 - .../cache/query/GridCacheQueryManager.java | 46 +- .../cache/store/CacheOsStoreManager.java | 4 +- .../datastructures/DataStructuresProcessor.java | 4 +- .../GridTransactionalCacheQueueImpl.java | 32 +- .../platform/PlatformAbstractTarget.java | 6 +- .../processors/platform/PlatformContext.java | 6 +- .../platform/PlatformContextImpl.java | 12 +- .../platform/PlatformExtendedException.java | 4 +- .../platform/PlatformProcessorImpl.java | 4 +- .../platform/cache/PlatformCache.java | 6 +- .../cache/PlatformCacheEntryFilterImpl.java | 4 +- .../cache/PlatformCacheEntryProcessorImpl.java | 6 +- .../platform/cache/PlatformCacheIterator.java | 4 +- .../PlatformCachePartialUpdateException.java | 4 +- .../cache/affinity/PlatformAffinity.java | 6 +- .../query/PlatformAbstractQueryCursor.java | 4 +- .../PlatformContinuousQueryRemoteFilter.java | 4 +- .../cache/query/PlatformFieldsQueryCursor.java | 4 +- .../cache/query/PlatformQueryCursor.java | 4 +- .../cache/store/PlatformCacheStoreCallback.java | 4 +- .../platform/cluster/PlatformClusterGroup.java | 6 +- .../cluster/PlatformClusterNodeFilterImpl.java | 4 +- .../platform/compute/PlatformAbstractJob.java | 4 +- .../platform/compute/PlatformAbstractTask.java | 4 +- .../platform/compute/PlatformClosureJob.java | 4 +- .../platform/compute/PlatformCompute.java | 8 +- .../platform/compute/PlatformFullJob.java | 4 +- .../platform/compute/PlatformFullTask.java | 6 +- .../cpp/PlatformCppConfigurationClosure.java | 4 +- .../datastreamer/PlatformDataStreamer.java | 5 +- .../PlatformStreamReceiverImpl.java | 4 +- .../dotnet/PlatformDotNetCacheStore.java | 6 +- .../PlatformDotNetConfigurationClosure.java | 12 +- .../events/PlatformEventFilterListenerImpl.java | 4 +- .../platform/events/PlatformEvents.java | 4 +- .../platform/memory/PlatformInputStream.java | 4 +- .../platform/memory/PlatformOutputStream.java | 4 +- .../messaging/PlatformMessageFilterImpl.java | 4 +- .../messaging/PlatformMessageLocalFilter.java | 2 +- .../platform/messaging/PlatformMessaging.java | 6 +- .../services/PlatformAbstractService.java | 6 +- .../platform/services/PlatformServices.java | 6 +- .../transactions/PlatformTransactions.java | 4 +- .../platform/utils/PlatformFutureUtils.java | 4 +- .../platform/utils/PlatformReaderBiClosure.java | 4 +- .../platform/utils/PlatformReaderClosure.java | 4 +- .../platform/utils/PlatformUtils.java | 6 +- .../platform/utils/PlatformWriterBiClosure.java | 4 +- .../platform/utils/PlatformWriterClosure.java | 4 +- .../internal/util/GridMessageCollection.java | 160 + .../ignite/internal/util/IgniteUtils.java | 18 +- .../internal/util/UUIDCollectionMessage.java | 42 +- .../util/nio/GridNioBackPressureControl.java | 14 +- .../ignite/internal/util/nio/GridNioServer.java | 11 +- .../ignite/internal/visor/cache/VisorCache.java | 13 + .../internal/visor/query/VisorQueryJob.java | 76 +- .../internal/visor/query/VisorQueryUtils.java | 5 +- .../marshaller/optimized/package-info.java | 2 +- .../org/apache/ignite/spi/IgniteSpiThread.java | 10 +- .../sharedfs/SharedFsCheckpointSpi.java | 4 +- .../communication/tcp/TcpCommunicationSpi.java | 6 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 13 +- .../org/apache/ignite/thread/IgniteThread.java | 45 +- .../ignite/thread/IgniteThreadPoolExecutor.java | 37 +- .../resources/META-INF/classnames.properties | 36 +- ...heJdbcPojoStoreBinaryMarshallerSelfTest.java | 2 +- .../GridEventStorageCheckAllEventsSelfTest.java | 22 +- .../IgniteClientReconnectAbstractTest.java | 96 +- .../IgniteClientReconnectAtomicsTest.java | 57 + .../IgniteClientReconnectCacheTest.java | 15 +- .../IgniteClientReconnectCollectionsTest.java | 51 + .../internal/binary/BinaryEnumsSelfTest.java | 446 ++ .../binary/BinaryFieldsAbstractSelfTest.java | 718 +++ .../binary/BinaryFieldsHeapSelfTest.java | 30 + .../binary/BinaryFieldsOffheapSelfTest.java | 60 + .../BinaryFooterOffsetsAbstractSelfTest.java | 205 + .../binary/BinaryFooterOffsetsHeapSelfTest.java | 30 + .../BinaryFooterOffsetsOffheapSelfTest.java | 60 + .../binary/BinaryMarshallerSelfTest.java | 4209 ++++++++++++++++++ .../BinaryObjectBuilderAdditionalSelfTest.java | 1264 ++++++ .../binary/BinaryObjectBuilderSelfTest.java | 1100 +++++ .../binary/GridPortableAffinityKeySelfTest.java | 234 + ...idPortableMarshallerCtxDisabledSelfTest.java | 247 + .../binary/GridPortableMetaDataSelfTest.java | 371 ++ .../binary/GridPortableWildcardsSelfTest.java | 464 ++ .../binary/TestCachingMetadataHandler.java | 45 + .../GridBinaryMarshalerAwareTestClass.java | 67 + .../mutabletest/GridPortableTestClasses.java | 484 ++ .../binary/mutabletest/package-info.java | 22 + .../BinaryFieldsHeapNonCompactSelfTest.java | 30 + .../BinaryFieldsOffheapNonCompactSelfTest.java | 30 + ...naryFooterOffsetsHeapNonCompactSelfTest.java | 30 + ...yFooterOffsetsOffheapNonCompactSelfTest.java | 30 + .../BinaryMarshallerNonCompactSelfTest.java | 30 + ...jectBuilderAdditionalNonCompactSelfTest.java | 30 + .../BinaryObjectBuilderNonCompactSelfTest.java | 30 + .../ignite/internal/binary/package-info.java | 22 + .../binary/test/GridPortableTestClass1.java | 28 + .../binary/test/GridPortableTestClass2.java | 24 + .../internal/binary/test/package-info.java | 22 + .../test/subpackage/GridPortableTestClass3.java | 24 + .../binary/test/subpackage/package-info.java | 22 + .../internal/portable/BinaryEnumsSelfTest.java | 446 -- .../portable/BinaryFieldsAbstractSelfTest.java | 718 --- .../portable/BinaryFieldsHeapSelfTest.java | 30 - .../portable/BinaryFieldsOffheapSelfTest.java | 60 - .../BinaryFooterOffsetsAbstractSelfTest.java | 205 - .../BinaryFooterOffsetsHeapSelfTest.java | 30 - .../BinaryFooterOffsetsOffheapSelfTest.java | 60 - .../portable/BinaryMarshallerSelfTest.java | 3877 ---------------- .../BinaryObjectBuilderAdditionalSelfTest.java | 1291 ------ .../portable/BinaryObjectBuilderSelfTest.java | 1103 ----- .../GridPortableAffinityKeySelfTest.java | 234 - ...idPortableMarshallerCtxDisabledSelfTest.java | 247 - .../portable/GridPortableMetaDataSelfTest.java | 371 -- .../portable/GridPortableWildcardsSelfTest.java | 464 -- .../portable/TestCachingMetadataHandler.java | 45 - .../GridBinaryMarshalerAwareTestClass.java | 67 - .../mutabletest/GridPortableTestClasses.java | 443 -- .../portable/mutabletest/package-info.java | 22 - .../BinaryFieldsHeapNonCompactSelfTest.java | 30 - .../BinaryFieldsOffheapNonCompactSelfTest.java | 30 - ...naryFooterOffsetsHeapNonCompactSelfTest.java | 30 - ...yFooterOffsetsOffheapNonCompactSelfTest.java | 30 - .../BinaryMarshallerNonCompactSelfTest.java | 30 - ...jectBuilderAdditionalNonCompactSelfTest.java | 30 - .../BinaryObjectBuilderNonCompactSelfTest.java | 30 - .../ignite/internal/portable/package-info.java | 22 - .../portable/test/GridPortableTestClass1.java | 28 - .../portable/test/GridPortableTestClass2.java | 24 - .../internal/portable/test/package-info.java | 22 - .../test/subpackage/GridPortableTestClass3.java | 24 - .../portable/test/subpackage/package-info.java | 22 - ...cheAbstractFullApiMultithreadedSelfTest.java | 2 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 4 +- .../cache/GridCacheAlwaysEvictionPolicy.java | 2 +- ...eAtomicEntryProcessorDeploymentSelfTest.java | 69 +- .../cache/GridCacheConcurrentMapSelfTest.java | 11 - .../GridCacheConditionalDeploymentSelfTest.java | 20 +- .../cache/GridCacheDeploymentSelfTest.java | 11 +- .../IgniteCacheEntryListenerAbstractTest.java | 8 +- .../IgniteCacheStoreValueAbstractTest.java | 6 +- ...yAtomicEntryProcessorDeploymentSelfTest.java | 129 + ...naryObjectsAbstractDataStreamerSelfTest.java | 192 + ...aryObjectsAbstractMultiThreadedSelfTest.java | 241 + .../GridCacheBinaryObjectsAbstractSelfTest.java | 981 ++++ ...ctionalEntryProcessorDeploymentSelfTest.java | 31 + ...ntNodeBinaryObjectMetadataMultinodeTest.java | 295 ++ ...CacheClientNodeBinaryObjectMetadataTest.java | 221 + .../GridCachePortableStoreAbstractSelfTest.java | 300 ++ .../GridCachePortableStoreObjectsSelfTest.java | 55 + ...GridCachePortableStorePortablesSelfTest.java | 66 + ...ridPortableCacheEntryMemorySizeSelfTest.java | 48 + ...leDuplicateIndexObjectsAbstractSelfTest.java | 161 + .../DataStreamProcessorPortableSelfTest.java | 71 + .../GridDataStreamerImplSelfTest.java | 345 ++ ...ridCacheAffinityRoutingPortableSelfTest.java | 54 + ...lyPortableDataStreamerMultiNodeSelfTest.java | 29 + ...rtableDataStreamerMultithreadedSelfTest.java | 47 + ...artitionedOnlyPortableMultiNodeSelfTest.java | 28 + ...tionedOnlyPortableMultithreadedSelfTest.java | 47 + ...AtomicNearDisabledOffheapTieredSelfTest.java | 29 + ...BinaryObjectsAtomicNearDisabledSelfTest.java | 51 + ...inaryObjectsAtomicOffheapTieredSelfTest.java | 29 + .../GridCacheBinaryObjectsAtomicSelfTest.java | 51 + ...tionedNearDisabledOffheapTieredSelfTest.java | 30 + ...yObjectsPartitionedNearDisabledSelfTest.java | 51 + ...ObjectsPartitionedOffheapTieredSelfTest.java | 30 + ...idCacheBinaryObjectsPartitionedSelfTest.java | 51 + .../GridCacheMemoryModePortableSelfTest.java | 36 + ...acheOffHeapTieredAtomicPortableSelfTest.java | 48 + ...eapTieredEvictionAtomicPortableSelfTest.java | 96 + ...heOffHeapTieredEvictionPortableSelfTest.java | 96 + .../GridCacheOffHeapTieredPortableSelfTest.java | 48 + ...ateIndexObjectPartitionedAtomicSelfTest.java | 38 + ...xObjectPartitionedTransactionalSelfTest.java | 41 + ...sNearPartitionedByteArrayValuesSelfTest.java | 41 + ...sPartitionedOnlyByteArrayValuesSelfTest.java | 42 + ...ridCacheBinaryObjectsReplicatedSelfTest.java | 51 + ...idCacheBinaryObjectsAtomicLocalSelfTest.java | 32 + ...BinaryObjectsLocalOffheapTieredSelfTest.java | 29 + .../GridCacheBinaryObjectsLocalSelfTest.java | 51 + ...IgniteCacheAbstractExecutionContextTest.java | 4 +- ...eAbstractDataStructuresFailoverSelfTest.java | 140 +- ...niteCacheClientNodeChangingTopologyTest.java | 125 +- ...eRebalancingUnmarshallingFailedSelfTest.java | 2 +- ...idCacheReplicatedUnswapAdvancedSelfTest.java | 44 +- .../GridCacheReplicatedPreloadSelfTest.java | 44 +- ...naryObjectsAbstractDataStreamerSelfTest.java | 192 - ...aryObjectsAbstractMultiThreadedSelfTest.java | 241 - .../GridCacheBinaryObjectsAbstractSelfTest.java | 981 ---- ...ntNodeBinaryObjectMetadataMultinodeTest.java | 295 -- ...CacheClientNodeBinaryObjectMetadataTest.java | 221 - .../GridCachePortableStoreAbstractSelfTest.java | 300 -- .../GridCachePortableStoreObjectsSelfTest.java | 55 - ...GridCachePortableStorePortablesSelfTest.java | 66 - ...ridPortableCacheEntryMemorySizeSelfTest.java | 48 - ...leDuplicateIndexObjectsAbstractSelfTest.java | 161 - .../DataStreamProcessorPortableSelfTest.java | 71 - .../GridDataStreamerImplSelfTest.java | 345 -- ...ridCacheAffinityRoutingPortableSelfTest.java | 54 - ...lyPortableDataStreamerMultiNodeSelfTest.java | 29 - ...rtableDataStreamerMultithreadedSelfTest.java | 47 - ...artitionedOnlyPortableMultiNodeSelfTest.java | 28 - ...tionedOnlyPortableMultithreadedSelfTest.java | 47 - ...AtomicNearDisabledOffheapTieredSelfTest.java | 29 - ...BinaryObjectsAtomicNearDisabledSelfTest.java | 51 - ...inaryObjectsAtomicOffheapTieredSelfTest.java | 29 - .../GridCacheBinaryObjectsAtomicSelfTest.java | 51 - ...tionedNearDisabledOffheapTieredSelfTest.java | 30 - ...yObjectsPartitionedNearDisabledSelfTest.java | 51 - ...ObjectsPartitionedOffheapTieredSelfTest.java | 30 - ...idCacheBinaryObjectsPartitionedSelfTest.java | 51 - .../GridCacheMemoryModePortableSelfTest.java | 36 - ...acheOffHeapTieredAtomicPortableSelfTest.java | 48 - ...eapTieredEvictionAtomicPortableSelfTest.java | 96 - ...heOffHeapTieredEvictionPortableSelfTest.java | 96 - .../GridCacheOffHeapTieredPortableSelfTest.java | 48 - ...ateIndexObjectPartitionedAtomicSelfTest.java | 38 - ...xObjectPartitionedTransactionalSelfTest.java | 41 - ...sNearPartitionedByteArrayValuesSelfTest.java | 41 - ...sPartitionedOnlyByteArrayValuesSelfTest.java | 42 - ...ridCacheBinaryObjectsReplicatedSelfTest.java | 51 - ...idCacheBinaryObjectsAtomicLocalSelfTest.java | 32 - ...BinaryObjectsLocalOffheapTieredSelfTest.java | 29 - .../GridCacheBinaryObjectsLocalSelfTest.java | 51 - .../DataStreamProcessorSelfTest.java | 25 +- .../loadtests/hashmap/GridHashMapLoadTest.java | 4 +- .../marshaller/GridMarshallerAbstractTest.java | 32 +- .../PlatformComputeBinarizableArgTask.java | 4 +- .../platform/PlatformEventsWriteEventTask.java | 4 +- .../session/GridSessionCheckpointSelfTest.java | 8 +- ...lientDiscoverySpiFailureTimeoutSelfTest.java | 5 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 130 +- .../testframework/junits/GridAbstractTest.java | 11 +- .../ignite/testframework/junits/IgniteMock.java | 6 +- .../junits/IgniteTestResources.java | 10 +- ...ObjectsCacheDataStructuresSelfTestSuite.java | 2 +- ...BinaryObjectsCacheExpiryPolicyTestSuite.java | 2 +- ...gniteBinaryObjectsCacheRestartTestSuite.java | 2 +- .../IgniteBinaryObjectsCacheTestSuite2.java | 2 +- .../IgniteBinaryObjectsCacheTestSuite3.java | 11 +- .../IgniteBinaryObjectsCacheTestSuite4.java | 2 +- ...IgniteBinaryObjectsComputeGridTestSuite.java | 2 +- .../ignite/testsuites/IgniteCacheTestSuite.java | 4 +- .../IgnitePortableCacheFullApiTestSuite.java | 4 +- .../IgnitePortableCacheTestSuite.java | 35 +- .../IgnitePortableObjectsTestSuite.java | 70 +- .../testsuites/IgniteUtilSelfTestSuite.java | 2 + .../ignite/util/GridMessageCollectionTest.java | 105 + .../ignite/portable/test1/1.1/test1-1.1.pom | 2 +- .../portable/test1/maven-metadata-local.xml | 2 +- .../ignite/portable/test2/1.1/test2-1.1.pom | 2 +- .../portable/test2/maven-metadata-local.xml | 2 +- ...cheDeploymentBinaryObjectEntryProcessor.java | 36 + .../tests/p2p/CacheDeploymentTestValue3.java | 41 + .../HibernateTransactionalDataRegion.java | 18 +- .../HibernateL2CacheTransactionalSelfTest.java | 23 +- .../IgnitePortableCacheQueryTestSuite.java | 8 +- modules/jta/pom.xml | 9 +- .../cache/jta/jndi/CacheJndiTmFactory.java | 132 + .../processors/cache/jta/CacheJtaManager.java | 41 +- .../cache/AbstarctCacheJtaSelfTest.java | 183 + .../cache/CacheJndiTmFactorySelfTest.java | 166 + ...CacheJtaConfigurationValidationSelfTest.java | 4 +- ...CacheJtaFactoryConfigValidationSelfTest.java | 142 + .../processors/cache/GridCacheJtaSelfTest.java | 221 - .../cache/GridCacheReplicatedJtaSelfTest.java | 32 - .../cache/GridJtaLifecycleAwareSelfTest.java | 191 + .../GridPartitionedCacheJtaFactorySelfTest.java | 41 + ...titionedCacheJtaLookupClassNameSelfTest.java | 83 + .../GridReplicatedCacheJtaFactorySelfTest.java | 32 + ...plicatedCacheJtaLookupClassNameSelfTest.java | 32 + .../GridTmLookupLifecycleAwareSelfTest.java | 122 - .../ignite/testsuites/IgniteJtaTestSuite.java | 26 +- .../osgi-karaf/src/main/resources/features.xml | 11 +- .../ignite/osgi/classloaders/package-info.java | 21 + .../org/apache/ignite/osgi/package-info.java | 21 + .../ignite/osgi/AbstractIgniteKarafTest.java | 2 - .../IgniteKarafFeaturesInstallationTest.java | 2 +- .../ignite/osgi/IgniteOsgiServiceTest.java | 2 +- .../src/binary_reader_writer_raw_test.cpp | 10 +- .../core-test/src/binary_reader_writer_test.cpp | 10 +- .../core/include/ignite/binary/binary_consts.h | 29 +- .../Binary/BinarySelfTest.cs | 67 + .../Config/marshaller-explicit.xml | 2 +- .../Apache.Ignite.Core.csproj | 5 + .../Cache/Query/IQueryCursor.cs | 2 +- .../Apache.Ignite.Core/Cache/Query/QueryBase.cs | 2 +- .../Store/CacheParallelLoadStoreAdapter.cs | 4 +- .../Cache/Store/CacheStoreAdapter.cs | 12 +- .../Cache/Store/ICacheStore.cs | 36 +- .../Apache.Ignite.Core/Cluster/ICluster.cs | 2 +- .../Cluster/IClusterMetrics.cs | 6 +- .../Apache.Ignite.Core/Cluster/IClusterNode.cs | 6 +- .../Apache.Ignite.Core/Compute/IComputeTask.cs | 2 +- .../Datastream/IDataStreamer.cs | 12 +- .../Apache.Ignite.Core/Events/CacheEvent.cs | 4 +- .../Apache.Ignite.Core/Events/TaskEvent.cs | 2 +- .../dotnet/Apache.Ignite.Core/IIgnite.cs | 6 +- .../dotnet/Apache.Ignite.Core/Ignition.cs | 24 +- .../Impl/Binary/BinaryObjectBuilder.cs | 8 +- .../Impl/Binary/BinaryObjectHeader.cs | 10 +- .../Impl/Binary/BinaryReflectiveActions.cs | 4 +- .../Impl/Binary/BinarySystemHandlers.cs | 34 +- .../Impl/Binary/BinaryUtils.cs | 94 +- .../Impl/Binary/Metadata/BinaryTypeHolder.cs | 1 + .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 2 - .../Impl/Common/DelegateConverter.cs | 15 +- .../Apache.Ignite.Core/Impl/NativeMethods.cs | 10 - .../Impl/Unmanaged/IgniteJniNativeMethods.cs | 358 ++ .../Impl/Unmanaged/UnmanagedUtils.cs | 788 +--- .../Transactions/ITransaction.cs | 2 +- modules/platforms/dotnet/Apache.Ignite.FxCop | 322 +- modules/platforms/dotnet/Apache.Ignite.dxg | 2387 ++++++++++ modules/platforms/dotnet/Apache.Ignite.sln | 1 + modules/platforms/dotnet/Apache.Ignite.slnrel | 43 - .../platforms/dotnet/Apache.Ignite_x86.slnrel | 43 - modules/platforms/dotnet/README.txt | 36 +- modules/platforms/dotnet/build.bat | 94 + .../Apache.Ignite.Examples.csproj | 4 +- .../Apache.Ignite.ExamplesDll.csproj | 4 +- modules/platforms/dotnet/examples/README.txt | 8 - .../ignite/schema/generator/CodeGenerator.java | 30 +- .../ignite/internal/GridFactorySelfTest.java | 29 + .../GridSpringBeanSerializationSelfTest.java | 2 + .../config/benchmark-failover.properties | 2 +- .../ignite-int-max-values-offheap-config.xml | 2 +- .../ignite-int-max-values-onheap-config.xml | 2 +- .../ignite-int-max-values-swap-config.xml | 2 +- ...IgniteTransactionalWriteInvokeBenchmark.java | 42 +- parent/pom.xml | 3 + 556 files changed, 41923 insertions(+), 37514 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0db011d4/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java ---------------------------------------------------------------------- diff --cc modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java index e1d3f2b,1e15c15..9465291 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/datastructures/GridCacheAbstractDataStructuresFailoverSelfTest.java @@@ -869,10 -1083,11 +939,10 @@@ public abstract class GridCacheAbstract Ignite g = startGrid(name); - callback.apply(g); + cb.apply(g); } finally { - if (i != TOP_CHANGE_CNT - 1) - stopGrid(name); + stopGrid(name); } } }
