http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionInternal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionInternal.java b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionInternal.java index ea3be2d..7d371e7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionInternal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionInternal.java @@ -17,11 +17,10 @@ package org.apache.ignite.internal; -import org.apache.ignite.compute.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.UUID; +import org.apache.ignite.compute.ComputeTaskSession; +import org.apache.ignite.lang.IgniteUuid; +import org.jetbrains.annotations.Nullable; /** * Internal task session interface. @@ -66,4 +65,4 @@ public interface GridTaskSessionInternal extends ComputeTaskSession { * @return Subject ID. */ public UUID subjectId(); -} +} \ 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/GridTaskSessionRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java index 42e1506..02d17db 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTaskSessionRequest.java @@ -17,13 +17,14 @@ package org.apache.ignite.internal; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.plugin.extensions.communication.*; - -import java.io.*; -import java.nio.*; -import java.util.*; +import java.io.Externalizable; +import java.nio.ByteBuffer; +import java.util.Map; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.lang.IgniteUuid; +import org.apache.ignite.plugin.extensions.communication.Message; +import org.apache.ignite.plugin.extensions.communication.MessageReader; +import org.apache.ignite.plugin.extensions.communication.MessageWriter; /** * Task session request. @@ -183,4 +184,4 @@ public class GridTaskSessionRequest implements Message { @Override public String toString() { return S.toString(GridTaskSessionRequest.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/GridTopic.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java b/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java index ba3b8b2..fbf2b18 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridTopic.java @@ -17,13 +17,17 @@ package org.apache.ignite.internal; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.nio.charset.*; -import java.util.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.Serializable; +import java.nio.charset.Charset; +import java.util.UUID; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteUuid; +import org.jetbrains.annotations.Nullable; /** * Communication topic. @@ -756,4 +760,4 @@ public enum GridTopic { return S.toString(T8.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/GridUpdateNotifier.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java b/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java index dc22128..448f87b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/GridUpdateNotifier.java @@ -17,22 +17,40 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -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.plugin.*; -import org.jetbrains.annotations.*; -import org.w3c.dom.*; -import org.xml.sax.*; - -import javax.xml.parsers.*; -import java.io.*; -import java.net.*; -import java.util.*; -import java.util.concurrent.*; - -import static java.net.URLEncoder.*; +import java.io.BufferedReader; +import java.io.ByteArrayInputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.io.OutputStream; +import java.io.PrintWriter; +import java.io.StringReader; +import java.io.StringWriter; +import java.net.URL; +import java.net.URLConnection; +import java.util.Collection; +import java.util.Map; +import java.util.concurrent.Executor; +import java.util.concurrent.RejectedExecutionException; +import javax.xml.parsers.DocumentBuilder; +import javax.xml.parsers.DocumentBuilderFactory; +import javax.xml.parsers.ParserConfigurationException; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.SB; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.internal.util.worker.GridWorker; +import org.apache.ignite.plugin.PluginProvider; +import org.jetbrains.annotations.Nullable; +import org.w3c.dom.Document; +import org.w3c.dom.Element; +import org.w3c.dom.Node; +import org.w3c.dom.NodeList; +import org.xml.sax.EntityResolver; +import org.xml.sax.InputSource; + +import static java.net.URLEncoder.encode; /** * This class is responsible for notification about new version availability. @@ -401,4 +419,4 @@ class GridUpdateNotifier { return obtainMeta("downloadUrl", node); } } -} +} \ 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/IgniteClientDisconnectedCheckedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteClientDisconnectedCheckedException.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteClientDisconnectedCheckedException.java index e58530d..e9079f9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteClientDisconnectedCheckedException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteClientDisconnectedCheckedException.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.lang.IgniteFuture; /** * @@ -46,4 +46,4 @@ public class IgniteClientDisconnectedCheckedException extends IgniteCheckedExcep public IgniteFuture<?> reconnectFuture() { return reconnectFut; } -} +} \ 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/IgniteCodeGeneratingFail.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteCodeGeneratingFail.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteCodeGeneratingFail.java index 8c4ce2e..e682139 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteCodeGeneratingFail.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteCodeGeneratingFail.java @@ -17,7 +17,10 @@ package org.apache.ignite.internal; -import java.lang.annotation.*; +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; /** * Annotates fields that code generator should not be override. @@ -26,4 +29,4 @@ import java.lang.annotation.*; @Target(ElementType.TYPE) public @interface IgniteCodeGeneratingFail { // 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/IgniteComponentType.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteComponentType.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteComponentType.java index 4b937b1..01872b6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteComponentType.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteComponentType.java @@ -17,12 +17,11 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.plugin.extensions.communication.*; -import org.jetbrains.annotations.*; - -import java.lang.reflect.*; +import java.lang.reflect.Constructor; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.plugin.extensions.communication.MessageFactory; +import org.jetbrains.annotations.Nullable; /** * Component type. @@ -314,4 +313,4 @@ public enum IgniteComponentType { return new IgniteCheckedException("Failed to create Ignite component (consider adding " + module + " module to classpath) [component=" + this + ", cls=" + clsName + ']', err); } -} +} \ 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/IgniteComputeImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteComputeImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteComputeImpl.java index 85fefa5..d6e9a8d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteComputeImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteComputeImpl.java @@ -17,21 +17,41 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.internal.cluster.*; -import org.apache.ignite.internal.managers.deployment.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.util.*; -import java.util.concurrent.*; - -import static org.apache.ignite.internal.GridClosureCallMode.*; -import static org.apache.ignite.internal.processors.task.GridTaskThreadContextKey.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.ObjectStreamException; +import java.util.Arrays; +import java.util.Collection; +import java.util.Map; +import java.util.UUID; +import java.util.concurrent.Callable; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteCompute; +import org.apache.ignite.IgniteDeploymentException; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.compute.ComputeTask; +import org.apache.ignite.compute.ComputeTaskFuture; +import org.apache.ignite.internal.cluster.ClusterGroupAdapter; +import org.apache.ignite.internal.managers.deployment.GridDeployment; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteCallable; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgniteReducer; +import org.apache.ignite.lang.IgniteRunnable; +import org.apache.ignite.lang.IgniteUuid; +import org.jetbrains.annotations.Nullable; + +import static org.apache.ignite.internal.GridClosureCallMode.BALANCE; +import static org.apache.ignite.internal.GridClosureCallMode.BROADCAST; +import static org.apache.ignite.internal.processors.task.GridTaskThreadContextKey.TC_NO_FAILOVER; +import static org.apache.ignite.internal.processors.task.GridTaskThreadContextKey.TC_SUBGRID; +import static org.apache.ignite.internal.processors.task.GridTaskThreadContextKey.TC_SUBJ_ID; +import static org.apache.ignite.internal.processors.task.GridTaskThreadContextKey.TC_TASK_NAME; +import static org.apache.ignite.internal.processors.task.GridTaskThreadContextKey.TC_TIMEOUT; /** * {@link IgniteCompute} implementation. @@ -561,4 +581,4 @@ public class IgniteComputeImpl extends AsyncSupportAdapter<IgniteCompute> @Override public <R> ComputeTaskFuture<R> future() { return (ComputeTaskFuture<R>)super.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/IgniteDeploymentCheckedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteDeploymentCheckedException.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteDeploymentCheckedException.java index 03450f1..d08d3c0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteDeploymentCheckedException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteDeploymentCheckedException.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteCheckedException; +import org.jetbrains.annotations.Nullable; /** * Deployment or re-deployment failed. @@ -55,4 +55,4 @@ public class IgniteDeploymentCheckedException extends IgniteCheckedException { public IgniteDeploymentCheckedException(String msg, @Nullable Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/IgniteEventsImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteEventsImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteEventsImpl.java index c27be6b..505bc9d 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteEventsImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteEventsImpl.java @@ -17,17 +17,25 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.events.*; -import org.apache.ignite.internal.cluster.*; -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.io.*; -import java.util.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.ObjectStreamException; +import java.util.Collection; +import java.util.List; +import java.util.UUID; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteEvents; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.events.Event; +import org.apache.ignite.internal.cluster.ClusterGroupAdapter; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.lang.IgnitePredicate; +import org.jetbrains.annotations.Nullable; /** * {@link IgniteEvents} implementation. @@ -306,4 +314,4 @@ public class IgniteEventsImpl extends AsyncSupportAdapter<IgniteEvents> implemen protected Object readResolve() throws ObjectStreamException { return prj.events(); } -} +} \ 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/IgniteEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteEx.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteEx.java index ef733cf..e3859c5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteEx.java @@ -17,16 +17,16 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.internal.cluster.*; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.processors.hadoop.*; -import org.apache.ignite.internal.processors.platform.*; -import org.apache.ignite.lang.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteFileSystem; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.internal.cluster.IgniteClusterEx; +import org.apache.ignite.internal.processors.cache.GridCacheUtilityKey; +import org.apache.ignite.internal.processors.cache.IgniteInternalCache; +import org.apache.ignite.internal.processors.hadoop.Hadoop; +import org.apache.ignite.lang.IgnitePredicate; +import org.jetbrains.annotations.Nullable; /** * Extended Grid interface which provides some additional methods required for kernal and Visor. @@ -140,4 +140,4 @@ public interface IgniteEx extends Ignite { * @return Kernal context. */ public GridKernalContext context(); -} +} \ 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/IgniteFutureCancelledCheckedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureCancelledCheckedException.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureCancelledCheckedException.java index da2f738..5058869 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureCancelledCheckedException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureCancelledCheckedException.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteCheckedException; +import org.jetbrains.annotations.Nullable; /** * Future computation cannot be retrieved because it was cancelled. @@ -55,4 +55,4 @@ public class IgniteFutureCancelledCheckedException extends IgniteCheckedExceptio public IgniteFutureCancelledCheckedException(String msg, @Nullable Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureTimeoutCheckedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureTimeoutCheckedException.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureTimeoutCheckedException.java index 1697577..de9fd59 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureTimeoutCheckedException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteFutureTimeoutCheckedException.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.IgniteCheckedException; +import org.jetbrains.annotations.Nullable; /** * Future computation completion is timed out. @@ -55,4 +55,4 @@ public class IgniteFutureTimeoutCheckedException extends IgniteCheckedException public IgniteFutureTimeoutCheckedException(String msg, @Nullable Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/IgniteInternalFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteInternalFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteInternalFuture.java index 74cfb06..b80a755 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteInternalFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteInternalFuture.java @@ -17,10 +17,11 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.lang.*; - -import java.util.concurrent.*; +import java.util.concurrent.Future; +import java.util.concurrent.TimeUnit; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteInClosure; /** * Extension for standard {@link Future} interface. It adds simplified exception handling, @@ -140,4 +141,4 @@ public interface IgniteInternalFuture<R> { * @return Result value if future has already been completed normally. */ public R result(); -} +} \ 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/IgniteInterruptedCheckedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteInterruptedCheckedException.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteInterruptedCheckedException.java index 282217d..556d39c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteInterruptedCheckedException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteInterruptedCheckedException.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; +import org.apache.ignite.IgniteCheckedException; /** * This exception is used to wrap standard {@link InterruptedException} into {@link IgniteCheckedException}. @@ -55,4 +55,4 @@ public class IgniteInterruptedCheckedException extends IgniteCheckedException { public IgniteInterruptedCheckedException(String msg, InterruptedException cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java index 1db73bf..4ff38c7 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteKernal.java @@ -17,80 +17,203 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.cluster.*; -import org.apache.ignite.internal.managers.*; -import org.apache.ignite.internal.managers.checkpoint.*; -import org.apache.ignite.internal.managers.collision.*; -import org.apache.ignite.internal.managers.communication.*; -import org.apache.ignite.internal.managers.deployment.*; -import org.apache.ignite.internal.managers.discovery.*; -import org.apache.ignite.internal.managers.eventstorage.*; -import org.apache.ignite.internal.managers.failover.*; -import org.apache.ignite.internal.managers.indexing.*; -import org.apache.ignite.internal.managers.loadbalancer.*; -import org.apache.ignite.internal.managers.swapspace.*; -import org.apache.ignite.internal.processors.*; -import org.apache.ignite.internal.processors.affinity.*; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.processors.cache.portable.*; -import org.apache.ignite.internal.processors.cacheobject.*; -import org.apache.ignite.internal.processors.clock.*; -import org.apache.ignite.internal.processors.closure.*; -import org.apache.ignite.internal.processors.cluster.*; -import org.apache.ignite.internal.processors.continuous.*; -import org.apache.ignite.internal.processors.datastreamer.*; -import org.apache.ignite.internal.processors.datastructures.*; -import org.apache.ignite.internal.processors.hadoop.*; -import org.apache.ignite.internal.processors.job.*; -import org.apache.ignite.internal.processors.jobmetrics.*; -import org.apache.ignite.internal.processors.nodevalidation.*; -import org.apache.ignite.internal.processors.offheap.*; -import org.apache.ignite.internal.processors.platform.*; -import org.apache.ignite.internal.processors.plugin.*; -import org.apache.ignite.internal.processors.port.*; -import org.apache.ignite.internal.processors.query.*; -import org.apache.ignite.internal.processors.resource.*; -import org.apache.ignite.internal.processors.rest.*; -import org.apache.ignite.internal.processors.security.*; -import org.apache.ignite.internal.processors.segmentation.*; -import org.apache.ignite.internal.processors.service.*; -import org.apache.ignite.internal.processors.session.*; -import org.apache.ignite.internal.processors.task.*; -import org.apache.ignite.internal.processors.timeout.*; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.internal.util.future.*; -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.lang.*; -import org.apache.ignite.lifecycle.*; -import org.apache.ignite.marshaller.*; -import org.apache.ignite.marshaller.optimized.*; -import org.apache.ignite.mxbean.*; -import org.apache.ignite.plugin.*; -import org.apache.ignite.spi.*; -import org.jetbrains.annotations.*; - -import javax.management.*; -import java.io.*; -import java.lang.management.*; -import java.lang.reflect.*; -import java.text.*; -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; - -import static org.apache.ignite.IgniteSystemProperties.*; -import static org.apache.ignite.internal.GridKernalState.*; -import static org.apache.ignite.internal.IgniteComponentType.*; -import static org.apache.ignite.internal.IgniteNodeAttributes.*; -import static org.apache.ignite.internal.IgniteVersionUtils.*; -import static org.apache.ignite.lifecycle.LifecycleEventType.*; +import java.io.Externalizable; +import java.io.File; +import java.io.IOException; +import java.io.InputStream; +import java.io.InvalidObjectException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.ObjectStreamException; +import java.io.Serializable; +import java.lang.management.ManagementFactory; +import java.lang.management.RuntimeMXBean; +import java.lang.reflect.Constructor; +import java.text.DateFormat; +import java.text.DecimalFormat; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collection; +import java.util.Collections; +import java.util.Date; +import java.util.List; +import java.util.ListIterator; +import java.util.Map; +import java.util.Properties; +import java.util.Timer; +import java.util.UUID; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.concurrent.atomic.AtomicReference; +import javax.management.JMException; +import javax.management.ObjectName; +import org.apache.ignite.IgniteAtomicLong; +import org.apache.ignite.IgniteAtomicReference; +import org.apache.ignite.IgniteAtomicSequence; +import org.apache.ignite.IgniteAtomicStamped; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteClientDisconnectedException; +import org.apache.ignite.IgniteCompute; +import org.apache.ignite.IgniteCountDownLatch; +import org.apache.ignite.IgniteDataStreamer; +import org.apache.ignite.IgniteEvents; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteFileSystem; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.IgniteMessaging; +import org.apache.ignite.IgnitePortables; +import org.apache.ignite.IgniteQueue; +import org.apache.ignite.IgniteScheduler; +import org.apache.ignite.IgniteServices; +import org.apache.ignite.IgniteSet; +import org.apache.ignite.IgniteSystemProperties; +import org.apache.ignite.IgniteTransactions; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.affinity.Affinity; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.cluster.ClusterMetrics; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.CollectionConfiguration; +import org.apache.ignite.configuration.ConnectorConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.configuration.NearCacheConfiguration; +import org.apache.ignite.internal.cluster.ClusterGroupAdapter; +import org.apache.ignite.internal.cluster.IgniteClusterEx; +import org.apache.ignite.internal.managers.GridManager; +import org.apache.ignite.internal.managers.checkpoint.GridCheckpointManager; +import org.apache.ignite.internal.managers.collision.GridCollisionManager; +import org.apache.ignite.internal.managers.communication.GridIoManager; +import org.apache.ignite.internal.managers.deployment.GridDeploymentManager; +import org.apache.ignite.internal.managers.discovery.GridDiscoveryManager; +import org.apache.ignite.internal.managers.eventstorage.GridEventStorageManager; +import org.apache.ignite.internal.managers.failover.GridFailoverManager; +import org.apache.ignite.internal.managers.indexing.GridIndexingManager; +import org.apache.ignite.internal.managers.loadbalancer.GridLoadBalancerManager; +import org.apache.ignite.internal.managers.swapspace.GridSwapSpaceManager; +import org.apache.ignite.internal.processors.GridProcessor; +import org.apache.ignite.internal.processors.affinity.GridAffinityProcessor; +import org.apache.ignite.internal.processors.cache.GridCacheAdapter; +import org.apache.ignite.internal.processors.cache.GridCacheContext; +import org.apache.ignite.internal.processors.cache.GridCacheProcessor; +import org.apache.ignite.internal.processors.cache.GridCacheUtilityKey; +import org.apache.ignite.internal.processors.cache.IgniteCacheProxy; +import org.apache.ignite.internal.processors.cache.IgniteInternalCache; +import org.apache.ignite.internal.processors.cache.portable.CacheObjectPortableProcessor; +import org.apache.ignite.internal.processors.cache.portable.CacheObjectPortableProcessorImpl; +import org.apache.ignite.internal.processors.cacheobject.IgniteCacheObjectProcessor; +import org.apache.ignite.internal.processors.clock.GridClockSyncProcessor; +import org.apache.ignite.internal.processors.closure.GridClosureProcessor; +import org.apache.ignite.internal.processors.cluster.ClusterProcessor; +import org.apache.ignite.internal.processors.continuous.GridContinuousProcessor; +import org.apache.ignite.internal.processors.datastreamer.DataStreamProcessor; +import org.apache.ignite.internal.processors.datastructures.DataStructuresProcessor; +import org.apache.ignite.internal.processors.hadoop.Hadoop; +import org.apache.ignite.internal.processors.job.GridJobProcessor; +import org.apache.ignite.internal.processors.jobmetrics.GridJobMetricsProcessor; +import org.apache.ignite.internal.processors.nodevalidation.DiscoveryNodeValidationProcessor; +import org.apache.ignite.internal.processors.nodevalidation.OsDiscoveryNodeValidationProcessor; +import org.apache.ignite.internal.processors.offheap.GridOffHeapProcessor; +import org.apache.ignite.internal.processors.platform.PlatformNoopProcessor; +import org.apache.ignite.internal.processors.platform.PlatformProcessor; +import org.apache.ignite.internal.processors.plugin.IgnitePluginProcessor; +import org.apache.ignite.internal.processors.port.GridPortProcessor; +import org.apache.ignite.internal.processors.port.GridPortRecord; +import org.apache.ignite.internal.processors.query.GridQueryProcessor; +import org.apache.ignite.internal.processors.resource.GridResourceProcessor; +import org.apache.ignite.internal.processors.resource.GridSpringResourceContext; +import org.apache.ignite.internal.processors.rest.GridRestProcessor; +import org.apache.ignite.internal.processors.security.GridSecurityProcessor; +import org.apache.ignite.internal.processors.segmentation.GridSegmentationProcessor; +import org.apache.ignite.internal.processors.service.GridServiceProcessor; +import org.apache.ignite.internal.processors.session.GridTaskSessionProcessor; +import org.apache.ignite.internal.processors.task.GridTaskProcessor; +import org.apache.ignite.internal.processors.timeout.GridTimeoutProcessor; +import org.apache.ignite.internal.util.GridEnumCache; +import org.apache.ignite.internal.util.GridTimerTask; +import org.apache.ignite.internal.util.future.GridFinishedFuture; +import org.apache.ignite.internal.util.future.GridFutureAdapter; +import org.apache.ignite.internal.util.future.IgniteFutureImpl; +import org.apache.ignite.internal.util.lang.GridAbsClosure; +import org.apache.ignite.internal.util.tostring.GridToStringExclude; +import org.apache.ignite.internal.util.typedef.C1; +import org.apache.ignite.internal.util.typedef.CI1; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.X; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.CU; +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.SB; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.lang.IgniteProductVersion; +import org.apache.ignite.lifecycle.LifecycleAware; +import org.apache.ignite.lifecycle.LifecycleBean; +import org.apache.ignite.lifecycle.LifecycleEventType; +import org.apache.ignite.marshaller.MarshallerExclusions; +import org.apache.ignite.marshaller.optimized.OptimizedMarshaller; +import org.apache.ignite.mxbean.ClusterLocalNodeMetricsMXBean; +import org.apache.ignite.mxbean.IgniteMXBean; +import org.apache.ignite.mxbean.ThreadPoolMXBean; +import org.apache.ignite.plugin.IgnitePlugin; +import org.apache.ignite.plugin.PluginNotFoundException; +import org.apache.ignite.plugin.PluginProvider; +import org.apache.ignite.spi.IgniteSpi; +import org.apache.ignite.spi.IgniteSpiVersionCheckException; +import org.jetbrains.annotations.Nullable; + +import static org.apache.ignite.IgniteSystemProperties.IGNITE_CONFIG_URL; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_DAEMON; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_NO_ASCII; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_SKIP_CONFIGURATION_CONSISTENCY_CHECK; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_STARVATION_CHECK_INTERVAL; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_SUCCESS_FILE; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_UPDATE_NOTIFIER; +import static org.apache.ignite.IgniteSystemProperties.getBoolean; +import static org.apache.ignite.IgniteSystemProperties.snapshot; +import static org.apache.ignite.internal.GridKernalState.DISCONNECTED; +import static org.apache.ignite.internal.GridKernalState.STARTED; +import static org.apache.ignite.internal.GridKernalState.STARTING; +import static org.apache.ignite.internal.GridKernalState.STOPPED; +import static org.apache.ignite.internal.GridKernalState.STOPPING; +import static org.apache.ignite.internal.IgniteComponentType.IGFS; +import static org.apache.ignite.internal.IgniteComponentType.IGFS_HELPER; +import static org.apache.ignite.internal.IgniteComponentType.SCHEDULE; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_BUILD_DATE; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_BUILD_VER; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_CLIENT_MODE; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_CONSISTENCY_CHECK_SKIPPED; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_DAEMON; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_DEPLOYMENT_MODE; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_GRID_NAME; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_IPS; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_JIT_NAME; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_JMX_PORT; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_JVM_ARGS; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_JVM_PID; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_LANG_RUNTIME; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_MACS; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_MARSHALLER; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_NODE_CONSISTENT_ID; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_PEER_CLASSLOADING; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_PHY_RAM; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_PREFIX; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_RESTART_ENABLED; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_REST_PORT_RANGE; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_SPI_CLASS; +import static org.apache.ignite.internal.IgniteNodeAttributes.ATTR_USER_NAME; +import static org.apache.ignite.internal.IgniteVersionUtils.ACK_VER_STR; +import static org.apache.ignite.internal.IgniteVersionUtils.BUILD_TSTAMP_STR; +import static org.apache.ignite.internal.IgniteVersionUtils.COPYRIGHT; +import static org.apache.ignite.internal.IgniteVersionUtils.REV_HASH_STR; +import static org.apache.ignite.internal.IgniteVersionUtils.VER; +import static org.apache.ignite.internal.IgniteVersionUtils.VER_STR; +import static org.apache.ignite.lifecycle.LifecycleEventType.AFTER_NODE_START; +import static org.apache.ignite.lifecycle.LifecycleEventType.BEFORE_NODE_START; /** * Ignite kernal. @@ -3066,4 +3189,4 @@ public class IgniteKernal implements IgniteEx, IgniteMXBean, Externalizable { @Override public String toString() { return S.toString(IgniteKernal.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/IgniteMessagingImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java index d6643a8..17c06fc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteMessagingImpl.java @@ -17,17 +17,24 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.internal.cluster.*; -import org.apache.ignite.internal.processors.continuous.*; -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.io.*; -import java.util.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.ObjectStreamException; +import java.util.Collection; +import java.util.UUID; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteMessaging; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.internal.cluster.ClusterGroupAdapter; +import org.apache.ignite.internal.processors.continuous.GridContinuousHandler; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.jetbrains.annotations.Nullable; /** * {@link IgniteMessaging} implementation. @@ -242,4 +249,4 @@ public class IgniteMessagingImpl extends AsyncSupportAdapter<IgniteMessaging> protected Object readResolve() throws ObjectStreamException { return prj.message(); } -} +} \ 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/IgniteNodeAttributes.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java index 10b8df0..300cc64 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteNodeAttributes.java @@ -141,4 +141,4 @@ public final class IgniteNodeAttributes { private IgniteNodeAttributes() { /* 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/IgniteProperties.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteProperties.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteProperties.java index 74c0ce4..3ea1bfb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteProperties.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteProperties.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal; -import java.io.*; -import java.util.*; +import java.io.IOException; +import java.io.InputStream; +import java.util.Properties; /** * Ignite properties holder. @@ -76,4 +77,4 @@ public class IgniteProperties { private IgniteProperties() { // 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/IgniteSchedulerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteSchedulerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteSchedulerImpl.java index 60513c2..ed8d1a4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteSchedulerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteSchedulerImpl.java @@ -17,14 +17,17 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.internal.util.future.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.scheduler.*; - -import java.io.*; -import java.util.concurrent.*; +import java.io.Externalizable; +import java.io.IOException; +import java.io.ObjectInput; +import java.io.ObjectOutput; +import java.io.ObjectStreamException; +import java.util.concurrent.Callable; +import org.apache.ignite.IgniteScheduler; +import org.apache.ignite.internal.util.future.IgniteFutureImpl; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.scheduler.SchedulerFuture; /** * {@link IgniteScheduler} implementation. @@ -139,4 +142,4 @@ public class IgniteSchedulerImpl implements IgniteScheduler, Externalizable { private Object readResolve() throws ObjectStreamException { return ctx.grid().scheduler(); } -} +} \ 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/IgniteServicesImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteServicesImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteServicesImpl.java index f0f5a70..8f4e0bb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteServicesImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteServicesImpl.java @@ -17,15 +17,23 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.internal.cluster.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.services.*; -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.io.ObjectStreamException; +import java.util.Collection; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteServices; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.internal.cluster.ClusterGroupAdapter; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.services.Service; +import org.apache.ignite.services.ServiceConfiguration; +import org.apache.ignite.services.ServiceDescriptor; +import org.jetbrains.annotations.Nullable; /** * {@link org.apache.ignite.IgniteCompute} implementation. @@ -281,4 +289,4 @@ public class IgniteServicesImpl extends AsyncSupportAdapter implements IgniteSer protected Object readResolve() throws ObjectStreamException { return prj.services(); } -} +} \ 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/IgniteTransactionsEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteTransactionsEx.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteTransactionsEx.java index 4e60659..9772dcc 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteTransactionsEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteTransactionsEx.java @@ -17,10 +17,11 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.internal.processors.cache.*; -import org.apache.ignite.internal.processors.cache.transactions.*; -import org.apache.ignite.transactions.*; +import org.apache.ignite.IgniteTransactions; +import org.apache.ignite.internal.processors.cache.GridCacheContext; +import org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx; +import org.apache.ignite.transactions.TransactionConcurrency; +import org.apache.ignite.transactions.TransactionIsolation; /** * Extended interface to work with system transactions. @@ -47,4 +48,4 @@ public interface IgniteTransactionsEx extends IgniteTransactions { * @return New transaction. */ public IgniteInternalTx txStartEx(GridCacheContext ctx, TransactionConcurrency concurrency, TransactionIsolation isolation); -} +} \ 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/IgniteVersionUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgniteVersionUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/IgniteVersionUtils.java index 3c47f23..7f81cb5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgniteVersionUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgniteVersionUtils.java @@ -17,10 +17,9 @@ package org.apache.ignite.internal; -import org.apache.ignite.lang.*; - -import java.text.*; -import java.util.*; +import java.text.SimpleDateFormat; +import java.util.Date; +import org.apache.ignite.lang.IgniteProductVersion; /** * Ignite version utils. @@ -75,4 +74,4 @@ public class IgniteVersionUtils { private IgniteVersionUtils() { // 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/IgnitionEx.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java index cd91fa8..02b28c5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionEx.java @@ -17,61 +17,110 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.cache.affinity.rendezvous.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.internal.processors.resource.*; -import org.apache.ignite.internal.util.*; -import org.apache.ignite.internal.util.spring.*; -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.logger.java.*; -import org.apache.ignite.marshaller.*; -import org.apache.ignite.marshaller.jdk.*; -import org.apache.ignite.marshaller.optimized.*; -import org.apache.ignite.mxbean.*; -import org.apache.ignite.plugin.segmentation.*; -import org.apache.ignite.resources.*; -import org.apache.ignite.spi.*; -import org.apache.ignite.spi.checkpoint.noop.*; -import org.apache.ignite.spi.collision.noop.*; -import org.apache.ignite.spi.communication.tcp.*; -import org.apache.ignite.spi.deployment.local.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.*; -import org.apache.ignite.spi.eventstorage.memory.*; -import org.apache.ignite.spi.failover.always.*; -import org.apache.ignite.spi.indexing.noop.*; -import org.apache.ignite.spi.loadbalancing.roundrobin.*; -import org.apache.ignite.spi.swapspace.file.*; -import org.apache.ignite.spi.swapspace.noop.*; -import org.apache.ignite.thread.*; -import org.jetbrains.annotations.*; -import org.jsr166.*; - -import javax.management.*; -import java.io.*; -import java.lang.management.*; -import java.lang.reflect.*; -import java.net.*; -import java.util.*; -import java.util.Map.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; -import java.util.logging.*; - -import static org.apache.ignite.IgniteState.*; -import static org.apache.ignite.IgniteSystemProperties.*; -import static org.apache.ignite.cache.CacheAtomicityMode.*; -import static org.apache.ignite.cache.CacheMode.*; -import static org.apache.ignite.cache.CacheRebalanceMode.*; -import static org.apache.ignite.cache.CacheWriteSynchronizationMode.*; -import static org.apache.ignite.configuration.IgniteConfiguration.*; -import static org.apache.ignite.internal.IgniteComponentType.*; -import static org.apache.ignite.plugin.segmentation.SegmentationPolicy.*; +import java.io.File; +import java.io.IOException; +import java.io.InputStream; +import java.lang.management.ManagementFactory; +import java.lang.reflect.Constructor; +import java.net.MalformedURLException; +import java.net.URL; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Collections; +import java.util.HashMap; +import java.util.HashSet; +import java.util.Iterator; +import java.util.List; +import java.util.Map; +import java.util.Map.Entry; +import java.util.UUID; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.LinkedBlockingQueue; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.logging.Handler; +import javax.management.JMException; +import javax.management.MBeanServer; +import javax.management.ObjectName; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteIllegalStateException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.IgniteState; +import org.apache.ignite.IgniteSystemProperties; +import org.apache.ignite.Ignition; +import org.apache.ignite.IgnitionListener; +import org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction; +import org.apache.ignite.compute.ComputeJob; +import org.apache.ignite.configuration.AtomicConfiguration; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.ConnectorConfiguration; +import org.apache.ignite.configuration.DeploymentMode; +import org.apache.ignite.configuration.FileSystemConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.configuration.TransactionConfiguration; +import org.apache.ignite.internal.processors.resource.GridSpringResourceContext; +import org.apache.ignite.internal.util.GridConcurrentHashSet; +import org.apache.ignite.internal.util.IgniteUtils; +import org.apache.ignite.internal.util.spring.IgniteSpringHelper; +import org.apache.ignite.internal.util.typedef.CA; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.G; +import org.apache.ignite.internal.util.typedef.internal.A; +import org.apache.ignite.internal.util.typedef.internal.CU; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.lang.IgniteBiTuple; +import org.apache.ignite.logger.LoggerNodeIdAware; +import org.apache.ignite.logger.java.JavaLogger; +import org.apache.ignite.marshaller.Marshaller; +import org.apache.ignite.marshaller.jdk.JdkMarshaller; +import org.apache.ignite.marshaller.optimized.OptimizedMarshaller; +import org.apache.ignite.mxbean.IgnitionMXBean; +import org.apache.ignite.plugin.segmentation.SegmentationPolicy; +import org.apache.ignite.resources.SpringApplicationContextResource; +import org.apache.ignite.spi.IgniteSpi; +import org.apache.ignite.spi.IgniteSpiMultipleInstancesSupport; +import org.apache.ignite.spi.checkpoint.noop.NoopCheckpointSpi; +import org.apache.ignite.spi.collision.noop.NoopCollisionSpi; +import org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi; +import org.apache.ignite.spi.deployment.local.LocalDeploymentSpi; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder; +import org.apache.ignite.spi.eventstorage.memory.MemoryEventStorageSpi; +import org.apache.ignite.spi.failover.always.AlwaysFailoverSpi; +import org.apache.ignite.spi.indexing.noop.NoopIndexingSpi; +import org.apache.ignite.spi.loadbalancing.roundrobin.RoundRobinLoadBalancingSpi; +import org.apache.ignite.spi.swapspace.file.FileSwapSpaceSpi; +import org.apache.ignite.spi.swapspace.noop.NoopSwapSpaceSpi; +import org.apache.ignite.thread.IgniteThreadPoolExecutor; +import org.jetbrains.annotations.Nullable; +import org.jsr166.ConcurrentHashMap8; + +import static org.apache.ignite.IgniteState.STARTED; +import static org.apache.ignite.IgniteState.STOPPED; +import static org.apache.ignite.IgniteState.STOPPED_ON_SEGMENTATION; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_CACHE_CLIENT; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_CONFIG_URL; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_DEP_MODE_OVERRIDE; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_LOCAL_HOST; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_NO_SHUTDOWN_HOOK; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_RESTART_CODE; +import static org.apache.ignite.IgniteSystemProperties.IGNITE_SUCCESS_FILE; +import static org.apache.ignite.cache.CacheAtomicityMode.ATOMIC; +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; +import static org.apache.ignite.cache.CacheMode.PARTITIONED; +import static org.apache.ignite.cache.CacheMode.REPLICATED; +import static org.apache.ignite.cache.CacheRebalanceMode.SYNC; +import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC; +import static org.apache.ignite.configuration.IgniteConfiguration.DFLT_PUBLIC_KEEP_ALIVE_TIME; +import static org.apache.ignite.configuration.IgniteConfiguration.DFLT_PUBLIC_THREADPOOL_QUEUE_CAP; +import static org.apache.ignite.configuration.IgniteConfiguration.DFLT_SYSTEM_KEEP_ALIVE_TIME; +import static org.apache.ignite.configuration.IgniteConfiguration.DFLT_SYSTEM_MAX_THREAD_CNT; +import static org.apache.ignite.configuration.IgniteConfiguration.DFLT_SYSTEM_THREADPOOL_QUEUE_CAP; +import static org.apache.ignite.internal.IgniteComponentType.SPRING; +import static org.apache.ignite.plugin.segmentation.SegmentationPolicy.RESTART_JVM; /** * This class defines a factory for the main Ignite API. It controls Grid life cycle @@ -2336,4 +2385,4 @@ public class IgnitionEx { } } } -} +} \ 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/IgnitionMXBeanAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMXBeanAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMXBeanAdapter.java index 17c8328..0edce70 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMXBeanAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/IgnitionMXBeanAdapter.java @@ -17,8 +17,9 @@ package org.apache.ignite.internal; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.mxbean.*; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.G; +import org.apache.ignite.mxbean.IgnitionMXBean; /** * Management bean that provides access to {@link org.apache.ignite.Ignition}. @@ -56,4 +57,4 @@ public class IgnitionMXBeanAdapter implements IgnitionMXBean { @Override public void restart(boolean cancel) { G.restart(cancel); } -} +} \ 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/MarshallerContextAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java index 6ef7713..c25da03 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextAdapter.java @@ -17,18 +17,26 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.marshaller.*; -import org.apache.ignite.plugin.*; -import org.jetbrains.annotations.*; -import org.jsr166.*; - -import java.io.*; -import java.net.*; -import java.util.*; -import java.util.concurrent.*; +import java.io.BufferedReader; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.net.URL; +import java.util.Enumeration; +import java.util.HashMap; +import java.util.HashSet; +import java.util.List; +import java.util.Set; +import java.util.concurrent.ConcurrentMap; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteException; +import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionFullMap; +import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionMap; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.marshaller.MarshallerContext; +import org.apache.ignite.plugin.PluginProvider; +import org.jetbrains.annotations.Nullable; +import org.jsr166.ConcurrentHashMap8; /** * Marshaller context adapter. @@ -200,4 +208,4 @@ public abstract class MarshallerContextAdapter implements MarshallerContext { * @throws IgniteCheckedException In case of error. */ protected abstract String className(int id) 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/MarshallerContextImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java index dc0fd57..52d3b1e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/MarshallerContextImpl.java @@ -17,16 +17,25 @@ package org.apache.ignite.internal; -import org.apache.ignite.*; -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.plugin.*; - -import javax.cache.event.*; -import java.io.*; -import java.util.*; -import java.util.concurrent.*; +import java.io.BufferedReader; +import java.io.File; +import java.io.FileReader; +import java.io.FileWriter; +import java.io.IOException; +import java.io.Writer; +import java.util.List; +import java.util.concurrent.CountDownLatch; +import javax.cache.event.CacheEntryEvent; +import javax.cache.event.CacheEntryListenerException; +import javax.cache.event.CacheEntryUpdatedListener; +import org.apache.ignite.IgniteCheckedException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.internal.processors.cache.CachePartialUpdateCheckedException; +import org.apache.ignite.internal.processors.cache.GridCacheAdapter; +import org.apache.ignite.internal.processors.cache.GridCacheTryPutFailedException; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.plugin.PluginProvider; /** * Marshaller context implementation. @@ -197,4 +206,4 @@ public class MarshallerContextImpl extends MarshallerContextAdapter { } } } -} +} \ 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/SkipDaemon.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/SkipDaemon.java b/modules/core/src/main/java/org/apache/ignite/internal/SkipDaemon.java index 5fb2c25..a829c08 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/SkipDaemon.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/SkipDaemon.java @@ -17,7 +17,10 @@ package org.apache.ignite.internal; -import java.lang.annotation.*; +import java.lang.annotation.ElementType; +import java.lang.annotation.Retention; +import java.lang.annotation.RetentionPolicy; +import java.lang.annotation.Target; /** * Lifecycle callbacks will not be called for grid components marked with this annotation. @@ -26,4 +29,4 @@ import java.lang.annotation.*; @Target(ElementType.TYPE) public @interface SkipDaemon { // 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/ThreadPoolMXBeanAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/ThreadPoolMXBeanAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/ThreadPoolMXBeanAdapter.java index 0de13e6..8d62e35 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/ThreadPoolMXBeanAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/ThreadPoolMXBeanAdapter.java @@ -17,10 +17,13 @@ package org.apache.ignite.internal; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.mxbean.*; - -import java.util.concurrent.*; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.RejectedExecutionHandler; +import java.util.concurrent.ThreadFactory; +import java.util.concurrent.ThreadPoolExecutor; +import java.util.concurrent.TimeUnit; +import org.apache.ignite.internal.util.typedef.internal.S; +import org.apache.ignite.mxbean.ThreadPoolMXBean; /** * Adapter for {@link org.apache.ignite.mxbean.ThreadPoolMXBean} which delegates all method calls to the underlying @@ -126,4 +129,4 @@ public class ThreadPoolMXBeanAdapter implements ThreadPoolMXBean { @Override public String toString() { return S.toString(ThreadPoolMXBeanAdapter.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/client/GridClient.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClient.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClient.java index 154f61b..cf4b518 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClient.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClient.java @@ -17,7 +17,8 @@ package org.apache.ignite.internal.client; -import java.util.*; +import java.util.Collection; +import java.util.UUID; /** * Ignite Java client API. @@ -143,4 +144,4 @@ public interface GridClient extends AutoCloseable { * {@code try-with-resources} statement. */ @Override public void close(); -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientAuthenticationException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientAuthenticationException.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientAuthenticationException.java index cd46d8b..3101c21 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientAuthenticationException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientAuthenticationException.java @@ -32,4 +32,4 @@ public class GridClientAuthenticationException extends GridClientException { public GridClientAuthenticationException(String msg) { super(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/internal/client/GridClientCacheFlag.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCacheFlag.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCacheFlag.java index 707a31b..382141c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCacheFlag.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCacheFlag.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.client; -import java.util.*; +import java.util.Collection; /** * Cache projection flags that specify projection behaviour. @@ -49,4 +49,4 @@ public enum GridClientCacheFlag { public static GridClientCacheFlag 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/internal/client/GridClientCacheMode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCacheMode.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCacheMode.java index b4c0022..3db76f5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCacheMode.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCacheMode.java @@ -29,4 +29,4 @@ public enum GridClientCacheMode { /** Partitioned cache. */ PARTITIONED -} +} \ 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/client/GridClientClosedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientClosedException.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientClosedException.java index ed0095e..f45fcec 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientClosedException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientClosedException.java @@ -32,4 +32,4 @@ public class GridClientClosedException extends GridClientException { public GridClientClosedException(String msg) { super(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/internal/client/GridClientCompute.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCompute.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCompute.java index 02cb428..c907779 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCompute.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientCompute.java @@ -17,10 +17,11 @@ package org.apache.ignite.internal.client; -import org.apache.ignite.internal.client.balancer.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.List; +import java.util.UUID; +import org.apache.ignite.internal.client.balancer.GridClientLoadBalancer; +import org.jetbrains.annotations.Nullable; /** * A compute projection of grid client. Contains various methods for task execution, full and partial (per node) @@ -416,4 +417,4 @@ public interface GridClientCompute { * Sets keep portables flag for the next task execution in the current thread. */ public GridClientCompute withKeepPortables(); -} +} \ 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/client/GridClientConfiguration.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientConfiguration.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientConfiguration.java index 7fa0dae..2015970 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientConfiguration.java @@ -17,18 +17,27 @@ package org.apache.ignite.internal.client; -import org.apache.ignite.internal.client.balancer.*; -import org.apache.ignite.internal.client.marshaller.*; -import org.apache.ignite.internal.client.marshaller.optimized.*; -import org.apache.ignite.internal.client.ssl.*; -import org.apache.ignite.internal.util.typedef.*; -import org.apache.ignite.internal.util.typedef.internal.*; -import org.apache.ignite.plugin.security.*; -import org.jetbrains.annotations.*; - -import java.net.*; -import java.util.*; -import java.util.concurrent.*; +import java.net.Socket; +import java.util.ArrayList; +import java.util.Arrays; +import java.util.Collection; +import java.util.Collections; +import java.util.Map; +import java.util.Properties; +import java.util.concurrent.ExecutorService; +import org.apache.ignite.internal.client.balancer.GridClientLoadBalancer; +import org.apache.ignite.internal.client.balancer.GridClientRandomBalancer; +import org.apache.ignite.internal.client.balancer.GridClientRoundRobinBalancer; +import org.apache.ignite.internal.client.marshaller.GridClientMarshaller; +import org.apache.ignite.internal.client.marshaller.optimized.GridClientOptimizedMarshaller; +import org.apache.ignite.internal.client.ssl.GridSslBasicContextFactory; +import org.apache.ignite.internal.client.ssl.GridSslContextFactory; +import org.apache.ignite.internal.util.typedef.F; +import org.apache.ignite.internal.util.typedef.internal.U; +import org.apache.ignite.plugin.security.SecurityCredentials; +import org.apache.ignite.plugin.security.SecurityCredentialsBasicProvider; +import org.apache.ignite.plugin.security.SecurityCredentialsProvider; +import org.jetbrains.annotations.Nullable; /** * Java client configuration. @@ -841,4 +850,4 @@ public class GridClientConfiguration { public boolean isDaemon() { return daemon; } -} +} \ 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/client/GridClientData.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientData.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientData.java index 73fa06f..b8919b5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientData.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientData.java @@ -17,7 +17,10 @@ package org.apache.ignite.internal.client; -import java.util.*; +import java.util.Collection; +import java.util.Map; +import java.util.Set; +import java.util.UUID; /** * A data projection of grid client. Contains various methods for cache operations and metrics retrieval. @@ -440,4 +443,4 @@ public interface GridClientData { * @throws GridClientException In case of error. */ public GridClientData flagsOff(GridClientCacheFlag... flags) throws GridClientException; -} +} \ 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/client/GridClientDataAffinity.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataAffinity.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataAffinity.java index 53a840f..0ada4bf 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataAffinity.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataAffinity.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.client; -import java.util.*; +import java.util.Collection; /** * Determines which node should be connected when operation on a key is requested. @@ -36,4 +36,4 @@ public interface GridClientDataAffinity { * @return Affinity nodes for the given partition. */ public GridClientNode node(Object key, Collection<? extends GridClientNode> nodes); -} +} \ 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/client/GridClientDataConfiguration.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataConfiguration.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataConfiguration.java index eaf39f4..322bccd 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataConfiguration.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataConfiguration.java @@ -17,7 +17,8 @@ package org.apache.ignite.internal.client; -import org.apache.ignite.internal.client.balancer.*; +import org.apache.ignite.internal.client.balancer.GridClientLoadBalancer; +import org.apache.ignite.internal.client.balancer.GridClientRandomBalancer; /** * Java client data configuration. @@ -115,4 +116,4 @@ public class GridClientDataConfiguration { public void setBalancer(GridClientLoadBalancer balancer) { this.balancer = balancer; } -} +} \ 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/client/GridClientDataMetrics.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataMetrics.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataMetrics.java index 9d2affa..c313e94 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataMetrics.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDataMetrics.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.client; -import java.io.*; +import java.io.Serializable; /** * Cache metrics used to obtain statistics on cache itself or any of its entries. @@ -74,4 +74,4 @@ public interface GridClientDataMetrics extends Serializable { * @return Number of misses. */ public int misses(); -} +} \ 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/client/GridClientDisconnectedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDisconnectedException.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDisconnectedException.java index 124f1ef..6678a3a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDisconnectedException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientDisconnectedException.java @@ -33,4 +33,4 @@ public class GridClientDisconnectedException extends GridClientException { public GridClientDisconnectedException(String msg, GridClientException cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientException.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientException.java index a27bff8..aa77394 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientException.java @@ -17,8 +17,8 @@ package org.apache.ignite.internal.client; -import org.apache.ignite.internal.util.typedef.*; -import org.jetbrains.annotations.*; +import org.apache.ignite.internal.util.typedef.F; +import org.jetbrains.annotations.Nullable; /** * Client exception is a common super class of all client exceptions. @@ -108,4 +108,4 @@ public class GridClientException extends Exception { @Override public String toString() { return getClass() + ": " + getMessage(); } -} +} \ 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/client/GridClientFactory.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFactory.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFactory.java index 1616d0a..0a1f857 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFactory.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFactory.java @@ -17,11 +17,12 @@ package org.apache.ignite.internal.client; -import org.apache.ignite.internal.client.impl.*; - -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.locks.*; +import java.util.UUID; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.locks.ReadWriteLock; +import java.util.concurrent.locks.ReentrantReadWriteLock; +import org.apache.ignite.internal.client.impl.GridClientImpl; /** * Client factory opens and closes clients. It also tracks all currently opened clients as well. @@ -135,4 +136,4 @@ public class GridClientFactory { busyLock.readLock().unlock(); } } -} +} \ 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/client/GridClientFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFuture.java index 4f40fae..eb2a985 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFuture.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.client; -import java.util.concurrent.*; +import java.util.concurrent.TimeUnit; /** * Future for asynchronous operations. @@ -58,4 +58,4 @@ public interface GridClientFuture<R> { * @param lsnrs Listeners to be registered. */ public void listen(GridClientFutureListener<R>... lsnrs); -} +} \ 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/client/GridClientFutureListener.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFutureListener.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFutureListener.java index 7314fbd..0715bda 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFutureListener.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFutureListener.java @@ -27,4 +27,4 @@ public interface GridClientFutureListener<R> { * @param fut Completed future. */ public void onDone(GridClientFuture<R> fut); -} +} \ 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/client/GridClientFutureTimeoutException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFutureTimeoutException.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFutureTimeoutException.java index a046367..65971f0 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFutureTimeoutException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientFutureTimeoutException.java @@ -42,4 +42,4 @@ public class GridClientFutureTimeoutException extends GridClientException { public GridClientFutureTimeoutException(String msg, Throwable cause) { super(msg, cause); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientHandshakeException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientHandshakeException.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientHandshakeException.java index cefc287..ecb2ddf 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientHandshakeException.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientHandshakeException.java @@ -45,4 +45,4 @@ public class GridClientHandshakeException extends GridClientException { public byte getStatusCode() { return statusCode; } -} +} \ 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/client/GridClientNode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientNode.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientNode.java index 74e612d..be8053b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientNode.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientNode.java @@ -17,10 +17,12 @@ package org.apache.ignite.internal.client; -import org.jetbrains.annotations.*; - -import java.net.*; -import java.util.*; +import java.net.InetSocketAddress; +import java.util.Collection; +import java.util.List; +import java.util.Map; +import java.util.UUID; +import org.jetbrains.annotations.Nullable; /** * Descriptor of remote grid node. Use {@link GridClientCompute#nodes()} to @@ -117,4 +119,4 @@ public interface GridClientNode { * {@code false} if request may be passed through a router. */ public boolean connectable(); -} +} \ 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/client/GridClientNodeMetrics.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientNodeMetrics.java b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientNodeMetrics.java index 7859ba5..dc9fd92 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientNodeMetrics.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/client/GridClientNodeMetrics.java @@ -17,7 +17,7 @@ package org.apache.ignite.internal.client; -import java.io.*; +import java.io.Serializable; /** * Node metrics for remote grid node. Metrics can be retrieved via @@ -521,4 +521,4 @@ public interface GridClientNodeMetrics extends Serializable { * @return Received bytes count. */ public long getReceivedBytesCount(); -} +} \ No newline at end of file
