JBoss Cache SVN: r5225 - benchmarks/benchmark-fwk/trunk.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 09:31:25 -0500 (Thu, 24 Jan 2008)
New Revision: 5225
Added:
benchmarks/benchmark-fwk/trunk/bindAddress.sh
Modified:
benchmarks/benchmark-fwk/trunk/cluster.sh
benchmarks/benchmark-fwk/trunk/runNode.sh
Log:
Added: benchmarks/benchmark-fwk/trunk/bindAddress.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/bindAddress.sh (rev 0)
+++ benchmarks/benchmark-fwk/trunk/bindAddress.sh 2008-01-24 14:31:25 UTC (rev 5225)
@@ -0,0 +1,5 @@
+#!/bin/sh
+
+### Set your bind address for the tests to use. Could be an IP, host name or a reference to an environment variable.
+BIND_ADDRESS=${MYTESTIP_4}
+
Modified: benchmarks/benchmark-fwk/trunk/cluster.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 14:17:55 UTC (rev 5224)
+++ benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 14:31:25 UTC (rev 5225)
@@ -27,8 +27,6 @@
# Number of servers to launch on - taken from the command line.
NUM_SERVERS=${4}
-USER_JVM_PARAMS=${5}
-
COMMAND=${1}
# the DNS domain of your servers
@@ -45,7 +43,7 @@
do
server="${HOSTNAMES[idx]}"
echo Starting CacheBenchmarkFramework on host ${server}
- ssh ${SSH_USER}(a)${server}.${DOMAIN} ". .bash_profile && cd ${CACHE_BENCHMARK_HOME} && ./runNode.sh ${idx} ${CACHE_DIST} ${CFG_FILE} ${NUM_SERVERS} ${USER_JVM_PARAMS}"
+ ssh ${SSH_USER}(a)${server}.${DOMAIN} ". .bash_profile && cd ${CACHE_BENCHMARK_HOME} && ./runNode.sh ${idx} ${CACHE_DIST} ${CFG_FILE} ${NUM_SERVERS}"
sleep 2
done
;;
@@ -55,14 +53,13 @@
server="${HOSTNAMES[idx]}"
echo Stopping CacheBenchmarkFramework on host ${server}
ssh ${SSH_USER}(a)${server}.${DOMAIN} "cd ${CACHE_BENCHMARK_HOME} && ./killNode.sh &"
- sleep 2
done
;;
*)
- echo "Usage: ${0} [start | stop] [cache distribution to test] [name of configuration file to use] [number of servers to launch on] [optional JVM params]"
+ echo "Usage: ${0} [start | stop] [cache distribution to test] [name of configuration file to use] [number of servers to launch on]"
echo
echo "Example:"
- echo " ${0} start jbosscache-2.0.0 repl_async.xml 6 \"-Dbind.address=1.2.3.4 -Dxyz=abc\""
+ echo " ${0} start jbosscache-2.0.0 repl_async.xml 6"
echo " ${0} stop"
echo " Note that the stop command will stop all instances on all configured hosts"
;;
Modified: benchmarks/benchmark-fwk/trunk/runNode.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/runNode.sh 2008-01-24 14:17:55 UTC (rev 5224)
+++ benchmarks/benchmark-fwk/trunk/runNode.sh 2008-01-24 14:31:25 UTC (rev 5225)
@@ -4,12 +4,11 @@
# those would make an automatic conversion from unix CLASSPATH to win classpath, needed when executing java -cp
preferIPv4Stack=true
-DEBUG=false
+DEBUG=true
CURRENT_INDEX=${1}
CACHE_PRODUCT=${2}
TEST_CFG=${3}
CLUSTER_SIZE=${4}
-USER_JVM_PARAMS=${5}
PIDFILE="PID.pid"
if [ -e ${PIDFILE} ]
then
@@ -29,12 +28,11 @@
then
echo Usage:
echo
- echo ./runNode.sh [current node index] [cache product to test] [test config file] [cluster size] [JVM params - optional]
+ echo ./runNode.sh [current node index] [cache product to test] [test config file] [cluster size]
echo param [current node index] : the index of this node in the list of nodes in the cluster [0 .. <cluster size> - 1]
echo param [cache product to test] : must be one of the directories names under './cache-products'
echo param [test config file] : configuration file to use with the cache product. Typically resides in './cache-products/XXX/conf/'
echo param [cluster size] : total number of nodes that will run tests.
- echo param [JVM params] : an optional extra set of parameters to be passed to the JVM - e.g., "-Dbind.address=127.0.0.1 -Dxyz=abc"
echo
echo Example: './runNode.sh 0 jbosscache-2.0.0 repl_async.xml 3' will start the 1st node running an instance of jbc2.0.0 on a cluster made out of 3 nodes, using the repl_async configuration.
exit 1
@@ -60,7 +58,9 @@
exit 2
fi
-JVM_OPTIONS="${JVM_OPTIONS} ${USER_JVM_PARAMS} -DcacheBenchFwk.cacheConfigFile=${TEST_CFG} -DcurrentIndex=${CURRENT_INDEX} -DclusterSize=${CLUSTER_SIZE} -DcurrentIndex=${CURRENT_INDEX} -Djava.net.preferIPv4Stack=${preferIPv4Stack}"
+. ./bindAddress.sh
+
+JVM_OPTIONS="${JVM_OPTIONS} -Dbind.address=${BIND_ADDRESS} -DcacheBenchFwk.cacheConfigFile=${TEST_CFG} -DcurrentIndex=${CURRENT_INDEX} -DclusterSize=${CLUSTER_SIZE} -DcurrentIndex=${CURRENT_INDEX} -Djava.net.preferIPv4Stack=${preferIPv4Stack}"
TO_EXECUTE="java $JVM_OPTIONS -cp $CLASSPATH org.cachebench.CacheBenchmarkRunner"
if [ "$DEBUG" = "debug" ]
16 years, 3 months
JBoss Cache SVN: r5224 - benchmarks/benchmark-fwk/trunk.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 09:17:55 -0500 (Thu, 24 Jan 2008)
New Revision: 5224
Modified:
benchmarks/benchmark-fwk/trunk/build.xml
Log:
Compile 1.4.1 as well
Modified: benchmarks/benchmark-fwk/trunk/build.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/build.xml 2008-01-24 14:11:22 UTC (rev 5223)
+++ benchmarks/benchmark-fwk/trunk/build.xml 2008-01-24 14:17:55 UTC (rev 5224)
@@ -494,7 +494,7 @@
<delete dir="${module.framework.basedir}/classes"/>
</target>
- <target name="all" depends="init, clean, compile.module.framework,compile.module.jbosscache200-plugin, compile.module.jbosscache210-plugin.production, compile.module.terracotta-plugin" description="build all"/>
+ <target name="all" depends="init, clean, compile.module.framework, compile.module.jbosscache140-plugin, compile.module.jbosscache200-plugin, compile.module.jbosscache210-plugin.production, compile.module.terracotta-plugin" description="build all"/>
<target name="checkClusterAddresses" depends="compile.module.framework.production"
description="Check whether the cluster config is a valid one">
16 years, 3 months
JBoss Cache SVN: r5223 - benchmarks/benchmark-fwk/trunk.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 09:11:22 -0500 (Thu, 24 Jan 2008)
New Revision: 5223
Modified:
benchmarks/benchmark-fwk/trunk/runNode.sh
Log:
Modified: benchmarks/benchmark-fwk/trunk/runNode.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/runNode.sh 2008-01-24 14:10:38 UTC (rev 5222)
+++ benchmarks/benchmark-fwk/trunk/runNode.sh 2008-01-24 14:11:22 UTC (rev 5223)
@@ -29,7 +29,7 @@
then
echo Usage:
echo
- echo ./runNode.sh [current node index] [cache product to test] [test config file] [cluster size] [JVM params (optional)]
+ echo ./runNode.sh [current node index] [cache product to test] [test config file] [cluster size] [JVM params - optional]
echo param [current node index] : the index of this node in the list of nodes in the cluster [0 .. <cluster size> - 1]
echo param [cache product to test] : must be one of the directories names under './cache-products'
echo param [test config file] : configuration file to use with the cache product. Typically resides in './cache-products/XXX/conf/'
16 years, 3 months
JBoss Cache SVN: r5222 - benchmarks/benchmark-fwk/trunk.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 09:10:38 -0500 (Thu, 24 Jan 2008)
New Revision: 5222
Modified:
benchmarks/benchmark-fwk/trunk/cluster.sh
Log:
Modified: benchmarks/benchmark-fwk/trunk/cluster.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:52:48 UTC (rev 5221)
+++ benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 14:10:38 UTC (rev 5222)
@@ -45,7 +45,7 @@
do
server="${HOSTNAMES[idx]}"
echo Starting CacheBenchmarkFramework on host ${server}
- ssh ${SSH_USER}(a)${server}.${DOMAIN} ". ./bash_profile && cd ${CACHE_BENCHMARK_HOME} && ./runNode.sh ${idx} ${CACHE_DIST} ${CFG_FILE} ${NUM_SERVERS} ${USER_JVM_PARAMS}"
+ ssh ${SSH_USER}(a)${server}.${DOMAIN} ". .bash_profile && cd ${CACHE_BENCHMARK_HOME} && ./runNode.sh ${idx} ${CACHE_DIST} ${CFG_FILE} ${NUM_SERVERS} ${USER_JVM_PARAMS}"
sleep 2
done
;;
16 years, 3 months
JBoss Cache SVN: r5221 - benchmarks/benchmark-fwk/trunk.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 08:52:48 -0500 (Thu, 24 Jan 2008)
New Revision: 5221
Modified:
benchmarks/benchmark-fwk/trunk/cluster.sh
Log:
Modified: benchmarks/benchmark-fwk/trunk/cluster.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:51:04 UTC (rev 5220)
+++ benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:52:48 UTC (rev 5221)
@@ -45,7 +45,7 @@
do
server="${HOSTNAMES[idx]}"
echo Starting CacheBenchmarkFramework on host ${server}
- ssh ${SSH_USER}(a)${server}.${DOMAIN} "cd ${CACHE_BENCHMARK_HOME} && ./runNode.sh ${idx} ${CACHE_DIST} ${CFG_FILE} ${NUM_SERVERS} ${USER_JVM_PARAMS}"
+ ssh ${SSH_USER}(a)${server}.${DOMAIN} ". ./bash_profile && cd ${CACHE_BENCHMARK_HOME} && ./runNode.sh ${idx} ${CACHE_DIST} ${CFG_FILE} ${NUM_SERVERS} ${USER_JVM_PARAMS}"
sleep 2
done
;;
@@ -53,7 +53,7 @@
for ((idx=0; idx < ${#HOSTNAMES[*]} ; idx++))
do
server="${HOSTNAMES[idx]}"
- echo Starting CacheBenchmarkFramework on host ${server}
+ echo Stopping CacheBenchmarkFramework on host ${server}
ssh ${SSH_USER}(a)${server}.${DOMAIN} "cd ${CACHE_BENCHMARK_HOME} && ./killNode.sh &"
sleep 2
done
16 years, 3 months
JBoss Cache SVN: r5220 - benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 08:51:04 -0500 (Thu, 24 Jan 2008)
New Revision: 5220
Added:
benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async-br.xml
Modified:
benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async.xml
benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-sync.xml
Log:
Updated cfgs for 1.4.1 testing
Copied: benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async-br.xml (from rev 5215, benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async.xml)
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async-br.xml (rev 0)
+++ benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async-br.xml 2008-01-24 13:51:04 UTC (rev 5220)
@@ -0,0 +1,72 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<server>
+ <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
+
+ <mbean code="org.jboss.cache.TreeCache" name="jboss.cache:service=TreeCache">
+
+ <depends>jboss:service=Naming</depends>
+ <depends>jboss:service=TransactionManager</depends>
+ <attribute name="TransactionManagerLookupClass">org.jboss.cache.DummyTransactionManagerLookup</attribute>
+
+ <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
+ <attribute name="CacheMode">REPL_ASYNC</attribute>
+ <attribute name="UseReplQueue">false</attribute>
+ <attribute name="ReplQueueInterval">0</attribute>
+ <attribute name="ReplQueueMaxElements">0</attribute>
+ <attribute name="ClusterName">TreeCache-Cluster</attribute>
+ <attribute name="ClusterConfig">
+ <config>
+ <TCP recv_buf_size="20000000" use_send_queues="false"
+ loopback="false"
+ discard_incompatible_packets="true"
+ max_bundle_size="64000"
+ max_bundle_timeout="30"
+ use_incoming_packet_handler="true"
+ enable_bundling="true"
+ enable_unicast_bundling="true"
+ enable_diagnostics="true"
+ />
+ <MPING mcast_addr="232.1.2.3" timeout="2000" num_initial_members="2"/>
+ <MERGE2 max_interval="30000" min_interval="10000"/>
+ <FD_SOCK/>
+ <VERIFY_SUSPECT timeout="1500"/>
+ <pbcast.NAKACK use_mcast_xmit="false" gc_lag="0"
+ retransmit_timeout="300,600,1200,2400,4800"
+ discard_delivered_msgs="true"/>
+ <pbcast.STABLE stability_delay="1000" desired_avg_gossip="50000"
+ max_bytes="400000"/>
+ <pbcast.GMS print_local_addr="true" join_timeout="5000"
+ join_retry_timeout="2000" shun="false"
+ view_bundling="true" view_ack_collection_timeout="5000"/>
+ <FC max_credits="5000000"
+ min_threshold="0.20"/>
+ <FRAG2 frag_size="60000"/>
+ <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
+ </config>
+ </attribute>
+ <attribute name="FetchInMemoryState">true</attribute>
+ <attribute name="InitialStateRetrievalTimeout">15000</attribute>
+ <attribute name="SyncReplTimeout">60000</attribute>
+ <attribute name="LockAcquisitionTimeout">10000</attribute>
+ <attribute name="EvictionPolicyClass"></attribute>
+ <attribute name="UseRegionBasedMarshalling">false</attribute>
+
+ <attribute name="BuddyReplicationConfig">
+ <config>
+ <buddyReplicationEnabled>true</buddyReplicationEnabled>
+ <buddyLocatorClass>org.jboss.cache.buddyreplication.NextMemberBuddyLocator</buddyLocatorClass>
+ <buddyLocatorProperties>
+ numBuddies = 1
+ ignoreColocatedBuddies = true
+ </buddyLocatorProperties>
+ <buddyPoolName>myBuddyPoolReplicationGroup</buddyPoolName>
+ <buddyCommunicationTimeout>10000</buddyCommunicationTimeout>
+ <dataGravitationRemoveOnFind>true</dataGravitationRemoveOnFind>
+ <dataGravitationSearchBackupTrees>true</dataGravitationSearchBackupTrees>
+ <autoDataGravitation>false</autoDataGravitation>
+ </config>
+ </attribute>
+ </mbean>
+
+</server>
Modified: benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async.xml 2008-01-24 13:50:41 UTC (rev 5219)
+++ benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-async.xml 2008-01-24 13:51:04 UTC (rev 5220)
@@ -1,147 +1,49 @@
<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- ===================================================================== -->
-<!-- -->
-<!-- Sample TreeCache Service Configuration -->
-<!-- -->
-<!-- ===================================================================== -->
-
<server>
- <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
+ <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
+ <mbean code="org.jboss.cache.TreeCache" name="jboss.cache:service=TreeCache">
-
- <!-- ==================================================================== -->
- <!-- Defines TreeCache configuration -->
- <!-- ==================================================================== -->
-
- <mbean code="org.jboss.cache.TreeCache"
- name="jboss.cache:service=TreeCache">
-
- <depends>jboss:service=Naming</depends>
- <depends>jboss:service=TransactionManager</depends>
-
- <!--
- Configure the TransactionManager
- -->
- <attribute name="TransactionManagerLookupClass">org.jboss.cache.DummyTransactionManagerLookup</attribute>
-
- <!--
- Isolation level : SERIALIZABLE
- REPEATABLE_READ (default)
- READ_COMMITTED
- READ_UNCOMMITTED
- NONE
- -->
- <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
-
- <!--
- Valid modes are LOCAL
- REPL_ASYNC
- REPL_SYNC
- INVALIDATION_ASYNC
- INVALIDATION_SYNC
- -->
- <attribute name="CacheMode">REPL_ASYNC</attribute>
-
- <!--
- Just used for async repl: use a replication queue
- -->
- <attribute name="UseReplQueue">false</attribute>
-
- <!--
- Replication interval for replication queue (in ms)
- -->
- <attribute name="ReplQueueInterval">0</attribute>
-
- <!--
- Max number of elements which trigger replication
- -->
- <attribute name="ReplQueueMaxElements">0</attribute>
-
- <!-- Name of cluster. Needs to be the same for all clusters, in order
- to find each other
- -->
- <attribute name="ClusterName">TreeCache-Cluster</attribute>
-
- <!-- JGroups protocol stack properties. Can also be a URL,
- e.g. file:/home/bela/default.xml
- <attribute name="ClusterProperties"></attribute>
- -->
-
- <attribute name="ClusterConfig">
- <config>
- <!-- UDP: if you have a multihomed machine,
- set the bind_addr attribute to the appropriate NIC IP address, e.g bind_addr="192.168.0.2"
- -->
- <!-- UDP: On Windows machines, because of the media sense feature
- being broken with multicast (even after disabling media sense)
- set the loopback attribute to true -->
- <UDP mcast_addr="228.1.2.3" mcast_port="48866"
- ip_ttl="64" ip_mcast="true"
- mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
- ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
- loopback="false"/>
- <PING timeout="2000" num_initial_members="3"
- up_thread="false" down_thread="false"/>
- <MERGE2 min_interval="10000" max_interval="20000"/>
- <!-- <FD shun="true" up_thread="true" down_thread="true" />-->
- <FD_SOCK/>
- <VERIFY_SUSPECT timeout="1500"
- up_thread="false" down_thread="false"/>
- <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
- max_xmit_size="8192" up_thread="false" down_thread="false"/>
- <UNICAST timeout="600,1200,2400" window_size="100" min_threshold="10"
- down_thread="false"/>
- <pbcast.STABLE desired_avg_gossip="20000"
- up_thread="false" down_thread="false"/>
- <FRAG frag_size="8192"
- down_thread="false" up_thread="false"/>
- <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
- shun="true" print_local_addr="true"/>
- <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
- </config>
- </attribute>
-
-
- <!--
- Whether or not to fetch state on joining a cluster
- NOTE this used to be called FetchStateOnStartup and has been renamed to be more descriptive.
- -->
- <attribute name="FetchInMemoryState">false</attribute>
-
- <!--
- The max amount of time (in milliseconds) we wait until the
- initial state (ie. the contents of the cache) are retrieved from
- existing members in a clustered environment
- -->
- <attribute name="InitialStateRetrievalTimeout">15000</attribute>
-
- <!--
- Number of milliseconds to wait until all responses for a
- synchronous call have been received.
- -->
- <attribute name="SyncReplTimeout">60000</attribute>
-
- <!-- Max number of milliseconds to wait for a lock acquisition -->
- <attribute name="LockAcquisitionTimeout">10000</attribute>
-
- <!-- Name of the eviction policy class. -->
- <attribute name="EvictionPolicyClass"></attribute>
-
- <!--
- Indicate whether to use region based marshalling or not. Set this to true if you are running under a scoped
- class loader, e.g., inside an application server. Default is "false".
- -->
- <attribute name="UseRegionBasedMarshalling">false</attribute>
- </mbean>
-
-
- <!-- Uncomment to get a graphical view of the TreeCache MBean above -->
- <!-- <mbean code="org.jboss.cache.TreeCacheView" name="jboss.cache:service=TreeCacheView">-->
- <!-- <depends>jboss.cache:service=TreeCache</depends>-->
- <!-- <attribute name="CacheService">jboss.cache:service=TreeCache</attribute>-->
- <!-- </mbean>-->
-
-
+ <depends>jboss:service=Naming</depends>
+ <depends>jboss:service=TransactionManager</depends>
+ <attribute name="TransactionManagerLookupClass">org.jboss.cache.DummyTransactionManagerLookup</attribute>
+ <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
+ <attribute name="CacheMode">REPL_ASYNC</attribute>
+ <attribute name="UseReplQueue">false</attribute>
+ <attribute name="ReplQueueInterval">0</attribute>
+ <attribute name="ReplQueueMaxElements">0</attribute>
+ <attribute name="ClusterName">TreeCache-Cluster</attribute>
+ <attribute name="ClusterConfig">
+ <config>
+ <UDP mcast_addr="232.1.2.3" mcast_port="48866"
+ ip_ttl="64" ip_mcast="true"
+ mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
+ ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
+ loopback="false"/>
+ <PING timeout="2000" num_initial_members="3"
+ up_thread="false" down_thread="false"/>
+ <MERGE2 min_interval="10000" max_interval="20000"/>
+ <FD_SOCK/>
+ <VERIFY_SUSPECT timeout="1500"
+ up_thread="false" down_thread="false"/>
+ <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
+ max_xmit_size="8192" up_thread="false" down_thread="false"/>
+ <UNICAST timeout="600,1200,2400" window_size="100" min_threshold="10"
+ down_thread="false"/>
+ <pbcast.STABLE desired_avg_gossip="20000"
+ up_thread="false" down_thread="false"/>
+ <FRAG frag_size="8192"
+ down_thread="false" up_thread="false"/>
+ <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
+ shun="true" print_local_addr="true"/>
+ <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
+ </config>
+ </attribute>
+ <attribute name="FetchInMemoryState">false</attribute>
+ <attribute name="InitialStateRetrievalTimeout">15000</attribute>
+ <attribute name="SyncReplTimeout">60000</attribute>
+ <attribute name="LockAcquisitionTimeout">10000</attribute>
+ <attribute name="EvictionPolicyClass"></attribute>
+ <attribute name="UseRegionBasedMarshalling">false</attribute>
+ </mbean>
</server>
Modified: benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-sync.xml
===================================================================
--- benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-sync.xml 2008-01-24 13:50:41 UTC (rev 5219)
+++ benchmarks/benchmark-fwk/trunk/cache-products/jbosscache-1.4.1/conf/pess-repl-sync.xml 2008-01-24 13:51:04 UTC (rev 5220)
@@ -1,147 +1,49 @@
<?xml version="1.0" encoding="UTF-8"?>
-
-<!-- ===================================================================== -->
-<!-- -->
-<!-- Sample TreeCache Service Configuration -->
-<!-- -->
-<!-- ===================================================================== -->
-
<server>
- <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
+ <classpath codebase="./lib" archives="jboss-cache.jar, jgroups.jar"/>
+ <mbean code="org.jboss.cache.TreeCache" name="jboss.cache:service=TreeCache">
-
- <!-- ==================================================================== -->
- <!-- Defines TreeCache configuration -->
- <!-- ==================================================================== -->
-
- <mbean code="org.jboss.cache.TreeCache"
- name="jboss.cache:service=TreeCache">
-
- <depends>jboss:service=Naming</depends>
- <depends>jboss:service=TransactionManager</depends>
-
- <!--
- Configure the TransactionManager
- -->
- <attribute name="TransactionManagerLookupClass">org.jboss.cache.DummyTransactionManagerLookup</attribute>
-
- <!--
- Isolation level : SERIALIZABLE
- REPEATABLE_READ (default)
- READ_COMMITTED
- READ_UNCOMMITTED
- NONE
- -->
- <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
-
- <!--
- Valid modes are LOCAL
- REPL_ASYNC
- REPL_SYNC
- INVALIDATION_ASYNC
- INVALIDATION_SYNC
- -->
- <attribute name="CacheMode">REPL_SYNC</attribute>
-
- <!--
- Just used for async repl: use a replication queue
- -->
- <attribute name="UseReplQueue">false</attribute>
-
- <!--
- Replication interval for replication queue (in ms)
- -->
- <attribute name="ReplQueueInterval">0</attribute>
-
- <!--
- Max number of elements which trigger replication
- -->
- <attribute name="ReplQueueMaxElements">0</attribute>
-
- <!-- Name of cluster. Needs to be the same for all clusters, in order
- to find each other
- -->
- <attribute name="ClusterName">TreeCache-Cluster</attribute>
-
- <!-- JGroups protocol stack properties. Can also be a URL,
- e.g. file:/home/bela/default.xml
- <attribute name="ClusterProperties"></attribute>
- -->
-
- <attribute name="ClusterConfig">
- <config>
- <!-- UDP: if you have a multihomed machine,
- set the bind_addr attribute to the appropriate NIC IP address, e.g bind_addr="192.168.0.2"
- -->
- <!-- UDP: On Windows machines, because of the media sense feature
- being broken with multicast (even after disabling media sense)
- set the loopback attribute to true -->
- <UDP mcast_addr="228.1.2.3" mcast_port="48866"
- ip_ttl="64" ip_mcast="true"
- mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
- ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
- loopback="false"/>
- <PING timeout="2000" num_initial_members="3"
- up_thread="false" down_thread="false"/>
- <MERGE2 min_interval="10000" max_interval="20000"/>
- <!-- <FD shun="true" up_thread="true" down_thread="true" />-->
- <FD_SOCK/>
- <VERIFY_SUSPECT timeout="1500"
- up_thread="false" down_thread="false"/>
- <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
- max_xmit_size="8192" up_thread="false" down_thread="false"/>
- <UNICAST timeout="600,1200,2400" window_size="100" min_threshold="10"
- down_thread="false"/>
- <pbcast.STABLE desired_avg_gossip="20000"
- up_thread="false" down_thread="false"/>
- <FRAG frag_size="8192"
- down_thread="false" up_thread="false"/>
- <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
- shun="true" print_local_addr="true"/>
- <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
- </config>
- </attribute>
-
-
- <!--
- Whether or not to fetch state on joining a cluster
- NOTE this used to be called FetchStateOnStartup and has been renamed to be more descriptive.
- -->
- <attribute name="FetchInMemoryState">false</attribute>
-
- <!--
- The max amount of time (in milliseconds) we wait until the
- initial state (ie. the contents of the cache) are retrieved from
- existing members in a clustered environment
- -->
- <attribute name="InitialStateRetrievalTimeout">15000</attribute>
-
- <!--
- Number of milliseconds to wait until all responses for a
- synchronous call have been received.
- -->
- <attribute name="SyncReplTimeout">60000</attribute>
-
- <!-- Max number of milliseconds to wait for a lock acquisition -->
- <attribute name="LockAcquisitionTimeout">10000</attribute>
-
- <!-- Name of the eviction policy class. -->
- <attribute name="EvictionPolicyClass"></attribute>
-
- <!--
- Indicate whether to use region based marshalling or not. Set this to true if you are running under a scoped
- class loader, e.g., inside an application server. Default is "false".
- -->
- <attribute name="UseRegionBasedMarshalling">false</attribute>
- </mbean>
-
-
- <!-- Uncomment to get a graphical view of the TreeCache MBean above -->
- <!-- <mbean code="org.jboss.cache.TreeCacheView" name="jboss.cache:service=TreeCacheView">-->
- <!-- <depends>jboss.cache:service=TreeCache</depends>-->
- <!-- <attribute name="CacheService">jboss.cache:service=TreeCache</attribute>-->
- <!-- </mbean>-->
-
-
+ <depends>jboss:service=Naming</depends>
+ <depends>jboss:service=TransactionManager</depends>
+ <attribute name="TransactionManagerLookupClass">org.jboss.cache.DummyTransactionManagerLookup</attribute>
+ <attribute name="IsolationLevel">REPEATABLE_READ</attribute>
+ <attribute name="CacheMode">REPL_SYNC</attribute>
+ <attribute name="UseReplQueue">false</attribute>
+ <attribute name="ReplQueueInterval">0</attribute>
+ <attribute name="ReplQueueMaxElements">0</attribute>
+ <attribute name="ClusterName">TreeCache-Cluster</attribute>
+ <attribute name="ClusterConfig">
+ <config>
+ <UDP mcast_addr="232.1.2.3" mcast_port="48866"
+ ip_ttl="64" ip_mcast="true"
+ mcast_send_buf_size="150000" mcast_recv_buf_size="80000"
+ ucast_send_buf_size="150000" ucast_recv_buf_size="80000"
+ loopback="false"/>
+ <PING timeout="2000" num_initial_members="3"
+ up_thread="false" down_thread="false"/>
+ <MERGE2 min_interval="10000" max_interval="20000"/>
+ <FD_SOCK/>
+ <VERIFY_SUSPECT timeout="1500"
+ up_thread="false" down_thread="false"/>
+ <pbcast.NAKACK gc_lag="50" retransmit_timeout="600,1200,2400,4800"
+ max_xmit_size="8192" up_thread="false" down_thread="false"/>
+ <UNICAST timeout="600,1200,2400" window_size="100" min_threshold="10"
+ down_thread="false"/>
+ <pbcast.STABLE desired_avg_gossip="20000"
+ up_thread="false" down_thread="false"/>
+ <FRAG frag_size="8192"
+ down_thread="false" up_thread="false"/>
+ <pbcast.GMS join_timeout="5000" join_retry_timeout="2000"
+ shun="true" print_local_addr="true"/>
+ <pbcast.STATE_TRANSFER up_thread="true" down_thread="true"/>
+ </config>
+ </attribute>
+ <attribute name="FetchInMemoryState">false</attribute>
+ <attribute name="InitialStateRetrievalTimeout">15000</attribute>
+ <attribute name="SyncReplTimeout">60000</attribute>
+ <attribute name="LockAcquisitionTimeout">10000</attribute>
+ <attribute name="EvictionPolicyClass"></attribute>
+ <attribute name="UseRegionBasedMarshalling">false</attribute>
+ </mbean>
</server>
16 years, 3 months
JBoss Cache SVN: r5219 - benchmarks/benchmark-fwk/trunk.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 08:50:41 -0500 (Thu, 24 Jan 2008)
New Revision: 5219
Modified:
benchmarks/benchmark-fwk/trunk/cluster.sh
benchmarks/benchmark-fwk/trunk/runNode.sh
Log:
Added support for user JVM params
Modified: benchmarks/benchmark-fwk/trunk/cluster.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:44:27 UTC (rev 5218)
+++ benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:50:41 UTC (rev 5219)
@@ -27,6 +27,8 @@
# Number of servers to launch on - taken from the command line.
NUM_SERVERS=${4}
+USER_JVM_PARAMS=${5}
+
COMMAND=${1}
# the DNS domain of your servers
@@ -43,7 +45,7 @@
do
server="${HOSTNAMES[idx]}"
echo Starting CacheBenchmarkFramework on host ${server}
- ssh ${SSH_USER}(a)${server}.${DOMAIN} "cd ${CACHE_BENCHMARK_HOME} && ./runNode.sh ${idx} ${CACHE_DIST} ${CFG_FILE} ${NUM_SERVERS}"
+ ssh ${SSH_USER}(a)${server}.${DOMAIN} "cd ${CACHE_BENCHMARK_HOME} && ./runNode.sh ${idx} ${CACHE_DIST} ${CFG_FILE} ${NUM_SERVERS} ${USER_JVM_PARAMS}"
sleep 2
done
;;
@@ -57,10 +59,10 @@
done
;;
*)
- echo "Usage: ${0} [start | stop] [cache distribution to test] [name of configuration file to use] [number of servers to launch on]"
+ echo "Usage: ${0} [start | stop] [cache distribution to test] [name of configuration file to use] [number of servers to launch on] [optional JVM params]"
echo
echo "Example:"
- echo " ${0} start jbosscache-2.0.0 repl_async.xml 6"
+ echo " ${0} start jbosscache-2.0.0 repl_async.xml 6 \"-Dbind.address=1.2.3.4 -Dxyz=abc\""
echo " ${0} stop"
echo " Note that the stop command will stop all instances on all configured hosts"
;;
Modified: benchmarks/benchmark-fwk/trunk/runNode.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/runNode.sh 2008-01-24 13:44:27 UTC (rev 5218)
+++ benchmarks/benchmark-fwk/trunk/runNode.sh 2008-01-24 13:50:41 UTC (rev 5219)
@@ -4,12 +4,12 @@
# those would make an automatic conversion from unix CLASSPATH to win classpath, needed when executing java -cp
preferIPv4Stack=true
-
+DEBUG=false
CURRENT_INDEX=${1}
CACHE_PRODUCT=${2}
TEST_CFG=${3}
CLUSTER_SIZE=${4}
-DEBUG=${5}
+USER_JVM_PARAMS=${5}
PIDFILE="PID.pid"
if [ -e ${PIDFILE} ]
then
@@ -29,11 +29,12 @@
then
echo Usage:
echo
- echo ./runNode.sh [current node index] [cache product to test] [test config file] [cluster size]
+ echo ./runNode.sh [current node index] [cache product to test] [test config file] [cluster size] [JVM params (optional)]
echo param [current node index] : the index of this node in the list of nodes in the cluster [0 .. <cluster size> - 1]
echo param [cache product to test] : must be one of the directories names under './cache-products'
echo param [test config file] : configuration file to use with the cache product. Typically resides in './cache-products/XXX/conf/'
echo param [cluster size] : total number of nodes that will run tests.
+ echo param [JVM params] : an optional extra set of parameters to be passed to the JVM - e.g., "-Dbind.address=127.0.0.1 -Dxyz=abc"
echo
echo Example: './runNode.sh 0 jbosscache-2.0.0 repl_async.xml 3' will start the 1st node running an instance of jbc2.0.0 on a cluster made out of 3 nodes, using the repl_async configuration.
exit 1
@@ -59,7 +60,7 @@
exit 2
fi
-JVM_OPTIONS="${JVM_OPTIONS} -DcacheBenchFwk.cacheConfigFile=${TEST_CFG} -DcurrentIndex=${CURRENT_INDEX} -DclusterSize=${CLUSTER_SIZE} -DcurrentIndex=${CURRENT_INDEX} -Djava.net.preferIPv4Stack=${preferIPv4Stack}"
+JVM_OPTIONS="${JVM_OPTIONS} ${USER_JVM_PARAMS} -DcacheBenchFwk.cacheConfigFile=${TEST_CFG} -DcurrentIndex=${CURRENT_INDEX} -DclusterSize=${CLUSTER_SIZE} -DcurrentIndex=${CURRENT_INDEX} -Djava.net.preferIPv4Stack=${preferIPv4Stack}"
TO_EXECUTE="java $JVM_OPTIONS -cp $CLASSPATH org.cachebench.CacheBenchmarkRunner"
if [ "$DEBUG" = "debug" ]
16 years, 3 months
JBoss Cache SVN: r5218 - benchmarks/benchmark-fwk/trunk/src/org/cachebench/smartfrog.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 08:44:27 -0500 (Thu, 24 Jan 2008)
New Revision: 5218
Modified:
benchmarks/benchmark-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java
Log:
removed sf
Modified: benchmarks/benchmark-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java
===================================================================
--- benchmarks/benchmark-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java 2008-01-24 13:22:55 UTC (rev 5217)
+++ benchmarks/benchmark-fwk/trunk/src/org/cachebench/smartfrog/CacheBenchmarkPrim.java 2008-01-24 13:44:27 UTC (rev 5218)
@@ -1,12 +1,12 @@
package org.cachebench.smartfrog;
-import org.smartfrog.sfcore.common.SmartFrogException;
-import org.smartfrog.sfcore.common.SmartFrogResolutionException;
-import org.smartfrog.sfcore.common.SmartFrogLivenessException;
-import org.smartfrog.sfcore.logging.LogSF;
-import org.smartfrog.sfcore.prim.Prim;
-import org.smartfrog.sfcore.prim.PrimImpl;
-import org.smartfrog.sfcore.prim.TerminationRecord;
+//import org.smartfrog.sfcore.common.SmartFrogException;
+//import org.smartfrog.sfcore.common.SmartFrogResolutionException;
+//import org.smartfrog.sfcore.common.SmartFrogLivenessException;
+//import org.smartfrog.sfcore.logging.LogSF;
+//import org.smartfrog.sfcore.prim.Prim;
+//import org.smartfrog.sfcore.prim.PrimImpl;
+//import org.smartfrog.sfcore.prim.TerminationRecord;
import java.io.*;
import java.rmi.RemoteException;
@@ -14,178 +14,178 @@
/**
* @author Mircea.Markus(a)jboss.com
*/
-public class CacheBenchmarkPrim extends PrimImpl implements Prim
+public class CacheBenchmarkPrim// extends PrimImpl implements Prim
{
- private static LogSF log;
-
- private int nodeIndex = -1;
- private String cacheDistribution;
- private File toRunIn;
- private int clusterSize = -1;
- private String scriptToExec;
- private int minClusterSize;
- private int maxClusterSize;
-
- public CacheBenchmarkPrim() throws RemoteException
- {
- }
-
- public void sfPing(Object o) throws SmartFrogLivenessException, RemoteException
- {
- super.sfPing(o); //To change body of overridden methods use File | Settings | File Templates.
- }
-
- public synchronized void sfDeploy() throws SmartFrogException, RemoteException
- {
- super.sfDeploy();
- log = super.sfGetApplicationLog();
- log.trace("deploy started");
- //reading the attributes here
- nodeIndex = (Integer) sfResolve("nodeIndex");
- log.info("Received current index: " + nodeIndex);
- cacheDistribution = (String) sfResolve("cacheDistribution");
- log.info("Received cache distribution: " + cacheDistribution);
- toRunIn = getFwkHomeDir();
- log.info("Received homedir: " + toRunIn);
- clusterSize = (Integer)sfResolve("clusterSize");
- log.info("Received cluster size: " + clusterSize);
- minClusterSize = (Integer) sfResolve("minClusterSize");
- log.info("Received MIN cluster size: " + minClusterSize);
- maxClusterSize = (Integer) sfResolve("maxClusterSize");
- log.info("Received MAX cluster size: " + maxClusterSize);
- scriptToExec = (String) sfResolve("scriptToExec");
- log.info("Received stringToExec: " + scriptToExec);
- log.trace("Deploy finished");
- }
-
- public synchronized void sfStart() throws SmartFrogException, RemoteException
- {
- if ((nodeIndex + 1) < clusterSize)
- {
- log.info("Running in a separate thread, not last node in the compound" + getNodeDescription());
- Thread thread = new Thread()
- {
- public void run()
- {
- runBenchmark();
- }
- };
- thread.start();
- }
- //the last node should run in a sync manner so that the coumpound would only end when the test ends
- else
- {
- log.info("Running in the same thread as this is the last node in the compound " + getNodeDescription());
- runBenchmark();
- }
- }
-
- private void runBenchmark()
- {
- try
- {
- super.sfStart();
- log.trace("Entered sfStart...");
- if (clusterSize <= nodeIndex)
- {
- log.info("Not processing this node as compund is smaller than " + nodeIndex + getNodeDescription());
- return;
- }
- if (clusterSize < minClusterSize || clusterSize > maxClusterSize)
- {
- log.info("Only clusters with size in range (" + minClusterSize + ", " + maxClusterSize + ") are " +
- "processed, skiping this one" + getNodeDescription());
- correctTerminationOfTestsIfNeeded();
- return;
- }
- String command = scriptToExec + " " + nodeIndex + " " + cacheDistribution + " " + clusterSize;
- log.info("Executing command: " + command);
- Process process = Runtime.getRuntime().exec(command, null, toRunIn);
- InputStreamReader reader = new InputStreamReader(process.getInputStream());
- BufferedReader bufferedReader = new LineNumberReader(reader);
- String line;
- while ((line = bufferedReader.readLine()) != null)
- {
- log.info(scriptToExec + " >>> " + line);
- }
- bufferedReader.close();
- int exitValue = process.waitFor();
- if (exitValue != 0 )
- {
- log.warn("Script exited with code: " + exitValue);
- }
-
- correctTerminationOfTestsIfNeeded();
- } catch (SmartFrogException e)
- {
- log.error("Unexpected error:" + e.getMessage(), e);
- terminate(e);
- } catch (IOException e)
- {
- log.warn("Does the script have X rights?", e);
- terminate(e);
-
- } catch (InterruptedException e)
- {
- log.err("This is quite strange", e);
- terminate(e);
- }
- }
-
- /**
- * The test will only be terminated if this is the last cluster compound running.
- */
- private void correctTerminationOfTestsIfNeeded()
- {
- if (this.clusterSize == this.maxClusterSize)
- {
- log.info("Good news, terminating ALL the tests, terminator is " + getNodeDescription());
- TerminationRecord terminationRecord = new TerminationRecord(TerminationRecord.NORMAL, "terminated the benchmark " +
- getNodeDescription(), null);
- sfTerminate(terminationRecord);
- log.info("Test terminated successfully " + getNodeDescription());
- }
- }
-
- private void terminate(Exception e)
- {
- TerminationRecord terminationRecord = new TerminationRecord(TerminationRecord.ABNORMAL , "terminated the benchmark " +
- getNodeDescription(),null, e);
- sfTerminate(terminationRecord);
-
- }
-
- private File getFwkHomeDir()
- throws SmartFrogResolutionException, RemoteException
- {
- File toRunIn;
- String cacheBenchmarkHome = sfResolve("cacheBenchmarkHome") + "";
- toRunIn = new File(cacheBenchmarkHome);
- if (!toRunIn.isDirectory())
- {
- log.error("cacheBenchmarkHome is not specified correctly: " + cacheBenchmarkHome);
- }
- return toRunIn;
- }
-
- protected synchronized void sfTerminateWith(TerminationRecord terminationRecord)
- {
- super.sfTerminateWith(terminationRecord);
- log.info("sfTerminateWith called with value:" + terminationRecord);
- }
-
- public String getNodeDescription()
- {
- return "( clusterSize:" + clusterSize + ", nodeIndex:" + this.nodeIndex + " )";
- }
-
- /**
- * Ugly HACK - seems like if the parent is pending in an sfRun, e.g. then it would not send hart beat checks
- * to the childrens so they would consider a issues.
- * Might be that this is not a totally proper scenarion for using the framework, but it solves our needs.
- */
- protected void sfLivenessFailure(Object source, Object target, Throwable failure)
- {
- log.trace("Recieved liveness error, ignoring. Source:" + source + ", target:" + target + ", failure: " + failure);
- }
+// private static LogSF log;
+//
+// private int nodeIndex = -1;
+// private String cacheDistribution;
+// private File toRunIn;
+// private int clusterSize = -1;
+// private String scriptToExec;
+// private int minClusterSize;
+// private int maxClusterSize;
+//
+// public CacheBenchmarkPrim() throws RemoteException
+// {
+// }
+//
+// public void sfPing(Object o) throws SmartFrogLivenessException, RemoteException
+// {
+// super.sfPing(o); //To change body of overridden methods use File | Settings | File Templates.
+// }
+//
+// public synchronized void sfDeploy() throws SmartFrogException, RemoteException
+// {
+// super.sfDeploy();
+// log = super.sfGetApplicationLog();
+// log.trace("deploy started");
+// //reading the attributes here
+// nodeIndex = (Integer) sfResolve("nodeIndex");
+// log.info("Received current index: " + nodeIndex);
+// cacheDistribution = (String) sfResolve("cacheDistribution");
+// log.info("Received cache distribution: " + cacheDistribution);
+// toRunIn = getFwkHomeDir();
+// log.info("Received homedir: " + toRunIn);
+// clusterSize = (Integer)sfResolve("clusterSize");
+// log.info("Received cluster size: " + clusterSize);
+// minClusterSize = (Integer) sfResolve("minClusterSize");
+// log.info("Received MIN cluster size: " + minClusterSize);
+// maxClusterSize = (Integer) sfResolve("maxClusterSize");
+// log.info("Received MAX cluster size: " + maxClusterSize);
+// scriptToExec = (String) sfResolve("scriptToExec");
+// log.info("Received stringToExec: " + scriptToExec);
+// log.trace("Deploy finished");
+// }
+//
+// public synchronized void sfStart() throws SmartFrogException, RemoteException
+// {
+// if ((nodeIndex + 1) < clusterSize)
+// {
+// log.info("Running in a separate thread, not last node in the compound" + getNodeDescription());
+// Thread thread = new Thread()
+// {
+// public void run()
+// {
+// runBenchmark();
+// }
+// };
+// thread.start();
+// }
+// //the last node should run in a sync manner so that the coumpound would only end when the test ends
+// else
+// {
+// log.info("Running in the same thread as this is the last node in the compound " + getNodeDescription());
+// runBenchmark();
+// }
+// }
+//
+// private void runBenchmark()
+// {
+// try
+// {
+// super.sfStart();
+// log.trace("Entered sfStart...");
+// if (clusterSize <= nodeIndex)
+// {
+// log.info("Not processing this node as compund is smaller than " + nodeIndex + getNodeDescription());
+// return;
+// }
+// if (clusterSize < minClusterSize || clusterSize > maxClusterSize)
+// {
+// log.info("Only clusters with size in range (" + minClusterSize + ", " + maxClusterSize + ") are " +
+// "processed, skiping this one" + getNodeDescription());
+// correctTerminationOfTestsIfNeeded();
+// return;
+// }
+// String command = scriptToExec + " " + nodeIndex + " " + cacheDistribution + " " + clusterSize;
+// log.info("Executing command: " + command);
+// Process process = Runtime.getRuntime().exec(command, null, toRunIn);
+// InputStreamReader reader = new InputStreamReader(process.getInputStream());
+// BufferedReader bufferedReader = new LineNumberReader(reader);
+// String line;
+// while ((line = bufferedReader.readLine()) != null)
+// {
+// log.info(scriptToExec + " >>> " + line);
+// }
+// bufferedReader.close();
+// int exitValue = process.waitFor();
+// if (exitValue != 0 )
+// {
+// log.warn("Script exited with code: " + exitValue);
+// }
+//
+// correctTerminationOfTestsIfNeeded();
+// } catch (SmartFrogException e)
+// {
+// log.error("Unexpected error:" + e.getMessage(), e);
+// terminate(e);
+// } catch (IOException e)
+// {
+// log.warn("Does the script have X rights?", e);
+// terminate(e);
+//
+// } catch (InterruptedException e)
+// {
+// log.err("This is quite strange", e);
+// terminate(e);
+// }
+// }
+//
+// /**
+// * The test will only be terminated if this is the last cluster compound running.
+// */
+// private void correctTerminationOfTestsIfNeeded()
+// {
+// if (this.clusterSize == this.maxClusterSize)
+// {
+// log.info("Good news, terminating ALL the tests, terminator is " + getNodeDescription());
+// TerminationRecord terminationRecord = new TerminationRecord(TerminationRecord.NORMAL, "terminated the benchmark " +
+// getNodeDescription(), null);
+// sfTerminate(terminationRecord);
+// log.info("Test terminated successfully " + getNodeDescription());
+// }
+// }
+//
+// private void terminate(Exception e)
+// {
+// TerminationRecord terminationRecord = new TerminationRecord(TerminationRecord.ABNORMAL , "terminated the benchmark " +
+// getNodeDescription(),null, e);
+// sfTerminate(terminationRecord);
+//
+// }
+//
+// private File getFwkHomeDir()
+// throws SmartFrogResolutionException, RemoteException
+// {
+// File toRunIn;
+// String cacheBenchmarkHome = sfResolve("cacheBenchmarkHome") + "";
+// toRunIn = new File(cacheBenchmarkHome);
+// if (!toRunIn.isDirectory())
+// {
+// log.error("cacheBenchmarkHome is not specified correctly: " + cacheBenchmarkHome);
+// }
+// return toRunIn;
+// }
+//
+// protected synchronized void sfTerminateWith(TerminationRecord terminationRecord)
+// {
+// super.sfTerminateWith(terminationRecord);
+// log.info("sfTerminateWith called with value:" + terminationRecord);
+// }
+//
+// public String getNodeDescription()
+// {
+// return "( clusterSize:" + clusterSize + ", nodeIndex:" + this.nodeIndex + " )";
+// }
+//
+// /**
+// * Ugly HACK - seems like if the parent is pending in an sfRun, e.g. then it would not send hart beat checks
+// * to the childrens so they would consider a issues.
+// * Might be that this is not a totally proper scenarion for using the framework, but it solves our needs.
+// */
+// protected void sfLivenessFailure(Object source, Object target, Throwable failure)
+// {
+// log.trace("Recieved liveness error, ignoring. Source:" + source + ", target:" + target + ", failure: " + failure);
+// }
}
16 years, 3 months
JBoss Cache SVN: r5217 - benchmarks/benchmark-fwk/trunk.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 08:22:55 -0500 (Thu, 24 Jan 2008)
New Revision: 5217
Modified:
benchmarks/benchmark-fwk/trunk/cluster.sh
Log:
Updated help docs
Modified: benchmarks/benchmark-fwk/trunk/cluster.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:20:44 UTC (rev 5216)
+++ benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:22:55 UTC (rev 5217)
@@ -61,5 +61,7 @@
echo
echo "Example:"
echo " ${0} start jbosscache-2.0.0 repl_async.xml 6"
+ echo " ${0} stop"
+ echo " Note that the stop command will stop all instances on all configured hosts"
;;
esac
16 years, 3 months
JBoss Cache SVN: r5216 - benchmarks/benchmark-fwk/trunk.
by jbosscache-commits＠lists.jboss.org
Author: manik.surtani(a)jboss.com
Date: 2008-01-24 08:20:44 -0500 (Thu, 24 Jan 2008)
New Revision: 5216
Modified:
benchmarks/benchmark-fwk/trunk/cluster.sh
Log:
Updated script
Modified: benchmarks/benchmark-fwk/trunk/cluster.sh
===================================================================
--- benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:13:04 UTC (rev 5215)
+++ benchmarks/benchmark-fwk/trunk/cluster.sh 2008-01-24 13:20:44 UTC (rev 5216)
@@ -48,11 +48,11 @@
done
;;
stop)
- for ((idx=0; idx < NUM_SERVERS ; idx++))
+ for ((idx=0; idx < ${#HOSTNAMES[*]} ; idx++))
do
server="${HOSTNAMES[idx]}"
echo Starting CacheBenchmarkFramework on host ${server}
- ssh ${SSH_USER}(a)${server}.${DOMAIN} "cd ${CACHE_BENCHMARK_HOME} && ./killNode.sh"
+ ssh ${SSH_USER}(a)${server}.${DOMAIN} "cd ${CACHE_BENCHMARK_HOME} && ./killNode.sh &"
sleep 2
done
;;
16 years, 3 months