geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dschnei...@apache.org
Subject incubator-geode git commit: GEODE-1302: remove unused RunCacheInOldGemfire
Date Thu, 07 Jul 2016 23:59:51 GMT
Repository: incubator-geode
Updated Branches:
  refs/heads/develop b9da9e661 -> ea48bd660


GEODE-1302: remove unused RunCacheInOldGemfire


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/ea48bd66
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/ea48bd66
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/ea48bd66

Branch: refs/heads/develop
Commit: ea48bd660a9eeb5bf48659b017a972bcb169d5df
Parents: b9da9e6
Author: Darrel Schneider <dschneider@pivotal.io>
Authored: Thu Jul 7 16:58:23 2016 -0700
Committer: Darrel Schneider <dschneider@pivotal.io>
Committed: Thu Jul 7 16:58:23 2016 -0700

----------------------------------------------------------------------
 .../internal/cache/RunCacheInOldGemfire.java    | 184 -------------------
 1 file changed, 184 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/ea48bd66/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/RunCacheInOldGemfire.java
----------------------------------------------------------------------
diff --git a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/RunCacheInOldGemfire.java
b/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/RunCacheInOldGemfire.java
deleted file mode 100644
index a2fa3be..0000000
--- a/geode-core/src/test/java/com/gemstone/gemfire/internal/cache/RunCacheInOldGemfire.java
+++ /dev/null
@@ -1,184 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-/**
- * 
- */
-package com.gemstone.gemfire.internal.cache;
-
-import static com.gemstone.gemfire.distributed.ConfigurationProperties.*;
-
-import com.gemstone.gemfire.cache.*;
-import com.gemstone.gemfire.distributed.DistributedSystem;
-import com.gemstone.gemfire.distributed.internal.InternalDistributedSystem;
-import com.gemstone.gemfire.internal.admin.remote.ShutdownAllRequest;
-
-import java.io.File;
-import java.util.Properties;
-
-import static com.gemstone.gemfire.distributed.ConfigurationProperties.LOCATORS;
-import static com.gemstone.gemfire.distributed.ConfigurationProperties.MCAST_PORT;
-
-/**
- *
- */
-public class RunCacheInOldGemfire {
-
-  public static final String diskStoreName1 = "ds1";
-  public static final String diskStoreName2 = "ds2";
-  public static final String regionName1 = "region1";
-  public static final String regionName2 = "region2";
-  public static final int maxOplogSize = 1;
-  public static final int entrySize = 1024;
-  public static final int numOfKeys = maxOplogSize * 1024 * 1024 / entrySize;
-  
-  protected Cache createCache(String mcastPort) {
-    Properties config = new Properties();
-    config.setProperty(MCAST_PORT, mcastPort);
-    config.setProperty(LOCATORS, "");
-    config.setProperty(LOG_FILE, "oldgemfire.log");
-    InternalDistributedSystem localsystem = (InternalDistributedSystem)DistributedSystem.connect(config);
-    Cache cache = CacheFactory.create(localsystem);
-    return cache;
-  }
-
-  protected DiskStore createDiskStore(Cache cache, String diskStoreName, String dirName)
{
-    // maxOplogSize==1m
-    File dir = new File(dirName);
-    dir.mkdirs();
-
-    DiskStore ds = cache.findDiskStore(diskStoreName);
-    if(ds == null) {
-      ds = cache.createDiskStoreFactory()
-      .setDiskDirs(new File[] {dir}).setMaxOplogSize(maxOplogSize).create(diskStoreName);
-    }
-    return ds;
-  }
-  
-  protected Region createPersistentRegion(Cache cache, String regionName, String diskStoreName,
boolean isPR) {
-    RegionFactory factory;
-    if (isPR) {
-      PartitionAttributesFactory paf = new PartitionAttributesFactory();
-      paf.setRedundantCopies(1);
-      factory = cache.createRegionFactory().setDiskStoreName(diskStoreName)
-      .setDataPolicy(DataPolicy.PERSISTENT_PARTITION)
-      .setPartitionAttributes(paf.create());
-    } else {
-      factory = cache.createRegionFactory().setDiskStoreName(diskStoreName)
-      .setDataPolicy(DataPolicy.PERSISTENT_REPLICATE);
-    }
-    return factory.create(regionName);
-  }
-
-  /**
-   * start a cache with data
-   * 
-   * @param args
-   */
-  public static void main(String[] args) {
-    // The main() is used for run by a script under older gemfire version
-    if (args.length != 5) {
-      System.out.println("Usage: java -cp geode-dependencies.jar:$JTESTS com.gemstone.gemfire.internal.cache.RunCacheInOldGemfire
mcastPort diskdir isPR doOps(true or false) isShutDownAll");
-    }
-    
-    String mcastPort = args[0];
-    String diskdir = args[1];
-    boolean isPR = Boolean.valueOf(args[2]);
-    boolean doOps = Boolean.valueOf(args[3]);
-    boolean isShutDownAll = Boolean.valueOf(args[4]);
-
-    RunCacheInOldGemfire test = new RunCacheInOldGemfire();
-    Cache cache = test.createCache(mcastPort);
-    
-    // create 2 diskstores using the same directory, which should be different with another
cache instance
-    test.createDiskStore(cache, diskStoreName1, diskdir);
-    test.createDiskStore(cache, diskStoreName2, diskdir);
-    // create 2 regions each uses different diskstore
-    Region region1 = test.createPersistentRegion(cache, regionName1, diskStoreName1, isPR);
-    Region region2 = test.createPersistentRegion(cache, regionName2, diskStoreName2, isPR);
-    
-    if (doOps) {
-      try {
-        Thread.sleep(5000);
-      } catch (InterruptedException e) {
-        e.printStackTrace();
-      }
-      
-      for (Region region: new Region[] {region1, region2}) {
-        // create enough entries to roll the oplog
-        // do some destroys, invalidates
-        region.put("key1", "value1");
-        for (int i=0; i<numOfKeys; i++) {
-          byte [] value = new byte[entrySize];
-          region.put(""+i, value);
-        }
-        region.put("key2", "value2");
-        region.put("key3", "value3");
-        region.put("key4", "value4");
-        region.put("key5", "value5");// create
-
-        region.destroy("key1");
-        region.destroy("key2");
-        region.invalidate("key3");
-        region.put("key5", "value6");// update
-      }
-    } // doOps
-    
-    try {
-    if (isShutDownAll) {
-      try {
-        Thread.sleep(2000);
-      } catch (InterruptedException e) {
-        e.printStackTrace();
-      }
-
-      GemFireCacheImpl gfc = (GemFireCacheImpl)cache;
-      ShutdownAllRequest.send(gfc.getDistributedSystem().getDistributionManager(), 0);
-    } else {
-      // wait until all the operations are done 
-      final long tilt = System.currentTimeMillis() + 60000;
-      while (true) {
-        String value1 = (String)region1.get("key5");
-        String value2 = (String)region2.get("key5");
-        if (value1 != null && value2 != null && value1.equals("value6") &&
value2.equals("value6")) {
-          break;
-        } else {
-          long timeLeft = tilt - System.currentTimeMillis();
-          if (timeLeft <= 0) {
-            break;
-          }
-          try {
-            Thread.sleep(2000);
-          } catch (InterruptedException e) {
-            e.printStackTrace();
-          }
-        }
-      } // while
-    }
-    } catch (Throwable t) {
-      boolean ignore = false;
-      if (t instanceof java.lang.Error) {
-        if (t.getMessage().contains("Maximum permit count exceeded")) {
-          System.out.println("Known issue caused by jdk1.6, ignored for the test:" + t.getMessage());
-          ignore = true;
-        }
-      }
-      if (!ignore) {
-        throw new RuntimeException(t);
-      }
-    }
-  }
-}


Mime
View raw message