Skip to content

Commit

Permalink
adding brad runner with variable txn clients (run_transactions_variab…
Browse files Browse the repository at this point in the history
…le_clients.py)
  • Loading branch information
wuziniu committed Mar 21, 2024
1 parent 8fa3ec1 commit 3bf2524
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 5 deletions.
4 changes: 0 additions & 4 deletions workloads/IMDB_extended/run_transactions_variable_clients.py
Original file line number Diff line number Diff line change
Expand Up @@ -247,7 +247,6 @@ def noop_handler(_signal, _frame):
def simulation_runner(
args,
worker_idx: int,
directory: Optional[Directory],
start_queue: mp.Queue,
control_semaphore: mp.Semaphore, # type: ignore
pause_semaphore: mp.Semaphore, # type: ignore
Expand Down Expand Up @@ -284,7 +283,6 @@ def noop_handler(_signal, _frame):
0.20,
0.10,
]
lookup_theatre_id_by_name = 0.8
txn_indexes = list(range(len(transactions)))
commits = [0 for _ in range(len(transactions))]
aborts = [0 for _ in range(len(transactions))]
Expand All @@ -311,7 +309,6 @@ def noop_handler(_signal, _frame):

txn_exec_count = 0
rand_backoff = None
overall_start = time.time()

latency_file = open(
out_dir / "oltp_latency_{}.csv".format(worker_idx), "w", encoding="UTF-8"
Expand Down Expand Up @@ -600,7 +597,6 @@ def main():
args=(
args,
idx,
directory,
start_queue[idx],
control_semaphore[idx],
pause_semaphore[idx],
Expand Down
1 change: 0 additions & 1 deletion workloads/IMDB_extended/run_variable_clients.py
Original file line number Diff line number Diff line change
Expand Up @@ -283,7 +283,6 @@ def noop_handler(_signal, _frame):
0.20,
0.10,
]
lookup_theatre_id_by_name = 0.8
txn_indexes = list(range(len(transactions)))
commits = [0 for _ in range(len(transactions))]
aborts = [0 for _ in range(len(transactions))]
Expand Down

0 comments on commit 3bf2524

Please sign in to comment.