You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2016/02/12 00:28:17 UTC

[42/43] ignite git commit: Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-2249

Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-2249


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6ff7391a
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6ff7391a
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6ff7391a

Branch: refs/heads/ignite-2249
Commit: 6ff7391a81cc7ea402484f3603cda89b8e49fc6f
Parents: 68d6130 35b0e6b
Author: Valentin Kulichenko <va...@gmail.com>
Authored: Thu Feb 11 15:01:47 2016 -0800
Committer: Valentin Kulichenko <va...@gmail.com>
Committed: Thu Feb 11 15:01:47 2016 -0800

----------------------------------------------------------------------
 .gitignore                                      |   3 +
 DEVNOTES.txt                                    |   4 +-
 .../apache/ignite/IgniteSystemProperties.java   |  12 +-
 .../ignite/binary/BinaryBasicNameMapper.java    |   2 +-
 .../apache/ignite/internal/IgniteKernal.java    |  14 +-
 .../internal/binary/BinaryClassDescriptor.java  |  22 +
 .../internal/binary/BinaryReaderExImpl.java     |   8 +-
 .../ignite/internal/binary/BinaryUtils.java     |  48 +-
 .../ignite/internal/binary/BinaryWriteMode.java |   3 +
 .../internal/binary/BinaryWriterExImpl.java     |  34 +
 .../internal/binary/GridBinaryMarshaller.java   |   3 +
 .../affinity/GridAffinityAssignment.java        |  36 +-
 .../affinity/GridAffinityAssignmentCache.java   |   2 +-
 .../cache/CacheEvictableEntryImpl.java          |   4 +-
 .../processors/cache/CacheLazyEntry.java        |   3 +
 .../processors/cache/GridCacheAdapter.java      |  47 +-
 .../cache/GridCacheAffinityManager.java         |  30 +-
 .../processors/cache/GridCacheContext.java      |   4 +-
 .../processors/cache/GridCacheMapEntry.java     | 118 +++-
 .../processors/cache/GridCacheMvccManager.java  |  42 +-
 .../processors/cache/GridCachePreloader.java    |   6 +
 .../cache/GridCachePreloaderAdapter.java        |   5 +
 .../processors/cache/GridCacheUtils.java        |  21 +-
 .../binary/CacheObjectBinaryProcessorImpl.java  |   6 +-
 .../dht/GridClientPartitionTopology.java        |   5 +
 .../distributed/dht/GridDhtCacheAdapter.java    |  72 +-
 .../distributed/dht/GridDhtEmbeddedFuture.java  |  13 +-
 .../cache/distributed/dht/GridDhtGetFuture.java | 176 +++--
 .../distributed/dht/GridDhtGetSingleFuture.java | 476 +++++++++++++
 .../distributed/dht/GridDhtLocalPartition.java  |  76 ++-
 .../distributed/dht/GridDhtPartitionState.java  |   2 +-
 .../dht/GridDhtPartitionTopology.java           |   5 +
 .../dht/GridDhtPartitionTopologyImpl.java       |  18 +-
 .../distributed/dht/GridDhtTxPrepareFuture.java |  40 +-
 .../dht/atomic/GridDhtAtomicCache.java          |  81 ++-
 .../dht/atomic/GridDhtAtomicUpdateFuture.java   |  85 ++-
 .../dht/atomic/GridDhtAtomicUpdateRequest.java  |  38 +-
 .../dht/colocated/GridDhtColocatedCache.java    |  40 +-
 .../dht/preloader/GridDhtPreloader.java         |  16 +
 ...arOptimisticSerializableTxPrepareFuture.java |   4 +-
 .../near/GridNearOptimisticTxPrepareFuture.java |   2 +-
 .../GridNearPessimisticTxPrepareFuture.java     |   2 +-
 .../cache/distributed/near/GridNearTxLocal.java |  67 +-
 .../cache/query/GridCacheQueryManager.java      |  30 +-
 .../continuous/CacheContinuousQueryHandler.java |   3 +-
 .../CacheContinuousQueryListener.java           |   2 +-
 .../continuous/CacheContinuousQueryManager.java | 120 +++-
 .../IgniteCacheObjectProcessorImpl.java         |   2 +-
 .../continuous/GridContinuousProcessor.java     |  16 +-
 .../GridCacheAtomicReferenceImpl.java           |  68 +-
 .../internal/processors/igfs/IgfsProcessor.java |  14 +
 .../platform/PlatformNoopProcessor.java         |  10 +
 .../processors/platform/PlatformProcessor.java  |  20 +
 .../platform/PlatformProcessorImpl.java         |  18 +
 .../callback/PlatformCallbackUtils.java         |   1 -
 .../datastructures/PlatformAtomicReference.java | 141 ++++
 .../datastructures/PlatformAtomicSequence.java  | 122 ++++
 .../util/future/GridCompoundFuture.java         |   2 +-
 .../ignite/internal/util/nio/GridNioServer.java | 143 +++-
 .../util/nio/GridSelectorNioSessionImpl.java    |   2 +-
 .../util/nio/SelectedSelectionKeySet.java       | 132 ++++
 .../org/apache/ignite/lang/IgniteBiTuple.java   |   6 +-
 .../optimized/OptimizedClassDescriptor.java     |  37 +-
 .../optimized/OptimizedMarshallerUtils.java     |   3 +
 .../optimized/OptimizedObjectInputStream.java   |  15 +-
 .../optimized/OptimizedObjectOutputStream.java  |   4 +-
 .../internal/GridNodeMetricsLogSelfTest.java    |  98 +++
 .../GridCacheOffHeapValuesEvictionSelfTest.java | 171 +++++
 .../IgniteCacheEntryListenerAbstractTest.java   | 454 ++++++++----
 ...cheEntryListenerAtomicOffheapTieredTest.java |  32 +
 ...cheEntryListenerAtomicOffheapValuesTest.java |  32 +
 ...niteCacheEntryListenerExpiredEventsTest.java | 202 ++++++
 ...teCacheEntryListenerTxOffheapTieredTest.java |  32 +
 ...teCacheEntryListenerTxOffheapValuesTest.java |  32 +
 .../cache/IgniteCacheEntryListenerTxTest.java   |   1 +
 .../IgniteTxPreloadAbstractTest.java            |   2 +-
 .../near/GridCacheNearReadersSelfTest.java      |  19 +-
 .../GridCacheReplicatedPreloadSelfTest.java     | 120 ++--
 ...ContinuousQueryFailoverAbstractSelfTest.java |  10 +
 ...tomicPrimaryWriteOrderOffheapTieredTest.java |  33 +
 ...tinuousQueryFailoverTxOffheapTieredTest.java |  32 +
 ...acheContinuousQueryRandomOperationsTest.java | 684 +++++++++++++++++++
 ...ridCacheContinuousQueryAbstractSelfTest.java |  19 +-
 ...eContinuousQueryAtomicOffheapTieredTest.java |  32 +
 ...eContinuousQueryAtomicOffheapValuesTest.java |  32 +
 ...CacheContinuousQueryTxOffheapTieredTest.java |  32 +
 ...CacheContinuousQueryTxOffheapValuesTest.java |  32 +
 .../igfs/IgfsProcessorValidationSelfTest.java   |  27 +
 .../apache/ignite/lang/GridTupleSelfTest.java   |  42 +-
 ...namicProxySerializationMultiJvmSelfTest.java | 131 ++++
 .../junits/common/GridCommonAbstractTest.java   |   2 +-
 .../junits/multijvm/IgniteNodeRunner.java       |  16 +-
 .../junits/multijvm/IgniteProcessProxy.java     |  19 +-
 .../ignite/testsuites/IgniteBasicTestSuite.java |   5 +
 .../testsuites/IgniteBinaryBasicTestSuite.java  |   2 +
 .../ignite/testsuites/IgniteCacheTestSuite.java |  10 +
 .../hadoop/fs/BasicHadoopFileSystemFactory.java |  22 +-
 .../fs/CachingHadoopFileSystemFactory.java      |   2 +-
 .../fs/KerberosHadoopFileSystemFactory.java     | 217 ++++++
 ...KerberosHadoopFileSystemFactorySelfTest.java | 121 ++++
 .../testsuites/IgniteHadoopTestSuite.java       |   3 +
 .../cache/CacheQueryBuildValueTest.java         | 144 ++++
 .../cache/IgniteCacheAbstractQuerySelfTest.java |  10 +-
 .../IgniteCacheQuerySelfTestSuite.java          |  14 +
 .../osgi-karaf/src/main/resources/features.xml  |  12 +-
 .../cpp/common/include/ignite/common/exports.h  |  15 +
 .../cpp/common/include/ignite/common/java.h     |  32 +
 .../platforms/cpp/common/project/vs/module.def  |  15 +-
 modules/platforms/cpp/common/src/exports.cpp    |  52 ++
 modules/platforms/cpp/common/src/java.cpp       | 181 +++++
 modules/platforms/cpp/core-test/Makefile.am     |   1 +
 .../cpp/core-test/project/vs/core-test.vcxproj  |   1 +
 .../project/vs/core-test.vcxproj.filters        |   3 +
 .../platforms/cpp/core-test/src/cache_test.cpp  |  12 +
 .../cpp/core-test/src/interop_memory_test.cpp   |  95 +++
 .../include/ignite/impl/ignite_environment.h    |  19 +-
 .../cpp/core/src/impl/cache/cache_impl.cpp      |   2 +-
 .../cpp/core/src/impl/ignite_environment.cpp    |  30 +-
 .../Apache.Ignite.Core.Tests.csproj             |   6 +
 .../Binary/BinarySelfTest.cs                    |  32 +
 .../Query/CacheQueriesCodeConfigurationTest.cs  |   4 +-
 .../DataStructures/AtomicReferenceTest.cs       | 239 +++++++
 .../DataStructures/AtomicSequenceTest.cs        | 131 ++++
 .../Apache.Ignite.Core.Tests/FutureTest.cs      |   1 +
 .../IgniteConfigurationSectionTest.cs           |  69 ++
 .../IgniteConfigurationSerializerTest.cs        | 554 +++++++++++++++
 .../dotnet/Apache.Ignite.Core.Tests/app.config  |  54 ++
 .../Apache.Ignite.Core.csproj                   |  15 +
 .../Binary/IBinarySerializer.cs                 |   6 +-
 .../Cache/CachePartialUpdateException.cs        |   1 -
 .../Cache/Configuration/QueryEntity.cs          |   4 +-
 .../Cache/Store/CacheStoreAdapter.cs            |   1 -
 .../Compute/ComputeTaskAdapter.cs               |   1 -
 .../Compute/ComputeTaskSplitAdapter.cs          |   1 -
 .../DataStructures/IAtomicReference.cs          |  64 ++
 .../DataStructures/IAtomicSequence.cs           |  69 ++
 .../Multicast/TcpDiscoveryMulticastIpFinder.cs  |   4 +-
 .../Tcp/Static/TcpDiscoveryStaticIpFinder.cs    |   6 +-
 .../Apache.Ignite.Core/Events/EventBase.cs      |   1 -
 .../dotnet/Apache.Ignite.Core/IIgnite.cs        |  28 +
 .../IgniteConfigurationSection.cs               |  80 +++
 .../IgniteConfigurationSection.xsd              | 281 ++++++++
 .../dotnet/Apache.Ignite.Core/Ignition.cs       |  39 ++
 .../Impl/Binary/BinaryUtils.cs                  | 166 ++++-
 .../Impl/Common/BooleanLowerCaseConverter.cs    |  60 ++
 .../Apache.Ignite.Core/Impl/Common/Future.cs    |  14 +-
 .../Impl/Common/FutureType.cs                   |  18 +-
 .../Common/IgniteConfigurationXmlSerializer.cs  | 407 +++++++++++
 .../Impl/Common/TypeStringConverter.cs          | 115 ++++
 .../Closure/ComputeAbstractClosureTask.cs       |   1 -
 .../Impl/DataStructures/AtomicReference.cs      |  92 +++
 .../Impl/DataStructures/AtomicSequence.cs       |  90 +++
 .../Impl/Events/EventTypeConverter.cs           | 133 ++++
 .../Apache.Ignite.Core/Impl/Handle/Handle.cs    |   8 +-
 .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs    |  50 ++
 .../Apache.Ignite.Core/Impl/IgniteProxy.cs      |  12 +
 .../Impl/Memory/PlatformMemoryStream.cs         | 320 +++++++--
 .../Impl/Unmanaged/IgniteJniNativeMethods.cs    |  37 +
 .../Impl/Unmanaged/UnmanagedUtils.cs            |  79 +++
 .../commands/tasks/VisorTasksCommand.scala      |   4 +-
 .../scala/org/apache/ignite/visor/visor.scala   |   4 +
 modules/yardstick/.gitignore                    |   2 +
 parent/pom.xml                                  |  93 ++-
 163 files changed, 8520 insertions(+), 840 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/6ff7391a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/binary/CacheObjectBinaryProcessorImpl.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/6ff7391a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/ignite/blob/6ff7391a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
----------------------------------------------------------------------