config.h

#ifndef _CONFIG_H_

#define _CONFIG_H_

/***tictoc****/
/*
#define WRITE_PERMISSION_LOCK         false
#define MULTI_VERSION                 false
#define ENABLE_LOCAL_CACHING          false
#define OCC_LOCK_TYPE                 WAIT_DIE
#define TICTOC_MV                     false
#define OCC_WAW_LOCK                  true
#define RO_LEASE                      false
#define ATOMIC_WORD                   false
#define TRACK_LAST                    false
#define UPDATE_TABLE_TS               true
#define WRITE_PERMISSION_LOCK         false
#define LOCK_ALL_BEFORE_COMMIT        false
#define LOCK_ALL_DEBUG                false
#define PAUSE __asm__ ( "pause;" );
#define COMPILER_BARRIER asm volatile("" ::: "memory");
*/

#define SIT_TCP         0
#define SIT_TWO_SIDE    1
#define SIT_ONE_SIDE    2
#define SIT_COROUTINE   3
#define SIT_DBPA        4
#define SIT_ALL         5
#define RDMA_SIT SIT_COROUTINE
#if RDMA_SIT == SIT_TCP
  #define RDMA_ONE_SIDE false
  #define RDMA_TWO_SIDE false
  #define USE_COROUTINE false
  #define USE_DBPAOR false
#define SERVER_GENERATE_QUERIES false
#elif RDMA_SIT == SIT_TWO_SIDE
  #define RDMA_ONE_SIDE false
  #define RDMA_TWO_SIDE true
  #define USE_COROUTINE false
  #define USE_DBPAOR false
#define SERVER_GENERATE_QUERIES false
#elif RDMA_SIT == SIT_ONE_SIDE
  #define RDMA_ONE_SIDE true
  #define RDMA_TWO_SIDE true
  #define USE_COROUTINE false
  #define USE_DBPAOR false
  #if CC_ALG == RDMA_CALVIN
    #define SERVER_GENERATE_QUERIES false
  #else
    #define SERVER_GENERATE_QUERIES true
  #endif
#elif RDMA_SIT == SIT_COROUTINE// || CC_ALG == RDMA_WOUND_WAIT
  #define RDMA_ONE_SIDE true
  #define RDMA_TWO_SIDE true
  #define USE_COROUTINE true
  #define USE_DBPAOR false
#define SERVER_GENERATE_QUERIES true
#elif RDMA_SIT == SIT_DBPA
  #define RDMA_ONE_SIDE true
  #define RDMA_TWO_SIDE true
  #define USE_COROUTINE false
  #define USE_DBPAOR true
#define SERVER_GENERATE_QUERIES true
#elif RDMA_SIT == SIT_ALL
  #define RDMA_ONE_SIDE true
  #define RDMA_TWO_SIDE true
  #define USE_COROUTINE true
  #define USE_DBPAOR true
#define SERVER_GENERATE_QUERIES true
#endif
/************RDMA TYPE**************/
#define CHANGE_TCP_ONLY 0
#define CHANGE_MSG_QUEUE 1

#define HIS_CHAIN_NUM 4
#define USE_CAS
#define MAX_SEND_SIZE 1

/***********************************************/
// DA Trans Creator
/***********************************************/
//which creator to use
#define CREATOR_USE_T false

//TraversalActionSequenceCreator
#define TRANS_CNT 2
#define ITEM_CNT 4
#define SUBTASK_NUM 1
#define SUBTASK_ID 0
#define MAX_DML 4
#define WITH_ABORT false
#define TAIL_DTL false
#define SAVE_HISTROY_WITH_EMPTY_OPT false
#define DYNAMIC_SEQ_LEN false
#define ONLY_ONE_HOME false
#define NO_PHYSICAL false
//InputActionSequenceCreator
#define INPUT_FILE_PATH "./input.txt"

// ! Parameters used to locate distributed performance bottlenecks.

