Skip to content

Fix steprun replica timing #787

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 1 commit into from
Jun 3, 2025
Merged

Fix steprun replica timing #787

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 5 additions & 5 deletions src/generic/genstep.tcl
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -193,16 +193,16 @@ proc replica_waittocomplete {} {
proc primary_waittocomplete { port_file } {
putscli "Primary entering loop waiting for vucomplete"
proc primary_wait_to_complete_loop { port_file } {
global opmode
global opmode forever
upvar wcomplete wcomplete
set wcomplete [vucomplete]
if {!$wcomplete} { catch {after 5000 primary_wait_to_complete_loop $port_file} } else {
if {!$wcomplete} { catch {after 10000 primary_wait_to_complete_loop $port_file} } else {
putscli "Primary complete"
putscli "deleting port_file $port_file"
delete_port_file $port_file
putscli "Step workload complete"
#Call exit for primary
exit
vudestroy
set forever 1
}
}
set wcomplete "false"
Expand Down Expand Up @@ -241,7 +241,7 @@ proc wait_to_connect_and_continue { rampup duration prefix dbconfig port_file }
if { $prefix eq "ora" } {
foreach command [ list "diset tpcc ora_timeprofile false" "diset tpcc rampup 0" "diset tpcc duration $duration" "vuset vu $vucount" ] { sendonecommand $command $stepcount }
} else {
foreach command [ list "diset tpcc $prefix\_timeprofile false" "diset tpcc $prefix\_rampup 0" "diset tpcc $prefix\_duration $duration" "vuset vu $vucount" ] { sendonecommand $command $stepcount }
foreach command [ list "set opmode Local" "diset tpcc $prefix\_timeprofile false" "diset tpcc $prefix\_rampup 0" "diset tpcc $prefix\_duration $duration" "vuset vu $vucount" ] { sendonecommand $command $stepcount }
}
incr stepcount
} else {
Expand Down