You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by an...@apache.org on 2015/10/08 05:01:39 UTC
[01/29] ignite git commit: Release notes
Repository: ignite
Updated Branches:
refs/heads/ignite-1168 6e0f41593 -> 5ef7c38f1
Release notes
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/60349316
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/60349316
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/60349316
Branch: refs/heads/ignite-1168
Commit: 603493169e66e9bc6a9f9129b2a7709fab1a6419
Parents: 7db44f1
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Thu Sep 24 13:33:24 2015 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Thu Sep 24 13:33:24 2015 +0300
----------------------------------------------------------------------
RELEASE_NOTES.txt | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/60349316/RELEASE_NOTES.txt
----------------------------------------------------------------------
diff --git a/RELEASE_NOTES.txt b/RELEASE_NOTES.txt
index d7097fd..cd0c2a2 100644
--- a/RELEASE_NOTES.txt
+++ b/RELEASE_NOTES.txt
@@ -7,6 +7,8 @@ Apache Ignite In-Memory Data Fabric 1.4
* Added support for log4j2.
* Added versioned entry to cache API.
* Added client node based JDBC driver implementation.
+* Fixed consistency issue for custom events processing within discovery.
+* Fixed race in cache swap/unswap logic.
* Fixed IGNITE_HOME resolution with JBoss.
* Fixed configuration file resolution on classpath.
* Fixed MBean registration for caches.
[10/29] ignite git commit: skip deployment of schema-import demo
Posted by an...@apache.org.
skip deployment of schema-import demo
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/656b1184
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/656b1184
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/656b1184
Branch: refs/heads/ignite-1168
Commit: 656b11847c413689db8e7f7a85baef9f1de223c7
Parents: 008c273
Author: Anton Vinogradov <av...@apache.org>
Authored: Fri Sep 25 10:54:22 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Fri Sep 25 10:54:22 2015 +0300
----------------------------------------------------------------------
examples/schema-import/pom.xml | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/656b1184/examples/schema-import/pom.xml
----------------------------------------------------------------------
diff --git a/examples/schema-import/pom.xml b/examples/schema-import/pom.xml
index f51007a..5358e71 100644
--- a/examples/schema-import/pom.xml
+++ b/examples/schema-import/pom.xml
@@ -20,7 +20,8 @@
<!--
POM file.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
@@ -88,6 +89,14 @@
<target>1.7</target>
</configuration>
</plugin>
+
+ <plugin>
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-deploy-plugin</artifactId>
+ <configuration>
+ <skip>true</skip>
+ </configuration>
+ </plugin>
</plugins>
</build>
</project>
[04/29] ignite git commit: 1.4.0-SNAPSHOT
Posted by an...@apache.org.
1.4.0-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fb9b14db
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fb9b14db
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fb9b14db
Branch: refs/heads/ignite-1168
Commit: fb9b14dbf9b8d66a9bfb3e2a4a02b4f43a5f5ac6
Parents: 169066b
Author: Ignite Teamcity <ig...@apache.org>
Authored: Thu Sep 24 14:38:34 2015 +0300
Committer: Ignite Teamcity <ig...@apache.org>
Committed: Thu Sep 24 14:38:34 2015 +0300
----------------------------------------------------------------------
pom.xml | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fb9b14db/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index f70bf3a..6d10b42 100644
--- a/pom.xml
+++ b/pom.xml
@@ -303,7 +303,7 @@
<!-- hotfix according to https://issues.apache.org/jira/browse/IGNITE-1399. Remove at 1.5 -->
<move todir="${basedir}/target/temp/release-package/libs/optional/ignite-platform" failonerror="false">
- <fileset dir="${basedir}/target/release-package/libs/optional/ignite-platform"/>
+ <fileset dir="${basedir}/target/release-package/libs/optional/ignite-platform" />
</move>
<zip destfile="${basedir}/target/bin/${ignite.zip.pattern}.zip" encoding="UTF-8">
@@ -325,7 +325,7 @@
<!-- hotfix according to https://issues.apache.org/jira/browse/IGNITE-1399. Remove at 1.5 -->
<move todir="${basedir}/target/release-package/libs/optional/ignite-platform" failonerror="false">
- <fileset dir="${basedir}/target/temp/release-package/libs/optional/ignite-platform"/>
+ <fileset dir="${basedir}/target/temp/release-package/libs/optional/ignite-platform" />
</move>
</target>
</configuration>
[12/29] ignite git commit: 1.4.0-SNAPSHOT
Posted by an...@apache.org.
1.4.0-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/87ff90c0
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/87ff90c0
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/87ff90c0
Branch: refs/heads/ignite-1168
Commit: 87ff90c0b69224f7546032291f0d5da41d358b2e
Parents: 8e21daa
Author: Ignite Teamcity <ig...@apache.org>
Authored: Fri Sep 25 15:55:58 2015 +0300
Committer: Ignite Teamcity <ig...@apache.org>
Committed: Fri Sep 25 15:55:58 2015 +0300
----------------------------------------------------------------------
examples/schema-import/pom.xml | 3 +--
pom.xml | 12 ++++++------
2 files changed, 7 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/87ff90c0/examples/schema-import/pom.xml
----------------------------------------------------------------------
diff --git a/examples/schema-import/pom.xml b/examples/schema-import/pom.xml
index 5358e71..0c5cddd 100644
--- a/examples/schema-import/pom.xml
+++ b/examples/schema-import/pom.xml
@@ -20,8 +20,7 @@
<!--
POM file.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
http://git-wip-us.apache.org/repos/asf/ignite/blob/87ff90c0/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index b1a9f65..6ddc443 100644
--- a/pom.xml
+++ b/pom.xml
@@ -627,12 +627,12 @@
</copy>
<!-- appending filename to md5 and sha1 files. to be improved. -->
- <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.md5" append="true" message=" ${project.artifactId}-${project.version}-src.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.sha1" append="true" message=" ${project.artifactId}-${project.version}-src.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.md5" append="true" message=" ${project.artifactId}-${project.version}-src.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.sha1" append="true" message=" ${project.artifactId}-${project.version}-src.zip" />
</target>
</configuration>
</execution>
[26/29] ignite git commit: ignite-1112 Tests muted.
Posted by an...@apache.org.
ignite-1112 Tests muted.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b3d347e3
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b3d347e3
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b3d347e3
Branch: refs/heads/ignite-1168
Commit: b3d347e35a254928fd1c4a0473f1b17d642c72f3
Parents: 2580994
Author: agura <ag...@gridgain.com>
Authored: Tue Oct 6 15:38:04 2015 +0300
Committer: agura <ag...@gridgain.com>
Committed: Tue Oct 6 15:38:04 2015 +0300
----------------------------------------------------------------------
...cheAtomicNearEnabledFairAffinityMultiJvmFullApiSelfTest.java | 5 +++++
.../GridCacheAtomicNearEnabledMultiJvmFullApiSelfTest.java | 5 +++++
2 files changed, 10 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/b3d347e3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledFairAffinityMultiJvmFullApiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledFairAffinityMultiJvmFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledFairAffinityMultiJvmFullApiSelfTest.java
index 8edf8b4..0948a1d 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledFairAffinityMultiJvmFullApiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledFairAffinityMultiJvmFullApiSelfTest.java
@@ -28,4 +28,9 @@ public class GridCacheAtomicNearEnabledFairAffinityMultiJvmFullApiSelfTest exten
protected boolean isMultiJvm() {
return true;
}
+
+ /** {@inheritDoc} */
+ @Override public void testPutAllPutAll() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1112");
+ }
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/b3d347e3/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledMultiJvmFullApiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledMultiJvmFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledMultiJvmFullApiSelfTest.java
index d11c679..8623de1 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledMultiJvmFullApiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/multijvm/GridCacheAtomicNearEnabledMultiJvmFullApiSelfTest.java
@@ -28,4 +28,9 @@ public class GridCacheAtomicNearEnabledMultiJvmFullApiSelfTest extends
protected boolean isMultiJvm() {
return true;
}
+
+ /** {@inheritDoc} */
+ @Override public void testPutAllPutAll() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1112");
+ }
}
\ No newline at end of file
[03/29] ignite git commit: schema-import examples fix
Posted by an...@apache.org.
schema-import examples fix
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/169066b9
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/169066b9
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/169066b9
Branch: refs/heads/ignite-1168
Commit: 169066b98ae89cf9e5eba8872817f466947c5919
Parents: 59bc35a
Author: Anton Vinogradov <av...@apache.org>
Authored: Thu Sep 24 14:33:26 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Thu Sep 24 14:33:26 2015 +0300
----------------------------------------------------------------------
examples/schema-import/pom.xml | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/169066b9/examples/schema-import/pom.xml
----------------------------------------------------------------------
diff --git a/examples/schema-import/pom.xml b/examples/schema-import/pom.xml
index d302606..fdbd631 100644
--- a/examples/schema-import/pom.xml
+++ b/examples/schema-import/pom.xml
@@ -26,13 +26,19 @@
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
+ <parent>
+ <groupId>org.apache.ignite</groupId>
+ <artifactId>ignite-parent</artifactId>
+ <version>1</version>
+ <relativePath>../../parent</relativePath>
+ </parent>
+
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
- <groupId>org.apache.ignite</groupId>
<artifactId>ignite-schema-import-demo</artifactId>
- <version>${project.version}</version>
+ <version>1.0.0-SNAPSHOT</version>
<dependencies>
<dependency>
[27/29] ignite git commit: ignite-1624 Tests muted
Posted by an...@apache.org.
ignite-1624 Tests muted
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f60cba79
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f60cba79
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f60cba79
Branch: refs/heads/ignite-1168
Commit: f60cba7986bcde8578e4e0dc4a065fb834514373
Parents: b3d347e
Author: agura <ag...@gridgain.com>
Authored: Wed Oct 7 13:34:33 2015 +0300
Committer: agura <ag...@gridgain.com>
Committed: Wed Oct 7 13:34:33 2015 +0300
----------------------------------------------------------------------
.../ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/f60cba79/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
index 9fbf5b1..0bb9a42 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
@@ -1074,6 +1074,8 @@ public class TcpClientDiscoverySpiSelfTest extends GridCommonAbstractTest {
* @throws Exception If failed.
*/
public void testJoinError() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1624");
+
startServerNodes(1);
Ignite ignite = G.ignite("server-0");
[22/29] ignite git commit: Minor fixes
Posted by an...@apache.org.
Minor fixes
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8fc14ec0
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8fc14ec0
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8fc14ec0
Branch: refs/heads/ignite-1168
Commit: 8fc14ec004cc87d731f4d089f5b5c44c91831e40
Parents: 8616889
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Tue Oct 6 13:36:25 2015 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Tue Oct 6 13:36:25 2015 +0300
----------------------------------------------------------------------
.../processors/cache/distributed/dht/GridDhtLockRequest.java | 5 ++---
modules/yardstick/pom.xml | 6 ++++++
2 files changed, 8 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/8fc14ec0/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java
index 87aa256..99c1b86 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtLockRequest.java
@@ -299,8 +299,7 @@ public class GridDhtLockRequest extends GridDistributedLockRequest {
return accessTtl;
}
- /** {@inheritDoc}
- * @param ctx*/
+ /** {@inheritDoc} */
@Override public void prepareMarshal(GridCacheSharedContext ctx) throws IgniteCheckedException {
super.prepareMarshal(ctx);
@@ -529,4 +528,4 @@ public class GridDhtLockRequest extends GridDistributedLockRequest {
@Override public String toString() {
return S.toString(GridDhtLockRequest.class, this, "super", super.toString());
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/8fc14ec0/modules/yardstick/pom.xml
----------------------------------------------------------------------
diff --git a/modules/yardstick/pom.xml b/modules/yardstick/pom.xml
index 2f0c5fe..d18e1a9 100644
--- a/modules/yardstick/pom.xml
+++ b/modules/yardstick/pom.xml
@@ -59,6 +59,12 @@
</dependency>
<dependency>
+ <groupId>org.apache.ignite</groupId>
+ <artifactId>ignite-log4j</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+
+ <dependency>
<groupId>org.yardstickframework</groupId>
<artifactId>yardstick</artifactId>
<version>${yardstick.version}</version>
[28/29] ignite git commit: Fix REST authentication.
Posted by an...@apache.org.
Fix REST authentication.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f025714e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f025714e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f025714e
Branch: refs/heads/ignite-1168
Commit: f025714ef0d21ffff7ebf6088c254f26dd9aa3fc
Parents: f60cba7
Author: ashutak <as...@gridgain.com>
Authored: Wed Oct 7 16:11:18 2015 +0300
Committer: ashutak <as...@gridgain.com>
Committed: Wed Oct 7 16:11:18 2015 +0300
----------------------------------------------------------------------
.../JettyRestProcessorAbstractSelfTest.java | 27 +-
.../apache/ignite/IgniteSystemProperties.java | 3 +
.../processors/rest/GridRestProcessor.java | 356 +++++++++++++++++--
.../handlers/cache/GridCacheCommandHandler.java | 2 +-
.../ignite/internal/util/IgniteUtils.java | 2 +-
5 files changed, 341 insertions(+), 49 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/f025714e/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/JettyRestProcessorAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/JettyRestProcessorAbstractSelfTest.java b/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/JettyRestProcessorAbstractSelfTest.java
index 8db4cd7..ac0edff 100644
--- a/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/JettyRestProcessorAbstractSelfTest.java
+++ b/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/JettyRestProcessorAbstractSelfTest.java
@@ -84,6 +84,13 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
protected abstract int restPort();
/**
+ * @return Security enabled flag. Should be the same with {@code ctx.security().enabled()}.
+ */
+ protected boolean securityEnabled() {
+ return false;
+ }
+
+ /**
* @param params Command parameters.
* @return Returned content.
* @throws Exception If failed.
@@ -133,7 +140,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
return "\\{\\\"affinityNodeId\\\":\\\"\\w{8}-\\w{4}-\\w{4}-\\w{4}-\\w{12}\\\"\\," +
"\\\"error\\\":\\\"\\\"\\," +
"\\\"response\\\":\\\"" + res + "\\\"\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -157,7 +164,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
private String integerPattern(int res, boolean success) {
return "\\{\\\"error\\\":\\\"\\\"\\," +
"\\\"response\\\":" + res + "\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -170,7 +177,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
return "\\{\\\"affinityNodeId\\\":\\\"\\\"\\," +
"\\\"error\\\":\\\"\\\"\\," +
"\\\"response\\\":" + res + "\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -183,7 +190,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
return "\\{\\\"affinityNodeId\\\":\\\"\\\"\\," +
"\\\"error\\\":\\\"\\\"\\," +
"\\\"response\\\":" + res + "\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -196,7 +203,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
return "\\{\\\"affinityNodeId\\\":\\\"\\w{8}-\\w{4}-\\w{4}-\\w{4}-\\w{12}\\\"\\," +
"\\\"error\\\":\\\"\\\"\\," +
"\\\"response\\\":" + res + "\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -209,7 +216,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
return "\\{\\\"affinityNodeId\\\":\\\"\\\"\\," +
"\\\"error\\\":\\\"\\\"\\," +
"\\\"response\\\":" + res + "\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -222,7 +229,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
return "\\{\\\"affinityNodeId\\\":\\\"(\\w{8}-\\w{4}-\\w{4}-\\w{4}-\\w{12})?\\\"\\," +
"\\\"error\\\":\\\"\\\"\\," +
"\\\"response\\\":" + res + "\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -234,7 +241,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
private String pattern(String res, boolean success) {
return "\\{\\\"error\\\":\\\"" + (!success ? ".+" : "") + "\\\"\\," +
"\\\"response\\\":" + res + "\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -246,7 +253,7 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
private String stringPattern(String res, boolean success) {
return "\\{\\\"error\\\":\\\"" + (!success ? ".+" : "") + "\\\"\\," +
"\\\"response\\\":\\\"" + res + "\\\"\\," +
- "\\\"sessionToken\\\":\\\"\\\"," +
+ "\\\"sessionToken\\\":\\\"" + (securityEnabled() && success ? ".+" : "") + "\\\"," +
"\\\"successStatus\\\":" + (success ? 0 : 1) + "\\}";
}
@@ -1316,4 +1323,4 @@ public abstract class JettyRestProcessorAbstractSelfTest extends AbstractRestPro
return id;
}
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/f025714e/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
index 1e4c8b7..5d3b08b 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteSystemProperties.java
@@ -96,6 +96,9 @@ public final class IgniteSystemProperties {
*/
public static final String IGNITE_JETTY_LOG_NO_OVERRIDE = "IGNITE_JETTY_LOG_NO_OVERRIDE";
+ /** This property allow rewriting default ({@code 30}) rest session expire time (in seconds). */
+ public static final String IGNITE_REST_SESSION_TIMEOUT = "IGNITE_REST_SESSION_TIMEOUT";
+
/**
* This property allows to override maximum count of task results stored on one node
* in REST processor.
http://git-wip-us.apache.org/repos/asf/ignite/blob/f025714e/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/GridRestProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/GridRestProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/GridRestProcessor.java
index d606ba4..d54c8bb 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/GridRestProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/GridRestProcessor.java
@@ -20,6 +20,7 @@ package org.apache.ignite.internal.processors.rest;
import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Collection;
import java.util.EnumMap;
import java.util.HashMap;
@@ -30,7 +31,9 @@ import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.RejectedExecutionException;
+import java.util.concurrent.atomic.AtomicLong;
import org.apache.ignite.IgniteCheckedException;
+import org.apache.ignite.IgniteSystemProperties;
import org.apache.ignite.configuration.ConnectorConfiguration;
import org.apache.ignite.configuration.ConnectorMessageInterceptor;
import org.apache.ignite.internal.GridKernalContext;
@@ -53,8 +56,10 @@ import org.apache.ignite.internal.processors.security.SecurityContext;
import org.apache.ignite.internal.util.GridSpinReadWriteLock;
import org.apache.ignite.internal.util.future.GridFinishedFuture;
import org.apache.ignite.internal.util.typedef.C1;
+import org.apache.ignite.internal.util.typedef.F;
import org.apache.ignite.internal.util.typedef.X;
import org.apache.ignite.internal.util.typedef.internal.LT;
+import org.apache.ignite.internal.util.typedef.internal.S;
import org.apache.ignite.internal.util.typedef.internal.U;
import org.apache.ignite.internal.util.worker.GridWorker;
import org.apache.ignite.internal.util.worker.GridWorkerFuture;
@@ -65,6 +70,7 @@ import org.apache.ignite.plugin.security.AuthenticationContext;
import org.apache.ignite.plugin.security.SecurityCredentials;
import org.apache.ignite.plugin.security.SecurityException;
import org.apache.ignite.plugin.security.SecurityPermission;
+import org.apache.ignite.thread.IgniteThread;
import org.jsr166.LongAdder8;
import static org.apache.ignite.internal.processors.rest.GridRestResponse.STATUS_AUTH_FAILED;
@@ -80,8 +86,11 @@ public class GridRestProcessor extends GridProcessorAdapter {
private static final String HTTP_PROTO_CLS =
"org.apache.ignite.internal.processors.rest.protocols.http.jetty.GridJettyRestProtocol";
- /** */
- public static final byte[] ZERO_BYTES = new byte[0];
+ /** Delay between sessions timeout checks. */
+ private static final int SES_TIMEOUT_CHECK_DELAY = 1_000;
+
+ /** Default session timout. */
+ private static final int DEFAULT_SES_TIMEOUT = 30_000;
/** Protocols. */
private final Collection<GridRestProtocol> protos = new ArrayList<>();
@@ -98,8 +107,14 @@ public class GridRestProcessor extends GridProcessorAdapter {
/** Workers count. */
private final LongAdder8 workersCnt = new LongAdder8();
- /** SecurityContext map. */
- private ConcurrentMap<UUID, SecurityContext> sesMap = new ConcurrentHashMap<>();
+ /** ClientId-SessionId map. */
+ private final ConcurrentMap<UUID, UUID> clientId2SesId = new ConcurrentHashMap<>();
+
+ /** SessionId-Session map. */
+ private final ConcurrentMap<UUID, Session> sesId2Ses = new ConcurrentHashMap<>();
+
+ /** */
+ private final Thread sesTimeoutCheckerThread;
/** Protocol handler. */
private final GridRestProtocolHandler protoHnd = new GridRestProtocolHandler() {
@@ -112,6 +127,9 @@ public class GridRestProcessor extends GridProcessorAdapter {
}
};
+ /** Session time to live. */
+ private final long sesTtl;
+
/**
* @param req Request.
* @return Future.
@@ -195,22 +213,40 @@ public class GridRestProcessor extends GridProcessorAdapter {
if (log.isDebugEnabled())
log.debug("Received request from client: " + req);
- SecurityContext subjCtx = null;
-
if (ctx.security().enabled()) {
+ Session ses;
+
try {
- subjCtx = authenticate(req);
+ ses = session(req);
+ }
+ catch (IgniteCheckedException e) {
+ GridRestResponse res = new GridRestResponse(STATUS_FAILED, e.getMessage());
- authorize(req, subjCtx);
+ return new GridFinishedFuture<>(res);
+ }
+
+ assert ses != null;
+
+ req.clientId(ses.clientId);
+ req.sessionToken(U.uuidToBytes(ses.sesId));
+
+ if (log.isDebugEnabled())
+ log.debug("Next clientId and sessionToken were extracted according to request: " +
+ "[clientId="+req.clientId()+", sesTok="+Arrays.toString(req.sessionToken())+"]");
+
+ SecurityContext secCtx0 = ses.secCtx;
+
+ try {
+ if (secCtx0 == null)
+ ses.secCtx = secCtx0 = authenticate(req);
+
+ authorize(req, secCtx0);
}
catch (SecurityException e) {
- assert subjCtx != null;
+ assert secCtx0 != null;
GridRestResponse res = new GridRestResponse(STATUS_SECURITY_CHECK_FAILED, e.getMessage());
- updateSession(req, subjCtx);
- res.sessionTokenBytes(ZERO_BYTES);
-
return new GridFinishedFuture<>(res);
}
catch (IgniteCheckedException e) {
@@ -228,16 +264,18 @@ public class GridRestProcessor extends GridProcessorAdapter {
return new GridFinishedFuture<>(
new IgniteCheckedException("Failed to find registered handler for command: " + req.command()));
- final SecurityContext subjCtx0 = subjCtx;
-
return res.chain(new C1<IgniteInternalFuture<GridRestResponse>, GridRestResponse>() {
@Override public GridRestResponse apply(IgniteInternalFuture<GridRestResponse> f) {
GridRestResponse res;
+ boolean failed = false;
+
try {
res = f.get();
}
catch (Exception e) {
+ failed = true;
+
if (!X.hasCause(e, VisorClusterGroupEmptyException.class))
LT.error(log, e, "Failed to handle request: " + req.command());
@@ -249,10 +287,8 @@ public class GridRestProcessor extends GridProcessorAdapter {
assert res != null;
- if (ctx.security().enabled()) {
- updateSession(req, subjCtx0);
- res.sessionTokenBytes(ZERO_BYTES);
- }
+ if (ctx.security().enabled() && !failed)
+ res.sessionTokenBytes(req.sessionToken());
interceptResponse(res, req);
@@ -262,10 +298,137 @@ public class GridRestProcessor extends GridProcessorAdapter {
}
/**
+ * @param req Request.
+ * @return Not null session.
+ * @throws IgniteCheckedException If failed.
+ */
+ private Session session(final GridRestRequest req) throws IgniteCheckedException {
+ final UUID clientId = req.clientId();
+ final byte[] sesTok = req.sessionToken();
+
+ while (true) {
+ if (F.isEmpty(sesTok) && clientId == null) {
+ Session ses = Session.random();
+
+ UUID oldSesId = clientId2SesId.put(ses.clientId, ses.sesId);
+
+ assert oldSesId == null : "Got an illegal state for request: " + req;
+
+ Session oldSes = sesId2Ses.put(ses.sesId, ses);
+
+ assert oldSes == null : "Got an illegal state for request: " + req;
+
+ return ses;
+ }
+
+ if (F.isEmpty(sesTok) && clientId != null) {
+ UUID sesId = clientId2SesId.get(clientId);
+
+ if (sesId == null) {
+ Session ses = Session.fromClientId(clientId);
+
+ if (clientId2SesId.putIfAbsent(ses.clientId, ses.sesId) != null)
+ continue; // Another thread already register session with the clientId.
+
+ Session prevSes = sesId2Ses.put(ses.sesId, ses);
+
+ assert prevSes == null : "Got an illegal state for request: " + req;
+
+ return ses;
+ }
+ else {
+ Session ses = sesId2Ses.get(sesId);
+
+ if (ses == null || !ses.touch())
+ continue; // Need to wait while timeout thread complete removing of timed out sessions.
+
+ return ses;
+ }
+ }
+
+ if (!F.isEmpty(sesTok) && clientId == null) {
+ UUID sesId = U.bytesToUuid(sesTok, 0);
+
+ Session ses = sesId2Ses.get(sesId);
+
+ if (ses == null)
+ throw new IgniteCheckedException("Failed to handle request - unknown session token " +
+ "(maybe expired session) [sesTok=" + U.byteArray2HexString(sesTok) + "]");
+
+ if (!ses.touch())
+ continue; // Need to wait while timeout thread complete removing of timed out sessions.
+
+ return ses;
+ }
+
+ if (!F.isEmpty(sesTok) && clientId != null) {
+ UUID sesId = clientId2SesId.get(clientId);
+
+ if (sesId == null || !sesId.equals(U.bytesToUuid(sesTok, 0)))
+ throw new IgniteCheckedException("Failed to handle request - unsupported case (misamatched " +
+ "clientId and session token) [clientId=" + clientId + ", sesTok=" +
+ U.byteArray2HexString(sesTok) + "]");
+
+ Session ses = sesId2Ses.get(sesId);
+
+ if (ses == null)
+ throw new IgniteCheckedException("Failed to handle request - unknown session token " +
+ "(maybe expired session) [sesTok=" + U.byteArray2HexString(sesTok) + "]");
+
+ if (!ses.touch())
+ continue; // Need to wait while timeout thread complete removing of timed out sessions.
+
+ return ses;
+ }
+
+ assert false : "Got an unreachable state.";
+ }
+ }
+
+ /**
* @param ctx Context.
*/
public GridRestProcessor(GridKernalContext ctx) {
super(ctx);
+
+ long sesExpTime0;
+ String sesExpTime = null;
+
+ try {
+ sesExpTime = System.getProperty(IgniteSystemProperties.IGNITE_REST_SESSION_TIMEOUT);
+
+ if (sesExpTime != null)
+ sesExpTime0 = Long.valueOf(sesExpTime) * 1000;
+ else
+ sesExpTime0 = DEFAULT_SES_TIMEOUT;
+ }
+ catch (NumberFormatException ignore) {
+ U.warn(log, "Failed parsing IGNITE_REST_SESSION_TIMEOUT system variable [IGNITE_REST_SESSION_TIMEOUT="
+ + sesExpTime + "]");
+
+ sesExpTime0 = DEFAULT_SES_TIMEOUT;
+ }
+
+ sesTtl = sesExpTime0;
+
+ sesTimeoutCheckerThread = new IgniteThread(ctx.gridName(), "session-timeout-worker",
+ new GridWorker(ctx.gridName(), "session-timeout-worker", log) {
+ @Override protected void body() throws InterruptedException {
+ while (!isCancelled()) {
+ Thread.sleep(SES_TIMEOUT_CHECK_DELAY);
+
+ for (Map.Entry<UUID, Session> e : sesId2Ses.entrySet()) {
+ Session ses = e.getValue();
+
+ if (ses.isTimedOut(sesTtl)) {
+ sesId2Ses.remove(ses.sesId, ses);
+
+ clientId2SesId.remove(ses.clientId, ses.sesId);
+ }
+ }
+ }
+ }
+ });
}
/** {@inheritDoc} */
@@ -310,6 +473,10 @@ public class GridRestProcessor extends GridProcessorAdapter {
for (GridRestProtocol proto : protos)
proto.onKernalStart();
+ sesTimeoutCheckerThread.setDaemon(true);
+
+ sesTimeoutCheckerThread.start();
+
startLatch.countDown();
if (log.isDebugEnabled())
@@ -334,6 +501,8 @@ public class GridRestProcessor extends GridProcessorAdapter {
}
}
+ U.interrupt(sesTimeoutCheckerThread);
+
if (interrupted)
Thread.currentThread().interrupt();
@@ -483,13 +652,8 @@ public class GridRestProcessor extends GridProcessorAdapter {
* @throws IgniteCheckedException If authentication failed.
*/
private SecurityContext authenticate(GridRestRequest req) throws IgniteCheckedException {
- UUID clientId = req.clientId();
- SecurityContext secCtx = clientId == null ? null : sesMap.get(clientId);
+ assert req.clientId() != null;
- if (secCtx != null)
- return secCtx;
-
- // Authenticate client if invalid session.
AuthenticationContext authCtx = new AuthenticationContext();
authCtx.subjectType(REMOTE_CLIENT);
@@ -531,18 +695,6 @@ public class GridRestProcessor extends GridProcessorAdapter {
}
/**
- * Update session.
- * @param req REST request.
- * @param sCtx Security context.
- */
- private void updateSession(GridRestRequest req, SecurityContext sCtx) {
- if (sCtx != null) {
- UUID id = req.clientId();
- sesMap.put(id, sCtx);
- }
- }
-
- /**
* @param req REST request.
* @param sCtx Security context.
* @throws SecurityException If authorization failed.
@@ -719,4 +871,134 @@ public class GridRestProcessor extends GridProcessorAdapter {
X.println(">>> protosSize: " + protos.size());
X.println(">>> handlersSize: " + handlers.size());
}
-}
\ No newline at end of file
+
+ /**
+ * Session.
+ */
+ private static class Session {
+ /** Expiration flag. It's a final state of lastToucnTime. */
+ private static final Long TIMEDOUT_FLAG = 0L;
+
+ /** Client id. */
+ private final UUID clientId;
+
+ /** Session token id. */
+ private final UUID sesId;
+
+ /** Security context. */
+ private volatile SecurityContext secCtx;
+
+ /**
+ * Time when session is used last time.
+ * If this time was set at TIMEDOUT_FLAG, then it should never be changed.
+ */
+ private final AtomicLong lastTouchTime = new AtomicLong(U.currentTimeMillis());
+
+ /**
+ * @param clientId Client ID.
+ * @param sesId session ID.
+ */
+ private Session(UUID clientId, UUID sesId) {
+ this.clientId = clientId;
+ this.sesId = sesId;
+ }
+
+ /**
+ * Static constructor.
+ *
+ * @return New session instance with random client ID and random session ID.
+ */
+ static Session random() {
+ return new Session(UUID.randomUUID(), UUID.randomUUID());
+ }
+
+ /**
+ * Static constructor.
+ *
+ * @param clientId Client ID.
+ * @return New session instance with given client ID and random session ID.
+ */
+ static Session fromClientId(UUID clientId) {
+ return new Session(clientId, UUID.randomUUID());
+ }
+
+ /**
+ * Static constructor.
+ *
+ * @param sesTokId Session token ID.
+ * @return New session instance with random client ID and given session ID.
+ */
+ static Session fromSessionToken(UUID sesTokId) {
+ return new Session(UUID.randomUUID(), sesTokId);
+ }
+
+ /**
+ * Checks expiration of session and if expired then sets TIMEDOUT_FLAG.
+ *
+ * @param sesTimeout Session timeout.
+ * @return <code>True</code> if expired.
+ * @see #touch()
+ */
+ boolean isTimedOut(long sesTimeout) {
+ long time0 = lastTouchTime.get();
+
+ if (time0 == TIMEDOUT_FLAG)
+ return true;
+
+ return U.currentTimeMillis() - time0 > sesTimeout && lastTouchTime.compareAndSet(time0, TIMEDOUT_FLAG);
+ }
+
+ /**
+ * Checks whether session at expired state (EPIRATION_FLAG) or not, if not then tries to update last touch time.
+ *
+ * @return {@code False} if session timed out (not successfully touched).
+ * @see #isTimedOut(long)
+ */
+ boolean touch() {
+ while (true) {
+ long time0 = lastTouchTime.get();
+
+ if (time0 == TIMEDOUT_FLAG)
+ return false;
+
+ boolean success = lastTouchTime.compareAndSet(time0, U.currentTimeMillis());
+
+ if (success)
+ return true;
+ }
+ }
+
+ /** {@inheritDoc} */
+ @Override public boolean equals(Object o) {
+ if (this == o)
+ return true;
+
+ if (!(o instanceof Session))
+ return false;
+
+ Session ses = (Session)o;
+
+ if (clientId != null ? !clientId.equals(ses.clientId) : ses.clientId != null)
+ return false;
+
+ if (sesId != null ? !sesId.equals(ses.sesId) : ses.sesId != null)
+ return false;
+
+ return true;
+ }
+
+ /** {@inheritDoc} */
+ @Override public int hashCode() {
+ int res = clientId != null ? clientId.hashCode() : 0;
+
+ res = 31 * res + (sesId != null ? sesId.hashCode() : 0);
+
+ return res;
+ }
+
+ /** {@inheritDoc} */
+ @Override public String toString() {
+ return S.toString(Session.class, this);
+ }
+ }
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/f025714e/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java
index b3af2f2..9d32c17 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/cache/GridCacheCommandHandler.java
@@ -1391,4 +1391,4 @@ public class GridCacheCommandHandler extends GridRestCommandHandlerAdapter {
return c.sizeAsync(new CachePeekMode[]{CachePeekMode.PRIMARY});
}
}
-}
\ No newline at end of file
+}
http://git-wip-us.apache.org/repos/asf/ignite/blob/f025714e/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
index e5090cb..3c1913a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java
@@ -9302,4 +9302,4 @@ public abstract class IgniteUtils {
throw new IgniteInterruptedCheckedException(e);
}
}
-}
\ No newline at end of file
+}
[09/29] ignite git commit: ignite-1.4 Added schema-import-demo to
exclude.
Posted by an...@apache.org.
ignite-1.4 Added schema-import-demo to exclude.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/008c2734
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/008c2734
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/008c2734
Branch: refs/heads/ignite-1168
Commit: 008c27341fe9b2996b01d0b55a4e7eb488180ed0
Parents: a2c972b
Author: Andrey <an...@gridgain.com>
Authored: Fri Sep 25 10:29:51 2015 +0700
Committer: Andrey <an...@gridgain.com>
Committed: Fri Sep 25 10:29:51 2015 +0700
----------------------------------------------------------------------
assembly/dependencies-fabric.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/008c2734/assembly/dependencies-fabric.xml
----------------------------------------------------------------------
diff --git a/assembly/dependencies-fabric.xml b/assembly/dependencies-fabric.xml
index f69ffde..f50847e 100644
--- a/assembly/dependencies-fabric.xml
+++ b/assembly/dependencies-fabric.xml
@@ -120,11 +120,11 @@
<exclude>org.apache.ignite:ignite-extdata-uri</exclude>
<exclude>org.apache.ignite:ignite-extdata-uri-dep</exclude>
<exclude>org.apache.ignite:ignite-examples</exclude>
+ <exclude>org.apache.ignite:ignite-schema-import-demo</exclude>
<exclude>org.apache.ignite:ignite-indexing</exclude>
<exclude>org.apache.ignite:ignite-visor-console</exclude>
<exclude>org.apache.ignite:ignite-visor-console_2.10</exclude>
<exclude>org.apache.ignite:ignite-visor-plugins</exclude>
- <exclude>org.apache.ignite:ignite-visor-trial</exclude>
<exclude>org.apache.ignite:ignite-hadoop</exclude>
<exclude>org.apache.ignite:ignite-schema-import</exclude>
<exclude>org.apache.ignite:ignite-codegen</exclude>
[21/29] ignite git commit: ignite-1618 Tests muted
Posted by an...@apache.org.
ignite-1618 Tests muted
Signed-off-by: Anton Vinogradov <av...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/35fa5e63
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/35fa5e63
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/35fa5e63
Branch: refs/heads/ignite-1168
Commit: 35fa5e630be2840eec2f9c9500e6f79bbc841597
Parents: 8616889
Author: agura <ag...@gridgain.com>
Authored: Mon Oct 5 22:03:46 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Tue Oct 6 11:11:13 2015 +0300
----------------------------------------------------------------------
.../cache/GridCacheDeploymentOffHeapSelfTest.java | 15 +++++++++++++++
1 file changed, 15 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/35fa5e63/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentOffHeapSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentOffHeapSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentOffHeapSelfTest.java
index fda054f..c51d72b 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentOffHeapSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentOffHeapSelfTest.java
@@ -38,4 +38,19 @@ public class GridCacheDeploymentOffHeapSelfTest extends GridCacheDeploymentSelfT
return cacheCfg;
}
+
+ /** {@inheritDoc} */
+ @Override public void testDeployment() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1618");
+ }
+
+ /** {@inheritDoc} */
+ @Override public void testDeployment6() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1618");
+ }
+
+ /** {@inheritDoc} */
+ @Override public void testDeployment7() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1618");
+ }
}
\ No newline at end of file
[05/29] ignite git commit: schema-import examples fix
Posted by an...@apache.org.
schema-import examples fix
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b054fdc8
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b054fdc8
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b054fdc8
Branch: refs/heads/ignite-1168
Commit: b054fdc86c574e6ba50708cbbec6dce9265cadf3
Parents: fb9b14d
Author: Anton Vinogradov <av...@apache.org>
Authored: Thu Sep 24 14:52:09 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Thu Sep 24 14:52:09 2015 +0300
----------------------------------------------------------------------
examples/schema-import/pom.xml | 2 +-
pom.xml | 1 +
2 files changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/b054fdc8/examples/schema-import/pom.xml
----------------------------------------------------------------------
diff --git a/examples/schema-import/pom.xml b/examples/schema-import/pom.xml
index fdbd631..fce6f47 100644
--- a/examples/schema-import/pom.xml
+++ b/examples/schema-import/pom.xml
@@ -38,7 +38,7 @@
</properties>
<artifactId>ignite-schema-import-demo</artifactId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.3.3-p7-SNAPSHOT</version>
<dependencies>
<dependency>
http://git-wip-us.apache.org/repos/asf/ignite/blob/b054fdc8/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 6d10b42..a5b47d5 100644
--- a/pom.xml
+++ b/pom.xml
@@ -466,6 +466,7 @@
<id>examples</id>
<modules>
<module>examples</module>
+ <module>examples/schema-import</module>
</modules>
</profile>
[15/29] ignite git commit: Test Failed
Posted by an...@apache.org.
Test Failed
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0309f968
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0309f968
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0309f968
Branch: refs/heads/ignite-1168
Commit: 0309f9688872e0c0fc7ff74514f06f47aef388b7
Parents: 150a644
Author: Anton Vinogradov <av...@apache.org>
Authored: Thu Oct 1 15:44:25 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Thu Oct 1 15:44:25 2015 +0300
----------------------------------------------------------------------
.../cache/distributed/near/GridCacheNearTxExceptionSelfTest.java | 4 ++++
.../datastreamer/DataStreamerMultiThreadedSelfTest.java | 4 +++-
.../datastreamer/DataStreamerMultinodeCreateCacheTest.java | 2 ++
3 files changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/0309f968/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxExceptionSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxExceptionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxExceptionSelfTest.java
index d6e3804..9546d61 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxExceptionSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/near/GridCacheNearTxExceptionSelfTest.java
@@ -30,4 +30,8 @@ public class GridCacheNearTxExceptionSelfTest extends IgniteTxExceptionAbstractS
@Override protected CacheMode cacheMode() {
return PARTITIONED;
}
+
+ @Override public void testTransformBackup(){
+ fail("https://issues.apache.org/jira/browse/IGNITE-1601");
+ }
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/0309f968/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java
index bfeebf2..c1251ae 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java
@@ -92,6 +92,8 @@ public class DataStreamerMultiThreadedSelfTest extends GridCommonAbstractTest {
* @throws Exception If failed.
*/
public void testStartStopIgnitesDynamicCache() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1602");
+
dynamicCache = true;
startStopIgnites();
@@ -103,7 +105,7 @@ public class DataStreamerMultiThreadedSelfTest extends GridCommonAbstractTest {
private void startStopIgnites() throws Exception {
for (int attempt = 0; attempt < 3; ++attempt) {
log.info("Iteration: " + attempt);
-
+
final Ignite ignite = startGrid(0);
Set<IgniteFuture> futs = new HashSet<>();
http://git-wip-us.apache.org/repos/asf/ignite/blob/0309f968/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java
index ca0ff21..6bde83a 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java
@@ -58,6 +58,8 @@ public class DataStreamerMultinodeCreateCacheTest extends GridCommonAbstractTest
* @throws Exception If failed.
*/
public void testCreateCacheAndStream() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1603");
+
final int THREADS = 5;
startGrids(THREADS);
[29/29] ignite git commit: Merge master into ignite-1168
Posted by an...@apache.org.
Merge master into ignite-1168
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5ef7c38f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5ef7c38f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5ef7c38f
Branch: refs/heads/ignite-1168
Commit: 5ef7c38f1ca6b8e075b59000dc48731c260a2a41
Parents: 6e0f415 f025714
Author: Andrey <an...@gridgain.com>
Authored: Thu Oct 8 10:01:27 2015 +0700
Committer: Andrey <an...@gridgain.com>
Committed: Thu Oct 8 10:01:27 2015 +0700
----------------------------------------------------------------------
RELEASE_NOTES.txt | 2 +
assembly/dependencies-fabric.xml | 2 +-
assembly/release-fabric.xml | 10 +-
examples/schema-import/pom-standalone.xml | 90 +++++
examples/schema-import/pom.xml | 13 +-
modules/apache-license-gen/README.txt | 33 ++
.../JettyRestProcessorAbstractSelfTest.java | 25 +-
.../org/apache/ignite/IgniteFileSystem.java | 2 +
.../apache/ignite/IgniteSystemProperties.java | 3 +
.../discovery/GridDiscoveryManager.java | 4 +-
.../cache/DynamicCacheDescriptor.java | 17 +
.../processors/cache/GridCacheContext.java | 2 +-
.../processors/cache/GridCacheMvccManager.java | 20 +-
.../GridCachePartitionExchangeManager.java | 72 +---
.../processors/cache/GridCacheProcessor.java | 26 +-
.../cache/distributed/dht/GridDhtGetFuture.java | 4 +-
.../distributed/dht/GridDhtLockRequest.java | 5 +-
.../dht/GridPartitionedGetFuture.java | 5 +-
.../dht/atomic/GridNearAtomicUpdateFuture.java | 9 +-
.../distributed/near/GridNearGetFuture.java | 2 +
.../internal/processors/igfs/IgfsFileInfo.java | 13 +-
.../internal/processors/igfs/IgfsImpl.java | 64 +---
.../processors/igfs/IgfsMetaManager.java | 180 +++++++++-
.../processors/rest/GridRestProcessor.java | 354 +++++++++++++++++--
.../ignite/internal/util/IgniteUtils.java | 2 +-
.../GridCacheDeploymentOffHeapSelfTest.java | 15 +
.../cache/IgniteCacheEntryListenerTxTest.java | 4 +
.../cache/IgniteCachePutAllRestartTest.java | 4 +-
.../CacheGetFutureHangsSelfTest.java | 156 ++++----
.../distributed/IgniteCacheCreatePutTest.java | 125 +++++++
.../dht/GridNearCacheTxNodeFailureSelfTest.java | 4 +
.../near/GridCacheNearTxExceptionSelfTest.java | 4 +
...bledFairAffinityMultiJvmFullApiSelfTest.java | 5 +
...tomicNearEnabledMultiJvmFullApiSelfTest.java | 5 +
.../DataStreamerMultiThreadedSelfTest.java | 4 +-
.../DataStreamerMultinodeCreateCacheTest.java | 2 +
.../processors/igfs/IgfsAbstractSelfTest.java | 185 ++++++----
.../tcp/TcpClientDiscoverySpiSelfTest.java | 2 +
.../testsuites/IgniteCacheTestSuite4.java | 5 +
.../ignite/igfs/Hadoop1DualAbstractTest.java | 5 +
modules/yardstick/pom.xml | 10 +-
pom.xml | 9 +-
42 files changed, 1134 insertions(+), 369 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5ef7c38f/modules/clients/src/test/java/org/apache/ignite/internal/processors/rest/JettyRestProcessorAbstractSelfTest.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5ef7c38f/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5ef7c38f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5ef7c38f/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/GridRestProcessor.java
----------------------------------------------------------------------
[17/29] ignite git commit: IGNITE-1573: Fixed IGFS "mkdirs"
concurrency problem.
Posted by an...@apache.org.
IGNITE-1573: Fixed IGFS "mkdirs" concurrency problem.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a411f94d
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a411f94d
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a411f94d
Branch: refs/heads/ignite-1168
Commit: a411f94d29b9073457ae2b31f89dd9f702e6bf53
Parents: fd091c8
Author: iveselovskiy <iv...@gridgain.com>
Authored: Fri Oct 2 10:54:33 2015 +0300
Committer: vozerov-gridgain <vo...@gridgain.com>
Committed: Fri Oct 2 10:54:33 2015 +0300
----------------------------------------------------------------------
.../org/apache/ignite/IgniteFileSystem.java | 2 +
.../internal/processors/igfs/IgfsFileInfo.java | 13 +-
.../internal/processors/igfs/IgfsImpl.java | 64 +------
.../processors/igfs/IgfsMetaManager.java | 180 +++++++++++++++++-
.../processors/igfs/IgfsAbstractSelfTest.java | 185 +++++++++++--------
5 files changed, 300 insertions(+), 144 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/a411f94d/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java b/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java
index a187a90..def2965 100644
--- a/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java
+++ b/modules/core/src/main/java/org/apache/ignite/IgniteFileSystem.java
@@ -417,6 +417,8 @@ public interface IgniteFileSystem extends IgniteAsyncSupport {
/**
* Creates directories under specified path with the specified properties.
+ * Note that the properties are applied only to created directories, but never
+ * updated for existing ones.
*
* @param path Path of directories chain to create.
* @param props Metadata properties to set on created directories.
http://git-wip-us.apache.org/repos/asf/ignite/blob/a411f94d/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java
index 8564500..fa79d80 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsFileInfo.java
@@ -124,6 +124,16 @@ public final class IgfsFileInfo implements Externalizable {
}
/**
+ * Consturcts directory with random ID, provided listing and properties.
+ *
+ * @param listing Listing.
+ * @param props The properties to set for the new directory.
+ */
+ IgfsFileInfo(@Nullable Map<String, IgfsListingEntry> listing, @Nullable Map<String,String> props) {
+ this(true/*dir*/, null, 0, 0, null, listing, props, null, false, System.currentTimeMillis(), false);
+ }
+
+ /**
* Constructs file info.
*
* @param blockSize Block size.
@@ -194,7 +204,7 @@ public final class IgfsFileInfo implements Externalizable {
* @param evictExclude Evict exclude flag.
*/
IgfsFileInfo(int blockSize, long len, boolean evictExclude, @Nullable Map<String, String> props) {
- this(blockSize == 0, // NB The contract is: (blockSize == null) <=> isDirectory()
+ this(blockSize == 0, // NB The contract is: (blockSize == 0) <=> isDirectory()
null, blockSize, len, null, null, props, null, true, System.currentTimeMillis(), evictExclude);
}
@@ -495,6 +505,7 @@ public final class IgfsFileInfo implements Externalizable {
}
/** {@inheritDoc} */
+ @SuppressWarnings("unchecked")
@Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException {
id = U.readGridUuid(in);
blockSize = in.readInt();
http://git-wip-us.apache.org/repos/asf/ignite/blob/a411f94d/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
index d5ba95f..fa3a955 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsImpl.java
@@ -23,6 +23,7 @@ import java.net.URI;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
+import java.util.HashMap;
import java.util.HashSet;
import java.util.LinkedHashMap;
import java.util.List;
@@ -58,7 +59,6 @@ import org.apache.ignite.igfs.IgfsInvalidPathException;
import org.apache.ignite.igfs.IgfsMetrics;
import org.apache.ignite.igfs.IgfsMode;
import org.apache.ignite.igfs.IgfsOutputStream;
-import org.apache.ignite.igfs.IgfsParentNotDirectoryException;
import org.apache.ignite.igfs.IgfsPath;
import org.apache.ignite.igfs.IgfsPathAlreadyExistsException;
import org.apache.ignite.igfs.IgfsPathIsDirectoryException;
@@ -93,7 +93,6 @@ import org.apache.ignite.thread.IgniteThreadPoolExecutor;
import org.jetbrains.annotations.Nullable;
import org.jsr166.ConcurrentHashMap8;
-import static org.apache.ignite.events.EventType.EVT_IGFS_DIR_CREATED;
import static org.apache.ignite.events.EventType.EVT_IGFS_DIR_DELETED;
import static org.apache.ignite.events.EventType.EVT_IGFS_DIR_RENAMED;
import static org.apache.ignite.events.EventType.EVT_IGFS_FILE_CLOSED_READ;
@@ -769,71 +768,18 @@ public final class IgfsImpl implements IgfsEx {
if (log.isDebugEnabled())
log.debug("Make directories: " + path);
- Map<String, String> props0 = props == null ? DFLT_DIR_META : props;
+ final Map<String, String> props0 = props == null ? DFLT_DIR_META : new HashMap<>(props);
IgfsMode mode = resolveMode(path);
- if (mode != PRIMARY) {
+ if (mode == PRIMARY)
+ meta.mkdirs(path, props0);
+ else {
assert mode == DUAL_SYNC || mode == DUAL_ASYNC;
await(path);
meta.mkdirsDual(secondaryFs, path, props0);
-
- return null;
- }
-
- List<IgniteUuid> ids = meta.fileIds(path);
- List<String> components = path.components();
-
- assert ids.size() == components.size() + 1 : "Components doesn't contain ROOT element" +
- " [ids=" + ids + ", components=" + components + ']';
-
- IgniteUuid parentId = ROOT_ID;
-
- IgfsPath curPath = path.root();
-
- for (int step = 0, size = components.size(); step < size; step++) {
- IgniteUuid fileId = ids.get(step + 1); // Skip the first ROOT element.
-
- if (fileId == null) {
- IgfsFileInfo fileInfo = new IgfsFileInfo(true, props0); // Create new directory.
-
- String fileName = components.get(step); // Get current component name.
-
- curPath = new IgfsPath(curPath, fileName);
-
- try {
- // Fails only if parent is not a directory or if modified concurrently.
- IgniteUuid oldId = meta.putIfAbsent(parentId, fileName, fileInfo);
-
- fileId = oldId == null ? fileInfo.id() : oldId; // Update node ID.
-
- if (oldId == null && evts.isRecordable(EVT_IGFS_DIR_CREATED))
- evts.record(new IgfsEvent(curPath, localNode(), EVT_IGFS_DIR_CREATED));
- }
- catch (IgniteCheckedException e) {
- if (log.isDebugEnabled())
- log.debug("Failed to create directory [path=" + path + ", parentId=" + parentId +
- ", fileName=" + fileName + ", step=" + step + ", e=" + e.getMessage() + ']');
-
- // Check directory with such name already exists.
- IgfsFileInfo stored = meta.info(meta.fileId(parentId, fileName));
-
- if (stored == null)
- throw e;
-
- if (!stored.isDirectory())
- throw new IgfsParentNotDirectoryException("Failed to create directory (parent " +
- "element is not a directory)");
-
- fileId = stored.id(); // Update node ID.
- }
- }
-
- assert fileId != null;
-
- parentId = fileId;
}
return null;
http://git-wip-us.apache.org/repos/asf/ignite/blob/a411f94d/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManager.java
index bb6404c..927067a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/igfs/IgfsMetaManager.java
@@ -51,6 +51,7 @@ import org.apache.ignite.igfs.IgfsConcurrentModificationException;
import org.apache.ignite.igfs.IgfsDirectoryNotEmptyException;
import org.apache.ignite.igfs.IgfsException;
import org.apache.ignite.igfs.IgfsFile;
+import org.apache.ignite.igfs.IgfsParentNotDirectoryException;
import org.apache.ignite.igfs.IgfsPath;
import org.apache.ignite.igfs.IgfsPathAlreadyExistsException;
import org.apache.ignite.igfs.IgfsPathIsDirectoryException;
@@ -673,9 +674,10 @@ public class IgfsMetaManager extends IgfsManager {
if (fileIds.contains(id) && !map.containsKey(id)) {
IgfsFileInfo info = new IgfsFileInfo(id);
- assert info.listing() != null;
+ IgfsFileInfo anotherInfo = id2InfoPrj.getAndPutIfAbsent(id, info);
- id2InfoPrj.putIfAbsent(id, info);
+ if (anotherInfo != null)
+ info = anotherInfo;
map.put(id, info);
}
@@ -1662,7 +1664,7 @@ public class IgfsMetaManager extends IgfsManager {
* @return Updated file info or {@code null} if such file ID not found.
* @throws IgniteCheckedException If operation failed.
*/
- @Nullable private IgfsFileInfo updatePropertiesNonTx(@Nullable IgniteUuid parentId, IgniteUuid fileId,
+ @Nullable private IgfsFileInfo updatePropertiesNonTx(final @Nullable IgniteUuid parentId, final IgniteUuid fileId,
String fileName, Map<String, String> props) throws IgniteCheckedException {
assert fileId != null;
assert !F.isEmpty(props) : "Expects not-empty file's properties";
@@ -1672,8 +1674,8 @@ public class IgfsMetaManager extends IgfsManager {
log.debug("Update file properties [fileId=" + fileId + ", props=" + props + ']');
try {
- IgfsFileInfo oldInfo;
- IgfsFileInfo parentInfo;
+ final IgfsFileInfo oldInfo;
+ final IgfsFileInfo parentInfo;
// Lock file ID for this transaction.
if (parentId == null) {
@@ -1690,8 +1692,6 @@ public class IgfsMetaManager extends IgfsManager {
return null; // Parent not found.
}
- assert validTxState(true);
-
if (oldInfo == null)
return null; // File not found.
@@ -1724,7 +1724,7 @@ public class IgfsMetaManager extends IgfsManager {
if (parentId != null) {
IgfsListingEntry entry = new IgfsListingEntry(newInfo);
- assert metaCache.get(parentId) != null;
+ assert id2InfoPrj.get(parentId) != null;
id2InfoPrj.invoke(parentId, new UpdateListing(fileName, entry, false));
}
@@ -1874,6 +1874,170 @@ public class IgfsMetaManager extends IgfsManager {
}
/**
+ * Mkdirs implementation.
+ *
+ * @param path The path to create.
+ * @param props The properties to use for created directories.
+ * @return True iff a directory was created during the operation.
+ * @throws IgniteCheckedException If a non-directory file exists on the requested path, and in case of other errors.
+ */
+ boolean mkdirs(final IgfsPath path, final Map<String, String> props) throws IgniteCheckedException {
+ assert props != null;
+ assert validTxState(false);
+
+ List<String> components;
+ SortedSet<IgniteUuid> idSet;
+ IgfsPath existingPath;
+
+ while (true) {
+ if (busyLock.enterBusy()) {
+ try {
+ // Take the ids in *path* order out of transaction:
+ final List<IgniteUuid> idList = fileIds(path);
+
+ idSet = new TreeSet<IgniteUuid>(PATH_ID_SORTING_COMPARATOR);
+
+ idSet.add(ROOT_ID);
+
+ components = path.components();
+
+ // Store all the non-null ids in the set & construct existing path in one loop:
+ existingPath = path.root();
+
+ assert idList.size() == components.size() + 1;
+
+ // Find the lowermost existing id:
+ IgniteUuid parentId = ROOT_ID;
+
+ for (int i = 1; i < idList.size(); i++) {
+ IgniteUuid id = idList.get(i);
+
+ if (id == null)
+ break;
+
+ parentId = id;
+
+ boolean added = idSet.add(id);
+
+ assert added;
+
+ existingPath = new IgfsPath(existingPath, components.get(i - 1));
+ }
+
+ // Start TX.
+ IgniteInternalTx tx = metaCache.txStartEx(PESSIMISTIC, REPEATABLE_READ);
+
+ try {
+ final Map<IgniteUuid, IgfsFileInfo> lockedInfos = lockIds(idSet);
+
+ // If the path was changed, we close the current Tx and repeat the procedure again
+ // starting from taking the path ids.
+ if (verifyPathIntegrity(existingPath, idList, lockedInfos)) {
+ // Locked path okay, trying to proceed with the remainder creation.
+ IgfsFileInfo parentInfo = lockedInfos.get(parentId);
+
+ // Check only the lowermost directory in the existing directory chain
+ // because others are already checked in #verifyPathIntegrity() above.
+ if (!parentInfo.isDirectory())
+ throw new IgfsParentNotDirectoryException("Failed to create directory (parent " +
+ "element is not a directory)");
+
+ if (idSet.size() == components.size() + 1) {
+ assert existingPath.equals(path);
+ assert lockedInfos.size() == idSet.size();
+
+ // The target directory already exists, nothing to do.
+ // (The fact that all the path consisns of directories is already checked above).
+ // Note that properties are not updated in this case.
+ return false;
+ }
+
+ Map<String, IgfsListingEntry> parentListing = parentInfo.listing();
+
+ String shortName = components.get(idSet.size() - 1);
+
+ IgfsListingEntry entry = parentListing.get(shortName);
+
+ if (entry == null) {
+ IgfsFileInfo childInfo = null;
+
+ String childName = null;
+
+ IgfsFileInfo newDirInfo;
+
+ // This loop creates the missing directory chain from the bottom to the top:
+ for (int i = components.size() - 1; i >= idSet.size() - 1; i--) {
+ // Required entry does not exist.
+ // Create new directory info:
+ if (childName == null) {
+ assert childInfo == null;
+
+ newDirInfo = new IgfsFileInfo(true, props);
+ }
+ else {
+ assert childInfo != null;
+
+ newDirInfo = new IgfsFileInfo(Collections.singletonMap(childName,
+ new IgfsListingEntry(childInfo)), props);
+ }
+
+ boolean put = id2InfoPrj.putIfAbsent(newDirInfo.id(), newDirInfo);
+
+ assert put; // Because we used a new id that should be unique.
+
+ childInfo = newDirInfo;
+ childName = components.get(i);
+ }
+
+ // Now link the newly created directory chain to the lowermost existing parent:
+ id2InfoPrj.invoke(parentId,
+ new UpdateListing(childName, new IgfsListingEntry(childInfo), false));
+
+ // We're close to finish:
+ tx.commit();
+
+ break;
+ }
+ else {
+ // Another thread created file or directory with the same name.
+ if (!entry.isDirectory()) {
+ // Entry exists, and it is not a directory:
+ throw new IgfsParentNotDirectoryException("Failed to create directory (parent " +
+ "element is not a directory)");
+ }
+
+ // If this is a directory, we continue the repeat loop,
+ // because we cannot lock this directory without
+ // lock ordering rule violation.
+ }
+ }
+ }
+ finally {
+ tx.close();
+ }
+ }
+ finally {
+ busyLock.leaveBusy();
+ }
+ }
+ else
+ throw new IllegalStateException("Failed to mkdir because Grid is stopping. [path=" + path + ']');
+ } // retry loop
+
+ if (evts.isRecordable(EVT_IGFS_DIR_CREATED)) {
+ IgfsPath createdPath = existingPath;
+
+ for (int i = idSet.size() - 1; i < components.size(); i++) {
+ createdPath = new IgfsPath(createdPath, components.get(i));
+
+ evts.record(new IgfsEvent(createdPath, locNode, EVT_IGFS_DIR_CREATED));
+ }
+ }
+
+ return true;
+ }
+
+ /**
* Set sampling flag.
*
* @param val Sampling flag state or {@code null} to clear sampling state and mark it as "not set".
http://git-wip-us.apache.org/repos/asf/ignite/blob/a411f94d/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java
index 7e73859..cc89fd1 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/igfs/IgfsAbstractSelfTest.java
@@ -57,6 +57,7 @@ import org.apache.ignite.igfs.IgfsIpcEndpointConfiguration;
import org.apache.ignite.igfs.IgfsIpcEndpointType;
import org.apache.ignite.igfs.IgfsMode;
import org.apache.ignite.igfs.IgfsOutputStream;
+import org.apache.ignite.igfs.IgfsParentNotDirectoryException;
import org.apache.ignite.igfs.IgfsPath;
import org.apache.ignite.igfs.IgfsPathNotFoundException;
import org.apache.ignite.igfs.secondary.IgfsSecondaryFileSystem;
@@ -101,12 +102,27 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
protected static final long BLOCK_SIZE = 32 * 1024 * 1024;
/** Default repeat count. */
- protected static final int REPEAT_CNT = 5; // Diagnostic: ~100; Regression: 5
+ protected static final int REPEAT_CNT = 10;
/** Concurrent operations count. */
- protected static final int OPS_CNT = 16; // Diagnostic: ~160; Regression: 16
+ protected static final int OPS_CNT = 32;
- /** Seed. */
+ /** Renames count. */
+ protected static final int RENAME_CNT = OPS_CNT;
+
+ /** Deletes count. */
+ protected static final int DELETE_CNT = OPS_CNT;
+
+ /** Updates count. */
+ protected static final int UPDATE_CNT = OPS_CNT;
+
+ /** Mkdirs count. */
+ protected static final int MKDIRS_CNT = OPS_CNT;
+
+ /** Create count. */
+ protected static final int CREATE_CNT = OPS_CNT;
+
+ /** Seed to generate random numbers. */
protected static final long SEED = System.currentTimeMillis();
/** Amount of blocks to prefetch. */
@@ -724,9 +740,46 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
*
* @throws Exception If failed.
*/
+ @SuppressWarnings("ConstantConditions")
public void testMkdirs() throws Exception {
Map<String, String> props = properties(null, null, "0555"); // mkdirs command doesn't propagate user info.
+ igfs.mkdirs(new IgfsPath("/x"), null);
+ checkExist(igfs, igfsSecondary, new IgfsPath("/x"));
+
+ igfs.mkdirs(new IgfsPath("/k/l"), null);
+ checkExist(igfs, igfsSecondary, new IgfsPath("/k/l"));
+
+ igfs.mkdirs(new IgfsPath("/x/y"), null);
+ checkExist(igfs, igfsSecondary, new IgfsPath("/x/y"));
+
+ igfs.mkdirs(new IgfsPath("/a/b/c/d"), null);
+ checkExist(igfs, igfsSecondary, new IgfsPath("/a/b/c/d"));
+
+ igfs.mkdirs(new IgfsPath("/a/b/c/d/e"), null);
+ checkExist(igfs, igfsSecondary, new IgfsPath("/a/b/c/d/e"));
+
+ create(igfs, null, new IgfsPath[] { new IgfsPath("/d/f") }); // "f" is a file.
+ checkExist(igfs, igfsSecondary, new IgfsPath("/d/f"));
+
+ try {
+ igfs.mkdirs(new IgfsPath("/d/f"), null);
+
+ fail("IgfsParentNotDirectoryException expected.");
+ }
+ catch (IgfsParentNotDirectoryException ignore) {
+ // No-op.
+ }
+
+ try {
+ igfs.mkdirs(new IgfsPath("/d/f/something/else"), null);
+
+ fail("IgfsParentNotDirectoryException expected.");
+ }
+ catch (IgfsParentNotDirectoryException ignore) {
+ // No-op.
+ }
+
create(igfs, paths(DIR, SUBDIR), null);
igfs.mkdirs(SUBSUBDIR, props);
@@ -747,6 +800,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
*
* @throws Exception If failed.
*/
+ @SuppressWarnings("ConstantConditions")
public void testMkdirsParentRoot() throws Exception {
Map<String, String> props = properties(null, null, "0555"); // mkdirs command doesn't propagate user info.
@@ -814,6 +868,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
*
* @throws Exception If failed.
*/
+ @SuppressWarnings("ConstantConditions")
public void testUpdate() throws Exception {
Map<String, String> props = properties("owner", "group", "0555");
@@ -832,6 +887,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
*
* @throws Exception If failed.
*/
+ @SuppressWarnings("ConstantConditions")
public void testUpdateParentRoot() throws Exception {
Map<String, String> props = properties("owner", "group", "0555");
@@ -936,6 +992,8 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
IgfsFile file = igfs.info(new IgfsPath("/"));
+ assert file != null;
+
Map<String,String> props = file.properties();
assertEquals("moo", props.get("foo"));
@@ -1619,8 +1677,6 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
public void testConcurrentMkdirsDelete() throws Exception {
- fail("https://issues.apache.org/jira/browse/IGNITE-1541");
-
for (int i = 0; i < REPEAT_CNT; i++) {
final CyclicBarrier barrier = new CyclicBarrier(2);
@@ -1900,14 +1956,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
public void testDeadlocksRename() throws Exception {
- for (int i = 0; i < REPEAT_CNT; i++) {
- try {
- checkDeadlocks(5, 2, 2, 2, OPS_CNT, 0, 0, 0, 0);
- }
- finally {
- clear(igfs, igfsSecondary);
- }
- }
+ checkDeadlocksRepeat(5, 2, 2, 2, RENAME_CNT, 0, 0, 0, 0);
}
/**
@@ -1916,14 +1965,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
public void testDeadlocksDelete() throws Exception {
- for (int i = 0; i < REPEAT_CNT; i++) {
- try {
- checkDeadlocks(5, 2, 2, 2, 0, OPS_CNT, 0, 0, 0);
- }
- finally {
- clear(igfs, igfsSecondary);
- }
- }
+ checkDeadlocksRepeat(5, 2, 2, 2, 0, DELETE_CNT, 0, 0, 0);
}
/**
@@ -1932,14 +1974,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
public void testDeadlocksUpdate() throws Exception {
- for (int i = 0; i < REPEAT_CNT; i++) {
- try {
- checkDeadlocks(5, 2, 2, 2, 0, 0, OPS_CNT, 0, 0);
- }
- finally {
- clear(igfs, igfsSecondary);
- }
- }
+ checkDeadlocksRepeat(5, 2, 2, 2, 0, 0, UPDATE_CNT, 0, 0);
}
/**
@@ -1948,14 +1983,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
public void testDeadlocksMkdirs() throws Exception {
- for (int i = 0; i < REPEAT_CNT; i++) {
- try {
- checkDeadlocks(5, 2, 2, 2, 0, 0, 0, OPS_CNT, 0);
- }
- finally {
- clear(igfs, igfsSecondary);
- }
- }
+ checkDeadlocksRepeat(5, 2, 2, 2, 0, 0, 0, MKDIRS_CNT, 0);
}
/**
@@ -1964,15 +1992,7 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
public void testDeadlocksDeleteRename() throws Exception {
- for (int i = 0; i < REPEAT_CNT; i++) {
- try {
- checkDeadlocks(5, 2, 2, 2,
- OPS_CNT, OPS_CNT, 0, 0, 0);
- }
- finally {
- clear(igfs, igfsSecondary);
- }
- }
+ checkDeadlocksRepeat(5, 2, 2, 2, RENAME_CNT, DELETE_CNT, 0, 0, 0);
}
/**
@@ -1980,18 +2000,17 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
*
* @throws Exception If failed.
*/
- public void testDeadlocksDeleteMkdirs() throws Exception {
- fail("https://issues.apache.org/jira/browse/IGNITE-1541");
+ public void testDeadlocksDeleteMkdirsRename() throws Exception {
+ checkDeadlocksRepeat(5, 2, 2, 2, RENAME_CNT, DELETE_CNT, 0, MKDIRS_CNT, 0);
+ }
- for (int i = 0; i < REPEAT_CNT; i++) {
- try {
- checkDeadlocks(5, 2, 2, 2,
- 0, OPS_CNT, 0, OPS_CNT, 0);
- }
- finally {
- clear(igfs, igfsSecondary);
- }
- }
+ /**
+ * Ensure that deadlocks do not occur during concurrent delete & rename operations.
+ *
+ * @throws Exception If failed.
+ */
+ public void testDeadlocksDeleteMkdirs() throws Exception {
+ checkDeadlocksRepeat(5, 2, 2, 2, 0, DELETE_CNT, 0, MKDIRS_CNT, 0);
}
/**
@@ -2000,14 +2019,9 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
public void testDeadlocksCreate() throws Exception {
- for (int i = 0; i < REPEAT_CNT; i++) {
- try {
- checkDeadlocks(5, 2, 2, 2, 0, 0, 0, 0, OPS_CNT);
- }
- finally {
- clear(igfs, igfsSecondary);
- }
- }
+ assert false : "https://issues.apache.org/jira/browse/IGNITE-1590";
+
+ checkDeadlocksRepeat(5, 2, 2, 2, 0, 0, 0, 0, CREATE_CNT);
}
/**
@@ -2016,16 +2030,33 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
public void testDeadlocks() throws Exception {
- fail("https://issues.apache.org/jira/browse/IGNITE-1541");
+ assert false : "https://issues.apache.org/jira/browse/IGNITE-1590";
+ checkDeadlocksRepeat(5, 2, 2, 2, RENAME_CNT, DELETE_CNT, UPDATE_CNT, MKDIRS_CNT, CREATE_CNT);
+ }
+
+ /**
+ * Invokes {@link #checkDeadlocks(int, int, int, int, int, int, int, int, int)} for
+ * {@link #REPEAT_CNT} times.
+ *
+ * @param lvlCnt Total levels in folder hierarchy.
+ * @param childrenDirPerLvl How many children directories to create per level.
+ * @param childrenFilePerLvl How many children file to create per level.
+ * @param primaryLvlCnt How many levels will exist in the primary file system before check start.
+ * @param renCnt How many renames to perform.
+ * @param delCnt How many deletes to perform.
+ * @param updateCnt How many updates to perform.
+ * @param mkdirsCnt How many directory creations to perform.
+ * @param createCnt How many file creations to perform.
+ * @throws Exception If failed.
+ */
+ private void checkDeadlocksRepeat(final int lvlCnt, final int childrenDirPerLvl, final int childrenFilePerLvl,
+ int primaryLvlCnt, int renCnt, int delCnt,
+ int updateCnt, int mkdirsCnt, int createCnt) throws Exception {
for (int i = 0; i < REPEAT_CNT; i++) {
try {
- checkDeadlocks(5, 2, 2, 2,
- OPS_CNT, // rename
- OPS_CNT, // delete
- OPS_CNT, // update
- OPS_CNT, // mkdirs
- OPS_CNT); // create
+ checkDeadlocks(lvlCnt, childrenDirPerLvl, childrenFilePerLvl, primaryLvlCnt, renCnt, delCnt,
+ updateCnt, mkdirsCnt, createCnt);
}
finally {
clear(igfs, igfsSecondary);
@@ -2050,9 +2081,8 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
* @throws Exception If failed.
*/
@SuppressWarnings("ConstantConditions")
- public void checkDeadlocks(final int lvlCnt, final int childrenDirPerLvl, final int childrenFilePerLvl,
- int primaryLvlCnt, int renCnt, int delCnt,
- int updateCnt, int mkdirsCnt, int createCnt) throws Exception {
+ private void checkDeadlocks(final int lvlCnt, final int childrenDirPerLvl, final int childrenFilePerLvl,
+ int primaryLvlCnt, int renCnt, int delCnt, int updateCnt, int mkdirsCnt, int createCnt) throws Exception {
assert childrenDirPerLvl > 0;
// First define file system structure.
@@ -2096,7 +2126,10 @@ public abstract class IgfsAbstractSelfTest extends IgfsCommonAbstractTest {
// Now as we have all paths defined, plan operations on them.
final Random rand = new Random(SEED);
- int totalOpCnt = renCnt + delCnt + updateCnt + mkdirsCnt + createCnt;
+ final int totalOpCnt = renCnt + delCnt + updateCnt + mkdirsCnt + createCnt;
+
+ if (totalOpCnt == 0)
+ throw new RuntimeException("Operations count is zero.");
final CyclicBarrier barrier = new CyclicBarrier(totalOpCnt);
[06/29] ignite git commit: 1.4.0-SNAPSHOT
Posted by an...@apache.org.
1.4.0-SNAPSHOT
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/de12e9ab
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/de12e9ab
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/de12e9ab
Branch: refs/heads/ignite-1168
Commit: de12e9ab1f6d2525a12867e6c3eb540d648edf94
Parents: b054fdc
Author: Ignite Teamcity <ig...@apache.org>
Authored: Thu Sep 24 14:55:33 2015 +0300
Committer: Ignite Teamcity <ig...@apache.org>
Committed: Thu Sep 24 14:55:33 2015 +0300
----------------------------------------------------------------------
examples/schema-import/pom.xml | 7 ++-----
1 file changed, 2 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/de12e9ab/examples/schema-import/pom.xml
----------------------------------------------------------------------
diff --git a/examples/schema-import/pom.xml b/examples/schema-import/pom.xml
index fce6f47..f51007a 100644
--- a/examples/schema-import/pom.xml
+++ b/examples/schema-import/pom.xml
@@ -20,10 +20,7 @@
<!--
POM file.
-->
-<project
- xmlns="http://maven.apache.org/POM/4.0.0"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
@@ -38,7 +35,7 @@
</properties>
<artifactId>ignite-schema-import-demo</artifactId>
- <version>1.3.3-p7-SNAPSHOT</version>
+ <version>1.4.0-SNAPSHOT</version>
<dependencies>
<dependency>
[13/29] ignite git commit: fixed sha1 & md5, again
Posted by an...@apache.org.
fixed sha1 & md5, again
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7752aa9b
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7752aa9b
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7752aa9b
Branch: refs/heads/ignite-1168
Commit: 7752aa9b796068cbc51cc4ad8d7fc4b59dfa1c2b
Parents: 87ff90c
Author: Anton Vinogradov <av...@apache.org>
Authored: Fri Sep 25 16:01:40 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Fri Sep 25 16:01:40 2015 +0300
----------------------------------------------------------------------
pom.xml | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/7752aa9b/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 6ddc443..606bb0a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -626,7 +626,15 @@
</fileset>
</copy>
- <!-- appending filename to md5 and sha1 files. to be improved. -->
+ <!-- appending filename to md5 and sha1 files. to be improved!! -->
+ <!-- update versions task will replace " " to " ", so additional echo added. -->
+ <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.md5" append="true" message=" " />
+ <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.sha1" append="true" message=" " />
+ <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.md5" append="true" message=" " />
+ <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.sha1" append="true" message=" " />
+ <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.md5" append="true" message=" " />
+ <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.sha1" append="true" message=" " />
+
<echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
<echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
<echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
[24/29] ignite git commit: Minor fixes
Posted by an...@apache.org.
Minor fixes
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/833405e3
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/833405e3
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/833405e3
Branch: refs/heads/ignite-1168
Commit: 833405e355a10e86db8054497d92f0b459c6e399
Parents: 6fce2c5
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Tue Oct 6 13:37:25 2015 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Tue Oct 6 13:37:25 2015 +0300
----------------------------------------------------------------------
modules/yardstick/pom.xml | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/833405e3/modules/yardstick/pom.xml
----------------------------------------------------------------------
diff --git a/modules/yardstick/pom.xml b/modules/yardstick/pom.xml
index d18e1a9..c87ecbc 100644
--- a/modules/yardstick/pom.xml
+++ b/modules/yardstick/pom.xml
@@ -20,7 +20,9 @@
<!--
POM file.
-->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
[20/29] ignite git commit: Test Failed
Posted by an...@apache.org.
Test Failed
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/86168895
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/86168895
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/86168895
Branch: refs/heads/ignite-1168
Commit: 8616889556edf4aef532389c2639555facfc710d
Parents: 9702b52
Author: Anton Vinogradov <av...@apache.org>
Authored: Fri Oct 2 17:35:20 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Fri Oct 2 17:35:20 2015 +0300
----------------------------------------------------------------------
.../distributed/dht/GridNearCacheTxNodeFailureSelfTest.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/86168895/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridNearCacheTxNodeFailureSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridNearCacheTxNodeFailureSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridNearCacheTxNodeFailureSelfTest.java
index 5735182..ca23646 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridNearCacheTxNodeFailureSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridNearCacheTxNodeFailureSelfTest.java
@@ -28,4 +28,8 @@ public class GridNearCacheTxNodeFailureSelfTest extends GridCacheTxNodeFailureSe
@Override protected CacheConfiguration cacheConfiguration(String gridName) {
return super.cacheConfiguration(gridName).setNearConfiguration(new NearCacheConfiguration());
}
+
+ @Override public void testPrimaryNodeFailureBackupCommitImplicit(){
+ fail("https://issues.apache.org/jira/browse/IGNITE-1611");
+ }
}
[25/29] ignite git commit: ignite-1620 Tests muted
Posted by an...@apache.org.
ignite-1620 Tests muted
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/25809947
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/25809947
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/25809947
Branch: refs/heads/ignite-1168
Commit: 25809947a7715d57092d8bb009ef6e48afa79b62
Parents: 833405e
Author: agura <ag...@gridgain.com>
Authored: Tue Oct 6 15:19:21 2015 +0300
Committer: agura <ag...@gridgain.com>
Committed: Tue Oct 6 15:19:21 2015 +0300
----------------------------------------------------------------------
.../java/org/apache/ignite/igfs/Hadoop1DualAbstractTest.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/25809947/modules/hadoop/src/test/java/org/apache/ignite/igfs/Hadoop1DualAbstractTest.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/test/java/org/apache/ignite/igfs/Hadoop1DualAbstractTest.java b/modules/hadoop/src/test/java/org/apache/ignite/igfs/Hadoop1DualAbstractTest.java
index ea65464..efe95be 100644
--- a/modules/hadoop/src/test/java/org/apache/ignite/igfs/Hadoop1DualAbstractTest.java
+++ b/modules/hadoop/src/test/java/org/apache/ignite/igfs/Hadoop1DualAbstractTest.java
@@ -64,6 +64,11 @@ public abstract class Hadoop1DualAbstractTest extends IgfsDualAbstractSelfTest {
super(mode);
}
+ /** {@inheritDoc} */
+ @Override public void testMkdirs() throws Exception {
+ fail("https://issues.apache.org/jira/browse/IGNITE-1620");
+ }
+
/**
* Creates secondary filesystems.
* @return IgfsSecondaryFileSystem
[18/29] ignite git commit: ignite-1534 Fixed races in dynamic cache
start exchange ordering.
Posted by an...@apache.org.
ignite-1534 Fixed races in dynamic cache start exchange ordering.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7b54cbd7
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7b54cbd7
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7b54cbd7
Branch: refs/heads/ignite-1168
Commit: 7b54cbd7499cd498b04e821dfa3b572bd94debec
Parents: a411f94
Author: sboikov <sb...@gridgain.com>
Authored: Fri Oct 2 11:19:06 2015 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Fri Oct 2 11:19:06 2015 +0300
----------------------------------------------------------------------
.../discovery/GridDiscoveryManager.java | 2 +-
.../cache/DynamicCacheDescriptor.java | 17 ++
.../processors/cache/GridCacheContext.java | 2 +-
.../processors/cache/GridCacheMvccManager.java | 20 ++-
.../GridCachePartitionExchangeManager.java | 72 ++-------
.../processors/cache/GridCacheProcessor.java | 26 ++--
.../cache/distributed/dht/GridDhtGetFuture.java | 4 +-
.../dht/GridPartitionedGetFuture.java | 5 +-
.../dht/atomic/GridNearAtomicUpdateFuture.java | 9 +-
.../distributed/near/GridNearGetFuture.java | 2 +
.../cache/IgniteCachePutAllRestartTest.java | 4 +-
.../CacheGetFutureHangsSelfTest.java | 156 +++++++++----------
.../distributed/IgniteCacheCreatePutTest.java | 125 +++++++++++++++
.../testsuites/IgniteCacheTestSuite4.java | 5 +
14 files changed, 284 insertions(+), 165 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
index b694523..a6f5f08 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
@@ -550,7 +550,7 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
gridStartTime = getSpi().getGridStartTime();
updateTopologyVersionIfGreater(new AffinityTopologyVersion(locNode.order()),
- new DiscoCache(localNode(), getSpi().getRemoteNodes()));
+ new DiscoCache(localNode(), F.view(topSnapshot, F.remoteNodes(locNode.id()))));
startLatch.countDown();
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
index 24df7e4..b100a31 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/DynamicCacheDescriptor.java
@@ -68,6 +68,9 @@ public class DynamicCacheDescriptor {
/** */
private AffinityTopologyVersion startTopVer;
+ /** */
+ private boolean rcvdOnDiscovery;
+
/**
* @param ctx Context.
* @param cacheCfg Cache configuration.
@@ -236,6 +239,20 @@ public class DynamicCacheDescriptor {
this.updatesAllowed = updatesAllowed;
}
+ /**
+ * @return {@code True} if received in discovery data.
+ */
+ public boolean receivedOnDiscovery() {
+ return rcvdOnDiscovery;
+ }
+
+ /**
+ * @param rcvdOnDiscovery {@code True} if received in discovery data.
+ */
+ public void receivedOnDiscovery(boolean rcvdOnDiscovery) {
+ this.rcvdOnDiscovery = rcvdOnDiscovery;
+ }
+
/** {@inheritDoc} */
@Override public String toString() {
return S.toString(DynamicCacheDescriptor.class, this, "cacheName", U.maskName(cacheCfg.getName()));
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
index 5385dec..3a1cee6 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheContext.java
@@ -1848,7 +1848,7 @@ public class GridCacheContext<K, V> implements Externalizable {
boolean deserializePortable,
boolean cpy) {
assert key != null;
- assert val != null;
+ assert val != null || skipVals;
if (!keepCacheObjects) {
Object key0 = key.value(cacheObjCtx, false);
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java
index dd51da2..0960c9d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheMvccManager.java
@@ -391,13 +391,14 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter {
/**
* @param futVer Future ID.
* @param fut Future.
+ * @return {@code False} if future was forcibly completed with error.
*/
- public void addAtomicFuture(GridCacheVersion futVer, GridCacheAtomicFuture<?> fut) {
+ public boolean addAtomicFuture(GridCacheVersion futVer, GridCacheAtomicFuture<?> fut) {
IgniteInternalFuture<?> old = atomicFuts.put(futVer, fut);
assert old == null : "Old future is not null [futVer=" + futVer + ", fut=" + fut + ", old=" + old + ']';
- onFutureAdded(fut);
+ return onFutureAdded(fut);
}
/**
@@ -529,12 +530,21 @@ public class GridCacheMvccManager extends GridCacheSharedManagerAdapter {
/**
* @param fut Future.
+ * @return {@code False} if future was forcibly completed with error.
*/
- private void onFutureAdded(IgniteInternalFuture<?> fut) {
- if (stopping)
+ private boolean onFutureAdded(IgniteInternalFuture<?> fut) {
+ if (stopping) {
((GridFutureAdapter)fut).onDone(stopError());
- else if (cctx.kernalContext().clientDisconnected())
+
+ return false;
+ }
+ else if (cctx.kernalContext().clientDisconnected()) {
((GridFutureAdapter)fut).onDone(disconnectedError(null));
+
+ return false;
+ }
+
+ return true;
}
/**
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
index 3e77e0d..adc2174 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCachePartitionExchangeManager.java
@@ -105,18 +105,12 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
/** Partition resend timeout after eviction. */
private final long partResendTimeout = getLong(IGNITE_PRELOAD_RESEND_TIMEOUT, DFLT_PRELOAD_RESEND_TIMEOUT);
- /** Latch which completes after local exchange future is created. */
- private GridFutureAdapter<?> locExchFut;
-
/** */
private final ReadWriteLock busyLock = new ReentrantReadWriteLock();
/** Last partition refresh. */
private final AtomicLong lastRefresh = new AtomicLong(-1);
- /** Pending futures. */
- private final Queue<GridDhtPartitionsExchangeFuture> pendingExchangeFuts = new ConcurrentLinkedQueue<>();
-
/** */
@GridToStringInclude
private ExchangeWorker exchWorker;
@@ -229,31 +223,18 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
}
if (exchId != null) {
- // Start exchange process.
- pendingExchangeFuts.add(exchFut);
+ if (log.isDebugEnabled())
+ log.debug("Discovery event (will start exchange): " + exchId);
// Event callback - without this callback future will never complete.
exchFut.onEvent(exchId, e);
+ // Start exchange process.
+ addFuture(exchFut);
+ }
+ else {
if (log.isDebugEnabled())
- log.debug("Discovery event (will start exchange): " + exchId);
-
- locExchFut.listen(new CI1<IgniteInternalFuture<?>>() {
- @Override public void apply(IgniteInternalFuture<?> t) {
- if (!enterBusy())
- return;
-
- try {
- // Unwind in the order of discovery events.
- for (GridDhtPartitionsExchangeFuture f = pendingExchangeFuts.poll(); f != null;
- f = pendingExchangeFuts.poll())
- addFuture(f);
- }
- finally {
- leaveBusy();
- }
- }
- });
+ log.debug("Do not start exchange for discovery event: " + evt);
}
}
finally {
@@ -266,8 +247,6 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
@Override protected void start0() throws IgniteCheckedException {
super.start0();
- locExchFut = new GridFutureAdapter<>();
-
exchWorker = new ExchangeWorker();
cctx.gridEvents().addLocalEventListener(discoLsnr, EVT_NODE_JOINED, EVT_NODE_LEFT, EVT_NODE_FAILED,
@@ -328,12 +307,9 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
if (reconnect)
reconnectExchangeFut = new GridFutureAdapter<>();
- new IgniteThread(cctx.gridName(), "exchange-worker", exchWorker).start();
-
- onDiscoveryEvent(cctx.localNodeId(), fut);
+ exchWorker.futQ.addFirst(fut);
- // Allow discovery events to get processed.
- locExchFut.onDone();
+ new IgniteThread(cctx.gridName(), "exchange-worker", exchWorker).start();
if (reconnect) {
fut.listen(new CI1<IgniteInternalFuture<AffinityTopologyVersion>>() {
@@ -382,8 +358,10 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
}
}
- for (GridCacheContext cacheCtx : cctx.cacheContexts())
- cacheCtx.preloader().onInitialExchangeComplete(null);
+ for (GridCacheContext cacheCtx : cctx.cacheContexts()) {
+ if (cacheCtx.startTopologyVersion() == null)
+ cacheCtx.preloader().onInitialExchangeComplete(null);
+ }
if (log.isDebugEnabled())
log.debug("Finished waiting for initial exchange: " + fut.exchangeId());
@@ -414,12 +392,6 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
for (AffinityReadyFuture f : readyFuts.values())
f.onDone(stopErr);
- for (GridDhtPartitionsExchangeFuture f : pendingExchangeFuts)
- f.onDone(stopErr);
-
- if (locExchFut != null)
- locExchFut.onDone(stopErr);
-
U.cancel(exchWorker);
if (log.isDebugEnabled())
@@ -583,22 +555,6 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
}
/**
- * @param nodeId New node ID.
- * @param fut Exchange future.
- */
- void onDiscoveryEvent(UUID nodeId, GridDhtPartitionsExchangeFuture fut) {
- if (!enterBusy())
- return;
-
- try {
- addFuture(fut);
- }
- finally {
- leaveBusy();
- }
- }
-
- /**
* @param evt Discovery event.
* @return Affinity topology version.
*/
@@ -1033,7 +989,7 @@ public class GridCachePartitionExchangeManager<K, V> extends GridCacheSharedMana
U.warn(log, "Pending exchange futures:");
- for (GridDhtPartitionsExchangeFuture fut : pendingExchangeFuts)
+ for (GridDhtPartitionsExchangeFuture fut : exchWorker.futQ)
U.warn(log, ">>> " + fut);
ExchangeFutureSet exchFuts = this.exchFuts;
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
index 6c13399..daa4475 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheProcessor.java
@@ -805,7 +805,7 @@ public class GridCacheProcessor extends GridProcessorAdapter {
boolean loc = desc.locallyConfigured();
- if (loc || CU.affinityNode(locNode, filter)) {
+ if (loc || (desc.receivedOnDiscovery() && CU.affinityNode(locNode, filter))) {
CacheObjectContext cacheObjCtx = ctx.cacheObjects().contextForCache(ccfg);
CachePluginManager pluginMgr = desc.pluginManager();
@@ -1958,7 +1958,11 @@ public class GridCacheProcessor extends GridProcessorAdapter {
if (req.initiatingNodeId() == null)
desc.staticallyConfigured(true);
- registeredCaches.put(maskNull(req.cacheName()), desc);
+ desc.receivedOnDiscovery(true);
+
+ DynamicCacheDescriptor old = registeredCaches.put(maskNull(req.cacheName()), desc);
+
+ assert old == null : old;
ctx.discovery().setCacheFilter(
req.cacheName(),
@@ -2474,10 +2478,16 @@ public class GridCacheProcessor extends GridProcessorAdapter {
}
}
else {
- if (req.clientStartOnly()) {
- assert req.initiatingNodeId() != null : req;
+ assert req.initiatingNodeId() != null : req;
+
+ // Cache already exists, exchange is needed only if client cache should be created.
+ ClusterNode node = ctx.discovery().node(req.initiatingNodeId());
- needExchange = ctx.discovery().addClientNode(req.cacheName(),
+ boolean clientReq = node != null &&
+ !ctx.discovery().cacheAffinityNode(node, req.cacheName());
+
+ if (req.clientStartOnly()) {
+ needExchange = clientReq && ctx.discovery().addClientNode(req.cacheName(),
req.initiatingNodeId(),
req.nearCacheConfiguration() != null);
}
@@ -2488,12 +2498,6 @@ public class GridCacheProcessor extends GridProcessorAdapter {
"(a cache with the same name is already started): " + U.maskName(req.cacheName())));
}
else {
- // Cache already exists, exchange is needed only if client cache should be created.
- ClusterNode node = ctx.discovery().node(req.initiatingNodeId());
-
- boolean clientReq = node != null &&
- !ctx.discovery().cacheAffinityNode(node, req.cacheName());
-
needExchange = clientReq && ctx.discovery().addClientNode(req.cacheName(),
req.initiatingNodeId(),
req.nearCacheConfiguration() != null);
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtGetFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtGetFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtGetFuture.java
index 76aaf72..a67b1de 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtGetFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridDhtGetFuture.java
@@ -447,8 +447,8 @@ public final class GridDhtGetFuture<K, V> extends GridCompoundIdentityFuture<Col
if (v == null)
it.remove();
- else if (!skipVals)
- info.value((CacheObject)v);
+ else
+ info.value(skipVals ? null : (CacheObject)v);
}
return infos;
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java
index 0202c53..abbe7b8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/GridPartitionedGetFuture.java
@@ -587,8 +587,11 @@ public class GridPartitionedGetFuture<K, V> extends GridCompoundIdentityFuture<M
if (keysSize != 0) {
Map<K, V> map = new GridLeanMap<>(keysSize);
- for (GridCacheEntryInfo info : infos)
+ for (GridCacheEntryInfo info : infos) {
+ assert skipVals == (info.value() == null);
+
cctx.addResult(map, info.key(), info.value(), skipVals, false, deserializePortable, false);
+ }
return map;
}
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
index fb2c5ad..41df53a 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicUpdateFuture.java
@@ -825,8 +825,13 @@ public class GridNearAtomicUpdateFuture extends GridFutureAdapter<Object>
futVer = cctx.versions().next(topVer);
- if (storeFuture())
- cctx.mvcc().addAtomicFuture(futVer, GridNearAtomicUpdateFuture.this);
+ if (storeFuture()) {
+ if (!cctx.mvcc().addAtomicFuture(futVer, GridNearAtomicUpdateFuture.this)) {
+ assert isDone() : GridNearAtomicUpdateFuture.this;
+
+ return;
+ }
+ }
// Assign version on near node in CLOCK ordering mode even if fastMap is false.
if (updVer == null)
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java
index a7875f6..d9763f8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearGetFuture.java
@@ -703,6 +703,8 @@ public final class GridNearGetFuture<K, V> extends GridCompoundIdentityFuture<Ma
CacheObject val = info.value();
KeyCacheObject key = info.key();
+ assert skipVals == (info.value() == null);
+
cctx.addResult(map, key, val, skipVals, false, deserializePortable, false);
}
catch (GridCacheEntryRemovedException ignore) {
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCachePutAllRestartTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCachePutAllRestartTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCachePutAllRestartTest.java
index fc14085..ae99926 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCachePutAllRestartTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCachePutAllRestartTest.java
@@ -163,12 +163,12 @@ public class IgniteCachePutAllRestartTest extends GridCommonAbstractTest {
info("Running iteration on the node [idx=" + node + ", nodeId=" + ignite.cluster().localNode().id() + ']');
+ final IgniteCache<Integer, Integer> cache = ignite.cache(CACHE_NAME);
+
IgniteInternalFuture<?> fut = GridTestUtils.runAsync(new Callable<Void>() {
@Override public Void call() throws Exception {
Thread.currentThread().setName("put-thread");
- IgniteCache<Integer, Integer> cache = ignite.cache(CACHE_NAME);
-
Random rnd = new Random();
long endTime = System.currentTimeMillis() + 60_000;
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheGetFutureHangsSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheGetFutureHangsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheGetFutureHangsSelfTest.java
index 8e8447e..e8622aa 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheGetFutureHangsSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/CacheGetFutureHangsSelfTest.java
@@ -18,23 +18,21 @@
package org.apache.ignite.internal.processors.cache.distributed;
import java.util.ArrayList;
-import java.util.Collection;
-import java.util.HashSet;
-import java.util.Set;
+import java.util.List;
import java.util.UUID;
import java.util.concurrent.ThreadLocalRandom;
-import java.util.concurrent.atomic.AtomicBoolean;
+import java.util.concurrent.atomic.AtomicReferenceArray;
import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.cache.CacheAtomicityMode;
import org.apache.ignite.cache.CacheMode;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.configuration.IgniteConfiguration;
-import org.apache.ignite.internal.IgniteEx;
import org.apache.ignite.internal.IgniteInternalFuture;
-import org.apache.ignite.internal.util.typedef.internal.U;
+import org.apache.ignite.internal.util.typedef.T2;
import org.apache.ignite.marshaller.optimized.OptimizedMarshaller;
import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+import org.jetbrains.annotations.Nullable;
import static org.apache.ignite.cache.CacheWriteSynchronizationMode.PRIMARY_SYNC;
@@ -45,22 +43,14 @@ public class CacheGetFutureHangsSelfTest extends GridCommonAbstractTest {
/** Grid count. */
private static final int GRID_CNT = 8;
- /** Grids. */
- private static Ignite[] grids;
+ /** */
+ private AtomicReferenceArray<Ignite> nodes;
- /** Ids. */
- private static String[] ids;
-
- /** Flags. */
- private static AtomicBoolean[] flags;
-
- /** Futs. */
- private static Collection<IgniteInternalFuture> futs;
-
- /** Alive grids. */
- private static Set<Integer> aliveGrids;
+ /** */
+ private volatile boolean done;
/** {@inheritDoc} */
+ @SuppressWarnings("unchecked")
@Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
IgniteConfiguration cfg = super.getConfiguration(gridName);
@@ -81,17 +71,27 @@ public class CacheGetFutureHangsSelfTest extends GridCommonAbstractTest {
return cfg;
}
+ /** {@inheritDoc} */
+ @Override protected void afterTestsStopped() throws Exception {
+ super.afterTestsStopped();
+
+ stopAllGrids();
+ }
+
+ /** {@inheritDoc} */
+ @Override protected long getTestTimeout() {
+ return 5 * 60_000;
+ }
+
/**
* @throws Exception If failed.
*/
- public void testFailover() throws Exception {
- int cnt = 10;
+ public void testContainsKeyFailover() throws Exception {
+ int cnt = 3;
for (int i = 0; i < cnt; i++) {
try {
- U.debug("*** Iteration " + (i + 1) + '/' + cnt);
-
- init();
+ log.info("Iteration: " + (i + 1) + '/' + cnt);
doTestFailover();
}
@@ -102,54 +102,34 @@ public class CacheGetFutureHangsSelfTest extends GridCommonAbstractTest {
}
/**
- * Initializes test.
- */
- private void init() {
- grids = new Ignite[GRID_CNT + 1];
-
- ids = new String[GRID_CNT + 1];
-
- aliveGrids = new HashSet<>();
-
- flags = new AtomicBoolean[GRID_CNT + 1];
-
- futs = new ArrayList<>();
- }
-
- /**
* Executes one test iteration.
+ * @throws Exception If failed.
*/
private void doTestFailover() throws Exception {
try {
- for (int i = 0; i < GRID_CNT + 1; i++) {
- final IgniteEx grid = startGrid(i);
+ done = false;
- grids[i] = grid;
+ nodes = new AtomicReferenceArray<>(GRID_CNT);
- ids[i] = grid.localNode().id().toString();
+ startGridsMultiThreaded(GRID_CNT, false);
- aliveGrids.add(i);
+ for (int i = 0; i < GRID_CNT ; i++)
+ assertTrue(nodes.compareAndSet(i, null, ignite(i)));
- flags[i] = new AtomicBoolean();
- }
+ List<IgniteInternalFuture> futs = new ArrayList<>();
for (int i = 0; i < GRID_CNT + 1; i++) {
- final int gridIdx = i;
-
futs.add(multithreadedAsync(new Runnable() {
@Override public void run() {
- IgniteCache cache = grids[gridIdx].cache(null);
+ T2<Ignite, Integer> ignite;
- while (!flags[gridIdx].get()) {
- int idx = ThreadLocalRandom.current().nextInt(GRID_CNT + 1);
+ while ((ignite = randomNode()) != null) {
+ IgniteCache<Object, Object> cache = ignite.get1().cache(null);
- String id = ids[idx];
+ for (int i = 0; i < 100; i++)
+ cache.containsKey(ThreadLocalRandom.current().nextInt(100_000));
- if (id != null /*&& grids[gridIdx] != null*/) {
- //U.debug("!!! Grid containsKey start " + gridIdx);
- cache.containsKey(id);
- //U.debug("!!! Grid containsKey finished " + gridIdx);
- }
+ assertTrue(nodes.compareAndSet(ignite.get2(), null, ignite.get1()));
try {
Thread.sleep(ThreadLocalRandom.current().nextLong(50));
@@ -163,18 +143,15 @@ public class CacheGetFutureHangsSelfTest extends GridCommonAbstractTest {
futs.add(multithreadedAsync(new Runnable() {
@Override public void run() {
- IgniteCache cache = grids[gridIdx].cache(null);
+ T2<Ignite, Integer> ignite;
- while (!flags[gridIdx].get()) {
- int idx = ThreadLocalRandom.current().nextInt(GRID_CNT + 1);
+ while ((ignite = randomNode()) != null) {
+ IgniteCache<Object, Object> cache = ignite.get1().cache(null);
- String id = ids[idx];
+ for (int i = 0; i < 100; i++)
+ cache.put(ThreadLocalRandom.current().nextInt(100_000), UUID.randomUUID());
- if (id != null /*&& grids[gridIdx] != null*/) {
- //U.debug("!!! Grid put start " + gridIdx);
- cache.put(id, UUID.randomUUID());
- //U.debug("!!! Grid put finished " + gridIdx);
- }
+ assertTrue(nodes.compareAndSet(ignite.get2(), null, ignite.get1()));
try {
Thread.sleep(ThreadLocalRandom.current().nextLong(50));
@@ -187,35 +164,50 @@ public class CacheGetFutureHangsSelfTest extends GridCommonAbstractTest {
}, 1, "put-thread-" + i));
}
- while (aliveGrids.size() > 1) {
- final int gridToKill = ThreadLocalRandom.current().nextInt(GRID_CNT) + 1;
+ try {
+ int aliveGrids = GRID_CNT;
- if (gridToKill > 0 && grids[gridToKill] != null) {
- U.debug("!!! Trying to kill grid " + gridToKill);
+ while (aliveGrids > 0) {
+ T2<Ignite, Integer> ignite = randomNode();
- //synchronized (mons[gridToKill]) {
- U.debug("!!! Grid stop start " + gridToKill);
+ assert ignite != null;
- grids[gridToKill].close();
+ Ignite ignite0 = ignite.get1();
- aliveGrids.remove(gridToKill);
+ log.info("Stop node: " + ignite0.name());
- grids[gridToKill] = null;
+ ignite0.close();
- flags[gridToKill].set(true);
+ log.info("Node stop finished: " + ignite0.name());
- U.debug("!!! Grid stop finished " + gridToKill);
- //}
+ aliveGrids--;
}
}
+ finally {
+ done = true;
+ }
- Thread.sleep(ThreadLocalRandom.current().nextLong(100));
+ for (IgniteInternalFuture fut : futs)
+ fut.get();
}
finally {
- flags[0].set(true);
+ done = true;
+ }
+ }
- for (IgniteInternalFuture fut : futs)
- fut.get();
+ /**
+ * @return Random node and its index.
+ */
+ @Nullable private T2<Ignite, Integer> randomNode() {
+ while (!done) {
+ int idx = ThreadLocalRandom.current().nextInt(GRID_CNT);
+
+ Ignite ignite = nodes.get(idx);
+
+ if (ignite != null && nodes.compareAndSet(idx, ignite, null))
+ return new T2<>(ignite, idx);
}
+
+ return null;
}
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheCreatePutTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheCreatePutTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheCreatePutTest.java
new file mode 100644
index 0000000..8b3d9d3
--- /dev/null
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/IgniteCacheCreatePutTest.java
@@ -0,0 +1,125 @@
+/*
+ * 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.internal.processors.cache.distributed;
+
+import java.util.concurrent.Callable;
+import java.util.concurrent.atomic.AtomicInteger;
+import org.apache.ignite.Ignite;
+import org.apache.ignite.IgniteCache;
+import org.apache.ignite.cache.CacheMode;
+import org.apache.ignite.configuration.CacheConfiguration;
+import org.apache.ignite.configuration.IgniteConfiguration;
+import org.apache.ignite.marshaller.optimized.OptimizedMarshaller;
+import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi;
+import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder;
+import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder;
+import org.apache.ignite.testframework.GridTestUtils;
+import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
+
+/**
+ *
+ */
+public class IgniteCacheCreatePutTest extends GridCommonAbstractTest {
+ /** Grid count. */
+ private static final int GRID_CNT = 3;
+
+ /** */
+ private static TcpDiscoveryIpFinder ipFinder = new TcpDiscoveryVmIpFinder(true);
+
+ /** {@inheritDoc} */
+ protected IgniteConfiguration getConfiguration(String gridName) throws Exception {
+ IgniteConfiguration cfg = super.getConfiguration(gridName);
+
+ cfg.setPeerClassLoadingEnabled(false);
+
+ TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
+ discoSpi.setIpFinder(ipFinder);
+
+ cfg.setDiscoverySpi(discoSpi);
+
+ OptimizedMarshaller marsh = new OptimizedMarshaller();
+ marsh.setRequireSerializable(false);
+
+ cfg.setMarshaller(marsh);
+
+ CacheConfiguration ccfg = new CacheConfiguration();
+
+ ccfg.setName("cache*");
+ ccfg.setCacheMode(CacheMode.PARTITIONED);
+ ccfg.setBackups(1);
+
+ cfg.setCacheConfiguration(ccfg);
+
+ return cfg;
+ }
+
+ /** {@inheritDoc} */
+ @Override protected long getTestTimeout() {
+ return 3 * 60 * 1000L;
+ }
+
+ /** {@inheritDoc} */
+ @Override protected void afterTestsStopped() throws Exception {
+ super.afterTestsStopped();
+
+ stopAllGrids();
+ }
+
+ /**
+ * @throws Exception If failed.
+ */
+ public void testStartNodes() throws Exception {
+ long stopTime = System.currentTimeMillis() + 2 * 60_000;
+
+ try {
+ int iter = 0;
+
+ while (System.currentTimeMillis() < stopTime) {
+ log.info("Iteration: " + iter++);
+
+ try {
+ final AtomicInteger idx = new AtomicInteger();
+
+ GridTestUtils.runMultiThreaded(new Callable<Void>() {
+ @Override
+ public Void call() throws Exception {
+ int node = idx.getAndIncrement();
+
+ Ignite ignite = startGrid(node);
+
+ IgniteCache<Object, Object> cache = ignite.getOrCreateCache("cache1");
+
+ assertNotNull(cache);
+
+ for (int i = 0; i < 100; i++)
+ cache.put(i, i);
+
+ return null;
+ }
+ }, GRID_CNT, "start");
+ }
+ finally {
+ stopAllGrids();
+ }
+ }
+ }
+ finally {
+ stopAllGrids();
+ }
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/7b54cbd7/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite4.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite4.java b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite4.java
index f8c9d26..b89bffd 100644
--- a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite4.java
+++ b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite4.java
@@ -77,8 +77,10 @@ import org.apache.ignite.internal.processors.cache.IgniteStartCacheInTransaction
import org.apache.ignite.internal.processors.cache.IgniteStartCacheInTransactionSelfTest;
import org.apache.ignite.internal.processors.cache.IgniteSystemCacheOnClientTest;
import org.apache.ignite.internal.processors.cache.distributed.CacheAffinityEarlyTest;
+import org.apache.ignite.internal.processors.cache.distributed.CacheGetFutureHangsSelfTest;
import org.apache.ignite.internal.processors.cache.distributed.CacheNoValueClassOnServerNodeTest;
import org.apache.ignite.internal.processors.cache.distributed.IgniteCacheCreatePutMultiNodeSelfTest;
+import org.apache.ignite.internal.processors.cache.distributed.IgniteCacheCreatePutTest;
import org.apache.ignite.internal.processors.cache.distributed.dht.GridCacheDhtTxPreloadSelfTest;
import org.apache.ignite.internal.processors.cache.distributed.dht.IgniteCacheLockFailoverSelfTest;
import org.apache.ignite.internal.processors.cache.distributed.dht.IgniteCacheMultiTxLockSelfTest;
@@ -205,6 +207,7 @@ public class IgniteCacheTestSuite4 extends TestSuite {
suite.addTestSuite(IgniteDynamicCacheStartNoExchangeTimeoutTest.class);
suite.addTestSuite(CacheAffinityEarlyTest.class);
suite.addTestSuite(IgniteCacheCreatePutMultiNodeSelfTest.class);
+ suite.addTestSuite(IgniteCacheCreatePutTest.class);
suite.addTestSuite(GridCacheTxLoadFromStoreOnLockSelfTest.class);
@@ -278,6 +281,8 @@ public class IgniteCacheTestSuite4 extends TestSuite {
suite.addTestSuite(CrossCacheLockTest.class);
suite.addTestSuite(IgniteCrossCacheTxSelfTest.class);
+ suite.addTestSuite(CacheGetFutureHangsSelfTest.class);
+
return suite;
}
}
\ No newline at end of file
[07/29] ignite git commit: schema-import examples fix
Posted by an...@apache.org.
schema-import examples fix
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/15d2f762
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/15d2f762
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/15d2f762
Branch: refs/heads/ignite-1168
Commit: 15d2f7625a0822167ea969dc289c10385092b5d0
Parents: de12e9a
Author: Anton Vinogradov <av...@apache.org>
Authored: Thu Sep 24 16:55:00 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Thu Sep 24 16:55:00 2015 +0300
----------------------------------------------------------------------
assembly/release-fabric.xml | 9 +++
examples/schema-import/pom-standalone.xml | 90 ++++++++++++++++++++++++++
pom.xml | 5 ++
3 files changed, 104 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/15d2f762/assembly/release-fabric.xml
----------------------------------------------------------------------
diff --git a/assembly/release-fabric.xml b/assembly/release-fabric.xml
index a8c4541..308853c 100644
--- a/assembly/release-fabric.xml
+++ b/assembly/release-fabric.xml
@@ -51,6 +51,12 @@
<outputDirectory>/examples</outputDirectory>
<destName>pom.xml</destName>
</file>
+
+ <file>
+ <source>examples/schema-import/pom-standalone.xml</source>
+ <outputDirectory>/examples/schema-import</outputDirectory>
+ <destName>pom.xml</destName>
+ </file>
</files>
<fileSets>
@@ -85,6 +91,9 @@
<include>schema-import/**</include>
<include>README.txt</include>
</includes>
+ <excludes>
+ <exclude>schema-import/pom*.xml</exclude>
+ </excludes>
</fileSet>
<fileSet>
http://git-wip-us.apache.org/repos/asf/ignite/blob/15d2f762/examples/schema-import/pom-standalone.xml
----------------------------------------------------------------------
diff --git a/examples/schema-import/pom-standalone.xml b/examples/schema-import/pom-standalone.xml
new file mode 100644
index 0000000..e443728
--- /dev/null
+++ b/examples/schema-import/pom-standalone.xml
@@ -0,0 +1,90 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<!--
+ ~ 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.
+ -->
+
+<!--
+ POM file.
+-->
+<project
+ xmlns="http://maven.apache.org/POM/4.0.0"
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+ <modelVersion>4.0.0</modelVersion>
+
+ <properties>
+ <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+ </properties>
+
+ <groupId>org.apache.ignite</groupId>
+ <artifactId>ignite-schema-import-demo</artifactId>
+ <version>to_be_replaced_by_ignite_version</version>
+
+ <dependencies>
+ <dependency>
+ <groupId>javax.cache</groupId>
+ <artifactId>cache-api</artifactId>
+ <version>1.0.0</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.ignite</groupId>
+ <artifactId>ignite-core</artifactId>
+ <version>to_be_replaced_by_ignite_version</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.ignite</groupId>
+ <artifactId>ignite-spring</artifactId>
+ <version>to_be_replaced_by_ignite_version</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.ignite</groupId>
+ <artifactId>ignite-log4j</artifactId>
+ <version>to_be_replaced_by_ignite_version</version>
+ </dependency>
+
+ <dependency>
+ <groupId>org.apache.ignite</groupId>
+ <artifactId>ignite-indexing</artifactId>
+ <version>to_be_replaced_by_ignite_version</version>
+ </dependency>
+ </dependencies>
+
+ <build>
+ <resources>
+ <resource>
+ <directory>src/main/java</directory>
+ <excludes>
+ <exclude>**/*.java</exclude>
+ </excludes>
+ </resource>
+ </resources>
+
+ <plugins>
+ <plugin>
+ <artifactId>maven-compiler-plugin</artifactId>
+ <version>3.1</version>
+ <configuration>
+ <source>1.7</source>
+ <target>1.7</target>
+ </configuration>
+ </plugin>
+ </plugins>
+ </build>
+</project>
http://git-wip-us.apache.org/repos/asf/ignite/blob/15d2f762/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index a5b47d5..6ddc443 100644
--- a/pom.xml
+++ b/pom.xml
@@ -299,6 +299,11 @@
<substitution expression="${project.version}" />
</replaceregexp>
+ <replaceregexp file="${basedir}/target/release-package/examples/schema-import/pom.xml" byline="true">
+ <regexp pattern="to_be_replaced_by_ignite_version" />
+ <substitution expression="${project.version}" />
+ </replaceregexp>
+
<chmod dir="${basedir}/target/release-package" perm="755" includes="**/*.sh" />
<!-- hotfix according to https://issues.apache.org/jira/browse/IGNITE-1399. Remove at 1.5 -->
[11/29] ignite git commit: fixed sha1 & md5, again
Posted by an...@apache.org.
fixed sha1 & md5, again
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/8e21daa8
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8e21daa8
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8e21daa8
Branch: refs/heads/ignite-1168
Commit: 8e21daa8ea1cbfc5dbb1f84e9ccaf7101152b5a6
Parents: 656b118
Author: Anton Vinogradov <av...@apache.org>
Authored: Fri Sep 25 15:50:00 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Fri Sep 25 15:50:00 2015 +0300
----------------------------------------------------------------------
pom.xml | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/8e21daa8/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 6ddc443..b1a9f65 100644
--- a/pom.xml
+++ b/pom.xml
@@ -627,12 +627,12 @@
</copy>
<!-- appending filename to md5 and sha1 files. to be improved. -->
- <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.md5" append="true" message=" ${project.artifactId}-${project.version}-src.zip" />
- <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.sha1" append="true" message=" ${project.artifactId}-${project.version}-src.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-fabric-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-fabric-${project.version}-bin.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.md5" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-hadoop-${project.version}-bin.zip.sha1" append="true" message=" ${project.artifactId}-hadoop-${project.version}-bin.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.md5" append="true" message=" ${project.artifactId}-${project.version}-src.zip" />
+ <echo file="${basedir}/target/site/${project.artifactId}-${project.version}-src.zip.sha1" append="true" message=" ${project.artifactId}-${project.version}-src.zip" />
</target>
</configuration>
</execution>
[02/29] ignite git commit: minor - added space
Posted by an...@apache.org.
minor - added space
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/59bc35a6
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/59bc35a6
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/59bc35a6
Branch: refs/heads/ignite-1168
Commit: 59bc35a61571284c106fe4f67060eccb8b60faea
Parents: 6034931
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Thu Sep 24 13:33:42 2015 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Thu Sep 24 13:33:42 2015 +0300
----------------------------------------------------------------------
.../ignite/internal/managers/discovery/GridDiscoveryManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/59bc35a6/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
index 3a09b2c..1801b9c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
@@ -2437,7 +2437,7 @@ public class GridDiscoveryManager extends GridManagerAdapter<DiscoverySpi> {
Map<String, Collection<ClusterNode>> cacheMap = new HashMap<>(allNodes.size(), 1.0f);
Map<String, Collection<ClusterNode>> rmtCacheMap = new HashMap<>(allNodes.size(), 1.0f);
- Map<String, Collection<ClusterNode>> dhtNodesMap =new HashMap<>(allNodes.size(), 1.0f);
+ Map<String, Collection<ClusterNode>> dhtNodesMap = new HashMap<>(allNodes.size(), 1.0f);
Collection<ClusterNode> nodesWithCaches = new HashSet<>(allNodes.size());
Collection<ClusterNode> rmtNodesWithCaches = new HashSet<>(allNodes.size());
[14/29] ignite git commit: Test Failed
Posted by an...@apache.org.
Test Failed
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/150a644e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/150a644e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/150a644e
Branch: refs/heads/ignite-1168
Commit: 150a644e9b939ccf921cac5c34af97358a16c50a
Parents: b08e0b2
Author: Anton Vinogradov <av...@apache.org>
Authored: Thu Oct 1 14:58:20 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Thu Oct 1 14:58:20 2015 +0300
----------------------------------------------------------------------
.../processors/cache/IgniteCacheEntryListenerTxTest.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/150a644e/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerTxTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerTxTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerTxTest.java
index cad57f0..a9e43d4 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerTxTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/IgniteCacheEntryListenerTxTest.java
@@ -47,4 +47,8 @@ public class IgniteCacheEntryListenerTxTest extends IgniteCacheEntryListenerAbst
@Override protected NearCacheConfiguration nearConfiguration() {
return null;
}
+
+ @Override public void testEvents(){
+ fail("https://issues.apache.org/jira/browse/IGNITE-1600");
+ }
}
\ No newline at end of file
[08/29] ignite git commit: schema-import examples fix
Posted by an...@apache.org.
schema-import examples fix
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a2c972bf
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a2c972bf
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a2c972bf
Branch: refs/heads/ignite-1168
Commit: a2c972bf5ef59ffd13d65eacc4356ea1ac65383c
Parents: 15d2f76
Author: Anton Vinogradov <av...@apache.org>
Authored: Thu Sep 24 18:11:17 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Thu Sep 24 18:11:17 2015 +0300
----------------------------------------------------------------------
assembly/release-fabric.xml | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/a2c972bf/assembly/release-fabric.xml
----------------------------------------------------------------------
diff --git a/assembly/release-fabric.xml b/assembly/release-fabric.xml
index 308853c..9f9fbb2 100644
--- a/assembly/release-fabric.xml
+++ b/assembly/release-fabric.xml
@@ -88,12 +88,11 @@
<includes>
<include>rest/**</include>
<include>memcached/**</include>
- <include>schema-import/**</include>
+ <include>schema-import/src/**</include>
+ <include>schema-import/bin/**</include>
+ <include>schema-import/README.txt</include>
<include>README.txt</include>
</includes>
- <excludes>
- <exclude>schema-import/pom*.xml</exclude>
- </excludes>
</fileSet>
<fileSet>
[16/29] ignite git commit: Merge branch 'ignite-1.4'
Posted by an...@apache.org.
Merge branch 'ignite-1.4'
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fd091c82
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fd091c82
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fd091c82
Branch: refs/heads/ignite-1168
Commit: fd091c82892040df8da935527ce72da996fa7718
Parents: 0309f96 7752aa9
Author: Anton Vinogradov <av...@apache.org>
Authored: Thu Oct 1 16:26:28 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Thu Oct 1 16:26:28 2015 +0300
----------------------------------------------------------------------
RELEASE_NOTES.txt | 2 +
assembly/dependencies-fabric.xml | 2 +-
assembly/release-fabric.xml | 10 ++-
examples/schema-import/pom-standalone.xml | 90 ++++++++++++++++++++
examples/schema-import/pom.xml | 13 ++-
.../discovery/GridDiscoveryManager.java | 2 +-
pom.xml | 9 +-
7 files changed, 119 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fd091c82/examples/schema-import/pom.xml
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fd091c82/modules/core/src/main/java/org/apache/ignite/internal/managers/discovery/GridDiscoveryManager.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/fd091c82/pom.xml
----------------------------------------------------------------------
[19/29] ignite git commit: Apache Ignite License Generator Module
Readme
Posted by an...@apache.org.
Apache Ignite License Generator Module Readme
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/9702b52f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/9702b52f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/9702b52f
Branch: refs/heads/ignite-1168
Commit: 9702b52f8ade6f2ee970d8cd77a71911106f3f21
Parents: 7b54cbd
Author: Anton Vinogradov <av...@apache.org>
Authored: Fri Oct 2 17:05:31 2015 +0300
Committer: Anton Vinogradov <av...@apache.org>
Committed: Fri Oct 2 17:05:31 2015 +0300
----------------------------------------------------------------------
modules/apache-license-gen/README.txt | 33 ++++++++++++++++++++++++++++++
1 file changed, 33 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/9702b52f/modules/apache-license-gen/README.txt
----------------------------------------------------------------------
diff --git a/modules/apache-license-gen/README.txt b/modules/apache-license-gen/README.txt
new file mode 100644
index 0000000..a0c027e
--- /dev/null
+++ b/modules/apache-license-gen/README.txt
@@ -0,0 +1,33 @@
+Apache Ignite License Generator Module
+------------------------------
+
+Apache Ignite License Generator module is a custom maven resource plugin.
+It generates /license/{module name}-licenses.txt file contains list of module's non transitive dependencies.
+Apache Ignite binary distribution contains all non transitive dependencies of it's modules.
+Set of modules included to binary distribution may vary as well as their dependencies list, versions and licenses.
+Automatic generation of /license/{module name}-licenses.txt file guarantee that binary distribution gives user
+actual information about licenses used by Apache Ignite's modules.
+
+Note that in case dependency provided under Apache License 2.0 only in will not appear inside generated file.
+
+To use Apache Ignite License Generator Module in your project please add following to pom.xml:
+
+<plugin><!-- generates dependencies licenses -->
+ <groupId>org.apache.maven.plugins</groupId>
+ <artifactId>maven-remote-resources-plugin</artifactId>
+ <executions>
+ <execution>
+ <id>ignite-dependencies</id>
+ <goals>
+ <goal>process</goal>
+ </goals>
+ <configuration>
+ <resourceBundles>
+ <resourceBundle>org.apache.ignite:ignite-apache-license-gen:${project.version}</resourceBundle>
+ </resourceBundles>
+ <excludeTransitive>true</excludeTransitive>
+ </configuration>
+ </execution>
+ </executions>
+ </plugin>
+
[23/29] ignite git commit: Merge remote-tracking branch
'origin/master'
Posted by an...@apache.org.
Merge remote-tracking branch 'origin/master'
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6fce2c52
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6fce2c52
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6fce2c52
Branch: refs/heads/ignite-1168
Commit: 6fce2c52fd08da232659ff5b90bf15ad60c9dced
Parents: 8fc14ec 35fa5e6
Author: Yakov Zhdanov <yz...@gridgain.com>
Authored: Tue Oct 6 13:36:41 2015 +0300
Committer: Yakov Zhdanov <yz...@gridgain.com>
Committed: Tue Oct 6 13:36:41 2015 +0300
----------------------------------------------------------------------
.../cache/GridCacheDeploymentOffHeapSelfTest.java | 15 +++++++++++++++
1 file changed, 15 insertions(+)
----------------------------------------------------------------------