#define SECOND 200 // Set the queue monitoring time.
// #define THD_ID_QUEUE
#define ONE_NODE_RECIEVE 0 // only node 0 will receive the txn query
#define USE_WORK_NUM_THREAD false
#if 1
// #define LESS_DIS // Reduce the number of yCSB remote data to 1
// #define LESS_DIS_NUM 0 // Reduce the number of yCSB remote data to 1
// #define NEW_WORK_QUEUE  // The workQueue data structure has been modified to perform 10,000 better than the original implementation.
// #define NO_2PC  // Removing 2PC, of course, would be problematic in distributed transactions.
// #define FAKE_PROCESS  // Io_thread returns as soon as it gets the request from the remote. Avoid waiting in the WORK_queue.
// #define NO_REMOTE // remove all remote txn
#endif 
#define TXN_QUEUE_PERCENT 0.0 // The proportion of the transaction to take from txn_queue firstly.
#define MALLOC_TYPE 0 // 0 represent normal malloc. 1 represent je-malloc
// ! end of these parameters
// ! Parameters used to locate distributed performance bottlenecks.
#define SEND_TO_SELF_PAHSE 0 // 0 means do not send to self, 1 will execute the phase1, 2 will execute phase2, 3 will exeute phase1 and phase 2
// msg send can be split into three stage, stage1 encapsulates msg; stage2 send msg; stgae3 parse msg;
#define SEND_STAGE 1 // 1 will execute the stage1, 2 will execute stage1 and 3, 3 will exeute all
// ! end of these parameters
/***********************************************/
// Simulation + Hardware
/***********************************************/
#define NODE_CNT 4
#define THREAD_CNT 24
#define REM_THREAD_CNT 1
#define SEND_THREAD_CNT 1
#define COROUTINE_CNT 8
#define CORE_CNT 2
// PART_CNT should be at least NODE_CNT
#define PART_CNT NODE_CNT
#define CLIENT_NODE_CNT 1
#define CLIENT_THREAD_CNT 4
#define CLIENT_REM_THREAD_CNT 1
#define CLIENT_SEND_THREAD_CNT 1
#define CLIENT_RUNTIME false

#define LOAD_METHOD LOAD_MAX
#define LOAD_PER_SERVER 100

// Replication
#define REPLICA_CNT 0
// AA (Active-Active), AP (Active-Passive)
#define REPL_TYPE AP

// each transaction only accesses only 1 virtual partition. But the lock/ts manager and index are
// not aware of such partitioning. VIRTUAL_PART_CNT describes the request distribution and is only
// used to generate queries. For HSTORE, VIRTUAL_PART_CNT should be the same as PART_CNT.
#define VIRTUAL_PART_CNT    PART_CNT
#define PAGE_SIZE         4096
#define CL_SIZE           64
#define CPU_FREQ          2.6
// enable hardware migration.
#define HW_MIGRATE          false

// # of transactions to run for warmup
#define WARMUP            0
// YCSB or TPCC or PPS or DA
#define WORKLOAD YCSB
// print the transaction latency distribution
#define PRT_LAT_DISTR false
#define STATS_ENABLE        true
#define TIME_ENABLE         true //STATS_ENABLE

#define FIN_BY_TIME true
#define MAX_TXN_IN_FLIGHT 10000

/***********************************************/
// Memory System
/***********************************************/
// Three different memory allocation methods are supported.
// 1. default libc malloc
// 2. per-thread malloc. each thread has a private local memory
//    pool
// 3. per-partition malloc. each partition has its own memory pool
//    which is mapped to a unique tile on the chip.
#define MEM_ALLIGN          8

// [THREAD_ALLOC]
#define THREAD_ALLOC        false
#define THREAD_ARENA_SIZE     (1UL << 22)
#define MEM_PAD           true

// [PART_ALLOC]
#define PART_ALLOC          false
#define MEM_SIZE          (1UL << 30)
#define NO_FREE           false

/***********************************************/
// Message Passing
/***********************************************/
#define TPORT_TYPE tcp
#define TPORT_PORT 7100
#define TPORT_TWOSIDE_PORT 7300
#define RDMA_TPORT 7200
#define SET_AFFINITY true

#define MAX_TPORT_NAME 128
#define MSG_SIZE 128 // in bytes
#define HEADER_SIZE sizeof(uint32_t)*2 // in bits
#define MSG_TIMEOUT 5000000000UL // in ns
#define NETWORK_TEST false
#define NETWORK_DELAY_TEST false
#define NETWORK_DELAY 0UL

