[21/54] [abbrv] ignite git commit: ignite-7772 System workers critical failures handling

2018-04-13 Thread agoncharuk 
ignite-7772 System workers critical failures handling

Signed-off-by: Andrey Gura 


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c807ae95
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c807ae95
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c807ae95

Branch: refs/heads/ignite-6083
Commit: c807ae952c233cf1a8c0a63d543fafe19c40c6aa
Parents: 05d7092
Author: Andrey Kuznetsov 
Authored: Tue Apr 10 17:30:12 2018 +0300
Committer: Andrey Gura 
Committed: Tue Apr 10 17:30:12 2018 +0300

--
 .../org/apache/ignite/internal/IgnitionEx.java  |  15 +-
 .../GridClientConnectionManagerAdapter.java |   6 +
 .../impl/GridTcpRouterNioListenerAdapter.java   |   6 +
 .../discovery/GridDiscoveryManager.java |  16 +-
 .../GridCachePartitionExchangeManager.java  |  12 +-
 .../cache/GridCacheSharedTtlCleanupManager.java |  41 +++--
 .../GridCacheDatabaseSharedManager.java |  60 +--
 .../wal/FileWriteAheadLogManager.java   | 157 ---
 .../wal/FsyncModeFileWriteAheadLogManager.java  |  34 +++-
 .../timeout/GridTimeoutProcessor.java   | 102 +++-
 .../ignite/internal/util/StripedExecutor.java   |  69 +---
 .../ignite/internal/util/nio/GridNioServer.java |  43 -
 .../util/nio/GridNioServerListener.java |   6 +
 .../util/nio/GridNioServerListenerAdapter.java  |   6 +
 .../communication/tcp/TcpCommunicationSpi.java  |  41 -
 .../ignite/spi/discovery/tcp/ServerImpl.java|  51 +-
 .../internal/util/StripedExecutorTest.java  |   2 +-
 17 files changed, 501 insertions(+), 166 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/ignite/blob/c807ae95/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java 
b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
index 417ba1e..10a0752 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
@@ -137,6 +137,7 @@ import static 
org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
 import static 
org.apache.ignite.configuration.IgniteConfiguration.DFLT_THREAD_KEEP_ALIVE_TIME;
 import static 
org.apache.ignite.configuration.MemoryConfiguration.DFLT_MEMORY_POLICY_MAX_SIZE;
 import static 
org.apache.ignite.configuration.MemoryConfiguration.DFLT_MEM_PLC_DEFAULT_NAME;
+import static org.apache.ignite.failure.FailureType.SYSTEM_WORKER_TERMINATION;
 import static org.apache.ignite.internal.IgniteComponentType.SPRING;
 import static 
org.apache.ignite.plugin.segmentation.SegmentationPolicy.RESTART_JVM;
 
@@ -1806,7 +1807,13 @@ public class IgnitionEx {
 cfg.getStripedPoolSize(),
 cfg.getIgniteInstanceName(),
 "sys",
-log);
+log,
+new Thread.UncaughtExceptionHandler() {
+@Override public void uncaughtException(Thread thread, 
Throwable t) {
+if (grid != null)
+grid.context().failure().process(new 
FailureContext(SYSTEM_WORKER_TERMINATION, t));
+}
+});
 
 // Note that since we use 'LinkedBlockingQueue', number of
 // maximum threads has no effect.
@@ -1846,6 +1853,12 @@ public class IgnitionEx {
 cfg.getIgniteInstanceName(),
 "data-streamer",
 log,
+new Thread.UncaughtExceptionHandler() {
+@Override public void uncaughtException(Thread thread, 
Throwable t) {
+if (grid != null)
+grid.context().failure().process(new 
FailureContext(SYSTEM_WORKER_TERMINATION, t));
+}
+},
 true);
 
 // Note that we do not pre-start threads here as igfs pool may not 
be needed.

http://git-wip-us.apache.org/repos/asf/ignite/blob/c807ae95/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
index 829b188..fe0453f 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/client/

[09/14] ignite git commit: ignite-7772 System workers critical failures handling

