http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpiMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpiMBean.java b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpiMBean.java index 4bd912f..75e8bb2 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpiMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/loadbalancing/weightedrandom/WeightedRandomLoadBalancingSpiMBean.java @@ -17,8 +17,8 @@ package org.apache.ignite.spi.loadbalancing.weightedrandom; -import org.apache.ignite.mxbean.*; -import org.apache.ignite.spi.*; +import org.apache.ignite.mxbean.MXBeanDescription; +import org.apache.ignite.spi.IgniteSpiManagementMBean; /** * Management MBean for {@link WeightedRandomLoadBalancingSpi} SPI. @@ -42,4 +42,4 @@ public interface WeightedRandomLoadBalancingSpiMBean extends IgniteSpiManagement */ @MXBeanDescription("Weight of this node.") public int getNodeWeight(); -} +} \ 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/spi/swapspace/SwapContext.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapContext.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapContext.java index 187aaa9..374f5f6 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapContext.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapContext.java @@ -17,7 +17,7 @@ package org.apache.ignite.spi.swapspace; -import org.apache.ignite.internal.util.typedef.internal.*; +import org.apache.ignite.internal.util.typedef.internal.S; /** * Context for swap operations. @@ -44,4 +44,4 @@ public class SwapContext { @Override public String toString() { return S.toString(SwapContext.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/spi/swapspace/SwapKey.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapKey.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapKey.java index a21024b..fb22be2 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapKey.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapKey.java @@ -17,9 +17,10 @@ package org.apache.ignite.spi.swapspace; -import org.apache.ignite.internal.util.tostring.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.tostring.GridToStringInclude; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.jetbrains.annotations.Nullable; /** * Utility wrapper class that represents swap key. @@ -121,4 +122,4 @@ public class SwapKey { @Override public String toString() { return S.toString(SwapKey.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/spi/swapspace/SwapSpaceSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapSpaceSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapSpaceSpi.java index 8c788c8..7e49324 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapSpaceSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapSpaceSpi.java @@ -17,11 +17,15 @@ package org.apache.ignite.spi.swapspace; -import org.apache.ignite.lang.*; -import org.apache.ignite.spi.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.Map; +import java.util.Set; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.spi.IgniteSpi; +import org.apache.ignite.spi.IgniteSpiCloseableIterator; +import org.apache.ignite.spi.IgniteSpiException; +import org.jetbrains.annotations.Nullable; /** * Provides a mechanism in grid for storing data on disk. Ignite cache uses swap space to overflow @@ -218,4 +222,4 @@ public interface SwapSpaceSpi extends IgniteSpi { */ @Nullable public IgniteSpiCloseableIterator<Map.Entry<byte[], byte[]>> rawIterator(@Nullable String spaceName, int part) throws IgniteSpiException; -} +} \ 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/spi/swapspace/SwapSpaceSpiListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapSpaceSpiListener.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapSpaceSpiListener.java index cb61a94..85f356f 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapSpaceSpiListener.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/SwapSpaceSpiListener.java @@ -17,7 +17,7 @@ package org.apache.ignite.spi.swapspace; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * Swap space SPI eviction listener. @@ -32,4 +32,4 @@ public interface SwapSpaceSpiListener { * @param valBytes Value bytes of affected entry. Not {@code null} only for evict notifications. */ public void onSwapEvent(int evtType, @Nullable String spaceName, @Nullable byte[] keyBytes, @Nullable byte[] valBytes); -} +} \ 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/spi/swapspace/file/FileSwapArray.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapArray.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapArray.java index 2f6b910..bab8649 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapArray.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapArray.java @@ -17,9 +17,8 @@ package org.apache.ignite.spi.swapspace.file; -import org.jetbrains.annotations.*; - -import java.util.concurrent.atomic.*; +import java.util.concurrent.atomic.AtomicReferenceArray; +import org.jetbrains.annotations.Nullable; /** * Growing array. @@ -186,4 +185,4 @@ class FileSwapArray<X> { arr.lazySet(idx, x); } } -} +} \ 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/spi/swapspace/file/FileSwapSpaceSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java index 000782a..19c7987 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpi.java @@ -17,27 +17,64 @@ package org.apache.ignite.spi.swapspace.file; -import org.apache.ignite.*; -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.apache.ignite.resources.*; -import org.apache.ignite.spi.*; -import org.apache.ignite.spi.swapspace.*; -import org.jetbrains.annotations.*; -import org.jsr166.*; - -import java.io.*; -import java.nio.*; -import java.nio.channels.*; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; -import java.util.concurrent.locks.*; - -import static org.apache.ignite.events.EventType.*; +import java.io.File; +import java.io.FileNotFoundException; +import java.io.IOException; +import java.io.RandomAccessFile; +import java.nio.ByteBuffer; +import java.nio.channels.AsynchronousCloseException; +import java.nio.channels.ClosedByInterruptException; +import java.nio.channels.ClosedChannelException; +import java.nio.channels.FileChannel; +import java.util.ArrayDeque; +import java.util.Arrays; +import java.util.Collection; +import java.util.Collections; +import java.util.HashMap; +import java.util.Iterator; +import java.util.Map; +import java.util.NoSuchElementException; +import java.util.Set; +import java.util.concurrent.Callable; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; +import java.util.concurrent.atomic.AtomicLong; +import java.util.concurrent.locks.Condition; +import java.util.concurrent.locks.LockSupport; +import java.util.concurrent.locks.ReentrantLock; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.IgniteInterruptedCheckedException; +import org.apache.ignite.internal.util.GridAtomicInitializer; +import org.apache.ignite.internal.util.GridCloseableIteratorAdapter; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.T2; +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.IgniteBiInClosure; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.resources.LoggerResource; +import org.apache.ignite.spi.IgniteSpiAdapter; +import org.apache.ignite.spi.IgniteSpiCloseableIterator; +import org.apache.ignite.spi.IgniteSpiConfiguration; +import org.apache.ignite.spi.IgniteSpiException; +import org.apache.ignite.spi.IgniteSpiMultipleInstancesSupport; +import org.apache.ignite.spi.IgniteSpiThread; +import org.apache.ignite.spi.swapspace.SwapContext; +import org.apache.ignite.spi.swapspace.SwapKey; +import org.apache.ignite.spi.swapspace.SwapSpaceSpi; +import org.apache.ignite.spi.swapspace.SwapSpaceSpiListener; +import org.jetbrains.annotations.Nullable; +import org.jsr166.ConcurrentHashMap8; + +import static org.apache.ignite.events.EventType.EVT_SWAP_SPACE_CLEARED; +import static org.apache.ignite.events.EventType.EVT_SWAP_SPACE_DATA_READ; +import static org.apache.ignite.events.EventType.EVT_SWAP_SPACE_DATA_REMOVED; +import static org.apache.ignite.events.EventType.EVT_SWAP_SPACE_DATA_STORED; /** * File-based swap space SPI implementation which holds keys in memory. This SPI is used by default. @@ -1866,4 +1903,4 @@ public class FileSwapSpaceSpi extends IgniteSpiAdapter implements SwapSpaceSpi, }; } } -} +} \ 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/spi/swapspace/file/FileSwapSpaceSpiMBean.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpiMBean.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpiMBean.java index 4c4623b..f06020c 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpiMBean.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/file/FileSwapSpaceSpiMBean.java @@ -17,8 +17,8 @@ package org.apache.ignite.spi.swapspace.file; -import org.apache.ignite.mxbean.*; -import org.apache.ignite.spi.*; +import org.apache.ignite.mxbean.MXBeanDescription; +import org.apache.ignite.spi.IgniteSpiManagementMBean; /** * Management bean for {@link FileSwapSpaceSpi}. @@ -64,4 +64,4 @@ public interface FileSwapSpaceSpiMBean extends IgniteSpiManagementMBean { */ @MXBeanDescription("Read pool size.") public int getReadStripesNumber(); -} +} \ 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/spi/swapspace/noop/NoopSwapSpaceSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/noop/NoopSwapSpaceSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/noop/NoopSwapSpaceSpi.java index 4f675b2..13622d9 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/swapspace/noop/NoopSwapSpaceSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/swapspace/noop/NoopSwapSpaceSpi.java @@ -17,16 +17,27 @@ package org.apache.ignite.spi.swapspace.noop; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; -import org.apache.ignite.spi.*; -import org.apache.ignite.spi.swapspace.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.Collections; +import java.util.Map; +import java.util.Set; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.GridEmptyCloseableIterator; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.resources.LoggerResource; +import org.apache.ignite.spi.IgniteSpiAdapter; +import org.apache.ignite.spi.IgniteSpiCloseableIterator; +import org.apache.ignite.spi.IgniteSpiException; +import org.apache.ignite.spi.IgniteSpiMultipleInstancesSupport; +import org.apache.ignite.spi.IgniteSpiNoop; +import org.apache.ignite.spi.swapspace.SwapContext; +import org.apache.ignite.spi.swapspace.SwapKey; +import org.apache.ignite.spi.swapspace.SwapSpaceSpi; +import org.apache.ignite.spi.swapspace.SwapSpaceSpiListener; +import org.jetbrains.annotations.Nullable; /** * No-op implementation of {@link org.apache.ignite.spi.swapspace.SwapSpaceSpi}. Exists for testing and benchmarking purposes. @@ -136,4 +147,4 @@ public class NoopSwapSpaceSpi extends IgniteSpiAdapter implements SwapSpaceSpi { @Override public String toString() { return S.toString(NoopSwapSpaceSpi.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/ssl/SslContextFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java b/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java index d52dcf3..06edd70 100644 --- a/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/ssl/SslContextFactory.java @@ -17,15 +17,24 @@ package org.apache.ignite.ssl; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; - -import javax.cache.configuration.*; -import javax.net.ssl.*; -import java.io.*; -import java.security.*; -import java.security.cert.*; -import java.util.*; +import java.io.FileInputStream; +import java.io.FileNotFoundException; +import java.io.IOException; +import java.io.InputStream; +import java.security.GeneralSecurityException; +import java.security.KeyStore; +import java.security.cert.CertificateException; +import java.security.cert.X509Certificate; +import java.util.Arrays; +import javax.cache.configuration.Factory; +import javax.net.ssl.KeyManagerFactory; +import javax.net.ssl.SSLContext; +import javax.net.ssl.SSLException; +import javax.net.ssl.TrustManager; +import javax.net.ssl.TrustManagerFactory; +import javax.net.ssl.X509TrustManager; +import org.apache.ignite.IgniteException; +import org.apache.ignite.internal.util.typedef.internal.A; /** * This SSL context factory that provides ssl context configuration with specified key @@ -455,4 +464,4 @@ public class SslContextFactory implements Factory<SSLContext> { throw new IgniteException(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/startup/BasicWarmupClosure.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java b/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java index 2418c71..270a5c6 100644 --- a/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java +++ b/modules/core/src/main/java/org/apache/ignite/startup/BasicWarmupClosure.java @@ -17,21 +17,34 @@ package org.apache.ignite.startup; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.logger.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; - -import java.text.*; -import java.util.*; -import java.util.concurrent.*; +import java.text.SimpleDateFormat; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Date; +import java.util.LinkedList; +import java.util.concurrent.Callable; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.Future; +import java.util.concurrent.ThreadLocalRandom; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteSystemProperties; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.IgniteKernal; +import org.apache.ignite.internal.processors.cache.IgniteCacheProxy; +import org.apache.ignite.internal.processors.cache.IgniteInternalCache; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.CU; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.logger.NullLogger; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; /** * Basic warm-up closure which warm-ups cache operations. @@ -556,4 +569,4 @@ public class BasicWarmupClosure implements IgniteInClosure<IgniteConfiguration> cache.replace(key, key, key); } } -} +} \ 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/startup/cmdline/AboutDialog.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/AboutDialog.java b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/AboutDialog.java index 22f5000..b6fe276 100644 --- a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/AboutDialog.java +++ b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/AboutDialog.java @@ -17,16 +17,35 @@ package org.apache.ignite.startup.cmdline; -import javax.imageio.*; -import javax.swing.*; -import javax.swing.border.*; -import java.awt.*; -import java.awt.event.*; -import java.awt.image.*; -import java.io.*; -import java.net.*; -import java.text.*; -import java.util.*; +import java.awt.BorderLayout; +import java.awt.Color; +import java.awt.FlowLayout; +import java.awt.GridBagConstraints; +import java.awt.GridBagLayout; +import java.awt.Insets; +import java.awt.event.ActionEvent; +import java.awt.event.ActionListener; +import java.awt.event.KeyEvent; +import java.awt.image.BufferedImage; +import java.io.IOException; +import java.net.URL; +import java.text.SimpleDateFormat; +import java.util.Date; +import javax.imageio.ImageIO; +import javax.swing.AbstractAction; +import javax.swing.Action; +import javax.swing.BorderFactory; +import javax.swing.Box; +import javax.swing.BoxLayout; +import javax.swing.ImageIcon; +import javax.swing.JButton; +import javax.swing.JComponent; +import javax.swing.JDialog; +import javax.swing.JLabel; +import javax.swing.JPanel; +import javax.swing.KeyStroke; +import javax.swing.SwingUtilities; +import javax.swing.border.Border; /** * About dialog. @@ -329,4 +348,4 @@ public class AboutDialog extends JDialog { } }); } -} +} \ 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/startup/cmdline/CommandLineRandomNumberGenerator.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineRandomNumberGenerator.java b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineRandomNumberGenerator.java index c12d51b..4780ad5 100644 --- a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineRandomNumberGenerator.java +++ b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineRandomNumberGenerator.java @@ -17,7 +17,7 @@ package org.apache.ignite.startup.cmdline; -import java.util.*; +import java.util.UUID; /** * Generates a random number and prints it to the console. @@ -31,4 +31,4 @@ public class CommandLineRandomNumberGenerator { public static void main(String[] args) { System.out.println(UUID.randomUUID()); } -} +} \ 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/startup/cmdline/CommandLineStartup.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java index 5b39069..043d651 100644 --- a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java +++ b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineStartup.java @@ -17,27 +17,40 @@ package org.apache.ignite.startup.cmdline; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.internal.util.lang.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.jetbrains.annotations.*; - -import javax.swing.*; -import java.awt.*; -import java.io.*; -import java.lang.reflect.*; +import java.awt.Image; +import java.io.BufferedReader; +import java.io.File; +import java.io.IOException; +import java.io.InputStreamReader; +import java.lang.reflect.InvocationHandler; +import java.lang.reflect.Method; import java.lang.reflect.Proxy; -import java.net.*; -import java.text.*; -import java.util.*; +import java.net.URL; +import java.text.SimpleDateFormat; +import java.util.Date; import java.util.List; -import java.util.concurrent.*; - -import static org.apache.ignite.IgniteState.*; -import static org.apache.ignite.IgniteSystemProperties.*; -import static org.apache.ignite.internal.IgniteVersionUtils.*; +import java.util.Locale; +import java.util.concurrent.CountDownLatch; +import javax.swing.ImageIcon; +import org.apache.ignite.IgniteState; +import org.apache.ignite.IgniteSystemProperties; +import org.apache.ignite.IgnitionListener; +import org.apache.ignite.internal.util.GridConfigurationFinder; +import org.apache.ignite.internal.util.lang.GridTuple3; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.G; +import org.apache.ignite.internal.util.typedef.X; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.jetbrains.annotations.Nullable; + +import static org.apache.ignite.IgniteState.STOPPED; +import static org.apache.ignite.IgniteState.STOPPED_ON_SEGMENTATION; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_PROG_NAME; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_RESTART_CODE; +import static org.apache.ignite.internal.IgniteVersionUtils.ACK_VER_STR; +import static org.apache.ignite.internal.IgniteVersionUtils.COPYRIGHT; +import static org.apache.ignite.internal.IgniteVersionUtils.RELEASE_DATE_STR; +import static org.apache.ignite.internal.IgniteVersionUtils.VER_STR; /** * This class defines command-line Ignite startup. This startup can be used to start Ignite @@ -337,4 +350,4 @@ public final class CommandLineStartup { else System.exit(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/startup/cmdline/CommandLineTransformer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineTransformer.java b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineTransformer.java index ae0c587..be758fa 100644 --- a/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineTransformer.java +++ b/modules/core/src/main/java/org/apache/ignite/startup/cmdline/CommandLineTransformer.java @@ -17,8 +17,9 @@ package org.apache.ignite.startup.cmdline; -import java.io.*; -import java.util.*; +import java.io.PrintStream; +import java.util.ArrayList; +import java.util.List; /** * This class is a workaround for a versatile problems with passing arguments to the Ignite Windows batch launcher @@ -232,4 +233,4 @@ public class CommandLineTransformer { private boolean checkJVMOptionIsSupported(String jvmOpt) { return !(jvmOpt.contains("-XX:OnError") || jvmOpt.contains("-XX:OnOutOfMemoryError")); } -} +} \ 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/startup/package-info.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/startup/package-info.java b/modules/core/src/main/java/org/apache/ignite/startup/package-info.java index 7c5467f..45a87dc 100644 --- a/modules/core/src/main/java/org/apache/ignite/startup/package-info.java +++ b/modules/core/src/main/java/org/apache/ignite/startup/package-info.java @@ -18,4 +18,4 @@ /** * Contains Ignite runtime startup classes. */ -package org.apache.ignite.startup; +package org.apache.ignite.startup; \ 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/stream/StreamAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/StreamAdapter.java b/modules/core/src/main/java/org/apache/ignite/stream/StreamAdapter.java index 0c4e2d1..97edcbb 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/StreamAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/StreamAdapter.java @@ -17,9 +17,9 @@ package org.apache.ignite.stream; -import org.apache.ignite.*; - -import java.util.*; +import java.util.Map; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteDataStreamer; /** * Convenience adapter for streamers. Adapters are optional components for http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/stream/StreamReceiver.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/StreamReceiver.java b/modules/core/src/main/java/org/apache/ignite/stream/StreamReceiver.java index a3d9dfb..c5f2f12 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/StreamReceiver.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/StreamReceiver.java @@ -17,10 +17,12 @@ package org.apache.ignite.stream; -import org.apache.ignite.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.Collection; +import java.util.Map; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteDataStreamer; +import org.apache.ignite.IgniteException; /** * Updates cache with batch of entries. Usually it is enough to configure {@link IgniteDataStreamer#allowOverwrite(boolean)} @@ -39,4 +41,4 @@ public interface StreamReceiver<K, V> extends Serializable { * @throws org.apache.ignite.IgniteException If failed. */ public void receive(IgniteCache<K, V> cache, Collection<Map.Entry<K, V>> entries) throws IgniteException; -} +} \ 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/stream/StreamTransformer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java b/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java index 3f22299..f0f41bf 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/StreamTransformer.java @@ -17,11 +17,14 @@ package org.apache.ignite.stream; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; - -import javax.cache.processor.*; -import java.util.*; +import java.util.Collection; +import java.util.Map; +import javax.cache.processor.EntryProcessor; +import javax.cache.processor.EntryProcessorException; +import javax.cache.processor.MutableEntry; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cache.CacheEntryProcessor; /** * Convenience adapter to transform update existing values in streaming cache @@ -50,4 +53,4 @@ public abstract class StreamTransformer<K, V> implements StreamReceiver<K, V>, 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/stream/StreamTupleExtractor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/StreamTupleExtractor.java b/modules/core/src/main/java/org/apache/ignite/stream/StreamTupleExtractor.java index d2a4ede..b6150ab 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/StreamTupleExtractor.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/StreamTupleExtractor.java @@ -17,7 +17,7 @@ package org.apache.ignite.stream; -import java.util.*; +import java.util.Map; /** * Stream tuple extractor to convert messages to Ignite key-value tuples. @@ -30,4 +30,4 @@ public interface StreamTupleExtractor<T, K, V> { * @return Key-value tuple. */ public Map.Entry<K, V> extract(T msg); -} +} \ 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/stream/StreamVisitor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java b/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java index a87ac94..69f664f 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/StreamVisitor.java @@ -17,10 +17,11 @@ package org.apache.ignite.stream; -import org.apache.ignite.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.Collection; +import java.util.Map; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.lang.IgniteBiInClosure; /** * Convenience adapter to visit every key-value tuple in the stream. Note, that the visitor @@ -50,4 +51,4 @@ public abstract class StreamVisitor<K, V> implements StreamReceiver<K, V>, Ignit } }; } -} +} \ 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/stream/package-info.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/package-info.java b/modules/core/src/main/java/org/apache/ignite/stream/package-info.java index 6451697..5469271 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/package-info.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/package-info.java @@ -18,4 +18,4 @@ /** * Contains Ignite Streamer classes. */ -package org.apache.ignite.stream; +package org.apache.ignite.stream; \ 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/stream/socket/SocketMessageConverter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketMessageConverter.java b/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketMessageConverter.java index 8161d86..03e82e3 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketMessageConverter.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketMessageConverter.java @@ -28,4 +28,4 @@ public interface SocketMessageConverter<T> { * @return Converted object. */ public T convert(byte[] msg); -} +} \ 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/stream/socket/SocketStreamer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java b/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java index 07ce77e..0d27af9 100644 --- a/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java +++ b/modules/core/src/main/java/org/apache/ignite/stream/socket/SocketStreamer.java @@ -17,17 +17,28 @@ package org.apache.ignite.stream.socket; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.nio.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.marshaller.jdk.*; -import org.apache.ignite.stream.*; - -import org.jetbrains.annotations.*; - -import java.net.*; -import java.nio.*; +import java.net.InetAddress; +import java.net.UnknownHostException; +import java.nio.ByteOrder; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteDataStreamer; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.nio.GridBufferedParser; +import org.apache.ignite.internal.util.nio.GridDelimitedParser; +import org.apache.ignite.internal.util.nio.GridNioCodecFilter; +import org.apache.ignite.internal.util.nio.GridNioFilter; +import org.apache.ignite.internal.util.nio.GridNioParser; +import org.apache.ignite.internal.util.nio.GridNioServer; +import org.apache.ignite.internal.util.nio.GridNioServerListener; +import org.apache.ignite.internal.util.nio.GridNioServerListenerAdapter; +import org.apache.ignite.internal.util.nio.GridNioSession; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.marshaller.jdk.JdkMarshaller; +import org.apache.ignite.stream.StreamAdapter; +import org.apache.ignite.stream.StreamTupleExtractor; +import org.jetbrains.annotations.Nullable; /** * Server that receives data from TCP socket, converts it to key-value pairs using {@link StreamTupleExtractor} and @@ -215,4 +226,4 @@ public class SocketStreamer<T, K, V> extends StreamAdapter<T, K, V> { } } } -} +} \ 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/thread/IgniteStripedThreadPoolExecutor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/thread/IgniteStripedThreadPoolExecutor.java b/modules/core/src/main/java/org/apache/ignite/thread/IgniteStripedThreadPoolExecutor.java index 761dba6..35882b9 100644 --- a/modules/core/src/main/java/org/apache/ignite/thread/IgniteStripedThreadPoolExecutor.java +++ b/modules/core/src/main/java/org/apache/ignite/thread/IgniteStripedThreadPoolExecutor.java @@ -17,10 +17,18 @@ package org.apache.ignite.thread; -import org.apache.ignite.internal.util.typedef.internal.*; - -import java.util.*; -import java.util.concurrent.*; +import java.util.Collection; +import java.util.LinkedList; +import java.util.List; +import java.util.concurrent.Callable; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.concurrent.Future; +import java.util.concurrent.ThreadFactory; +import java.util.concurrent.TimeUnit; +import java.util.concurrent.TimeoutException; +import org.apache.ignite.internal.util.typedef.internal.S; /** * An {@link ExecutorService} that executes submitted tasks using pooled grid threads. @@ -221,4 +229,4 @@ public class IgniteStripedThreadPoolExecutor implements ExecutorService { @Override public String toString() { return S.toString(IgniteStripedThreadPoolExecutor.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/thread/IgniteThread.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/thread/IgniteThread.java b/modules/core/src/main/java/org/apache/ignite/thread/IgniteThread.java index a956e30..6ea77ae 100644 --- a/modules/core/src/main/java/org/apache/ignite/thread/IgniteThread.java +++ b/modules/core/src/main/java/org/apache/ignite/thread/IgniteThread.java @@ -17,10 +17,9 @@ package org.apache.ignite.thread; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.internal.util.worker.*; - -import java.util.concurrent.atomic.*; +import java.util.concurrent.atomic.AtomicLong; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.worker.GridWorker; /** * This class adds some necessary plumbing on top of the {@link Thread} class. @@ -105,4 +104,4 @@ public class IgniteThread extends Thread { @Override public String toString() { return S.toString(IgniteThread.class, this, "name", getName()); } -} +} \ 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/thread/IgniteThreadFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/thread/IgniteThreadFactory.java b/modules/core/src/main/java/org/apache/ignite/thread/IgniteThreadFactory.java index 57cdb49..cd0a9cc 100644 --- a/modules/core/src/main/java/org/apache/ignite/thread/IgniteThreadFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/thread/IgniteThreadFactory.java @@ -17,9 +17,8 @@ package org.apache.ignite.thread; -import org.jetbrains.annotations.*; - -import java.util.concurrent.*; +import java.util.concurrent.ThreadFactory; +import org.jetbrains.annotations.NotNull; /** * This class provides implementation of {@link ThreadFactory} factory @@ -58,4 +57,4 @@ public class IgniteThreadFactory implements ThreadFactory { @Override public Thread newThread(@NotNull Runnable r) { return new IgniteThread(gridName, threadName, r); } -} +} \ 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/thread/IgniteThreadPoolExecutor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/thread/IgniteThreadPoolExecutor.java b/modules/core/src/main/java/org/apache/ignite/thread/IgniteThreadPoolExecutor.java index e0ba3d1..0af422f 100644 --- a/modules/core/src/main/java/org/apache/ignite/thread/IgniteThreadPoolExecutor.java +++ b/modules/core/src/main/java/org/apache/ignite/thread/IgniteThreadPoolExecutor.java @@ -17,9 +17,14 @@ package org.apache.ignite.thread; -import org.jetbrains.annotations.*; - -import java.util.concurrent.*; +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.LinkedBlockingDeque; +import java.util.concurrent.RejectedExecutionHandler; +import java.util.concurrent.ThreadFactory; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.TimeUnit; +import org.jetbrains.annotations.Nullable; /** * An {@link ExecutorService} that executes submitted tasks using pooled grid threads. @@ -247,4 +252,4 @@ public class IgniteThreadPoolExecutor extends ThreadPoolExecutor { hnd == null ? new AbortPolicy() : hnd ); } -} +} \ 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/transactions/Transaction.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/Transaction.java b/modules/core/src/main/java/org/apache/ignite/transactions/Transaction.java index 256dcb4..a6e960d 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/Transaction.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/Transaction.java @@ -17,10 +17,12 @@ package org.apache.ignite.transactions; -import org.apache.ignite.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.UUID; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteTransactions; +import org.apache.ignite.lang.IgniteAsyncSupport; +import org.apache.ignite.lang.IgniteAsyncSupported; +import org.apache.ignite.lang.IgniteUuid; /** * Grid cache transaction. Cache transactions have a default 2PC (two-phase-commit) behavior and @@ -241,4 +243,4 @@ public interface Transaction extends AutoCloseable, IgniteAsyncSupport { */ @IgniteAsyncSupported public void rollback() throws IgniteException; -} +} \ 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/transactions/TransactionConcurrency.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionConcurrency.java b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionConcurrency.java index 64265a1..5b2aff1 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionConcurrency.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionConcurrency.java @@ -17,7 +17,7 @@ package org.apache.ignite.transactions; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * Transaction concurrency control. See {@link Transaction} for more information @@ -42,4 +42,4 @@ public enum TransactionConcurrency { @Nullable public static TransactionConcurrency fromOrdinal(int ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : 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/transactions/TransactionHeuristicException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionHeuristicException.java b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionHeuristicException.java index fa82cf9..b3cc77c 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionHeuristicException.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionHeuristicException.java @@ -17,7 +17,7 @@ package org.apache.ignite.transactions; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; /** * Exception thrown whenever grid transaction enters an unknown state. @@ -48,4 +48,4 @@ public class TransactionHeuristicException extends IgniteException { public TransactionHeuristicException(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/transactions/TransactionIsolation.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionIsolation.java b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionIsolation.java index 1bc7f12..d7671f0 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionIsolation.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionIsolation.java @@ -17,7 +17,7 @@ package org.apache.ignite.transactions; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * Defines different cache transaction isolation levels. See {@link Transaction} @@ -46,4 +46,4 @@ public enum TransactionIsolation { public static TransactionIsolation fromOrdinal(int ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : 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/transactions/TransactionMetrics.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionMetrics.java b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionMetrics.java index 0fd8f55..a5af51e 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionMetrics.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionMetrics.java @@ -17,7 +17,7 @@ package org.apache.ignite.transactions; -import java.io.*; +import java.io.Serializable; /** * Transaction metrics, shared across all caches. @@ -50,4 +50,4 @@ public interface TransactionMetrics extends Serializable { * @return Number of transaction rollbacks. */ public int txRollbacks(); -} +} \ 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/transactions/TransactionOptimisticException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionOptimisticException.java b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionOptimisticException.java index 4dd9e12..7b8ad8e 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionOptimisticException.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionOptimisticException.java @@ -17,7 +17,7 @@ package org.apache.ignite.transactions; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; /** * Exception thrown whenever grid transactions fail optimistically. @@ -44,4 +44,4 @@ public class TransactionOptimisticException extends IgniteException { public TransactionOptimisticException(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/transactions/TransactionRollbackException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionRollbackException.java b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionRollbackException.java index c551328..d60087b 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionRollbackException.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionRollbackException.java @@ -17,7 +17,7 @@ package org.apache.ignite.transactions; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; /** * Exception thrown whenever grid transactions has been automatically rolled back. @@ -44,4 +44,4 @@ public class TransactionRollbackException extends IgniteException { public TransactionRollbackException(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/transactions/TransactionState.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionState.java b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionState.java index 5cacbf5..1980242 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionState.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionState.java @@ -17,7 +17,7 @@ package org.apache.ignite.transactions; -import org.jetbrains.annotations.*; +import org.jetbrains.annotations.Nullable; /** * Cache transaction state. @@ -62,4 +62,4 @@ public enum TransactionState { @Nullable public static TransactionState fromOrdinal(int ord) { return ord >= 0 && ord < VALS.length ? VALS[ord] : 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/transactions/TransactionTimeoutException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionTimeoutException.java b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionTimeoutException.java index 019c9dc..970672e 100644 --- a/modules/core/src/main/java/org/apache/ignite/transactions/TransactionTimeoutException.java +++ b/modules/core/src/main/java/org/apache/ignite/transactions/TransactionTimeoutException.java @@ -17,7 +17,7 @@ package org.apache.ignite.transactions; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; /** * Exception thrown whenever grid transactions time out. @@ -44,4 +44,4 @@ public class TransactionTimeoutException extends IgniteException { public TransactionTimeoutException(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/jetbrains/annotations/NotNull.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/jetbrains/annotations/NotNull.java b/modules/core/src/main/java/org/jetbrains/annotations/NotNull.java index 764868d..66c66f3 100644 --- a/modules/core/src/main/java/org/jetbrains/annotations/NotNull.java +++ b/modules/core/src/main/java/org/jetbrains/annotations/NotNull.java @@ -16,7 +16,11 @@ package org.jetbrains.annotations; -import java.lang.annotation.*; +import java.lang.annotation.Documented; +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; /** * An element annotated with NotNull claims <code>null</code> value is <em>forbidden</em> @@ -31,4 +35,4 @@ import java.lang.annotation.*; @Target({ElementType.METHOD, ElementType.FIELD, ElementType.PARAMETER, ElementType.LOCAL_VARIABLE}) public @interface NotNull { String value() default ""; -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/jsr166/ConcurrentHashMap8.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/jsr166/ConcurrentHashMap8.java b/modules/core/src/main/java/org/jsr166/ConcurrentHashMap8.java index 0b60ff7..d93f12e 100644 --- a/modules/core/src/main/java/org/jsr166/ConcurrentHashMap8.java +++ b/modules/core/src/main/java/org/jsr166/ConcurrentHashMap8.java @@ -15,10 +15,20 @@ package org.jsr166; -import java.io.*; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.locks.*; +import java.io.Serializable; +import java.util.AbstractMap; +import java.util.Arrays; +import java.util.Collection; +import java.util.ConcurrentModificationException; +import java.util.Enumeration; +import java.util.HashMap; +import java.util.Hashtable; +import java.util.Iterator; +import java.util.Map; +import java.util.NoSuchElementException; +import java.util.Set; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.locks.AbstractQueuedSynchronizer; /** * A hash table supporting full concurrency of retrievals and @@ -3795,4 +3805,4 @@ public class ConcurrentHashMap8<K, V> } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/jsr166/ConcurrentLinkedDeque8.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/jsr166/ConcurrentLinkedDeque8.java b/modules/core/src/main/java/org/jsr166/ConcurrentLinkedDeque8.java index 9c8c2db..75db13c 100644 --- a/modules/core/src/main/java/org/jsr166/ConcurrentLinkedDeque8.java +++ b/modules/core/src/main/java/org/jsr166/ConcurrentLinkedDeque8.java @@ -15,12 +15,18 @@ package org.jsr166; -import sun.misc.*; - -import java.lang.reflect.*; -import java.security.*; -import java.util.*; +import java.lang.reflect.Field; +import java.security.AccessController; +import java.security.PrivilegedActionException; +import java.security.PrivilegedExceptionAction; +import java.util.AbstractCollection; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Deque; +import java.util.Iterator; +import java.util.NoSuchElementException; import java.util.Queue; +import sun.misc.Unsafe; /** @@ -1729,4 +1735,4 @@ public class ConcurrentLinkedDeque8<E> } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/jsr166/ConcurrentLinkedHashMap.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/jsr166/ConcurrentLinkedHashMap.java b/modules/core/src/main/java/org/jsr166/ConcurrentLinkedHashMap.java index 1de7cc1..5b7381e 100644 --- a/modules/core/src/main/java/org/jsr166/ConcurrentLinkedHashMap.java +++ b/modules/core/src/main/java/org/jsr166/ConcurrentLinkedHashMap.java @@ -11,11 +11,27 @@ package org.jsr166; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.locks.*; - -import static org.jsr166.ConcurrentLinkedHashMap.QueuePolicy.*; +import java.util.AbstractCollection; +import java.util.AbstractMap; +import java.util.AbstractSet; +import java.util.ArrayDeque; +import java.util.Collection; +import java.util.ConcurrentModificationException; +import java.util.Deque; +import java.util.Enumeration; +import java.util.HashMap; +import java.util.Hashtable; +import java.util.Iterator; +import java.util.Map; +import java.util.NoSuchElementException; +import java.util.Queue; +import java.util.Set; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.locks.ReentrantReadWriteLock; + +import static org.jsr166.ConcurrentLinkedHashMap.QueuePolicy.PER_SEGMENT_Q; +import static org.jsr166.ConcurrentLinkedHashMap.QueuePolicy.PER_SEGMENT_Q_OPTIMIZED_RMV; +import static org.jsr166.ConcurrentLinkedHashMap.QueuePolicy.SINGLE_Q; /** * A hash table supporting full concurrency of retrievals and @@ -2147,4 +2163,4 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements */ PER_SEGMENT_Q_OPTIMIZED_RMV } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/jsr166/LongAdder8.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/jsr166/LongAdder8.java b/modules/core/src/main/java/org/jsr166/LongAdder8.java index 79ea32e..2535cf4 100644 --- a/modules/core/src/main/java/org/jsr166/LongAdder8.java +++ b/modules/core/src/main/java/org/jsr166/LongAdder8.java @@ -14,8 +14,10 @@ package org.jsr166; -import java.io.*; -import java.util.concurrent.atomic.*; +import java.io.IOException; +import java.io.ObjectInputStream; +import java.io.Serializable; +import java.util.concurrent.atomic.AtomicLong; /** * One or more variables that together maintain an initially zero @@ -206,4 +208,4 @@ public class LongAdder8 extends Striped64_8 implements Serializable { base = s.readLong(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/jsr166/Striped64_8.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/jsr166/Striped64_8.java b/modules/core/src/main/java/org/jsr166/Striped64_8.java index 7281334..6f2f4f6 100644 --- a/modules/core/src/main/java/org/jsr166/Striped64_8.java +++ b/modules/core/src/main/java/org/jsr166/Striped64_8.java @@ -14,7 +14,7 @@ package org.jsr166; -import java.util.*; +import java.util.Random; /** * A package-local class holding common representation and mechanics @@ -347,4 +347,4 @@ abstract class Striped64_8 extends Number { } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridCacheAffinityBackupsSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridCacheAffinityBackupsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/GridCacheAffinityBackupsSelfTest.java index 212eb23..50ba241 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridCacheAffinityBackupsSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/GridCacheAffinityBackupsSelfTest.java @@ -17,14 +17,16 @@ package org.apache.ignite; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.affinity.fair.*; -import org.apache.ignite.cache.affinity.rendezvous.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.testframework.junits.common.*; - -import java.util.*; +import java.util.Collection; +import java.util.HashSet; +import java.util.UUID; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.cache.affinity.fair.FairAffinityFunction; +import org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; /** * Tests affinity function with different number of backups. @@ -101,4 +103,4 @@ public class GridCacheAffinityBackupsSelfTest extends GridCommonAbstractTest { stopAllGrids(); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridSuppressedExceptionSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridSuppressedExceptionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/GridSuppressedExceptionSelfTest.java index 4c27d50..2485cbb 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridSuppressedExceptionSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/GridSuppressedExceptionSelfTest.java @@ -17,10 +17,9 @@ package org.apache.ignite; -import junit.framework.*; -import org.apache.ignite.internal.util.typedef.*; - -import java.io.*; +import java.io.IOException; +import junit.framework.TestCase; +import org.apache.ignite.internal.util.typedef.X; /** * @@ -139,4 +138,4 @@ public class GridSuppressedExceptionSelfTest extends TestCase { else generateException(calls - 1, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridTestIoUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridTestIoUtils.java b/modules/core/src/test/java/org/apache/ignite/GridTestIoUtils.java index 2dc5faa..de09e06 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestIoUtils.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestIoUtils.java @@ -17,14 +17,24 @@ package org.apache.ignite; -import org.apache.commons.io.*; -import org.apache.ignite.marshaller.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.util.*; - -import static junit.framework.Assert.*; +import java.io.ByteArrayInputStream; +import java.io.ByteArrayOutputStream; +import java.io.Closeable; +import java.io.Externalizable; +import java.io.IOException; +import java.io.InputStream; +import java.io.ObjectInputStream; +import java.io.ObjectOutputStream; +import java.io.ObjectStreamClass; +import java.io.Serializable; +import java.util.Arrays; +import org.apache.commons.io.IOUtils; +import org.apache.ignite.marshaller.Marshaller; +import org.jetbrains.annotations.Nullable; + +import static junit.framework.Assert.assertEquals; +import static junit.framework.Assert.assertTrue; +import static junit.framework.Assert.fail; /** * IO test utilities. @@ -195,4 +205,4 @@ public final class GridTestIoUtils { private GridTestIoUtils() { // No-op. } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridTestJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridTestJob.java b/modules/core/src/test/java/org/apache/ignite/GridTestJob.java index 018d2c5..a4dbe53 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestJob.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestJob.java @@ -17,8 +17,8 @@ package org.apache.ignite; -import org.apache.ignite.compute.*; -import org.apache.ignite.resources.*; +import org.apache.ignite.compute.ComputeJobAdapter; +import org.apache.ignite.resources.LoggerResource; /** * Test job. @@ -47,4 +47,4 @@ public class GridTestJob extends ComputeJobAdapter { return argument(0); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridTestJobContext.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridTestJobContext.java b/modules/core/src/test/java/org/apache/ignite/GridTestJobContext.java index cb8c187..2ad9e61 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestJobContext.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestJobContext.java @@ -17,11 +17,11 @@ package org.apache.ignite; -import org.apache.ignite.compute.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.HashMap; +import java.util.Map; +import org.apache.ignite.compute.ComputeJobContext; +import org.apache.ignite.lang.IgniteUuid; +import org.jetbrains.annotations.Nullable; /** * Test job context. @@ -90,4 +90,4 @@ public class GridTestJobContext implements ComputeJobContext { @Override public void callcc() { // No-op. } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java b/modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java index 74c18e8..cdba72b 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestJobResult.java @@ -17,10 +17,11 @@ package org.apache.ignite; -import org.apache.ignite.cluster.*; -import org.apache.ignite.compute.*; - -import java.io.*; +import java.io.Serializable; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.compute.ComputeJob; +import org.apache.ignite.compute.ComputeJobContext; +import org.apache.ignite.compute.ComputeJobResult; /** * Test job result. @@ -92,4 +93,4 @@ public class GridTestJobResult implements ComputeJobResult { /** {@inheritDoc} */ @Override public ClusterNode getNode() { return node; } /** {@inheritDoc} */ @Override public ComputeJobContext getJobContext() { return jobCtx; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridTestNodeStartup.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridTestNodeStartup.java b/modules/core/src/test/java/org/apache/ignite/GridTestNodeStartup.java index 5b43c88..386db54 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestNodeStartup.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestNodeStartup.java @@ -17,9 +17,8 @@ package org.apache.ignite; -import org.apache.ignite.internal.util.typedef.*; - -import javax.swing.*; +import javax.swing.JOptionPane; +import org.apache.ignite.internal.util.typedef.G; /** * Starts test node. @@ -46,4 +45,4 @@ public class GridTestNodeStartup { G.stopAll(false); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridTestStoreNodeStartup.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridTestStoreNodeStartup.java b/modules/core/src/test/java/org/apache/ignite/GridTestStoreNodeStartup.java index f79dc6e..1e4bbc9 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestStoreNodeStartup.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestStoreNodeStartup.java @@ -17,9 +17,9 @@ package org.apache.ignite; -import org.apache.ignite.internal.util.typedef.*; - -import javax.swing.*; +import javax.swing.JOptionPane; +import org.apache.ignite.internal.util.typedef.G; +import org.apache.ignite.internal.util.typedef.P2; /** * Starts test node. @@ -54,4 +54,4 @@ public class GridTestStoreNodeStartup { G.stopAll(false); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridTestTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridTestTask.java b/modules/core/src/test/java/org/apache/ignite/GridTestTask.java index 08a0994..dbe34c6 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestTask.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestTask.java @@ -17,10 +17,13 @@ package org.apache.ignite; -import org.apache.ignite.compute.*; -import org.apache.ignite.resources.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.List; +import org.apache.ignite.compute.ComputeJob; +import org.apache.ignite.compute.ComputeJobResult; +import org.apache.ignite.compute.ComputeTaskSplitAdapter; +import org.apache.ignite.resources.LoggerResource; /** * Test task. @@ -50,4 +53,4 @@ public class GridTestTask extends ComputeTaskSplitAdapter<Object, Object> { return results; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java b/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java index d2439a5..618cdbb 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java @@ -17,11 +17,19 @@ package org.apache.ignite; -import org.apache.ignite.compute.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.HashMap; +import java.util.Map; +import java.util.UUID; +import org.apache.ignite.compute.ComputeJobSibling; +import org.apache.ignite.compute.ComputeTaskSession; +import org.apache.ignite.compute.ComputeTaskSessionAttributeListener; +import org.apache.ignite.compute.ComputeTaskSessionScope; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgniteUuid; +import org.jetbrains.annotations.Nullable; /** * Test task session. @@ -230,4 +238,4 @@ public class GridTestTaskSession implements ComputeTaskSession { return buf.toString(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/IgniteCacheAffinitySelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/IgniteCacheAffinitySelfTest.java b/modules/core/src/test/java/org/apache/ignite/IgniteCacheAffinitySelfTest.java index 3679cdd..3d76268 100644 --- a/modules/core/src/test/java/org/apache/ignite/IgniteCacheAffinitySelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/IgniteCacheAffinitySelfTest.java @@ -17,19 +17,25 @@ package org.apache.ignite; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cache.affinity.fair.*; -import org.apache.ignite.cache.affinity.rendezvous.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import org.apache.ignite.cache.CacheAtomicityMode; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.cache.affinity.Affinity; +import org.apache.ignite.cache.affinity.fair.FairAffinityFunction; +import org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.configuration.NearCacheConfiguration; import org.apache.ignite.internal.processors.affinity.GridAffinityProcessor; -import org.apache.ignite.internal.processors.cache.*; +import org.apache.ignite.internal.processors.cache.IgniteCacheAbstractTest; -import java.util.*; - -import static org.apache.ignite.cache.CacheAtomicityMode.*; -import static org.apache.ignite.cache.CacheMode.*; +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; +import static org.apache.ignite.cache.CacheMode.PARTITIONED; /** * Tests for {@link GridAffinityProcessor.CacheAffinityProxy}. @@ -312,4 +318,4 @@ public class IgniteCacheAffinitySelfTest extends IgniteCacheAbstractTest { private Collection<ClusterNode> nodes() { return grid(0).cluster().nodes(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/IgniteExternalizableAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/IgniteExternalizableAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/IgniteExternalizableAbstractTest.java index 7078dde..63436ab 100644 --- a/modules/core/src/test/java/org/apache/ignite/IgniteExternalizableAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/IgniteExternalizableAbstractTest.java @@ -17,12 +17,14 @@ package org.apache.ignite; -import org.apache.ignite.marshaller.*; -import org.apache.ignite.marshaller.jdk.*; -import org.apache.ignite.marshaller.optimized.*; -import org.apache.ignite.testframework.junits.common.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.List; +import org.apache.ignite.marshaller.Marshaller; +import org.apache.ignite.marshaller.MarshallerContext; +import org.apache.ignite.marshaller.MarshallerContextTestImpl; +import org.apache.ignite.marshaller.jdk.JdkMarshaller; +import org.apache.ignite.marshaller.optimized.OptimizedMarshaller; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; /** * Base externalizable test class. @@ -46,4 +48,4 @@ public class IgniteExternalizableAbstractTest extends GridCommonAbstractTest { return marshallers; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/cache/IgniteWarmupClosureSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/IgniteWarmupClosureSelfTest.java b/modules/core/src/test/java/org/apache/ignite/cache/IgniteWarmupClosureSelfTest.java index 4d91347..c9671fd 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/IgniteWarmupClosureSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/IgniteWarmupClosureSelfTest.java @@ -17,12 +17,13 @@ package org.apache.ignite.cache; -import org.apache.ignite.configuration.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; -import org.apache.ignite.startup.*; -import org.apache.ignite.testframework.junits.common.*; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; +import org.apache.ignite.startup.BasicWarmupClosure; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; /** * @@ -79,4 +80,4 @@ public class IgniteWarmupClosureSelfTest extends GridCommonAbstractTest { public void testWarmupClosure() throws Exception { startGrid(1); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java b/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java index da27fb2..888904b 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java @@ -17,21 +17,23 @@ package org.apache.ignite.cache.affinity; -import org.apache.ignite.*; -import org.apache.ignite.cache.affinity.fair.*; -import org.apache.ignite.cache.affinity.rendezvous.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; -import org.apache.ignite.testframework.junits.common.*; - -import java.util.*; - -import static org.apache.ignite.cache.CacheMode.*; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.cache.affinity.fair.FairAffinityFunction; +import org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.configuration.NearCacheConfiguration; +import org.apache.ignite.internal.IgniteNodeAttributes; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; + +import static org.apache.ignite.cache.CacheMode.REPLICATED; /** * @@ -189,4 +191,4 @@ public class IgniteClientNodeAffinityTest extends GridCommonAbstractTest { return true; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionNodesSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionNodesSelfTest.java b/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionNodesSelfTest.java index b000b8d..cf57b66 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionNodesSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionNodesSelfTest.java @@ -17,16 +17,19 @@ package org.apache.ignite.cache.affinity.fair; -import org.apache.ignite.cache.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; -import org.apache.ignite.testframework.junits.common.*; - -import java.util.*; +import java.util.Collection; +import java.util.List; +import java.util.TreeSet; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.IgniteEx; +import org.apache.ignite.internal.IgniteKernal; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; /** * Tests partition fair affinity in real grid. @@ -239,4 +242,4 @@ public class GridFairAffinityFunctionNodesSelfTest extends GridCommonAbstractTes throw new IllegalStateException(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionSelfTest.java b/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionSelfTest.java index dcf4508..e746b42 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/GridFairAffinityFunctionSelfTest.java @@ -17,14 +17,22 @@ package org.apache.ignite.cache.affinity.fair; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.events.*; -import org.apache.ignite.internal.processors.affinity.*; -import org.apache.ignite.testframework.*; -import org.apache.ignite.testframework.junits.common.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Map; +import java.util.Random; +import java.util.UUID; +import org.apache.ignite.cache.affinity.AffinityFunction; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.events.DiscoveryEvent; +import org.apache.ignite.events.EventType; +import org.apache.ignite.internal.processors.affinity.AffinityTopologyVersion; +import org.apache.ignite.internal.processors.affinity.GridAffinityFunctionContextImpl; +import org.apache.ignite.testframework.GridTestNode; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; /** * @@ -259,4 +267,4 @@ public class GridFairAffinityFunctionSelfTest extends GridCommonAbstractTest { private static int deviation(int val, int ideal) { return Math.round(Math.abs(((float)val - ideal) / ideal * 100)); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/IgniteFairAffinityDynamicCacheSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/IgniteFairAffinityDynamicCacheSelfTest.java b/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/IgniteFairAffinityDynamicCacheSelfTest.java index e51be58..eb1c455 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/IgniteFairAffinityDynamicCacheSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/affinity/fair/IgniteFairAffinityDynamicCacheSelfTest.java @@ -17,17 +17,18 @@ package org.apache.ignite.cache.affinity.fair; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; -import org.apache.ignite.testframework.*; -import org.apache.ignite.testframework.junits.common.*; - -import java.util.concurrent.*; +import java.util.concurrent.Callable; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.cache.CacheAtomicityMode; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.IgniteInternalFuture; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; +import org.apache.ignite.testframework.GridTestUtils; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; /** * @@ -93,4 +94,4 @@ public class IgniteFairAffinityDynamicCacheSelfTest extends GridCommonAbstractTe destFut.get(2000L); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerAbstractSelfTest.java index 8e53f05..010f1da 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/store/CacheStoreSessionListenerAbstractSelfTest.java @@ -17,21 +17,25 @@ package org.apache.ignite.cache.store; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; -import org.apache.ignite.testframework.junits.common.*; -import org.apache.ignite.transactions.*; - -import javax.cache.configuration.*; -import javax.cache.integration.*; -import java.io.*; -import java.sql.*; -import java.util.concurrent.atomic.*; +import java.io.Serializable; +import java.sql.Connection; +import java.sql.DriverManager; +import java.sql.ResultSet; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.concurrent.atomic.AtomicInteger; +import javax.cache.configuration.Factory; +import javax.cache.integration.CacheWriterException; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cache.CacheAtomicityMode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.internal.util.typedef.X; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; +import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; +import org.apache.ignite.transactions.Transaction; /** * Tests for store session listeners. @@ -330,4 +334,4 @@ public abstract class CacheStoreSessionListenerAbstractSelfTest extends GridComm * @return Session listener factory. */ protected abstract Factory<CacheStoreSessionListener> sessionListenerFactory(); -} +} \ No newline at end of file
