ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [03/50] [abbrv] ignite git commit: Merge branch 'ignite-1.5'
Date Mon, 11 Jan 2016 05:57:33 GMT
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-1537
Commit: 0db011d4a8ad9ecaa7bfa2bc1c603077ed4a36d1
Parents: 49a0e6d 1dbf20e
Author: ashutak <ashutak@gridgain.com>
Authored: Fri Dec 11 12:45:21 2015 +0300
Committer: ashutak <ashutak@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);
                              }
                          }
                      }


Mime
View raw message