[jboss-cvs] JBossCache/tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl ...
Mircea Markus
mircea.markus at gmail.com
Sat Feb 10 12:47:02 EST 2007
User: mmarkus
Date: 07/02/10 12:47:02
Added: tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl
RemoveNewBenchmark.java
NewImplRepeatingBenchmark.java
ExistsNewBenchmark.java LoadNewBenchmark.java
GetAttributesNewBenchmark.java
ChildrenNamesNewBenchmark.java
NewImplBenchmark.java
Log:
JDBCCaheLoader performance improvements. Also added benchmarks for comparisons and backward compatibility tests
Revision Changes Path
1.1 date: 2007/02/10 17:47:02; author: mmarkus; state: Exp;JBossCache/tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl/RemoveNewBenchmark.java
Index: RemoveNewBenchmark.java
===================================================================
package org.jboss.cache.manualtests.cacheloader.newimpl;
import org.jboss.cache.Fqn;
import org.jboss.cache.loader.CacheLoader;
/**
* Benchmark for "remove(Fqn)" operation.
*
* @author Mircea.Markus at iquestint.com
* @version 1.0
*/
public class RemoveNewBenchmark extends NewImplBenchmark
{
protected void processOperation(Fqn node, CacheLoader loader) throws Exception
{
loader.remove(node);
}
protected String getName()
{
return "NewImp - remove node";
}
}
1.1 date: 2007/02/10 17:47:02; author: mmarkus; state: Exp;JBossCache/tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl/NewImplRepeatingBenchmark.java
Index: NewImplRepeatingBenchmark.java
===================================================================
package org.jboss.cache.manualtests.cacheloader.newimpl;
import org.jboss.cache.manualtests.cacheloader.RepeatingBenchmark;
import org.jboss.cache.loader.CacheLoader;
import org.jboss.cache.loader.JDBCCacheLoader;
import org.jboss.cache.config.CacheLoaderConfig;
import java.util.Properties;
/**
* @author Mircea.Markus at iquestint.com
* @version 1.0
*/
public abstract class NewImplRepeatingBenchmark extends RepeatingBenchmark
{
protected CacheLoader getCacheLoader() throws Exception
{
Properties prop = getProperties();
String props = "cache.jdbc.driver =" + prop.getProperty("cache.jdbc.driver") + "\n" +
"cache.jdbc.url=" + prop.getProperty("cache.jdbc.url") + "\n" +
"cache.jdbc.user=" + prop.getProperty("cache.jdbc.user") + "\n" +
"cache.jdbc.password=" + prop.getProperty("cache.jdbc.password") + "\n" +
"cache.jdbc.node.type=" + prop.getProperty("cache.jdbc.node.type") + "\n" +
"cache.jdbc.sql-concat=" + prop.getProperty("cache.jdbc.sql-concat") + "\n" +
"cache.jdbc.connection.factory=org.jboss.cache.manualtests.cacheloader.OneConnectionFactory";
CacheLoaderConfig.IndividualCacheLoaderConfig base = getSingleCacheLoaderConfig(false, "", "org.jboss.cache.loader.JDBCCacheLoader", props, false, true, false, false).getFirstCacheLoaderConfig();
JDBCCacheLoader jdbcCacheLoader = new JDBCCacheLoader();
jdbcCacheLoader.setConfig(base);
return jdbcCacheLoader;
}
}
1.1 date: 2007/02/10 17:47:02; author: mmarkus; state: Exp;JBossCache/tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl/ExistsNewBenchmark.java
Index: ExistsNewBenchmark.java
===================================================================
package org.jboss.cache.manualtests.cacheloader.newimpl;
import org.jboss.cache.Fqn;
import org.jboss.cache.loader.CacheLoader;
/**
* Benchmark for "exists" operation.
*
* @author Mircea.Markus at iquestint.com
* @version 1.0
*/
public class ExistsNewBenchmark extends NewImplRepeatingBenchmark
{
public void repeatOperation(Fqn node, CacheLoader loader) throws Exception
{
loader.exists(node);
}
protected String getName()
{
return "NewImp - boolean exists(Fqn)";
}
}
1.1 date: 2007/02/10 17:47:02; author: mmarkus; state: Exp;JBossCache/tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl/LoadNewBenchmark.java
Index: LoadNewBenchmark.java
===================================================================
package org.jboss.cache.manualtests.cacheloader.newimpl;
import org.jboss.cache.Fqn;
import org.jboss.cache.loader.CacheLoader;
import org.jboss.util.stream.MarshalledValueOutputStream;
import java.io.ByteArrayOutputStream;
/**
* Benchmark for "loadState" operation.
*
* @author Mircea.Markus at iquestint.com
* @version 1.0
*/
public class LoadNewBenchmark extends NewImplBenchmark
{
protected void processOperation(Fqn node, CacheLoader loader) throws Exception
{
ByteArrayOutputStream baos = new ByteArrayOutputStream(10240);
MarshalledValueOutputStream os = new MarshalledValueOutputStream(baos);
loader.loadState(node, os);
}
protected String getName()
{
return "NewImp - load node";
}
}
1.1 date: 2007/02/10 17:47:02; author: mmarkus; state: Exp;JBossCache/tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl/GetAttributesNewBenchmark.java
Index: GetAttributesNewBenchmark.java
===================================================================
package org.jboss.cache.manualtests.cacheloader.newimpl;
import org.jboss.cache.Fqn;
import org.jboss.cache.loader.CacheLoader;
/**
* Benchmark for "get(Fqn)" operation.
*
* @author Mircea.Markus at iquestint.com
* @version 1.0
*/
public class GetAttributesNewBenchmark extends NewImplRepeatingBenchmark
{
public void repeatOperation(Fqn node, CacheLoader loader) throws Exception
{
loader.get(node);
}
protected String getName()
{
return "NewImp - get(Fqn):Map";
}
}
1.1 date: 2007/02/10 17:47:02; author: mmarkus; state: Exp;JBossCache/tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl/ChildrenNamesNewBenchmark.java
Index: ChildrenNamesNewBenchmark.java
===================================================================
package org.jboss.cache.manualtests.cacheloader.newimpl;
import org.jboss.cache.Fqn;
import org.jboss.cache.loader.CacheLoader;
/**
* Benchmarks "getChildrenNames" operation.
*
* @author Mircea.Markus at iquestint.com
* @version 1.0
*/
public class ChildrenNamesNewBenchmark extends NewImplRepeatingBenchmark
{
public void repeatOperation(Fqn node, CacheLoader loader) throws Exception
{
loader.getChildrenNames(node);
}
protected String getName()
{
return "NewImp - getChildrenNames";
}
}
1.1 date: 2007/02/10 17:47:02; author: mmarkus; state: Exp;JBossCache/tests/perf/org/jboss/cache/manualtests/cacheloader/newimpl/NewImplBenchmark.java
Index: NewImplBenchmark.java
===================================================================
package org.jboss.cache.manualtests.cacheloader.newimpl;
import org.jboss.cache.loader.CacheLoader;
import org.jboss.cache.loader.JDBCCacheLoader;
import org.jboss.cache.manualtests.cacheloader.BaseBenchmark;
import org.jboss.cache.config.CacheLoaderConfig;
import java.util.Properties;
/**
* @author Mircea.Markus at iquestint.com
* @version 1.0
*/
public abstract class NewImplBenchmark extends BaseBenchmark
{
protected CacheLoader getCacheLoader() throws Exception
{
Properties prop = getProperties();
String props = "cache.jdbc.driver =" + prop.getProperty("cache.jdbc.driver") + "\n" +
"cache.jdbc.url=" + prop.getProperty("cache.jdbc.url") + "\n" +
"cache.jdbc.user=" + prop.getProperty("cache.jdbc.user") + "\n" +
"cache.jdbc.password=" + prop.getProperty("cache.jdbc.password") + "\n" +
"cache.jdbc.node.type=" + prop.getProperty("cache.jdbc.node.type") + "\n" +
"cache.jdbc.sql-concat=" + prop.getProperty("cache.jdbc.sql-concat") + "\n" +
"cache.jdbc.connection.factory=org.jboss.cache.manualtests.cacheloader.OneConnectionFactory";
CacheLoaderConfig.IndividualCacheLoaderConfig base = getSingleCacheLoaderConfig(false, "", "org.jboss.cache.loader.JDBCCacheLoader", props, false, true, false, false).getFirstCacheLoaderConfig();
JDBCCacheLoader jdbcCacheLoader = new JDBCCacheLoader();
jdbcCacheLoader.setConfig(base);
return jdbcCacheLoader;
}
}
More information about the jboss-cvs-commits
mailing list