From f08192937d73e8660e5297d5c35275cbc0299fcc Mon Sep 17 00:00:00 2001 From: wuxt Date: Fri, 11 Jul 2025 17:39:58 +0800 Subject: [PATCH 1/2] Initial commit from Han --- han.ini | 0 1 file changed, 0 insertions(+), 0 deletions(-) create mode 100644 han.ini diff --git a/han.ini b/han.ini new file mode 100644 index 00000000..e69de29b From d4b3271011a5abdc443603711bbc89731e96ea50 Mon Sep 17 00:00:00 2001 From: wuxt Date: Fri, 11 Jul 2025 18:26:56 +0800 Subject: [PATCH 2/2] EXEC Interval Control From Han --- contrib/deneva/concurrency_control/occ.cpp | 8 ++++++++ contrib/deneva/config.h | 3 +++ 2 files changed, 11 insertions(+) diff --git a/contrib/deneva/concurrency_control/occ.cpp b/contrib/deneva/concurrency_control/occ.cpp index 9e35b332..9158fe59 100644 --- a/contrib/deneva/concurrency_control/occ.cpp +++ b/contrib/deneva/concurrency_control/occ.cpp @@ -22,6 +22,9 @@ #include "mem_alloc.h" #include "row_occ.h" #include "txn.h" +#include "unistd.h" + +#define QUERY_EXECUTION_INTERVAL 100 set_ent::set_ent() { set_size = 0; @@ -48,6 +51,9 @@ RC OptCC::validate(TxnManager * txn) { rc = central_validate(txn); #endif INC_STATS(txn->get_thd_id(),occ_validate_time,get_sys_clock() - starttime); + + // Add to history + usleep(QUERY_EXECUTION_INTERVAL * 1000); // ms->us return rc; } @@ -57,6 +63,8 @@ void OptCC::finish(RC rc, TxnManager * txn) { #else central_finish(rc,txn); #endif + //Add to history + usleep(QUERY_EXECUTION_INTERVAL * 1000); // ms->us } RC OptCC::per_row_validate(TxnManager *txn) { diff --git a/contrib/deneva/config.h b/contrib/deneva/config.h index e94fd130..ef459b7b 100644 --- a/contrib/deneva/config.h +++ b/contrib/deneva/config.h @@ -38,6 +38,9 @@ #define SAVE_HISTROY_WITH_EMPTY_OPT false #define DYNAMIC_SEQ_LEN false +//Execution Interval /TXN +#define QUERY_EXECUTION_INTERVAL 100 //ms + //InputActionSequenceCreator #define INPUT_FILE_PATH "./input.txt"