Permalink
Browse files

concur tests working up to 200 connections

  • Loading branch information...
1 parent 038c30b commit e79ca0d974a2c6b37d3cfe2ba0d18a5b7d0bd950 @buzztroll buzztroll committed Dec 20, 2011
Showing with 19 additions and 5 deletions.
  1. +6 −2 scale_scripts/concur_pingpong.py
  2. +1 −1 scale_scripts/ping.yml
  3. +12 −2 scale_scripts/run_concur_pingpong.sh
@@ -16,7 +16,7 @@ def __init__(self, CFG):
self.dashi.handle(self.final_msg, "final_msg")
def ping(self, from_name=None):
- print "ponging to %s" % (from_name)
+ #print "ponging to %s" % (from_name)
self.dashi.fire(from_name, "pong")
def final_msg(self):
@@ -51,7 +51,7 @@ def run(self):
def go(self):
self.timer.start()
- print "sending first ping to %s" % (self.CFG.test.ponger_name)
+ #print "sending first ping to %s" % (self.CFG.test.ponger_name)
self.dashi.fire(self.CFG.test.ponger_name, "ping", from_name=self._myname)
while not self.done:
try:
@@ -64,6 +64,7 @@ def timeout(self):
self.done = True
def pong(self):
+ #print "got pong"
self.message_count = self.message_count + 1
self.dashi.fire(self.CFG.test.ponger_name, "ping", from_name=self._myname)
@@ -96,14 +97,17 @@ def main(argv):
res['message_count'] = msg_count_total
res['runtime'] = runtime
res['process_type'] = "pinger"
+ res['connection_count'] = len(thrs)
print "JSON: %s" % (json.dumps(res))
else:
+ print "ponger go"
receiver = DashiConcurScalePonger(CFG)
receiver.go()
if __name__ == '__main__':
+ print "start"
rc = main(sys.argv)
print "exit"
sys.exit(rc)
View
@@ -20,4 +20,4 @@ test:
ponger_name: pong
consume_timeout: 5
consume_count: 1
- runtime: 60
+ runtime: 30
@@ -23,26 +23,35 @@ scp $l_pgm_file $pinger_host:$r_pgm_file
scp $l_pgm_file $ponger_host:$r_pgm_file
trials=1
+con_cur="1 8 16 64 128 199"
touch $out_file
date >> $out_file
+for cur in $con_cur
+do
for i in `seq $trials`
do
echo "running: $i"
+ ssh $pinger_host pkill python
+ ssh $ponger_host pkill python
+
cpu_file=$out_file.pong.$i
ssh $ponger_host top -b -d 1 > $cpu_file&
kill_pid1=$!
cpu_file=$out_file.$i.$cnt.$sz.sendcpu
ssh $pinger_host top -b -d 1 > $cpu_file&
kill_pid2=$!
- cmd_line_args="--server.amqp.host=$amqp_host --dashi.exchange=$exchange"
+ cmd_line_args="--server.amqp.host=$amqp_host --dashi.exchange=$exchange --test.concur=$cur"
- ssh $ponger_host $py $r_pgm_file --test.type=pong $cmd_line_args $r_conf_file &
+ ponger_cmd="ssh $ponger_host $py $r_pgm_file --test.type=pong $cmd_line_args $r_conf_file"
+ $ponger_cmd &
recv_pid=$!
+ echo $ponger_cmd
sleep 2
+
ssh $pinger_host $py $r_pgm_file --test.type=ping $cmd_line_args $r_conf_file | tee $out_file
echo "pinger finished, waiting for ponger"
@@ -55,3 +64,4 @@ do
sleep 2
done
+done

0 comments on commit e79ca0d

Please sign in to comment.