#define MAX_QUEUE_LEN NODE_CNT * 2

#define PRIORITY_WORK_QUEUE false
#define PRIORITY PRIORITY_ACTIVE
#define MSG_SIZE_MAX 4096
#define MSG_TIME_LIMIT 0

/***********************************************/
// Concurrency Control
/***********************************************/

// WAIT_DIE, NO_WAIT, DL_DETECT, TIMESTAMP, MVCC, HSTORE, OCC, VLL, RDMA_SILO, RDMA_NO_WAIT, RDMA_NO_WAIT2, RDMA_WAIT_DIE2,RDMA_TS1,RDMA_SILO,RDMA_MVCC,RDMA_MAAT,RDMA_CICADA
//RDMA_NO_WAIT2, RDMA_WAIT_DIE2:no matter read or write, mutex lock is used 
#define ISOLATION_LEVEL SERIALIZABLE

#define CC_ALG RDMA_MOCC

#define YCSB_ABORT_MODE false
#define QUEUE_C  APACITY_NEW 1000000

#define DEBUG_PRINTF  false

#if RDMA_ONE_SIDE 
#define BATCH_INDEX_AND_READ false //keep this "false", a fail test for SILO
#endif

/***********************************************/
// USE RDMA
/**********************************************/
#if (CC_ALG == RDMA_MAAT || CC_ALG == RDMA_SILO || CC_ALG == RDMA_MVCC || CC_ALG == RDMA_NO_WAIT || CC_ALG == RDMA_NO_WAIT2 || CC_ALG == RDMA_WAIT_DIE2 || CC_ALG == RDMA_TS1 || CC_ALG == RDMA_WOUND_WAIT2 || CC_ALG == RDMA_CICADA || CC_ALG == RDMA_CNULL || CC_ALG == RDMA_WOUND_WAIT || CC_ALG == RDMA_WAIT_DIE || CC_ALG == RDMA_MOCC || RDMA_TWO_SIDE == true) && RDMA_SIT != 0
// #define USE_RDMA CHANGE_MSG_QUEUE
#define USE_RDMA CHANGE_TCP_ONLY
#endif
#define RDMA_BUFFER_SIZE (1<<26)
#define RDMA_CYC_QP_NUM (1<<10)
#define RDMA_LOCAL_BUFFER_SIZE (10240)
#define RDMA_BUFFER_ITEM_SIZE (1<<12)
#define RDMA_USE_NIC_IDX 0
#define RDMA_REG_MEM_NAME 73
#define RDMA_CQ_NAME "rdma_channel"
#define RDMA_ENTRY_NUM 6000U
#define RDMA_SEND_COUNT (2048)

#if USE_WORK_NUM_THREAD
  #define WORK_THREAD_NUM 1
#else
  #define WORK_THREAD_NUM 0
#endif
#if LOGGING
  #define LOG_THREAD_NUM 1
#else
  #define LOG_THREAD_NUM 0
#endif
#if CC_ALG == CALVIN || CC_ALG == RDMA_CALVIN
  #define CALVIN_THREAD_NUM 2
#else
  #define CALVIN_THREAD_NUM 0
#endif
#define RDMA_MAX_CLIENT_QP (THREAD_CNT + REM_THREAD_CNT + SEND_THREAD_CNT + 1 + LOG_THREAD_NUM + WORK_THREAD_NUM + CALVIN_THREAD_NUM)
// #define RDMA_SEND_COUNT (RDMA_BUFFER_SIZE / 4096)
// #define RDMA_COLOR_LOG

// all transactions acquire tuples according to the primary key order.
#define KEY_ORDER         false
// transaction roll back changes after abort
#define ROLL_BACK         true
// per-row lock/ts management or central lock/ts management
#define CENTRAL_MAN         false
#define BUCKET_CNT          31
#define ABORT_PENALTY 10 * 1000000UL   // in ns.
#define ABORT_PENALTY_MAX 5 * 100 * 1000000UL   // in ns.
#define BACKOFF true
// [ INDEX ]
#define ENABLE_LATCH        false
#define CENTRAL_INDEX       false
#define CENTRAL_MANAGER       false
//#ifdef USE_RDMA
#if RDMA_ONE_SIDE == true
#define INDEX_STRUCT        IDX_RDMA
#else
#define INDEX_STRUCT        IDX_HASH
#endif
#define BTREE_ORDER         16

