bench_runner.c 62 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920
  1. #ifndef _POSIX_C_SOURCE
  2. #define _POSIX_C_SOURCE 199309L
  3. #endif
  4. #include "runners/bench_runner.h"
  5. #include "bd/lfs_emubd.h"
  6. #include <getopt.h>
  7. #include <sys/types.h>
  8. #include <errno.h>
  9. #include <setjmp.h>
  10. #include <fcntl.h>
  11. #include <stdarg.h>
  12. #include <stdio.h>
  13. #include <unistd.h>
  14. // some helpers
  15. // append to an array with amortized doubling
  16. void *mappend(void **p,
  17. size_t size,
  18. size_t *count,
  19. size_t *capacity) {
  20. uint8_t *p_ = *p;
  21. size_t count_ = *count;
  22. size_t capacity_ = *capacity;
  23. count_ += 1;
  24. if (count_ > capacity_) {
  25. capacity_ = (2*capacity_ < 4) ? 4 : 2*capacity_;
  26. p_ = realloc(p_, capacity_*size);
  27. if (!p_) {
  28. return NULL;
  29. }
  30. }
  31. *p = p_;
  32. *count = count_;
  33. *capacity = capacity_;
  34. return &p_[(count_-1)*size];
  35. }
  36. // a quick self-terminating text-safe varint scheme
  37. static void leb16_print(uintmax_t x) {
  38. while (true) {
  39. char nibble = (x & 0xf) | (x > 0xf ? 0x10 : 0);
  40. printf("%c", (nibble < 10) ? '0'+nibble : 'a'+nibble-10);
  41. if (x <= 0xf) {
  42. break;
  43. }
  44. x >>= 4;
  45. }
  46. }
  47. static uintmax_t leb16_parse(const char *s, char **tail) {
  48. uintmax_t x = 0;
  49. size_t i = 0;
  50. while (true) {
  51. uintmax_t nibble = s[i];
  52. if (nibble >= '0' && nibble <= '9') {
  53. nibble = nibble - '0';
  54. } else if (nibble >= 'a' && nibble <= 'v') {
  55. nibble = nibble - 'a' + 10;
  56. } else {
  57. // invalid?
  58. if (tail) {
  59. *tail = (char*)s;
  60. }
  61. return 0;
  62. }
  63. x |= (nibble & 0xf) << (4*i);
  64. i += 1;
  65. if (!(nibble & 0x10)) {
  66. break;
  67. }
  68. }
  69. if (tail) {
  70. *tail = (char*)s + i;
  71. }
  72. return x;
  73. }
  74. // bench_runner types
  75. typedef struct bench_geometry {
  76. const char *name;
  77. bench_define_t defines[BENCH_GEOMETRY_DEFINE_COUNT];
  78. } bench_geometry_t;
  79. typedef struct bench_id {
  80. const char *name;
  81. const bench_define_t *defines;
  82. size_t define_count;
  83. } bench_id_t;
  84. // bench suites are linked into a custom ld section
  85. extern struct bench_suite __start__bench_suites;
  86. extern struct bench_suite __stop__bench_suites;
  87. const struct bench_suite *bench_suites = &__start__bench_suites;
  88. #define BENCH_SUITE_COUNT \
  89. ((size_t)(&__stop__bench_suites - &__start__bench_suites))
  90. // bench define management
  91. typedef struct bench_define_map {
  92. const bench_define_t *defines;
  93. size_t count;
  94. } bench_define_map_t;
  95. typedef struct bench_define_names {
  96. const char *const *names;
  97. size_t count;
  98. } bench_define_names_t;
  99. intmax_t bench_define_lit(void *data) {
  100. return (intmax_t)data;
  101. }
  102. #define BENCH_CONST(x) {bench_define_lit, (void*)(uintptr_t)(x)}
  103. #define BENCH_LIT(x) ((bench_define_t)BENCH_CONST(x))
  104. #define BENCH_DEF(k, v) \
  105. intmax_t bench_define_##k(void *data) { \
  106. (void)data; \
  107. return v; \
  108. }
  109. BENCH_IMPLICIT_DEFINES
  110. #undef BENCH_DEF
  111. #define BENCH_DEFINE_MAP_EXPLICIT 0
  112. #define BENCH_DEFINE_MAP_OVERRIDE 1
  113. #define BENCH_DEFINE_MAP_PERMUTATION 2
  114. #define BENCH_DEFINE_MAP_GEOMETRY 3
  115. #define BENCH_DEFINE_MAP_IMPLICIT 4
  116. #define BENCH_DEFINE_MAP_COUNT 5
  117. bench_define_map_t bench_define_maps[BENCH_DEFINE_MAP_COUNT] = {
  118. [BENCH_DEFINE_MAP_IMPLICIT] = {
  119. (const bench_define_t[BENCH_IMPLICIT_DEFINE_COUNT]) {
  120. #define BENCH_DEF(k, v) \
  121. [k##_i] = {bench_define_##k, NULL},
  122. BENCH_IMPLICIT_DEFINES
  123. #undef BENCH_DEF
  124. },
  125. BENCH_IMPLICIT_DEFINE_COUNT,
  126. },
  127. };
  128. #define BENCH_DEFINE_NAMES_SUITE 0
  129. #define BENCH_DEFINE_NAMES_IMPLICIT 1
  130. #define BENCH_DEFINE_NAMES_COUNT 2
  131. bench_define_names_t bench_define_names[BENCH_DEFINE_NAMES_COUNT] = {
  132. [BENCH_DEFINE_NAMES_IMPLICIT] = {
  133. (const char *const[BENCH_IMPLICIT_DEFINE_COUNT]){
  134. #define BENCH_DEF(k, v) \
  135. [k##_i] = #k,
  136. BENCH_IMPLICIT_DEFINES
  137. #undef BENCH_DEF
  138. },
  139. BENCH_IMPLICIT_DEFINE_COUNT,
  140. },
  141. };
  142. intmax_t *bench_define_cache;
  143. size_t bench_define_cache_count;
  144. unsigned *bench_define_cache_mask;
  145. const char *bench_define_name(size_t define) {
  146. // lookup in our bench names
  147. for (size_t i = 0; i < BENCH_DEFINE_NAMES_COUNT; i++) {
  148. if (define < bench_define_names[i].count
  149. && bench_define_names[i].names
  150. && bench_define_names[i].names[define]) {
  151. return bench_define_names[i].names[define];
  152. }
  153. }
  154. return NULL;
  155. }
  156. bool bench_define_ispermutation(size_t define) {
  157. // is this define specific to the permutation?
  158. for (size_t i = 0; i < BENCH_DEFINE_MAP_IMPLICIT; i++) {
  159. if (define < bench_define_maps[i].count
  160. && bench_define_maps[i].defines[define].cb) {
  161. return true;
  162. }
  163. }
  164. return false;
  165. }
  166. intmax_t bench_define(size_t define) {
  167. // is the define in our cache?
  168. if (define < bench_define_cache_count
  169. && (bench_define_cache_mask[define/(8*sizeof(unsigned))]
  170. & (1 << (define%(8*sizeof(unsigned)))))) {
  171. return bench_define_cache[define];
  172. }
  173. // lookup in our bench defines
  174. for (size_t i = 0; i < BENCH_DEFINE_MAP_COUNT; i++) {
  175. if (define < bench_define_maps[i].count
  176. && bench_define_maps[i].defines[define].cb) {
  177. intmax_t v = bench_define_maps[i].defines[define].cb(
  178. bench_define_maps[i].defines[define].data);
  179. // insert into cache!
  180. bench_define_cache[define] = v;
  181. bench_define_cache_mask[define / (8*sizeof(unsigned))]
  182. |= 1 << (define%(8*sizeof(unsigned)));
  183. return v;
  184. }
  185. }
  186. return 0;
  187. // not found?
  188. const char *name = bench_define_name(define);
  189. fprintf(stderr, "error: undefined define %s (%zd)\n",
  190. name ? name : "(unknown)",
  191. define);
  192. assert(false);
  193. exit(-1);
  194. }
  195. void bench_define_flush(void) {
  196. // clear cache between permutations
  197. memset(bench_define_cache_mask, 0,
  198. sizeof(unsigned)*(
  199. (bench_define_cache_count+(8*sizeof(unsigned))-1)
  200. / (8*sizeof(unsigned))));
  201. }
  202. // geometry updates
  203. const bench_geometry_t *bench_geometry = NULL;
  204. void bench_define_geometry(const bench_geometry_t *geometry) {
  205. bench_define_maps[BENCH_DEFINE_MAP_GEOMETRY] = (bench_define_map_t){
  206. geometry->defines, BENCH_GEOMETRY_DEFINE_COUNT};
  207. }
  208. // override updates
  209. typedef struct bench_override {
  210. const char *name;
  211. const intmax_t *defines;
  212. size_t permutations;
  213. } bench_override_t;
  214. const bench_override_t *bench_overrides = NULL;
  215. size_t bench_override_count = 0;
  216. bench_define_t *bench_override_defines = NULL;
  217. size_t bench_override_define_count = 0;
  218. size_t bench_override_define_permutations = 1;
  219. size_t bench_override_define_capacity = 0;
  220. // suite/perm updates
  221. void bench_define_suite(const struct bench_suite *suite) {
  222. bench_define_names[BENCH_DEFINE_NAMES_SUITE] = (bench_define_names_t){
  223. suite->define_names, suite->define_count};
  224. // make sure our cache is large enough
  225. if (lfs_max(suite->define_count, BENCH_IMPLICIT_DEFINE_COUNT)
  226. > bench_define_cache_count) {
  227. // align to power of two to avoid any superlinear growth
  228. size_t ncount = 1 << lfs_npw2(
  229. lfs_max(suite->define_count, BENCH_IMPLICIT_DEFINE_COUNT));
  230. bench_define_cache = realloc(bench_define_cache, ncount*sizeof(intmax_t));
  231. bench_define_cache_mask = realloc(bench_define_cache_mask,
  232. sizeof(unsigned)*(
  233. (ncount+(8*sizeof(unsigned))-1)
  234. / (8*sizeof(unsigned))));
  235. bench_define_cache_count = ncount;
  236. }
  237. // map any overrides
  238. if (bench_override_count > 0) {
  239. // first figure out the total size of override permutations
  240. size_t count = 0;
  241. size_t permutations = 1;
  242. for (size_t i = 0; i < bench_override_count; i++) {
  243. for (size_t d = 0;
  244. d < lfs_max(
  245. suite->define_count,
  246. BENCH_IMPLICIT_DEFINE_COUNT);
  247. d++) {
  248. // define name match?
  249. const char *name = bench_define_name(d);
  250. if (name && strcmp(name, bench_overrides[i].name) == 0) {
  251. count = lfs_max(count, d+1);
  252. permutations *= bench_overrides[i].permutations;
  253. break;
  254. }
  255. }
  256. }
  257. bench_override_define_count = count;
  258. bench_override_define_permutations = permutations;
  259. // make sure our override arrays are big enough
  260. if (count * permutations > bench_override_define_capacity) {
  261. // align to power of two to avoid any superlinear growth
  262. size_t ncapacity = 1 << lfs_npw2(count * permutations);
  263. bench_override_defines = realloc(
  264. bench_override_defines,
  265. sizeof(bench_define_t)*ncapacity);
  266. bench_override_define_capacity = ncapacity;
  267. }
  268. // zero unoverridden defines
  269. memset(bench_override_defines, 0,
  270. sizeof(bench_define_t) * count * permutations);
  271. // compute permutations
  272. size_t p = 1;
  273. for (size_t i = 0; i < bench_override_count; i++) {
  274. for (size_t d = 0;
  275. d < lfs_max(
  276. suite->define_count,
  277. BENCH_IMPLICIT_DEFINE_COUNT);
  278. d++) {
  279. // define name match?
  280. const char *name = bench_define_name(d);
  281. if (name && strcmp(name, bench_overrides[i].name) == 0) {
  282. // scatter the define permutations based on already
  283. // seen permutations
  284. for (size_t j = 0; j < permutations; j++) {
  285. bench_override_defines[j*count + d] = BENCH_LIT(
  286. bench_overrides[i].defines[(j/p)
  287. % bench_overrides[i].permutations]);
  288. }
  289. // keep track of how many permutations we've seen so far
  290. p *= bench_overrides[i].permutations;
  291. break;
  292. }
  293. }
  294. }
  295. }
  296. }
  297. void bench_define_perm(
  298. const struct bench_suite *suite,
  299. const struct bench_case *case_,
  300. size_t perm) {
  301. if (case_->defines) {
  302. bench_define_maps[BENCH_DEFINE_MAP_PERMUTATION] = (bench_define_map_t){
  303. case_->defines + perm*suite->define_count,
  304. suite->define_count};
  305. } else {
  306. bench_define_maps[BENCH_DEFINE_MAP_PERMUTATION] = (bench_define_map_t){
  307. NULL, 0};
  308. }
  309. }
  310. void bench_define_override(size_t perm) {
  311. bench_define_maps[BENCH_DEFINE_MAP_OVERRIDE] = (bench_define_map_t){
  312. bench_override_defines + perm*bench_override_define_count,
  313. bench_override_define_count};
  314. }
  315. void bench_define_explicit(
  316. const bench_define_t *defines,
  317. size_t define_count) {
  318. bench_define_maps[BENCH_DEFINE_MAP_EXPLICIT] = (bench_define_map_t){
  319. defines, define_count};
  320. }
  321. void bench_define_cleanup(void) {
  322. // bench define management can allocate a few things
  323. free(bench_define_cache);
  324. free(bench_define_cache_mask);
  325. free(bench_override_defines);
  326. }
  327. // bench state
  328. extern const bench_geometry_t *bench_geometries;
  329. extern size_t bench_geometry_count;
  330. const bench_id_t *bench_ids = (const bench_id_t[]) {
  331. {NULL, NULL, 0},
  332. };
  333. size_t bench_id_count = 1;
  334. size_t bench_step_start = 0;
  335. size_t bench_step_stop = -1;
  336. size_t bench_step_step = 1;
  337. const char *bench_disk_path = NULL;
  338. const char *bench_trace_path = NULL;
  339. FILE *bench_trace_file = NULL;
  340. uint32_t bench_trace_cycles = 0;
  341. lfs_emubd_sleep_t bench_read_sleep = 0.0;
  342. lfs_emubd_sleep_t bench_prog_sleep = 0.0;
  343. lfs_emubd_sleep_t bench_erase_sleep = 0.0;
  344. // trace printing
  345. void bench_trace(const char *fmt, ...) {
  346. if (bench_trace_path) {
  347. if (!bench_trace_file) {
  348. // Tracing output is heavy and trying to open every trace
  349. // call is slow, so we only try to open the trace file every
  350. // so often. Note this doesn't affect successfully opened files
  351. if (bench_trace_cycles % 128 != 0) {
  352. bench_trace_cycles += 1;
  353. return;
  354. }
  355. bench_trace_cycles += 1;
  356. int fd;
  357. if (strcmp(bench_trace_path, "-") == 0) {
  358. fd = dup(1);
  359. if (fd < 0) {
  360. return;
  361. }
  362. } else {
  363. fd = open(
  364. bench_trace_path,
  365. O_WRONLY | O_CREAT | O_APPEND | O_NONBLOCK,
  366. 0666);
  367. if (fd < 0) {
  368. return;
  369. }
  370. int err = fcntl(fd, F_SETFL, O_WRONLY | O_CREAT | O_APPEND);
  371. assert(!err);
  372. }
  373. FILE *f = fdopen(fd, "a");
  374. assert(f);
  375. int err = setvbuf(f, NULL, _IOLBF, BUFSIZ);
  376. assert(!err);
  377. bench_trace_file = f;
  378. }
  379. va_list va;
  380. va_start(va, fmt);
  381. int res = vfprintf(bench_trace_file, fmt, va);
  382. if (res < 0) {
  383. fclose(bench_trace_file);
  384. bench_trace_file = NULL;
  385. }
  386. va_end(va);
  387. }
  388. }
  389. // bench recording state
  390. static struct lfs_config *bench_cfg = NULL;
  391. static lfs_emubd_io_t bench_last_read = 0;
  392. static lfs_emubd_io_t bench_last_prog = 0;
  393. static lfs_emubd_io_t bench_last_erased = 0;
  394. lfs_emubd_io_t bench_read = 0;
  395. lfs_emubd_io_t bench_prog = 0;
  396. lfs_emubd_io_t bench_erased = 0;
  397. void bench_reset(void) {
  398. bench_read = 0;
  399. bench_prog = 0;
  400. bench_erased = 0;
  401. bench_last_read = 0;
  402. bench_last_prog = 0;
  403. bench_last_erased = 0;
  404. }
  405. void bench_start(void) {
  406. assert(bench_cfg);
  407. lfs_emubd_sio_t read = lfs_emubd_getread(bench_cfg);
  408. assert(read >= 0);
  409. lfs_emubd_sio_t prog = lfs_emubd_getprog(bench_cfg);
  410. assert(prog >= 0);
  411. lfs_emubd_sio_t erased = lfs_emubd_geterased(bench_cfg);
  412. assert(erased >= 0);
  413. bench_last_read = read;
  414. bench_last_prog = prog;
  415. bench_last_erased = erased;
  416. }
  417. void bench_stop(void) {
  418. assert(bench_cfg);
  419. lfs_emubd_sio_t read = lfs_emubd_getread(bench_cfg);
  420. assert(read >= 0);
  421. lfs_emubd_sio_t prog = lfs_emubd_getprog(bench_cfg);
  422. assert(prog >= 0);
  423. lfs_emubd_sio_t erased = lfs_emubd_geterased(bench_cfg);
  424. assert(erased >= 0);
  425. bench_read += read - bench_last_read;
  426. bench_prog += prog - bench_last_prog;
  427. bench_erased += erased - bench_last_erased;
  428. }
  429. // encode our permutation into a reusable id
  430. static void perm_printid(
  431. const struct bench_suite *suite,
  432. const struct bench_case *case_) {
  433. (void)suite;
  434. // case[:permutation]
  435. printf("%s:", case_->name);
  436. for (size_t d = 0;
  437. d < lfs_max(
  438. suite->define_count,
  439. BENCH_IMPLICIT_DEFINE_COUNT);
  440. d++) {
  441. if (bench_define_ispermutation(d)) {
  442. leb16_print(d);
  443. leb16_print(BENCH_DEFINE(d));
  444. }
  445. }
  446. }
  447. // a quick trie for keeping track of permutations we've seen
  448. typedef struct bench_seen {
  449. struct bench_seen_branch *branches;
  450. size_t branch_count;
  451. size_t branch_capacity;
  452. } bench_seen_t;
  453. struct bench_seen_branch {
  454. intmax_t define;
  455. struct bench_seen branch;
  456. };
  457. bool bench_seen_insert(
  458. bench_seen_t *seen,
  459. const struct bench_suite *suite,
  460. const struct bench_case *case_) {
  461. (void)case_;
  462. bool was_seen = true;
  463. // use the currently set defines
  464. for (size_t d = 0;
  465. d < lfs_max(
  466. suite->define_count,
  467. BENCH_IMPLICIT_DEFINE_COUNT);
  468. d++) {
  469. // treat unpermuted defines the same as 0
  470. intmax_t define = bench_define_ispermutation(d) ? BENCH_DEFINE(d) : 0;
  471. // already seen?
  472. struct bench_seen_branch *branch = NULL;
  473. for (size_t i = 0; i < seen->branch_count; i++) {
  474. if (seen->branches[i].define == define) {
  475. branch = &seen->branches[i];
  476. break;
  477. }
  478. }
  479. // need to create a new node
  480. if (!branch) {
  481. was_seen = false;
  482. branch = mappend(
  483. (void**)&seen->branches,
  484. sizeof(struct bench_seen_branch),
  485. &seen->branch_count,
  486. &seen->branch_capacity);
  487. branch->define = define;
  488. branch->branch = (bench_seen_t){NULL, 0, 0};
  489. }
  490. seen = &branch->branch;
  491. }
  492. return was_seen;
  493. }
  494. void bench_seen_cleanup(bench_seen_t *seen) {
  495. for (size_t i = 0; i < seen->branch_count; i++) {
  496. bench_seen_cleanup(&seen->branches[i].branch);
  497. }
  498. free(seen->branches);
  499. }
  500. // iterate through permutations in a bench case
  501. static void case_forperm(
  502. const struct bench_suite *suite,
  503. const struct bench_case *case_,
  504. const bench_define_t *defines,
  505. size_t define_count,
  506. void (*cb)(
  507. void *data,
  508. const struct bench_suite *suite,
  509. const struct bench_case *case_),
  510. void *data) {
  511. if (defines) {
  512. bench_define_explicit(defines, define_count);
  513. bench_define_flush();
  514. cb(data, suite, case_);
  515. return;
  516. }
  517. bench_seen_t seen = {NULL, 0, 0};
  518. for (size_t k = 0; k < case_->permutations; k++) {
  519. // define permutation
  520. bench_define_perm(suite, case_, k);
  521. for (size_t v = 0; v < bench_override_define_permutations; v++) {
  522. // define override permutation
  523. bench_define_override(v);
  524. for (size_t g = 0; g < bench_geometry_count; g++) {
  525. // define geometry
  526. bench_define_geometry(&bench_geometries[g]);
  527. bench_define_flush();
  528. // have we seen this permutation before?
  529. bool was_seen = bench_seen_insert(&seen, suite, case_);
  530. if (!(k == 0 && v == 0 && g == 0) && was_seen) {
  531. continue;
  532. }
  533. cb(data, suite, case_);
  534. }
  535. }
  536. }
  537. bench_seen_cleanup(&seen);
  538. }
  539. // how many permutations are there actually in a bench case
  540. struct perm_count_state {
  541. size_t total;
  542. size_t filtered;
  543. };
  544. void perm_count(
  545. void *data,
  546. const struct bench_suite *suite,
  547. const struct bench_case *case_) {
  548. struct perm_count_state *state = data;
  549. (void)suite;
  550. (void)case_;
  551. state->total += 1;
  552. if (case_->filter && !case_->filter()) {
  553. return;
  554. }
  555. state->filtered += 1;
  556. }
  557. // operations we can do
  558. static void summary(void) {
  559. printf("%-23s %7s %7s %7s %11s\n",
  560. "", "flags", "suites", "cases", "perms");
  561. size_t suites = 0;
  562. size_t cases = 0;
  563. bench_flags_t flags = 0;
  564. struct perm_count_state perms = {0, 0};
  565. for (size_t t = 0; t < bench_id_count; t++) {
  566. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  567. bench_define_suite(&bench_suites[i]);
  568. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  569. // does neither suite nor case name match?
  570. if (bench_ids[t].name && !(
  571. strcmp(bench_ids[t].name,
  572. bench_suites[i].name) == 0
  573. || strcmp(bench_ids[t].name,
  574. bench_suites[i].cases[j].name) == 0)) {
  575. continue;
  576. }
  577. cases += 1;
  578. case_forperm(
  579. &bench_suites[i],
  580. &bench_suites[i].cases[j],
  581. bench_ids[t].defines,
  582. bench_ids[t].define_count,
  583. perm_count,
  584. &perms);
  585. }
  586. suites += 1;
  587. flags |= bench_suites[i].flags;
  588. }
  589. }
  590. char perm_buf[64];
  591. sprintf(perm_buf, "%zu/%zu", perms.filtered, perms.total);
  592. char flag_buf[64];
  593. sprintf(flag_buf, "%s%s",
  594. (flags & BENCH_REENTRANT) ? "r" : "",
  595. (!flags) ? "-" : "");
  596. printf("%-23s %7s %7zu %7zu %11s\n",
  597. "TOTAL",
  598. flag_buf,
  599. suites,
  600. cases,
  601. perm_buf);
  602. }
  603. static void list_suites(void) {
  604. // at least size so that names fit
  605. unsigned name_width = 23;
  606. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  607. size_t len = strlen(bench_suites[i].name);
  608. if (len > name_width) {
  609. name_width = len;
  610. }
  611. }
  612. name_width = 4*((name_width+1+4-1)/4)-1;
  613. printf("%-*s %7s %7s %11s\n",
  614. name_width, "suite", "flags", "cases", "perms");
  615. for (size_t t = 0; t < bench_id_count; t++) {
  616. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  617. bench_define_suite(&bench_suites[i]);
  618. size_t cases = 0;
  619. struct perm_count_state perms = {0, 0};
  620. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  621. // does neither suite nor case name match?
  622. if (bench_ids[t].name && !(
  623. strcmp(bench_ids[t].name,
  624. bench_suites[i].name) == 0
  625. || strcmp(bench_ids[t].name,
  626. bench_suites[i].cases[j].name) == 0)) {
  627. continue;
  628. }
  629. cases += 1;
  630. case_forperm(
  631. &bench_suites[i],
  632. &bench_suites[i].cases[j],
  633. bench_ids[t].defines,
  634. bench_ids[t].define_count,
  635. perm_count,
  636. &perms);
  637. }
  638. // no benches found?
  639. if (!cases) {
  640. continue;
  641. }
  642. char perm_buf[64];
  643. sprintf(perm_buf, "%zu/%zu", perms.filtered, perms.total);
  644. char flag_buf[64];
  645. sprintf(flag_buf, "%s%s",
  646. (bench_suites[i].flags & BENCH_REENTRANT) ? "r" : "",
  647. (!bench_suites[i].flags) ? "-" : "");
  648. printf("%-*s %7s %7zu %11s\n",
  649. name_width,
  650. bench_suites[i].name,
  651. flag_buf,
  652. cases,
  653. perm_buf);
  654. }
  655. }
  656. }
  657. static void list_cases(void) {
  658. // at least size so that names fit
  659. unsigned name_width = 23;
  660. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  661. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  662. size_t len = strlen(bench_suites[i].cases[j].name);
  663. if (len > name_width) {
  664. name_width = len;
  665. }
  666. }
  667. }
  668. name_width = 4*((name_width+1+4-1)/4)-1;
  669. printf("%-*s %7s %11s\n", name_width, "case", "flags", "perms");
  670. for (size_t t = 0; t < bench_id_count; t++) {
  671. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  672. bench_define_suite(&bench_suites[i]);
  673. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  674. // does neither suite nor case name match?
  675. if (bench_ids[t].name && !(
  676. strcmp(bench_ids[t].name,
  677. bench_suites[i].name) == 0
  678. || strcmp(bench_ids[t].name,
  679. bench_suites[i].cases[j].name) == 0)) {
  680. continue;
  681. }
  682. struct perm_count_state perms = {0, 0};
  683. case_forperm(
  684. &bench_suites[i],
  685. &bench_suites[i].cases[j],
  686. bench_ids[t].defines,
  687. bench_ids[t].define_count,
  688. perm_count,
  689. &perms);
  690. char perm_buf[64];
  691. sprintf(perm_buf, "%zu/%zu", perms.filtered, perms.total);
  692. char flag_buf[64];
  693. sprintf(flag_buf, "%s%s",
  694. (bench_suites[i].cases[j].flags & BENCH_REENTRANT)
  695. ? "r" : "",
  696. (!bench_suites[i].cases[j].flags)
  697. ? "-" : "");
  698. printf("%-*s %7s %11s\n",
  699. name_width,
  700. bench_suites[i].cases[j].name,
  701. flag_buf,
  702. perm_buf);
  703. }
  704. }
  705. }
  706. }
  707. static void list_suite_paths(void) {
  708. // at least size so that names fit
  709. unsigned name_width = 23;
  710. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  711. size_t len = strlen(bench_suites[i].name);
  712. if (len > name_width) {
  713. name_width = len;
  714. }
  715. }
  716. name_width = 4*((name_width+1+4-1)/4)-1;
  717. printf("%-*s %s\n", name_width, "suite", "path");
  718. for (size_t t = 0; t < bench_id_count; t++) {
  719. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  720. size_t cases = 0;
  721. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  722. // does neither suite nor case name match?
  723. if (bench_ids[t].name && !(
  724. strcmp(bench_ids[t].name,
  725. bench_suites[i].name) == 0
  726. || strcmp(bench_ids[t].name,
  727. bench_suites[i].cases[j].name) == 0)) {
  728. continue;
  729. cases += 1;
  730. }
  731. }
  732. // no benches found?
  733. if (!cases) {
  734. continue;
  735. }
  736. printf("%-*s %s\n",
  737. name_width,
  738. bench_suites[i].name,
  739. bench_suites[i].path);
  740. }
  741. }
  742. }
  743. static void list_case_paths(void) {
  744. // at least size so that names fit
  745. unsigned name_width = 23;
  746. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  747. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  748. size_t len = strlen(bench_suites[i].cases[j].name);
  749. if (len > name_width) {
  750. name_width = len;
  751. }
  752. }
  753. }
  754. name_width = 4*((name_width+1+4-1)/4)-1;
  755. printf("%-*s %s\n", name_width, "case", "path");
  756. for (size_t t = 0; t < bench_id_count; t++) {
  757. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  758. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  759. // does neither suite nor case name match?
  760. if (bench_ids[t].name && !(
  761. strcmp(bench_ids[t].name,
  762. bench_suites[i].name) == 0
  763. || strcmp(bench_ids[t].name,
  764. bench_suites[i].cases[j].name) == 0)) {
  765. continue;
  766. }
  767. printf("%-*s %s\n",
  768. name_width,
  769. bench_suites[i].cases[j].name,
  770. bench_suites[i].cases[j].path);
  771. }
  772. }
  773. }
  774. }
  775. struct list_defines_define {
  776. const char *name;
  777. intmax_t *values;
  778. size_t value_count;
  779. size_t value_capacity;
  780. };
  781. struct list_defines_defines {
  782. struct list_defines_define *defines;
  783. size_t define_count;
  784. size_t define_capacity;
  785. };
  786. static void list_defines_add(
  787. struct list_defines_defines *defines,
  788. size_t d) {
  789. const char *name = bench_define_name(d);
  790. intmax_t value = BENCH_DEFINE(d);
  791. // define already in defines?
  792. for (size_t i = 0; i < defines->define_count; i++) {
  793. if (strcmp(defines->defines[i].name, name) == 0) {
  794. // value already in values?
  795. for (size_t j = 0; j < defines->defines[i].value_count; j++) {
  796. if (defines->defines[i].values[j] == value) {
  797. return;
  798. }
  799. }
  800. *(intmax_t*)mappend(
  801. (void**)&defines->defines[i].values,
  802. sizeof(intmax_t),
  803. &defines->defines[i].value_count,
  804. &defines->defines[i].value_capacity) = value;
  805. return;
  806. }
  807. }
  808. // new define?
  809. struct list_defines_define *define = mappend(
  810. (void**)&defines->defines,
  811. sizeof(struct list_defines_define),
  812. &defines->define_count,
  813. &defines->define_capacity);
  814. define->name = name;
  815. define->values = malloc(sizeof(intmax_t));
  816. define->values[0] = value;
  817. define->value_count = 1;
  818. define->value_capacity = 1;
  819. }
  820. void perm_list_defines(
  821. void *data,
  822. const struct bench_suite *suite,
  823. const struct bench_case *case_) {
  824. struct list_defines_defines *defines = data;
  825. (void)suite;
  826. (void)case_;
  827. // collect defines
  828. for (size_t d = 0;
  829. d < lfs_max(suite->define_count,
  830. BENCH_IMPLICIT_DEFINE_COUNT);
  831. d++) {
  832. if (d < BENCH_IMPLICIT_DEFINE_COUNT
  833. || bench_define_ispermutation(d)) {
  834. list_defines_add(defines, d);
  835. }
  836. }
  837. }
  838. void perm_list_permutation_defines(
  839. void *data,
  840. const struct bench_suite *suite,
  841. const struct bench_case *case_) {
  842. struct list_defines_defines *defines = data;
  843. (void)suite;
  844. (void)case_;
  845. // collect permutation_defines
  846. for (size_t d = 0;
  847. d < lfs_max(suite->define_count,
  848. BENCH_IMPLICIT_DEFINE_COUNT);
  849. d++) {
  850. if (bench_define_ispermutation(d)) {
  851. list_defines_add(defines, d);
  852. }
  853. }
  854. }
  855. extern const bench_geometry_t builtin_geometries[];
  856. static void list_defines(void) {
  857. struct list_defines_defines defines = {NULL, 0, 0};
  858. // add defines
  859. for (size_t t = 0; t < bench_id_count; t++) {
  860. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  861. bench_define_suite(&bench_suites[i]);
  862. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  863. // does neither suite nor case name match?
  864. if (bench_ids[t].name && !(
  865. strcmp(bench_ids[t].name,
  866. bench_suites[i].name) == 0
  867. || strcmp(bench_ids[t].name,
  868. bench_suites[i].cases[j].name) == 0)) {
  869. continue;
  870. }
  871. case_forperm(
  872. &bench_suites[i],
  873. &bench_suites[i].cases[j],
  874. bench_ids[t].defines,
  875. bench_ids[t].define_count,
  876. perm_list_defines,
  877. &defines);
  878. }
  879. }
  880. }
  881. for (size_t i = 0; i < defines.define_count; i++) {
  882. printf("%s=", defines.defines[i].name);
  883. for (size_t j = 0; j < defines.defines[i].value_count; j++) {
  884. printf("%jd", defines.defines[i].values[j]);
  885. if (j != defines.defines[i].value_count-1) {
  886. printf(",");
  887. }
  888. }
  889. printf("\n");
  890. }
  891. for (size_t i = 0; i < defines.define_count; i++) {
  892. free(defines.defines[i].values);
  893. }
  894. free(defines.defines);
  895. }
  896. static void list_permutation_defines(void) {
  897. struct list_defines_defines defines = {NULL, 0, 0};
  898. // add permutation defines
  899. for (size_t t = 0; t < bench_id_count; t++) {
  900. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  901. bench_define_suite(&bench_suites[i]);
  902. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  903. // does neither suite nor case name match?
  904. if (bench_ids[t].name && !(
  905. strcmp(bench_ids[t].name,
  906. bench_suites[i].name) == 0
  907. || strcmp(bench_ids[t].name,
  908. bench_suites[i].cases[j].name) == 0)) {
  909. continue;
  910. }
  911. case_forperm(
  912. &bench_suites[i],
  913. &bench_suites[i].cases[j],
  914. bench_ids[t].defines,
  915. bench_ids[t].define_count,
  916. perm_list_permutation_defines,
  917. &defines);
  918. }
  919. }
  920. }
  921. for (size_t i = 0; i < defines.define_count; i++) {
  922. printf("%s=", defines.defines[i].name);
  923. for (size_t j = 0; j < defines.defines[i].value_count; j++) {
  924. printf("%jd", defines.defines[i].values[j]);
  925. if (j != defines.defines[i].value_count-1) {
  926. printf(",");
  927. }
  928. }
  929. printf("\n");
  930. }
  931. for (size_t i = 0; i < defines.define_count; i++) {
  932. free(defines.defines[i].values);
  933. }
  934. free(defines.defines);
  935. }
  936. static void list_implicit_defines(void) {
  937. struct list_defines_defines defines = {NULL, 0, 0};
  938. // yes we do need to define a suite, this does a bit of bookeeping
  939. // such as setting up the define cache
  940. bench_define_suite(&(const struct bench_suite){0});
  941. // make sure to include builtin geometries here
  942. extern const bench_geometry_t builtin_geometries[];
  943. for (size_t g = 0; builtin_geometries[g].name; g++) {
  944. bench_define_geometry(&builtin_geometries[g]);
  945. bench_define_flush();
  946. // add implicit defines
  947. for (size_t d = 0; d < BENCH_IMPLICIT_DEFINE_COUNT; d++) {
  948. list_defines_add(&defines, d);
  949. }
  950. }
  951. for (size_t i = 0; i < defines.define_count; i++) {
  952. printf("%s=", defines.defines[i].name);
  953. for (size_t j = 0; j < defines.defines[i].value_count; j++) {
  954. printf("%jd", defines.defines[i].values[j]);
  955. if (j != defines.defines[i].value_count-1) {
  956. printf(",");
  957. }
  958. }
  959. printf("\n");
  960. }
  961. for (size_t i = 0; i < defines.define_count; i++) {
  962. free(defines.defines[i].values);
  963. }
  964. free(defines.defines);
  965. }
  966. // geometries to bench
  967. const bench_geometry_t builtin_geometries[] = {
  968. {"default", {{NULL}, BENCH_CONST(16), BENCH_CONST(512), {NULL}}},
  969. {"eeprom", {{NULL}, BENCH_CONST(1), BENCH_CONST(512), {NULL}}},
  970. {"emmc", {{NULL}, {NULL}, BENCH_CONST(512), {NULL}}},
  971. {"nor", {{NULL}, BENCH_CONST(1), BENCH_CONST(4096), {NULL}}},
  972. {"nand", {{NULL}, BENCH_CONST(4096), BENCH_CONST(32768), {NULL}}},
  973. {NULL, {{NULL}, {NULL}, {NULL}, {NULL}}},
  974. };
  975. const bench_geometry_t *bench_geometries = builtin_geometries;
  976. size_t bench_geometry_count = 5;
  977. static void list_geometries(void) {
  978. // at least size so that names fit
  979. unsigned name_width = 23;
  980. for (size_t g = 0; builtin_geometries[g].name; g++) {
  981. size_t len = strlen(builtin_geometries[g].name);
  982. if (len > name_width) {
  983. name_width = len;
  984. }
  985. }
  986. name_width = 4*((name_width+1+4-1)/4)-1;
  987. // yes we do need to define a suite, this does a bit of bookeeping
  988. // such as setting up the define cache
  989. bench_define_suite(&(const struct bench_suite){0});
  990. printf("%-*s %7s %7s %7s %7s %11s\n",
  991. name_width, "geometry", "read", "prog", "erase", "count", "size");
  992. for (size_t g = 0; builtin_geometries[g].name; g++) {
  993. bench_define_geometry(&builtin_geometries[g]);
  994. bench_define_flush();
  995. printf("%-*s %7ju %7ju %7ju %7ju %11ju\n",
  996. name_width,
  997. builtin_geometries[g].name,
  998. READ_SIZE,
  999. PROG_SIZE,
  1000. BLOCK_SIZE,
  1001. BLOCK_COUNT,
  1002. BLOCK_SIZE*BLOCK_COUNT);
  1003. }
  1004. }
  1005. // global bench step count
  1006. size_t bench_step = 0;
  1007. void perm_run(
  1008. void *data,
  1009. const struct bench_suite *suite,
  1010. const struct bench_case *case_) {
  1011. (void)data;
  1012. // skip this step?
  1013. if (!(bench_step >= bench_step_start
  1014. && bench_step < bench_step_stop
  1015. && (bench_step-bench_step_start) % bench_step_step == 0)) {
  1016. bench_step += 1;
  1017. return;
  1018. }
  1019. bench_step += 1;
  1020. // filter?
  1021. if (case_->filter && !case_->filter()) {
  1022. printf("skipped ");
  1023. perm_printid(suite, case_);
  1024. printf("\n");
  1025. return;
  1026. }
  1027. // create block device and configuration
  1028. lfs_emubd_t bd;
  1029. struct lfs_config cfg = {
  1030. .context = &bd,
  1031. .read = lfs_emubd_read,
  1032. .prog = lfs_emubd_prog,
  1033. .erase = lfs_emubd_erase,
  1034. .sync = lfs_emubd_sync,
  1035. .read_size = READ_SIZE,
  1036. .prog_size = PROG_SIZE,
  1037. .block_size = BLOCK_SIZE,
  1038. .block_count = BLOCK_COUNT,
  1039. .block_cycles = BLOCK_CYCLES,
  1040. .cache_size = CACHE_SIZE,
  1041. .lookahead_size = LOOKAHEAD_SIZE,
  1042. };
  1043. struct lfs_emubd_config bdcfg = {
  1044. .erase_value = ERASE_VALUE,
  1045. .erase_cycles = ERASE_CYCLES,
  1046. .badblock_behavior = BADBLOCK_BEHAVIOR,
  1047. .disk_path = bench_disk_path,
  1048. .read_sleep = bench_read_sleep,
  1049. .prog_sleep = bench_prog_sleep,
  1050. .erase_sleep = bench_erase_sleep,
  1051. };
  1052. int err = lfs_emubd_createcfg(&cfg, bench_disk_path, &bdcfg);
  1053. if (err) {
  1054. fprintf(stderr, "error: could not create block device: %d\n", err);
  1055. exit(-1);
  1056. }
  1057. // run the bench
  1058. bench_cfg = &cfg;
  1059. bench_reset();
  1060. printf("running ");
  1061. perm_printid(suite, case_);
  1062. printf("\n");
  1063. case_->run(&cfg);
  1064. printf("finished ");
  1065. perm_printid(suite, case_);
  1066. printf(" %"PRIu64" %"PRIu64" %"PRIu64,
  1067. bench_read,
  1068. bench_prog,
  1069. bench_erased);
  1070. printf("\n");
  1071. // cleanup
  1072. err = lfs_emubd_destroy(&cfg);
  1073. if (err) {
  1074. fprintf(stderr, "error: could not destroy block device: %d\n", err);
  1075. exit(-1);
  1076. }
  1077. }
  1078. static void run(void) {
  1079. // ignore disconnected pipes
  1080. signal(SIGPIPE, SIG_IGN);
  1081. for (size_t t = 0; t < bench_id_count; t++) {
  1082. for (size_t i = 0; i < BENCH_SUITE_COUNT; i++) {
  1083. bench_define_suite(&bench_suites[i]);
  1084. for (size_t j = 0; j < bench_suites[i].case_count; j++) {
  1085. // does neither suite nor case name match?
  1086. if (bench_ids[t].name && !(
  1087. strcmp(bench_ids[t].name,
  1088. bench_suites[i].name) == 0
  1089. || strcmp(bench_ids[t].name,
  1090. bench_suites[i].cases[j].name) == 0)) {
  1091. continue;
  1092. }
  1093. case_forperm(
  1094. &bench_suites[i],
  1095. &bench_suites[i].cases[j],
  1096. bench_ids[t].defines,
  1097. bench_ids[t].define_count,
  1098. perm_run,
  1099. NULL);
  1100. }
  1101. }
  1102. }
  1103. }
  1104. // option handling
  1105. enum opt_flags {
  1106. OPT_HELP = 'h',
  1107. OPT_SUMMARY = 'Y',
  1108. OPT_LIST_SUITES = 'l',
  1109. OPT_LIST_CASES = 'L',
  1110. OPT_LIST_SUITE_PATHS = 1,
  1111. OPT_LIST_CASE_PATHS = 2,
  1112. OPT_LIST_DEFINES = 3,
  1113. OPT_LIST_PERMUTATION_DEFINES = 4,
  1114. OPT_LIST_IMPLICIT_DEFINES = 5,
  1115. OPT_LIST_GEOMETRIES = 6,
  1116. OPT_DEFINE = 'D',
  1117. OPT_GEOMETRY = 'G',
  1118. OPT_STEP = 's',
  1119. OPT_DISK = 'd',
  1120. OPT_TRACE = 't',
  1121. OPT_READ_SLEEP = 7,
  1122. OPT_PROG_SLEEP = 8,
  1123. OPT_ERASE_SLEEP = 9,
  1124. };
  1125. const char *short_opts = "hYlLD:G:s:d:t:";
  1126. const struct option long_opts[] = {
  1127. {"help", no_argument, NULL, OPT_HELP},
  1128. {"summary", no_argument, NULL, OPT_SUMMARY},
  1129. {"list-suites", no_argument, NULL, OPT_LIST_SUITES},
  1130. {"list-cases", no_argument, NULL, OPT_LIST_CASES},
  1131. {"list-suite-paths", no_argument, NULL, OPT_LIST_SUITE_PATHS},
  1132. {"list-case-paths", no_argument, NULL, OPT_LIST_CASE_PATHS},
  1133. {"list-defines", no_argument, NULL, OPT_LIST_DEFINES},
  1134. {"list-permutation-defines",
  1135. no_argument, NULL, OPT_LIST_PERMUTATION_DEFINES},
  1136. {"list-implicit-defines",
  1137. no_argument, NULL, OPT_LIST_IMPLICIT_DEFINES},
  1138. {"list-geometries", no_argument, NULL, OPT_LIST_GEOMETRIES},
  1139. {"define", required_argument, NULL, OPT_DEFINE},
  1140. {"geometry", required_argument, NULL, OPT_GEOMETRY},
  1141. {"step", required_argument, NULL, OPT_STEP},
  1142. {"disk", required_argument, NULL, OPT_DISK},
  1143. {"trace", required_argument, NULL, OPT_TRACE},
  1144. {"read-sleep", required_argument, NULL, OPT_READ_SLEEP},
  1145. {"prog-sleep", required_argument, NULL, OPT_PROG_SLEEP},
  1146. {"erase-sleep", required_argument, NULL, OPT_ERASE_SLEEP},
  1147. {NULL, 0, NULL, 0},
  1148. };
  1149. const char *const help_text[] = {
  1150. "Show this help message.",
  1151. "Show quick summary.",
  1152. "List bench suites.",
  1153. "List bench cases.",
  1154. "List the path for each bench suite.",
  1155. "List the path and line number for each bench case.",
  1156. "List all defines in this bench-runner.",
  1157. "List explicit defines in this bench-runner.",
  1158. "List implicit defines in this bench-runner.",
  1159. "List the available disk geometries.",
  1160. "Override a bench define.",
  1161. "Comma-separated list of disk geometries to bench.",
  1162. "Comma-separated range of bench permutations to run (start,stop,step).",
  1163. "Redirect block device operations to this file.",
  1164. "Redirect trace output to this file.",
  1165. "Artificial read delay in seconds.",
  1166. "Artificial prog delay in seconds.",
  1167. "Artificial erase delay in seconds.",
  1168. };
  1169. int main(int argc, char **argv) {
  1170. void (*op)(void) = run;
  1171. size_t bench_override_capacity = 0;
  1172. size_t bench_geometry_capacity = 0;
  1173. size_t bench_id_capacity = 0;
  1174. // parse options
  1175. while (true) {
  1176. int c = getopt_long(argc, argv, short_opts, long_opts, NULL);
  1177. switch (c) {
  1178. // generate help message
  1179. case OPT_HELP: {
  1180. printf("usage: %s [options] [bench_id]\n", argv[0]);
  1181. printf("\n");
  1182. printf("options:\n");
  1183. size_t i = 0;
  1184. while (long_opts[i].name) {
  1185. size_t indent;
  1186. if (long_opts[i].has_arg == no_argument) {
  1187. if (long_opts[i].val >= '0' && long_opts[i].val < 'z') {
  1188. indent = printf(" -%c, --%s ",
  1189. long_opts[i].val,
  1190. long_opts[i].name);
  1191. } else {
  1192. indent = printf(" --%s ",
  1193. long_opts[i].name);
  1194. }
  1195. } else {
  1196. if (long_opts[i].val >= '0' && long_opts[i].val < 'z') {
  1197. indent = printf(" -%c %s, --%s %s ",
  1198. long_opts[i].val,
  1199. long_opts[i].name,
  1200. long_opts[i].name,
  1201. long_opts[i].name);
  1202. } else {
  1203. indent = printf(" --%s %s ",
  1204. long_opts[i].name,
  1205. long_opts[i].name);
  1206. }
  1207. }
  1208. // a quick, hacky, byte-level method for text wrapping
  1209. size_t len = strlen(help_text[i]);
  1210. size_t j = 0;
  1211. if (indent < 24) {
  1212. printf("%*s %.80s\n",
  1213. (int)(24-1-indent),
  1214. "",
  1215. &help_text[i][j]);
  1216. j += 80;
  1217. } else {
  1218. printf("\n");
  1219. }
  1220. while (j < len) {
  1221. printf("%24s%.80s\n", "", &help_text[i][j]);
  1222. j += 80;
  1223. }
  1224. i += 1;
  1225. }
  1226. printf("\n");
  1227. exit(0);
  1228. }
  1229. // summary/list flags
  1230. case OPT_SUMMARY:
  1231. op = summary;
  1232. break;
  1233. case OPT_LIST_SUITES:
  1234. op = list_suites;
  1235. break;
  1236. case OPT_LIST_CASES:
  1237. op = list_cases;
  1238. break;
  1239. case OPT_LIST_SUITE_PATHS:
  1240. op = list_suite_paths;
  1241. break;
  1242. case OPT_LIST_CASE_PATHS:
  1243. op = list_case_paths;
  1244. break;
  1245. case OPT_LIST_DEFINES:
  1246. op = list_defines;
  1247. break;
  1248. case OPT_LIST_PERMUTATION_DEFINES:
  1249. op = list_permutation_defines;
  1250. break;
  1251. case OPT_LIST_IMPLICIT_DEFINES:
  1252. op = list_implicit_defines;
  1253. break;
  1254. case OPT_LIST_GEOMETRIES:
  1255. op = list_geometries;
  1256. break;
  1257. // configuration
  1258. case OPT_DEFINE: {
  1259. // allocate space
  1260. bench_override_t *override = mappend(
  1261. (void**)&bench_overrides,
  1262. sizeof(bench_override_t),
  1263. &bench_override_count,
  1264. &bench_override_capacity);
  1265. // parse into string key/intmax_t value, cannibalizing the
  1266. // arg in the process
  1267. char *sep = strchr(optarg, '=');
  1268. char *parsed = NULL;
  1269. if (!sep) {
  1270. goto invalid_define;
  1271. }
  1272. *sep = '\0';
  1273. override->name = optarg;
  1274. optarg = sep+1;
  1275. // parse comma-separated permutations
  1276. {
  1277. override->defines = NULL;
  1278. override->permutations = 0;
  1279. size_t override_capacity = 0;
  1280. while (true) {
  1281. optarg += strspn(optarg, " ");
  1282. if (strncmp(optarg, "range", strlen("range")) == 0) {
  1283. // range of values
  1284. optarg += strlen("range");
  1285. optarg += strspn(optarg, " ");
  1286. if (*optarg != '(') {
  1287. goto invalid_define;
  1288. }
  1289. optarg += 1;
  1290. intmax_t start = strtoumax(optarg, &parsed, 0);
  1291. intmax_t stop = -1;
  1292. intmax_t step = 1;
  1293. // allow empty string for start=0
  1294. if (parsed == optarg) {
  1295. start = 0;
  1296. }
  1297. optarg = parsed + strspn(parsed, " ");
  1298. if (*optarg != ',' && *optarg != ')') {
  1299. goto invalid_define;
  1300. }
  1301. if (*optarg == ',') {
  1302. optarg += 1;
  1303. stop = strtoumax(optarg, &parsed, 0);
  1304. // allow empty string for stop=end
  1305. if (parsed == optarg) {
  1306. stop = -1;
  1307. }
  1308. optarg = parsed + strspn(parsed, " ");
  1309. if (*optarg != ',' && *optarg != ')') {
  1310. goto invalid_define;
  1311. }
  1312. if (*optarg == ',') {
  1313. optarg += 1;
  1314. step = strtoumax(optarg, &parsed, 0);
  1315. // allow empty string for stop=1
  1316. if (parsed == optarg) {
  1317. step = 1;
  1318. }
  1319. optarg = parsed + strspn(parsed, " ");
  1320. if (*optarg != ')') {
  1321. goto invalid_define;
  1322. }
  1323. }
  1324. } else {
  1325. // single value = stop only
  1326. stop = start;
  1327. start = 0;
  1328. }
  1329. if (*optarg != ')') {
  1330. goto invalid_define;
  1331. }
  1332. optarg += 1;
  1333. // calculate the range of values
  1334. assert(step != 0);
  1335. for (intmax_t i = start;
  1336. (step < 0)
  1337. ? i > stop
  1338. : (uintmax_t)i < (uintmax_t)stop;
  1339. i += step) {
  1340. *(intmax_t*)mappend(
  1341. (void**)&override->defines,
  1342. sizeof(intmax_t),
  1343. &override->permutations,
  1344. &override_capacity) = i;
  1345. }
  1346. } else if (*optarg != '\0') {
  1347. // single value
  1348. intmax_t define = strtoimax(optarg, &parsed, 0);
  1349. if (parsed == optarg) {
  1350. goto invalid_define;
  1351. }
  1352. optarg = parsed + strspn(parsed, " ");
  1353. *(intmax_t*)mappend(
  1354. (void**)&override->defines,
  1355. sizeof(intmax_t),
  1356. &override->permutations,
  1357. &override_capacity) = define;
  1358. } else {
  1359. break;
  1360. }
  1361. if (*optarg == ',') {
  1362. optarg += 1;
  1363. }
  1364. }
  1365. }
  1366. assert(override->permutations > 0);
  1367. break;
  1368. invalid_define:
  1369. fprintf(stderr, "error: invalid define: %s\n", optarg);
  1370. exit(-1);
  1371. }
  1372. case OPT_GEOMETRY: {
  1373. // reset our geometry scenarios
  1374. if (bench_geometry_capacity > 0) {
  1375. free((bench_geometry_t*)bench_geometries);
  1376. }
  1377. bench_geometries = NULL;
  1378. bench_geometry_count = 0;
  1379. bench_geometry_capacity = 0;
  1380. // parse the comma separated list of disk geometries
  1381. while (*optarg) {
  1382. // allocate space
  1383. bench_geometry_t *geometry = mappend(
  1384. (void**)&bench_geometries,
  1385. sizeof(bench_geometry_t),
  1386. &bench_geometry_count,
  1387. &bench_geometry_capacity);
  1388. // parse the disk geometry
  1389. optarg += strspn(optarg, " ");
  1390. // named disk geometry
  1391. size_t len = strcspn(optarg, " ,");
  1392. for (size_t i = 0; builtin_geometries[i].name; i++) {
  1393. if (len == strlen(builtin_geometries[i].name)
  1394. && memcmp(optarg,
  1395. builtin_geometries[i].name,
  1396. len) == 0) {
  1397. *geometry = builtin_geometries[i];
  1398. optarg += len;
  1399. goto geometry_next;
  1400. }
  1401. }
  1402. // comma-separated read/prog/erase/count
  1403. if (*optarg == '{') {
  1404. lfs_size_t sizes[4];
  1405. size_t count = 0;
  1406. char *s = optarg + 1;
  1407. while (count < 4) {
  1408. char *parsed = NULL;
  1409. sizes[count] = strtoumax(s, &parsed, 0);
  1410. count += 1;
  1411. s = parsed + strspn(parsed, " ");
  1412. if (*s == ',') {
  1413. s += 1;
  1414. continue;
  1415. } else if (*s == '}') {
  1416. s += 1;
  1417. break;
  1418. } else {
  1419. goto geometry_unknown;
  1420. }
  1421. }
  1422. // allow implicit r=p and p=e for common geometries
  1423. memset(geometry, 0, sizeof(bench_geometry_t));
  1424. if (count >= 3) {
  1425. geometry->defines[READ_SIZE_i]
  1426. = BENCH_LIT(sizes[0]);
  1427. geometry->defines[PROG_SIZE_i]
  1428. = BENCH_LIT(sizes[1]);
  1429. geometry->defines[BLOCK_SIZE_i]
  1430. = BENCH_LIT(sizes[2]);
  1431. } else if (count >= 2) {
  1432. geometry->defines[PROG_SIZE_i]
  1433. = BENCH_LIT(sizes[0]);
  1434. geometry->defines[BLOCK_SIZE_i]
  1435. = BENCH_LIT(sizes[1]);
  1436. } else {
  1437. geometry->defines[BLOCK_SIZE_i]
  1438. = BENCH_LIT(sizes[0]);
  1439. }
  1440. if (count >= 4) {
  1441. geometry->defines[BLOCK_COUNT_i]
  1442. = BENCH_LIT(sizes[3]);
  1443. }
  1444. optarg = s;
  1445. goto geometry_next;
  1446. }
  1447. // leb16-encoded read/prog/erase/count
  1448. if (*optarg == ':') {
  1449. lfs_size_t sizes[4];
  1450. size_t count = 0;
  1451. char *s = optarg + 1;
  1452. while (true) {
  1453. char *parsed = NULL;
  1454. uintmax_t x = leb16_parse(s, &parsed);
  1455. if (parsed == s || count >= 4) {
  1456. break;
  1457. }
  1458. sizes[count] = x;
  1459. count += 1;
  1460. s = parsed;
  1461. }
  1462. // allow implicit r=p and p=e for common geometries
  1463. memset(geometry, 0, sizeof(bench_geometry_t));
  1464. if (count >= 3) {
  1465. geometry->defines[READ_SIZE_i]
  1466. = BENCH_LIT(sizes[0]);
  1467. geometry->defines[PROG_SIZE_i]
  1468. = BENCH_LIT(sizes[1]);
  1469. geometry->defines[BLOCK_SIZE_i]
  1470. = BENCH_LIT(sizes[2]);
  1471. } else if (count >= 2) {
  1472. geometry->defines[PROG_SIZE_i]
  1473. = BENCH_LIT(sizes[0]);
  1474. geometry->defines[BLOCK_SIZE_i]
  1475. = BENCH_LIT(sizes[1]);
  1476. } else {
  1477. geometry->defines[BLOCK_SIZE_i]
  1478. = BENCH_LIT(sizes[0]);
  1479. }
  1480. if (count >= 4) {
  1481. geometry->defines[BLOCK_COUNT_i]
  1482. = BENCH_LIT(sizes[3]);
  1483. }
  1484. optarg = s;
  1485. goto geometry_next;
  1486. }
  1487. geometry_unknown:
  1488. // unknown scenario?
  1489. fprintf(stderr, "error: unknown disk geometry: %s\n",
  1490. optarg);
  1491. exit(-1);
  1492. geometry_next:
  1493. optarg += strspn(optarg, " ");
  1494. if (*optarg == ',') {
  1495. optarg += 1;
  1496. } else if (*optarg == '\0') {
  1497. break;
  1498. } else {
  1499. goto geometry_unknown;
  1500. }
  1501. }
  1502. break;
  1503. }
  1504. case OPT_STEP: {
  1505. char *parsed = NULL;
  1506. bench_step_start = strtoumax(optarg, &parsed, 0);
  1507. bench_step_stop = -1;
  1508. bench_step_step = 1;
  1509. // allow empty string for start=0
  1510. if (parsed == optarg) {
  1511. bench_step_start = 0;
  1512. }
  1513. optarg = parsed + strspn(parsed, " ");
  1514. if (*optarg != ',' && *optarg != '\0') {
  1515. goto step_unknown;
  1516. }
  1517. if (*optarg == ',') {
  1518. optarg += 1;
  1519. bench_step_stop = strtoumax(optarg, &parsed, 0);
  1520. // allow empty string for stop=end
  1521. if (parsed == optarg) {
  1522. bench_step_stop = -1;
  1523. }
  1524. optarg = parsed + strspn(parsed, " ");
  1525. if (*optarg != ',' && *optarg != '\0') {
  1526. goto step_unknown;
  1527. }
  1528. if (*optarg == ',') {
  1529. optarg += 1;
  1530. bench_step_step = strtoumax(optarg, &parsed, 0);
  1531. // allow empty string for stop=1
  1532. if (parsed == optarg) {
  1533. bench_step_step = 1;
  1534. }
  1535. optarg = parsed + strspn(parsed, " ");
  1536. if (*optarg != '\0') {
  1537. goto step_unknown;
  1538. }
  1539. }
  1540. } else {
  1541. // single value = stop only
  1542. bench_step_stop = bench_step_start;
  1543. bench_step_start = 0;
  1544. }
  1545. break;
  1546. step_unknown:
  1547. fprintf(stderr, "error: invalid step: %s\n", optarg);
  1548. exit(-1);
  1549. }
  1550. case OPT_DISK:
  1551. bench_disk_path = optarg;
  1552. break;
  1553. case OPT_TRACE:
  1554. bench_trace_path = optarg;
  1555. break;
  1556. case OPT_READ_SLEEP: {
  1557. char *parsed = NULL;
  1558. double read_sleep = strtod(optarg, &parsed);
  1559. if (parsed == optarg) {
  1560. fprintf(stderr, "error: invalid read-sleep: %s\n", optarg);
  1561. exit(-1);
  1562. }
  1563. bench_read_sleep = read_sleep*1.0e9;
  1564. break;
  1565. }
  1566. case OPT_PROG_SLEEP: {
  1567. char *parsed = NULL;
  1568. double prog_sleep = strtod(optarg, &parsed);
  1569. if (parsed == optarg) {
  1570. fprintf(stderr, "error: invalid prog-sleep: %s\n", optarg);
  1571. exit(-1);
  1572. }
  1573. bench_prog_sleep = prog_sleep*1.0e9;
  1574. break;
  1575. }
  1576. case OPT_ERASE_SLEEP: {
  1577. char *parsed = NULL;
  1578. double erase_sleep = strtod(optarg, &parsed);
  1579. if (parsed == optarg) {
  1580. fprintf(stderr, "error: invalid erase-sleep: %s\n", optarg);
  1581. exit(-1);
  1582. }
  1583. bench_erase_sleep = erase_sleep*1.0e9;
  1584. break;
  1585. }
  1586. // done parsing
  1587. case -1:
  1588. goto getopt_done;
  1589. // unknown arg, getopt prints a message for us
  1590. default:
  1591. exit(-1);
  1592. }
  1593. }
  1594. getopt_done: ;
  1595. if (argc > optind) {
  1596. // reset our bench identifier list
  1597. bench_ids = NULL;
  1598. bench_id_count = 0;
  1599. bench_id_capacity = 0;
  1600. }
  1601. // parse bench identifier, if any, cannibalizing the arg in the process
  1602. for (; argc > optind; optind++) {
  1603. bench_define_t *defines = NULL;
  1604. size_t define_count = 0;
  1605. // parse name, can be suite or case
  1606. char *name = argv[optind];
  1607. char *defines_ = strchr(name, ':');
  1608. if (defines_) {
  1609. *defines_ = '\0';
  1610. defines_ += 1;
  1611. }
  1612. // remove optional path and .toml suffix
  1613. char *slash = strrchr(name, '/');
  1614. if (slash) {
  1615. name = slash+1;
  1616. }
  1617. size_t name_len = strlen(name);
  1618. if (name_len > 5 && strcmp(&name[name_len-5], ".toml") == 0) {
  1619. name[name_len-5] = '\0';
  1620. }
  1621. if (defines_) {
  1622. // parse defines
  1623. while (true) {
  1624. char *parsed;
  1625. size_t d = leb16_parse(defines_, &parsed);
  1626. intmax_t v = leb16_parse(parsed, &parsed);
  1627. if (parsed == defines_) {
  1628. break;
  1629. }
  1630. defines_ = parsed;
  1631. if (d >= define_count) {
  1632. // align to power of two to avoid any superlinear growth
  1633. size_t ncount = 1 << lfs_npw2(d+1);
  1634. defines = realloc(defines,
  1635. ncount*sizeof(bench_define_t));
  1636. memset(defines+define_count, 0,
  1637. (ncount-define_count)*sizeof(bench_define_t));
  1638. define_count = ncount;
  1639. }
  1640. defines[d] = BENCH_LIT(v);
  1641. }
  1642. }
  1643. // append to identifier list
  1644. *(bench_id_t*)mappend(
  1645. (void**)&bench_ids,
  1646. sizeof(bench_id_t),
  1647. &bench_id_count,
  1648. &bench_id_capacity) = (bench_id_t){
  1649. .name = name,
  1650. .defines = defines,
  1651. .define_count = define_count,
  1652. };
  1653. }
  1654. // do the thing
  1655. op();
  1656. // cleanup (need to be done for valgrind benching)
  1657. bench_define_cleanup();
  1658. if (bench_overrides) {
  1659. for (size_t i = 0; i < bench_override_count; i++) {
  1660. free((void*)bench_overrides[i].defines);
  1661. }
  1662. free((void*)bench_overrides);
  1663. }
  1664. if (bench_geometry_capacity) {
  1665. free((void*)bench_geometries);
  1666. }
  1667. if (bench_id_capacity) {
  1668. for (size_t i = 0; i < bench_id_count; i++) {
  1669. free((void*)bench_ids[i].defines);
  1670. }
  1671. free((void*)bench_ids);
  1672. }
  1673. }