You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by dp...@apache.org on 2018/12/18 16:24:49 UTC
[2/5] ignite git commit: IGNITE-10709 New inspections introduced in
2018+ IntelliJ IDEA version were disabled on TC configuration,
unused Suppress removal. - Fixes #5680.
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);