[jbosscache-commits] JBoss Cache SVN: r5075 - in cache-bench-fwk/trunk/cache-products: jbosscache-2.1.0cr2 and 4 other directories.

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2008-01-08 14:13:03 -0500 (Tue, 08 Jan 2008)
New Revision: 5075

Added:
   cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/
   cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/conf/
   cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/lib/
   cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/src/
   cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/src/org/
   cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/src/org/cachebench/
   cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/src/org/cachebench/cachewrappers/
   cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/src/org/cachebench/cachewrappers/JBossCache210Cr2Wrapper.java
Log:


Added: cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/src/org/cachebench/cachewrappers/JBossCache210Cr2Wrapper.java
===================================================================
--- cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/src/org/cachebench/cachewrappers/JBossCache210Cr2Wrapper.java	                        (rev 0)
+++ cache-bench-fwk/trunk/cache-products/jbosscache-2.1.0cr2/src/org/cachebench/cachewrappers/JBossCache210Cr2Wrapper.java	2008-01-08 19:13:03 UTC (rev 5075)
@@ -0,0 +1,83 @@
+package org.cachebench.cachewrappers;
+
+import org.jboss.cache.Cache;
+import org.jboss.cache.DefaultCacheFactory;
+import org.jboss.cache.Fqn;
+import org.jboss.cache.CacheSPI;
+import org.jboss.cache.marshall.NodeData;
+import org.jboss.cache.buddyreplication.GravitateResult;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.cachebench.CacheWrapper;
+
+import java.util.Map;
+
+/**
+ * @author Mircea.Markus at jboss.com
+ * @since 2.2
+ */
+public class JBossCache210Cr2Wrapper implements CacheWrapper
+{
+   private Cache cache;
+   private Log log = LogFactory.getLog(JBossCache210Cr2Wrapper.class);
+
+   public void init(Map parameters) throws Exception
+   {
+      log.info("Creating cache with the following configuration: " + parameters);
+      cache = DefaultCacheFactory.getInstance().createCache((String)parameters.get("config"));
+      log.info("Running cache with following config: " + cache.getConfiguration());
+      log.info("Running follwing JBossCacheVersion: " + org.jboss.cache.Version.version);
+      log.info("Running follwing JBossCacheCodeName: " + org.jboss.cache.Version.codename);
+   }
+
+   public void setUp() throws Exception
+   {
+   }
+
+   public void tearDown() throws Exception
+   {
+      cache.stop();
+   }
+
+   public void put(Object key, Object value) throws Exception
+   {
+      // make sure the threads don't conflict!
+      Fqn f = new Fqn("test", key);
+      cache.put(f, key, value);
+   }
+
+   public Object get(Object key) throws Exception
+   {
+      Fqn f = new Fqn("test", key);
+      return cache.get(f, key);
+   }
+
+   public void empty() throws Exception
+   {
+      //not removing root because there it fails with buddy replication: http://jira.jboss.com/jira/browse/JBCACHE-1241
+      cache.removeNode(new Fqn("test"));
+   }
+
+   public int getNumMembers()
+   {
+      return cache.getMembers().size();
+   }
+
+   public String getInfo()
+   {
+      return "Num direct children: " + cache.getRoot().getChildren().size();
+   }
+
+   public Object getReplicatedData(String key) throws Exception
+   {
+      CacheSPI cacheSpi = (CacheSPI) cache;
+      GravitateResult result = cacheSpi.gravitateData(new Fqn("test", key), true);
+      if (!result.isDataFound())
+      {
+         //totall replication?
+         return get(key);
+      }
+      NodeData nodeData = result.getNodeData().get(0);
+      return nodeData.getAttributes().get(key);
+   }
+}