You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/11/23 09:46:33 UTC
[30/30] ignite git commit: Merge branches 'ignite-1.5' and
'ignite-1753-1282' of https://git-wip-us.apache.org/repos/asf/ignite into
ignite-1753-1282
Merge branches 'ignite-1.5' and 'ignite-1753-1282' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-1753-1282
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/febbb06c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/febbb06c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/febbb06c
Branch: refs/heads/ignite-1753-1282
Commit: febbb06c61e8c619af4bfd567cc933925fca510c
Parents: 3216dd4 96ae696
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Mon Nov 23 15:45:58 2015 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Mon Nov 23 15:45:58 2015 +0700
----------------------------------------------------------------------
.../datastructures/IgniteSemaphoreExample.java | 168 ++
.../ignite/examples/CacheExamplesSelfTest.java | 10 +-
.../stream/camel/IgniteCamelStreamerTest.java | 16 +-
.../camel/IgniteCamelStreamerTestSuite.java | 1 -
.../src/main/java/org/apache/ignite/Ignite.java | 17 +
.../java/org/apache/ignite/IgniteSemaphore.java | 312 ++++
.../apache/ignite/events/DiscoveryEvent.java | 6 +-
.../apache/ignite/internal/IgniteKernal.java | 30 +-
.../internal/MarshallerContextAdapter.java | 4 +-
.../internal/direct/DirectByteBufferStream.java | 1499 -----------------
.../internal/direct/DirectMessageReader.java | 144 +-
.../internal/direct/DirectMessageWriter.java | 65 +-
.../direct/DirectMessageWriterState.java | 123 --
.../direct/state/DirectMessageState.java | 98 ++
.../direct/state/DirectMessageStateItem.java | 28 +
.../direct/stream/DirectByteBufferStream.java | 316 ++++
.../stream/v1/DirectByteBufferStreamImplV1.java | 1360 +++++++++++++++
.../stream/v2/DirectByteBufferStreamImplV2.java | 1583 ++++++++++++++++++
.../managers/communication/GridIoManager.java | 64 +-
.../internal/portable/BinaryReaderExImpl.java | 226 ++-
.../GridCachePartitionExchangeManager.java | 34 +-
.../processors/cache/GridCacheUtils.java | 39 +-
.../CacheDataStructuresManager.java | 2 +-
.../GridFutureRemapTimeoutObject.java | 72 -
.../dht/GridClientPartitionTopology.java | 38 +-
.../cache/distributed/dht/GridDhtGetFuture.java | 24 +-
.../distributed/dht/GridDhtLockFuture.java | 78 +-
.../dht/GridDhtPartitionTopology.java | 12 +-
.../dht/GridDhtPartitionTopologyImpl.java | 45 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 1 -
.../dht/GridPartitionedGetFuture.java | 30 +-
.../colocated/GridDhtColocatedLockFuture.java | 596 +++----
.../dht/preloader/GridDhtPartitionFullMap.java | 41 +-
.../dht/preloader/GridDhtPartitionMap.java | 148 +-
.../dht/preloader/GridDhtPartitionMap2.java | 306 ++++
.../GridDhtPartitionsExchangeFuture.java | 24 +-
.../GridDhtPartitionsSingleMessage.java | 6 +-
.../distributed/near/GridNearCacheAdapter.java | 1 -
.../distributed/near/GridNearGetFuture.java | 30 +-
.../distributed/near/GridNearLockFuture.java | 741 ++++----
.../distributed/near/GridNearLockMapping.java | 6 +-
...arOptimisticSerializableTxPrepareFuture.java | 3 -
.../near/GridNearOptimisticTxPrepareFuture.java | 1 -
.../near/GridNearTxFinishFuture.java | 4 -
.../distributed/near/GridNearTxRemote.java | 1 -
.../processors/cache/local/GridLocalCache.java | 1 -
.../cache/local/GridLocalLockFuture.java | 2 -
.../cache/transactions/IgniteInternalTx.java | 1 -
.../cache/transactions/IgniteTxAdapter.java | 1 -
.../IgniteTxImplicitSingleStateImpl.java | 29 +-
.../cache/transactions/IgniteTxManager.java | 1 -
.../IgniteTxRemoteSingleStateImpl.java | 19 +-
.../cache/transactions/IgniteTxStateImpl.java | 1 -
.../continuous/GridContinuousProcessor.java | 6 +-
.../datastructures/DataStructuresProcessor.java | 240 ++-
.../GridAtomicCacheQueueImpl.java | 126 +-
.../GridCacheAtomicReferenceImpl.java | 10 +-
.../GridCacheCountDownLatchImpl.java | 15 +-
.../datastructures/GridCacheQueueAdapter.java | 32 +-
.../datastructures/GridCacheSemaphoreEx.java | 47 +
.../datastructures/GridCacheSemaphoreImpl.java | 763 +++++++++
.../datastructures/GridCacheSemaphoreState.java | 144 ++
.../GridTransactionalCacheQueueImpl.java | 193 +--
.../ignite/internal/util/IgniteUtils.java | 31 +
.../internal/util/ipc/IpcToNioAdapter.java | 14 +-
.../util/nio/GridCommunicationClient.java | 4 +-
.../internal/util/nio/GridDirectParser.java | 37 +-
.../util/nio/GridNioMessageReaderFactory.java | 37 +
.../util/nio/GridNioMessageWriterFactory.java | 35 +
.../ignite/internal/util/nio/GridNioServer.java | 51 +-
.../util/nio/GridShmemCommunicationClient.java | 12 +-
.../ignite/internal/visor/cache/VisorCache.java | 6 +-
.../communication/MessageFormatter.java | 15 +-
.../extensions/communication/MessageReader.java | 26 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 6 +-
.../communication/tcp/TcpCommunicationSpi.java | 80 +-
.../ignite/spi/discovery/DiscoverySpi.java | 2 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 36 +
.../org/apache/ignite/stream/StreamAdapter.java | 1 -
.../apache/ignite/stream/StreamTransformer.java | 9 +-
.../resources/META-INF/classnames.properties | 61 +-
.../IgniteClientReconnectAtomicsTest.java | 44 +-
...eAbstractDataStructuresFailoverSelfTest.java | 1065 +++++++-----
.../IgniteClientDataStructuresAbstractTest.java | 59 +-
.../IgniteDataStructureUniqueNameTest.java | 14 +-
.../IgniteSemaphoreAbstractSelfTest.java | 411 +++++
.../local/IgniteLocalSemaphoreSelfTest.java | 98 ++
...rtitionedDataStructuresFailoverSelfTest.java | 7 +-
...edOffheapDataStructuresFailoverSelfTest.java | 12 +-
.../IgnitePartitionedSemaphoreSelfTest.java | 33 +
...eplicatedDataStructuresFailoverSelfTest.java | 7 +-
.../IgniteReplicatedSemaphoreSelfTest.java | 33 +
.../dht/GridCacheDhtPreloadDelayedSelfTest.java | 12 +-
.../dht/GridCacheDhtPreloadSelfTest.java | 4 +-
.../distributed/dht/GridCacheDhtTestUtils.java | 8 +-
...gniteAtomicLongChangingTopologySelfTest.java | 2 +
...cingDelayedPartitionMapExchangeSelfTest.java | 178 ++
.../CacheVersionedEntryAbstractTest.java | 2 +-
.../continuous/GridEventConsumeSelfTest.java | 111 +-
.../cache/GridCacheDataStructuresLoadTest.java | 283 ++--
...GridTcpCommunicationSpiRecoverySelfTest.java | 4 +-
...lientDiscoverySpiFailureTimeoutSelfTest.java | 4 +-
.../spi/discovery/tcp/TcpDiscoverySelfTest.java | 90 +-
.../testframework/GridSpiTestContext.java | 12 +-
.../testframework/junits/GridAbstractTest.java | 6 +-
.../ignite/testframework/junits/IgniteMock.java | 10 +
.../junits/multijvm/IgniteProcessProxy.java | 7 +
.../testsuites/IgniteCacheTestSuite3.java | 2 +
.../h2/twostep/GridReduceQueryExecutor.java | 4 +-
.../org/apache/ignite/IgniteSpringBean.java | 12 +
.../spring/IgniteTransactionHolder.java | 97 ++
.../spring/SpringTransactionManager.java | 522 ++++++
.../transactions/spring/package-info.java | 22 +
.../test/java/config/spring-transactions.xml | 36 +
.../testsuites/IgniteSpringTestSuite.java | 5 +-
.../GridSpringTransactionManagerSelfTest.java | 165 ++
.../spring/GridSpringTransactionService.java | 68 +
.../cache/WaitMapExchangeFinishCallable.java | 4 +-
.../IgniteFailoverAbstractBenchmark.java | 4 +-
parent/pom.xml | 4 +-
120 files changed, 10011 insertions(+), 3897 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/febbb06c/modules/core/src/main/java/org/apache/ignite/internal/visor/cache/VisorCache.java
----------------------------------------------------------------------