You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2017/04/13 13:41:08 UTC
[01/22] ignite git commit: Merge remote-tracking branch
'origin/ignite-3477-master' into ignite-3477-master-apache
Repository: ignite
Updated Branches:
refs/heads/ignite-3477-master 431058329 -> 00d63a8a9
Merge remote-tracking branch 'origin/ignite-3477-master' into ignite-3477-master-apache
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/55b28831
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/55b28831
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/55b28831
Branch: refs/heads/ignite-3477-master
Commit: 55b288310a419dd0ad53f9efe93fbb772a1cc0a1
Parents: a7afb7f 73b6b66
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Mon Apr 10 15:01:29 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Mon Apr 10 15:01:29 2017 +0300
----------------------------------------------------------------------
.../MarshallerContextLockingSelfTest.java | 33 +-
.../hibernate/HibernateKeyTransformer.java | 2 +-
.../cache/hibernate/HibernateKeyWrapper.java | 2 +-
.../cache/GridCacheOffHeapAndSwapSelfTest.java | 453 -------------------
.../query/h2/opt/GridH2TableSelfTest.java | 2 +
.../query/h2/sql/GridQueryParsingTest.java | 6 +-
.../IgniteCacheWithIndexingTestSuite.java | 2 -
7 files changed, 38 insertions(+), 462 deletions(-)
----------------------------------------------------------------------
[18/22] ignite git commit: Merge remote-tracking branch
'professional/ignite-3477-master' into ignite-3477-master
Posted by ag...@apache.org.
Merge remote-tracking branch 'professional/ignite-3477-master' into ignite-3477-master
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c31de278
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c31de278
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c31de278
Branch: refs/heads/ignite-3477-master
Commit: c31de2783d66eec7ae7237fc6ca1fbbfa7c1fb3b
Parents: 81a0f9a a563ba0
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Thu Apr 13 16:16:22 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Thu Apr 13 16:16:22 2017 +0300
----------------------------------------------------------------------
.../java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
[03/22] ignite git commit: Merge remote-tracking branch
'origin/ignite-3477-master' into ignite-3477-master-apache
Posted by ag...@apache.org.
Merge remote-tracking branch 'origin/ignite-3477-master' into ignite-3477-master-apache
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/4ae084d0
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/4ae084d0
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/4ae084d0
Branch: refs/heads/ignite-3477-master
Commit: 4ae084d047edd3b7dea73c66a373e37eb4cde876
Parents: 1a7b91d 7eb1234
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Tue Apr 11 15:25:55 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Tue Apr 11 15:25:55 2017 +0300
----------------------------------------------------------------------
.../communication/GridIoMessageFactory.java | 8 +-
.../GridCachePartitionExchangeManager.java | 6 +-
.../processors/cache/GridCachePreloader.java | 4 +-
.../cache/GridCachePreloaderAdapter.java | 4 +-
.../distributed/dht/GridDhtLocalPartition.java | 7 +-
.../dht/preloader/GridDhtPartitionDemander.java | 2 +-
.../dht/preloader/GridDhtPartitionSupplier.java | 8 +-
.../GridDhtPartitionSupplyMessage.java | 103 +++--
.../GridDhtPartitionSupplyMessageV2.java | 422 -------------------
.../dht/preloader/GridDhtPreloader.java | 2 +-
.../utils/PlatformConfigurationUtils.java | 3 +-
.../resources/META-INF/classnames.properties | 1 -
.../cache/ClusterStateAbstractTest.java | 10 +-
.../CacheLateAffinityAssignmentTest.java | 6 +-
.../IgniteCacheReadFromBackupTest.java | 6 +-
.../atomic/IgniteCacheAtomicProtocolTest.java | 3 +-
.../processors/query/h2/IgniteH2Indexing.java | 15 +-
.../processors/query/h2/opt/GridH2Table.java | 15 +-
.../cpp/core-test/config/cache-identity-32.xml | 50 +++
.../core-test/config/cache-identity-default.xml | 154 +++++++
.../cpp/core-test/config/cache-identity.xml | 124 +-----
.../cpp/core-test/config/cache-store-32.xml | 50 +++
.../core-test/config/cache-store-default.xml | 71 ++++
.../cpp/core-test/config/cache-store.xml | 41 +-
.../cpp/core-test/project/vs/core-test.vcxproj | 8 +
.../project/vs/core-test.vcxproj.filters | 12 +
.../src/binary_identity_resolver_test.cpp | 8 +
.../cpp/core-test/src/binary_object_test.cpp | 8 +
.../cpp/core-test/src/cache_invoke_test.cpp | 4 +
.../cpp/core-test/src/cache_store_test.cpp | 11 +-
.../cpp/core-test/src/cluster_test.cpp | 4 +
.../cpp/core-test/src/continuous_query_test.cpp | 5 +
.../Affinity/AffinityFunctionSpringTest.cs | 6 +-
.../Cache/Affinity/AffinityFunctionTest.cs | 92 +---
.../Cache/CacheConfigurationTest.cs | 23 +-
.../Config/Cache/Affinity/affinity-function.xml | 4 +-
.../IgniteConfigurationSerializerTest.cs | 8 +-
.../IgniteConfigurationTest.cs | 2 -
.../Apache.Ignite.Core.csproj | 2 -
.../Cache/Affinity/Fair/FairAffinityFunction.cs | 32 --
.../Cache/Affinity/Fair/Package-Info.cs | 26 --
.../Cache/Affinity/IAffinityFunction.cs | 3 +-
.../Cache/Configuration/CacheConfiguration.cs | 81 +---
.../IgniteConfigurationSection.xsd | 29 --
.../Affinity/AffinityFunctionSerializer.cs | 18 +-
45 files changed, 513 insertions(+), 988 deletions(-)
----------------------------------------------------------------------
[08/22] ignite git commit: Merge remote-tracking branch
'origin/ignite-3477-master' into ignite-3477-master-apache
Posted by ag...@apache.org.
Merge remote-tracking branch 'origin/ignite-3477-master' into ignite-3477-master-apache
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3e5e1f01
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3e5e1f01
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3e5e1f01
Branch: refs/heads/ignite-3477-master
Commit: 3e5e1f01af8eb68cd69d7c1922c07fe367777ae7
Parents: 81e7538 7883668
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Wed Apr 12 15:07:44 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Wed Apr 12 15:07:44 2017 +0300
----------------------------------------------------------------------
.../configuration/DataPageEvictionMode.java | 16 +++-
.../MemoryPolicyConfiguration.java | 18 ++--
.../processors/cache/GridCacheContext.java | 2 -
.../distributed/dht/GridDhtLocalPartition.java | 2 +-
.../dht/preloader/GridDhtPreloader.java | 6 +-
.../core/src/test/config/spring-multicache.xml | 16 ++++
.../IgniteCacheTopologySafeGetSelfTest.java | 2 +-
.../paged/PageEvictionAbstractTest.java | 4 +-
.../paged/PageEvictionMultinodeTest.java | 4 +-
.../paged/PageEvictionReadThroughTest.java | 2 +-
.../cpp/core-test/src/continuous_query_test.cpp | 11 ++-
.../core/include/ignite/impl/module_manager.h | 26 ++++++
.../examples/include/ignite/examples/person.h | 1 -
.../Cache/CacheMetricsTest.cs | 86 +++++++++-----------
.../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 80 ------------------
.../Impl/Cache/CacheMetricsImpl.cs | 60 --------------
16 files changed, 125 insertions(+), 211 deletions(-)
----------------------------------------------------------------------
[12/22] ignite git commit: ignite-3477-master add latch in test
Posted by ag...@apache.org.
ignite-3477-master add latch in test
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/355efcd0
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/355efcd0
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/355efcd0
Branch: refs/heads/ignite-3477-master
Commit: 355efcd06ec765b78453b0a6d8b7da201ed3596d
Parents: 10c0364
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Wed Apr 12 17:24:11 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Wed Apr 12 17:24:11 2017 +0300
----------------------------------------------------------------------
...lerCacheClientRequestsMappingOnMissTest.java | 94 +++++++++++++++-----
1 file changed, 71 insertions(+), 23 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/355efcd0/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteMarshallerCacheClientRequestsMappingOnMissTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteMarshallerCacheClientRequestsMappingOnMissTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteMarshallerCacheClientRequestsMappingOnMissTest.java
index d0e863e..362d6a1 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteMarshallerCacheClientRequestsMappingOnMissTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteMarshallerCacheClientRequestsMappingOnMissTest.java
@@ -24,6 +24,8 @@ import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.Map;
import java.util.UUID;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
import org.apache.ignite.Ignite;
import org.apache.ignite.configuration.CacheConfiguration;
@@ -151,94 +153,130 @@ public class IgniteMarshallerCacheClientRequestsMappingOnMissTest extends GridCo
*/
public void testNoNodesDieOnRequest() throws Exception {
Ignite srv1 = startGrid(0);
+
replaceWithCountingMappingRequestListener(((GridKernalContext)U.field(srv1, "ctx")).io());
Ignite srv2 = startGrid(1);
+
replaceWithCountingMappingRequestListener(((GridKernalContext)U.field(srv2, "ctx")).io());
Ignite srv3 = startGrid(2);
+
replaceWithCountingMappingRequestListener(((GridKernalContext)U.field(srv3, "ctx")).io());
- srv3.cache(null).put(1, new Organization(1, "Microsoft", "One Microsoft Way Redmond, WA 98052-6399, USA"));
+ srv3.cache(null).put(
+ 1, new Organization(1, "Microsoft", "One Microsoft Way Redmond, WA 98052-6399, USA"));
clientMode = true;
Ignite cl1 = startGrid(4);
+
cl1.cache(null).get(1);
- assertEquals("Expected requests count is 1, actual is " + mappingReqsCounter.get(),
- 1,
- mappingReqsCounter.get());
+ int result = mappingReqsCounter.get();
+
+ assertEquals("Expected requests count is 1, actual is " + result, 1, result);
}
/**
*
*/
public void testOneNodeDiesOnRequest() throws Exception {
+ CountDownLatch nodeStopLatch = new CountDownLatch(1);
+
Ignite srv1 = startGrid(0);
- replaceWithStoppingMappingRequestListener(((GridKernalContext)U.field(srv1, "ctx")).io(), 0);
+
+ replaceWithStoppingMappingRequestListener(
+ ((GridKernalContext)U.field(srv1, "ctx")).io(), 0, nodeStopLatch);
Ignite srv2 = startGrid(1);
+
replaceWithCountingMappingRequestListener(((GridKernalContext)U.field(srv2, "ctx")).io());
Ignite srv3 = startGrid(2);
+
replaceWithCountingMappingRequestListener(((GridKernalContext)U.field(srv3, "ctx")).io());
- srv3.cache(null).put(1, new Organization(1, "Microsoft", "One Microsoft Way Redmond, WA 98052-6399, USA"));
+ srv3.cache(null).put(
+ 1, new Organization(1, "Microsoft", "One Microsoft Way Redmond, WA 98052-6399, USA"));
clientMode = true;
Ignite cl1 = startGrid(4);
+
cl1.cache(null).get(1);
- assertEquals("Expected requests count is 2, actual is " + mappingReqsCounter.get(),
- 2,
- mappingReqsCounter.get());
+ nodeStopLatch.await(5_000, TimeUnit.MILLISECONDS);
+
+ int result = mappingReqsCounter.get();
+
+ assertEquals("Expected requests count is 2, actual is " + result, 2, result);
}
/**
*
*/
public void testTwoNodesDieOnRequest() throws Exception {
+ CountDownLatch nodeStopLatch = new CountDownLatch(2);
+
Ignite srv1 = startGrid(0);
- replaceWithStoppingMappingRequestListener(((GridKernalContext)U.field(srv1, "ctx")).io(), 0);
+
+ replaceWithStoppingMappingRequestListener(
+ ((GridKernalContext)U.field(srv1, "ctx")).io(), 0, nodeStopLatch);
Ignite srv2 = startGrid(1);
- replaceWithStoppingMappingRequestListener(((GridKernalContext)U.field(srv2, "ctx")).io(), 1);
+
+ replaceWithStoppingMappingRequestListener(
+ ((GridKernalContext)U.field(srv2, "ctx")).io(), 1, nodeStopLatch);
Ignite srv3 = startGrid(2);
+
replaceWithCountingMappingRequestListener(((GridKernalContext)U.field(srv3, "ctx")).io());
- srv3.cache(null).put(1, new Organization(1, "Microsoft", "One Microsoft Way Redmond, WA 98052-6399, USA"));
+ srv3.cache(null).put(
+ 1, new Organization(1, "Microsoft", "One Microsoft Way Redmond, WA 98052-6399, USA"));
clientMode = true;
Ignite cl1 = startGrid(4);
+
cl1.cache(null).get(1);
- assertEquals("Expected requests count is 3, actual is " + mappingReqsCounter.get(),
- 3,
- mappingReqsCounter.get());
+ nodeStopLatch.await(5_000, TimeUnit.MILLISECONDS);
+
+ int result = mappingReqsCounter.get();
+
+ assertEquals("Expected requests count is 3, actual is " + result, 3, result);
}
/**
*
*/
public void testAllNodesDieOnRequest() throws Exception {
+ CountDownLatch nodeStopLatch = new CountDownLatch(3);
+
Ignite srv1 = startGrid(0);
- replaceWithStoppingMappingRequestListener(((GridKernalContext)U.field(srv1, "ctx")).io(), 0);
+
+ replaceWithStoppingMappingRequestListener(
+ ((GridKernalContext)U.field(srv1, "ctx")).io(), 0, nodeStopLatch);
Ignite srv2 = startGrid(1);
- replaceWithStoppingMappingRequestListener(((GridKernalContext)U.field(srv2, "ctx")).io(), 1);
+
+ replaceWithStoppingMappingRequestListener(
+ ((GridKernalContext)U.field(srv2, "ctx")).io(), 1, nodeStopLatch);
Ignite srv3 = startGrid(2);
- replaceWithStoppingMappingRequestListener(((GridKernalContext)U.field(srv3, "ctx")).io(), 2);
- srv3.cache(null).put(1, new Organization(1, "Microsoft", "One Microsoft Way Redmond, WA 98052-6399, USA"));
+ replaceWithStoppingMappingRequestListener(
+ ((GridKernalContext)U.field(srv3, "ctx")).io(), 2, nodeStopLatch);
+
+ srv3.cache(null).put(
+ 1, new Organization(1, "Microsoft", "One Microsoft Way Redmond, WA 98052-6399, USA"));
clientMode = true;
Ignite cl1 = startGrid(4);
+
try {
cl1.cache(null).get(1);
}
@@ -246,9 +284,11 @@ public class IgniteMarshallerCacheClientRequestsMappingOnMissTest extends GridCo
e.printStackTrace();
}
- assertEquals("Expected requests count is 3, actual is " + mappingReqsCounter.get(),
- 3,
- mappingReqsCounter.get());
+ nodeStopLatch.await(5_000, TimeUnit.MILLISECONDS);
+
+ int result = mappingReqsCounter.get();
+
+ assertEquals("Expected requests count is 3, actual is " + result, 3, result);
}
/**
@@ -262,6 +302,7 @@ public class IgniteMarshallerCacheClientRequestsMappingOnMissTest extends GridCo
GridMessageListener wrapper = new GridMessageListener() {
@Override public void onMessage(UUID nodeId, Object msg) {
mappingReqsCounter.incrementAndGet();
+
delegate.onMessage(nodeId, msg);
}
};
@@ -272,7 +313,11 @@ public class IgniteMarshallerCacheClientRequestsMappingOnMissTest extends GridCo
/**
*
*/
- private void replaceWithStoppingMappingRequestListener(GridIoManager ioMgr, final int nodeIdToStop) {
+ private void replaceWithStoppingMappingRequestListener(
+ GridIoManager ioMgr,
+ final int nodeIdToStop,
+ final CountDownLatch latch
+ ) {
ioMgr.removeMessageListener(GridTopic.TOPIC_MAPPING_MARSH);
ioMgr.addMessageListener(GridTopic.TOPIC_MAPPING_MARSH, new GridMessageListener() {
@@ -280,6 +325,9 @@ public class IgniteMarshallerCacheClientRequestsMappingOnMissTest extends GridCo
new Thread(new Runnable() {
@Override public void run() {
mappingReqsCounter.incrementAndGet();
+
+ latch.countDown();
+
stopGrid(nodeIdToStop, true);
}
}).start();
[17/22] ignite git commit: ignite-3477-master fix
IgniteCacheQueryNodeRestartDistributedJoinSelfTest
Posted by ag...@apache.org.
ignite-3477-master fix IgniteCacheQueryNodeRestartDistributedJoinSelfTest
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/81a0f9a7
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/81a0f9a7
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/81a0f9a7
Branch: refs/heads/ignite-3477-master
Commit: 81a0f9a711e5893f4ae172b9e49b65d191b179a1
Parents: 6bb4c81
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Thu Apr 13 16:15:43 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Thu Apr 13 16:15:43 2017 +0300
----------------------------------------------------------------------
...cheQueryNodeRestartDistributedJoinSelfTest.java | 17 ++++++++++++++++-
1 file changed, 16 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/81a0f9a7/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartDistributedJoinSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartDistributedJoinSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartDistributedJoinSelfTest.java
index 8367b2c..4f20078 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartDistributedJoinSelfTest.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/IgniteCacheQueryNodeRestartDistributedJoinSelfTest.java
@@ -36,6 +36,21 @@ import java.util.concurrent.atomic.AtomicIntegerArray;
* Test for distributed queries with node restarts.
*/
public class IgniteCacheQueryNodeRestartDistributedJoinSelfTest extends IgniteCacheQueryAbstractDistributedJoinSelfTest {
+ /** Total nodes. */
+ private int totalNodes = 6;
+
+ /** {@inheritDoc} */
+ @Override protected void beforeTestsStarted() throws Exception {
+ super.beforeTestsStarted();
+
+ if (totalNodes > GRID_CNT) {
+ for (int i = GRID_CNT; i < totalNodes; i++)
+ startGrid(i);
+ }
+ else
+ totalNodes = GRID_CNT;
+ }
+
/**
* @throws Exception If failed.
*/
@@ -61,7 +76,7 @@ public class IgniteCacheQueryNodeRestartDistributedJoinSelfTest extends IgniteCa
final int nodeLifeTime = 4000;
final int logFreq = 100;
- final AtomicIntegerArray locks = new AtomicIntegerArray(GRID_CNT);
+ final AtomicIntegerArray locks = new AtomicIntegerArray(totalNodes);
SqlFieldsQuery qry0 ;
[02/22] ignite git commit: Merge remote-tracking branch
'origin/ignite-3477-master' into ignite-3477-master-apache
Posted by ag...@apache.org.
Merge remote-tracking branch 'origin/ignite-3477-master' into ignite-3477-master-apache
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1a7b91d6
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1a7b91d6
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1a7b91d6
Branch: refs/heads/ignite-3477-master
Commit: 1a7b91d6e2a45d6869eaa79a213d414db6c0f5d6
Parents: 55b2883 8122099
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Tue Apr 11 13:10:08 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Tue Apr 11 13:10:08 2017 +0300
----------------------------------------------------------------------
DEVNOTES.txt | 3 -
assembly/dependencies-fabric-lgpl.xml | 3 -
assembly/dependencies-fabric.xml | 4 +-
assembly/dependencies-schema-import.xml | 57 -
assembly/libs/README.txt | 1 +
assembly/release-base.xml | 2 -
assembly/release-fabric-base.xml | 9 -
assembly/release-schema-import.xml | 50 -
bin/ignite-schema-import.bat | 110 -
bin/ignite-schema-import.sh | 87 -
examples/README-LGPL.txt | 4 +-
examples/README.txt | 2 -
examples/pom-standalone-lgpl.xml | 1 -
examples/pom-standalone.xml | 1 -
examples/pom.xml | 1 -
examples/schema-import/README.txt | 38 -
examples/schema-import/bin/db-init.sql | 28 -
examples/schema-import/bin/h2-server.bat | 80 -
examples/schema-import/bin/h2-server.sh | 66 -
.../schema-import/bin/schema-import.properties | 28 -
examples/schema-import/pom-standalone.xml | 90 -
examples/schema-import/pom.xml | 101 -
.../org/apache/ignite/schema/CacheConfig.java | 36 -
.../java/org/apache/ignite/schema/Demo.java | 134 --
.../java/org/apache/ignite/schema/DemoNode.java | 38 -
.../ignite/schema/H2DataSourceFactory.java | 35 -
.../java/org/apache/ignite/schema/Person.java | 44 -
.../org/apache/ignite/schema/PersonKey.java | 37 -
.../JettyRestProcessorAbstractSelfTest.java | 3 +-
.../org/apache/ignite/IgniteFileSystem.java | 26 +-
.../apache/ignite/cache/CacheMemoryMode.java | 63 -
.../org/apache/ignite/cache/CachePeekMode.java | 5 +-
.../affinity/fair/FairAffinityFunction.java | 1159 ----------
.../cache/affinity/fair/package-info.java | 21 -
.../configuration/CacheConfiguration.java | 309 +--
.../configuration/CollectionConfiguration.java | 16 -
.../configuration/DataPageEvictionMode.java | 32 +
.../configuration/FileSystemConfiguration.java | 6 +-
.../configuration/IgniteConfiguration.java | 4 +-
.../MemoryPolicyConfiguration.java | 70 +
.../configuration/NearCacheConfiguration.java | 57 +-
.../ignite/internal/IgniteEventsImpl.java | 8 +-
.../org/apache/ignite/internal/IgnitionEx.java | 4 +-
.../binary/builder/BinaryObjectBuilderImpl.java | 36 +-
.../communication/GridIoMessageFactory.java | 12 -
.../eventstorage/GridEventStorageManager.java | 12 +-
.../ignite/internal/pagemem/PageSupport.java | 10 +
.../pagemem/impl/PageMemoryNoStoreImpl.java | 8 +
.../processors/cache/CacheEvictionManager.java | 15 -
.../processors/cache/CacheMetricsImpl.java | 11 +-
.../cache/CacheOffheapEvictionManager.java | 21 +-
.../processors/cache/GridCacheAdapter.java | 101 +-
.../processors/cache/GridCacheAtomicFuture.java | 2 +-
.../processors/cache/GridCacheAttributes.java | 14 -
.../cache/GridCacheConcurrentMap.java | 7 +-
.../cache/GridCacheConcurrentMapImpl.java | 221 +-
.../processors/cache/GridCacheEntryEx.java | 5 +-
.../cache/GridCacheEvictionManager.java | 1757 +--------------
.../cache/GridCacheEvictionRequest.java | 248 --
.../cache/GridCacheEvictionResponse.java | 225 --
.../processors/cache/GridCacheIoManager.java | 14 -
.../cache/GridCacheLocalConcurrentMap.java | 54 +
.../processors/cache/GridCacheMapEntry.java | 46 +-
.../processors/cache/GridCacheMvccManager.java | 84 +-
.../processors/cache/GridCacheProcessor.java | 21 +-
.../processors/cache/GridCacheUtils.java | 8 -
.../cache/GridDeferredAckMessageSender.java | 11 +-
.../processors/cache/GridNoStorageCacheMap.java | 1 +
.../cache/IgniteCacheOffheapManagerImpl.java | 79 +-
.../processors/cache/database/CacheDataRow.java | 5 +
.../cache/database/CacheDataRowAdapter.java | 116 +-
.../IgniteCacheDatabaseSharedManager.java | 126 +-
.../processors/cache/database/MemoryPolicy.java | 19 +-
.../evict/FairFifoPageEvictionTracker.java | 74 +
.../database/evict/NoOpPageEvictionTracker.java | 50 +
.../evict/PageAbstractEvictionTracker.java | 243 ++
.../database/evict/PageEvictionTracker.java | 52 +
.../evict/Random2LruPageEvictionTracker.java | 180 ++
.../evict/RandomLruPageEvictionTracker.java | 157 ++
.../cache/database/freelist/FreeListImpl.java | 62 +-
.../cache/database/tree/io/DataPageIO.java | 110 +-
.../GridDistributedCacheAdapter.java | 6 +
.../dht/GridCachePartitionedConcurrentMap.java | 15 +-
.../distributed/dht/GridDhtCacheAdapter.java | 29 +-
.../distributed/dht/GridDhtLocalPartition.java | 315 +--
.../dht/GridDhtPartitionTopologyImpl.java | 2 +-
.../GridDhtAtomicAbstractUpdateFuture.java | 4 +-
.../dht/atomic/GridDhtAtomicCache.java | 2 +
.../GridNearAtomicAbstractUpdateFuture.java | 2 +-
.../GridNearAtomicSingleUpdateFuture.java | 21 +-
.../dht/atomic/GridNearAtomicUpdateFuture.java | 23 +-
.../distributed/near/GridNearCacheAdapter.java | 21 +-
.../cache/distributed/near/GridNearTxLocal.java | 2 +
.../distributed/near/GridNearTxRemote.java | 4 +-
.../local/atomic/GridLocalAtomicCache.java | 6 +-
.../cache/transactions/IgniteTxHandler.java | 2 +-
.../cache/transactions/IgniteTxManager.java | 2 +-
.../cacheobject/IgniteCacheObjectProcessor.java | 7 -
.../IgniteCacheObjectProcessorImpl.java | 16 -
.../datastructures/DataStructuresProcessor.java | 1 -
.../internal/processors/igfs/IgfsAsyncImpl.java | 8 +-
.../internal/processors/igfs/IgfsImpl.java | 20 +-
.../utils/PlatformConfigurationUtils.java | 85 +-
.../org/apache/ignite/internal/util/F0.java | 196 +-
.../ignite/internal/util/lang/GridFunc.java | 620 +----
.../visor/cache/VisorCacheConfiguration.java | 1 -
.../cache/VisorCacheEvictionConfiguration.java | 55 -
.../cache/VisorCacheQueryConfiguration.java | 1 -
.../visor/igfs/VisorIgfsFormatTask.java | 2 +-
.../visor/node/VisorIgfsConfiguration.java | 2 +-
.../deployment/local/LocalDeploymentSpi.java | 5 +-
.../spi/eventstorage/NoopEventStorageSpi.java | 53 +
.../test/config/store/jdbc/ignite-jdbc-type.xml | 2 +-
.../GridCacheAffinityBackupsSelfTest.java | 20 +-
.../ignite/IgniteCacheAffinitySelfTest.java | 12 +-
.../affinity/AffinityClientNodeSelfTest.java | 15 +-
.../affinity/AffinityHistoryCleanupTest.java | 3 +-
.../fair/FairAffinityDynamicCacheSelfTest.java | 86 -
...airAffinityFunctionBackupFilterSelfTest.java | 44 -
...ffinityFunctionExcludeNeighborsSelfTest.java | 31 -
.../fair/FairAffinityFunctionNodesSelfTest.java | 247 --
.../fair/FairAffinityFunctionSelfTest.java | 31 -
.../affinity/fair/FairAffinityNodesRestart.java | 130 --
.../local/LocalAffinityFunctionTest.java | 4 +-
.../cache/store/jdbc/model/Organization.java | 2 -
.../cache/store/jdbc/model/OrganizationKey.java | 2 -
.../ignite/cache/store/jdbc/model/Person.java | 2 -
.../store/jdbc/model/PersonComplexKey.java | 4 +-
.../cache/store/jdbc/model/PersonKey.java | 2 -
.../ignite/igfs/IgfsEventsAbstractSelfTest.java | 2 +-
.../igfs/IgfsFragmentizerAbstractSelfTest.java | 2 +-
.../ignite/igfs/IgfsFragmentizerSelfTest.java | 2 +-
.../internal/ClusterNodeMetricsSelfTest.java | 46 +-
.../GridEventStorageDefaultExceptionTest.java | 94 +
.../BinaryObjectOffHeapUnswapTemporaryTest.java | 365 ---
.../cache/CacheConfigurationLeakTest.java | 1 +
.../cache/CacheDeferredDeleteQueueTest.java | 2 +-
...cheDhtLocalPartitionAfterRemoveSelfTest.java | 2 +-
.../cache/CacheEnumOperationsAbstractTest.java | 52 +-
...CacheExchangeMessageDuplicatedStateTest.java | 33 -
.../cache/CacheGetEntryAbstractTest.java | 2 +
...erceptorPartitionCounterLocalSanityTest.java | 25 +-
...torPartitionCounterRandomOperationsTest.java | 111 -
.../cache/CacheNearReaderUpdateTest.java | 12 -
.../cache/CacheOffheapMapEntrySelfTest.java | 42 +-
.../CachePutEventListenerErrorSelfTest.java | 41 +-
.../CacheSerializableTransactionsTest.java | 54 +-
.../cache/CacheSwapUnswapGetTest.java | 310 ---
.../cache/CrossCacheTxRandomOperationsTest.java | 36 +-
...idAbstractCacheInterceptorRebalanceTest.java | 6 -
...ridCacheAbstractByteArrayValuesSelfTest.java | 6 -
.../cache/GridCacheAbstractFullApiSelfTest.java | 184 +-
.../GridCacheAbstractLocalStoreSelfTest.java | 13 -
.../GridCacheAbstractRemoveFailureTest.java | 26 +-
.../cache/GridCacheAbstractSelfTest.java | 21 +-
.../cache/GridCacheClearSelfTest.java | 113 +-
.../GridCacheConcurrentTxMultiNodeTest.java | 2 +-
...idCacheConfigurationConsistencySelfTest.java | 41 +-
.../GridCacheDeploymentOffHeapSelfTest.java | 41 -
...ridCacheDeploymentOffHeapValuesSelfTest.java | 41 -
.../GridCacheEvictionEventAbstractTest.java | 5 +-
...heInterceptorAtomicOffheapRebalanceTest.java | 30 -
...GridCacheInterceptorAtomicRebalanceTest.java | 6 -
...ceptorTransactionalOffheapRebalanceTest.java | 35 -
...heInterceptorTransactionalRebalanceTest.java | 6 -
.../cache/GridCacheLifecycleAwareSelfTest.java | 1 +
.../cache/GridCacheMemoryModeSelfTest.java | 285 ---
.../cache/GridCacheObjectToStringSelfTest.java | 1 +
...HeapMultiThreadedUpdateAbstractSelfTest.java | 3 -
.../GridCacheOffHeapTieredAbstractSelfTest.java | 679 ------
.../GridCacheOffHeapTieredAtomicSelfTest.java | 32 -
...heOffHeapTieredEvictionAbstractSelfTest.java | 364 ---
...acheOffHeapTieredEvictionAtomicSelfTest.java | 32 -
.../GridCacheOffHeapTieredEvictionSelfTest.java | 33 -
.../cache/GridCacheOffHeapTieredSelfTest.java | 33 -
.../cache/GridCacheOffheapUpdateSelfTest.java | 3 -
.../cache/GridCachePartitionedGetSelfTest.java | 1 -
...chePartitionedOffHeapLocalStoreSelfTest.java | 44 -
.../GridCachePreloadingEvictionsSelfTest.java | 7 +-
.../cache/GridCachePutAllFailoverSelfTest.java | 58 -
.../cache/GridCacheReloadSelfTest.java | 4 +-
.../cache/GridCacheSwapPreloadSelfTest.java | 1 -
.../processors/cache/GridCacheTestEntryEx.java | 2 +-
.../GridCacheTtlManagerEvictionSelfTest.java | 26 +-
.../GridCacheValueBytesPreloadingSelfTest.java | 44 -
.../GridCacheVersionTopologyChangeTest.java | 5 -
.../cache/IgniteCacheAbstractTest.java | 6 +-
...IgniteCacheAtomicPutAllFailoverSelfTest.java | 5 -
.../IgniteCacheConfigVariationsFullApiTest.java | 189 +-
.../IgniteCacheEntryListenerAbstractTest.java | 11 -
...cheEntryListenerAtomicOffheapTieredTest.java | 32 -
...cheEntryListenerAtomicOffheapValuesTest.java | 32 -
...niteCacheEntryListenerExpiredEventsTest.java | 26 +-
...teCacheEntryListenerTxOffheapTieredTest.java | 32 -
...teCacheEntryListenerTxOffheapValuesTest.java | 32 -
...niteCacheExpireAndUpdateConsistencyTest.java | 35 +-
.../IgniteCacheInterceptorSelfTestSuite.java | 2 -
...gniteCacheInvokeReadThroughAbstractTest.java | 4 -
...iteCacheInvokeReadThroughSingleNodeTest.java | 32 +-
.../cache/IgniteCacheInvokeReadThroughTest.java | 92 +-
...gniteCacheLoadRebalanceEvictionSelfTest.java | 3 +-
...gniteCacheP2pUnmarshallingNearErrorTest.java | 4 +-
.../cache/IgniteCachePeekModesAbstractTest.java | 117 +-
.../IgniteCacheReadThroughEvictionSelfTest.java | 10 +-
.../IgniteCacheStoreValueAbstractTest.java | 5 -
.../cache/IgniteCacheTxNearPeekModesTest.java | 5 +-
.../cache/IgniteCacheTxPeekModesTest.java | 5 +-
.../IgniteClientAffinityAssignmentSelfTest.java | 20 +-
...eDynamicCacheStartNoExchangeTimeoutTest.java | 3 -
.../cache/OffHeapTieredTransactionSelfTest.java | 134 --
...heapCacheMetricsForClusterGroupSelfTest.java | 3 -
.../GridCacheBinaryObjectsAbstractSelfTest.java | 26 +-
...AtomicNearDisabledOffheapTieredSelfTest.java | 29 -
...ObjectsAtomicNearDisabledOnheapSelfTest.java | 25 +
...inaryObjectsAtomicOffheapTieredSelfTest.java | 29 -
...dCacheBinaryObjectsAtomicOnheapSelfTest.java | 25 +
...tionedNearDisabledOffheapTieredSelfTest.java | 30 -
...tsPartitionedNearDisabledOnheapSelfTest.java | 25 +
...ObjectsPartitionedOffheapTieredSelfTest.java | 30 -
...eBinaryObjectsPartitionedOnheapSelfTest.java | 25 +
.../dht/GridCacheMemoryModeBinarySelfTest.java | 36 -
...dCacheOffHeapTieredAtomicBinarySelfTest.java | 48 -
.../GridCacheOffHeapTieredBinarySelfTest.java | 48 -
...fHeapTieredEvictionAtomicBinarySelfTest.java | 96 -
...acheOffHeapTieredEvictionBinarySelfTest.java | 96 -
...BinaryObjectsLocalOffheapTieredSelfTest.java | 29 -
...idCacheBinaryObjectsLocalOnheapSelfTest.java | 26 +
.../GridCacheQueueCleanupSelfTest.java | 7 -
...dCacheQueueMultiNodeConsistencySelfTest.java | 7 -
.../IgniteCollectionAbstractTest.java | 7 -
.../IgniteDataStructureUniqueNameTest.java | 7 -
.../GridCacheLocalAtomicOffheapSetSelfTest.java | 32 -
.../GridCacheLocalAtomicQueueApiSelfTest.java | 6 -
.../local/GridCacheLocalAtomicSetSelfTest.java | 7 -
.../GridCacheLocalOffheapQueueApiSelfTest.java | 31 -
.../local/GridCacheLocalQueueApiSelfTest.java | 7 -
.../local/GridCacheLocalSetSelfTest.java | 7 -
...artitionedAtomicOffheapQueueApiSelfTest.java | 32 -
...omicOffheapQueueCreateMultiNodeSelfTest.java | 32 -
...onedAtomicOffheapQueueMultiNodeSelfTest.java | 32 -
...dCachePartitionedAtomicQueueApiSelfTest.java | 7 -
...ionedAtomicQueueCreateMultiNodeSelfTest.java | 7 -
...micQueueFailoverDataConsistencySelfTest.java | 7 -
...PartitionedAtomicQueueMultiNodeSelfTest.java | 7 -
...itionedAtomicQueueRotativeMultiNodeTest.java | 7 -
...chePartitionedAtomicSetFailoverSelfTest.java | 7 -
...rtitionedDataStructuresFailoverSelfTest.java | 7 -
...artitionedOffHeapValuesQueueApiSelfTest.java | 35 -
...achePartitionedOffHeapValuesSetSelfTest.java | 32 -
...edOffheapDataStructuresFailoverSelfTest.java | 33 -
...hePartitionedOffheapSetFailoverSelfTest.java | 32 -
.../GridCachePartitionedQueueApiSelfTest.java | 7 -
...PartitionedQueueCreateMultiNodeSelfTest.java | 7 -
...dCachePartitionedQueueEntryMoveSelfTest.java | 7 -
...nedQueueFailoverDataConsistencySelfTest.java | 7 -
...CachePartitionedQueueJoinedNodeSelfTest.java | 7 -
...dCachePartitionedQueueMultiNodeSelfTest.java | 7 -
...hePartitionedQueueRotativeMultiNodeTest.java | 7 -
...GridCachePartitionedSetFailoverSelfTest.java | 7 -
.../GridCachePartitionedSetSelfTest.java | 7 -
.../IgnitePartitionedQueueNoBackupsTest.java | 7 -
...eplicatedDataStructuresFailoverSelfTest.java | 7 -
.../GridCacheReplicatedQueueApiSelfTest.java | 7 -
...idCacheReplicatedQueueMultiNodeSelfTest.java | 7 -
...cheReplicatedQueueRotativeMultiNodeTest.java | 7 -
.../GridCacheReplicatedSetSelfTest.java | 7 -
...eLateAffinityAssignmentFairAffinityTest.java | 32 -
...tractDistributedByteArrayValuesSelfTest.java | 120 +-
.../GridCacheAbstractNodeRestartSelfTest.java | 116 +-
...tractPartitionedByteArrayValuesSelfTest.java | 33 -
.../IgniteCacheAtomicNodeRestartTest.java | 5 -
...teCacheClientNodePartitionsExchangeTest.java | 18 +-
.../IgniteCacheNearOffheapGetSelfTest.java | 136 --
.../IgniteCacheTxFairAffinityNodeJoinTest.java | 35 -
.../IgniteCacheTxIteratorSelfTest.java | 34 +-
...arDisabledFairAffinityPutGetRestartTest.java | 35 -
...tPartitionedOnlyByteArrayValuesSelfTest.java | 55 +-
...eColocatedOptimisticTransactionSelfTest.java | 1 -
.../dht/GridCacheDhtEntrySelfTest.java | 4 +-
...GridCacheDhtEvictionNearReadersSelfTest.java | 6 +-
.../dht/GridCacheDhtEvictionSelfTest.java | 356 ---
.../dht/GridCacheDhtPreloadOffHeapSelfTest.java | 38 -
.../dht/GridCacheDhtPreloadOnheapSelfTest.java | 26 +
.../dht/GridCacheDhtPreloadSelfTest.java | 38 +-
...icOffHeapTieredMultiNodeFullApiSelfTest.java | 43 -
...NearDisabledAtomicOnheapFullApiSelfTest.java | 38 +
...ledAtomicOnheapMultiNodeFullApiSelfTest.java | 38 +
...ledFairAffinityMultiNodeFullApiSelfTest.java | 36 -
...ionedNearDisabledOffHeapFullApiSelfTest.java | 33 -
...DisabledOffHeapMultiNodeFullApiSelfTest.java | 33 -
...abledOffHeapTieredAtomicFullApiSelfTest.java | 57 -
...earDisabledOffHeapTieredFullApiSelfTest.java | 33 -
...edOffHeapTieredMultiNodeFullApiSelfTest.java | 33 -
...tionedNearDisabledOnheapFullApiSelfTest.java | 27 +
...rDisabledOnheapMultiNodeFullApiSelfTest.java | 27 +
.../dht/IgniteCacheConcurrentPutGetRemove.java | 27 +-
.../IgniteCacheCrossCacheTxFailoverTest.java | 46 +-
.../dht/IgniteCacheMultiTxLockSelfTest.java | 1 +
.../IgniteCachePutRetryAbstractSelfTest.java | 53 +-
.../dht/IgniteCachePutRetryAtomicSelfTest.java | 2 +-
...gniteCachePutRetryTransactionalSelfTest.java | 28 +-
.../AtomicPutAllChangingTopologyTest.java | 4 +-
...eAtomicInvalidPartitionHandlingSelfTest.java | 65 +-
...nlyFairAffinityMultiNodeFullApiSelfTest.java | 36 -
...tomicClientOnlyMultiNodeFullApiSelfTest.java | 113 +-
...micFairAffinityMultiNodeFullApiSelfTest.java | 35 -
...ledFairAffinityMultiNodeFullApiSelfTest.java | 36 -
...eAtomicNearOnlyMultiNodeFullApiSelfTest.java | 52 -
.../GridCacheAtomicOffHeapFullApiSelfTest.java | 67 -
...heAtomicOffHeapMultiNodeFullApiSelfTest.java | 68 -
...CacheAtomicOffHeapTieredFullApiSelfTest.java | 32 -
...icOffHeapTieredMultiNodeFullApiSelfTest.java | 33 -
.../GridCacheAtomicOnheapFullApiSelfTest.java | 28 +
...cheAtomicOnheapMultiNodeFullApiSelfTest.java | 26 +
...derFairAffinityMultiNodeFullApiSelfTest.java | 36 -
...PrimaryWriteOrderOffHeapFullApiSelfTest.java | 32 -
...yWriteOrderOffHeapTieredFullApiSelfTest.java | 33 -
...cPrimaryWriteOrderOnheapFullApiSelfTest.java | 28 +
...riteOrderOnheapMultiNodeFullApiSelfTest.java | 29 +
...ityOrderOffHeapMultiNodeFullApiSelfTest.java | 33 -
...erOffHeapTieredMultiNodeFullApiSelfTest.java | 33 -
...nlyFairAffinityMultiNodeFullApiSelfTest.java | 35 -
.../near/GridCacheNearReadersSelfTest.java | 7 +-
...ePartitionedAtomicOnheapFullApiSelfTest.java | 38 +
...nedAtomicOnheapMultiNodeFullApiSelfTest.java | 38 +
.../GridCachePartitionedEvictionSelfTest.java | 1 +
.../GridCachePartitionedFullApiSelfTest.java | 2 -
...achePartitionedMultiNodeFullApiSelfTest.java | 43 -
...ePartitionedMultiThreadedPutGetSelfTest.java | 2 +-
...dCachePartitionedOffHeapFullApiSelfTest.java | 32 -
...titionedOffHeapMultiNodeFullApiSelfTest.java | 32 -
...PartitionedOffHeapTieredFullApiSelfTest.java | 32 -
...edOffHeapTieredMultiNodeFullApiSelfTest.java | 74 -
...idCachePartitionedOnheapFullApiSelfTest.java | 26 +
...rtitionedOnheapMultiNodeFullApiSelfTest.java | 26 +
.../GridNearOffheapCacheStoreUpdateTest.java | 35 -
...xcludeNeighborsMultiNodeFullApiSelfTest.java | 36 -
...tedFairAffinityMultiNodeFullApiSelfTest.java | 35 -
...stractReplicatedByteArrayValuesSelfTest.java | 29 -
...nedFairAffinityMultiNodeFullApiSelfTest.java | 37 -
.../GridCacheReplicatedEvictionSelfTest.java | 135 --
...idCacheReplicatedOffHeapFullApiSelfTest.java | 32 -
...plicatedOffHeapMultiNodeFullApiSelfTest.java | 32 -
...eReplicatedOffHeapTieredFullApiSelfTest.java | 33 -
...edOffHeapTieredMultiNodeFullApiSelfTest.java | 33 -
...ridCacheReplicatedOnheapFullApiSelfTest.java | 26 +
...eplicatedOnheapMultiNodeFullApiSelfTest.java | 26 +
...idCacheReplicatedPreloadOffHeapSelfTest.java | 37 -
.../cache/eviction/EvictionAbstractTest.java | 37 +-
.../GridCacheBatchEvictUnswapSelfTest.java | 199 --
...heConcurrentEvictionConsistencySelfTest.java | 6 +-
.../GridCacheConcurrentEvictionsSelfTest.java | 1 +
.../GridCacheDistributedEvictionsSelfTest.java | 235 --
.../GridCacheEmptyEntriesAbstractSelfTest.java | 4 +-
.../GridCacheEvictableEntryEqualsSelfTest.java | 1 +
.../GridCacheEvictionFilterSelfTest.java | 2 +-
.../GridCacheEvictionLockUnlockSelfTest.java | 1 +
.../GridCacheEvictionTouchSelfTest.java | 12 +-
...cheSynchronousEvictionsFailoverSelfTest.java | 166 --
.../lru/LruNearEvictionPolicySelfTest.java | 28 -
.../LruNearOnlyNearEvictionPolicySelfTest.java | 55 -
.../paged/PageEvictionAbstractTest.java | 124 +
.../paged/PageEvictionMultinodeTest.java | 110 +
.../paged/PageEvictionReadThroughTest.java | 140 ++
.../paged/PageEvictionTouchOrderTest.java | 109 +
.../paged/PageEvictionWithRebalanceTest.java | 81 +
.../Random2LruPageEvictionMultinodeTest.java | 30 +
...Random2LruPageEvictionWithRebalanceTest.java | 30 +
.../RandomLruPageEvictionMultinodeTest.java | 30 +
.../RandomLruPageEvictionWithRebalanceTest.java | 30 +
.../cache/eviction/paged/TestObject.java | 78 +
.../SortedEvictionPolicyPerformanceTest.java | 2 +-
...CacheAtomicLocalOffheapExpiryPolicyTest.java | 30 -
...eCacheAtomicLocalOnheapExpiryPolicyTest.java | 26 +
...gniteCacheAtomicOffheapExpiryPolicyTest.java | 30 -
...IgniteCacheAtomicOnheapExpiryPolicyTest.java | 26 +
...rimaryWriteOrderOffheapExpiryPolicyTest.java | 31 -
...teOrderWithStoreOffheapExpiryPolicyTest.java | 31 -
...AtomicReplicatedOffheapExpiryPolicyTest.java | 30 -
...eAtomicWithStoreOffheapExpiryPolicyTest.java | 30 -
.../IgniteCacheExpiryPolicyAbstractTest.java | 13 -
.../IgniteCacheExpiryPolicyTestSuite.java | 13 -
...niteCacheTxLocalOffheapExpiryPolicyTest.java | 30 -
.../IgniteCacheTxOffheapExpiryPolicyTest.java | 30 -
...acheTxReplicatedOffheapExpiryPolicyTest.java | 30 -
...CacheTxWithStoreOffheapExpiryPolicyTest.java | 30 -
...dCacheLocalAtomicOffHeapFullApiSelfTest.java | 42 -
...LocalAtomicOffHeapTieredFullApiSelfTest.java | 32 -
.../GridCacheLocalByteArrayValuesSelfTest.java | 64 +-
.../GridCacheLocalOffHeapFullApiSelfTest.java | 30 -
...dCacheLocalOffHeapTieredFullApiSelfTest.java | 32 -
...LocalCacheOffHeapAndSwapMetricsSelfTest.java | 463 ----
...OnlyFairAffinityMultiJvmFullApiSelfTest.java | 31 -
...omicFairAffinityMultiJvmFullApiSelfTest.java | 31 -
...bledFairAffinityMultiJvmFullApiSelfTest.java | 36 -
...cheAtomicOffHeapMultiJvmFullApiSelfTest.java | 31 -
...micOffHeapTieredMultiJvmFullApiSelfTest.java | 36 -
...acheAtomicOnheapMultiJvmFullApiSelfTest.java | 28 +
...rderFairAffinityMultiJvmFullApiSelfTest.java | 31 -
...WriteOrderOnheapMultiJvmFullApiSelfTest.java | 29 +
...rityOrderOffHeapMultiJvmFullApiSelfTest.java | 31 -
...derOffHeapTieredMultiJvmFullApiSelfTest.java | 36 -
...OnlyFairAffinityMultiJvmFullApiSelfTest.java | 31 -
...onedFairAffinityMultiJvmFullApiSelfTest.java | 31 -
...micOffHeapTieredMultiJvmFullApiSelfTest.java | 36 -
...bledAtomicOnheapMultiJvmFullApiSelfTest.java | 28 +
...bledFairAffinityMultiJvmFullApiSelfTest.java | 31 -
...rDisabledOffHeapMultiJvmFullApiSelfTest.java | 31 -
...ledOffHeapTieredMultiJvmFullApiSelfTest.java | 36 -
...arDisabledOnheapMultiJvmFullApiSelfTest.java | 28 +
...rtitionedOffHeapMultiJvmFullApiSelfTest.java | 31 -
...nedOffHeapTieredMultiJvmFullApiSelfTest.java | 36 -
...artitionedOnheapMultiJvmFullApiSelfTest.java | 28 +
...eplicatedOffHeapMultiJvmFullApiSelfTest.java | 31 -
...tedOffHeapTieredMultiJvmFullApiSelfTest.java | 36 -
...ReplicatedOnheapMultiJvmFullApiSelfTest.java | 28 +
.../GridCacheSwapScanQueryAbstractSelfTest.java | 450 ----
.../query/GridCacheSwapScanQuerySelfTest.java | 25 -
.../IgniteCacheQueryCacheDestroySelfTest.java | 2 -
.../continuous/CacheContinuousBatchAckTest.java | 73 +-
...eContinuousQueryAsyncFilterListenerTest.java | 170 +-
...acheContinuousQueryExecuteInPrimaryTest.java | 2 -
...usQueryFactoryFilterRandomOperationTest.java | 2 -
...ContinuousQueryFailoverAbstractSelfTest.java | 10 -
...tomicPrimaryWriteOrderOffheapTieredTest.java | 33 -
...tinuousQueryFailoverTxOffheapTieredTest.java | 32 -
.../CacheContinuousQueryOperationP2PTest.java | 31 +-
.../CacheContinuousQueryOrderingEventTest.java | 127 +-
...acheContinuousQueryRandomOperationsTest.java | 246 --
...CacheKeepBinaryIterationNearEnabledTest.java | 6 +-
...acheKeepBinaryIterationStoreEnabledTest.java | 6 +-
.../CacheKeepBinaryIterationTest.java | 105 +-
...ridCacheContinuousQueryAbstractSelfTest.java | 10 -
...eContinuousQueryAtomicOffheapTieredTest.java | 32 -
...eContinuousQueryAtomicOffheapValuesTest.java | 32 -
...CacheContinuousQueryTxOffheapTieredTest.java | 32 -
...CacheContinuousQueryTxOffheapValuesTest.java | 32 -
...edEntryPartitionedAtomicOffHeapSelfTest.java | 35 -
...PartitionedTransactionalOffHeapSelfTest.java | 36 -
...nedEntryReplicatedAtomicOffHeapSelfTest.java | 35 -
...yReplicatedTransactionalOffHeapSelfTest.java | 36 -
.../database/FreeListImplSelfTest.java | 13 +-
.../DataStreamProcessorSelfTest.java | 2 -
...faultIgfsSecondaryFileSystemTestAdapter.java | 2 +-
.../igfs/IgfsAbstractBaseSelfTest.java | 20 +-
.../processors/igfs/IgfsAbstractSelfTest.java | 15 +-
.../IgfsAtomicPrimaryOffheapTieredSelfTest.java | 39 -
.../IgfsAtomicPrimaryOffheapValuesSelfTest.java | 39 -
...sCachePerBlockLruEvictionPolicySelfTest.java | 3 +-
.../processors/igfs/IgfsMaxSizeSelfTest.java | 1 -
.../igfs/IgfsMetaManagerSelfTest.java | 2 +-
.../processors/igfs/IgfsMetricsSelfTest.java | 2 +-
.../internal/processors/igfs/IgfsMock.java | 4 +-
.../igfs/IgfsPrimaryOffheapTieredSelfTest.java | 33 -
.../igfs/IgfsPrimaryOffheapValuesSelfTest.java | 33 -
.../processors/igfs/IgfsProcessorSelfTest.java | 8 +-
.../processors/igfs/IgfsStreamsSelfTest.java | 2 +-
.../processors/igfs/IgfsTaskSelfTest.java | 2 +-
.../IgfsAbstractRecordResolverSelfTest.java | 2 +-
.../loadtests/GridCacheMultiNodeLoadTest.java | 1 +
.../GridCachePartitionedAtomicLongLoadTest.java | 2 +-
...gniteClientReconnectMassiveShutdownTest.java | 3 -
.../ignite/testframework/GridTestUtils.java | 113 -
.../configvariations/ConfigVariations.java | 28 +-
.../testframework/junits/GridAbstractTest.java | 56 +-
...IgniteCacheConfigVariationsAbstractTest.java | 38 +-
.../junits/common/GridCommonAbstractTest.java | 10 +-
.../ConfigVariationsTestSuiteBuilderTest.java | 4 +-
.../ignite/testsuites/IgniteBasicTestSuite.java | 2 -
.../testsuites/IgniteBinaryCacheTestSuite.java | 19 -
.../IgniteBinaryObjectsTestSuite.java | 13 -
.../IgniteCacheDataStructuresSelfTestSuite.java | 18 -
.../IgniteCacheEvictionSelfTestSuite.java | 21 +-
.../IgniteCacheFailoverTestSuite.java | 4 -
...IgniteCacheFullApiMultiJvmSelfTestSuite.java | 52 +-
.../IgniteCacheFullApiSelfTestSuite.java | 102 +-
.../IgniteCacheMetricsSelfTestSuite.java | 2 -
.../ignite/testsuites/IgniteCacheTestSuite.java | 36 +-
.../testsuites/IgniteCacheTestSuite2.java | 28 +-
.../testsuites/IgniteCacheTestSuite3.java | 14 +-
.../testsuites/IgniteCacheTestSuite4.java | 9 -
.../testsuites/IgniteCacheTestSuite5.java | 10 -
.../testsuites/IgniteComputeGridTestSuite.java | 2 +
.../ignite/testsuites/IgniteIgfsTestSuite.java | 9 -
.../impl/HadoopAbstractMapReduceTest.java | 1 -
.../impl/HadoopTaskExecutionSelfTest.java | 2 +-
...opClientProtocolMultipleServersSelfTest.java | 2 +-
.../client/HadoopClientProtocolSelfTest.java | 2 +-
.../igfs/HadoopFIleSystemFactorySelfTest.java | 1 -
.../igfs/HadoopIgfsDualAbstractSelfTest.java | 1 -
.../hadoop/impl/igfs/IgfsEventsTestSuite.java | 2 +-
.../cache/hibernate/HibernateCacheProxy.java | 2 +-
.../cache/hibernate/HibernateKeyWrapper.java | 34 +-
.../cache/hibernate/HibernateRegionFactory.java | 3 +-
.../hibernate/HibernateL2CacheSelfTest.java | 2 +-
modules/hibernate5/README.txt | 48 +
modules/hibernate5/licenses/apache-2.0.txt | 202 ++
modules/hibernate5/pom.xml | 146 ++
.../HibernateAbstractRegionAccessStrategy.java | 99 +
.../HibernateAccessStrategyAdapter.java | 379 ++++
.../cache/hibernate/HibernateCacheProxy.java | 811 +++++++
.../hibernate/HibernateCollectionRegion.java | 114 +
.../cache/hibernate/HibernateEntityRegion.java | 129 ++
.../hibernate/HibernateGeneralDataRegion.java | 72 +
.../hibernate/HibernateKeyTransformer.java | 28 +
.../cache/hibernate/HibernateKeyWrapper.java | 108 +
.../hibernate/HibernateNaturalIdRegion.java | 113 +
.../HibernateNonStrictAccessStrategy.java | 222 ++
.../hibernate/HibernateQueryResultsRegion.java | 70 +
.../HibernateReadOnlyAccessStrategy.java | 107 +
.../HibernateReadWriteAccessStrategy.java | 328 +++
.../ignite/cache/hibernate/HibernateRegion.java | 99 +
.../cache/hibernate/HibernateRegionFactory.java | 255 +++
.../hibernate/HibernateTimestampsRegion.java | 39 +
.../HibernateTransactionalAccessStrategy.java | 141 ++
.../HibernateTransactionalDataRegion.java | 107 +
.../ignite/cache/hibernate/package-info.java | 24 +
.../hibernate/CacheHibernateBlobStore.java | 542 +++++
.../CacheHibernateBlobStoreEntry.hbm.xml | 31 +
.../hibernate/CacheHibernateBlobStoreEntry.java | 89 +
.../CacheHibernateBlobStoreFactory.java | 235 ++
.../CacheHibernateStoreSessionListener.java | 223 ++
.../cache/store/hibernate/package-info.java | 22 +
.../src/test/config/factory-cache.xml | 59 +
.../src/test/config/factory-cache1.xml | 61 +
.../config/factory-incorrect-store-cache.xml | 56 +
.../HibernateL2CacheConfigurationSelfTest.java | 409 ++++
.../hibernate/HibernateL2CacheSelfTest.java | 1948 ++++++++++++++++
.../HibernateL2CacheTransactionalSelfTest.java | 154 ++
...nateL2CacheTransactionalUseSyncSelfTest.java | 31 +
.../CacheHibernateBlobStoreNodeRestartTest.java | 54 +
.../CacheHibernateBlobStoreSelfTest.java | 113 +
.../CacheHibernateStoreFactorySelfTest.java | 326 +++
...heHibernateStoreSessionListenerSelfTest.java | 241 ++
.../cache/store/hibernate/hibernate.cfg.xml | 42 +
.../cache/store/hibernate/package-info.java | 22 +
.../IgniteBinaryHibernate5TestSuite.java | 37 +
.../testsuites/IgniteHibernate5TestSuite.java | 57 +
.../processors/query/h2/opt/GridH2Row.java | 5 +
.../cache/CacheIndexStreamerTest.java | 3 -
.../cache/CacheIndexingOffheapCleanupTest.java | 157 --
.../CacheOffheapBatchIndexingBaseTest.java | 6 +-
.../CacheOffheapBatchIndexingMultiTypeTest.java | 17 +-
...CacheOffheapBatchIndexingSingleTypeTest.java | 20 +-
.../CacheOperationsWithExpirationTest.java | 68 +-
.../cache/CacheQueryEvictDataLostTest.java | 120 +
.../CacheQueryOffheapEvictDataLostTest.java | 136 --
.../CacheRandomOperationsMultithreadedTest.java | 64 +-
.../ClientReconnectAfterClusterRestartTest.java | 16 +-
.../cache/GridCacheOffHeapSelfTest.java | 1 -
.../GridCacheOffheapIndexEntryEvictTest.java | 4 -
.../cache/GridCacheOffheapIndexGetSelfTest.java | 8 -
.../cache/GridCacheQuerySimpleBenchmark.java | 3 -
.../cache/GridIndexingWithNoopSwapSelfTest.java | 3 +-
...aryObjectQueryArgumentsOffheapLocalTest.java | 28 -
...teBinaryObjectQueryArgumentsOffheapTest.java | 30 -
.../IgniteBinaryObjectQueryArgumentsTest.java | 11 -
...CacheDistributedJoinQueryConditionsTest.java | 16 -
.../cache/IgniteCacheOffheapEvictQueryTest.java | 6 -
.../cache/IgniteCacheOffheapIndexScanTest.java | 3 -
...CacheOffheapTieredMultithreadedSelfTest.java | 301 ---
.../cache/IgniteCacheQueriesLoadTest1.java | 2 -
...QueryMultiThreadedOffHeapTieredSelfTest.java | 38 -
.../IgniteCacheQueryMultiThreadedSelfTest.java | 24 +-
...QueryOffheapEvictsMultiThreadedSelfTest.java | 28 -
...eCacheQueryOffheapMultiThreadedSelfTest.java | 28 -
.../cache/IgniteCrossCachesJoinsQueryTest.java | 16 -
...QueryNodeRestartDistributedJoinSelfTest.java | 50 +-
.../cache/ttl/CacheTtlAbstractSelfTest.java | 9 +-
.../ttl/CacheTtlAtomicAbstractSelfTest.java | 29 +
.../cache/ttl/CacheTtlAtomicLocalSelfTest.java | 34 +
.../ttl/CacheTtlAtomicPartitionedSelfTest.java | 34 +
.../ttl/CacheTtlOffheapAbstractSelfTest.java | 29 -
.../CacheTtlOffheapAtomicAbstractSelfTest.java | 29 -
.../ttl/CacheTtlOffheapAtomicLocalSelfTest.java | 34 -
...acheTtlOffheapAtomicPartitionedSelfTest.java | 34 -
...TtlOffheapTransactionalAbstractSelfTest.java | 29 -
...cheTtlOffheapTransactionalLocalSelfTest.java | 34 -
...OffheapTransactionalPartitionedSelfTest.java | 34 -
.../ttl/CacheTtlOnheapAbstractSelfTest.java | 29 -
.../CacheTtlOnheapAtomicAbstractSelfTest.java | 29 -
.../ttl/CacheTtlOnheapAtomicLocalSelfTest.java | 34 -
...CacheTtlOnheapAtomicPartitionedSelfTest.java | 34 -
...eTtlOnheapTransactionalAbstractSelfTest.java | 29 -
...acheTtlOnheapTransactionalLocalSelfTest.java | 34 -
...lOnheapTransactionalPartitionedSelfTest.java | 34 -
.../CacheTtlTransactionalAbstractSelfTest.java | 29 +
.../ttl/CacheTtlTransactionalLocalSelfTest.java | 34 +
...acheTtlTransactionalPartitionedSelfTest.java | 34 +
.../query/IgniteSqlSegmentedIndexSelfTest.java | 3 +-
.../IgniteCacheQuerySelfTestSuite.java | 11 +-
.../IgniteCacheQuerySelfTestSuite2.java | 13 +-
.../IgniteCacheQuerySelfTestSuite3.java | 8 -
.../IgniteCacheQuerySelfTestSuite4.java | 4 -
.../IgniteCacheWithIndexingTestSuite.java | 26 +-
modules/log4j2/pom.xml | 4 +-
.../ignite/logger/log4j2/Log4J2Logger.java | 23 +-
.../include/ignite/impl/binary/binary_utils.h | 1 -
.../ignite/impl/binary/binary_writer_impl.h | 5 +-
.../Cache/CacheConfigurationTest.cs | 9 -
.../Apache.Ignite.Core.Tests/EventsTest.cs | 63 +-
.../IgniteConfigurationSerializerTest.cs | 15 +-
.../IgniteConfigurationTest.cs | 15 +-
.../Apache.Ignite.Core.csproj | 3 +
.../Cache/Configuration/CacheConfiguration.cs | 23 -
.../Events/IEventStorageSpi.cs | 33 +
.../Events/MemoryEventStorageSpi.cs | 100 +
.../Events/NoopEventStorageSpi.cs | 27 +
.../Apache.Ignite.Core/IgniteConfiguration.cs | 48 +-
.../IgniteConfigurationSection.xsd | 22 +
.../Plugin/IPluginConfiguration.cs | 4 +-
.../Datagrid/MultiTieredCacheExample.cs | 2 -
modules/schema-import-db/README.txt | 4 -
modules/schema-import-db/pom.xml | 55 -
.../apache/ignite/schema/parser/DbColumn.java | 88 -
.../ignite/schema/parser/DbMetadataReader.java | 147 --
.../apache/ignite/schema/parser/DbTable.java | 82 -
.../parser/dialect/DB2MetadataDialect.java | 33 -
.../parser/dialect/DatabaseMetadataDialect.java | 102 -
.../parser/dialect/JdbcMetadataDialect.java | 199 --
.../parser/dialect/MySQLMetadataDialect.java | 82 -
.../parser/dialect/OracleMetadataDialect.java | 360 ---
modules/schema-import/README.txt | 216 --
modules/schema-import/pom.xml | 119 -
.../main/java/media/data_connection_48x48.png | Bin 4443 -> 0 bytes
.../src/main/java/media/error_48x48.png | Bin 4349 -> 0 bytes
.../src/main/java/media/ignite_128x128.png | Bin 4917 -> 0 bytes
.../src/main/java/media/ignite_16x16.png | Bin 608 -> 0 bytes
.../src/main/java/media/ignite_24x24.png | Bin 930 -> 0 bytes
.../src/main/java/media/ignite_32x32.png | Bin 1203 -> 0 bytes
.../src/main/java/media/ignite_48x48.png | Bin 1868 -> 0 bytes
.../src/main/java/media/ignite_64x64.png | Bin 2453 -> 0 bytes
.../src/main/java/media/information_48x48.png | Bin 4102 -> 0 bytes
.../src/main/java/media/question_48x48.png | Bin 3857 -> 0 bytes
.../src/main/java/media/sign_warning_48x48.png | Bin 2988 -> 0 bytes
.../schema-import/src/main/java/media/style.css | 134 --
.../src/main/java/media/text_tree_48x48.png | Bin 2567 -> 0 bytes
.../ignite/schema/generator/CodeGenerator.java | 831 -------
.../ignite/schema/generator/GeneratorUtils.java | 70 -
.../ignite/schema/generator/XmlGenerator.java | 446 ----
.../ignite/schema/model/PojoDescriptor.java | 497 ----
.../apache/ignite/schema/model/PojoField.java | 461 ----
.../ignite/schema/model/SchemaDescriptor.java | 62 -
.../schema/parser/DatabaseMetadataParser.java | 115 -
.../ignite/schema/ui/ConfirmCallable.java | 83 -
.../org/apache/ignite/schema/ui/Controls.java | 697 ------
.../org/apache/ignite/schema/ui/GridPaneEx.java | 180 --
.../org/apache/ignite/schema/ui/MessageBox.java | 274 ---
.../apache/ignite/schema/ui/ModalDialog.java | 50 -
.../ignite/schema/ui/SchemaImportApp.java | 2115 ------------------
.../ignite/schema/ui/TextColumnValidator.java | 32 -
.../schema/test/AbstractSchemaImportTest.java | 181 --
.../test/generator/CodeGeneratorTest.java | 81 -
.../schema/test/generator/XmlGeneratorTest.java | 42 -
.../ignite/schema/test/model/CacheConfig.txt | 409 ----
.../apache/ignite/schema/test/model/Objects.txt | 531 -----
.../ignite/schema/test/model/ObjectsKey.txt | 96 -
.../ignite/schema/test/model/Primitives.txt | 535 -----
.../ignite/schema/test/model/PrimitivesKey.txt | 96 -
.../org/apache/ignite/schema/test/model/Tst.txt | 535 -----
.../apache/ignite/schema/test/model/TstKey.txt | 96 -
.../schema/test/model/ignite-type-metadata.xml | 666 ------
.../test/parser/DbMetadataParserTest.java | 134 --
.../testsuites/IgniteSchemaImportTestSuite.java | 42 -
.../ignite/internal/GridFactorySelfTest.java | 3 +
.../commands/cache/VisorCacheCommand.scala | 5 -
modules/web-console/web-agent/pom.xml | 12 -
.../ignite/console/agent/db/DbColumn.java | 88 +
.../console/agent/db/DbMetadataReader.java | 142 ++
.../apache/ignite/console/agent/db/DbTable.java | 82 +
.../agent/db/dialect/DB2MetadataDialect.java | 33 +
.../db/dialect/DatabaseMetadataDialect.java | 102 +
.../agent/db/dialect/JdbcMetadataDialect.java | 199 ++
.../agent/db/dialect/MySQLMetadataDialect.java | 82 +
.../agent/db/dialect/OracleMetadataDialect.java | 359 +++
.../agent/handlers/DatabaseListener.java | 20 +-
modules/yardstick/README.txt | 2 -
.../config/benchmark-atomic-win.properties | 8 +-
.../config/benchmark-atomic.properties | 6 -
.../config/benchmark-client-mode.properties | 9 -
.../config/benchmark-multicast.properties | 9 -
.../config/benchmark-query-win.properties | 5 +-
.../yardstick/config/benchmark-query.properties | 3 -
.../config/benchmark-tx-win.properties | 6 +-
.../yardstick/config/benchmark-tx.properties | 4 -
modules/yardstick/config/benchmark.properties | 11 +-
modules/yardstick/config/ignite-base-config.xml | 63 -
.../config/ignite-base-load-config.xml | 63 -
.../config/ignite-cache-load-config.xml | 5 -
.../config/ignite-failover-base-config.xml | 37 -
.../ignite-int-max-values-offheap-config.xml | 88 -
.../ignite-int-max-values-swap-config.xml | 93 -
.../test-max-int-values-offheap.properties | 65 -
.../config/test-max-int-values-swap.properties | 64 -
.../yardstick/IgniteBenchmarkArguments.java | 29 -
.../org/apache/ignite/yardstick/IgniteNode.java | 10 -
.../cache/IgniteGetOffHeapBenchmark.java | 32 -
.../cache/IgniteGetOffHeapValuesBenchmark.java | 32 -
.../cache/IgnitePutGetOffHeapBenchmark.java | 32 -
.../IgnitePutGetOffHeapValuesBenchmark.java | 32 -
.../cache/IgnitePutGetTxOffHeapBenchmark.java | 32 -
.../IgnitePutGetTxOffHeapValuesBenchmark.java | 32 -
.../cache/IgnitePutOffHeapBenchmark.java | 32 -
.../cache/IgnitePutOffHeapValuesBenchmark.java | 32 -
.../IgnitePutRandomValueSizeBenchmark.java | 2 +-
.../cache/IgnitePutTxOffHeapBenchmark.java | 32 -
.../IgnitePutTxOffHeapValuesBenchmark.java | 32 -
.../IgniteSqlQueryJoinOffHeapBenchmark.java | 32 -
.../cache/IgniteSqlQueryOffHeapBenchmark.java | 32 -
.../IgniteSqlQueryPutOffHeapBenchmark.java | 32 -
.../dml/IgniteSqlDeleteFilteredBenchmark.java | 5 +-
.../dml/IgniteSqlUpdateFilteredBenchmark.java | 5 +-
...IgniteAtomicOffHeapInvokeRetryBenchmark.java | 31 -
.../IgniteAtomicOffHeapRetriesBenchmark.java | 31 -
...ransactionalOffHeapInvokeRetryBenchmark.java | 33 -
...ransactionalOffHeapWriteInvokeBenchmark.java | 37 -
...eTransactionalOffHeapWriteReadBenchmark.java | 32 -
.../IgniteCacheRandomOperationBenchmark.java | 7 -
pom.xml | 122 +-
719 files changed, 14708 insertions(+), 33261 deletions(-)
----------------------------------------------------------------------
[07/22] ignite git commit: ignite-3477 : Fixed possible endless
iteration over queue with evicted patitions.
Posted by ag...@apache.org.
ignite-3477 : Fixed possible endless iteration over queue with evicted patitions.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5cded42e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5cded42e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5cded42e
Branch: refs/heads/ignite-3477-master
Commit: 5cded42e8a45cd799122061499e0c95b00803504
Parents: face0c7
Author: Ilya Lantukh <il...@gridgain.com>
Authored: Wed Apr 12 12:43:49 2017 +0300
Committer: Ilya Lantukh <il...@gridgain.com>
Committed: Wed Apr 12 12:43:49 2017 +0300
----------------------------------------------------------------------
.../cache/distributed/dht/preloader/GridDhtPreloader.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5cded42e/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
index c033b93..517f04a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPreloader.java
@@ -47,6 +47,7 @@ import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtAffini
import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtFuture;
import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtInvalidPartitionException;
import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtLocalPartition;
+import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionState;
import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionTopology;
import org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateRequest;
import org.apache.ignite.internal.util.future.GridCompoundFuture;
@@ -72,6 +73,7 @@ import static org.apache.ignite.events.EventType.EVT_NODE_JOINED;
import static org.apache.ignite.events.EventType.EVT_NODE_LEFT;
import static org.apache.ignite.internal.managers.communication.GridIoPolicy.AFFINITY_POOL;
import static org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionState.MOVING;
+import static org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionState.OWNING;
import static org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtPartitionState.RENTING;
import static org.apache.ignite.internal.util.GridConcurrentFactory.newMap;
@@ -790,7 +792,9 @@ public class GridDhtPreloader extends GridCachePreloaderAdapter {
try {
part.tryEvict();
- if (part.state() == RENTING || part.shouldBeRenting())
+ GridDhtPartitionState state = part.state();
+
+ if (state == RENTING || ((state == MOVING || state == OWNING) && part.shouldBeRenting()))
partsToEvict.push(part);
}
catch (Throwable ex) {
[21/22] ignite git commit: IGNITE-3477 - Fixing .NET tests
Posted by ag...@apache.org.
IGNITE-3477 - Fixing .NET tests
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/10485a0f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/10485a0f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/10485a0f
Branch: refs/heads/ignite-3477-master
Commit: 10485a0f99faa67b25682e623167e1246b83cc67
Parents: 8d2b020
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Thu Apr 13 16:37:23 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Thu Apr 13 16:37:23 2017 +0300
----------------------------------------------------------------------
.../internal/binary/BinaryReaderExImpl.java | 2 +-
.../ignite/internal/binary/BinaryUtils.java | 14 ++++++--
.../cache/database/tree/io/DataPageIO.java | 5 +--
...tCachePluginConfigurationClosureFactory.java | 37 ++++++++++++++++++++
4 files changed, 52 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/10485a0f/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryReaderExImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryReaderExImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryReaderExImpl.java
index d6fefe3..c8ca803 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryReaderExImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryReaderExImpl.java
@@ -1911,7 +1911,7 @@ public class BinaryReaderExImpl implements BinaryReader, BinaryRawReaderEx, Bina
break;
case BINARY_OBJ:
- obj = BinaryUtils.doReadBinaryObject(in, ctx);
+ obj = BinaryUtils.doReadBinaryObject(in, ctx, false);
((BinaryObjectImpl)obj).context(ctx);
http://git-wip-us.apache.org/repos/asf/ignite/blob/10485a0f/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java
index e4011a4..f36c137 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/binary/BinaryUtils.java
@@ -1451,7 +1451,7 @@ public class BinaryUtils {
/**
* @return Value.
*/
- public static BinaryObject doReadBinaryObject(BinaryInputStream in, BinaryContext ctx) {
+ public static BinaryObject doReadBinaryObject(BinaryInputStream in, BinaryContext ctx, boolean detach) {
if (in.offheapPointer() > 0) {
int len = in.readInt();
@@ -1467,7 +1467,15 @@ public class BinaryUtils {
byte[] arr = doReadByteArray(in);
int start = in.readInt();
- return new BinaryObjectImpl(ctx, arr, start);
+ BinaryObjectImpl binO = new BinaryObjectImpl(ctx, arr, start);
+
+ if (detach) {
+ binO.detachAllowed(true);
+
+ return binO.detach();
+ }
+
+ return binO;
}
}
@@ -1892,7 +1900,7 @@ public class BinaryUtils {
return doReadMap(in, ctx, ldr, handles, false, null);
case GridBinaryMarshaller.BINARY_OBJ:
- return doReadBinaryObject(in, ctx);
+ return doReadBinaryObject(in, ctx, detach);
case GridBinaryMarshaller.ENUM:
return doReadBinaryEnum(in, ctx, doReadEnumType(in));
http://git-wip-us.apache.org/repos/asf/ignite/blob/10485a0f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/io/DataPageIO.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/io/DataPageIO.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/io/DataPageIO.java
index 9546890..3ed69e1 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/io/DataPageIO.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/database/tree/io/DataPageIO.java
@@ -1397,10 +1397,11 @@ public class DataPageIO extends PageIO {
PageUtils.putShort(addr, 0, (short)payloadSize);
addr += 2;
- if (cacheIdSize != 0)
+ if (cacheIdSize != 0) {
PageUtils.putInt(addr, 0, row.cacheId());
- addr += cacheIdSize;
+ addr += cacheIdSize;
+ }
addr += row.key().putValue(addr);
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/10485a0f/modules/core/src/test/java/org/apache/ignite/platform/plugin/cache/PlatformTestCachePluginConfigurationClosureFactory.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/platform/plugin/cache/PlatformTestCachePluginConfigurationClosureFactory.java b/modules/core/src/test/java/org/apache/ignite/platform/plugin/cache/PlatformTestCachePluginConfigurationClosureFactory.java
new file mode 100644
index 0000000..c294342
--- /dev/null
+++ b/modules/core/src/test/java/org/apache/ignite/platform/plugin/cache/PlatformTestCachePluginConfigurationClosureFactory.java
@@ -0,0 +1,37 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.platform.plugin.cache;
+
+import org.apache.ignite.plugin.platform.PlatformCachePluginConfigurationClosure;
+import org.apache.ignite.plugin.platform.PlatformCachePluginConfigurationClosureFactory;
+
+/**
+ * Test closure factory.
+ */
+public class PlatformTestCachePluginConfigurationClosureFactory
+ implements PlatformCachePluginConfigurationClosureFactory {
+ /** {@inheritDoc} */
+ @Override public int id() {
+ return 0;
+ }
+
+ /** {@inheritDoc} */
+ @Override public PlatformCachePluginConfigurationClosure create() {
+ return new PlatformTestCachePluginConfigurationClosure();
+ }
+}
[13/22] ignite git commit: ignite-3477-master memory configuration
for test deadlockDetection
Posted by ag...@apache.org.
ignite-3477-master memory configuration for test deadlockDetection
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b066f609
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b066f609
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b066f609
Branch: refs/heads/ignite-3477-master
Commit: b066f6094997fd3b1b21e624f5599781320cfa83
Parents: 355efcd
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Wed Apr 12 18:33:17 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Wed Apr 12 18:33:17 2017 +0300
----------------------------------------------------------------------
.../TxPessimisticDeadlockDetectionTest.java | 17 +++++++++++++++++
1 file changed, 17 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/b066f609/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxPessimisticDeadlockDetectionTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxPessimisticDeadlockDetectionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxPessimisticDeadlockDetectionTest.java
index 9e7cb1c..4660972 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxPessimisticDeadlockDetectionTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/transactions/TxPessimisticDeadlockDetectionTest.java
@@ -36,6 +36,8 @@ import org.apache.ignite.cache.CacheWriteSynchronizationMode;
import org.apache.ignite.cluster.ClusterNode;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.configuration.MemoryConfiguration;
+import org.apache.ignite.configuration.MemoryPolicyConfiguration;
import org.apache.ignite.configuration.NearCacheConfiguration;
import org.apache.ignite.internal.IgniteInternalFuture;
import org.apache.ignite.internal.IgniteKernal;
@@ -96,6 +98,18 @@ public class TxPessimisticDeadlockDetectionTest extends GridCommonAbstractTest {
cfg.setDiscoverySpi(discoSpi);
}
+ MemoryConfiguration memCfg = new MemoryConfiguration();
+
+ MemoryPolicyConfiguration plc = new MemoryPolicyConfiguration();
+
+ plc.setName("dfltPlc");
+ plc.setSize(MemoryConfiguration.DFLT_MEMORY_POLICY_SIZE * 10);
+
+ memCfg.setDefaultMemoryPolicyName("dfltPlc");
+ memCfg.setMemoryPolicies(plc);
+
+ cfg.setMemoryConfiguration(memCfg);
+
cfg.setClientMode(client);
return cfg;
@@ -190,6 +204,9 @@ public class TxPessimisticDeadlockDetectionTest extends GridCommonAbstractTest {
ccfg.setNearConfiguration(near ? new NearCacheConfiguration() : null);
ccfg.setWriteSynchronizationMode(syncMode);
+ if (cacheMode == LOCAL)
+ ccfg.setMemoryPolicyName("dfltPlc");
+
IgniteCache cache = ignite(0).createCache(ccfg);
if (near) {
[04/22] ignite git commit: Merge remote-tracking branch
'origin/ignite-3477-master' into ignite-3477-master-apache
Posted by ag...@apache.org.
Merge remote-tracking branch 'origin/ignite-3477-master' into ignite-3477-master-apache
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fef28344
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fef28344
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fef28344
Branch: refs/heads/ignite-3477-master
Commit: fef2834495cc2c7245dfb0282f8411f7651b1887
Parents: 4ae084d d69a594
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Tue Apr 11 16:45:37 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Tue Apr 11 16:45:37 2017 +0300
----------------------------------------------------------------------
.../cache/distributed/dht/GridDhtLocalPartition.java | 14 ++++++++------
.../distributed/dht/preloader/GridDhtPreloader.java | 4 ++--
.../eviction/paged/PageEvictionWithRebalanceTest.java | 6 +++---
3 files changed, 13 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
[14/22] ignite git commit: ignite-3477-master fix hibernate class
description
Posted by ag...@apache.org.
ignite-3477-master fix hibernate class description
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5489acea
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5489acea
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5489acea
Branch: refs/heads/ignite-3477-master
Commit: 5489acea248acd40d2f916b31ced361afa778aa2
Parents: b066f60
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Thu Apr 13 11:26:00 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Thu Apr 13 11:26:00 2017 +0300
----------------------------------------------------------------------
.../org/apache/ignite/cache/hibernate/HibernateKeyTransformer.java | 2 +-
.../org/apache/ignite/cache/hibernate/HibernateKeyWrapper.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5489acea/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyTransformer.java
----------------------------------------------------------------------
diff --git a/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyTransformer.java b/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyTransformer.java
index 2922f7f..ecad0b6 100644
--- a/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyTransformer.java
+++ b/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyTransformer.java
@@ -18,7 +18,7 @@
package org.apache.ignite.cache.hibernate;
/**
- *
+ * An interface for transforming hibernate keys to Ignite keys.
*/
public interface HibernateKeyTransformer {
/**
http://git-wip-us.apache.org/repos/asf/ignite/blob/5489acea/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyWrapper.java
----------------------------------------------------------------------
diff --git a/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyWrapper.java b/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyWrapper.java
index 3f2b97f..ff52124 100644
--- a/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyWrapper.java
+++ b/modules/hibernate5/src/main/java/org/apache/ignite/cache/hibernate/HibernateKeyWrapper.java
@@ -24,7 +24,7 @@ import org.hibernate.persister.collection.CollectionPersister;
import org.hibernate.persister.entity.EntityPersister;
/**
- *
+ * Hibernate cache key wrapper.
*/
public class HibernateKeyWrapper {
/** Key. */
[10/22] ignite git commit: ignite-3477-master more info for
investigation
Posted by ag...@apache.org.
ignite-3477-master more info for investigation
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/2b6826e1
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/2b6826e1
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/2b6826e1
Branch: refs/heads/ignite-3477-master
Commit: 2b6826e13deff5b174ad6188f6fd636e455c93d4
Parents: 3a62833
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Wed Apr 12 15:39:47 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Wed Apr 12 15:39:47 2017 +0300
----------------------------------------------------------------------
.../processors/cache/transactions/IgniteTxHandler.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/2b6826e1/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java
index 099a4ae..153ad04 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxHandler.java
@@ -1167,7 +1167,11 @@ public class IgniteTxHandler {
else
sendReply(nodeId, req, true, null);
- assert req.txState() != null || (ctx.tm().tx(req.version()) == null && ctx.tm().nearTx(req.version()) == null) : req;
+ IgniteInternalTx tx0 = ctx.tm().tx(req.version());
+
+ IgniteInternalTx nearTx0 = ctx.tm().nearTx(req.version());
+
+ assert req.txState() != null || (tx0 == null && nearTx0 == null) : req + " tx=" + tx0 + " nearTx=" + nearTx0;
}
/**
[11/22] ignite git commit: ignite-3477-master fix stop node after test
Posted by ag...@apache.org.
ignite-3477-master fix stop node after test
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/10c0364c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/10c0364c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/10c0364c
Branch: refs/heads/ignite-3477-master
Commit: 10c0364c4a6f5bd90d8dfb3d222b4a5792222c7a
Parents: 2b6826e
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Wed Apr 12 15:58:41 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Wed Apr 12 15:58:41 2017 +0300
----------------------------------------------------------------------
.../cache/distributed/near/GridCacheNearTxForceKeyTest.java | 7 +++++++
1 file changed, 7 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/10c0364c/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java
index f1c791e..66f34c9 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java
@@ -80,4 +80,11 @@ public class GridCacheNearTxForceKeyTest extends GridCommonAbstractTest {
assertTrue(ignite0.affinity(null).isPrimary(ignite1.cluster().localNode(), key));
}
+
+ /** {@inheritDoc} */
+ @Override protected void afterTestsStopped() throws Exception {
+ super.afterTestsStopped();
+
+ stopAllGrids();
+ }
}
[20/22] ignite git commit: IGNITE-3477 - Fixing flaky full API suite
Posted by ag...@apache.org.
IGNITE-3477 - Fixing flaky full API suite
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8d2b020c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8d2b020c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8d2b020c
Branch: refs/heads/ignite-3477-master
Commit: 8d2b020c7068a000c2eeaa5096e24cdf8937125d
Parents: 1469f28
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Thu Apr 13 16:36:54 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Thu Apr 13 16:36:54 2017 +0300
----------------------------------------------------------------------
.../processors/cache/H2CacheStoreStrategy.java | 35 ++++++++++++++++----
1 file changed, 28 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/8d2b020c/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java
index 0167b7d..72b049b 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/H2CacheStoreStrategy.java
@@ -54,6 +54,9 @@ public class H2CacheStoreStrategy implements TestCacheStoreStrategy {
/** Pool to get {@link Connection}s from. */
private final JdbcConnectionPool dataSrc;
+ /** */
+ private final int port;
+
/** Script that creates CACHE table. */
private static final String CREATE_CACHE_TABLE =
"create table if not exists CACHE(k binary not null, v binary not null, PRIMARY KEY(k));";
@@ -75,9 +78,14 @@ public class H2CacheStoreStrategy implements TestCacheStoreStrategy {
* @throws IgniteCheckedException If failed.
*/
public H2CacheStoreStrategy() throws IgniteCheckedException {
+ Server srv = null;
+
try {
- Server.createTcpServer().start();
- dataSrc = H2CacheStoreSessionListenerFactory.createDataSource();
+ srv = Server.createTcpServer().start();
+
+ port = srv.getPort();
+
+ dataSrc = H2CacheStoreSessionListenerFactory.createDataSource(port);
try (Connection conn = connection()) {
RunScript.execute(conn, new StringReader(CREATE_CACHE_TABLE));
@@ -86,7 +94,8 @@ public class H2CacheStoreStrategy implements TestCacheStoreStrategy {
}
}
catch (SQLException e) {
- throw new IgniteCheckedException(e);
+ throw new IgniteCheckedException("Failed to set up cache store strategy" +
+ (srv == null ? "" : ": " + srv.getStatus()), e);
}
}
@@ -242,7 +251,7 @@ public class H2CacheStoreStrategy implements TestCacheStoreStrategy {
/** {@inheritDoc} */
@Override public void updateCacheConfiguration(CacheConfiguration<Object, Object> cfg) {
- cfg.setCacheStoreSessionListenerFactories(new H2CacheStoreSessionListenerFactory());
+ cfg.setCacheStoreSessionListenerFactories(new H2CacheStoreSessionListenerFactory(port));
}
/** {@inheritDoc} */
@@ -260,11 +269,23 @@ public class H2CacheStoreStrategy implements TestCacheStoreStrategy {
/** Serializable {@link Factory} producing H2 backed {@link CacheStoreSessionListener}s. */
public static class H2CacheStoreSessionListenerFactory implements Factory<CacheStoreSessionListener> {
+ /** */
+ private int port;
+
+ /**
+ * @param port Port.
+ */
+ public H2CacheStoreSessionListenerFactory(int port) {
+ this.port = port;
+ }
+
/**
* @return Connection pool
*/
- static JdbcConnectionPool createDataSource() {
- JdbcConnectionPool pool = JdbcConnectionPool.create("jdbc:h2:tcp://localhost/mem:TestDb;LOCK_MODE=0", "sa", "");
+ static JdbcConnectionPool createDataSource(int port) {
+ JdbcConnectionPool pool = JdbcConnectionPool.create("jdbc:h2:tcp://localhost:" + port +
+ "/mem:TestDb;LOCK_MODE=0", "sa", "");
+
pool.setMaxConnections(Integer.getInteger("H2_JDBC_CONNECTIONS", 100));
return pool;
}
@@ -272,7 +293,7 @@ public class H2CacheStoreStrategy implements TestCacheStoreStrategy {
/** {@inheritDoc} */
@Override public CacheStoreSessionListener create() {
CacheJdbcStoreSessionListener lsnr = new CacheJdbcStoreSessionListener();
- lsnr.setDataSource(createDataSource());
+ lsnr.setDataSource(createDataSource(port));
return lsnr;
}
}
[15/22] ignite git commit: Merge remote-tracking branch
'origin/ignite-3477-master' into ignite-3477-master
Posted by ag...@apache.org.
Merge remote-tracking branch 'origin/ignite-3477-master' into ignite-3477-master
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6bb4c817
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6bb4c817
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6bb4c817
Branch: refs/heads/ignite-3477-master
Commit: 6bb4c817177c6c1680737ae14e1a9369184caef7
Parents: 5489ace 5839f48
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Thu Apr 13 12:14:54 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Thu Apr 13 12:14:54 2017 +0300
----------------------------------------------------------------------
.gitignore | 31 +-
examples/pom.xml | 6 +
.../examples/springdata/PersonRepository.java | 59 ++++
.../examples/springdata/SpringAppCfg.java | 69 ++++
.../examples/springdata/SpringDataExample.java | 154 +++++++++
.../examples/SpringDataExampleSelfTest.java | 32 ++
.../testsuites/IgniteExamplesSelfTestSuite.java | 2 +
.../rendezvous/RendezvousAffinityFunction.java | 26 +-
.../datastructures/GridCacheSemaphoreImpl.java | 74 ++++-
.../datastructures/GridCacheSemaphoreState.java | 22 ++
...inityFunctionFastPowerOfTwoHashSelfTest.java | 50 +++
...ousAffinityFunctionStandardHashSelfTest.java | 50 +++
...eAbstractDataStructuresFailoverSelfTest.java | 21 +-
.../testsuites/IgniteCacheTestSuite2.java | 4 +
.../binary/include/ignite/binary/binary_type.h | 127 +++----
.../ignite/impl/binary/binary_id_resolver.h | 33 +-
.../ignite/impl/binary/binary_object_impl.h | 3 +-
.../ignite/impl/binary/binary_reader_impl.h | 80 ++++-
.../include/ignite/impl/binary/binary_utils.h | 6 +-
.../ignite/impl/binary/binary_writer_impl.h | 15 +-
.../core-test/include/ignite/binary_test_defs.h | 95 +++---
.../cpp/core-test/include/ignite/complex_type.h | 30 +-
.../cpp/core-test/include/ignite/test_type.h | 37 +--
.../src/binary_identity_resolver_test.cpp | 38 +--
.../cpp/core-test/src/binary_object_test.cpp | 4 +-
.../cpp/core-test/src/binary_test_defs.cpp | 5 +
.../cpp/core-test/src/cache_invoke_test.cpp | 18 +-
.../cpp/core-test/src/cache_query_test.cpp | 12 +-
.../platforms/cpp/core-test/src/cache_test.cpp | 36 +-
.../cpp/core-test/src/continuous_query_test.cpp | 30 +-
.../cpp/core/include/ignite/ignite_binding.h | 6 +-
.../impl/cache/cache_entry_processor_holder.h | 33 +-
.../cpp/odbc-test/include/complex_type.h | 26 +-
.../platforms/cpp/odbc-test/include/test_type.h | 37 +--
.../Binary/BinaryTypeConfiguration.cs | 1 -
.../Impl/Binary/BinaryObject.cs | 2 -
modules/spring-data/README.txt | 32 ++
modules/spring-data/licenses/apache-2.0.txt | 202 ++++++++++++
modules/spring-data/pom.xml | 79 +++++
.../springdata/repository/IgniteRepository.java | 58 ++++
.../config/EnableIgniteRepositories.java | 119 +++++++
.../config/IgniteRepositoriesRegistar.java | 36 ++
.../IgniteRepositoryConfigurationExtension.java | 49 +++
.../springdata/repository/config/Query.java | 37 +++
.../repository/config/RepositoryConfig.java | 39 +++
.../repository/config/package-info.java | 22 ++
.../springdata/repository/package-info.java | 22 ++
.../repository/query/IgniteQuery.java | 83 +++++
.../repository/query/IgniteQueryGenerator.java | 243 ++++++++++++++
.../repository/query/IgniteRepositoryQuery.java | 306 +++++++++++++++++
.../repository/query/package-info.java | 22 ++
.../support/IgniteRepositoryFactory.java | 168 ++++++++++
.../support/IgniteRepositoryFactoryBean.java | 85 +++++
.../support/IgniteRepositoryImpl.java | 160 +++++++++
.../repository/support/package-info.java | 22 ++
.../IgniteSpringDataCrudSelfTest.java | 233 +++++++++++++
.../IgniteSpringDataQueriesSelfTest.java | 291 ++++++++++++++++
.../misc/ApplicationConfiguration.java | 46 +++
.../apache/ignite/springdata/misc/Person.java | 97 ++++++
.../springdata/misc/PersonRepository.java | 92 ++++++
.../springdata/misc/PersonSecondRepository.java | 40 +++
.../testsuites/IgniteSpringDataTestSuite.java | 41 +++
modules/web-console/frontend/.eslintrc | 2 +-
modules/web-console/frontend/app/app.js | 3 -
.../form-field-datepicker.pug | 59 ----
.../form-field-datepicker.scss | 20 --
.../list-of-registered-users.categories.js | 4 +-
.../list-of-registered-users.column-defs.js | 44 +--
.../list-of-registered-users.controller.js | 141 ++++++--
.../list-of-registered-users.scss | 4 +
.../list-of-registered-users.tpl.pug | 76 +++--
.../ui-grid-header/ui-grid-header.scss | 91 -----
.../ui-grid-header/ui-grid-header.tpl.pug | 29 --
.../ui-grid-settings/ui-grid-settings.pug | 33 --
.../ui-grid-settings/ui-grid-settings.scss | 144 --------
.../frontend/app/helpers/jade/mixins.pug | 3 +
.../frontend/app/modules/states/admin.state.js | 11 +-
.../frontend/app/primitives/badge/index.scss | 4 +
.../frontend/app/primitives/btn/index.scss | 41 +++
.../app/primitives/datepicker/index.pug | 60 ++++
.../app/primitives/datepicker/index.scss | 64 ++++
.../frontend/app/primitives/dropdown/index.pug | 43 +++
.../frontend/app/primitives/dropdown/index.scss | 82 +++++
.../frontend/app/primitives/index.js | 8 +
.../frontend/app/primitives/page/index.scss | 35 ++
.../frontend/app/primitives/panel/index.scss | 51 +++
.../frontend/app/primitives/tabs/index.scss | 15 +
.../app/primitives/ui-grid-header/index.scss | 91 +++++
.../app/primitives/ui-grid-header/index.tpl.pug | 29 ++
.../app/primitives/ui-grid-settings/index.pug | 33 ++
.../app/primitives/ui-grid-settings/index.scss | 171 ++++++++++
.../frontend/app/primitives/ui-grid/index.scss | 329 +++++++++++++++++++
.../frontend/public/stylesheets/style.scss | 5 -
modules/web-console/frontend/views/base2.pug | 22 ++
.../frontend/views/settings/admin.tpl.pug | 3 +-
.../web-console/frontend/views/sql/sql.tpl.pug | 1 -
.../cache/websession/WebSessionFilter.java | 22 +-
parent/pom.xml | 1 +
pom.xml | 1 +
99 files changed, 4807 insertions(+), 866 deletions(-)
----------------------------------------------------------------------
[19/22] ignite git commit: Merge branch 'ignite-3477-master' of
https://github.com/gridgain/apache-ignite into ignite-3477-master
Posted by ag...@apache.org.
Merge branch 'ignite-3477-master' of https://github.com/gridgain/apache-ignite into ignite-3477-master
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1469f284
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1469f284
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1469f284
Branch: refs/heads/ignite-3477-master
Commit: 1469f2848e0dc190400b85ee501bf513d47d0239
Parents: 4849447 c31de27
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Thu Apr 13 16:32:43 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Thu Apr 13 16:32:43 2017 +0300
----------------------------------------------------------------------
.../cache/transactions/IgniteTxHandler.java | 6 +-
.../ignite/spi/discovery/tcp/ClientImpl.java | 4 +-
...lerCacheClientRequestsMappingOnMissTest.java | 94 +++++++++++++++-----
.../near/GridCacheNearTxForceKeyTest.java | 7 ++
.../TxPessimisticDeadlockDetectionTest.java | 17 ++++
.../hibernate/HibernateKeyTransformer.java | 2 +-
.../cache/hibernate/HibernateKeyWrapper.java | 2 +-
...QueryNodeRestartDistributedJoinSelfTest.java | 17 +++-
8 files changed, 121 insertions(+), 28 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1469f284/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java
----------------------------------------------------------------------
diff --cc modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java
index 47d54d5,66f34c9..f5b7635
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxForceKeyTest.java
@@@ -78,6 -76,15 +78,13 @@@ public class GridCacheNearTxForceKeyTes
assertNull(cache.getAndPut(key, key));
- awaitPartitionMapExchange();
-
assertTrue(ignite0.affinity(null).isPrimary(ignite1.cluster().localNode(), key));
}
+
+ /** {@inheritDoc} */
+ @Override protected void afterTestsStopped() throws Exception {
+ super.afterTestsStopped();
+
+ stopAllGrids();
+ }
}
[05/22] ignite git commit: Merge remote-tracking branch
'origin/ignite-3477-master' into ignite-3477-master-apache
Posted by ag...@apache.org.
Merge remote-tracking branch 'origin/ignite-3477-master' into ignite-3477-master-apache
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/67cd7193
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/67cd7193
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/67cd7193
Branch: refs/heads/ignite-3477-master
Commit: 67cd71939b05bba426450d37b322b67eceb397da
Parents: fef2834 c9fd6b9
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Tue Apr 11 17:12:39 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Tue Apr 11 17:12:39 2017 +0300
----------------------------------------------------------------------
modules/platforms/cpp/core-test/config/cache-test-default.xml | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
[16/22] ignite git commit: ClientReconnectMessage id shouldn't be
saved for lastMsgId on client side
Posted by ag...@apache.org.
ClientReconnectMessage id shouldn't be saved for lastMsgId on client side
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a563ba05
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a563ba05
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a563ba05
Branch: refs/heads/ignite-3477-master
Commit: a563ba0556d940cc3665973b6098758786db72c1
Parents: 6bb4c81
Author: Sergey Chugunov <se...@gmail.com>
Authored: Wed Apr 12 13:41:09 2017 +0300
Committer: Sergey Chugunov <se...@gmail.com>
Committed: Thu Apr 13 12:48:36 2017 +0300
----------------------------------------------------------------------
.../java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/a563ba05/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
index 6c7c220..34ee414 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java
@@ -1842,7 +1842,9 @@ class ClientImpl extends TcpDiscoveryImpl {
spi.stats.onMessageProcessingFinished(msg);
- if (spi.ensured(msg) && state == CONNECTED)
+ if (spi.ensured(msg)
+ && state == CONNECTED
+ && !(msg instanceof TcpDiscoveryClientReconnectMessage))
lastMsgId = msg.id();
}
[09/22] ignite git commit: Merge branch 'ignite-3477-master-apache'
into ignite-3477-master
Posted by ag...@apache.org.
Merge branch 'ignite-3477-master-apache' into ignite-3477-master
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3a62833a
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3a62833a
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3a62833a
Branch: refs/heads/ignite-3477-master
Commit: 3a62833adb72ca3b0998b0df5c7026196dfd943d
Parents: 5cded42 3e5e1f0
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Wed Apr 12 15:08:50 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Wed Apr 12 15:08:50 2017 +0300
----------------------------------------------------------------------
.../processors/cache/GridCacheContext.java | 2 -
.../distributed/dht/GridDhtLocalPartition.java | 2 +-
.../dht/atomic/GridDhtAtomicCache.java | 37 +++++----
.../IgniteCacheTopologySafeGetSelfTest.java | 2 +-
.../cpp/core-test/src/continuous_query_test.cpp | 11 ++-
.../core/include/ignite/impl/module_manager.h | 26 ++++++
.../examples/include/ignite/examples/person.h | 1 -
.../Cache/CacheMetricsTest.cs | 86 +++++++++-----------
.../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 80 ------------------
.../Impl/Cache/CacheMetricsImpl.cs | 70 ----------------
10 files changed, 92 insertions(+), 225 deletions(-)
----------------------------------------------------------------------
[22/22] ignite git commit: Merge branch 'ignite-3477-master' of
https://git-wip-us.apache.org/repos/asf/ignite into ignite-3477-master
Posted by ag...@apache.org.
Merge branch 'ignite-3477-master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-3477-master
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/00d63a8a
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/00d63a8a
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/00d63a8a
Branch: refs/heads/ignite-3477-master
Commit: 00d63a8a960680749920b32d12462717037026e3
Parents: 10485a0 4310583
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Thu Apr 13 16:37:47 2017 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Thu Apr 13 16:37:47 2017 +0300
----------------------------------------------------------------------
examples/pom-standalone-lgpl.xml | 6 ++++++
examples/pom-standalone.xml | 6 ++++++
2 files changed, 12 insertions(+)
----------------------------------------------------------------------
[06/22] ignite git commit: Merge remote-tracking branch
'origin/ignite-3477-master' into ignite-3477-master-apache
Posted by ag...@apache.org.
Merge remote-tracking branch 'origin/ignite-3477-master' into ignite-3477-master-apache
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/81e75380
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/81e75380
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/81e75380
Branch: refs/heads/ignite-3477-master
Commit: 81e75380004918bb30ba686b950fd1b0a6fed5a7
Parents: 67cd719 e319697
Author: Dmitriy Govorukhin <dg...@gridgain.com>
Authored: Tue Apr 11 17:53:24 2017 +0300
Committer: Dmitriy Govorukhin <dg...@gridgain.com>
Committed: Tue Apr 11 17:53:24 2017 +0300
----------------------------------------------------------------------
.../dht/atomic/GridDhtAtomicCache.java | 37 ++++++++++----------
.../Impl/Cache/CacheMetricsImpl.cs | 10 ------
2 files changed, 19 insertions(+), 28 deletions(-)
----------------------------------------------------------------------