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-2.0 Commit: fa358cc1b81310cf5ffe5a3da17a3dad842de33f Parents: b65802b 10ade28 Author: devozerov <[email protected]> Authored: Fri Dec 9 13:10:43 2016 +0300 Committer: devozerov <[email protected]> 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(-) ----------------------------------------------------------------------
