You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by nt...@apache.org on 2016/01/19 11:59:28 UTC
[37/38] ignite git commit: Merge branch 'master' into ignite-gg-10837
Merge branch 'master' into ignite-gg-10837
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2a1a4cd1
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2a1a4cd1
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2a1a4cd1
Branch: refs/heads/ignite-gg-10837
Commit: 2a1a4cd131366e8f6cc450ec5c977baa79fc0919
Parents: 272f397 6779145
Author: nikolay_tikhonov <nt...@gridgain.com>
Authored: Tue Jan 19 13:44:32 2016 +0300
Committer: nikolay_tikhonov <nt...@gridgain.com>
Committed: Tue Jan 19 13:44:32 2016 +0300
----------------------------------------------------------------------
.../apache/ignite/internal/GridComponent.java | 5 +-
.../internal/GridEventConsumeHandler.java | 3 +-
.../internal/GridMessageListenHandler.java | 6 +-
.../ignite/internal/GridUpdateNotifier.java | 454 ------------------
.../apache/ignite/internal/IgniteKernal.java | 126 +----
.../ignite/internal/IgniteVersionUtils.java | 4 +-
.../internal/binary/BinaryClassDescriptor.java | 15 +-
.../internal/binary/BinaryEnumObjectImpl.java | 3 +-
.../ignite/internal/binary/BinaryUtils.java | 78 ++++
.../internal/direct/DirectMessageReader.java | 11 +
.../internal/direct/DirectMessageWriter.java | 13 +
.../direct/state/DirectMessageState.java | 10 +
.../stream/v1/DirectByteBufferStreamImplV1.java | 8 +
.../stream/v2/DirectByteBufferStreamImplV2.java | 8 +
.../managers/discovery/CustomEventListener.java | 4 +-
.../discovery/DiscoveryCustomMessage.java | 9 -
.../discovery/GridDiscoveryManager.java | 41 +-
.../processors/cache/CacheObjectContext.java | 91 ++--
.../cache/DynamicCacheChangeBatch.java | 5 -
.../processors/cache/GridCacheAdapter.java | 30 +-
.../processors/cache/GridCacheContext.java | 33 ++
.../processors/cache/GridCacheProcessor.java | 42 +-
.../binary/CacheObjectBinaryProcessorImpl.java | 33 +-
.../dht/CacheDistributedGetFutureAdapter.java | 28 +-
.../dht/GridClientPartitionTopology.java | 2 +
.../dht/GridDhtPartitionTopologyImpl.java | 27 +-
.../dht/GridPartitionedGetFuture.java | 241 +++++-----
.../dht/GridPartitionedSingleGetFuture.java | 229 ++++++----
.../dht/atomic/GridDhtAtomicCache.java | 26 ++
.../colocated/GridDhtColocatedLockFuture.java | 4 -
.../dht/preloader/GridDhtPartitionDemander.java | 11 +-
.../GridDhtPartitionsExchangeFuture.java | 8 +-
.../distributed/near/GridNearGetFuture.java | 267 ++++++-----
.../continuous/CacheContinuousQueryEntry.java | 70 +--
.../continuous/CacheContinuousQueryHandler.java | 36 +-
.../cache/transactions/IgniteTxManager.java | 18 +-
.../processors/cluster/ClusterProcessor.java | 174 +++++++
.../processors/cluster/GridUpdateNotifier.java | 457 +++++++++++++++++++
.../continuous/AbstractContinuousMessage.java | 5 -
.../continuous/GridContinuousHandler.java | 4 +-
.../continuous/GridContinuousProcessor.java | 26 +-
.../internal/processors/igfs/IgfsProcessor.java | 3 -
.../platform/PlatformAbstractTarget.java | 28 +-
.../platform/PlatformNoopProcessor.java | 5 +
.../processors/platform/PlatformProcessor.java | 8 +
.../platform/PlatformProcessorImpl.java | 5 +
.../platform/cache/PlatformCache.java | 6 +-
.../platform/compute/PlatformCompute.java | 132 +++++-
.../dotnet/PlatformDotNetCacheStore.java | 33 +-
.../platform/events/PlatformEvents.java | 16 +-
.../platform/messaging/PlatformMessaging.java | 7 +-
.../platform/services/PlatformServices.java | 14 +-
.../internal/util/nio/GridDirectParser.java | 52 ++-
.../communication/tcp/TcpCommunicationSpi.java | 9 +-
.../tcp/ipfinder/TcpDiscoveryIpFinder.java | 14 +-
.../ipfinder/jdbc/TcpDiscoveryJdbcIpFinder.java | 48 +-
.../internal/GridUpdateNotifierSelfTest.java | 137 ------
...UpdateNotifierPerClusterSettingSelfTest.java | 130 ++++++
.../internal/TestRecordingCommunicationSpi.java | 157 +++++++
.../binary/BinaryMarshallerSelfTest.java | 44 +-
...idCacheConfigurationConsistencySelfTest.java | 58 +--
.../cache/GridCacheDeploymentSelfTest.java | 3 +-
...IgniteCacheGetCustomCollectionsSelfTest.java | 128 ++++++
...gniteCacheLoadRebalanceEvictionSelfTest.java | 188 ++++++++
.../cache/IgniteCacheNearLockValueSelfTest.java | 62 +--
.../cache/IgniteCacheStoreCollectionTest.java | 12 +
...eDynamicCacheStartNoExchangeTimeoutTest.java | 7 +
...niteDynamicCacheStartStopConcurrentTest.java | 119 +++++
...ridCachePartitionNotLoadedEventSelfTest.java | 7 +-
.../IgniteCacheAtomicNodeRestartTest.java | 2 +
...niteCacheClientNodeChangingTopologyTest.java | 4 +-
.../distributed/IgniteCacheGetRestartTest.java | 280 ++++++++++++
.../IgniteCacheReadFromBackupTest.java | 427 +++++++++++++++++
.../IgniteCacheSingleGetMessageTest.java | 88 +---
.../IgniteCrossCacheTxStoreSelfTest.java | 1 +
.../GridCacheDhtPreloadMessageCountTest.java | 62 +--
.../near/GridCacheGetStoreErrorSelfTest.java | 9 +-
.../GridCachePartitionedNodeRestartTest.java | 4 +-
...ePartitionedOptimisticTxNodeRestartTest.java | 4 +-
...ContinuousQueryFailoverAbstractSelfTest.java | 80 ++++
.../CacheContinuousQueryLostPartitionTest.java | 256 +++++++++++
.../cluster/GridUpdateNotifierSelfTest.java | 140 ++++++
.../IgniteServiceDynamicCachesSelfTest.java | 183 ++++++++
.../platform/PlatformComputeBroadcastTask.java | 7 +
.../platform/PlatformComputeEchoTask.java | 6 +-
...CommunicationRecoveryAckClosureSelfTest.java | 2 +
.../startup/GridRandomCommandLineLoader.java | 4 +-
.../ignite/testframework/GridTestUtils.java | 27 ++
.../IgniteCacheRestartTestSuite2.java | 3 +
.../testsuites/IgniteCacheTestSuite4.java | 9 +
.../testsuites/IgniteCacheTestSuite5.java | 2 +
.../testsuites/IgniteKernalSelfTestSuite.java | 4 +-
.../hadoop/fs/BasicHadoopFileSystemFactory.java | 19 +-
.../fs/IgniteHadoopIgfsSecondaryFileSystem.java | 6 +-
.../hadoop/fs/v1/IgniteHadoopFileSystem.java | 7 +-
.../hadoop/fs/v2/IgniteHadoopFileSystem.java | 7 +
...niteCacheP2pUnmarshallingQueryErrorTest.java | 18 +-
.../IgniteBinaryCacheQueryTestSuite.java | 2 +
.../cpp/common/include/ignite/common/exports.h | 1 +
.../cpp/common/include/ignite/common/java.h | 3 +
.../platforms/cpp/common/project/vs/module.def | 3 +-
modules/platforms/cpp/common/src/exports.cpp | 4 +
modules/platforms/cpp/common/src/java.cpp | 20 +
.../Apache.Ignite.Core.Tests.csproj | 1 +
.../Binary/BinaryBuilderSelfTest.cs | 8 +-
.../Cache/CacheAbstractTest.cs | 19 +
.../Compute/CancellationTest.cs | 174 +++++++
.../Compute/ComputeApiTest.cs | 2 +-
.../Apache.Ignite.Core/Binary/IBinaryObject.cs | 8 +
.../Common/IgniteFutureCancelledException.cs | 1 +
.../dotnet/Apache.Ignite.Core/IIgnite.cs | 7 +
.../Apache.Ignite.Core/Impl/Binary/Binary.cs | 3 +
.../Impl/Binary/BinaryEnum.cs | 6 +
.../Impl/Binary/BinaryObject.cs | 6 +
.../Impl/Cache/Store/CacheStore.cs | 9 +-
.../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 6 +
.../Apache.Ignite.Core/Impl/IgniteProxy.cs | 6 +
.../Impl/Unmanaged/IgniteJniNativeMethods.cs | 3 +
.../Impl/Unmanaged/UnmanagedUtils.cs | 22 +-
.../Services/ServicesExample.cs | 2 +-
modules/storm/README.txt | 37 ++
modules/storm/licenses/apache-2.0.txt | 202 ++++++++
modules/storm/pom.xml | 104 +++++
.../ignite/stream/storm/StormStreamer.java | 304 ++++++++++++
.../ignite/stream/storm/package-info.java | 22 +
.../storm/IgniteStormStreamerSelfTestSuite.java | 38 ++
.../storm/StormIgniteStreamerSelfTest.java | 184 ++++++++
.../ignite/stream/storm/TestStormSpout.java | 141 ++++++
.../storm/src/test/resources/example-ignite.xml | 71 +++
.../yardstick/cache/IgniteGetTxBenchmark.java | 30 ++
pom.xml | 1 +
131 files changed, 5574 insertions(+), 1634 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2a1a4cd1/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2a1a4cd1/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridDhtAtomicCache.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2a1a4cd1/modules/core/src/test/java/org/apache/ignite/testframework/GridTestUtils.java
----------------------------------------------------------------------