2018-04-11 Thread akuznetsov 
ignite-7772 System workers critical failures handling

Signed-off-by: Andrey Gura 


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c807ae95
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c807ae95
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c807ae95

Branch: refs/heads/ignite-8201
Commit: c807ae952c233cf1a8c0a63d543fafe19c40c6aa
Parents: 05d7092
Author: Andrey Kuznetsov 
Authored: Tue Apr 10 17:30:12 2018 +0300
Committer: Andrey Gura 
Committed: Tue Apr 10 17:30:12 2018 +0300

--
 .../org/apache/ignite/internal/IgnitionEx.java  |  15 +-
 .../GridClientConnectionManagerAdapter.java |   6 +
 .../impl/GridTcpRouterNioListenerAdapter.java   |   6 +
 .../discovery/GridDiscoveryManager.java |  16 +-
 .../GridCachePartitionExchangeManager.java  |  12 +-
 .../cache/GridCacheSharedTtlCleanupManager.java |  41 +++--
 .../GridCacheDatabaseSharedManager.java |  60 +--
 .../wal/FileWriteAheadLogManager.java   | 157 ---
 .../wal/FsyncModeFileWriteAheadLogManager.java  |  34 +++-
 .../timeout/GridTimeoutProcessor.java   | 102 +++-
 .../ignite/internal/util/StripedExecutor.java   |  69 +---
 .../ignite/internal/util/nio/GridNioServer.java |  43 -
 .../util/nio/GridNioServerListener.java |   6 +
 .../util/nio/GridNioServerListenerAdapter.java  |   6 +
 .../communication/tcp/TcpCommunicationSpi.java  |  41 -
 .../ignite/spi/discovery/tcp/ServerImpl.java|  51 +-
 .../internal/util/StripedExecutorTest.java  |   2 +-
 17 files changed, 501 insertions(+), 166 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/ignite/blob/c807ae95/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java 
b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
index 417ba1e..10a0752 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
@@ -137,6 +137,7 @@ import static 
org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
 import static 
org.apache.ignite.configuration.IgniteConfiguration.DFLT_THREAD_KEEP_ALIVE_TIME;
 import static 
org.apache.ignite.configuration.MemoryConfiguration.DFLT_MEMORY_POLICY_MAX_SIZE;
 import static 
org.apache.ignite.configuration.MemoryConfiguration.DFLT_MEM_PLC_DEFAULT_NAME;
+import static org.apache.ignite.failure.FailureType.SYSTEM_WORKER_TERMINATION;
 import static org.apache.ignite.internal.IgniteComponentType.SPRING;
 import static 
org.apache.ignite.plugin.segmentation.SegmentationPolicy.RESTART_JVM;
 
@@ -1806,7 +1807,13 @@ public class IgnitionEx {
 cfg.getStripedPoolSize(),
 cfg.getIgniteInstanceName(),
 "sys",
-log);
+log,
+new Thread.UncaughtExceptionHandler() {
+@Override public void uncaughtException(Thread thread, 
Throwable t) {
+if (grid != null)
+grid.context().failure().process(new 
FailureContext(SYSTEM_WORKER_TERMINATION, t));
+}
+});
 
 // Note that since we use 'LinkedBlockingQueue', number of
 // maximum threads has no effect.
@@ -1846,6 +1853,12 @@ public class IgnitionEx {
 cfg.getIgniteInstanceName(),
 "data-streamer",
 log,
+new Thread.UncaughtExceptionHandler() {
+@Override public void uncaughtException(Thread thread, 
Throwable t) {
+if (grid != null)
+grid.context().failure().process(new 
FailureContext(SYSTEM_WORKER_TERMINATION, t));
+}
+},
 true);
 
 // Note that we do not pre-start threads here as igfs pool may not 
be needed.

http://git-wip-us.apache.org/repos/asf/ignite/blob/c807ae95/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
index 829b188..fe0453f 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/client/

ignite git commit: ignite-7772 System workers critical failures handling

