Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id E3C39200CEB for ; Fri, 7 Jul 2017 11:37:08 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id E2929168B29; Fri, 7 Jul 2017 09:37:08 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 9006E168B42 for ; Fri, 7 Jul 2017 11:37:05 +0200 (CEST) Received: (qmail 79012 invoked by uid 500); 7 Jul 2017 09:37:04 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 78656 invoked by uid 99); 7 Jul 2017 09:37:04 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 07 Jul 2017 09:37:04 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 2E2D4F5539; Fri, 7 Jul 2017 09:37:03 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: vozerov@apache.org To: commits@ignite.apache.org Date: Fri, 07 Jul 2017 09:37:51 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [50/50] [abbrv] ignite git commit: Merge branch 'ignite-2.1' archived-at: Fri, 07 Jul 2017 09:37:09 -0000 Merge branch 'ignite-2.1' Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d1d68023 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d1d68023 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d1d68023 Branch: refs/heads/master Commit: d1d6802378d874b039f775fe787f78c507661bb2 Parents: 651ffc5 31e9d3b Author: devozerov Authored: Fri Jul 7 12:36:13 2017 +0300 Committer: devozerov Committed: Fri Jul 7 12:36:13 2017 +0300 ---------------------------------------------------------------------- .../jdbc2/JdbcAbstractDmlStatementSelfTest.java | 12 + .../jdbc2/JdbcDynamicIndexAbstractSelfTest.java | 2 - .../jdbc2/JdbcPreparedStatementSelfTest.java | 35 + .../jdbc/JdbcPreparedStatementSelfTest.java | 35 + .../JdbcThinDynamicIndexAbstractSelfTest.java | 2 - .../thin/JdbcThinPreparedStatementSelfTest.java | 35 + .../rendezvous/RendezvousAffinityFunction.java | 4 - .../PersistentStoreConfiguration.java | 39 +- .../org/apache/ignite/events/EventType.java | 12 + .../ignite/events/WalSegmentArchivedEvent.java | 62 + .../apache/ignite/internal/GridComponent.java | 4 +- .../ignite/internal/GridPluginComponent.java | 2 +- .../internal/IgniteDiagnosticMessage.java | 12 +- .../IgniteDiagnosticPrepareContext.java | 3 + .../apache/ignite/internal/IgniteKernal.java | 33 +- .../ignite/internal/MarshallerContextImpl.java | 10 +- .../internal/jdbc/JdbcPreparedStatement.java | 6 +- .../internal/jdbc/thin/JdbcThinConnection.java | 7 +- .../jdbc/thin/JdbcThinPreparedStatement.java | 2 - .../internal/jdbc2/JdbcPreparedStatement.java | 12 +- .../internal/managers/GridManagerAdapter.java | 2 +- .../internal/managers/discovery/DiscoCache.java | 17 +- .../discovery/DiscoveryLocalJoinData.java | 104 ++ .../discovery/GridDiscoveryManager.java | 128 +- ...ishSnapshotOperationAckDiscoveryMessage.java | 7 + .../snapshot/SnapshotCheckParameters.java | 75 + .../pagemem/snapshot/SnapshotOperation.java | 26 +- .../pagemem/store/IgnitePageStoreManager.java | 3 +- .../internal/pagemem/wal/record/WALRecord.java | 11 +- .../processors/GridProcessorAdapter.java | 2 +- .../cache/CacheAffinitySharedManager.java | 67 +- .../processors/cache/CacheGroupContext.java | 4 +- .../processors/cache/CacheGroupData.java | 4 +- .../cache/ChangeGlobalStateMessage.java | 120 -- .../processors/cache/ClusterCachesInfo.java | 497 +++++-- .../internal/processors/cache/ClusterState.java | 38 - .../cache/DynamicCacheChangeRequest.java | 52 +- .../processors/cache/ExchangeActions.java | 37 +- .../processors/cache/GridCacheAdapter.java | 62 +- .../processors/cache/GridCacheAttributes.java | 7 + .../processors/cache/GridCacheEntryEx.java | 17 +- .../processors/cache/GridCacheEventManager.java | 2 - .../cache/GridCacheEvictionManager.java | 1 - .../processors/cache/GridCacheIoManager.java | 43 +- .../processors/cache/GridCacheMapEntry.java | 56 +- .../processors/cache/GridCacheMvccManager.java | 9 +- .../GridCachePartitionExchangeManager.java | 441 +++--- .../processors/cache/GridCacheProcessor.java | 211 +-- .../cache/GridCacheSharedContext.java | 65 +- .../cache/GridCacheSharedManager.java | 6 - .../cache/GridCacheSharedManagerAdapter.java | 16 - .../cache/GridDeferredAckMessageSender.java | 3 +- .../cache/IgniteCacheOffheapManagerImpl.java | 7 +- .../processors/cache/PendingDiscoveryEvent.java | 61 + .../processors/cache/StateChangeRequest.java | 77 ++ .../binary/CacheObjectBinaryProcessorImpl.java | 4 +- .../distributed/GridCacheTxRecoveryFuture.java | 1 - .../GridDistributedTxRemoteAdapter.java | 13 +- .../distributed/dht/GridDhtCacheAdapter.java | 1 - .../cache/distributed/dht/GridDhtGetFuture.java | 1 - .../distributed/dht/GridDhtGetSingleFuture.java | 2 - .../dht/GridDhtPartitionTopologyImpl.java | 18 +- .../dht/GridDhtTopologyFutureAdapter.java | 2 +- .../dht/GridDhtTransactionalCacheAdapter.java | 2 +- .../distributed/dht/GridDhtTxFinishFuture.java | 33 +- .../dht/GridPartitionedSingleGetFuture.java | 3 - .../GridNearAtomicAbstractUpdateFuture.java | 1 - .../dht/preloader/GridDhtForceKeysFuture.java | 1 - .../dht/preloader/GridDhtPartitionDemander.java | 2 + .../GridDhtPartitionsExchangeFuture.java | 236 +++- .../preloader/GridDhtPartitionsFullMessage.java | 44 +- .../GridDhtPartitionsSingleMessage.java | 38 +- .../dht/preloader/GridDhtPreloader.java | 2 +- .../distributed/near/GridNearGetFuture.java | 2 - .../near/GridNearTxFinishFuture.java | 2 +- .../near/GridNearTxPrepareRequest.java | 1 - .../cache/persistence/DbCheckpointListener.java | 16 +- .../GridCacheDatabaseSharedManager.java | 115 +- .../persistence/GridCacheOffheapManager.java | 46 +- .../IgniteCacheDatabaseSharedManager.java | 74 +- .../persistence/IgniteCacheSnapshotManager.java | 20 +- .../persistence/file/FilePageStoreManager.java | 14 +- .../persistence/freelist/FreeListImpl.java | 11 +- .../persistence/tree/io/TrackingPageIO.java | 12 +- .../wal/AbstractWalRecordsIterator.java | 287 ++++ .../persistence/wal/ByteBufferExpander.java | 64 + .../cache/persistence/wal/FileInput.java | 36 +- .../cache/persistence/wal/FileWALPointer.java | 4 +- .../wal/FileWriteAheadLogManager.java | 594 ++++---- .../cache/persistence/wal/RecordSerializer.java | 5 + .../persistence/wal/SegmentArchiveResult.java | 61 + .../persistence/wal/SegmentEofException.java | 3 +- .../wal/reader/IgniteWalIteratorFactory.java | 102 ++ .../wal/reader/StandaloneGridKernalContext.java | 499 +++++++ ...ndaloneIgniteCacheDatabaseSharedManager.java | 30 + .../reader/StandaloneWalRecordsIterator.java | 258 ++++ .../wal/serializer/RecordV1Serializer.java | 45 +- .../query/GridCacheDistributedQueryManager.java | 4 +- .../store/GridCacheStoreManagerAdapter.java | 2 +- .../cache/transactions/IgniteTxAdapter.java | 28 +- .../cache/transactions/IgniteTxHandler.java | 2 +- .../transactions/IgniteTxLocalAdapter.java | 12 +- .../cache/version/GridCacheVersionManager.java | 6 - .../cacheobject/IgniteCacheObjectProcessor.java | 5 - .../IgniteCacheObjectProcessorImpl.java | 5 - .../cluster/ChangeGlobalStateFinishMessage.java | 86 ++ .../cluster/ChangeGlobalStateMessage.java | 140 ++ .../processors/cluster/ClusterProcessor.java | 3 +- .../cluster/DiscoveryDataClusterState.java | 157 +++ .../cluster/GridClusterStateProcessor.java | 1129 ++++++--------- .../cluster/IgniteChangeGlobalStateSupport.java | 3 +- .../datastreamer/DataStreamProcessor.java | 3 +- .../datastreamer/DataStreamerImpl.java | 14 +- .../datastructures/DataStructuresProcessor.java | 6 +- .../datastructures/GridCacheAtomicLongImpl.java | 2 +- .../GridCacheAtomicReferenceImpl.java | 2 +- .../GridCacheAtomicSequenceImpl.java | 2 +- .../GridCacheAtomicStampedImpl.java | 2 +- .../GridCacheCountDownLatchImpl.java | 2 +- .../datastructures/GridCacheLockImpl.java | 4 +- .../datastructures/GridCacheQueueAdapter.java | 1 - .../datastructures/GridCacheSemaphoreImpl.java | 2 +- .../datastructures/GridCacheSetImpl.java | 1 - .../internal/processors/igfs/IgfsImpl.java | 2 - .../internal/processors/igfs/IgfsProcessor.java | 2 +- .../GridMarshallerMappingProcessor.java | 16 +- .../utils/PlatformConfigurationUtils.java | 8 +- .../processors/query/GridQueryProcessor.java | 8 +- .../processors/rest/GridRestProcessor.java | 2 +- .../cluster/GridChangeStateCommandHandler.java | 2 +- .../service/GridServiceProcessor.java | 33 +- .../processors/service/GridServiceProxy.java | 9 +- .../processors/task/GridTaskProcessor.java | 2 +- .../visor/cache/VisorCacheConfiguration.java | 11 +- .../visor/node/VisorBasicConfiguration.java | 2 +- .../node/VisorMemoryPolicyConfiguration.java | 2 +- .../visor/node/VisorNodeDataCollectorJob.java | 32 +- .../node/VisorNodeDataCollectorJobResult.java | 73 +- .../visor/node/VisorNodeDataCollectorTask.java | 14 +- .../node/VisorNodeDataCollectorTaskResult.java | 28 +- .../visor/node/VisorPersistenceMetrics.java | 214 +++ .../visor/service/VisorServiceTask.java | 10 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 12 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 11 +- .../org.apache.ignite.plugin.PluginProvider | 3 +- .../internal/TestRecordingCommunicationSpi.java | 10 + ...GridManagerLocalMessageListenerSelfTest.java | 4 +- ...unicationBalanceMultipleConnectionsTest.java | 5 + .../cache/GridCacheAbstractMetricsSelfTest.java | 24 - .../processors/cache/GridCacheTestEntryEx.java | 10 +- .../cache/IgniteActiveClusterTest.java | 182 --- .../cache/IgniteCacheAbstractTest.java | 17 + .../processors/cache/IgniteCacheGroupsTest.java | 60 + .../IgniteClusterActivateDeactivateTest.java | 1284 ++++++++++++++++++ ...erActivateDeactivateTestWithPersistence.java | 197 +++ .../IgniteDaemonNodeMarshallerCacheTest.java | 10 - ...iteMarshallerCacheClassNameConflictTest.java | 11 +- .../IgniteMarshallerCacheFSRestoreTest.java | 217 +++ .../IgniteSemaphoreAbstractSelfTest.java | 17 +- ...titionEvictionDuringReadThroughSelfTest.java | 160 +++ ...acheStoreSessionWriteBehindAbstractTest.java | 62 +- ...TxStoreSessionWriteBehindCoalescingTest.java | 88 ++ ...IgnitePersistentStoreDataStructuresTest.java | 2 + .../wal/IgniteWalHistoryReservationsTest.java | 2 +- .../db/wal/IgniteWalRecoveryTest.java | 100 +- .../db/wal/reader/IgniteWalReaderTest.java | 385 ++++++ .../db/wal/reader/MockWalIteratorFactory.java | 114 ++ .../pagemem/NoOpPageStoreManager.java | 12 +- .../persistence/pagemem/NoOpWALManager.java | 23 +- .../AbstractNodeJoinTemplate.java | 149 +- .../IgniteChangeGlobalStateAbstractTest.java | 65 +- .../IgniteChangeGlobalStateCacheTest.java | 2 +- ...IgniteChangeGlobalStateDataStreamerTest.java | 5 +- ...gniteChangeGlobalStateDataStructureTest.java | 6 +- .../IgniteChangeGlobalStateFailOverTest.java | 26 +- .../IgniteChangeGlobalStateTest.java | 158 +-- .../IgniteStandByClusterTest.java | 181 ++- .../join/JoinActiveNodeToActiveCluster.java | 62 +- ...ctiveNodeToActiveClusterWithPersistence.java | 17 + .../IgniteStandByClientReconnectTest.java | 13 +- ...eStandByClientReconnectToNewClusterTest.java | 13 +- ...ClientWriteBehindStoreNonCoalescingTest.java | 30 +- .../datastreamer/DataStreamerImplSelfTest.java | 123 +- .../GridServiceProcessorProxySelfTest.java | 65 + ...cpCommunicationSpiMultithreadedSelfTest.java | 2 +- .../testframework/junits/GridAbstractTest.java | 4 +- .../junits/common/GridCommonAbstractTest.java | 3 + .../ignite/testsuites/IgniteBasicTestSuite.java | 2 + .../testsuites/IgniteCacheTestSuite4.java | 2 + .../testsuites/IgniteCacheTestSuite5.java | 3 + .../ignite/testsuites/IgnitePdsTestSuite2.java | 9 +- .../testsuites/IgniteStandByClusterSuite.java | 5 +- .../processors/hadoop/HadoopProcessor.java | 4 +- ...ileSystemShmemExternalDualAsyncSelfTest.java | 5 + .../processors/query/h2/opt/GridH2Table.java | 49 +- .../cache/IgniteCacheAbstractQuerySelfTest.java | 3 +- .../DynamicIndexAbstractConcurrentSelfTest.java | 81 +- .../cache/index/H2DynamicTableSelfTest.java | 53 + .../Cache/CacheAbstractTest.cs | 26 +- .../Cache/CacheConfigurationTest.cs | 21 + .../Cache/PersistentStoreTest.cs | 75 +- .../Cache/Store/CacheStoreTest.cs | 21 +- .../Apache.Ignite.Core.Tests/EventsTest.cs | 19 +- .../Cache/Configuration/CacheConfiguration.cs | 75 +- .../Apache.Ignite.Core/Common/JavaException.cs | 15 +- .../Apache.Ignite.Core/IgniteConfiguration.cs | 7 +- .../Impl/Events/RemoteListenEventFilter.cs | 3 + .../Apache.Ignite.Core/Impl/ExceptionUtils.cs | 5 +- .../spark/JavaEmbeddedIgniteRDDSelfTest.java | 5 + .../frontend/app/data/pom-dependencies.json | 5 +- .../frontend/app/filters/duration.filter.js | 2 +- .../configuration/generator/Maven.service.js | 21 +- .../states/configuration/caches/affinity.pug | 18 +- .../states/configuration/caches/general.pug | 50 +- .../yardstick/IgniteBenchmarkArguments.java | 46 + .../cache/IgniteStreamerBenchmark.java | 234 ++++ 216 files changed, 9165 insertions(+), 3050 deletions(-) ----------------------------------------------------------------------