ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [47/50] [abbrv] ignite git commit: Merge branch 'ignite-1.5'
Date Tue, 24 Nov 2015 08:20:22 GMT
Merge branch 'ignite-1.5'


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

Branch: refs/heads/ignite-1924
Commit: 2e7911a2c11f7760d6b2aa9f8f70f028667a31f4
Parents: b60305f 2de3b19
Author: Valentin Kulichenko <valentin.kulichenko@gmail.com>
Authored: Fri Nov 20 16:28:38 2015 -0800
Committer: Valentin Kulichenko <valentin.kulichenko@gmail.com>
Committed: Fri Nov 20 16:28:38 2015 -0800

----------------------------------------------------------------------
 .../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    |   21 +
 .../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 +-
 .../GridCachePartitionExchangeManager.java      |   34 +-
 .../processors/cache/GridCacheUtils.java        |   39 +-
 .../CacheDataStructuresManager.java             |    2 +-
 .../GridFutureRemapTimeoutObject.java           |   72 -
 .../dht/GridClientPartitionTopology.java        |   38 +-
 .../distributed/dht/GridDhtLockFuture.java      |    1 -
 .../dht/GridDhtPartitionTopology.java           |   12 +-
 .../dht/GridDhtPartitionTopologyImpl.java       |   45 +-
 .../distributed/dht/GridDhtTxPrepareFuture.java |    1 -
 .../dht/GridPartitionedGetFuture.java           |   30 +-
 .../colocated/GridDhtColocatedLockFuture.java   |    1 -
 .../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    |    2 -
 ...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 +-
 .../transactions/IgniteTxLocalAdapter.java      |    1 -
 .../cache/transactions/IgniteTxManager.java     |    1 -
 .../IgniteTxRemoteSingleStateImpl.java          |   19 +-
 .../cache/transactions/IgniteTxStateImpl.java   |    1 -
 .../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 |   47 +-
 .../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 -
 .../resources/META-INF/classnames.properties    |    1 +
 .../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 ++
 .../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 +
 .../cache/WaitMapExchangeFinishCallable.java    |    4 +-
 .../IgniteFailoverAbstractBenchmark.java        |    4 +-
 106 files changed, 8090 insertions(+), 3032 deletions(-)
----------------------------------------------------------------------



Mime
View raw message