forked from efficient/cicada-exp-sigmod2017-DBx1000
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathconfig-std.h
310 lines (278 loc) · 9.11 KB
/
config-std.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
#ifndef _CONFIG_H_
#define _CONFIG_H_
/***********************************************/
// Simulation + Hardware
/***********************************************/
#define THREAD_CNT 1
#define IO_CNT 1
#define SCHEDULER_CNT 1
#define WORKER_CNT 1
#define PART_CNT 1
// each transaction only accesses 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 1
#define PAGE_SIZE 4096
#define CL_SIZE 64
// # of transactions to run for warmup
#define WARMUP 0
// YCSB or TPCC or TATP
#define WORKLOAD YCSB
// print the transaction latency distribution
#define PRT_LAT_DISTR false
#define STATS_ENABLE true
#define TIME_ENABLE false
#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
// [RCU_ALLOC]
#define RCU_ALLOC false
#define RCU_ALLOC_SIZE (20 * 1073741824UL) // 20 GB
// MICA Page pool size (in GiB)
#define MICA_PAGE_POOL_SIZE 32
// MICA Scheduler pool size (in GiB)
#define MICA_SCHED_POOL_SIZE 4
/***********************************************/
// Concurrency Control
/***********************************************/
// WAIT_DIE, NO_WAIT, DL_DETECT, TIMESTAMP, MVCC, HEKATON, HSTORE, OCC, VLL, TICTOC, SILO
// TODO TIMESTAMP does not work at this moment
#define CC_ALG TICTOC
#define ISOLATION_LEVEL SERIALIZABLE
// 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 100000
#define ABORT_BUFFER_SIZE 10
#define ABORT_BUFFER_ENABLE true
// [ INDEX ]
#define ENABLE_LATCH false
#define CENTRAL_INDEX false
#define CENTRAL_MANAGER false
#define INDEX_STRUCT IDX_HASH
#define BTREE_ORDER 16
// [DL_DETECT]
#define DL_LOOP_DETECT 1000 // 100 us
#define DL_LOOP_TRIAL 100 // 1 us
#define NO_DL KEY_ORDER
#define TIMEOUT 1000000 // 1ms
// [TIMESTAMP]
#define TS_TWR false
#define TS_ALLOC TS_CAS
#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 1024
//#define MAX_READ_REQ 1024
#define MIN_TS_INTVL 5000000 //5 ms. In nanoseconds
// [OCC]
#define MAX_WRITE_SET 10
#define PER_ROW_VALID true
// [TICTOC]
#define WRITE_COPY_FORM "data" // ptr or data
#define TICTOC_MV false
#define WR_VALIDATION_SEPARATE true
#define WRITE_PERMISSION_LOCK false
#define ATOMIC_TIMESTAMP "false"
// [TICTOC, SILO]
#define VALIDATION_LOCK "no-wait" // no-wait or waiting
#define PRE_ABORT "true"
#define ATOMIC_WORD true
// [HSTORE]
// when set to true, hstore will not access the global timestamp.
// This is fine for single partition transactions.
#define HSTORE_LOCAL_TS false
// [VLL]
#define TXN_QUEUE_SIZE_LIMIT THREAD_CNT
/***********************************************/
// Logging
/***********************************************/
#define MICA_LOGGER MICA_LOG_NULL
#define MICA_LOG_INIT_DIR "/mnt/huge/cicada/log/init"
#define MICA_LOG_WARMUP_DIR "/mnt/huge/cicada/log/warmup"
#define MICA_LOG_WORKLOAD_DIR "/mnt/huge/cicada/log/workload"
#define MICA_RELAY_INIT_DIR "/mnt/huge/cicada/relay/init"
#define MICA_RELAY_WARMUP_DIR "/mnt/huge/cicada/relay/warmup"
#define MICA_RELAY_WORKLOAD_DIR "/mnt/huge/cicada/relay/workload"
#define MICA_REPL_ENABLED false
#define MICA_CCC MICA_CCC_NONE
#define MICA_REPL_USE_UPSERT false
#define MICA_REPL_UPSERT_ASSUME_NEW false
// LOG_BATCH_TIME doesn't seem to do anything
#define LOG_BATCH_TIME 10 // in ms
/***********************************************/
// Benchmark
/***********************************************/
// max number of rows touched per transaction
#define MAX_ROW_PER_TXN 1024
#define QUERY_INTVL 1UL
#define MAX_TXN_PER_PART 100
#define MAX_WARMUP_DURATION 10.0
#define MAX_TXN_DURATION 30.0
#define FIRST_PART_LOCAL true
#define MAX_TUPLE_SIZE 1024 // in bytes
// ==== [YCSB] ====
#define INIT_PARALLELISM 40
#define SYNTH_TABLE_SIZE (1024 * 40)
#define ZIPF_THETA 0.6
#define READ_PERC 0.9
#define WRITE_PERC 0.1
#define SCAN_PERC 0
#define SCAN_LEN 20
#define PART_PER_TXN 1
#define PERC_MULTI_PART 1
#define REQ_PER_QUERY 16
#define FIELD_PER_TUPLE 1
// ==== [TPCC] ====
// For large warehouse count, the tables do not fit in memory
// small tpcc schemas shrink the table size.
#define TPCC_SMALL false
// 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 1
//
#define TPCC_INSERT_ROWS false
#define TPCC_DELETE_ROWS false
#define TPCC_INSERT_INDEX false
#define TPCC_DELETE_INDEX false
// TPCC_FULL requires TPCC_INSERT_ROWS and TPCC_UPDATE_INDEX to fully function
#define TPCC_FULL false
#define TPCC_CF false
#define TPCC_SPLIT_DELIVERY false
#define TPCC_VALIDATE_GAP false
#define TPCC_VALIDATE_NODE true
#define SIMPLE_INDEX_UPDATE false
//
enum TPCCTxnType {TPCC_ALL,
TPCC_PAYMENT,
TPCC_NEW_ORDER,
TPCC_ORDER_STATUS,
TPCC_DELIVERY,
TPCC_STOCK_LEVEL};
extern TPCCTxnType g_tpcc_txn_type;
//#define TXN_TYPE TPCC_ALL
#define PERC_PAYMENT 0.5
#define FIRSTNAME_MINLEN 8
#define FIRSTNAME_LEN 16
#define LASTNAME_LEN 16
#define DIST_PER_WARE 10
// ==== [TATP] ====
#define TATP_DEFAULT_NUM_SUBSCRIBERS 100000
#define TATP_SUB_NBR_PADDING_SIZE 15
#define TATP_FREQUENCY_DELETE_CALL_FORWARDING 2
#define TATP_FREQUENCY_GET_ACCESS_DATA 35
#define TATP_FREQUENCY_GET_NEW_DESTINATION 10
#define TATP_FREQUENCY_GET_SUBSCRIBER_DATA 35
#define TATP_FREQUENCY_INSERT_CALL_FORWARDING 2
#define TATP_FREQUENCY_UPDATE_LOCATION 14
#define TATP_FREQUENCY_UPDATE_SUBSCRIBER_DATA 2
#define TATP_SCALE_FACTOR 1
#define TATP_SUB_SIZE (TATP_DEFAULT_NUM_SUBSCRIBERS * TATP_SCALE_FACTOR)
// ==== [INSERT] ====
#define INSERT_INSERTS_PER_TXN 1
// ==== [UPDATE] ====
#define UPDATE_UPDATES_PER_TXN 1
// ==== [ADVERSARIAL] ====
#define ADVERSARIAL_INSERTS_PER_TXN 1
/***********************************************/
// TODO centralized CC management.
/***********************************************/
#define MAX_LOCK_CNT (20 * THREAD_CNT)
#define TSTAB_SIZE 50 * THREAD_CNT
#define TSTAB_FREE TSTAB_SIZE
#define TSREQ_FREE 4 * TSTAB_FREE
#define MVHIS_FREE 4 * TSTAB_FREE
#define SPIN false
/***********************************************/
// Test cases
/***********************************************/
#define TEST_ALL true
enum TestCases {
READ_WRITE,
CONFLICT
};
extern TestCases g_test_case;
/***********************************************/
// 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_CC false //true
/***********************************************/
// Constant
/***********************************************/
// INDEX_STRUCT
#define IDX_HASH 1
#define IDX_BTREE 2
#define IDX_MICA 3
// WORKLOAD
#define YCSB 1
#define TPCC 2
#define TATP 3
#define TEST 4
#define INSERT 5
#define UPDATE 6
#define ADVERSARIAL 7
// 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 OCC 7
#define TICTOC 8
#define SILO 9
#define VLL 10
#define HEKATON 11
#define MICA 12
//Isolation Levels
#define SERIALIZABLE 1
#define SNAPSHOT 2
#define REPEATABLE_READ 3
// MICA Loggers
#define MICA_LOG_NULL 1
#define MICA_LOG_MMAP 2
// MICA CCC
#define MICA_CCC_NONE 1
#define MICA_CCC_COPYCAT 2
#define MICA_CCC_KUAFU 3
// TIMESTAMP allocation method.
#define TS_MUTEX 1
#define TS_CAS 2
#define TS_HW 3
#define TS_CLOCK 4
#define MICA_FULLINDEX false
#define MICA_NO_TSC false
#define MICA_NO_PRE_VALIDATION false
#define MICA_NO_INSERT_NEWEST_VERSION_ONLY false
#define MICA_NO_SORT_WRITE_SET_BY_CONTENTION false
#define MICA_NO_STRAGGLER_AVOIDANCE false
#define MICA_NO_WAIT_FOR_PENDING false
#define MICA_NO_INLINING false
#define MICA_NO_BACKOFF false
#define MICA_USE_FIXED_BACKOFF false
#define MICA_FIXED_BACKOFF 0.
#define MICA_USE_SLOW_GC false
#define MICA_SLOW_GC 10
#define PRINT_LAT_DIST true
#endif