diff distributed/nodes_stress_write_cassandra.rb @ 12:c69a41ffc439

Modified cassandra benchmark
author Nobuyasu
date Mon, 20 Jan 2014 17:01:23 +0900
parents f94fc7812cd8
children 77a01d4fca04
line wrap: on
line diff
--- a/distributed/nodes_stress_write_cassandra.rb	Mon Jan 20 02:59:12 2014 +0900
+++ b/distributed/nodes_stress_write_cassandra.rb	Mon Jan 20 17:01:23 2014 +0900
@@ -3,21 +3,31 @@
 require 'net/http'
 require 'benchmark'
 require 'uri'
-require '/home/mass/share/student/k128576/jungle_benchmark/distributed/get_node_name.rb'
-include GetNodeName
+require '/home/mass/share/student/k128576/jungle_benchmark/distributed/get_node_list.rb'
+require '/home/mass/share/student/k128576/jungle_benchmark/distributed/get_url_list.rb'
+include GetNodeList
+include GetUrlList
 
 schedule = ARGV[0].to_i
 time = Time.now.to_i 
 sleepTime = schedule - time
 sleep(sleepTime) 
 
-UUID="13814000-1dd2-11b2-b303-72d4cffbf294"
-nodename = get_node_name("/home/mass/share/student/k128576/jungle_benchmark/distributed/nodes.txt")
+UUID="13814000-1dd2-11b2-918d-0050568b0070"
+
+nodeList = get_node_list("/home/mass/share/student/k128576/jungle_benchmark/distributed/nodes.txt")
+urlList = get_url_list(nodeList, ':8080/editMessage?bname=hello%20world&uuid='+UUID);
+hostname = `hostname`
+if /[0-9]+/ =~ hostname then
+ mynum = $&.to_i
+end
+urlList = urlList.rotate(mynum)
+urlSize = urlList.size()
+
+count = ARGV[1].to_i
 r = Benchmark.measure {
-  count = ARGV[1].to_i
-  uri = URI.parse('http://'+nodename.chomp+':8080/editMessage?bname=hello%20world&uuid='+UUID)
   count.times {|i|
-    res = Net::HTTP.post_form(uri, {:author =>'oshiro', :bname =>'hello world', :uuid =>'0', :key =>'0', :msg =>"fugafuga #{i}"})
+    res = Net::HTTP.post_form(urlList[i%urlSize], {:author =>'oshiro', :bname =>'hello world', :uuid =>'0', :key =>'0', :msg =>"hogehoge #{i}"})
  }
 }
 puts r.real