[jbosscache-commits] JBoss Cache SVN: r7057 - core/trunk/src/test/java/org/jboss/cache/profiling.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2008-11-03 12:09:55 -0500 (Mon, 03 Nov 2008)
New Revision: 7057

Modified:
   core/trunk/src/test/java/org/jboss/cache/profiling/MemConsumptionTest.java
Log:


Modified: core/trunk/src/test/java/org/jboss/cache/profiling/MemConsumptionTest.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/profiling/MemConsumptionTest.java	2008-11-03 16:32:39 UTC (rev 7056)
+++ core/trunk/src/test/java/org/jboss/cache/profiling/MemConsumptionTest.java	2008-11-03 17:09:55 UTC (rev 7057)
@@ -22,6 +22,7 @@
 package org.jboss.cache.profiling;
 
 import org.jboss.cache.Cache;
+import org.jboss.cache.CacheException;
 import org.jboss.cache.DefaultCacheFactory;
 import org.jboss.cache.Fqn;
 import org.jboss.cache.util.TestingUtil;
@@ -35,24 +36,39 @@
 @Test(groups = "profiling")
 public class MemConsumptionTest
 {
-   // adjust the next 3 numbers
+   // adjust the next 4 values
    int numNodes = 1000000;
    int payloadSize = 20; // bytes
    int keySize = 10; // bytes
+   PayloadType payloadType = PayloadType.STRINGS;
 
+   enum PayloadType {STRINGS, BYTE_ARRAYS}
+
+   int bytesPerCharacter = 2;
+
    Random r = new Random();
 
    public void testMemConsumption() throws IOException
-   {
-      int kBytesCached = (2 * numNodes * (payloadSize + keySize)) / 1024;
+   {      
+      int kBytesCached = (bytesPerCharacter * numNodes * (payloadSize + keySize)) / 1024;
       System.out.println("Bytes to be cached: " + NumberFormat.getIntegerInstance().format(kBytesCached) + " kb");
 
-      Cache<String, String> c = new DefaultCacheFactory<String, String>().createCache(false); // default LOCAL cache
-//      c.getConfiguration().setConcurrencyLevel(numNodes);
+      Cache c = new DefaultCacheFactory().createCache(false); // default LOCAL cache
       c.start();
       for (int i = 0; i < numNodes; i++)
       {
-         c.put(Fqn.fromString("/node" + i), generateRandomString(keySize), generateRandomString(payloadSize));
+         switch (payloadType)
+         {
+            case STRINGS:
+               c.put(Fqn.fromString("/node" + i), generateRandomString(keySize), generateRandomString(payloadSize));
+               break;
+            case BYTE_ARRAYS:
+               c.put(Fqn.fromString("/node" + i), generateUniqueKey(i, keySize), generateBytePayload(payloadSize));
+               break;
+            default:
+               throw new CacheException("Unknown payload type");
+         }
+
          if (i % 1000 == 0) System.out.println("Added " + i + " entries");
       }