http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java index d4ec78f..3adc282 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProcessor.java @@ -208,7 +208,6 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void onKernalStart(boolean active) throws IgniteCheckedException { if (ctx.isDaemon() || !active) return; @@ -799,7 +798,6 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite /** * @return Future. */ - @SuppressWarnings("unchecked") public IgniteInternalFuture<?> cancelAll() { Iterator<Cache.Entry<Object, Object>> it = serviceEntries(ServiceDeploymentPredicate.INSTANCE); @@ -999,7 +997,6 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite * @param <T> Service type. * @return Service by specified service name. */ - @SuppressWarnings("unchecked") public <T> T service(String name) { ctx.security().authorize(name, SecurityPermission.SERVICE_INVOKE, null); @@ -1064,7 +1061,6 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite * @return The proxy of a service by its name and class. * @throws IgniteException If failed to create proxy. */ - @SuppressWarnings("unchecked") public <T> T serviceProxy(ClusterGroup prj, String name, Class<? super T> svcItf, boolean sticky, long timeout) throws IgniteException { ctx.security().authorize(name, SecurityPermission.SERVICE_INVOKE, null); @@ -1106,7 +1102,6 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite * @param <T> Service type. * @return Services by specified service name. */ - @SuppressWarnings("unchecked") public <T> Collection<T> services(String name) { ctx.security().authorize(name, SecurityPermission.SERVICE_INVOKE, null); @@ -1570,7 +1565,6 @@ public class GridServiceProcessor extends GridProcessorAdapter implements Ignite /** * Service deployment listener. */ - @SuppressWarnings("unchecked") private class ServiceEntriesListener implements CacheEntryUpdatedListener<Object, Object> { /** {@inheritDoc} */ @Override public void onUpdated(final Iterable<CacheEntryEvent<?, ?>> deps) {
http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProxy.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProxy.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProxy.java index eb2d509..4d98187 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProxy.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/GridServiceProxy.java @@ -104,7 +104,6 @@ public class GridServiceProxy<T> implements Serializable { * @param timeout Service availability wait timeout. Cannot be negative. * @param ctx Context. */ - @SuppressWarnings("unchecked") public GridServiceProxy(ClusterGroup prj, String name, Class<? super T> svc, http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceContextImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceContextImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceContextImpl.java index 490b598..f624334 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceContextImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceContextImpl.java @@ -106,7 +106,6 @@ public class ServiceContextImpl implements ServiceContext { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Nullable @Override public <K> K affinityKey() { return (K)affKey; } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceDescriptorImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceDescriptorImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceDescriptorImpl.java index 9ec3eb0..4db44cb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceDescriptorImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/service/ServiceDescriptorImpl.java @@ -88,7 +88,6 @@ public class ServiceDescriptorImpl implements ServiceDescriptor { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Nullable @Override public <K> K affinityKey() { return (K)dep.configuration().getAffinityKey(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java index e24e644..83e156a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskProcessor.java @@ -548,7 +548,6 @@ public class GridTaskProcessor extends GridProcessorAdapter implements IgniteCha * @param execName Name of the custom executor. * @return Task future. */ - @SuppressWarnings("unchecked") private <T, R> ComputeTaskInternalFuture<R> startTask( @Nullable String taskName, @Nullable Class<?> taskCls, @@ -1134,7 +1133,6 @@ public class GridTaskProcessor extends GridProcessorAdapter implements IgniteCha * @param nodeId Node ID. * @param msg Task session request. */ - @SuppressWarnings({"unchecked"}) private void processTaskSessionRequest(UUID nodeId, GridTaskSessionRequest msg) { assert nodeId != null; assert msg != null; @@ -1244,7 +1242,6 @@ public class GridTaskProcessor extends GridProcessorAdapter implements IgniteCha /** * Listener for individual task events. */ - @SuppressWarnings({"deprecation"}) private class TaskEventListener implements GridTaskEventListener { /** */ private final GridMessageListener msgLsnr = new JobMessageListener(false); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java index 16461c9..3eef2b6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/task/GridTaskWorker.java @@ -357,7 +357,6 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject { * @param key Thread-local context key. * @return Thread-local context value, if any. */ - @SuppressWarnings({"unchecked"}) @Nullable private <V> V getThreadContext(GridTaskThreadContextKey key) { return thCtx == null ? null : (V)thCtx.get(key); } @@ -469,7 +468,6 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject { /** * Maps this task's jobs to nodes and sends them out. */ - @SuppressWarnings({"unchecked"}) @Override protected void body() { evtLsnr.onTaskStarted(this); @@ -1647,7 +1645,6 @@ class GridTaskWorker<T, R> extends GridWorker implements GridTimeoutObject { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public boolean equals(Object obj) { if (this == obj) return true; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/GridArrays.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridArrays.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridArrays.java index 75d73ee..47680fe 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridArrays.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridArrays.java @@ -58,7 +58,6 @@ public final class GridArrays { * @param idx Index to remove. * @return Smaller array. */ - @SuppressWarnings("unchecked") public static <T> T[] remove(T[] arr, int idx) { int len = arr.length; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashMap.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashMap.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashMap.java index ee6e9f5..d3f5c33 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashMap.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashMap.java @@ -119,7 +119,6 @@ public class GridBoundedLinkedHashMap<K, V> extends LinkedHashMap<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public Object clone() { GridBoundedLinkedHashMap<K, V> m = (GridBoundedLinkedHashMap<K, V>)super.clone(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashSet.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashSet.java index 7880190..9bae9eb 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashSet.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridBoundedLinkedHashSet.java @@ -199,7 +199,6 @@ public class GridBoundedLinkedHashSet<E> extends GridSerializableSet<E> implemen * @return a shallow copy of this set. * @throws CloneNotSupportedException Thrown if cloning is not supported. */ - @SuppressWarnings("unchecked") @Override public Object clone() throws CloneNotSupportedException { GridBoundedLinkedHashSet<E> newSet = (GridBoundedLinkedHashSet<E>)super.clone(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java index 688e164..dbb397b 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridConcurrentSkipListSet.java @@ -108,7 +108,7 @@ public class GridConcurrentSkipListSet<E> extends GridSerializableSet<E> impleme } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked", "CloneCallsConstructors"}) + @SuppressWarnings({"CloneCallsConstructors"}) @Override public GridConcurrentSkipListSet<E> clone() { try { GridConcurrentSkipListSet<E> clone = (GridConcurrentSkipListSet<E>)super.clone(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanMap.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanMap.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanMap.java index 5452a25..eaf54e4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanMap.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanMap.java @@ -256,7 +256,7 @@ public class GridLeanMap<K, V> extends GridSerializableMap<K, V> implements Clon } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked", "CloneDoesntDeclareCloneNotSupportedException"}) + @SuppressWarnings({"CloneDoesntDeclareCloneNotSupportedException"}) @Override protected Object clone() { try { GridLeanMap<K, V> clone = (GridLeanMap<K, V>)super.clone(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanSet.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanSet.java index 125e61f..5be1e67 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanSet.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridLeanSet.java @@ -63,7 +63,6 @@ public class GridLeanSet<E> extends GridSetWrapper<E> implements Cloneable { } /** {@inheritDoc} */ - @SuppressWarnings( {"unchecked"}) @Override public Object clone() { try { GridLeanSet<E> clone = (GridLeanSet<E>)super.clone(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/GridListSet.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridListSet.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridListSet.java index 6f49c1b..9ceeda3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridListSet.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridListSet.java @@ -242,7 +242,6 @@ public class GridListSet<V> extends GridSerializableSet<V> implements Cloneable } /** {@inheritDoc} */ - @SuppressWarnings( {"unchecked"}) @Override public boolean remove(Object val) { A.notNull(val, "val"); @@ -339,7 +338,6 @@ public class GridListSet<V> extends GridSerializableSet<V> implements Cloneable } /** {@inheritDoc} */ - @SuppressWarnings( {"unchecked"}) @Override public boolean contains(Object val) { A.notNull(val, "val"); @@ -393,7 +391,6 @@ public class GridListSet<V> extends GridSerializableSet<V> implements Cloneable * @return Clone of this set. * @throws CloneNotSupportedException */ - @SuppressWarnings( {"unchecked"}) @Override protected Object clone() throws CloneNotSupportedException { GridListSet<V> clone = (GridListSet<V>)super.clone(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java index fb5a793..760b794 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/GridSetWrapper.java @@ -43,7 +43,6 @@ public class GridSetWrapper<E> extends GridSerializableSet<E> { * * @param map Map to be used for set implementation. */ - @SuppressWarnings({"unchecked"}) public GridSetWrapper(Map<E, ?> map) { A.notNull(map, "map"); @@ -77,7 +76,6 @@ public class GridSetWrapper<E> extends GridSerializableSet<E> { * * @return Wrapped map. */ - @SuppressWarnings({"unchecked"}) protected final <T extends Map<E, Object>> T map() { return (T)map; } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java index 2f8eb1c..1d9a0ad 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java @@ -1179,7 +1179,6 @@ public abstract class IgniteUtils { * * @deprecated Calls to this method should never be committed to master. */ - @SuppressWarnings("deprecation") @Deprecated public static void dumpStack() { dumpStack("Dumping stack."); @@ -1637,7 +1636,6 @@ public abstract class IgniteUtils { * @return New instance of the class or {@code null} if empty constructor could not be assigned. * @throws IgniteCheckedException If failed. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <T> T forceNewInstance(Class<?> cls) throws IgniteCheckedException { Constructor ctor = forceEmptyConstructor(cls); @@ -5246,7 +5244,6 @@ public abstract class IgniteUtils { * @throws IOException If de-serialization failed. * @throws ClassNotFoundException If deserialized class could not be found. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <K, V> Map<K, V> readMap(ObjectInput in) throws IOException, ClassNotFoundException { int size = in.readInt(); @@ -5267,7 +5264,6 @@ public abstract class IgniteUtils { * @throws IOException If de-serialization failed. * @throws ClassNotFoundException If deserialized class could not be found. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <K, V> TreeMap<K, V> readTreeMap( ObjectInput in) throws IOException, ClassNotFoundException { int size = in.readInt(); @@ -5291,7 +5287,6 @@ public abstract class IgniteUtils { * @throws IOException If de-serialization failed. * @throws ClassNotFoundException If deserialized class could not be found. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <K, V> HashMap<K, V> readHashMap(ObjectInput in) throws IOException, ClassNotFoundException { int size = in.readInt(); @@ -5315,7 +5310,6 @@ public abstract class IgniteUtils { * @throws IOException If de-serialization failed. * @throws ClassNotFoundException If deserialized class could not be found. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <K, V> LinkedHashMap<K, V> readLinkedMap(ObjectInput in) throws IOException, ClassNotFoundException { int size = in.readInt(); @@ -5356,7 +5350,6 @@ public abstract class IgniteUtils { * @throws IOException If de-serialization failed. * @throws ClassNotFoundException If deserialized class could not be found. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <V> Map<Integer, V> readIntKeyMap(ObjectInput in) throws IOException, ClassNotFoundException { int size = in.readInt(); @@ -5398,7 +5391,6 @@ public abstract class IgniteUtils { * @return Read map. * @throws IOException If de-serialization failed. */ - @SuppressWarnings({"unchecked"}) @Nullable public static Map<Integer, Integer> readIntKeyIntValueMap(DataInput in) throws IOException { Map<Integer, Integer> map = null; @@ -5421,7 +5413,6 @@ public abstract class IgniteUtils { * @throws IOException If deserialization failed. * @throws ClassNotFoundException If deserialized class could not be found. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <E> List<E> readList(ObjectInput in) throws IOException, ClassNotFoundException { int size = in.readInt(); @@ -7049,7 +7040,6 @@ public abstract class IgniteUtils { * @param bLen Length of prefix {@code b}. * @return Increasing array which is union of {@code a} and {@code b}. */ - @SuppressWarnings("IfMayBeConditional") public static int[] unique(int[] a, int aLen, int[] b, int bLen) { assert a != null; assert b != null; @@ -7092,7 +7082,6 @@ public abstract class IgniteUtils { * @param bLen Length of prefix {@code b}. * @return Increasing array which is difference between {@code a} and {@code b}. */ - @SuppressWarnings("IfMayBeConditional") public static int[] difference(int[] a, int aLen, int[] b, int bLen) { assert a != null; assert b != null; @@ -7358,7 +7347,6 @@ public abstract class IgniteUtils { * * @deprecated Calls to this method should never be committed to master. */ - @SuppressWarnings("deprecation") @Deprecated public static void dumpStack(Thread t) { dumpStack(t, System.err); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/StripedCompositeReadWriteLock.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedCompositeReadWriteLock.java b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedCompositeReadWriteLock.java index 42ec397..786d647 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/StripedCompositeReadWriteLock.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/StripedCompositeReadWriteLock.java @@ -209,7 +209,6 @@ public class StripedCompositeReadWriteLock implements ReadWriteLock { } /** {@inheritDoc} */ - @SuppressWarnings("NullableProblems") @Override public boolean tryLock(long time, TimeUnit unit) throws InterruptedException { int i = 0; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java index 2299dcc..45465be 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridCompoundFuture.java @@ -161,7 +161,6 @@ public class GridCompoundFuture<T, R> extends GridFutureAdapter<R> implements Ig * * @return Collection of futures. */ - @SuppressWarnings("unchecked") public final synchronized Collection<IgniteInternalFuture<T>> futures() { if (futs == null) return Collections.emptyList(); @@ -221,7 +220,6 @@ public class GridCompoundFuture<T, R> extends GridFutureAdapter<R> implements Ig * * @param fut Future to add. */ - @SuppressWarnings("unchecked") public final void add(IgniteInternalFuture<T> fut) { assert fut != null; @@ -339,7 +337,6 @@ public class GridCompoundFuture<T, R> extends GridFutureAdapter<R> implements Ig /** * @return Futures size. */ - @SuppressWarnings("unchecked") protected final int futuresCountNoLock() { assert Thread.holdsLock(this); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java index b149035..926def2 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFinishedFuture.java @@ -75,7 +75,6 @@ public class GridFinishedFuture<T> implements IgniteInternalFuture<T> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public T result() { return resFlag == RES ? (T)res : null; } @@ -96,7 +95,6 @@ public class GridFinishedFuture<T> implements IgniteInternalFuture<T> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public T get() throws IgniteCheckedException { if (resFlag == ERR) throw U.cast((Throwable)res); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java index 6eafe48..cddb19c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/GridFutureAdapter.java @@ -124,7 +124,6 @@ public class GridFutureAdapter<R> implements IgniteInternalFuture<R> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public R result() { Object state0 = state; @@ -251,7 +250,6 @@ public class GridFutureAdapter<R> implements IgniteInternalFuture<R> { * @return Result. * @throws IgniteCheckedException If resolved to exception. */ - @SuppressWarnings("unchecked") private R resolve() throws IgniteCheckedException { if(state == CANCELLED) throw new IgniteFutureCancelledCheckedException("Future was cancelled: " + this); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java index a018628..6978501 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/future/IgniteFutureImpl.java @@ -198,7 +198,6 @@ public class IgniteFutureImpl<V> implements IgniteFuture<V> { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public boolean equals(Object obj) { if (obj == null || !obj.getClass().equals(InternalFutureListener.class)) return false; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java index 1094de3..2d4d1cf 100755 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridFunc.java @@ -1007,7 +1007,6 @@ public class GridFunc { * @param <T1> Type of the collection. * @return Light-weight view on given collection with provided predicate. */ - @SuppressWarnings("RedundantTypeArguments") @SafeVarargs public static <T1, T2> Collection<T2> viewReadOnly(@Nullable final Collection<? extends T1> c, final IgniteClosure<? super T1, T2> trans, @Nullable final IgnitePredicate<? super T1>... p) { @@ -1291,7 +1290,6 @@ public class GridFunc { * @return Factory closure that creates new {@link Set} instance every time * its {@link org.apache.ignite.lang.IgniteOutClosure#apply()} method is called. */ - @SuppressWarnings("unchecked") public static <T> IgniteCallable<Set<T>> newSet() { return (IgniteCallable<Set<T>>)SET_FACTORY; } @@ -1305,7 +1303,6 @@ public class GridFunc { * @return Factory closure that creates new {@link Map} instance every * time its {@link org.apache.ignite.lang.IgniteOutClosure#apply()} method is called. */ - @SuppressWarnings("unchecked") @Deprecated public static <K, V> IgniteCallable<Map<K, V>> newMap() { return (IgniteCallable<Map<K, V>>)MAP_FACTORY; @@ -1320,7 +1317,6 @@ public class GridFunc { * @return Factory closure that creates new {@link Map} instance every * time its {@link org.apache.ignite.lang.IgniteOutClosure#apply()} method is called. */ - @SuppressWarnings("unchecked") public static <K, V> IgniteCallable<ConcurrentMap<K, V>> newCMap() { return (IgniteCallable<ConcurrentMap<K, V>>)CONCURRENT_MAP_FACTORY; } @@ -1332,7 +1328,6 @@ public class GridFunc { * @return Factory closure that creates new {@link GridConcurrentHashSet} instance every * time its {@link org.apache.ignite.lang.IgniteOutClosure#apply()} method is called. */ - @SuppressWarnings("unchecked") public static <E> IgniteCallable<Set<E>> newCSet() { return (IgniteCallable<Set<E>>)CONCURRENT_SET_FACTORY; } @@ -1413,7 +1408,6 @@ public class GridFunc { * @param <T> Type of the free variable, i.e. the element the predicate is called on. * @return Predicate that always returns {@code true}. */ - @SuppressWarnings( {"unchecked"}) public static <T> IgnitePredicate<T> alwaysTrue() { return (IgnitePredicate<T>)ALWAYS_TRUE; } @@ -1425,7 +1419,6 @@ public class GridFunc { * @param <T> Type of the free variable, i.e. the element the predicate is called on. * @return Predicate that always returns {@code false}. */ - @SuppressWarnings( {"unchecked"}) public static <T> IgnitePredicate<T> alwaysFalse() { return (IgnitePredicate<T>)ALWAYS_FALSE; } @@ -1720,7 +1713,6 @@ public class GridFunc { * @param it Iterable to fetch. * @return Modified target collection. */ - @SuppressWarnings("unchecked") @Deprecated public static <T, C extends Collection<T>> C addAll(C c, Iterable<? extends T> it) { if (it == null) @@ -1909,7 +1901,6 @@ public class GridFunc { * @param <X> Type of the free variable for the closure and type of the array * elements. */ - @SuppressWarnings("RedundantTypeArguments") @Deprecated public static <X> void forEach(X[] c, IgniteInClosure<? super X> f, @Nullable IgnitePredicate<? super X>... p) { A.notNull(c, "c", f, "f"); @@ -3030,7 +3021,6 @@ public class GridFunc { * @param <V> Value type. * @return Closure that returns value for an entry. */ - @SuppressWarnings({"unchecked"}) public static <K, V> IgniteClosure<Cache.Entry<K, V>, V> cacheEntry2Get() { return (IgniteClosure<Cache.Entry<K, V>, V>)CACHE_ENTRY_VAL_GET; } @@ -3042,7 +3032,6 @@ public class GridFunc { * @param <V> Cache value type. * @return Predicate which returns {@code true} if entry has peek value. */ - @SuppressWarnings({"unchecked"}) public static <K, V> IgnitePredicate<Cache.Entry<K, V>> cacheHasPeekValue() { return (IgnitePredicate<Cache.Entry<K, V>>)CACHE_ENTRY_HAS_PEEK_VAL; } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java index d00fd10..9ad05b57 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridMetadataAwareAdapter.java @@ -107,7 +107,6 @@ public class GridMetadataAwareAdapter { * @param <V> Type of the value. * @return Metadata previously associated with given name, or {@code null} if there was none. */ - @SuppressWarnings({"unchecked"}) @Nullable public <V> V addMeta(int key, V val) { assert val != null; @@ -132,7 +131,6 @@ public class GridMetadataAwareAdapter { * @param <V> Type of the value. * @return Metadata value or {@code null}. */ - @SuppressWarnings({"unchecked"}) @Nullable public <V> V meta(int key) { synchronized (this) { return data != null && data.length > key ? (V)data[key] : null; @@ -146,7 +144,6 @@ public class GridMetadataAwareAdapter { * @param <V> Type of the value. * @return Value of removed metadata or {@code null}. */ - @SuppressWarnings({"unchecked"}) @Nullable public <V> V removeMeta(int key) { synchronized (this) { if (data == null || data.length <= key) @@ -168,7 +165,6 @@ public class GridMetadataAwareAdapter { * @param <V> Value type. * @return {@code True} if value was removed, {@code false} otherwise. */ - @SuppressWarnings({"unchecked"}) public <V> boolean removeMeta(int key, V val) { assert val != null; @@ -243,7 +239,6 @@ public class GridMetadataAwareAdapter { * @param <V> Type of the value. * @return {@code null} if new value was put, or current value if put didn't happen. */ - @SuppressWarnings({"unchecked"}) @Nullable public <V> V putMetaIfAbsent(int key, V val) { assert val != null; @@ -266,7 +261,6 @@ public class GridMetadataAwareAdapter { * @param <V> Type of the value. * @return The value of the metadata after execution of this method. */ - @SuppressWarnings({"unchecked"}) public <V> V addMetaIfAbsent(int key, V val) { assert val != null; @@ -291,7 +285,6 @@ public class GridMetadataAwareAdapter { * @param <V> Type of the value. * @return The value of the metadata after execution of this method. */ - @SuppressWarnings({"unchecked"}) @Nullable public <V> V addMetaIfAbsent(int key, @Nullable Callable<V> c) { assert c != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java index 721d142..ae3ad01 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple.java @@ -116,7 +116,6 @@ public class GridTuple<V> implements Iterable<V>, Cloneable, Externalizable { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { val = (V)in.readObject(); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java index 76fbdb5..e610bf6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple3.java @@ -189,7 +189,6 @@ public class GridTuple3<V1, V2, V3> implements Iterable<Object>, Externalizable, } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { val1 = (V1)in.readObject(); val2 = (V2)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java index 2889899..f5e9ec6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple4.java @@ -218,7 +218,6 @@ public class GridTuple4<V1, V2, V3, V4> implements Iterable<Object>, Externaliza } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { val1 = (V1)in.readObject(); val2 = (V2)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java index e1748bf..45ecbe9 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple5.java @@ -247,7 +247,6 @@ public class GridTuple5<V1, V2, V3, V4, V5> implements Iterable<Object>, Externa } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { v1 = (V1)in.readObject(); v2 = (V2)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java index c7d7ee6..de4d1ed5 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/GridTuple6.java @@ -279,7 +279,6 @@ public class GridTuple6<V1, V2, V3, V4, V5, V6> implements Iterable<Object>, Ext } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { v1 = (V1)in.readObject(); v2 = (V2)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/PredicateMapView.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/PredicateMapView.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/PredicateMapView.java index 01e6d8a..355e06a 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/PredicateMapView.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/PredicateMapView.java @@ -70,12 +70,10 @@ public class PredicateMapView<K, V> extends GridSerializableMap<K, V> { return F.size(map.keySet(), preds); } - @SuppressWarnings({"unchecked"}) @Override public boolean remove(Object o) { return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().remove(o); } - @SuppressWarnings({"unchecked"}) @Override public boolean contains(Object o) { return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o); } @@ -92,7 +90,6 @@ public class PredicateMapView<K, V> extends GridSerializableMap<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Nullable @Override public V get(Object key) { return GridFunc.isAll((K)key, preds) ? map.get(key) : null; } @@ -108,7 +105,6 @@ public class PredicateMapView<K, V> extends GridSerializableMap<K, V> { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public boolean containsKey(Object key) { return GridFunc.isAll((K)key, preds) && map.containsKey(key); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView.java index a089f67..b35014f 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView.java @@ -110,12 +110,10 @@ public class TransformMapView<K, V1, V> extends GridSerializableMap<K, V1> { return hasPred ? F.size(map.keySet(), preds) : map.size(); } - @SuppressWarnings({"unchecked"}) @Override public boolean remove(Object o) { throw new UnsupportedOperationException("Remove is not support for readonly map view."); } - @SuppressWarnings({"unchecked"}) @Override public boolean contains(Object o) { return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o); } @@ -132,7 +130,6 @@ public class TransformMapView<K, V1, V> extends GridSerializableMap<K, V1> { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Nullable @Override public V1 get(Object key) { if (GridFunc.isAll((K)key, preds)) { V v = map.get(key); @@ -155,7 +152,6 @@ public class TransformMapView<K, V1, V> extends GridSerializableMap<K, V1> { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public boolean containsKey(Object key) { return GridFunc.isAll((K)key, preds) && map.containsKey(key); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView2.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView2.java b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView2.java index 523d4cc..9361e55 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView2.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/lang/gridfunc/TransformMapView2.java @@ -108,12 +108,10 @@ public class TransformMapView2<K, V, V1> extends GridSerializableMap<K, V1> { return F.size(map.keySet(), preds); } - @SuppressWarnings({"unchecked"}) @Override public boolean remove(Object o) { throw new UnsupportedOperationException("Remove is not support for readonly map view."); } - @SuppressWarnings({"unchecked"}) @Override public boolean contains(Object o) { return F.isAll((Entry<K, V>)o, entryPred) && map.entrySet().contains(o); } @@ -130,7 +128,6 @@ public class TransformMapView2<K, V, V1> extends GridSerializableMap<K, V1> { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Nullable @Override public V1 get(Object key) { if (GridFunc.isAll((K)key, preds)) { V v = map.get(key); @@ -153,7 +150,6 @@ public class TransformMapView2<K, V, V1> extends GridSerializableMap<K, V1> { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public boolean containsKey(Object key) { return GridFunc.isAll((K)key, preds) && map.containsKey(key); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java index b3c4fc1..7e3221e 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/nio/GridNioServer.java @@ -743,7 +743,6 @@ public class GridNioServer<T> { /** * @return Future. */ - @SuppressWarnings("ForLoopReplaceableByForEach") public IgniteInternalFuture<String> dumpStats() { String msg = "NIO server statistics [readerSesBalanceCnt=" + readerMoveCnt.get() + ", writerSesBalanceCnt=" + writerMoveCnt.get() + ']'; @@ -1335,7 +1334,6 @@ public class GridNioServer<T> { * @param key Key that is ready to be written. * @throws IOException If write failed. */ - @SuppressWarnings("ForLoopReplaceableByForEach") private void processWriteSsl(SelectionKey key) throws IOException { WritableByteChannel sockCh = (WritableByteChannel)key.channel(); @@ -1572,7 +1570,6 @@ public class GridNioServer<T> { * @param key Key that is ready to be written. * @throws IOException If write failed. */ - @SuppressWarnings("ForLoopReplaceableByForEach") private void processWrite0(SelectionKey key) throws IOException { WritableByteChannel sockCh = (WritableByteChannel)key.channel(); @@ -1711,7 +1708,6 @@ public class GridNioServer<T> { * @param ses Session. * @param msg Message. */ - @SuppressWarnings("unchecked") private void onMessageWritten(GridSelectorNioSessionImpl ses, Message msg) { if (lsnr != null) lsnr.onMessageSent(ses, (T)msg); @@ -2750,7 +2746,6 @@ public class GridNioServer<T> { * @param key Key. * @throws IOException If failed. */ - @SuppressWarnings("unchecked") private void processConnect(SelectionKey key) throws IOException { SocketChannel ch = (SocketChannel)key.channel(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java b/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java index be69b24..59371e3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/typedef/X.java @@ -291,7 +291,6 @@ public final class X { * @param <T> Type of cloning object. * @return Copy of a passed in object. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <T> T cloneObject(@Nullable T obj, boolean deep, boolean honorCloneable) { if (obj == null) return null; @@ -310,7 +309,6 @@ public final class X { * @param <T> Type of cloning object. * @return Copy of a passed in object. */ - @SuppressWarnings({"unchecked"}) @Nullable private static <T> T shallowClone(@Nullable T obj) { if (obj == null) return null; @@ -524,7 +522,6 @@ public final class X { * @param cls Cause class to get cause (if {@code null}, {@code null} is returned). * @return First causing exception of passed in class, {@code null} otherwise. */ - @SuppressWarnings({"unchecked"}) @Nullable public static <T extends Throwable> T cause(@Nullable Throwable t, @Nullable Class<T> cls) { if (t == null || cls == null) return null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/lang/IgniteBiTuple.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/lang/IgniteBiTuple.java b/modules/core/src/main/java/org/apache/ignite/lang/IgniteBiTuple.java index 2b79e37..2918199 100644 --- a/modules/core/src/main/java/org/apache/ignite/lang/IgniteBiTuple.java +++ b/modules/core/src/main/java/org/apache/ignite/lang/IgniteBiTuple.java @@ -272,7 +272,6 @@ public class IgniteBiTuple<V1, V2> implements Map<V1, V2>, Map.Entry<V1, V2>, } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { val1 = (V1)in.readObject(); val2 = (V2)in.readObject(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/logger/java/JavaLogger.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/logger/java/JavaLogger.java b/modules/core/src/main/java/org/apache/ignite/logger/java/JavaLogger.java index cbbf849..ce70413 100644 --- a/modules/core/src/main/java/org/apache/ignite/logger/java/JavaLogger.java +++ b/modules/core/src/main/java/org/apache/ignite/logger/java/JavaLogger.java @@ -405,7 +405,6 @@ public class JavaLogger implements IgniteLogger, LoggerNodeIdAware { * @param <T> Class type. * @return First found handler of specified class type or {@code null} if that handler isn't configured. */ - @SuppressWarnings("unchecked") private static <T> T findHandler(Logger log, Class<T> cls) { while (log != null) { for (Handler hnd : log.getHandlers()) { http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java b/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java index ae4033b..742925d 100644 --- a/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java +++ b/modules/core/src/main/java/org/apache/ignite/marshaller/jdk/JdkMarshaller.java @@ -124,7 +124,6 @@ public class JdkMarshaller extends AbstractNodeNameAwareMarshaller { } /** {@inheritDoc} */ - @SuppressWarnings({"unchecked"}) @Override protected <T> T unmarshal0(InputStream in, @Nullable ClassLoader clsLdr) throws IgniteCheckedException { assert in != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java index e094151..7cb153e 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ClientImpl.java @@ -541,7 +541,6 @@ class ClientImpl extends TcpDiscoveryImpl { * @throws IgniteSpiException If failed. * @see TcpDiscoverySpi#joinTimeout */ - @SuppressWarnings("BusyWait") @Nullable private T2<SocketStream, Boolean> joinTopology( InetSocketAddress prevAddr, long timeout, http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java index 27df937..a16e440 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java @@ -2624,7 +2624,6 @@ class ServerImpl extends TcpDiscoveryImpl { */ private class RingMessageWorker extends MessageWorker<TcpDiscoveryAbstractMessage> { /** Next node. */ - @SuppressWarnings({"FieldAccessedSynchronizedAndUnsynchronized"}) private TcpDiscoveryNode next; /** Pending messages. */ http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java index c48fa11..bee7a84 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpDiscoverySpi.java @@ -1174,7 +1174,6 @@ public class TcpDiscoverySpi extends IgniteSpiAdapter implements IgniteDiscovery * @return {@link LinkedHashSet} of internal and external addresses of provided node. * Internal addresses placed before external addresses. */ - @SuppressWarnings("TypeMayBeWeakened") LinkedHashSet<InetSocketAddress> getNodeAddresses(TcpDiscoveryNode node) { LinkedHashSet<InetSocketAddress> res = new LinkedHashSet<>(node.socketAddresses()); @@ -1193,7 +1192,6 @@ public class TcpDiscoverySpi extends IgniteSpiAdapter implements IgniteDiscovery * Internal addresses placed before external addresses. * Internal addresses will be sorted with {@code inetAddressesComparator(sameHost)}. */ - @SuppressWarnings("TypeMayBeWeakened") LinkedHashSet<InetSocketAddress> getNodeAddresses(TcpDiscoveryNode node, boolean sameHost) { List<InetSocketAddress> addrs = U.arrayList(node.socketAddresses()); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java index 763a678..0daf68f 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/internal/TcpDiscoveryNode.java @@ -240,7 +240,6 @@ public class TcpDiscoveryNode extends GridMetadataAwareAdapter implements Ignite } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <T> T attribute(String name) { // Even though discovery SPI removes this attribute after authentication, keep this check for safety. if (IgniteNodeAttributes.ATTR_SECURITY_CREDENTIALS.equals(name)) http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java index 6c47014..0473ab2 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ipfinder/multicast/TcpDiscoveryMulticastIpFinder.java @@ -794,7 +794,6 @@ public class TcpDiscoveryMulticastIpFinder extends TcpDiscoveryVmIpFinder { */ private class AddressSender extends IgniteSpiThread { /** */ - @SuppressWarnings("FieldAccessedSynchronizedAndUnsynchronized") private MulticastSocket sock; /** */ http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/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 5c9b4ac..6287019 100644 --- a/modules/core/src/main/java/org/jsr166/ConcurrentLinkedHashMap.java +++ b/modules/core/src/main/java/org/jsr166/ConcurrentLinkedHashMap.java @@ -111,7 +111,6 @@ import static org.jsr166.ConcurrentLinkedHashMap.QueuePolicy.SINGLE_Q; * @param <K> the type of keys maintained by this map * @param <V> the type of mapped values */ -@SuppressWarnings("NullableProblems") public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements ConcurrentMap<K, V> { /* * The basic strategy is to subdivide the table among Segments, @@ -599,7 +598,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements * @param newVal New value * @return {@code true} If value was replaced. */ - @SuppressWarnings({"unchecked"}) boolean replace(K key, int hash, V oldVal, V newVal) { writeLock().lock(); @@ -634,7 +632,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements * @return {@code oldVal}, if value was replaced, non-null object if map * contained some other value and {@code null} if there were no such key. */ - @SuppressWarnings({"unchecked"}) V replacex(K key, int hash, V oldVal, V newVal) { writeLock().lock(); @@ -663,7 +660,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements return replaced; } - @SuppressWarnings({"unchecked"}) V replace(K key, int hash, V newVal) { writeLock().lock(); @@ -688,7 +684,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements return oldVal; } - @SuppressWarnings({"unchecked"}) V put(K key, int hash, V val, boolean onlyIfAbsent) { writeLock().lock(); @@ -810,7 +805,7 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements /** * This method is called under the segment lock. */ - @SuppressWarnings({"ForLoopReplaceableByForEach", "unchecked"}) + @SuppressWarnings({"ForLoopReplaceableByForEach"}) void rehash() { HashEntry<K, V>[] oldTbl = tbl; int oldCap = oldTbl.length; @@ -1093,7 +1088,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements * negative or the load factor or concurLvl are * non-positive. */ - @SuppressWarnings({"unchecked"}) public ConcurrentLinkedHashMap(int initCap, float loadFactor, int concurLvl) { this(initCap, loadFactor, concurLvl, 0); } @@ -1477,7 +1471,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements * * @throws NullPointerException if the specified key is null */ - @SuppressWarnings("NullableProblems") @Override public boolean remove(Object key, Object val) { int hash = hash(key.hashCode()); @@ -1489,7 +1482,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements * * @throws NullPointerException if any of the arguments are null */ - @SuppressWarnings("NullableProblems") @Override public boolean replace(K key, V oldVal, V newVal) { if (oldVal == null || newVal == null) throw new NullPointerException(); @@ -1534,7 +1526,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements * or <tt>null</tt> if there was no mapping for the key * @throws NullPointerException if the specified key or value is null */ - @SuppressWarnings("NullableProblems") @Override public V replace(K key, V val) { if (val == null) throw new NullPointerException(); @@ -1941,7 +1932,6 @@ public class ConcurrentLinkedHashMap<K, V> extends AbstractMap<K, V> implements * @param e Current next. * @return {@code True} if advance succeeded. */ - @SuppressWarnings( {"unchecked"}) private boolean advanceInBucket(@Nullable HashEntry<K, V> e, boolean skipFirst) { if (e == null) return false; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/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 983afde..61d0aa0 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestIoUtils.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestIoUtils.java @@ -81,7 +81,6 @@ public final class GridTestIoUtils { * @throws IOException If deserialization failed. * @throws ClassNotFoundException If deserialization failed. */ - @SuppressWarnings({"unchecked"}) public static <T extends Serializable> T deserializeJdk(byte[] bytes) throws IOException, ClassNotFoundException { ObjectInputStream in = null; @@ -105,7 +104,6 @@ public final class GridTestIoUtils { * @throws IOException If deserialization failed. * @throws ClassNotFoundException If deserialization failed. */ - @SuppressWarnings({"unchecked"}) public static <T> T deserializeJdk(byte[] bytes, final ClassLoader clsLdr) throws IOException, ClassNotFoundException { ObjectInputStream in = null; @@ -131,7 +129,6 @@ public final class GridTestIoUtils { * @return The same object, but passed through marshaller: obj->marshal->buf->unmarshal->copy. * @throws Exception If failed. */ - @SuppressWarnings("unchecked") public static <T> T externalize(Externalizable obj, Marshaller marshaller) throws Exception { assert marshaller != null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/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 2ad9e61..8ccf0c1 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestJobContext.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestJobContext.java @@ -61,7 +61,6 @@ public class GridTestJobContext implements ComputeJobContext { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <K, V> V getAttribute(K key) { return (V)attrs.get(key); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/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 618cdbb..3b5f48e 100644 --- a/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java +++ b/modules/core/src/test/java/org/apache/ignite/GridTestTaskSession.java @@ -153,7 +153,6 @@ public class GridTestTaskSession implements ComputeTaskSession { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public <K, V> V getAttribute(K key) { return (V)attrs.get(key); } http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunctionSimpleBenchmark.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunctionSimpleBenchmark.java b/modules/core/src/test/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunctionSimpleBenchmark.java index 7dec6b2..abc6455 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunctionSimpleBenchmark.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunctionSimpleBenchmark.java @@ -1042,7 +1042,6 @@ public class RendezvousAffinityFunctionSimpleBenchmark extends GridCommonAbstrac } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { parts = in.readInt(); exclNeighbors = in.readBoolean(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/ClusterGroupSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/ClusterGroupSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/ClusterGroupSelfTest.java index 0fb9f80..3816513 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/ClusterGroupSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/ClusterGroupSelfTest.java @@ -55,7 +55,6 @@ public class ClusterGroupSelfTest extends ClusterGroupAbstractTest { private static Ignite ignite; /** {@inheritDoc} */ - @SuppressWarnings({"ConstantConditions"}) @Override protected void beforeTestsStarted() throws Exception { assert NODES_CNT > 2; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageRuntimeConfigurationSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageRuntimeConfigurationSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageRuntimeConfigurationSelfTest.java index 22f917c..816d43e 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageRuntimeConfigurationSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridEventStorageRuntimeConfigurationSelfTest.java @@ -53,7 +53,6 @@ public class GridEventStorageRuntimeConfigurationSelfTest extends GridCommonAbst private int[] inclEvtTypes; /** {@inheritDoc} */ - @SuppressWarnings("deprecation") @Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleVersionsDeploymentSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleVersionsDeploymentSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleVersionsDeploymentSelfTest.java index 33bfb22..793de58 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleVersionsDeploymentSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridMultipleVersionsDeploymentSelfTest.java @@ -104,7 +104,6 @@ public class GridMultipleVersionsDeploymentSelfTest extends GridCommonAbstractTe /** * @throws Exception If test failed. */ - @SuppressWarnings("unchecked") @Test public void testMultipleVersionsLocalDeploy() throws Exception { try { @@ -164,7 +163,6 @@ public class GridMultipleVersionsDeploymentSelfTest extends GridCommonAbstractTe /** * @throws Exception If test failed. */ - @SuppressWarnings("unchecked") @Test public void testMultipleVersionsP2PDeploy() throws Exception { try { http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/GridSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/GridSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/GridSelfTest.java index 32b0e8a..2b3e625 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/GridSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/GridSelfTest.java @@ -43,7 +43,6 @@ public class GridSelfTest extends ClusterGroupAbstractTest { private static final int NODES_CNT = 4; /** {@inheritDoc} */ - @SuppressWarnings({"ConstantConditions"}) @Override protected void beforeTestsStarted() throws Exception { assert NODES_CNT > 2; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectApiExceptionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectApiExceptionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectApiExceptionTest.java index e964ebb..b20d5b0 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectApiExceptionTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectApiExceptionTest.java @@ -225,7 +225,6 @@ public class IgniteClientReconnectApiExceptionTest extends IgniteClientReconnect /** * @throws Exception If failed. */ - @SuppressWarnings("unchecked") private void cacheOperationsTest() throws Exception { clientMode = true; @@ -543,7 +542,6 @@ public class IgniteClientReconnectApiExceptionTest extends IgniteClientReconnect /** * @throws Exception If failed. */ - @SuppressWarnings("unchecked") private void igniteOperationsTest() throws Exception { clientMode = true; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/IgniteExplicitImplicitDeploymentSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/IgniteExplicitImplicitDeploymentSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/IgniteExplicitImplicitDeploymentSelfTest.java index c39e725..1144348 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/IgniteExplicitImplicitDeploymentSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/IgniteExplicitImplicitDeploymentSelfTest.java @@ -125,7 +125,6 @@ public class IgniteExplicitImplicitDeploymentSelfTest extends GridCommonAbstract * @param byName If {@code true} than executes task by class name. * @throws Exception If test failed. */ - @SuppressWarnings("unchecked") private void execExplicitDeployLocally(boolean byCls, boolean byTask, boolean byName) throws Exception { Ignite ignite = null; @@ -191,7 +190,6 @@ public class IgniteExplicitImplicitDeploymentSelfTest extends GridCommonAbstract * @param byName If {@code true} than executes task by class name. * @throws Exception If test failed. */ - @SuppressWarnings("unchecked") private void execImplicitDeployLocally(boolean byCls, boolean byTask, boolean byName) throws Exception { Ignite ignite = null; @@ -270,7 +268,6 @@ public class IgniteExplicitImplicitDeploymentSelfTest extends GridCommonAbstract * @param byName If {@code true} than executes task by class name. * @throws Exception If test failed. */ - @SuppressWarnings("unchecked") private void execExplicitDeployP2P(boolean byCls, boolean byTask, boolean byName) throws Exception { Ignite ignite1 = null; Ignite ignite2 = null; @@ -342,7 +339,6 @@ public class IgniteExplicitImplicitDeploymentSelfTest extends GridCommonAbstract * @param byName If {@code true} than executes task by class name. * @throws Exception If test failed. */ - @SuppressWarnings("unchecked") private void execImplicitDeployP2P(boolean byCls, boolean byTask, boolean byName) throws Exception { Ignite ignite1 = null; Ignite ignite2 = null; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/binary/BinaryObjectTypeCompatibilityTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/binary/BinaryObjectTypeCompatibilityTest.java b/modules/core/src/test/java/org/apache/ignite/internal/binary/BinaryObjectTypeCompatibilityTest.java index 423c3d1..773d94c 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/binary/BinaryObjectTypeCompatibilityTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/binary/BinaryObjectTypeCompatibilityTest.java @@ -167,7 +167,6 @@ public class BinaryObjectTypeCompatibilityTest extends GridCommonAbstractTest { * @param <T> Result type. * @return Deserialized value, if {@link BinaryObject} was provided, or the same object otherwise. */ - @SuppressWarnings("unchecked") private <T> T deserialize(Object obj) { if (obj instanceof BinaryObject) return ((BinaryObject)obj).deserialize(); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/direct/stream/v2/DirectByteBufferStreamImplV2ByteOrderSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/direct/stream/v2/DirectByteBufferStreamImplV2ByteOrderSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/direct/stream/v2/DirectByteBufferStreamImplV2ByteOrderSelfTest.java index 74e9f0f..5d5675b 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/direct/stream/v2/DirectByteBufferStreamImplV2ByteOrderSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/direct/stream/v2/DirectByteBufferStreamImplV2ByteOrderSelfTest.java @@ -504,7 +504,6 @@ public class DirectByteBufferStreamImplV2ByteOrderSelfTest extends TestCase { * @param <T> Array type. * @return {@code ArrayCreator} for a required type. */ - @SuppressWarnings("unchecked") private <T> DirectByteBufferStreamImplV2.ArrayCreator<T> arrayCreator(final T arr) { return new DirectByteBufferStreamImplV2.ArrayCreator<T>() { @Override public T create(int len) { http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessorAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessorAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessorAbstractSelfTest.java index 1ce1e24..598f754 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessorAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/affinity/GridAffinityProcessorAbstractSelfTest.java @@ -91,7 +91,6 @@ public abstract class GridAffinityProcessorAbstractSelfTest extends GridCommonAb protected abstract AffinityFunction affinityFunction(); /** {@inheritDoc} */ - @SuppressWarnings({"ConstantConditions"}) @Override protected void beforeTestsStarted() throws Exception { assert NODES_CNT >= 1; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheConcurrentReadThroughTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheConcurrentReadThroughTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheConcurrentReadThroughTest.java index e26d901..1fa96b7 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheConcurrentReadThroughTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheConcurrentReadThroughTest.java @@ -62,7 +62,6 @@ public class CacheConcurrentReadThroughTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(gridName); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsManageTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsManageTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsManageTest.java index 4121ceb..610ac90 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsManageTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheMetricsManageTest.java @@ -500,7 +500,6 @@ public class CacheMetricsManageTest extends GridCommonAbstractTest { } /** {@inheritDoc} */ - @SuppressWarnings("unchecked") @Override protected IgniteConfiguration getConfiguration(String igniteInstanceName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(igniteInstanceName); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java index e709bfd..c26589a 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractFullApiSelfTest.java @@ -4484,7 +4484,6 @@ public abstract class GridCacheAbstractFullApiSelfTest extends GridCacheAbstract storeStgy.removeFromStore(key); assertTrue(GridTestUtils.waitForCondition(new GridAbsPredicateX() { - @SuppressWarnings("unchecked") @Override public boolean applyx() { try { Integer val = c.get(key); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractMetricsSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractMetricsSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractMetricsSelfTest.java index 873987a..0949177 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractMetricsSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheAbstractMetricsSelfTest.java @@ -1029,7 +1029,6 @@ public abstract class GridCacheAbstractMetricsSelfTest extends GridCacheAbstract storeStgy.removeFromStore(key); assertTrue(GridTestUtils.waitForCondition(new GridAbsPredicateX() { - @SuppressWarnings("unchecked") @Override public boolean applyx() { try { if (c.get(key) != null) http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeLoadTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeLoadTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeLoadTest.java index 9f94ea8..b6e2288 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeLoadTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheConcurrentTxMultiNodeLoadTest.java @@ -269,7 +269,7 @@ public class GridCacheConcurrentTxMultiNodeLoadTest extends GridCommonAbstractTe */ private void displayReqCount() { new Thread(new Runnable() { - @SuppressWarnings({"BusyWait", "InfiniteLoopStatement"}) + @SuppressWarnings({"BusyWait"}) @Override public void run() { int interval = 10; http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentSelfTest.java index f3aa2c3..62eeaff 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheDeploymentSelfTest.java @@ -237,14 +237,12 @@ public class GridCacheDeploymentSelfTest extends GridCommonAbstractTest { } /** @throws Exception If failed. */ - @SuppressWarnings("unchecked") @Test public void testDeployment4() throws Exception { doDeployment4(false); } /** @throws Exception If failed. */ - @SuppressWarnings("unchecked") @Test public void testDeployment4BackupLeavesGrid() throws Exception { doDeployment4(true); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheInterceptorAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheInterceptorAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheInterceptorAbstractSelfTest.java index 04a3cfa..8c42096 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheInterceptorAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheInterceptorAbstractSelfTest.java @@ -1163,7 +1163,6 @@ public abstract class GridCacheInterceptorAbstractSelfTest extends GridCacheAbst * @param expOld Expected expOld value. * @throws Exception If failed. */ - @SuppressWarnings("unchecked") private void update(int grid, Operation op, String key, final Integer val, @Nullable final Integer expOld) throws Exception { cacheUpdate(grid, false, op, key, val, expOld, null); @@ -1177,7 +1176,6 @@ public abstract class GridCacheInterceptorAbstractSelfTest extends GridCacheAbst * @param expRmvRet Expected remove result. * @throws Exception If failed. */ - @SuppressWarnings("unchecked") private void remove(int grid, Operation op, String key, @Nullable final Integer expOld, @Nullable final Integer expRmvRet) throws Exception { cacheUpdate(grid, true, op, key, null, expOld, expRmvRet); @@ -1193,7 +1191,6 @@ public abstract class GridCacheInterceptorAbstractSelfTest extends GridCacheAbst * @param expRmvRet Expected remove result. * @throws Exception If failed. */ - @SuppressWarnings("unchecked") private void cacheUpdate(int grid, boolean rmv, Operation op, String key, final Integer val, @Nullable final Integer expOld, @Nullable final Integer expRmvRet) throws Exception { @@ -1277,7 +1274,6 @@ public abstract class GridCacheInterceptorAbstractSelfTest extends GridCacheAbst * @param map Key/values map. * @throws Exception If failed. */ - @SuppressWarnings("unchecked") private void batchUpdate(int grid, Operation op, final Map<String, Integer> map) throws Exception { cacheBatchUpdate(grid, false, op, map); } @@ -1288,7 +1284,6 @@ public abstract class GridCacheInterceptorAbstractSelfTest extends GridCacheAbst * @param map Key/values map. * @throws Exception If failed. */ - @SuppressWarnings("unchecked") private void batchRemove(int grid, Operation op, final Map<String, Integer> map) throws Exception { cacheBatchUpdate(grid, true, op, map); } @@ -1300,7 +1295,6 @@ public abstract class GridCacheInterceptorAbstractSelfTest extends GridCacheAbst * @param map Key/values map. * @throws Exception If failed. */ - @SuppressWarnings("unchecked") private void cacheBatchUpdate(int grid, boolean rmv, Operation op, final Map<String, Integer> map) throws Exception { IgniteCache<String, Integer> cache = jcache(grid); http://git-wip-us.apache.org/repos/asf/ignite/blob/ad9d5610/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheMvccSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheMvccSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheMvccSelfTest.java index 1644103..fda6a4b 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheMvccSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheMvccSelfTest.java @@ -1360,7 +1360,6 @@ public class GridCacheMvccSelfTest extends GridCommonAbstractTest { /** * @throws Exception If failed. */ - @SuppressWarnings({"ObjectEquality"}) @Test public void testUsedCandidates() throws Exception { GridCacheAdapter<String, String> cache = grid.internalCache(DEFAULT_CACHE_NAME);
