Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id C105B200BB4 for ; Tue, 18 Oct 2016 01:37:31 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id BF7EE160AEC; Mon, 17 Oct 2016 23:37:31 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id DF2B1160AF0 for ; Tue, 18 Oct 2016 01:37:30 +0200 (CEST) Received: (qmail 74005 invoked by uid 500); 17 Oct 2016 23:37:30 -0000 Mailing-List: contact commits-help@geode.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@geode.incubator.apache.org Delivered-To: mailing list commits@geode.incubator.apache.org Received: (qmail 73992 invoked by uid 99); 17 Oct 2016 23:37:30 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 17 Oct 2016 23:37:30 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 955BDC05BF for ; Mon, 17 Oct 2016 23:37:29 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -6.219 X-Spam-Level: X-Spam-Status: No, score=-6.219 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id 7sa82T7b3ccK for ; Mon, 17 Oct 2016 23:37:27 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id 5538B5F24B for ; Mon, 17 Oct 2016 23:37:26 +0000 (UTC) Received: (qmail 73254 invoked by uid 99); 17 Oct 2016 23:37:25 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 17 Oct 2016 23:37:25 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 607D5E00DC; Mon, 17 Oct 2016 23:37:25 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: klund@apache.org To: commits@geode.incubator.apache.org Date: Mon, 17 Oct 2016 23:37:25 -0000 Message-Id: X-Mailer: ASF-Git Admin Mailer Subject: [1/5] incubator-geode git commit: GEODE-2007: fix unchecked warnings archived-at: Mon, 17 Oct 2016 23:37:31 -0000 Repository: incubator-geode Updated Branches: refs/heads/develop a3bd25664 -> 5c50954d1 GEODE-2007: fix unchecked warnings Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/a53c4b15 Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/a53c4b15 Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/a53c4b15 Branch: refs/heads/develop Commit: a53c4b1509867a1847b8a21ef8b926911f874bb1 Parents: 7330733 Author: Kirk Lund Authored: Mon Oct 17 12:49:00 2016 -0700 Committer: Kirk Lund Committed: Mon Oct 17 16:30:19 2016 -0700 ---------------------------------------------------------------------- .../apache/geode/modules/session/catalina/DeltaSession7.java | 3 +-- .../modules/session/Tomcat8SessionsClientServerDUnitTest.java | 3 ++- .../org/apache/geode/internal/cache/GemFireCacheImpl.java | 2 +- .../org/apache/geode/internal/cache/ha/HARegionQueue.java | 7 ++++--- .../cache/tier/sockets/DeltaPropagationWithCQDUnitTest.java | 4 ++-- .../test/java/org/apache/geode/OldClientSupportDUnitTest.java | 4 ++-- 6 files changed, 12 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a53c4b15/extensions/geode-modules-tomcat7/src/main/java/org/apache/geode/modules/session/catalina/DeltaSession7.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-tomcat7/src/main/java/org/apache/geode/modules/session/catalina/DeltaSession7.java b/extensions/geode-modules-tomcat7/src/main/java/org/apache/geode/modules/session/catalina/DeltaSession7.java index 0df05ff..c0dfe23 100644 --- a/extensions/geode-modules-tomcat7/src/main/java/org/apache/geode/modules/session/catalina/DeltaSession7.java +++ b/extensions/geode-modules-tomcat7/src/main/java/org/apache/geode/modules/session/catalina/DeltaSession7.java @@ -535,8 +535,7 @@ public class DeltaSession7 extends StandardSession implements DataSerializable, } } - @SuppressWarnings({"unchecked", "rawtypes"}) - protected ConcurrentMap readInAttributes(final DataInput in) throws IOException, ClassNotFoundException { + protected ConcurrentMap readInAttributes(final DataInput in) throws IOException, ClassNotFoundException { return DataSerializer.readObject(in); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a53c4b15/extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/Tomcat8SessionsClientServerDUnitTest.java ---------------------------------------------------------------------- diff --git a/extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/Tomcat8SessionsClientServerDUnitTest.java b/extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/Tomcat8SessionsClientServerDUnitTest.java index 8b29048..384689e 100644 --- a/extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/Tomcat8SessionsClientServerDUnitTest.java +++ b/extensions/geode-modules-tomcat8/src/test/java/org/apache/geode/modules/session/Tomcat8SessionsClientServerDUnitTest.java @@ -19,6 +19,7 @@ package org.apache.geode.modules.session; import static org.apache.geode.distributed.ConfigurationProperties.*; import static org.apache.geode.internal.cache.CacheServerLauncher.serverPort; +import java.util.List; import java.util.Properties; import org.junit.experimental.categories.Category; @@ -49,7 +50,7 @@ public class Tomcat8SessionsClientServerDUnitTest extends TestSessionsTomcat8Bas @Override public void preTearDown() { vm0.invoke(() -> { - GemFireCacheImpl.getInstance().getCacheServers().forEach(e -> ((CacheServer)e).stop()); + (GemFireCacheImpl.getInstance().getCacheServers()).forEach(cacheServer -> cacheServer.stop()); }); server.stopContainer(); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a53c4b15/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java b/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java index 6c195e7..f673ded 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/GemFireCacheImpl.java @@ -4015,7 +4015,7 @@ public class GemFireCacheImpl implements InternalCache, ClientCache, HasCachePer } } - public List getCacheServers() { + public List getCacheServers() { List cacheServersWithoutReceiver = null; if (!allCacheServers.isEmpty()) { Iterator allCacheServersIterator = allCacheServers.iterator(); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a53c4b15/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java index 027a1b5..f2b1185 100755 --- a/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java +++ b/geode-core/src/main/java/org/apache/geode/internal/cache/ha/HARegionQueue.java @@ -22,6 +22,7 @@ import org.apache.geode.cache.TimeoutException; import org.apache.geode.cache.query.internal.CqQueryVsdStats; import org.apache.geode.cache.query.internal.cq.CqService; import org.apache.geode.cache.query.internal.cq.InternalCqQuery; +import org.apache.geode.cache.server.CacheServer; import org.apache.geode.cache.util.CacheListenerAdapter; import org.apache.geode.distributed.DistributedMember; import org.apache.geode.distributed.internal.DM; @@ -2987,10 +2988,10 @@ protected boolean checkEventForRemoval(Long counter, ThreadIdentifier threadid, && !queueRemovalMessageList.isEmpty()) { // messages exist QueueRemovalMessage qrm = new QueueRemovalMessage(); qrm.resetRecipients(); - List servers = this.cache.getCacheServers(); + List servers = this.cache.getCacheServers(); List recipients = new LinkedList(); - for (CacheServerImpl server: servers) { - recipients.addAll(server.getCacheServerAdvisor().adviseBridgeServers()); + for (CacheServer server: servers) { + recipients.addAll(CacheServerImpl.class.cast(server).getCacheServerAdvisor().adviseBridgeServers()); } qrm.setRecipients(recipients); qrm.setMessagesList(queueRemovalMessageList); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a53c4b15/geode-cq/src/test/java/org/apache/geode/internal/cache/tier/sockets/DeltaPropagationWithCQDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-cq/src/test/java/org/apache/geode/internal/cache/tier/sockets/DeltaPropagationWithCQDUnitTest.java b/geode-cq/src/test/java/org/apache/geode/internal/cache/tier/sockets/DeltaPropagationWithCQDUnitTest.java index 3990265..119b382 100644 --- a/geode-cq/src/test/java/org/apache/geode/internal/cache/tier/sockets/DeltaPropagationWithCQDUnitTest.java +++ b/geode-cq/src/test/java/org/apache/geode/internal/cache/tier/sockets/DeltaPropagationWithCQDUnitTest.java @@ -200,10 +200,10 @@ public class DeltaPropagationWithCQDUnitTest extends JUnit4DistributedTestCase { public static void verifyFullValueRequestsFromClients(Long expected) throws Exception { - List servers = ((GemFireCacheImpl)cache).getCacheServers(); + List servers = ((GemFireCacheImpl)cache).getCacheServers(); assertEquals("expected one server but found these: " + servers, 1, servers.size()); - CacheClientProxy[] proxies = servers.get(0).getAcceptor().getCacheClientNotifier() + CacheClientProxy[] proxies = CacheServerImpl.class.cast(servers.get(0)).getAcceptor().getCacheClientNotifier() .getClientProxies().toArray(new CacheClientProxy[0]); // find the proxy for the client that processed the CQs - it will have http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/a53c4b15/geode-old-client-support/src/test/java/org/apache/geode/OldClientSupportDUnitTest.java ---------------------------------------------------------------------- diff --git a/geode-old-client-support/src/test/java/org/apache/geode/OldClientSupportDUnitTest.java b/geode-old-client-support/src/test/java/org/apache/geode/OldClientSupportDUnitTest.java index 0b48e16..36d13b5 100644 --- a/geode-old-client-support/src/test/java/org/apache/geode/OldClientSupportDUnitTest.java +++ b/geode-old-client-support/src/test/java/org/apache/geode/OldClientSupportDUnitTest.java @@ -102,8 +102,8 @@ public class OldClientSupportDUnitTest extends JUnit4CacheTestCase { } } - private Object instantiate(Class aClass) throws Exception { - Constructor c = null; + private Object instantiate(Class aClass) throws Exception { + Constructor c = null; try { c = aClass.getConstructor(); return c.newInstance();