From 3bf2524de6f36c8a848f4f368b4fc5fcd9f6aac5 Mon Sep 17 00:00:00 2001 From: wuziniu Date: Thu, 21 Mar 2024 17:03:58 -0400 Subject: [PATCH] adding brad runner with variable txn clients (run_transactions_variable_clients.py) --- workloads/IMDB_extended/run_transactions_variable_clients.py | 4 ---- workloads/IMDB_extended/run_variable_clients.py | 1 - 2 files changed, 5 deletions(-) diff --git a/workloads/IMDB_extended/run_transactions_variable_clients.py b/workloads/IMDB_extended/run_transactions_variable_clients.py index 5f4a3fda..abadcee5 100644 --- a/workloads/IMDB_extended/run_transactions_variable_clients.py +++ b/workloads/IMDB_extended/run_transactions_variable_clients.py @@ -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 @@ -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))] @@ -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" @@ -600,7 +597,6 @@ def main(): args=( args, idx, - directory, start_queue[idx], control_semaphore[idx], pause_semaphore[idx], diff --git a/workloads/IMDB_extended/run_variable_clients.py b/workloads/IMDB_extended/run_variable_clients.py index d1497127..c3f05491 100644 --- a/workloads/IMDB_extended/run_variable_clients.py +++ b/workloads/IMDB_extended/run_variable_clients.py @@ -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))]