Merge remote-tracking branch 'remotes/apache-main/ignite-1.5' into ignite-801
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d99233d6 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d99233d6 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d99233d6 Branch: refs/heads/ignite-801 Commit: d99233d6690ab38219be13f88624abde6f6b58f7 Parents: 71669ca 900788b Author: Denis Magda <[email protected]> Authored: Fri Nov 20 10:57:03 2015 +0300 Committer: Denis Magda <[email protected]> Committed: Fri Nov 20 10:57:03 2015 +0300 ---------------------------------------------------------------------- modules/camel/README.txt | 34 + modules/camel/licenses/apache-2.0.txt | 202 ++ modules/camel/pom.xml | 102 + .../ignite/stream/camel/CamelStreamer.java | 237 ++ .../stream/camel/IgniteCamelStreamerTest.java | 420 ++++ .../camel/IgniteCamelStreamerTestSuite.java | 48 + .../src/test/resources/camel.test.properties | 18 + .../ignite/codegen/MessageCodeGenerator.java | 11 +- .../java/org/apache/ignite/IgniteCache.java | 3 +- .../java/org/apache/ignite/IgniteCompute.java | 3 +- .../org/apache/ignite/compute/ComputeJob.java | 2 +- .../internal/GridEventConsumeHandler.java | 22 +- .../internal/GridMessageListenHandler.java | 18 + .../ignite/internal/GridUpdateNotifier.java | 2 +- .../communication/GridIoMessageFactory.java | 26 +- .../discovery/GridDiscoveryManager.java | 2 +- .../processors/cache/GridCacheAdapter.java | 103 +- .../processors/cache/GridCacheAtomicFuture.java | 6 + .../cache/GridCacheDeploymentManager.java | 2 +- .../processors/cache/GridCacheEntryEx.java | 12 +- .../processors/cache/GridCacheFuture.java | 13 - .../processors/cache/GridCacheGateway.java | 1 - .../processors/cache/GridCacheIoManager.java | 50 +- .../processors/cache/GridCacheMapEntry.java | 147 +- .../processors/cache/GridCacheMessage.java | 20 +- .../processors/cache/GridCacheMvcc.java | 7 - .../processors/cache/GridCacheMvccFuture.java | 7 + .../processors/cache/GridCacheMvccManager.java | 150 +- .../GridCachePartitionExchangeManager.java | 59 +- .../cache/GridCacheSharedContext.java | 7 +- .../cache/GridCacheUpdateAtomicResult.java | 15 +- .../cache/GridCacheUpdateTxResult.java | 24 +- .../processors/cache/IgniteCacheProxy.java | 3 + .../distributed/GridCacheTxRecoveryFuture.java | 54 +- .../distributed/GridDistributedBaseMessage.java | 56 - .../distributed/GridDistributedLockRequest.java | 6 - .../GridDistributedLockResponse.java | 32 +- .../GridDistributedTxPrepareRequest.java | 67 +- .../GridDistributedTxRemoteAdapter.java | 22 +- .../dht/CacheDistributedGetFutureAdapter.java | 27 +- .../cache/distributed/dht/CacheGetFuture.java | 32 + .../dht/GridClientPartitionTopology.java | 38 +- .../distributed/dht/GridDhtCacheAdapter.java | 141 ++ .../distributed/dht/GridDhtLocalPartition.java | 35 + .../distributed/dht/GridDhtLockFuture.java | 79 +- .../distributed/dht/GridDhtLockRequest.java | 2 +- .../dht/GridDhtPartitionTopology.java | 26 +- .../dht/GridDhtPartitionTopologyImpl.java | 112 +- .../dht/GridDhtTransactionalCacheAdapter.java | 14 +- .../distributed/dht/GridDhtTxFinishFuture.java | 38 +- .../distributed/dht/GridDhtTxFinishRequest.java | 112 +- .../cache/distributed/dht/GridDhtTxLocal.java | 4 +- .../distributed/dht/GridDhtTxLocalAdapter.java | 9 + .../distributed/dht/GridDhtTxPrepareFuture.java | 77 +- .../dht/GridDhtTxPrepareRequest.java | 54 +- .../dht/GridPartitionedGetFuture.java | 69 +- .../dht/GridPartitionedSingleGetFuture.java | 697 ++++++ .../dht/atomic/GridDhtAtomicCache.java | 206 +- .../dht/atomic/GridDhtAtomicUpdateFuture.java | 159 +- .../dht/atomic/GridDhtAtomicUpdateRequest.java | 151 +- .../dht/atomic/GridNearAtomicUpdateFuture.java | 5 - .../dht/colocated/GridDhtColocatedCache.java | 162 +- .../colocated/GridDhtColocatedLockFuture.java | 81 +- .../GridDhtPartitionsExchangeFuture.java | 35 +- .../preloader/GridDhtPartitionsFullMessage.java | 64 +- .../GridDhtPartitionsSingleMessage.java | 56 +- .../distributed/near/CacheVersionedValue.java | 2 +- .../distributed/near/GridNearAtomicCache.java | 10 +- .../distributed/near/GridNearCacheAdapter.java | 4 +- .../distributed/near/GridNearGetFuture.java | 57 +- .../distributed/near/GridNearGetRequest.java | 1 - .../distributed/near/GridNearGetResponse.java | 2 - .../distributed/near/GridNearLockFuture.java | 72 +- .../distributed/near/GridNearLockRequest.java | 4 +- ...arOptimisticSerializableTxPrepareFuture.java | 108 +- .../near/GridNearOptimisticTxPrepareFuture.java | 69 +- .../GridNearPessimisticTxPrepareFuture.java | 58 +- .../near/GridNearSingleGetRequest.java | 396 ++++ .../near/GridNearSingleGetResponse.java | 321 +++ .../near/GridNearTransactionalCache.java | 9 +- .../near/GridNearTxFinishFuture.java | 42 +- .../cache/distributed/near/GridNearTxLocal.java | 164 +- .../near/GridNearTxPrepareFutureAdapter.java | 20 +- .../near/GridNearTxPrepareRequest.java | 52 +- .../distributed/near/GridNearTxRemote.java | 7 + .../processors/cache/local/GridLocalCache.java | 4 +- .../cache/local/GridLocalLockFuture.java | 5 - .../CacheContinuousQueryBatchAck.java | 163 ++ .../continuous/CacheContinuousQueryEntry.java | 196 +- .../continuous/CacheContinuousQueryEvent.java | 3 +- .../continuous/CacheContinuousQueryHandler.java | 811 ++++++- .../CacheContinuousQueryListener.java | 35 + .../continuous/CacheContinuousQueryManager.java | 151 +- .../cache/transactions/IgniteInternalTx.java | 1 + .../cache/transactions/IgniteTxAdapter.java | 1 + .../cache/transactions/IgniteTxEntry.java | 29 +- .../cache/transactions/IgniteTxHandler.java | 22 +- .../IgniteTxImplicitSingleStateImpl.java | 7 + .../transactions/IgniteTxLocalAdapter.java | 32 +- .../cache/transactions/IgniteTxManager.java | 3 +- .../cache/transactions/IgniteTxRemoteEx.java | 7 +- .../IgniteTxRemoteStateAdapter.java | 5 + .../cache/transactions/IgniteTxState.java | 6 + .../cache/transactions/IgniteTxStateImpl.java | 69 +- .../clock/GridClockSyncProcessor.java | 28 +- .../continuous/GridContinuousBatch.java | 44 + .../continuous/GridContinuousBatchAdapter.java | 46 + .../continuous/GridContinuousHandler.java | 22 + .../continuous/GridContinuousProcessor.java | 221 +- .../StartRoutineAckDiscoveryMessage.java | 14 +- .../StartRoutineDiscoveryMessage.java | 21 +- .../internal/util/UUIDCollectionMessage.java | 114 + .../util/future/GridCompoundFuture.java | 15 +- .../ignite/internal/util/lang/GridFunc.java | 8 +- .../ignite/internal/util/nio/GridNioServer.java | 13 +- .../ignite/marshaller/MarshallerExclusions.java | 4 +- .../org/apache/ignite/stream/StreamAdapter.java | 19 +- .../IgniteClientReconnectCacheTest.java | 11 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 75 + .../GridCacheConcurrentTxMultiNodeTest.java | 15 - .../cache/GridCachePartitionedGetSelfTest.java | 3 +- .../processors/cache/GridCacheTestEntryEx.java | 10 +- .../IgniteCacheAbstractStopBusySelfTest.java | 27 +- .../IgniteCacheP2pUnmarshallingErrorTest.java | 184 +- .../CacheGetFutureHangsSelfTest.java | 6 + .../GridCacheAbstractNodeRestartSelfTest.java | 2 + .../IgniteCacheSingleGetMessageTest.java | 357 +++ .../GridCacheReplicatedMetricsSelfTest.java | 9 - .../IgniteCacheTxStoreSessionTest.java | 2 +- ...ContinuousQueryFailoverAbstractSelfTest.java | 2235 ++++++++++++++++++ ...ryFailoverAtomicNearEnabledSelfSelfTest.java | 46 + ...FailoverAtomicPrimaryWriteOrderSelfTest.java | 44 + ...usQueryFailoverAtomicReplicatedSelfTest.java | 40 + ...inuousQueryFailoverTxReplicatedSelfTest.java | 32 + .../CacheContinuousQueryFailoverTxSelfTest.java | 39 + ...ridCacheContinuousQueryAbstractSelfTest.java | 153 +- .../GridCacheContinuousQueryTxSelfTest.java | 49 + ...CacheContinuousQueryClientReconnectTest.java | 187 ++ .../IgniteCacheContinuousQueryClientTest.java | 157 +- ...cheContinuousQueryClientTxReconnectTest.java | 32 + .../p2p/GridP2PSameClassLoaderSelfTest.java | 16 +- .../testframework/junits/GridAbstractTest.java | 2 +- .../junits/common/GridCommonAbstractTest.java | 3 + .../testsuites/IgniteCacheTestSuite3.java | 2 + .../testsuites/IgniteCacheTestSuite4.java | 3 + modules/flume/README.md | 40 - modules/flume/README.txt | 72 + modules/flume/licenses/apache-2.0.txt | 202 ++ .../IgniteCacheQuerySelfTestSuite.java | 16 +- modules/twitter/README.txt | 32 + modules/twitter/licenses/apache-2.0.txt | 202 ++ modules/twitter/pom.xml | 122 + .../ignite/stream/twitter/OAuthSettings.java | 86 + .../ignite/stream/twitter/TwitterStreamer.java | 295 +++ .../twitter/IgniteTwitterStreamerTest.java | 234 ++ .../twitter/IgniteTwitterStreamerTestSuite.java | 32 + .../stream/twitter/TwitterStreamerImpl.java | 79 + .../config/benchmark-multicast.properties | 6 +- .../benchmark-query-put-separated.properties | 87 + .../yardstick/cache/CacheEntryEventProbe.java | 156 ++ .../cache/IgniteSqlQueryPutBenchmark.java | 20 + .../IgniteSqlQueryPutSeparatedBenchmark.java | 84 + pom.xml | 2 + 163 files changed, 12099 insertions(+), 1424 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d99233d6/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d99233d6/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java ----------------------------------------------------------------------