// [TIMESTAMP]
#define TS_TWR            false
#define TS_ALLOC          TS_CLOCK
#define TS_BATCH_ALLOC        false
#define TS_BATCH_NUM        1
// [MVCC]
// when read/write history is longer than HIS_RECYCLE_LEN
// the history should be recycled.
#define HIS_RECYCLE_LEN       10
#define MAX_PRE_REQ         MAX_TXN_IN_FLIGHT * NODE_CNT//1024
#define MAX_READ_REQ        MAX_TXN_IN_FLIGHT * NODE_CNT//1024
#define MIN_TS_INTVL        10 * 1000000UL // 10ms
// [OCC]
#define MAX_WRITE_SET       10
#define PER_ROW_VALID       false
// [VLL]
#define TXN_QUEUE_SIZE_LIMIT    THREAD_CNT
// [CALVIN]
#define SEQ_THREAD_CNT 4
// [TICTOC]
#define MAX_NUM_WAITS 4
#define PRE_ABORT true
#define OCC_LOCK_TYPE WAIT_DIE
#define OCC_WAW_LOCK true
// [SILO]
#define VALIDATION_LOCK				"no-wait" // no-wait or waiting
#define PRE_ABORT2					"true"
#define ATOMIC_WORD					false
// [RDMA_RETRY]
#define MAX_RETRY_COUNT 1
// [RDMA_MAAT]
#define RDMA_TXNTABLE_MAX (COROUTINE_CNT + 1) * THREAD_CNT
#define COMMIT_ADJUST false
#define MAAT_NODES_COUNT 2
// [RDMA_TS1]
#define RDMA_TSSTATE_COUNT 5
// [RDMA_TS1]
#define USE_READ_WAIT_QUEUE false
#define YIELD_WHEN_WAITING_READ false
#define TS_RETRY_COUNT int(ZIPF_THETA * 20 + 1)
#define CASCADING_LENGTH 10
// #define ROW_SET_LENGTH 100
#define MAX_RETRY_TIME 2
#define LOCK_LENGTH 10
// [RDMA_DSLR]
#define DSLR_MAX_RETRY_TIME 50
// [RDMA_CICADA]
#define CICADA_MAX_RETRY_TIME 50
/***********************************************/
// Logging
/***********************************************/
#define LOG_COMMAND         false
#define LOG_REDO          false
#define LOGGING false
#define LOG_BUF_MAX 10
#define LOG_BUF_TIMEOUT 10 * 1000000UL // 10ms