2018-04-10 Thread agura 
Repository: ignite
Updated Branches:
  refs/heads/ignite-2.5 b28287d18 -> a832f2b2e


ignite-7772 System workers critical failures handling

Signed-off-by: Andrey Gura 


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a832f2b2
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a832f2b2
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a832f2b2

Branch: refs/heads/ignite-2.5
Commit: a832f2b2e5788c45114c3cb5529d7cf53d08f9a6
Parents: b28287d
Author: Andrey Kuznetsov 
Authored: Tue Apr 10 17:30:12 2018 +0300
Committer: Andrey Gura 
Committed: Tue Apr 10 18:07:17 2018 +0300

--
 .../org/apache/ignite/internal/IgnitionEx.java  |  15 +-
 .../GridClientConnectionManagerAdapter.java |   6 +
 .../impl/GridTcpRouterNioListenerAdapter.java   |   6 +
 .../discovery/GridDiscoveryManager.java |  16 +-
 .../GridCachePartitionExchangeManager.java  |  12 +-
 .../cache/GridCacheSharedTtlCleanupManager.java |  41 +++--
 .../GridCacheDatabaseSharedManager.java |  60 +--
 .../wal/FileWriteAheadLogManager.java   | 157 ---
 .../wal/FsyncModeFileWriteAheadLogManager.java  |  34 +++-
 .../timeout/GridTimeoutProcessor.java   | 102 +++-
 .../ignite/internal/util/StripedExecutor.java   |  69 +---
 .../ignite/internal/util/nio/GridNioServer.java |  43 -
 .../util/nio/GridNioServerListener.java |   6 +
 .../util/nio/GridNioServerListenerAdapter.java  |   6 +
 .../communication/tcp/TcpCommunicationSpi.java  |  41 -
 .../ignite/spi/discovery/tcp/ServerImpl.java|  51 +-
 .../internal/util/StripedExecutorTest.java  |   2 +-
 17 files changed, 501 insertions(+), 166 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/ignite/blob/a832f2b2/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java 
b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
index 3abc711..c0de080 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
@@ -137,6 +137,7 @@ import static 
org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
 import static 
org.apache.ignite.configuration.IgniteConfiguration.DFLT_THREAD_KEEP_ALIVE_TIME;
 import static 
org.apache.ignite.configuration.MemoryConfiguration.DFLT_MEMORY_POLICY_MAX_SIZE;
 import static 
org.apache.ignite.configuration.MemoryConfiguration.DFLT_MEM_PLC_DEFAULT_NAME;
+import static org.apache.ignite.failure.FailureType.SYSTEM_WORKER_TERMINATION;
 import static org.apache.ignite.internal.IgniteComponentType.SPRING;
 import static 
org.apache.ignite.plugin.segmentation.SegmentationPolicy.RESTART_JVM;
 
@@ -1806,7 +1807,13 @@ public class IgnitionEx {
 cfg.getStripedPoolSize(),
 cfg.getIgniteInstanceName(),
 "sys",
-log);
+log,
+new Thread.UncaughtExceptionHandler() {
+@Override public void uncaughtException(Thread thread, 
Throwable t) {
+if (grid != null)
+grid.context().failure().process(new 
FailureContext(SYSTEM_WORKER_TERMINATION, t));
+}
+});
 
 // Note that since we use 'LinkedBlockingQueue', number of
 // maximum threads has no effect.
@@ -1846,6 +1853,12 @@ public class IgnitionEx {
 cfg.getIgniteInstanceName(),
 "data-streamer",
 log,
+new Thread.UncaughtExceptionHandler() {
+@Override public void uncaughtException(Thread thread, 
Throwable t) {
+if (grid != null)
+grid.context().failure().process(new 
FailureContext(SYSTEM_WORKER_TERMINATION, t));
+}
+},
 true);
 
 // Note that we do not pre-start threads here as igfs pool may not 
be needed.

http://git-wip-us.apache.org/repos/asf/ignite/blob/a832f2b2/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
index 829b188..fe0453f 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionMan

ignite git commit: ignite-7772 System workers critical failures handling

