geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From upthewatersp...@apache.org
Subject [1/3] incubator-geode git commit: Removing statics from the lambda expressions
Date Thu, 18 Feb 2016 02:04:22 GMT
Repository: incubator-geode
Updated Branches:
  refs/heads/feature/GEODE-866 0804a1396 -> 923e219f2


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/923e219f/gemfire-core/src/test/java/com/gemstone/gemfire/security/DeltaClientPostAuthorizationDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/test/java/com/gemstone/gemfire/security/DeltaClientPostAuthorizationDUnitTest.java
b/gemfire-core/src/test/java/com/gemstone/gemfire/security/DeltaClientPostAuthorizationDUnitTest.java
index 0e33a62..ec1c692 100644
--- a/gemfire-core/src/test/java/com/gemstone/gemfire/security/DeltaClientPostAuthorizationDUnitTest.java
+++ b/gemfire-core/src/test/java/com/gemstone/gemfire/security/DeltaClientPostAuthorizationDUnitTest.java
@@ -284,8 +284,10 @@ public class DeltaClientPostAuthorizationDUnitTest extends
             opFlags), new Integer(expectedResult));
       }
       else {
-        clientVM.invoke(() -> DeltaClientPostAuthorizationDUnitTest.doOp( new Byte(opCode.toOrdinal()),
-                currentOp.getIndices(), new Integer(opFlags),
+        byte ordinal = opCode.toOrdinal();
+        int[] indices = currentOp.getIndices();
+        clientVM.invoke(() -> DeltaClientPostAuthorizationDUnitTest.doOp( new Byte(ordinal),
+                indices, new Integer(opFlags),
                 new Integer(expectedResult) ));
       }
     }

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/923e219f/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/CQListGIIDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/CQListGIIDUnitTest.java
b/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/CQListGIIDUnitTest.java
index 0ddb70d..5f3ab7d 100755
--- a/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/CQListGIIDUnitTest.java
+++ b/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/CQListGIIDUnitTest.java
@@ -63,6 +63,9 @@ import com.gemstone.gemfire.test.dunit.Host;
 import com.gemstone.gemfire.test.dunit.NetworkUtils;
 import com.gemstone.gemfire.test.dunit.VM;
 
+import junit.framework.Test;
+import junit.framework.TestSuite;
+
 /**
  *
  *
@@ -95,9 +98,9 @@ public class CQListGIIDUnitTest extends DistributedTestCase {
 
   protected static VM clientVM2 = null;
 
-  private static int PORT1;
+  private int PORT1;
 
-  private static int PORT2;
+  private int PORT2;
 
   private static final String regionName = "CQListGIIDUnitTest";
 
@@ -183,6 +186,18 @@ public class CQListGIIDUnitTest extends DistributedTestCase {
     serverVM1.invoke(() -> CQListGIIDUnitTest.closeCache());
     disconnectAllFromDS();
   }
+  
+  public static Test suite() {
+    Class[] classes = new Class[] {com.gemstone.gemfire.internal.cache.ha.CQListGIIDUnitTest.class,
+ com.gemstone.gemfire.internal.cache.tier.sockets.DataSerializerPropogationDUnitTest.class,
+ com.gemstone.gemfire.internal.cache.tier.sockets.EventIDVerificationDUnitTest.class,
+ com.gemstone.gemfire.internal.cache.tier.sockets.EventIDVerificationInP2PDUnitTest.class,
+ com.gemstone.gemfire.internal.cache.tier.sockets.UpdatePropagationDUnitTest.class,
+ com.gemstone.gemfire.internal.cache.tier.sockets.UpdatePropagationPRDUnitTest.class,
+ com.gemstone.gemfire.security.DeltaClientPostAuthorizationDUnitTest.class};
+    return new TestSuite(classes);
+  }
+
 
   private void createCache(Properties props) throws Exception {
     DistributedSystem ds = getSystem(props);

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/923e219f/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/HADispatcherDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/HADispatcherDUnitTest.java
b/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/HADispatcherDUnitTest.java
index 5b10d3d..d74f3ff 100755
--- a/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/HADispatcherDUnitTest.java
+++ b/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/ha/HADispatcherDUnitTest.java
@@ -91,9 +91,9 @@ public class HADispatcherDUnitTest extends DistributedTestCase
 
   VM client2 = null;
 
-  public static int PORT1;
+  public int PORT1;
 
-  public static int PORT2;
+  public int PORT2;
 
   private static final String REGION_NAME = "HADispatcherDUnitTest_region";
 
@@ -144,11 +144,11 @@ public class HADispatcherDUnitTest extends DistributedTestCase
     client1.invoke(() -> CacheServerTestUtil.disableShufflingOfEndpoints());
     client2.invoke(() -> CacheServerTestUtil.disableShufflingOfEndpoints());
     client1.invoke(() -> HADispatcherDUnitTest.createClientCache(
-            NetworkUtils.getServerHostName(Host.getHost(0)),
+            NetworkUtils.getServerHostName(host),
             new Integer(PORT1), new Integer(PORT2),
             new Boolean(false) ));
     client2.invoke(() -> HADispatcherDUnitTest.createClientCache(
-            NetworkUtils.getServerHostName(Host.getHost(0)),
+            NetworkUtils.getServerHostName(host),
             new Integer(PORT1), new Integer(PORT2),
             new Boolean(true) ));
     //createClientCache(new Integer(PORT1), new Integer(PORT2), new Boolean(true) );
@@ -380,8 +380,8 @@ public class HADispatcherDUnitTest extends DistributedTestCase
   public static void createClientCache(String hostName, Integer port1, Integer port2,
       Boolean isListenerPresent) throws Exception
   {
-    PORT1 = port1.intValue();
-    PORT2 = port2.intValue();
+    int PORT1 = port1.intValue();
+    int PORT2 = port2.intValue();
     Properties props = new Properties();
     props.setProperty(DistributionConfig.MCAST_PORT_NAME, "0");
     props.setProperty(DistributionConfig.LOCATORS_NAME, "");

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/923e219f/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DeltaToRegionRelationCQRegistrationDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DeltaToRegionRelationCQRegistrationDUnitTest.java
b/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DeltaToRegionRelationCQRegistrationDUnitTest.java
index 8f0db70..824f2e7 100755
--- a/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DeltaToRegionRelationCQRegistrationDUnitTest.java
+++ b/gemfire-cq/src/test/java/com/gemstone/gemfire/internal/cache/tier/sockets/DeltaToRegionRelationCQRegistrationDUnitTest.java
@@ -66,9 +66,9 @@ public class DeltaToRegionRelationCQRegistrationDUnitTest extends DistributedTes
   
   VM client2 = null;
  
-  private static  int PORT1 ;
+  private int PORT1 ;
   
-  private static  int PORT2 ;
+  private int PORT2 ;
   
   private static PoolImpl p = null; 
   /*

http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/923e219f/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java
----------------------------------------------------------------------
diff --git a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java
b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java
index a0a57ba..bd24d9a 100644
--- a/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java
+++ b/gemfire-wan/src/test/java/com/gemstone/gemfire/internal/cache/wan/serial/SerialGatewaySenderEventListenerDUnitTest.java
@@ -152,8 +152,7 @@ public class SerialGatewaySenderEventListenerDUnitTest extends WANTestBase
{
     vm3.invoke(() -> WANTestBase.validateRegionSize(
         getTestMethodName() + "_RR", 0 ));
 
-    fail("tried to invoke missing method");
-//    vm4.invoke(() -> SerialGatewaySenderEventListenerDUnitTest.validateReceivedEventsMapSizeListener1("ln",
keyValues ));
+    vm4.invoke(() -> SerialGatewaySenderEventListenerDUnitTest.validateReceivedEventsMapSizeListener1("ln",
keyValues ));
   }
 
   /**
@@ -305,7 +304,7 @@ public class SerialGatewaySenderEventListenerDUnitTest extends WANTestBase
{
     }
   }
   
-  public static void validateReceivedEventsMapSizeListener1(final String senderId, final
HashMap map) {
+  public static void validateReceivedEventsMapSizeListener1(final String senderId, final
Map map) {
 
     Set<GatewaySender> senders = cache.getGatewaySenders();
     GatewaySender sender = null;


Mime
View raw message