/***********************************************/
// Benchmark
/***********************************************/
// max number of rows touched per transaction
#define MAX_ROW_PER_TXN       64
#define QUERY_INTVL         1UL
#define MAX_TXN_PER_PART 10000
#define FIRST_PART_LOCAL      true
#define MAX_TUPLE_SIZE        1024 // in bytes
#define GEN_BY_MPR false
// ==== [YCSB] ====
// SKEW_METHOD:
//    ZIPF: use ZIPF_THETA distribution
//    HOT: use ACCESS_PERC of the accesses go to DATA_PERC of the data
#define SKEW_METHOD ZIPF
#define DATA_PERC 100
#define ACCESS_PERC 0.03
#define INIT_PARALLELISM 1
#define SYNTH_TABLE_SIZE 41943040
#define ZIPF_THETA 0.95
#define TXN_WRITE_PERC 1
#define TUP_WRITE_PERC 0.2
#define SCAN_PERC           0
#define SCAN_LEN          20
#define PART_PER_TXN 2
#define PERC_MULTI_PART     MPR
#define REQ_PER_QUERY 10
#define FIELD_PER_TUPLE       10
#define CREATE_TXN_FILE false
#define STRICT_PPT 1
// ==== [TPCC] ====
// For large warehouse count, the tables do not fit in memory
// small tpcc schemas shrink the table size.
#define TPCC_SMALL          false
#define MAX_ITEMS_SMALL 10000
#define CUST_PER_DIST_SMALL 2000
#define MAX_ITEMS_NORM 100000
#define CUST_PER_DIST_NORM 3000
#define MAX_ITEMS_PER_TXN 15
// Some of the transactions read the data but never use them.
// If TPCC_ACCESS_ALL == fales, then these parts of the transactions
// are not modeled.
#define TPCC_ACCESS_ALL       false
#define WH_UPDATE         true
#define NUM_WH 32
#define TPCC_INDEX_NUM 700 000 
// % of transactions that access multiple partitions
#define MPR 1.0
#define MPIR 0.01
#define MPR_NEWORDER      20 // In %
enum TPCCTable {
  TPCC_WAREHOUSE,
          TPCC_DISTRICT,
          TPCC_CUSTOMER,
          TPCC_HISTORY,
          TPCC_NEWORDER,
          TPCC_ORDER,
          TPCC_ORDERLINE,
          TPCC_ITEM,
  TPCC_STOCK
};
enum TPCCTxnType {
  TPCC_ALL,
          TPCC_PAYMENT,
          TPCC_NEW_ORDER,
          TPCC_ORDER_STATUS,
          TPCC_DELIVERY,
  TPCC_STOCK_LEVEL
};
enum DATxnType {
  DA_READ,
  DA_WRITE,
  DA_COMMIT,
  DA_ABORT,
  DA_SCAN
};
#define MAX_DA_TABLE_SIZE 10000
extern TPCCTxnType g_tpcc_txn_type;
//#define TXN_TYPE          TPCC_ALL
#define PERC_PAYMENT 0.0
#define FIRSTNAME_MINLEN      8
#define FIRSTNAME_LEN         16
#define LASTNAME_LEN        16

#define DIST_PER_WH       10

// PPS (Product-Part-Supplier)
#define MAX_PPS_PARTS_PER 10
#define MAX_PPS_PART_KEY 10000
#define MAX_PPS_PRODUCT_KEY 1000
#define MAX_PPS_SUPPLIER_KEY 1000
#define MAX_PPS_PART_PER_PRODUCT 10
#define MAX_PPS_PART_PER_SUPPLIER 10
#define MAX_PPS_PART_PER_PRODUCT_KEY 10
#define MAX_PPS_PART_PER_SUPPLIER_KEY 10

#define PERC_PPS_GETPART 0.00
#define PERC_PPS_GETSUPPLIER 0.00
#define PERC_PPS_GETPRODUCT 0.0
#define PERC_PPS_GETPARTBYSUPPLIER 0.0
#define PERC_PPS_GETPARTBYPRODUCT 0.2
#define PERC_PPS_ORDERPRODUCT 0.6
#define PERC_PPS_UPDATEPRODUCTPART 0.2
#define PERC_PPS_UPDATEPART 0.0

enum PPSTxnType {
  PPS_ALL = 0,
          PPS_GETPART,
          PPS_GETSUPPLIER,
          PPS_GETPRODUCT,
          PPS_GETPARTBYSUPPLIER,
          PPS_GETPARTBYPRODUCT,
          PPS_ORDERPRODUCT,
          PPS_UPDATEPRODUCTPART,
          PPS_UPDATEPART
          };

// [RDMA_MAAT]
#if WORKLOAD == YCSB
#define ROW_SET_LENGTH int(ZIPF_THETA * 50 + 10)
#define WAIT_QUEUE_LENGTH int(ZIPF_THETA * 10 + 3)
#else
#define WAIT_QUEUE_LENGTH int(PERC_PAYMENT * PERC_PAYMENT * 100 + 3)
#define ROW_SET_LENGTH int(PERC_PAYMENT * 100 + 30)
#endif
 
#define HOT_VALUE 10000
#define MOCC_MAX_RETRY_COUNT 5
#define MAAT_CAS true
/***********************************************/
// DEBUG info
/***********************************************/
#define WL_VERB           true
#define IDX_VERB          false
#define VERB_ALLOC          true

