You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/12/09 11:27:45 UTC
[23/25] ignite git commit: Merge remote-tracking branch
'origin/master'
Merge remote-tracking branch 'origin/master'
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fa358cc1
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fa358cc1
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fa358cc1
Branch: refs/heads/ignite-4371
Commit: fa358cc1b81310cf5ffe5a3da17a3dad842de33f
Parents: b65802b 10ade28
Author: devozerov <vo...@gridgain.com>
Authored: Fri Dec 9 13:10:43 2016 +0300
Committer: devozerov <vo...@gridgain.com>
Committed: Fri Dec 9 13:10:43 2016 +0300
----------------------------------------------------------------------
.../ignite/examples/ExampleNodeStartup.java | 2 +-
.../examples/datagrid/CachePutGetExample.java | 2 +-
.../scalar/examples/ScalarJvmCloudExample.scala | 2 +-
.../rest/ClientMemcachedProtocolSelfTest.java | 4 +-
.../rest/protocols/tcp/MockNioSession.java | 25 +-
.../apache/ignite/IgniteSystemProperties.java | 3 +
.../cache/store/CacheLoadOnlyStoreAdapter.java | 6 +-
.../configuration/IgniteConfiguration.java | 50 +-
.../internal/GridEventConsumeHandler.java | 2 +-
.../ignite/internal/GridJobContextImpl.java | 4 +-
.../ignite/internal/GridKernalContext.java | 9 +
.../ignite/internal/GridKernalContextImpl.java | 16 +-
.../internal/GridPerformanceSuggestions.java | 2 +-
.../org/apache/ignite/internal/GridTopic.java | 5 +-
.../ignite/internal/IgniteInternalFuture.java | 11 +
.../apache/ignite/internal/IgniteKernal.java | 85 +-
.../org/apache/ignite/internal/IgnitionEx.java | 32 +-
.../GridClientConnectionManagerAdapter.java | 1 +
.../client/router/impl/GridTcpRouterImpl.java | 1 +
.../managers/communication/GridIoManager.java | 207 ++-
.../managers/communication/GridIoMessage.java | 13 +
.../communication/GridIoMessageFactory.java | 12 +-
.../communication/IgniteIoTestMessage.java | 235 +++
.../processors/cache/GridCacheAdapter.java | 26 +-
.../processors/cache/GridCacheMessage.java | 7 +
.../processors/cache/GridCacheUtils.java | 35 +
.../processors/cache/IgniteCacheProxy.java | 8 +
.../distributed/GridDistributedLockRequest.java | 5 +
.../GridDistributedTxFinishResponse.java | 6 +
.../GridDistributedUnlockRequest.java | 5 +
.../distributed/dht/GridDhtCacheAdapter.java | 3 +-
.../distributed/dht/GridDhtLockResponse.java | 9 +-
.../dht/atomic/GridDhtAtomicCache.java | 5 +-
.../GridDhtAtomicSingleUpdateRequest.java | 5 +
.../dht/atomic/GridDhtAtomicUpdateRequest.java | 5 +
.../atomic/GridNearAtomicFullUpdateRequest.java | 5 +
.../GridNearAtomicSingleUpdateRequest.java | 5 +
.../distributed/near/GridNearGetRequest.java | 5 +
.../local/atomic/GridLocalAtomicCache.java | 3 +
.../query/GridCacheDistributedQueryManager.java | 2 +-
.../cache/query/GridCacheQueryRequest.java | 6 +-
.../transactions/IgniteTxLocalAdapter.java | 8 +-
.../datastreamer/DataStreamProcessor.java | 22 +-
.../internal/processors/igfs/IgfsContext.java | 4 +-
.../processors/igfs/IgfsDataManager.java | 6 +-
.../internal/processors/igfs/IgfsImpl.java | 2 +-
.../internal/processors/odbc/OdbcProcessor.java | 1 +
.../platform/compute/PlatformCompute.java | 6 +
.../tcp/GridTcpMemcachedNioListener.java | 15 +-
.../protocols/tcp/GridTcpRestNioListener.java | 2 +-
.../rest/protocols/tcp/GridTcpRestProtocol.java | 1 +
.../service/GridServiceProcessor.java | 6 +-
.../ignite/internal/util/IgniteUtils.java | 62 +-
.../ignite/internal/util/StripedExecutor.java | 667 +++++++++
.../util/future/GridFinishedFuture.java | 24 +
.../internal/util/future/GridFutureAdapter.java | 15 +-
.../util/future/GridFutureChainListener.java | 30 +-
.../internal/util/ipc/IpcToNioAdapter.java | 2 +-
.../nio/GridAbstractCommunicationClient.java | 12 +-
.../util/nio/GridCommunicationClient.java | 9 +-
.../nio/GridConnectionBytesVerifyFilter.java | 15 +-
.../util/nio/GridNioAsyncNotifyFilter.java | 10 +-
.../internal/util/nio/GridNioCodecFilter.java | 17 +-
.../ignite/internal/util/nio/GridNioFilter.java | 16 +-
.../internal/util/nio/GridNioFilterAdapter.java | 10 +-
.../internal/util/nio/GridNioFilterChain.java | 14 +-
.../ignite/internal/util/nio/GridNioFuture.java | 4 +-
.../util/nio/GridNioRecoveryDescriptor.java | 124 +-
.../ignite/internal/util/nio/GridNioServer.java | 1404 +++++++++++++++---
.../internal/util/nio/GridNioSession.java | 25 +-
.../internal/util/nio/GridNioSessionImpl.java | 65 +-
.../ignite/internal/util/nio/GridNioWorker.java | 48 +
.../util/nio/GridSelectorNioSessionImpl.java | 221 ++-
.../util/nio/GridShmemCommunicationClient.java | 7 +-
.../util/nio/GridTcpNioCommunicationClient.java | 55 +-
.../internal/util/nio/SessionWriteRequest.java | 85 ++
.../internal/util/nio/ssl/GridNioSslFilter.java | 10 +-
.../util/nio/ssl/GridNioSslHandler.java | 4 +-
.../util/tostring/GridToStringBuilder.java | 2 +-
.../communication/tcp/TcpCommunicationSpi.java | 1340 ++++++++++++-----
.../tcp/TcpCommunicationSpiMBean.java | 40 +
.../ignite/spi/discovery/tcp/ServerImpl.java | 14 +-
.../ignite/stream/socket/SocketStreamer.java | 1 +
.../ignite/thread/IgniteThreadFactory.java | 8 +-
.../IgniteSlowClientDetectionSelfTest.java | 1 +
...unicationBalanceMultipleConnectionsTest.java | 28 +
.../IgniteCommunicationBalanceTest.java | 339 +++++
.../communication/IgniteIoTestMessagesTest.java | 95 ++
.../IgniteVariousConnectionNumberTest.java | 166 +++
.../cache/CrossCacheTxRandomOperationsTest.java | 30 +-
...idAbstractCacheInterceptorRebalanceTest.java | 4 +-
...CacheOffHeapMultiThreadedUpdateSelfTest.java | 6 +-
...eAtomicMessageRecovery10ConnectionsTest.java | 28 +
...cMessageRecoveryNoPairedConnectionsTest.java | 47 +
...acheConnectionRecovery10ConnectionsTest.java | 35 +
.../distributed/IgniteCacheCreatePutTest.java | 2 +-
.../IgniteCacheMessageRecoveryAbstractTest.java | 24 +-
.../IgniteCacheMessageWriteTimeoutTest.java | 17 +-
.../dht/IgniteCacheMultiTxLockSelfTest.java | 6 +-
...erNoStripedPoolMultiNodeFullApiSelfTest.java | 35 +
...edNoStripedPoolMultiNodeFullApiSelfTest.java | 35 +
.../TxDeadlockDetectionNoHangsTest.java | 2 +-
.../TxOptimisticDeadlockDetectionTest.java | 29 +-
.../GridServiceProcessorProxySelfTest.java | 2 +-
.../util/future/GridFutureAdapterSelfTest.java | 122 +-
.../nio/impl/GridNioFilterChainSelfTest.java | 32 +-
.../loadtests/nio/GridNioBenchmarkClient.java | 4 +-
.../p2p/GridP2PRecursionTaskSelfTest.java | 2 +-
.../spi/GridTcpSpiForwardingSelfTest.java | 18 +-
.../GridTcpCommunicationSpiAbstractTest.java | 28 +-
...mmunicationSpiConcurrentConnectSelfTest.java | 82 +-
.../GridTcpCommunicationSpiConfigSelfTest.java | 5 +-
...cpCommunicationSpiMultithreadedSelfTest.java | 23 +-
...dTcpCommunicationSpiRecoveryAckSelfTest.java | 9 +-
...tionSpiRecoveryFailureDetectionSelfTest.java | 1 +
...ationSpiRecoveryNoPairedConnectionsTest.java | 28 +
...GridTcpCommunicationSpiRecoverySelfTest.java | 67 +-
...CommunicationRecoveryAckClosureSelfTest.java | 9 +-
.../junits/GridTestKernalContext.java | 4 +-
.../IgniteCacheFullApiSelfTestSuite.java | 6 +
.../ignite/testsuites/IgniteCacheTestSuite.java | 17 +-
.../IgniteSpiCommunicationSelfTestSuite.java | 2 +
.../hadoop/jobtracker/HadoopJobTracker.java | 4 +-
.../HadoopExternalCommunication.java | 5 +-
.../communication/HadoopIpcToNioAdapter.java | 2 +-
.../communication/HadoopMarshallerFilter.java | 6 +-
.../ignite/stream/kafka/KafkaStreamer.java | 2 +-
.../ignite/tools/classgen/ClassesGenerator.java | 8 +-
.../ignite/yardstick/IgniteBenchmarkUtils.java | 6 +-
.../yardstick/cache/CacheEntryEventProbe.java | 2 +-
.../yardstick/cache/IgniteIoTestBenchmark.java | 73 +
.../io/IgniteIoTestAbstractBenchmark.java | 61 +
.../io/IgniteIoTestSendAllBenchmark.java | 32 +
.../io/IgniteIoTestSendRandomBenchmark.java | 35 +
134 files changed, 5935 insertions(+), 998 deletions(-)
----------------------------------------------------------------------