Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 2074517485 for ; Tue, 1 Sep 2015 03:31:58 +0000 (UTC) Received: (qmail 89181 invoked by uid 500); 1 Sep 2015 03:31:58 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 89083 invoked by uid 500); 1 Sep 2015 03:31:58 -0000 Mailing-List: contact commits-help@ignite.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.apache.org Delivered-To: mailing list commits@ignite.apache.org Received: (qmail 88281 invoked by uid 99); 1 Sep 2015 03:31:56 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 01 Sep 2015 03:31:56 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id B1ED4DF989; Tue, 1 Sep 2015 03:31:56 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: akuznetsov@apache.org To: commits@ignite.apache.org Date: Tue, 01 Sep 2015 03:32:12 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [18/64] [abbrv] [partial] ignite git commit: master - imports http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableList.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableList.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableList.java index 91301be..78eece8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableList.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableList.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util; -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.AbstractList; /** * Makes {@link AbstractList} as {@link Serializable} and is @@ -30,4 +30,4 @@ public abstract class GridSerializableList extends AbstractList implements private static final long serialVersionUID = 0L; // No-op. -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableMap.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableMap.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableMap.java index e3a61f9..7c5c629 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableMap.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableMap.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util; -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.AbstractMap; /** * Makes {@link AbstractMap} as {@link Serializable} and is @@ -34,4 +34,4 @@ public abstract class GridSerializableMap extends AbstractMap implem private static final long serialVersionUID = 0L; // No-op. -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableSet.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableSet.java index dc5e35d..1fb7b38 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableSet.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSerializableSet.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.util; -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.AbstractCollection; +import java.util.AbstractSet; /** * Makes {@link AbstractSet} as {@link Serializable} and is @@ -34,4 +35,4 @@ public abstract class GridSerializableSet extends AbstractSet implements S private static final long serialVersionUID = 0L; // No-op. -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java index 80577f8..5104097 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java @@ -17,10 +17,12 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.util.*; +import java.util.Collection; +import java.util.Iterator; +import java.util.Map; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Set implementation that delegates to map. @@ -133,4 +135,4 @@ public class GridSetWrapper extends GridSerializableSet { @Override public String toString() { return S.toString(GridSetWrapper.class, this, "elements", map.keySet()); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSnapshotLock.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSnapshotLock.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSnapshotLock.java index e8acfc0..ad56f59 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSnapshotLock.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSnapshotLock.java @@ -17,9 +17,8 @@ package org.apache.ignite.internal.util; -import org.jetbrains.annotations.*; - -import java.util.concurrent.locks.*; +import java.util.concurrent.locks.AbstractQueuedSynchronizer; +import org.jetbrains.annotations.Nullable; /** * Synchronization primitive allowing concurrent updates and taking consistent snapshots. @@ -216,4 +215,4 @@ public abstract class GridSnapshotLock { return true; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpiCloseableIteratorWrapper.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpiCloseableIteratorWrapper.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpiCloseableIteratorWrapper.java index b2b2dac..5c76cbd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpiCloseableIteratorWrapper.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpiCloseableIteratorWrapper.java @@ -17,9 +17,9 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.spi.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.lang.GridCloseableIterator; +import org.apache.ignite.spi.IgniteSpiCloseableIterator; /** * Wrapper used to covert {@link org.apache.ignite.spi.IgniteSpiCloseableIterator} to {@link GridCloseableIterator}. @@ -54,4 +54,4 @@ public class GridSpiCloseableIteratorWrapper extends GridCloseableIteratorAda @Override protected void onClose() throws IgniteCheckedException { iter.close(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinBusyLock.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinBusyLock.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinBusyLock.java index 267d739..2aae6ef 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinBusyLock.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinBusyLock.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.internal.util.tostring.*; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; /** * Synchronization aid to track "busy" state of a subsystem that owns it. @@ -81,4 +81,4 @@ public class GridSpinBusyLock { public void unblock() { lock.writeUnlock(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinReadWriteLock.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinReadWriteLock.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinReadWriteLock.java index 4baa346..a1fa892 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinReadWriteLock.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSpinReadWriteLock.java @@ -17,11 +17,11 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import sun.misc.*; - -import java.util.concurrent.*; +import java.util.concurrent.TimeUnit; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import sun.misc.Unsafe; /** * @@ -410,4 +410,4 @@ public class GridSpinReadWriteLock { @Override public String toString() { return S.toString(GridSpinReadWriteLock.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java index 4b61ad7..bc979f5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilder.java @@ -17,7 +17,10 @@ package org.apache.ignite.internal.util; -import java.io.*; +import java.io.IOException; +import java.io.ObjectInputStream; +import java.io.ObjectOutputStream; +import java.io.Serializable; /** * Optimized string builder with better API. @@ -444,4 +447,4 @@ public class GridStringBuilder implements Serializable { public String toString() { return impl.toString(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilderFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilderFactory.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilderFactory.java index e3fe885..0f3403a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilderFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStringBuilderFactory.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.internal.util.typedef.internal.*; +import org.apache.ignite.internal.util.typedef.internal.SB; /** * Per-thread cache of {@link StringBuilder} instances. @@ -95,4 +95,4 @@ public final class GridStringBuilderFactory { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedLock.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedLock.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedLock.java index a007815..f7033aa 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedLock.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedLock.java @@ -17,10 +17,11 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import java.util.concurrent.locks.*; +import java.util.concurrent.locks.Lock; +import java.util.concurrent.locks.ReentrantLock; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.jetbrains.annotations.Nullable; /** * This is an utility class for 'splitting' locking of some @@ -140,4 +141,4 @@ public class GridStripedLock { @Override public String toString() { return S.toString(GridStripedLock.class, this, "concurrency", locks.length); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedReadWriteLock.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedReadWriteLock.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedReadWriteLock.java index c6cb628..77419a1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedReadWriteLock.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridStripedReadWriteLock.java @@ -17,11 +17,13 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import java.util.concurrent.locks.*; +import java.util.concurrent.locks.Lock; +import java.util.concurrent.locks.ReadWriteLock; +import java.util.concurrent.locks.ReentrantReadWriteLock; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.jetbrains.annotations.Nullable; /** * This is an utility class for 'splitting' locking of some @@ -97,4 +99,4 @@ public class GridStripedReadWriteLock { @Override public String toString() { return S.toString(GridStripedReadWriteLock.class, this, "concurrency", locks.length); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridSynchronizedMap.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSynchronizedMap.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSynchronizedMap.java index 345f7bc..e83aafd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSynchronizedMap.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSynchronizedMap.java @@ -17,10 +17,12 @@ package org.apache.ignite.internal.util; -import org.jsr166.*; - -import java.io.*; -import java.util.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.util.Map; +import org.jsr166.ConcurrentHashMap8; /** * Synchronized map for cache values that is safe to update in-place. Main reason for this map @@ -97,4 +99,4 @@ public class GridSynchronizedMap extends ConcurrentHashMap8 implemen assert mapSize == size : "Invalid map size after reading [size=" + size + ", mapSize=" + size + ']'; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimer.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimer.java index 05e52f1..5f1bd3a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimer.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimer.java @@ -17,10 +17,10 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.text.*; -import java.util.*; +import java.text.SimpleDateFormat; +import java.util.Date; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; /** * Timer to use mostly for debugging purposes. @@ -151,4 +151,4 @@ public class GridTimer { @Override public String toString() { return S.toString(GridTimer.class, this, "duration", duration()); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimerTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimerTask.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimerTask.java index 71eecb6..dd86b38 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimerTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridTimerTask.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util; -import java.util.*; +import java.util.TimerTask; /** * Utility extension for {@link TimerTask}. @@ -37,4 +37,4 @@ public abstract class GridTimerTask extends TimerTask { Thread.currentThread().interrupt(); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridUnsafe.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridUnsafe.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridUnsafe.java index d1eeb9c..2867b0a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridUnsafe.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridUnsafe.java @@ -17,10 +17,11 @@ package org.apache.ignite.internal.util; -import sun.misc.*; - -import java.lang.reflect.*; -import java.security.*; +import java.lang.reflect.Field; +import java.security.AccessController; +import java.security.PrivilegedActionException; +import java.security.PrivilegedExceptionAction; +import sun.misc.Unsafe; /** * Provides handle on Unsafe class from SUN which cannot be instantiated directly. @@ -58,4 +59,4 @@ public class GridUnsafe { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/GridWeakIterator.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridWeakIterator.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridWeakIterator.java index 17a7e83..e1d84d0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridWeakIterator.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridWeakIterator.java @@ -17,11 +17,11 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.lang.*; - -import java.lang.ref.*; -import java.util.*; +import java.lang.ref.ReferenceQueue; +import java.lang.ref.WeakReference; +import java.util.Iterator; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.lang.GridCloseableIterator; /** * Weak iterator. http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java index ab113d7..1c3a5b5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteExceptionRegistry.java @@ -17,16 +17,21 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; - -import static org.apache.ignite.IgniteSystemProperties.*; +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Date; +import java.util.Iterator; +import java.util.List; +import java.util.concurrent.ConcurrentLinkedDeque; +import java.util.concurrent.atomic.AtomicLong; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.IgniteSystemProperties; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; + +import static org.apache.ignite.IgniteSystemProperties.IGNITE_EXCEPTION_REGISTRY_MAX_SIZE; /** * Utility to collect suppressed errors within internal code. @@ -240,4 +245,4 @@ public class IgniteExceptionRegistry { return S.toString(ExceptionInfo.class, this); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/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 c9be652..ba918f6 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 @@ -17,68 +17,230 @@ package org.apache.ignite.internal.util; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.events.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.cluster.*; -import org.apache.ignite.internal.compute.*; -import org.apache.ignite.internal.events.*; -import org.apache.ignite.internal.managers.deployment.*; -import org.apache.ignite.internal.mxbean.*; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.processors.cache.version.*; -import org.apache.ignite.internal.transactions.*; -import org.apache.ignite.internal.util.future.*; -import org.apache.ignite.internal.util.io.*; -import org.apache.ignite.internal.util.ipc.shmem.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.internal.util.worker.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.lifecycle.*; -import org.apache.ignite.plugin.*; -import org.apache.ignite.plugin.extensions.communication.*; -import org.apache.ignite.spi.*; -import org.apache.ignite.spi.discovery.*; -import org.apache.ignite.transactions.*; -import org.jetbrains.annotations.*; -import org.jsr166.*; -import sun.misc.*; - -import javax.management.*; -import javax.naming.*; -import javax.net.ssl.*; -import java.io.*; +import java.io.BufferedInputStream; +import java.io.BufferedOutputStream; +import java.io.DataInput; +import java.io.DataOutput; +import java.io.Externalizable; +import java.io.File; +import java.io.FileInputStream; +import java.io.FileNotFoundException; +import java.io.FileOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.OutputStream; +import java.io.PrintStream; +import java.io.Reader; +import java.io.StringWriter; +import java.io.Writer; import java.lang.annotation.Annotation; -import java.lang.management.*; +import java.lang.management.CompilationMXBean; +import java.lang.management.LockInfo; +import java.lang.management.ManagementFactory; +import java.lang.management.MemoryMXBean; +import java.lang.management.MonitorInfo; +import java.lang.management.OperatingSystemMXBean; +import java.lang.management.RuntimeMXBean; +import java.lang.management.ThreadInfo; +import java.lang.management.ThreadMXBean; import java.lang.reflect.Array; -import java.lang.reflect.*; -import java.math.*; -import java.net.*; -import java.nio.*; -import java.nio.channels.*; -import java.nio.charset.*; -import java.security.*; -import java.security.cert.*; -import java.sql.*; -import java.text.*; -import java.util.*; +import java.lang.reflect.Constructor; +import java.lang.reflect.Field; +import java.lang.reflect.InvocationTargetException; +import java.lang.reflect.Method; +import java.lang.reflect.Modifier; +import java.math.BigDecimal; +import java.math.MathContext; +import java.net.DatagramSocket; +import java.net.InetAddress; +import java.net.InetSocketAddress; +import java.net.MalformedURLException; +import java.net.NetworkInterface; +import java.net.SocketException; +import java.net.URI; +import java.net.URISyntaxException; +import java.net.URL; +import java.net.URLClassLoader; +import java.net.URLConnection; +import java.net.UnknownHostException; +import java.nio.ByteBuffer; +import java.nio.channels.FileLock; +import java.nio.channels.SelectionKey; +import java.nio.channels.Selector; +import java.nio.charset.Charset; +import java.security.AccessController; +import java.security.KeyManagementException; +import java.security.MessageDigest; +import java.security.NoSuchAlgorithmException; +import java.security.PrivilegedAction; +import java.security.ProtectionDomain; +import java.security.cert.X509Certificate; +import java.sql.Connection; +import java.sql.SQLException; +import java.text.SimpleDateFormat; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Calendar; +import java.util.Collection; +import java.util.Collections; +import java.util.Comparator; import java.util.Date; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; -import java.util.concurrent.locks.*; -import java.util.jar.*; -import java.util.logging.*; -import java.util.regex.*; -import java.util.zip.*; - -import static org.apache.ignite.IgniteSystemProperties.*; -import static org.apache.ignite.events.EventType.*; -import static org.apache.ignite.internal.IgniteNodeAttributes.*; +import java.util.Enumeration; +import java.util.HashMap; +import java.util.HashSet; +import java.util.Iterator; +import java.util.LinkedHashMap; +import java.util.LinkedHashSet; +import java.util.LinkedList; +import java.util.List; +import java.util.Map; +import java.util.NoSuchElementException; +import java.util.ServiceLoader; +import java.util.Set; +import java.util.StringTokenizer; +import java.util.TimeZone; +import java.util.TreeMap; +import java.util.UUID; +import java.util.concurrent.BrokenBarrierException; +import java.util.concurrent.Callable; +import java.util.concurrent.CancellationException; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.CyclicBarrier; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.Future; +import java.util.concurrent.Semaphore; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.atomic.AtomicReference; +import java.util.concurrent.locks.Condition; +import java.util.jar.JarFile; +import java.util.logging.ConsoleHandler; +import java.util.logging.Handler; +import java.util.logging.Level; +import java.util.logging.Logger; +import java.util.regex.Pattern; +import java.util.zip.ZipEntry; +import java.util.zip.ZipFile; +import javax.management.DynamicMBean; +import javax.management.JMException; +import javax.management.MBeanServer; +import javax.management.MalformedObjectNameException; +import javax.management.ObjectName; +import javax.naming.Context; +import javax.naming.NamingException; +import javax.net.ssl.HostnameVerifier; +import javax.net.ssl.HttpsURLConnection; +import javax.net.ssl.SSLContext; +import javax.net.ssl.SSLSession; +import javax.net.ssl.TrustManager; +import javax.net.ssl.X509TrustManager; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteClientDisconnectedException; +import org.apache.ignite.IgniteDeploymentException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteInterruptedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.IgniteSystemProperties; +import org.apache.ignite.cluster.ClusterGroupEmptyException; +import org.apache.ignite.cluster.ClusterMetrics; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.cluster.ClusterTopologyException; +import org.apache.ignite.compute.ComputeTask; +import org.apache.ignite.compute.ComputeTaskCancelledException; +import org.apache.ignite.compute.ComputeTaskName; +import org.apache.ignite.compute.ComputeTaskTimeoutException; +import org.apache.ignite.configuration.AddressResolver; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.events.EventType; +import org.apache.ignite.internal.GridKernalContext; +import org.apache.ignite.internal.IgniteClientDisconnectedCheckedException; +import org.apache.ignite.internal.IgniteDeploymentCheckedException; +import org.apache.ignite.internal.IgniteFutureCancelledCheckedException; +import org.apache.ignite.internal.IgniteFutureTimeoutCheckedException; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.IgniteInterruptedCheckedException; +import org.apache.ignite.internal.IgniteNodeAttributes; +import org.apache.ignite.internal.cluster.ClusterGroupEmptyCheckedException; +import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException; +import org.apache.ignite.internal.compute.ComputeTaskCancelledCheckedException; +import org.apache.ignite.internal.compute.ComputeTaskTimeoutCheckedException; +import org.apache.ignite.internal.events.DiscoveryCustomEvent; +import org.apache.ignite.internal.managers.deployment.GridDeploymentInfo; +import org.apache.ignite.internal.mxbean.IgniteStandardMXBean; +import org.apache.ignite.internal.processors.cache.GridCacheAttributes; +import org.apache.ignite.internal.processors.cache.version.GridCacheVersion; +import org.apache.ignite.internal.processors.cache.version.GridCacheVersionEx; +import org.apache.ignite.internal.transactions.IgniteTxHeuristicCheckedException; +import org.apache.ignite.internal.transactions.IgniteTxOptimisticCheckedException; +import org.apache.ignite.internal.transactions.IgniteTxRollbackCheckedException; +import org.apache.ignite.internal.transactions.IgniteTxTimeoutCheckedException; +import org.apache.ignite.internal.util.future.IgniteFutureImpl; +import org.apache.ignite.internal.util.io.GridFilenameUtils; +import org.apache.ignite.internal.util.ipc.shmem.IpcSharedMemoryNativeLoader; +import org.apache.ignite.internal.util.lang.GridClosureException; +import org.apache.ignite.internal.util.lang.GridPeerDeployAware; +import org.apache.ignite.internal.util.lang.GridTuple; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.CI1; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.G; +import org.apache.ignite.internal.util.typedef.P1; +import org.apache.ignite.internal.util.typedef.X; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.SB; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.internal.util.worker.GridWorker; +import org.apache.ignite.lang.IgniteBiTuple; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteFutureCancelledException; +import org.apache.ignite.lang.IgniteFutureTimeoutException; +import org.apache.ignite.lang.IgniteOutClosure; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.lang.IgniteProductVersion; +import org.apache.ignite.lang.IgniteUuid; +import org.apache.ignite.lifecycle.LifecycleAware; +import org.apache.ignite.plugin.PluginProvider; +import org.apache.ignite.plugin.extensions.communication.Message; +import org.apache.ignite.plugin.extensions.communication.MessageWriter; +import org.apache.ignite.spi.IgniteSpi; +import org.apache.ignite.spi.IgniteSpiException; +import org.apache.ignite.spi.discovery.DiscoverySpi; +import org.apache.ignite.spi.discovery.DiscoverySpiOrderSupport; +import org.apache.ignite.transactions.TransactionHeuristicException; +import org.apache.ignite.transactions.TransactionOptimisticException; +import org.apache.ignite.transactions.TransactionRollbackException; +import org.apache.ignite.transactions.TransactionTimeoutException; +import org.jetbrains.annotations.NotNull; +import org.jetbrains.annotations.Nullable; +import org.jsr166.ConcurrentHashMap8; +import sun.misc.SharedSecrets; +import sun.misc.URLClassPath; +import sun.misc.Unsafe; + +import static org.apache.ignite.IgniteSystemProperties.IGNITE_DISABLE_HOSTNAME_VERIFIER; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_HOME; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_LOCAL_HOST; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_MBEAN_APPEND_CLASS_LOADER_ID; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_MBEAN_APPEND_JVM_ID; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_NO_DISCO_ORDER; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_SSH_HOST; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_SSH_USER_NAME; +import static org.apache.ignite.IgniteSystemProperties.getBoolean; +import static org.apache.ignite.events.EventType.EVTS_ALL; +import static org.apache.ignite.events.EventType.EVTS_ALL_MINUS_METRIC_UPDATE; +import static org.apache.ignite.events.EventType.EVT_NODE_METRICS_UPDATED; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_BUILD_DATE; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_BUILD_VER; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_CACHE; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_JVM_PID; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_MACS; /** * Collection of utility methods used throughout the system. @@ -9124,4 +9286,4 @@ public abstract class IgniteUtils { return hasShmem; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUuidCache.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUuidCache.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUuidCache.java index 045589c..4ca00d9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUuidCache.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUuidCache.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util; -import java.util.*; -import java.util.concurrent.*; +import java.util.UUID; +import java.util.concurrent.ConcurrentMap; /** * @@ -56,4 +56,4 @@ public final class IgniteUuidCache { private IgniteUuidCache() { // No-op. } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java index d56ed7c..0a6d9aa 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java @@ -17,19 +17,25 @@ package org.apache.ignite.internal.util.future; -import org.apache.ignite.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.cluster.*; -import org.apache.ignite.internal.transactions.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; -import org.jsr166.*; - -import java.util.*; -import java.util.concurrent.atomic.*; +import java.util.Collection; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicMarkableReference; +import java.util.concurrent.atomic.AtomicReference; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.IgniteFutureCancelledCheckedException; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.cluster.ClusterTopologyCheckedException; +import org.apache.ignite.internal.transactions.IgniteTxOptimisticCheckedException; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.lang.IgniteReducer; +import org.jetbrains.annotations.Nullable; +import org.jsr166.ConcurrentLinkedDeque8; /** * Future composed of multiple inner futures. @@ -357,4 +363,4 @@ public class GridCompoundFuture extends GridFutureAdapter { return "Compound future listener: " + GridCompoundFuture.this; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundIdentityFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundIdentityFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundIdentityFuture.java index cf14948..bb5abf2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundIdentityFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundIdentityFuture.java @@ -17,10 +17,10 @@ package org.apache.ignite.internal.util.future; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.internal.GridKernalContext; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.lang.IgniteReducer; +import org.jetbrains.annotations.Nullable; /** * Future composed of multiple inner futures. @@ -48,4 +48,4 @@ public class GridCompoundIdentityFuture extends GridCompoundFuture { @Override public String toString() { return S.toString(GridCompoundIdentityFuture.class, this, super.toString()); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridEmbeddedFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridEmbeddedFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridEmbeddedFuture.java index 11b28b5..4a802cb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridEmbeddedFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridEmbeddedFuture.java @@ -17,11 +17,15 @@ package org.apache.ignite.internal.util.future; -import org.apache.ignite.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteIllegalStateException; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.util.lang.GridClosureException; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteBiClosure; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.lang.IgniteOutClosure; /** * Future which waits for embedded future to complete and then asynchronously executes @@ -343,4 +347,4 @@ public class GridEmbeddedFuture extends GridFutureAdapter { */ protected abstract void applyx(IgniteInternalFuture f) throws Exception; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java index 2adee90..6baedbd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java @@ -17,13 +17,14 @@ package org.apache.ignite.internal.util.future; -import org.apache.ignite.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; - -import java.util.concurrent.*; +import java.util.concurrent.TimeUnit; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.util.lang.GridClosureException; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteInClosure; /** * Future that is completed at creation time. @@ -154,4 +155,4 @@ public class GridFinishedFuture implements IgniteInternalFuture { @Override public String toString() { return S.toString(GridFinishedFuture.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java index 91ce549..0f65d33 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java @@ -17,16 +17,21 @@ package org.apache.ignite.internal.util.future; -import org.apache.ignite.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.locks.*; +import java.util.Arrays; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.locks.AbstractQueuedSynchronizer; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.IgniteFutureCancelledCheckedException; +import org.apache.ignite.internal.IgniteFutureTimeoutCheckedException; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.IgniteInterruptedCheckedException; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteInClosure; +import org.jetbrains.annotations.Nullable; /** * Future adapter. @@ -489,4 +494,4 @@ public class GridFutureAdapter extends AbstractQueuedSynchronizer implements return "ChainFuture [orig=" + fut + ", doneCb=" + doneCb + ']'; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureChainListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureChainListener.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureChainListener.java index 43ffa61..947b2ad 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureChainListener.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureChainListener.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.util.future; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.util.lang.GridClosureException; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteInClosure; /** * Future listener to fill chained future with converted result of the source future. @@ -61,4 +62,4 @@ public class GridFutureChainListener implements IgniteInClosure extends IgniteFutureImpl { @Override public String toString() { return S.toString(IgniteFinishedFutureImpl.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java index 13d564d..7d74154 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java @@ -17,14 +17,17 @@ package org.apache.ignite.internal.util.future; -import org.apache.ignite.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; - -import java.util.concurrent.*; +import java.util.concurrent.TimeUnit; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.util.lang.GridClosureException; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgniteInClosure; /** * Implementation of public API future. @@ -202,4 +205,4 @@ public class IgniteFutureImpl implements IgniteFuture { return lsnr.toString(); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyArgumentBuilder.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyArgumentBuilder.java b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyArgumentBuilder.java index 1a0edb2..2c44746 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyArgumentBuilder.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyArgumentBuilder.java @@ -17,12 +17,18 @@ package org.apache.ignite.internal.util.gridify; -import org.apache.ignite.*; -import org.apache.ignite.compute.gridify.*; -import org.apache.ignite.compute.gridify.aop.*; - -import java.lang.annotation.*; -import java.util.*; +import java.lang.annotation.Annotation; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collection; +import java.util.List; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.compute.gridify.GridifyArgument; +import org.apache.ignite.compute.gridify.GridifyInput; +import org.apache.ignite.compute.gridify.GridifySetToSet; +import org.apache.ignite.compute.gridify.GridifySetToValue; +import org.apache.ignite.compute.gridify.aop.GridifyArgumentAdapter; /** * Argument builder used for creating arguments for tasks and jobs in gridified methods. @@ -183,4 +189,4 @@ public final class GridifyArgumentBuilder { return res; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyJobAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyJobAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyJobAdapter.java index 93b9eae..32824b4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyJobAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyJobAdapter.java @@ -17,11 +17,12 @@ package org.apache.ignite.internal.util.gridify; -import org.apache.ignite.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.compute.gridify.*; - -import java.lang.reflect.*; +import java.lang.reflect.InvocationTargetException; +import java.lang.reflect.Method; +import java.lang.reflect.Modifier; +import org.apache.ignite.IgniteException; +import org.apache.ignite.compute.ComputeJobAdapter; +import org.apache.ignite.compute.gridify.GridifyArgument; /** * Convenience adapter for custom {@code gridify} jobs. In addition to @@ -103,4 +104,4 @@ public class GridifyJobAdapter extends ComputeJobAdapter { throw new IgniteException("Failed to find method for execution.", e); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyRangeArgument.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyRangeArgument.java b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyRangeArgument.java index c01536c..66c8ed7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyRangeArgument.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyRangeArgument.java @@ -17,10 +17,9 @@ package org.apache.ignite.internal.util.gridify; -import org.apache.ignite.compute.gridify.aop.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.util.*; +import java.util.Iterator; +import org.apache.ignite.compute.gridify.aop.GridifyArgumentAdapter; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Convenience adapter for {@link org.apache.ignite.compute.gridify.GridifyArgument} interface. @@ -101,4 +100,4 @@ public class GridifyRangeArgument extends GridifyArgumentAdapter { @Override public String toString() { return S.toString(GridifyRangeArgument.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java index bc1b68e..b0640c2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/gridify/GridifyUtils.java @@ -17,14 +17,31 @@ package org.apache.ignite.internal.util.gridify; -import org.apache.ignite.compute.gridify.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.lang.annotation.*; -import java.lang.reflect.*; -import java.util.*; +import java.io.IOException; +import java.io.ObjectInputStream; +import java.io.ObjectOutputStream; +import java.io.Serializable; +import java.lang.annotation.Annotation; +import java.lang.reflect.Array; +import java.lang.reflect.Constructor; +import java.lang.reflect.InvocationTargetException; +import java.lang.reflect.Modifier; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.Enumeration; +import java.util.HashSet; +import java.util.Iterator; +import java.util.LinkedList; +import java.util.List; +import java.util.NoSuchElementException; +import java.util.Queue; +import java.util.Set; +import org.apache.ignite.compute.gridify.GridifyInput; +import org.apache.ignite.compute.gridify.GridifySetToSet; +import org.apache.ignite.compute.gridify.GridifySetToValue; +import org.apache.ignite.internal.util.typedef.internal.SB; +import org.jetbrains.annotations.Nullable; /** * Utility class with common methods used in gridify annotations. @@ -519,4 +536,4 @@ public final class GridifyUtils { out.defaultWriteObject(); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayInputStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayInputStream.java b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayInputStream.java index 9085a3e..2626bf2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayInputStream.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayInputStream.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.util.io; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; +import java.io.ByteArrayInputStream; +import java.io.InputStream; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; /** * This class defines input stream backed by byte array. @@ -206,4 +207,4 @@ public class GridByteArrayInputStream extends InputStream { @Override public String toString() { return S.toString(GridByteArrayInputStream.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayOutputStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayOutputStream.java b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayOutputStream.java index 52d81e1..c0c11ba 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayOutputStream.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridByteArrayOutputStream.java @@ -17,10 +17,13 @@ package org.apache.ignite.internal.util.io; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; -import java.util.*; +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.IOException; +import java.io.OutputStream; +import java.util.Arrays; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; /** * This class defines output stream backed by byte array. @@ -164,4 +167,4 @@ public class GridByteArrayOutputStream extends OutputStream { @Override public String toString() { return S.toString(GridByteArrayOutputStream.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataInput.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataInput.java b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataInput.java index a0c556e..83514ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataInput.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataInput.java @@ -17,7 +17,9 @@ package org.apache.ignite.internal.util.io; -import java.io.*; +import java.io.DataInput; +import java.io.IOException; +import java.io.InputStream; /** * Extended data input. @@ -129,4 +131,4 @@ public interface GridDataInput extends DataInput { * @throws IOException In case of error. */ public char[] readCharArray() throws IOException; -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataOutput.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataOutput.java b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataOutput.java index 579c61b..01772b7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataOutput.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridDataOutput.java @@ -17,7 +17,9 @@ package org.apache.ignite.internal.util.io; -import java.io.*; +import java.io.DataOutput; +import java.io.IOException; +import java.io.OutputStream; /** * Extended data output. @@ -116,4 +118,4 @@ public interface GridDataOutput extends DataOutput { * @throws IOException In case of error. */ public void writeCharArray(char[] arr) throws IOException; -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridFilenameUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridFilenameUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridFilenameUtils.java index d2d5b2a..7f4bcb6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridFilenameUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridFilenameUtils.java @@ -17,8 +17,12 @@ package org.apache.ignite.internal.util.io; -import java.io.*; -import java.util.*; +import java.io.File; +import java.io.IOException; +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Stack; /** * General filename and filepath manipulation utilities. @@ -1556,4 +1560,4 @@ public class GridFilenameUtils { } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridReversedLinesFileReader.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridReversedLinesFileReader.java b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridReversedLinesFileReader.java index 44fab00..0473b5a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridReversedLinesFileReader.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridReversedLinesFileReader.java @@ -17,8 +17,14 @@ package org.apache.ignite.internal.util.io; -import java.io.*; -import java.nio.charset.*; +import java.io.Closeable; +import java.io.File; +import java.io.IOException; +import java.io.RandomAccessFile; +import java.io.UnsupportedEncodingException; +import java.nio.charset.Charset; +import java.nio.charset.CharsetEncoder; +import java.nio.charset.UnsupportedCharsetException; /** * Reads lines in a file reversely (similar to a BufferedReader, but starting at @@ -330,4 +336,4 @@ public class GridReversedLinesFileReader implements Closeable { return 0; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataInput.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataInput.java b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataInput.java index fb498d6..00fa2c3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataInput.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataInput.java @@ -17,14 +17,18 @@ package org.apache.ignite.internal.util.io; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import sun.misc.*; - -import java.io.*; - -import static org.apache.ignite.IgniteSystemProperties.*; +import java.io.EOFException; +import java.io.IOException; +import java.io.InputStream; +import java.io.UTFDataFormatException; +import org.apache.ignite.internal.util.GridUnsafe; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.SB; +import org.apache.ignite.internal.util.typedef.internal.U; +import sun.misc.Unsafe; + +import static org.apache.ignite.IgniteSystemProperties.IGNITE_MARSHAL_BUFFERS_RECHECK; /** * Data input based on {@code Unsafe} operations. @@ -600,4 +604,4 @@ public class GridUnsafeDataInput extends InputStream implements GridDataInput { @Override public String toString() { return S.toString(GridUnsafeDataInput.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutput.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutput.java b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutput.java index e299f9e..b7c82a6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutput.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/io/GridUnsafeDataOutput.java @@ -17,13 +17,14 @@ package org.apache.ignite.internal.util.io; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import sun.misc.*; +import java.io.IOException; +import java.io.OutputStream; +import org.apache.ignite.internal.util.GridUnsafe; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import sun.misc.Unsafe; -import java.io.*; - -import static org.apache.ignite.IgniteSystemProperties.*; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_MARSHAL_BUFFERS_RECHECK; /** * Data output based on {@code Unsafe} operations. @@ -497,4 +498,4 @@ public class GridUnsafeDataOutput extends OutputStream implements GridDataOutput @Override public String toString() { return S.toString(GridUnsafeDataOutput.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpoint.java index 94696a0..7fc237e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpoint.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.util.ipc; -import org.apache.ignite.*; - -import java.io.*; +import java.io.Closeable; +import java.io.InputStream; +import java.io.OutputStream; +import org.apache.ignite.IgniteCheckedException; /** * IGFS IPC endpoint used for point-to-point communication. @@ -46,4 +47,4 @@ public interface IpcEndpoint extends Closeable { * once it is not needed. */ @Override public void close(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointBindException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointBindException.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointBindException.java index ab1e3cf..59970f1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointBindException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointBindException.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.ipc; -import org.apache.ignite.*; +import org.apache.ignite.IgniteCheckedException; /** * Represents exception occurred during IPC endpoint binding. @@ -44,4 +44,4 @@ public class IpcEndpointBindException extends IgniteCheckedException { public IpcEndpointBindException(String msg, Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointFactory.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointFactory.java index 06710fb..78f81cd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointFactory.java @@ -17,10 +17,13 @@ package org.apache.ignite.internal.util.ipc; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.ipc.loopback.*; -import org.apache.ignite.internal.util.ipc.shmem.*; -import org.apache.ignite.internal.util.typedef.internal.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.ipc.loopback.IpcClientTcpEndpoint; +import org.apache.ignite.internal.util.ipc.loopback.IpcServerTcpEndpoint; +import org.apache.ignite.internal.util.ipc.shmem.IpcSharedMemoryClientEndpoint; +import org.apache.ignite.internal.util.ipc.shmem.IpcSharedMemoryServerEndpoint; +import org.apache.ignite.internal.util.typedef.internal.A; /** * Igfs endpoint factory for inter-process communication. @@ -81,4 +84,4 @@ public class IpcEndpointFactory { private static IpcEndpoint connectSharedMemoryEndpoint(int port, IgniteLogger log) throws IgniteCheckedException { return new IpcSharedMemoryClientEndpoint(port, log); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointType.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointType.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointType.java index 6636d94..62acdd3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointType.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcEndpointType.java @@ -26,4 +26,4 @@ public enum IpcEndpointType { /** Shared memory region. Supported on POSIX-compliant OSes. */ SHARED_MEMORY -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcServerEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcServerEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcServerEndpoint.java index ec13308..b0fe796 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcServerEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcServerEndpoint.java @@ -17,10 +17,9 @@ package org.apache.ignite.internal.util.ipc; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; - -import java.io.*; +import java.io.Closeable; +import org.apache.ignite.IgniteCheckedException; +import org.jetbrains.annotations.Nullable; /** * IPC server endpoint that is capable for client connections accepting. @@ -70,4 +69,4 @@ public interface IpcServerEndpoint extends Closeable { * @return {@code true} if it's a management endpoint. */ public boolean isManagement(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcToNioAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcToNioAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcToNioAdapter.java index 0a5d4fa..e732a79 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcToNioAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/IpcToNioAdapter.java @@ -17,15 +17,26 @@ package org.apache.ignite.internal.util.ipc; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.nio.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.plugin.extensions.communication.*; - -import java.io.*; -import java.nio.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; +import java.io.IOException; +import java.io.InputStream; +import java.nio.ByteBuffer; +import java.nio.ByteOrder; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.atomic.AtomicReference; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.nio.GridNioFilter; +import org.apache.ignite.internal.util.nio.GridNioFilterAdapter; +import org.apache.ignite.internal.util.nio.GridNioFilterChain; +import org.apache.ignite.internal.util.nio.GridNioFinishedFuture; +import org.apache.ignite.internal.util.nio.GridNioFuture; +import org.apache.ignite.internal.util.nio.GridNioMetricsListener; +import org.apache.ignite.internal.util.nio.GridNioServerListener; +import org.apache.ignite.internal.util.nio.GridNioSession; +import org.apache.ignite.internal.util.nio.GridNioSessionImpl; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.plugin.extensions.communication.Message; +import org.apache.ignite.plugin.extensions.communication.MessageFormatter; /** * Allows to re-use existing {@link GridNioFilter}s on IPC (specifically shared memory IPC) @@ -244,4 +255,4 @@ public class IpcToNioAdapter { proceedSessionWriteTimeout(ses); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcClientTcpEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcClientTcpEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcClientTcpEndpoint.java index ab787b6..7f3cd46 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcClientTcpEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcClientTcpEndpoint.java @@ -17,12 +17,14 @@ package org.apache.ignite.internal.util.ipc.loopback; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.ipc.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; -import java.net.*; +import java.io.IOException; +import java.io.InputStream; +import java.io.OutputStream; +import java.net.InetSocketAddress; +import java.net.Socket; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.ipc.IpcEndpoint; +import org.apache.ignite.internal.util.typedef.internal.U; /** * Loopback IPC endpoint based on socket. @@ -84,4 +86,4 @@ public class IpcClientTcpEndpoint implements IpcEndpoint { @Override public void close() { U.closeQuiet(clientSock); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcServerTcpEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcServerTcpEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcServerTcpEndpoint.java index 7a4cc69..81bdd1b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcServerTcpEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/loopback/IpcServerTcpEndpoint.java @@ -17,14 +17,19 @@ package org.apache.ignite.internal.util.ipc.loopback; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.ipc.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.resources.*; - -import java.io.*; -import java.net.*; -import java.util.*; +import java.io.IOException; +import java.net.InetSocketAddress; +import java.net.ServerSocket; +import java.net.Socket; +import java.util.Map; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.ipc.IpcEndpoint; +import org.apache.ignite.internal.util.ipc.IpcEndpointBindException; +import org.apache.ignite.internal.util.ipc.IpcServerEndpoint; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.resources.LoggerResource; /** * Server loopback IPC endpoint. @@ -176,4 +181,4 @@ public class IpcServerTcpEndpoint implements IpcServerEndpoint { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcOutOfSystemResourcesException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcOutOfSystemResourcesException.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcOutOfSystemResourcesException.java index 10aea80..7bef711 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcOutOfSystemResourcesException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcOutOfSystemResourcesException.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteCheckedException; +import org.jetbrains.annotations.Nullable; /** * Thrown when IPC runs out of system resources (for example, no more free shared memory is @@ -56,4 +56,4 @@ public class IpcOutOfSystemResourcesException extends IgniteCheckedException { public IpcOutOfSystemResourcesException(String msg, @Nullable Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java index a4f7804..9d1fc6d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java @@ -17,12 +17,19 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.ipc.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; -import java.net.*; +import java.io.File; +import java.io.IOException; +import java.io.InputStream; +import java.io.ObjectInputStream; +import java.io.ObjectOutputStream; +import java.io.OutputStream; +import java.net.InetSocketAddress; +import java.net.Socket; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.ipc.IpcEndpoint; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; /** * IPC endpoint based on shared memory space. @@ -334,4 +341,4 @@ public class IpcSharedMemoryClientEndpoint implements IpcEndpoint { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitRequest.java index c187dbc..19f0b35 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitRequest.java @@ -17,7 +17,10 @@ package org.apache.ignite.internal.util.ipc.shmem; -import java.io.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; /** * @@ -64,4 +67,4 @@ public class IpcSharedMemoryInitRequest implements Externalizable { @Override public String toString() { return "IpcSharedMemoryInitRequest [pid=" + pid + ']'; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitResponse.java index 9f2ed24..0d0a749 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInitResponse.java @@ -17,10 +17,12 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import java.io.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.jetbrains.annotations.Nullable; /** * @@ -168,4 +170,4 @@ public class IpcSharedMemoryInitResponse implements Externalizable { ", pid=" + pid + ", size=" + size + ']'; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInputStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInputStream.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInputStream.java index 0909da0..883e9a5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInputStream.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryInputStream.java @@ -17,10 +17,10 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; +import java.io.IOException; +import java.io.InputStream; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.internal.S; /** * @@ -96,4 +96,4 @@ public class IpcSharedMemoryInputStream extends InputStream { @Override public String toString() { return S.toString(IpcSharedMemoryInputStream.class, this); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryNativeLoader.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryNativeLoader.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryNativeLoader.java index d4ae147..2771d28 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryNativeLoader.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryNativeLoader.java @@ -17,19 +17,26 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; -import java.net.*; -import java.nio.channels.*; -import java.security.*; -import java.util.*; -import java.util.jar.*; -import java.util.zip.*; - -import static org.apache.ignite.internal.IgniteVersionUtils.*; +import java.io.File; +import java.io.FileInputStream; +import java.io.FileOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.RandomAccessFile; +import java.net.URL; +import java.nio.channels.FileLock; +import java.security.NoSuchAlgorithmException; +import java.util.ArrayList; +import java.util.Collection; +import java.util.jar.JarFile; +import java.util.zip.ZipEntry; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +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.U; + +import static org.apache.ignite.internal.IgniteVersionUtils.VER_STR; /** * Shared memory native loader. @@ -406,4 +413,4 @@ public class IpcSharedMemoryNativeLoader { srcIS.close(); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOperationTimedoutException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOperationTimedoutException.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOperationTimedoutException.java index f0c3f53..2b9d506 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOperationTimedoutException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOperationTimedoutException.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteCheckedException; +import org.jetbrains.annotations.Nullable; /** * Thrown when IPC operation (such as {@link IpcSharedMemorySpace#wait(long)}) @@ -56,4 +56,4 @@ public class IpcSharedMemoryOperationTimedoutException extends IgniteCheckedExce public IpcSharedMemoryOperationTimedoutException(String msg, @Nullable Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOutputStream.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOutputStream.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOutputStream.java index eb85fc1..8812126 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOutputStream.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryOutputStream.java @@ -17,10 +17,10 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; +import java.io.IOException; +import java.io.OutputStream; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.internal.S; /** * @@ -77,4 +77,4 @@ public class IpcSharedMemoryOutputStream extends OutputStream { @Override public String toString() { return S.toString(IpcSharedMemoryOutputStream.class, this); } -} +} \ No newline at end of file