#define DEBUG_LOCK          false
#define DEBUG_TIMESTAMP       false
#define DEBUG_SYNTH         false
#define DEBUG_ASSERT        false
#define DEBUG_DISTR false
#define DEBUG_ALLOC false
#define DEBUG_RACE false
#define DEBUG_TIMELINE        false
#define DEBUG_BREAKDOWN       false
#define DEBUG_LATENCY       false

/***********************************************/
// MODES
/***********************************************/
// QRY Only do query operations, no 2PC
// TWOPC Only do 2PC, no query work
// SIMPLE Immediately send OK back to client
// NOCC Don't do CC
// NORMAL normal operation
#define MODE NORMAL_MODE


/***********************************************/
// Constant
/***********************************************/

// INDEX_STRUCT
#define IDX_HASH          1
#define IDX_BTREE         2
#define IDX_RDMA          3
// WORKLOAD
#define YCSB            1
#define TPCC            2
#define PPS             3
#define TEST            4
#define DA 5
// Concurrency Control Algorithm
#define NO_WAIT           1
#define WAIT_DIE          2
#define DL_DETECT         3
#define TIMESTAMP         4
#define MVCC            5
#define HSTORE            6
#define HSTORE_SPEC           7
#define OCC             8
#define VLL             9
#define CALVIN      10
#define MAAT      11
#define WDL           12
#define WOOKONG     13
#define TICTOC     14
#define FOCC       15
#define BOCC       16
#define SSI        17
#define WSI        18
#define DLI_BASE 19
#define DLI_OCC 20
#define DLI_MVCC_OCC 21
#define DTA 22
#define DLI_DTA 23
#define DLI_MVCC 24
#define DLI_DTA2 25
#define DLI_DTA3 26
#define SILO 27
#define CNULL 28
#define RDMA_SILO 29
#define RDMA_MVCC 30
#define RDMA_NO_WAIT 31
#define RDMA_NO_WAIT2 32
#define RDMA_WAIT_DIE2 33
#define RDMA_TS1 34
#define RDMA_MAAT 35
#define RDMA_CICADA 36
#define RDMA_CALVIN 38
#define RDMA_CNULL 37
#define RDMA_WOUND_WAIT2 39
#define CICADA  40
#define WOUND_WAIT 41
#define RDMA_WAIT_DIE 42
#define RDMA_WOUND_WAIT 43
#define RDMA_MOCC 44
#define RDMA_TS 46
#define RDMA_DSLR_NO_WAIT 45
// TIMESTAMP allocation method.
#define TS_MUTEX          1
#define TS_CAS            2
#define TS_HW           3
#define TS_CLOCK          4
#define LTS_CURL_CLOCK          5
#define LTS_TCP_CLOCK          6

#define LTS_TCP_IP  "10.77.110.148"
#define LTS_TCP_PORT  62389
// MODES
// NORMAL < NOCC < QRY_ONLY < SETUP < SIMPLE
#define NORMAL_MODE 1
#define NOCC_MODE 2
#define QRY_ONLY_MODE 3
#define SETUP_MODE 4
#define SIMPLE_MODE 5
// SKEW METHODS
#define ZIPF 1
#define HOT 2
// PRIORITY WORK QUEUE
#define PRIORITY_FCFS 1
#define PRIORITY_ACTIVE 2
#define PRIORITY_HOME 3
// Replication
#define AA 1
#define AP 2
// Load
#define LOAD_MAX 1
#define LOAD_RATE 2
// Transport
#define TCP 1
#define IPC 2
// Isolation levels
#define SERIALIZABLE 1
#define READ_COMMITTED 2
#define READ_UNCOMMITTED 3
#define NOLOCK 4

// Stats and timeout
#define BILLION 1000000000UL // in ns => 1 second
#define MILLION 1000000UL // in ns => 1 second
#define USECONDE 1000UL //us
#define STAT_ARR_SIZE 1024
#define PROG_TIMER 10 * BILLION // in s
#define BATCH_TIMER 0
#define SEQ_BATCH_TIMER 5 * 1 * MILLION // ~5ms -- same as CALVIN paper
#define DONE_TIMER 1 * 20 * BILLION // ~1 minutes
#define WARMUP_TIMER 1 * 10 * BILLION // ~1 minutes

#define SEED 0
#define SHMEM_ENV false
#define ENVIRONMENT_EC2 false

#endif