Return-Path: X-Original-To: apmail-geode-commits-archive@minotaur.apache.org Delivered-To: apmail-geode-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 401EA1899E for ; Fri, 19 Feb 2016 18:36:45 +0000 (UTC) Received: (qmail 19833 invoked by uid 500); 19 Feb 2016 18:36:45 -0000 Delivered-To: apmail-geode-commits-archive@geode.apache.org Received: (qmail 19798 invoked by uid 500); 19 Feb 2016 18:36:45 -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 19789 invoked by uid 99); 19 Feb 2016 18:36:45 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 19 Feb 2016 18:36:45 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 9F142C191F for ; Fri, 19 Feb 2016 18:36:44 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -3.226 X-Spam-Level: X-Spam-Status: No, score=-3.226 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=-0.006] autolearn=disabled Received: from mx2-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id BbzY2e3wFFPg for ; Fri, 19 Feb 2016 18:36:42 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx2-lw-eu.apache.org (ASF Mail Server at mx2-lw-eu.apache.org) with SMTP id 282C65F1D5 for ; Fri, 19 Feb 2016 18:36:39 +0000 (UTC) Received: (qmail 19571 invoked by uid 99); 19 Feb 2016 18:36:39 -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; Fri, 19 Feb 2016 18:36:39 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 47760E09C5; Fri, 19 Feb 2016 18:36:39 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: upthewaterspout@apache.org To: commits@geode.incubator.apache.org Date: Fri, 19 Feb 2016 18:36:52 -0000 Message-Id: <20fab825f6934f94b6afbf5955be40f3@git.apache.org> In-Reply-To: <6b97abc8452d42b888de3a2f139a1c3f@git.apache.org> References: <6b97abc8452d42b888de3a2f139a1c3f@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [15/63] [abbrv] incubator-geode git commit: Automatically converting calls of vm.invoke to lambdas http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WANSSLDUnitTest.java ---------------------------------------------------------------------- diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WANSSLDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WANSSLDUnitTest.java index fba8b2e..36f1226 100644 --- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WANSSLDUnitTest.java +++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WANSSLDUnitTest.java @@ -33,31 +33,29 @@ public class WANSSLDUnitTest extends WANTestBase{ } public void testSenderSSLReceiverSSL(){ - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); - vm2.invoke(WANTestBase.class, "createReceiverWithSSL", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiverWithSSL( nyPort )); - vm4.invoke(WANTestBase.class, "createCacheWithSSL", new Object[] { lnPort }); + vm4.invoke(() -> WANTestBase.createCacheWithSSL( lnPort )); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", - 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", + 1000 )); - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName() + "_RR", 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName() + "_RR", 1000 )); } public void testSenderNoSSLReceiverSSL() { @@ -65,32 +63,29 @@ public class WANSSLDUnitTest extends WANTestBase{ IgnoredException.addIgnoredException("SSL Error"); IgnoredException.addIgnoredException("Unrecognized SSL message"); try { - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); - vm2.invoke(WANTestBase.class, "createReceiverWithSSL", - new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiverWithSSL( nyPort )); - vm4.invoke(WANTestBase.class, "createCache", new Object[] { lnPort }); + vm4.invoke(() -> WANTestBase.createCache( lnPort )); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", - 1000 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", + 1000 )); - vm2.invoke(WANTestBase.class, "validateRegionSize", new Object[] { - getTestMethodName() + "_RR", 1000 }); + vm2.invoke(() -> WANTestBase.validateRegionSize( + getTestMethodName() + "_RR", 1000 )); fail("Expected exception as only Receiver is SSL enabled. Not Sender"); } catch (Exception e) { @@ -101,32 +96,29 @@ public class WANSSLDUnitTest extends WANTestBase{ public void testSenderSSLReceiverNoSSL(){ IgnoredException.addIgnoredException("Acceptor received unknown"); IgnoredException.addIgnoredException("failed accepting client"); - Integer lnPort = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); - Integer nyPort = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnPort }); + Integer lnPort = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); + Integer nyPort = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnPort )); - vm2.invoke(WANTestBase.class, "createReceiver", new Object[] { nyPort }); + vm2.invoke(() -> WANTestBase.createReceiver( nyPort )); - vm4.invoke(WANTestBase.class, "createCacheWithSSL", - new Object[] { lnPort }); + vm4.invoke(() -> WANTestBase.createCacheWithSSL( lnPort )); - vm4.invoke(WANTestBase.class, "createSender", new Object[] { "ln", 2, - false, 100, 10, false, false, null, true }); + vm4.invoke(() -> WANTestBase.createSender( "ln", 2, + false, 100, 10, false, false, null, true )); - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", null, isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", null, isOffHeap() )); - vm4.invoke(WANTestBase.class, "startSender", new Object[] { "ln" }); + vm4.invoke(() -> WANTestBase.startSender( "ln" )); - vm4.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm4.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm4.invoke(WANTestBase.class, "doPuts", new Object[] { getTestMethodName() + "_RR", - 1 }); + vm4.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", + 1 )); - Boolean doesSizeMatch = (Boolean)vm2.invoke(WANSSLDUnitTest.class, "ValidateSSLRegionSize", new Object[] { - getTestMethodName() + "_RR", 1 }); + Boolean doesSizeMatch = (Boolean)vm2.invoke(() -> WANSSLDUnitTest.ValidateSSLRegionSize( + getTestMethodName() + "_RR", 1 )); assertFalse(doesSizeMatch); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/69024aa9/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java ---------------------------------------------------------------------- diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java index 459b718..b92de53 100644 --- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java +++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/misc/WanAutoDiscoveryDUnitTest.java @@ -52,8 +52,8 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { public void test_GatewaySender_Started_Before_Locator() { try { int port = AvailablePortHelper.getRandomAvailablePortForDUnitSite(); - vm0.invoke(WANTestBase.class, "createCache", new Object[]{port}); - vm0.invoke(WANTestBase.class, "createSender", new Object[]{"ln",2,false,100,10,false,false, null, false}); + vm0.invoke(() -> WANTestBase.createCache(port)); + vm0.invoke(() -> WANTestBase.createSender("ln",2,false,100,10,false,false, null, false)); fail("Expected GemFireConfigException but not thrown"); } catch (Exception e) { @@ -74,13 +74,10 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { */ public void __test_AllLocatorsinDSShouldHaveDistributedSystemId() throws Exception { try { - Integer lnLocPort1 = (Integer)vm0.invoke( - WANTestBase.class, "createFirstLocatorWithDSId", - new Object[] {1}); + Integer lnLocPort1 = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1)); - Integer lnLocPort2 = (Integer)vm1.invoke( - WANTestBase.class, "createSecondLocator", new Object[] { 2, - lnLocPort1 }); + Integer lnLocPort2 = (Integer)vm1.invoke(() -> WANTestBase.createSecondLocator( 2, + lnLocPort1 )); fail("Expected IncompatibleSystemException but not thrown"); } catch (Exception e) { @@ -100,34 +97,25 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { Map> dsVsPort = new HashMap>(); dsVsPort.put(1, locatorPorts); - Integer lnLocPort1 = (Integer)vm0.invoke( - WANTestBase.class, "createFirstLocatorWithDSId", - new Object[] {1}); + Integer lnLocPort1 = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId(1)); locatorPorts.add(lnLocPort1); - Integer lnLocPort2 = (Integer)vm1.invoke(WANTestBase.class, - "createSecondLocator", new Object[] { 1, lnLocPort1 }); + Integer lnLocPort2 = (Integer)vm1.invoke(() -> WANTestBase.createSecondLocator( 1, lnLocPort1 )); locatorPorts.add(lnLocPort2); locatorPorts = new ArrayList(); dsVsPort.put(2, locatorPorts); - Integer nyLocPort1 = (Integer)vm2.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnLocPort1 }); + Integer nyLocPort1 = (Integer)vm2.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnLocPort1 )); locatorPorts.add(nyLocPort1); - Integer nyLocPort2 = (Integer)vm3.invoke( - WANTestBase.class, "createSecondRemoteLocator", new Object[] { - 2, nyLocPort1, lnLocPort1}); + Integer nyLocPort2 = (Integer)vm3.invoke(() -> WANTestBase.createSecondRemoteLocator( + 2, nyLocPort1, lnLocPort1)); locatorPorts.add(nyLocPort2); - vm0.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm1.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm2.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm3.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); + vm0.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm1.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm2.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm3.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); } /** @@ -141,36 +129,28 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { ArrayList locatorPorts = new ArrayList(); dsVsPort.put(1, locatorPorts); - Integer lnLocPort1 = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnLocPort1 = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); locatorPorts.add(lnLocPort1); locatorPorts = new ArrayList(); dsVsPort.put(2, locatorPorts); - Integer nyLocPort1 = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnLocPort1 }); + Integer nyLocPort1 = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnLocPort1 )); locatorPorts.add(nyLocPort1); locatorPorts = new ArrayList(); dsVsPort.put(3, locatorPorts); - Integer tkLocPort = (Integer)vm2.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 3, lnLocPort1 }); + Integer tkLocPort = (Integer)vm2.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, lnLocPort1 )); locatorPorts.add(tkLocPort); locatorPorts = new ArrayList(); dsVsPort.put(4, locatorPorts); - Integer hkLocPort = (Integer)vm3.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 4, lnLocPort1 }); + Integer hkLocPort = (Integer)vm3.invoke(() -> WANTestBase.createFirstRemoteLocator( 4, lnLocPort1 )); locatorPorts.add(hkLocPort); - vm0.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm1.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm2.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm3.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); + vm0.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm1.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm2.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm3.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); } public void test_TK_Recognises_LN_AND_NY() { @@ -180,29 +160,23 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { ArrayList locatorPorts = new ArrayList(); dsVsPort.put(1, locatorPorts); - Integer lnLocPort1 = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnLocPort1 = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); locatorPorts.add(lnLocPort1); locatorPorts = new ArrayList(); dsVsPort.put(2, locatorPorts); - Integer nyLocPort1 = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnLocPort1 }); + Integer nyLocPort1 = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnLocPort1 )); locatorPorts.add(nyLocPort1); locatorPorts = new ArrayList(); dsVsPort.put(3, locatorPorts); - Integer tkLocPort = (Integer)vm2.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 3, nyLocPort1 }); + Integer tkLocPort = (Integer)vm2.invoke(() -> WANTestBase.createFirstRemoteLocator( 3, nyLocPort1 )); locatorPorts.add(tkLocPort); - vm0.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm1.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm2.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); + vm0.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm1.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm2.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); } public void test_NY_Recognises_TK_AND_HK_Simeltenously() { @@ -210,14 +184,12 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { ArrayList locatorPortsln = new ArrayList(); dsVsPort.put(1, locatorPortsln); - Integer lnLocPort1 = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnLocPort1 = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); locatorPortsln.add(lnLocPort1); ArrayList locatorPortsny = new ArrayList(); dsVsPort.put(2, locatorPortsny); - Integer nyLocPort1 = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnLocPort1 }); + Integer nyLocPort1 = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnLocPort1 )); locatorPortsny.add(nyLocPort1); int AsyncInvocationArrSize = 4; @@ -225,21 +197,17 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { ArrayList locatorPortstk = new ArrayList(); dsVsPort.put(3, locatorPortstk); - async[0] = vm2.invokeAsync(WANTestBase.class, "createFirstRemoteLocator", - new Object[] { 3, lnLocPort1 }); + async[0] = vm2.invokeAsync(() -> WANTestBase.createFirstRemoteLocator( 3, lnLocPort1 )); ArrayList locatorPortshk = new ArrayList(); dsVsPort.put(4, locatorPortshk); - async[1] = vm3.invokeAsync( - WANTestBase.class, "createFirstRemoteLocator", new Object[] {4, nyLocPort1}); + async[1] = vm3.invokeAsync(() -> WANTestBase.createFirstRemoteLocator(4, nyLocPort1)); ArrayList locatorPortsln2 = new ArrayList(); - async[2] = vm4.invokeAsync(WANTestBase.class, - "createSecondLocator", new Object[] { 1, lnLocPort1 }); + async[2] = vm4.invokeAsync(() -> WANTestBase.createSecondLocator( 1, lnLocPort1 )); ArrayList locatorPortsny2 = new ArrayList(); - async[3] = vm5.invokeAsync(WANTestBase.class, - "createSecondLocator", new Object[] { 2, nyLocPort1 }); + async[3] = vm5.invokeAsync(() -> WANTestBase.createSecondLocator( 2, nyLocPort1 )); try { @@ -257,61 +225,50 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { locatorPortsln.add((Integer)async[2].getReturnValue()); locatorPortsny.add((Integer)async[3].getReturnValue()); - vm0.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm1.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm2.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm3.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); + vm0.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm1.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm2.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm3.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); } public void test_LN_Sender_recogises_ALL_NY_Locators() { - Integer lnLocPort1 = (Integer)vm0.invoke(WANTestBase.class, - "createFirstLocatorWithDSId", new Object[] { 1 }); + Integer lnLocPort1 = (Integer)vm0.invoke(() -> WANTestBase.createFirstLocatorWithDSId( 1 )); - Integer lnLocPort2 = (Integer)vm5.invoke(WANTestBase.class, - "createSecondLocator", new Object[] { 1, lnLocPort1 }); + Integer lnLocPort2 = (Integer)vm5.invoke(() -> WANTestBase.createSecondLocator( 1, lnLocPort1 )); - vm2.invoke(WANTestBase.class, "createCache", new Object[]{lnLocPort1, lnLocPort2}); + vm2.invoke(() -> WANTestBase.createCache(lnLocPort1, lnLocPort2)); - vm2.invoke(WANTestBase.class, "createSender", - new Object[] {"ln",2,false,100,10,false,false, null, true}); + vm2.invoke(() -> WANTestBase.createSender("ln",2,false,100,10,false,false, null, true)); - Integer nyLocPort1 = (Integer)vm1.invoke(WANTestBase.class, - "createFirstRemoteLocator", new Object[] { 2, lnLocPort1 }); + Integer nyLocPort1 = (Integer)vm1.invoke(() -> WANTestBase.createFirstRemoteLocator( 2, lnLocPort1 )); - vm2.invoke(WANTestBase.class, "startSender",new Object[]{"ln"}); + vm2.invoke(() -> WANTestBase.startSender("ln")); //Since to fix Bug#46289, we have moved call to initProxy in getConnection which will be called only when batch is getting dispatched. //So for locator discovery callback to work, its now expected that atleast try to send a batch so that proxy will be initialized - vm2.invoke(WANTestBase.class, "createReplicatedRegion", new Object[] { - getTestMethodName() + "_RR", "ln", isOffHeap() }); + vm2.invoke(() -> WANTestBase.createReplicatedRegion( + getTestMethodName() + "_RR", "ln", isOffHeap() )); - vm2.invoke(WANTestBase.class, "doPuts", - new Object[] { getTestMethodName() + "_RR", 10}); + vm2.invoke(() -> WANTestBase.doPuts( getTestMethodName() + "_RR", 10)); Integer nyLocPort2 = (Integer)vm3 - .invoke(WANTestBase.class, "createSecondRemoteLocator", new Object[] { - 2, nyLocPort1, lnLocPort1 }); + .invoke(() -> WANTestBase.createSecondRemoteLocator( + 2, nyLocPort1, lnLocPort1 )); InetSocketAddress locatorToWaitFor = new InetSocketAddress("localhost", nyLocPort2); - vm2.invoke(WANTestBase.class, "checkLocatorsinSender", - new Object[] {"ln", locatorToWaitFor }); + vm2.invoke(() -> WANTestBase.checkLocatorsinSender("ln", locatorToWaitFor )); Integer nyLocPort3 = (Integer)vm4 - .invoke(WANTestBase.class, "createSecondRemoteLocator", new Object[] { - 2, nyLocPort1, lnLocPort1 }); + .invoke(() -> WANTestBase.createSecondRemoteLocator( + 2, nyLocPort1, lnLocPort1 )); locatorToWaitFor = new InetSocketAddress("localhost", nyLocPort3); - vm2.invoke(WANTestBase.class, "checkLocatorsinSender", - new Object[] {"ln", locatorToWaitFor }); + vm2.invoke(() -> WANTestBase.checkLocatorsinSender("ln", locatorToWaitFor )); } @@ -343,17 +300,13 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { int AsyncInvocationArrSize = 9; AsyncInvocation[] async = new AsyncInvocation[AsyncInvocationArrSize]; - async[0] = vm0.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 1, site1Port1, site1LocatorsPort, site2LocatorsPort}); + async[0] = vm0.invokeAsync(() -> WANTestBase.createLocator( 1, site1Port1, site1LocatorsPort, site2LocatorsPort)); - async[1] = vm1.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 2, site2Port1, site2LocatorsPort, site3LocatorsPort}); + async[1] = vm1.invokeAsync(() -> WANTestBase.createLocator( 2, site2Port1, site2LocatorsPort, site3LocatorsPort)); - async[2] = vm2.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 3, site3Port1, site3LocatorsPort, site4LocatorsPort}); + async[2] = vm2.invokeAsync(() -> WANTestBase.createLocator( 3, site3Port1, site3LocatorsPort, site4LocatorsPort)); - async[3] = vm3.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 4, site4Port1, site4LocatorsPort, site1LocatorsPort}); + async[3] = vm3.invokeAsync(() -> WANTestBase.createLocator( 4, site4Port1, site4LocatorsPort, site1LocatorsPort)); // pause(5000); try { @@ -366,14 +319,10 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { fail("Could not join async operations"); } - vm0.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm1.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm2.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm3.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); + vm0.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm1.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm2.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm3.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); } public void ___test_3Sites3Locators() { @@ -409,28 +358,19 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { int AsyncInvocationArrSize = 9; AsyncInvocation[] async = new AsyncInvocation[AsyncInvocationArrSize]; - async[0] = vm0.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 1, site1Port1, site1LocatorsPort, site2LocatorsPort}); + async[0] = vm0.invokeAsync(() -> WANTestBase.createLocator( 1, site1Port1, site1LocatorsPort, site2LocatorsPort)); - async[8] = vm0.invokeAsync(WANTestBase.class, - "checkAllSiteMetaDataFor3Sites", new Object[] {dsVsPort}); + async[8] = vm0.invokeAsync(() -> WANTestBase.checkAllSiteMetaDataFor3Sites(dsVsPort)); - async[1] = vm1.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 1, site1Port2, site1LocatorsPort, site2LocatorsPort}); - async[2] = vm2.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 1, site1Port3, site1LocatorsPort, site2LocatorsPort}); + async[1] = vm1.invokeAsync(() -> WANTestBase.createLocator( 1, site1Port2, site1LocatorsPort, site2LocatorsPort)); + async[2] = vm2.invokeAsync(() -> WANTestBase.createLocator( 1, site1Port3, site1LocatorsPort, site2LocatorsPort)); - async[3] = vm3.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 2, site2Port1, site2LocatorsPort, site3LocatorsPort}); - async[4] = vm4.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 2, site2Port2, site2LocatorsPort, site3LocatorsPort}); - async[5] = vm5.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 2, site2Port3, site2LocatorsPort, site3LocatorsPort}); + async[3] = vm3.invokeAsync(() -> WANTestBase.createLocator( 2, site2Port1, site2LocatorsPort, site3LocatorsPort)); + async[4] = vm4.invokeAsync(() -> WANTestBase.createLocator( 2, site2Port2, site2LocatorsPort, site3LocatorsPort)); + async[5] = vm5.invokeAsync(() -> WANTestBase.createLocator( 2, site2Port3, site2LocatorsPort, site3LocatorsPort)); - async[6] = vm6.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 3, site3Port1, site3LocatorsPort, site1LocatorsPort}); - async[7] = vm7.invokeAsync(WANTestBase.class, - "createLocator", new Object[] { 3, site3Port2, site3LocatorsPort, site1LocatorsPort}); + async[6] = vm6.invokeAsync(() -> WANTestBase.createLocator( 3, site3Port1, site3LocatorsPort, site1LocatorsPort)); + async[7] = vm7.invokeAsync(() -> WANTestBase.createLocator( 3, site3Port2, site3LocatorsPort, site1LocatorsPort)); WANTestBase.createLocator(3, site3Port3, site3LocatorsPort, site1LocatorsPort); long startTime = System.currentTimeMillis(); @@ -460,22 +400,14 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { LogWriterUtils.getLogWriter().info("Time taken for all 9 locators discovery in 3 sites: " + (endTime.longValue() - startTime)); - vm0.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm1.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm2.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm3.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm4.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm5.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm6.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); - vm7.invoke(WANTestBase.class, "checkAllSiteMetaDataFor3Sites", - new Object[] { dsVsPort }); + vm0.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm1.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm2.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm3.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm4.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm5.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm6.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); + vm7.invoke(() -> WANTestBase.checkAllSiteMetaDataFor3Sites( dsVsPort )); WANTestBase.checkAllSiteMetaDataFor3Sites(dsVsPort); } @@ -485,19 +417,14 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { Map> dsVsPort = new HashMap>(); dsVsPort.put(1, locatorPorts); - Integer lnLocPort1 = (Integer)vm0.invoke( - WANTestBase.class, "createFirstPeerLocator", - new Object[] {1}); + Integer lnLocPort1 = (Integer)vm0.invoke(() -> WANTestBase.createFirstPeerLocator(1)); locatorPorts.add(lnLocPort1); - Integer lnLocPort2 = (Integer)vm1.invoke(WANTestBase.class, - "createSecondPeerLocator", new Object[] { 1, lnLocPort1 }); + Integer lnLocPort2 = (Integer)vm1.invoke(() -> WANTestBase.createSecondPeerLocator( 1, lnLocPort1 )); locatorPorts.add(lnLocPort2); - vm0.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm1.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); + vm0.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm1.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); } public void test_LN_NY_TK_5_PeerLocators_1_ServerLocator() { @@ -506,53 +433,36 @@ public class WanAutoDiscoveryDUnitTest extends WANTestBase { ArrayList locatorPorts = new ArrayList(); dsVsPort.put(1, locatorPorts); - Integer lnLocPort1 = (Integer)vm0.invoke( - WANTestBase.class, "createFirstPeerLocator", - new Object[] {1}); + Integer lnLocPort1 = (Integer)vm0.invoke(() -> WANTestBase.createFirstPeerLocator(1)); locatorPorts.add(lnLocPort1); - Integer lnLocPort2 = (Integer)vm1.invoke(WANTestBase.class, - "createSecondPeerLocator", new Object[] { 1, lnLocPort1 }); + Integer lnLocPort2 = (Integer)vm1.invoke(() -> WANTestBase.createSecondPeerLocator( 1, lnLocPort1 )); locatorPorts.add(lnLocPort2); locatorPorts = new ArrayList(); dsVsPort.put(2, locatorPorts); - Integer nyLocPort1 = (Integer)vm2.invoke( - WANTestBase.class, "createFirstRemotePeerLocator", - new Object[] {2, lnLocPort1}); + Integer nyLocPort1 = (Integer)vm2.invoke(() -> WANTestBase.createFirstRemotePeerLocator(2, lnLocPort1)); locatorPorts.add(nyLocPort1); - Integer nyLocPort2 = (Integer)vm3.invoke(WANTestBase.class, - "createSecondRemotePeerLocator", new Object[] { 2, nyLocPort1, lnLocPort2}); + Integer nyLocPort2 = (Integer)vm3.invoke(() -> WANTestBase.createSecondRemotePeerLocator( 2, nyLocPort1, lnLocPort2)); locatorPorts.add(nyLocPort2); locatorPorts = new ArrayList(); dsVsPort.put(3, locatorPorts); - Integer tkLocPort1 = (Integer)vm4.invoke( - WANTestBase.class, "createFirstRemotePeerLocator", - new Object[] {3, nyLocPort1}); + Integer tkLocPort1 = (Integer)vm4.invoke(() -> WANTestBase.createFirstRemotePeerLocator(3, nyLocPort1)); locatorPorts.add(tkLocPort1); - Integer tkLocPort2 = (Integer)vm5.invoke(WANTestBase.class, - "createSecondRemotePeerLocator", new Object[] { 3, tkLocPort1, nyLocPort1}); + Integer tkLocPort2 = (Integer)vm5.invoke(() -> WANTestBase.createSecondRemotePeerLocator( 3, tkLocPort1, nyLocPort1)); locatorPorts.add(tkLocPort2); - Integer tkLocPort3 = (Integer)vm6.invoke(WANTestBase.class, - "createSecondRemoteLocator", new Object[] { 3, tkLocPort1, nyLocPort2}); + Integer tkLocPort3 = (Integer)vm6.invoke(() -> WANTestBase.createSecondRemoteLocator( 3, tkLocPort1, nyLocPort2)); locatorPorts.add(tkLocPort3); // pause(5000); - vm0.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm1.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm2.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm3.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm4.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm5.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); - vm6.invoke(WANTestBase.class, "checkAllSiteMetaData", - new Object[] { dsVsPort }); + vm0.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm1.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm2.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm3.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm4.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm5.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); + vm6.invoke(() -> WANTestBase.checkAllSiteMetaData( dsVsPort )); }