ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject [37/38] ignite git commit: Merge branch 'master' into ignite-gg-10837
Date Tue, 19 Jan 2016 10:59:28 GMT
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 <ntikhonov@gridgain.com>
Authored: Tue Jan 19 13:44:32 2016 +0300
Committer: nikolay_tikhonov <ntikhonov@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
----------------------------------------------------------------------


Mime
View raw message