2018-04-10 Thread agura 
Repository: ignite
Updated Branches:
  refs/heads/master 05d7092e2 -> c807ae952


ignite-7772 System workers critical failures handling

Signed-off-by: Andrey Gura 


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c807ae95
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c807ae95
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c807ae95

Branch: refs/heads/master
Commit: c807ae952c233cf1a8c0a63d543fafe19c40c6aa
Parents: 05d7092
Author: Andrey Kuznetsov 
Authored: Tue Apr 10 17:30:12 2018 +0300
Committer: Andrey Gura 
Committed: Tue Apr 10 17:30:12 2018 +0300

--
 .../org/apache/ignite/internal/IgnitionEx.java  |  15 +-
 .../GridClientConnectionManagerAdapter.java |   6 +
 .../impl/GridTcpRouterNioListenerAdapter.java   |   6 +
 .../discovery/GridDiscoveryManager.java |  16 +-
 .../GridCachePartitionExchangeManager.java  |  12 +-
 .../cache/GridCacheSharedTtlCleanupManager.java |  41 +++--
 .../GridCacheDatabaseSharedManager.java |  60 +--
 .../wal/FileWriteAheadLogManager.java   | 157 ---
 .../wal/FsyncModeFileWriteAheadLogManager.java  |  34 +++-
 .../timeout/GridTimeoutProcessor.java   | 102 +++-
 .../ignite/internal/util/StripedExecutor.java   |  69 +---
 .../ignite/internal/util/nio/GridNioServer.java |  43 -
 .../util/nio/GridNioServerListener.java |   6 +
 .../util/nio/GridNioServerListenerAdapter.java  |   6 +
 .../communication/tcp/TcpCommunicationSpi.java  |  41 -
 .../ignite/spi/discovery/tcp/ServerImpl.java|  51 +-
 .../internal/util/StripedExecutorTest.java  |   2 +-
 17 files changed, 501 insertions(+), 166 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/ignite/blob/c807ae95/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java 
b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
index 417ba1e..10a0752 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java
@@ -137,6 +137,7 @@ import static 
org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC;
 import static 
org.apache.ignite.configuration.IgniteConfiguration.DFLT_THREAD_KEEP_ALIVE_TIME;
 import static 
org.apache.ignite.configuration.MemoryConfiguration.DFLT_MEMORY_POLICY_MAX_SIZE;
 import static 
org.apache.ignite.configuration.MemoryConfiguration.DFLT_MEM_PLC_DEFAULT_NAME;
+import static org.apache.ignite.failure.FailureType.SYSTEM_WORKER_TERMINATION;
 import static org.apache.ignite.internal.IgniteComponentType.SPRING;
 import static 
org.apache.ignite.plugin.segmentation.SegmentationPolicy.RESTART_JVM;
 
@@ -1806,7 +1807,13 @@ public class IgnitionEx {
 cfg.getStripedPoolSize(),
 cfg.getIgniteInstanceName(),
 "sys",
-log);
+log,
+new Thread.UncaughtExceptionHandler() {
+@Override public void uncaughtException(Thread thread, 
Throwable t) {
+if (grid != null)
+grid.context().failure().process(new 
FailureContext(SYSTEM_WORKER_TERMINATION, t));
+}
+});
 
 // Note that since we use 'LinkedBlockingQueue', number of
 // maximum threads has no effect.
@@ -1846,6 +1853,12 @@ public class IgnitionEx {
 cfg.getIgniteInstanceName(),
 "data-streamer",
 log,
+new Thread.UncaughtExceptionHandler() {
+@Override public void uncaughtException(Thread thread, 
Throwable t) {
+if (grid != null)
+grid.context().failure().process(new 
FailureContext(SYSTEM_WORKER_TERMINATION, t));
+}
+},
 true);
 
 // Note that we do not pre-start threads here as igfs pool may not 
be needed.

http://git-wip-us.apache.org/repos/asf/ignite/blob/c807ae95/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
--
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdapter.java
index 829b188..fe0453f 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/client/impl/connection/GridClientConnectionManagerAdap