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 EFFA6175A8 for ; Mon, 31 Aug 2015 14:44:11 +0000 (UTC) Received: (qmail 96448 invoked by uid 500); 31 Aug 2015 14:44:11 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 96356 invoked by uid 500); 31 Aug 2015 14:44:11 -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 95595 invoked by uid 99); 31 Aug 2015 14:44:11 -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; Mon, 31 Aug 2015 14:44:11 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 122D7E03E6; Mon, 31 Aug 2015 14:44:11 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sergi@apache.org To: commits@ignite.apache.org Date: Mon, 31 Aug 2015 14:44:26 -0000 Message-Id: In-Reply-To: <3f3e2a85e9984561a3bace3ca2c2f278@git.apache.org> References: <3f3e2a85e9984561a3bace3ca2c2f278@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [17/55] [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/ipc/shmem/IpcSharedMemoryServerEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java index 8c3f29e..e7b420e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryServerEndpoint.java @@ -17,25 +17,43 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.processors.resource.*; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.internal.util.ipc.*; -import org.apache.ignite.internal.util.lang.*; -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.internal.util.worker.*; -import org.apache.ignite.resources.*; -import org.apache.ignite.thread.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.net.*; -import java.nio.channels.*; -import java.util.*; -import java.util.concurrent.atomic.*; +import java.io.File; +import java.io.IOException; +import java.io.InputStream; +import java.io.ObjectInputStream; +import java.io.ObjectOutput; +import java.io.ObjectOutputStream; +import java.io.RandomAccessFile; +import java.net.InetSocketAddress; +import java.net.ServerSocket; +import java.net.Socket; +import java.nio.channels.FileLock; +import java.nio.channels.FileLockInterruptionException; +import java.nio.channels.OverlappingFileLockException; +import java.util.Collection; +import java.util.Map; +import java.util.UUID; +import java.util.concurrent.atomic.AtomicLong; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.IgniteInterruptedCheckedException; +import org.apache.ignite.internal.processors.resource.GridResourceProcessor; +import org.apache.ignite.internal.util.GridConcurrentHashSet; +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.lang.IgnitePair; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.LT; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.internal.util.worker.GridWorker; +import org.apache.ignite.resources.IgniteInstanceResource; +import org.apache.ignite.resources.LoggerResource; +import org.apache.ignite.thread.IgniteThread; +import org.jetbrains.annotations.Nullable; /** * Server shared memory IPC endpoint. @@ -739,4 +757,4 @@ public class IpcSharedMemoryServerEndpoint 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/IpcSharedMemorySpace.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java index 249d995..bdf73cd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemorySpace.java @@ -17,15 +17,16 @@ package org.apache.ignite.internal.util.ipc.shmem; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; +import java.io.Closeable; +import java.nio.ByteBuffer; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.concurrent.locks.ReadWriteLock; +import java.util.concurrent.locks.ReentrantReadWriteLock; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.typedef.internal.S; -import java.io.*; -import java.nio.*; -import java.util.concurrent.atomic.*; -import java.util.concurrent.locks.*; - -import static org.apache.ignite.IgniteSystemProperties.*; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_IPC_SHMEM_SPACE_DEBUG; /** * @@ -371,4 +372,4 @@ public class IpcSharedMemorySpace implements Closeable { @Override public String toString() { return S.toString(IpcSharedMemorySpace.class, this, "closed", closed.get()); } -} +} \ 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/IpcSharedMemoryUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryUtils.java index 71bcac4..be7f42b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryUtils.java @@ -17,13 +17,15 @@ 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.lang.management.*; -import java.nio.*; -import java.util.*; +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStreamReader; +import java.lang.management.ManagementFactory; +import java.nio.ByteBuffer; +import java.util.ArrayList; +import java.util.Collection; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.internal.U; /** * NOTE: Native library should be loaded, before methods of this class are called. @@ -239,4 +241,4 @@ public class IpcSharedMemoryUtils { else throw new IllegalStateException("This OS is not supported."); } -} +} \ 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/lang/GridAbsClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsClosure.java index 7cc6ee5..7ba4271 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsClosure.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.lang.*; +import org.apache.ignite.lang.IgniteRunnable; /** * Defines a convenient absolute, i.e. {@code no-arg} and {@code no return value} closure. This closure @@ -49,4 +49,4 @@ public abstract class GridAbsClosure implements IgniteRunnable { @Override public final void run() { apply(); } -} +} \ 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/lang/GridAbsClosureX.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsClosureX.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsClosureX.java index 6a794cf..8e14609 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsClosureX.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsClosureX.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.F; /** * Convenient abs-closure subclass that allows for thrown grid exception. This class @@ -45,4 +45,4 @@ public abstract class GridAbsClosureX extends GridAbsClosure { * @throws IgniteCheckedException Thrown in case of any error condition inside of the closure. */ public abstract void applyx() throws IgniteCheckedException; -} +} \ 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/lang/GridAbsPredicate.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsPredicate.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsPredicate.java index 04ba747..bec9951 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsPredicate.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsPredicate.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.internal.util.typedef.P1; /** * Defines absolute (no-arg) predicate construct. Predicate like closure is a first-class function @@ -41,4 +41,4 @@ public interface GridAbsPredicate { * @return Return value. */ public boolean apply(); -} +} \ 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/lang/GridAbsPredicateX.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsPredicateX.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsPredicateX.java index 2150a16..8912eb4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsPredicateX.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridAbsPredicateX.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.F; /** * Convenient predicate subclass that allows for thrown grid exception. This class @@ -43,4 +43,4 @@ public abstract class GridAbsPredicateX implements GridAbsPredicate { * @throws IgniteCheckedException Thrown in case of any error condition inside of the predicate. */ public abstract boolean applyx() throws IgniteCheckedException; -} +} \ 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/lang/GridCloseableIterator.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridCloseableIterator.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridCloseableIterator.java index 622c9b5..0cea229 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridCloseableIterator.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridCloseableIterator.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.spi.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.spi.IgniteSpiCloseableIterator; /** * Defines "rich" closeable iterator interface that is also acts like lambda function and iterable. @@ -59,4 +59,4 @@ public interface GridCloseableIterator extends GridIterator, IgniteSpiClos * @return {@code True} if iterator has been closed. */ public boolean isClosed(); -} +} \ 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/lang/GridClosure3.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridClosure3.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridClosure3.java index 4365034..0af4645 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridClosure3.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridClosure3.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.internal.util.typedef.C3; /** * Defines generic {@code for-each} type of closure. Closure is a first-class function that is defined with @@ -49,4 +49,4 @@ public interface GridClosure3 { * @return Optional return value. */ public R apply(E1 e1, E2 e2, E3 e3); -} +} \ 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/lang/GridClosure3X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridClosure3X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridClosure3X.java index 0a53e71..ebce5df 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridClosure3X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridClosure3X.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.CX3; +import org.apache.ignite.internal.util.typedef.F; /** * Convenient closure subclass that allows for thrown grid exception. This class @@ -48,4 +49,4 @@ public abstract class GridClosure3X implements GridClosure3 implements Iterator { @Override public void remove() { throw new UnsupportedOperationException(); } -} +} \ 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/lang/GridFunc.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java index 5c43ad9..a9e6cd0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java @@ -17,21 +17,65 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.util.*; -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 javax.cache.*; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collection; +import java.util.Collections; +import java.util.ConcurrentModificationException; +import java.util.HashMap; +import java.util.HashSet; +import java.util.Iterator; +import java.util.LinkedList; +import java.util.List; +import java.util.Map; +import java.util.NavigableSet; +import java.util.NoSuchElementException; +import java.util.RandomAccess; +import java.util.Set; +import java.util.UUID; +import java.util.concurrent.Callable; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicLong; +import java.util.concurrent.atomic.AtomicReference; +import javax.cache.Cache; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.compute.ComputeJobResult; +import org.apache.ignite.internal.IgniteFutureTimeoutCheckedException; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.util.F0; +import org.apache.ignite.internal.util.GridConcurrentHashSet; +import org.apache.ignite.internal.util.GridEmptyIterator; +import org.apache.ignite.internal.util.GridLeanMap; +import org.apache.ignite.internal.util.GridLeanSet; +import org.apache.ignite.internal.util.GridSerializableCollection; +import org.apache.ignite.internal.util.GridSerializableIterator; +import org.apache.ignite.internal.util.GridSerializableList; +import org.apache.ignite.internal.util.GridSerializableMap; +import org.apache.ignite.internal.util.GridSerializableSet; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.CA; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.P1; +import org.apache.ignite.internal.util.typedef.R1; +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.lang.IgniteBiClosure; +import org.apache.ignite.lang.IgniteBiTuple; +import org.apache.ignite.lang.IgniteCallable; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.lang.IgniteOutClosure; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.lang.IgniteReducer; +import org.jetbrains.annotations.NotNull; +import org.jetbrains.annotations.Nullable; +import org.jsr166.ConcurrentHashMap8; +import org.jsr166.ConcurrentLinkedDeque8; +import org.jsr166.ThreadLocalRandom8; /** * Contains factory and utility methods for {@code closures}, {@code predicates}, and {@code tuples}. @@ -4514,4 +4558,4 @@ public class GridFunc { public static IgnitePredicate> unfinishedFutures() { return UNFINISHED_FUTURE; } -} +} \ 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/lang/GridInClosure3.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridInClosure3.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridInClosure3.java index 7308036..8420384 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridInClosure3.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridInClosure3.java @@ -17,7 +17,8 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.internal.util.typedef.C3; +import org.apache.ignite.internal.util.typedef.CI3; /** * Defines a convenient {@code side-effect only} closure, i.e. the closure that has {@code void} return type. @@ -46,4 +47,4 @@ public interface GridInClosure3 { * @param e3 Third bound free variable, i.e. the element the closure is called or closed on. */ public void apply(E1 e1, E2 e2, E3 e3); -} +} \ 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/lang/GridIterable.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterable.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterable.java index ca1ebf7..5b7db68 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterable.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterable.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import java.util.*; +import java.util.Iterator; /** * Defines "rich" iterable interface that is also acts as lambda function and iterator. @@ -32,4 +32,4 @@ public interface GridIterable extends GridIterator { * @return Instance of new {@link GridIterator}. */ @Override public GridIterator iterator(); -} +} \ 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/lang/GridIterableAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterableAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterableAdapter.java index 63c1285..b463513 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterableAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterableAdapter.java @@ -17,10 +17,10 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.util.*; +import java.util.Iterator; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Convenient adapter for "rich" iterable interface. @@ -117,4 +117,4 @@ public class GridIterableAdapter implements GridIterable { it.remove(); } } -} +} \ 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/lang/GridIterator.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterator.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterator.java index 2fcc323..d0b196b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterator.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridIterator.java @@ -17,10 +17,10 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.*; - -import java.util.*; +import java.util.Iterator; +import java.util.NoSuchElementException; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.GridSerializableIterator; /** * Defines "rich" iterator interface that is also acts like lambda function and iterable. @@ -64,4 +64,4 @@ public interface GridIterator extends Iterable, GridSerializableIterator implements GridIterator { @Override public final Iterator iterator() { return 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/lang/GridMapEntry.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMapEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMapEntry.java index ff6e178..eed017f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMapEntry.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMapEntry.java @@ -17,12 +17,11 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.Map; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Simple {@link java.util.Map.Entry} implementation. @@ -89,4 +88,4 @@ public class GridMapEntry implements Map.Entry, Serializable { @Override public String toString() { return S.toString(GridMapEntry.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/lang/GridMetadataAwareAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java index a67f83d..decc244 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java @@ -17,13 +17,15 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.util.*; -import java.util.concurrent.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.util.Arrays; +import java.util.concurrent.Callable; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.F; +import org.jetbrains.annotations.Nullable; /** * Convenient adapter for working with metadata.

Thread Safety

This class provides necessary @@ -389,4 +391,4 @@ public class GridMetadataAwareAdapter { throw new InternalError(); } } -} +} \ 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/lang/GridNodePredicate.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridNodePredicate.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridNodePredicate.java index b85acd8..4ce0b35 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridNodePredicate.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridNodePredicate.java @@ -17,14 +17,20 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.cluster.*; -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 java.util.*; +import java.util.Collection; +import java.util.Collections; +import java.util.HashSet; +import java.util.Iterator; +import java.util.Set; +import java.util.UUID; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +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.IgnitePredicate; +import org.jetbrains.annotations.Nullable; /** * Convenient node predicate as a separate class. It allows to avoid "dragging" enclosing @@ -154,4 +160,4 @@ public class GridNodePredicate implements IgnitePredicate, Iterable @Override public String toString() { return S.toString(GridNodePredicate.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/lang/GridPeerDeployAware.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAware.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAware.java index dcaa7cc..eaf2fa8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAware.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAware.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import java.io.*; +import java.io.Serializable; /** * Represents any class that needs to maintain or carry on peer deployment information. @@ -49,4 +49,4 @@ public interface GridPeerDeployAware extends Serializable { * @return Class loader for the class. */ public ClassLoader classLoader(); -} +} \ 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/lang/GridPeerDeployAwareAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAwareAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAwareAdapter.java index 20d8481..7b3f502 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAwareAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPeerDeployAwareAdapter.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.typedef.internal.*; +import org.apache.ignite.internal.util.typedef.internal.U; /** * Adapter for common interfaces in closures, reducers and predicates. @@ -66,4 +66,4 @@ public class GridPeerDeployAwareAdapter implements GridPeerDeployAware { return pda.classLoader(); } -} +} \ 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/lang/GridPlainAbsClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainAbsClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainAbsClosure.java index 87ac592..37fe6d8 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainAbsClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainAbsClosure.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; +import org.apache.ignite.IgniteCheckedException; /** * Plain closure that does not accept any arguments, returns nothing and do not implement @@ -30,4 +30,4 @@ public interface GridPlainAbsClosure { * @throws IgniteCheckedException If error occurred. */ public void apply() throws IgniteCheckedException; -} +} \ 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/lang/GridPlainCallable.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainCallable.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainCallable.java index 8f8905b..621e455 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainCallable.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainCallable.java @@ -17,11 +17,11 @@ package org.apache.ignite.internal.util.lang; -import java.util.concurrent.*; +import java.util.concurrent.Callable; /** * Callable instance that should never be deployed or injected. */ public interface GridPlainCallable extends Callable { // 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/lang/GridPlainClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainClosure.java index ccf1bc9..d36f496 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainClosure.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; +import org.apache.ignite.IgniteCheckedException; /** * Closure that takes argument, returns result and do not implement {@code GridPeerDeployAware}. @@ -29,4 +29,4 @@ public interface GridPlainClosure { * @throws IgniteCheckedException If error occurred. */ public R apply(T arg) throws IgniteCheckedException; -} +} \ 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/lang/GridPlainClosure2.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainClosure2.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainClosure2.java index c21b626..f74e019 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainClosure2.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainClosure2.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; +import org.apache.ignite.IgniteCheckedException; /** * Closure taking 2 arguments. @@ -30,4 +30,4 @@ public interface GridPlainClosure2 { * @throws IgniteCheckedException If error occurred. */ public R apply(T1 arg1, T2 arg2) throws IgniteCheckedException; -} +} \ 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/lang/GridPlainInClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainInClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainInClosure.java index 85c469e..e47f248 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainInClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainInClosure.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; +import org.apache.ignite.IgniteCheckedException; /** * Plain closure that takes one input argument and does not implement {@code GridPeerDeployAware}. @@ -28,4 +28,4 @@ public interface GridPlainInClosure { * @throws IgniteCheckedException If error occurred. */ public void apply(T arg) throws IgniteCheckedException; -} +} \ 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/lang/GridPlainOutClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainOutClosure.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainOutClosure.java index 4616303..96ea9c0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainOutClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainOutClosure.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; +import org.apache.ignite.IgniteCheckedException; /** * Closure that takes no arguments, returns result and does not implement {@code GridPeerDeployAware}. @@ -28,4 +28,4 @@ public interface GridPlainOutClosure { * @throws IgniteCheckedException If error occurred. */ public R apply() throws IgniteCheckedException; -} +} \ 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/lang/GridPlainRunnable.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainRunnable.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainRunnable.java index 00bc0c7..94794ab 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainRunnable.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPlainRunnable.java @@ -22,4 +22,4 @@ package org.apache.ignite.internal.util.lang; */ public interface GridPlainRunnable extends Runnable { // 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/lang/GridPredicate3.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPredicate3.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPredicate3.java index 5538733..615f467 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPredicate3.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPredicate3.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.internal.util.typedef.P3; /** * Defines predicate construct. Predicate like closure is a first-class function @@ -54,4 +54,4 @@ public interface GridPredicate3 { * @return Return value. */ public abstract boolean apply(E1 e1, E2 e2, E3 e3); -} +} \ 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/lang/GridPredicate3X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPredicate3X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPredicate3X.java index 2337949..958ae63 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPredicate3X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridPredicate3X.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.PX3; /** * Convenient predicate subclass that allows for thrown grid exception. This class @@ -48,4 +49,4 @@ public abstract class GridPredicate3X implements GridPredicate3 extends GridTuple3 { @Override public Object clone() { return super.clone(); } -} +} \ 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/lang/GridTuple.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java index 8e274b7..2342239 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java @@ -17,12 +17,15 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -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.Iterator; +import java.util.NoSuchElementException; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.jetbrains.annotations.Nullable; /** * Convenience class representing mutable tuple of a single value. @@ -144,4 +147,4 @@ public class GridTuple implements Iterable, Cloneable, Externalizable { @Override public String toString() { return S.toString(GridTuple.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/lang/GridTuple3.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java index 5ab4fb4..b999e2a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java @@ -17,13 +17,16 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -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.Iterator; +import java.util.NoSuchElementException; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.jetbrains.annotations.Nullable; /** * Convenience class representing mutable tuple of three values. @@ -223,4 +226,4 @@ public class GridTuple3 implements Iterable, Externalizable, @Override public String toString() { return S.toString(GridTuple3.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/lang/GridTuple4.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java index 310e0fb..835cdcb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java @@ -17,13 +17,16 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -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.Iterator; +import java.util.NoSuchElementException; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.jetbrains.annotations.Nullable; /** * Convenience class representing mutable tuple of four values. @@ -254,4 +257,4 @@ public class GridTuple4 implements Iterable, Externaliza @Override public String toString() { return S.toString(GridTuple4.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/lang/GridTuple5.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java index 578f5a8..9790f48 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java @@ -17,13 +17,16 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -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.Iterator; +import java.util.NoSuchElementException; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.jetbrains.annotations.Nullable; /** * Convenience class representing mutable tuple of five values. @@ -285,4 +288,4 @@ public class GridTuple5 implements Iterable, Externa @Override public String toString() { return S.toString(GridTuple5.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/lang/GridTuple6.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java index 1f8b330..044944b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java @@ -17,13 +17,16 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -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.Iterator; +import java.util.NoSuchElementException; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.jetbrains.annotations.Nullable; /** * Convenience class representing mutable tuple of six values. @@ -319,4 +322,4 @@ public class GridTuple6 implements Iterable, Ext @Override public String toString() { return S.toString(GridTuple6.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/lang/GridTupleV.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTupleV.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTupleV.java index 6945ac3..225366a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTupleV.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTupleV.java @@ -17,11 +17,17 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -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.Arrays; +import java.util.Iterator; +import java.util.NoSuchElementException; +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; /** * Constructs a tuple over a given array. @@ -185,4 +191,4 @@ public class GridTupleV implements Iterable, Externalizable, Cloneable { @Override public String toString() { return S.toString(GridTupleV.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/lang/IgniteClosure2X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteClosure2X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteClosure2X.java index ed01add..9c243f7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteClosure2X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteClosure2X.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.CX2; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.lang.IgniteBiClosure; /** * Convenient closure subclass that allows for thrown grid exception. This class @@ -50,4 +51,4 @@ public abstract class IgniteClosure2X implements IgniteBiClosure implements IgniteClosure { * @throws IgniteCheckedException Thrown in case of any error condition inside of the closure. */ public abstract R applyx(E e) throws IgniteCheckedException; -} +} \ 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/lang/IgniteInClosure2X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteInClosure2X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteInClosure2X.java index 2fcc930..edaf35f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteInClosure2X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteInClosure2X.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.CIX2; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.lang.IgniteBiInClosure; /** * Convenient in-closure subclass that allows for thrown grid exception. This class @@ -49,4 +50,4 @@ public abstract class IgniteInClosure2X implements IgniteBiInClosure implements IgniteInClosure { * @throws IgniteCheckedException Thrown in case of any error condition inside of the closure. */ public abstract void applyx(T t) throws IgniteCheckedException; -} +} \ 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/lang/IgniteOutClosureX.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteOutClosureX.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteOutClosureX.java index 84aea09..0f4eb84 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteOutClosureX.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteOutClosureX.java @@ -17,9 +17,9 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.lang.IgniteOutClosure; /** * Convenient out-closure subclass that allows for thrown grid exception. This class @@ -47,4 +47,4 @@ public abstract class IgniteOutClosureX implements IgniteOutClosure { * @throws IgniteCheckedException Thrown in case of any error condition inside of the closure. */ public abstract T applyx() throws IgniteCheckedException; -} +} \ 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/lang/IgnitePair.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgnitePair.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgnitePair.java index decc7fc..a6acce4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgnitePair.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgnitePair.java @@ -17,10 +17,9 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.io.*; +import java.io.Externalizable; +import org.apache.ignite.lang.IgniteBiTuple; +import org.jetbrains.annotations.Nullable; /** * Simple extension over {@link org.apache.ignite.lang.IgniteBiTuple} for pair of objects of the same type. @@ -51,4 +50,4 @@ public class IgnitePair extends IgniteBiTuple { @Override public Object clone() { return super.clone(); } -} +} \ 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/lang/IgnitePredicate2X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgnitePredicate2X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgnitePredicate2X.java index a7ed105..094005b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgnitePredicate2X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgnitePredicate2X.java @@ -17,9 +17,10 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.PX2; +import org.apache.ignite.lang.IgniteBiPredicate; /** * Convenient predicate subclass that allows for thrown grid exception. This class @@ -50,4 +51,4 @@ public abstract class IgnitePredicate2X implements IgniteBiPredicate implements IgnitePredicate { * @throws IgniteCheckedException Thrown in case of any error condition inside of the predicate. */ public abstract boolean applyx(E1 e) throws IgniteCheckedException; -} +} \ 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/lang/IgniteReducer2.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer2.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer2.java index 19c189e..308d41e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer2.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer2.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.lang.IgniteOutClosure; +import org.jetbrains.annotations.Nullable; /** * Defines generic {@code for-all} or {@code reduce} type of closure. Unlike {@code for-each} type of closure @@ -50,4 +50,4 @@ public interface IgniteReducer2 extends IgniteOutClosure { * collecting and call {@link #apply()} method. */ public abstract boolean collect(@Nullable E1 e1, @Nullable E2 e2); -} +} \ 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/lang/IgniteReducer2X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer2X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer2X.java index 14a5fd0..2e2daa1 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer2X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer2X.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.RX2; /** * Convenient reducer subclass that allows for thrown grid exception. This class @@ -47,4 +48,4 @@ public abstract class IgniteReducer2X implements IgniteReducer2 extends IgniteOutClosure { * collecting and call {@link #apply()} method. */ public boolean collect(@Nullable E1 e1, @Nullable E2 e2, @Nullable E3 e3); -} +} \ 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/lang/IgniteReducer3X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer3X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer3X.java index c091e5b..15e0781 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer3X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/IgniteReducer3X.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal.util.lang; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.RX3; /** * Convenient reducer subclass that allows for thrown grid exception. This class @@ -47,4 +48,4 @@ public abstract class IgniteReducer3X implements IgniteReducer3 implements IgniteReducer { * @throws IgniteCheckedException Thrown in case of any error condition inside of the reducer. */ public abstract R applyx() throws IgniteCheckedException; -} +} \ 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/nio/GridAbstractCommunicationClient.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridAbstractCommunicationClient.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridAbstractCommunicationClient.java index d75fb2d..9b014ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridAbstractCommunicationClient.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridAbstractCommunicationClient.java @@ -17,10 +17,10 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import java.util.concurrent.atomic.*; +import java.util.concurrent.atomic.AtomicInteger; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.jetbrains.annotations.Nullable; /** * Implements basic lifecycle for communication clients. @@ -109,4 +109,4 @@ public abstract class GridAbstractCommunicationClient implements GridCommunicati @Override public String toString() { return S.toString(GridAbstractCommunicationClient.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/nio/GridBufferedParser.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridBufferedParser.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridBufferedParser.java index a03d2c8..303991d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridBufferedParser.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridBufferedParser.java @@ -17,10 +17,10 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; - -import java.io.*; -import java.nio.*; +import java.io.IOException; +import java.nio.ByteBuffer; +import java.nio.ByteOrder; +import org.apache.ignite.IgniteCheckedException; /** * This class implements stream parser based on {@link GridNioServerBuffer}. @@ -89,4 +89,4 @@ public class GridBufferedParser implements GridNioParser { @Override public String toString() { return GridBufferedParser.class.getSimpleName(); } -} +} \ 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/nio/GridCommunicationClient.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java index 1a26ad5..a933916 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridCommunicationClient.java @@ -17,15 +17,16 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.plugin.extensions.communication.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.nio.*; -import java.util.*; +import java.io.InputStream; +import java.io.OutputStream; +import java.nio.ByteBuffer; +import java.util.UUID; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.internal.util.lang.IgniteInClosure2X; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.plugin.extensions.communication.Message; +import org.jetbrains.annotations.Nullable; /** * @@ -106,4 +107,4 @@ public interface GridCommunicationClient { * @return {@code True} if send is asynchronous. */ public boolean async(); -} +} \ 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/nio/GridConnectionBytesVerifyFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridConnectionBytesVerifyFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridConnectionBytesVerifyFilter.java index 8bee151..13d7ca7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridConnectionBytesVerifyFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridConnectionBytesVerifyFilter.java @@ -17,10 +17,11 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.nio.*; +import java.nio.ByteBuffer; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.typedef.internal.LT; +import org.apache.ignite.internal.util.typedef.internal.U; /** * Verifies that first bytes received in accepted (incoming) @@ -136,4 +137,4 @@ public class GridConnectionBytesVerifyFilter extends GridNioFilterAdapter { @Override public void onSessionWriteTimeout(GridNioSession ses) throws IgniteCheckedException { 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/nio/GridDelimitedParser.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDelimitedParser.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDelimitedParser.java index 256597c..7458e7c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDelimitedParser.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDelimitedParser.java @@ -17,10 +17,9 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; - -import java.io.*; -import java.nio.*; +import java.io.IOException; +import java.nio.ByteBuffer; +import org.apache.ignite.IgniteCheckedException; /** * This class implements stream parser based on {@link GridNioDelimitedBuffer}. @@ -88,4 +87,4 @@ public class GridDelimitedParser implements GridNioParser { @Override public String toString() { return this.getClass().getSimpleName(); } -} +} \ 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/nio/GridDirectParser.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java index 939ad0a..987090d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridDirectParser.java @@ -17,12 +17,15 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; -import org.apache.ignite.plugin.extensions.communication.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.nio.*; +import java.io.IOException; +import java.io.UnsupportedEncodingException; +import java.nio.ByteBuffer; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.plugin.extensions.communication.Message; +import org.apache.ignite.plugin.extensions.communication.MessageFactory; +import org.apache.ignite.plugin.extensions.communication.MessageFormatter; +import org.apache.ignite.plugin.extensions.communication.MessageReader; +import org.jetbrains.annotations.Nullable; /** * Parser for direct messages. @@ -90,4 +93,4 @@ public class GridDirectParser implements GridNioParser { // No encoding needed for direct messages. throw new UnsupportedEncodingException(); } -} +} \ 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/nio/GridNioAsyncNotifyFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java index d69beb1..9925d2e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioAsyncNotifyFilter.java @@ -17,11 +17,12 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.internal.util.worker.*; - -import java.util.concurrent.*; +import java.util.concurrent.Executor; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.internal.util.worker.GridWorker; +import org.apache.ignite.internal.util.worker.GridWorkerPool; /** * Enables multithreaded notification of session opened, message received and session closed events. @@ -138,4 +139,4 @@ public class GridNioAsyncNotifyFilter extends GridNioFilterAdapter { "originalEx=" + ex + ", ex=" + 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/nio/GridNioBackPressureControl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioBackPressureControl.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioBackPressureControl.java index 7f9f9c3..b15e4a6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioBackPressureControl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioBackPressureControl.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.thread.*; +import org.apache.ignite.thread.IgniteThread; /** * Utility class that allows to ignore back-pressure control for threads that are processing messages. @@ -53,4 +53,4 @@ public class GridNioBackPressureControl { else threadProcMsg.set(processing); } -} +} \ 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/nio/GridNioCodecFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java index b3ed8e7..a2f543d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioCodecFilter.java @@ -17,12 +17,13 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.io.*; -import java.nio.*; +import java.io.IOException; +import java.nio.ByteBuffer; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.internal.LT; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Filter that transforms byte buffers to user-defined objects and vice-versa @@ -136,4 +137,4 @@ public class GridNioCodecFilter extends GridNioFilterAdapter { @Override public void onSessionWriteTimeout(GridNioSession ses) throws IgniteCheckedException { 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/nio/GridNioDelimitedBuffer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java index 44ab4a5..fdbd402 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioDelimitedBuffer.java @@ -17,10 +17,9 @@ package org.apache.ignite.internal.util.nio; -import org.jetbrains.annotations.*; - -import java.nio.*; -import java.util.*; +import java.nio.ByteBuffer; +import java.util.Arrays; +import org.jetbrains.annotations.Nullable; /** * Buffer with message delimiter support. @@ -103,4 +102,4 @@ public class GridNioDelimitedBuffer { return null; } -} +} \ 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/nio/GridNioEmbeddedFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java index a1d6337..be77d39 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioEmbeddedFuture.java @@ -17,11 +17,11 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; -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.IgniteCheckedException; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.lang.IgniteInClosure; +import org.jetbrains.annotations.Nullable; /** * Future that delegates to some other future. @@ -68,4 +68,4 @@ public class GridNioEmbeddedFuture extends GridNioFutureImpl { @Override public String toString() { return S.toString(GridNioEmbeddedFuture.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/nio/GridNioException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioException.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioException.java index 4295225..7de1d45 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioException.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteCheckedException; +import org.jetbrains.annotations.Nullable; /** * Nio specific exception. @@ -55,4 +55,4 @@ public class GridNioException extends IgniteCheckedException { public GridNioException(Throwable cause) { super(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/nio/GridNioFilter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilter.java index 419d68c..5f88b1f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioFilter.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.util.nio; -import org.apache.ignite.*; +import org.apache.ignite.IgniteCheckedException; /** * This interface defines the general element in transformation chain between the nio server and @@ -241,4 +241,4 @@ public interface GridNioFilter { * @throws IgniteCheckedException If filter is not in chain or GridNioException occurred in the underlying filter. */ public GridNioFuture onResumeReads(GridNioSession ses) throws IgniteCheckedException; -} +} \ No newline at end of file