Permalink
Browse files

fixes to new reconfiguration invocation

  • Loading branch information...
aaronelmore committed May 6, 2014
1 parent 7b0dc7c commit 833ad15f680b22455af7ef4f32cf847b345998c8
@@ -1052,11 +1052,13 @@ def extractReconfigEvents(rawReconfigs, expType, warmUp):
raise Exception("Invalid reconfig param: %s. Have at least a delayTimeMS:planID")
delayTimeMS = float(vals[0])
'''
if not warmUpApplied and warmUp > 0:
delayTimeMS += warmUp
#add slight buffer
delayTimeMS += 1000
warmUpApplied = True
'''
reconfig = { "delayTimeMS": delayTimeMS, "planID": vals[1], "leaderID": 0, "reconfigType": reconfigType }
if len(vals) == 3:
reconfig["leaderID"] = vals[2]
@@ -41,7 +41,7 @@ for b in ycsb; do
--client.duration=120000 \
--client.warmup=10000 \
--client.output_results_csv=interval_res.csv
--reconfig=95000:2:0
--reconfig=15000:2:0
)
i=0
@@ -345,7 +345,8 @@ def exec_benchmark(self, inst, project, \
if reconfigEvents:
if len(reconfigEvents) > 1:
raise NotImplementedError()
cmd = "-Dproc='@ReconfigurationStatic' -Dproc_start_time=%s -Dparam0=%s -Dparam1=%s -Dparam2=%s" % (reconfig['delayTimeMS'], reconfig['leaderID'], reconfig['planID'], reconfig['reconfigType'])
reconfig = reconfigEvents[0]
reconfig_cmd = "-Dproc=@ReconfigurationStatic -Dproc_start_time=%d -Dparam0=%s -Dparam1=%s -Dparam2=%s" % (reconfig['delayTimeMS'], reconfig['leaderID'], reconfig['planID'], reconfig['reconfigType'])
cmd = "ant %s hstore-benchmark %s %s" % (prefix, hstore_opts_cmd, reconfig_cmd)
output = run(cmd)

0 comments on commit 833ad15

Please sign in to comment.