#ifndef PURE_MODULE_LIST_H #define PURE_MODULE_LIST_H #include "result.h" #include "state.h" #include #include #include /* Executor paths that run once per module or app (loading, verifying, * starting, replacing, reading stored states) are built for size; events * stay built for speed. */ #if defined(__GNUC__) || defined(__clang__) #define PURE_COLD __attribute__((cold)) #else #define PURE_COLD #endif /* Runtime-owned lists of records for the module executor. An item is one * cell per field: a number, or text bytes the list owns. Every change made * during an event is logged; a failed event undoes the log in reverse and a * successful one frees what it replaced. */ typedef struct { double num; unsigned char *text; size_t size; } PureCell; typedef struct PureList PureList; /* An event's list changes; a removed item's cells wait in cells. */ typedef struct { void *entries; size_t count, capacity; PureCell *cells; size_t cell_count, cell_capacity; } PureUndo; /* Nodes and texts a list let go while a shared copy may still read them. */ typedef struct { void *entries; size_t count, capacity; } PureRetired; /* Items one after another, as a leaf of the list keeps them: positions start * to start + count - 1, each field's cells side by side (a number field's as * numbers, a text field's as spans). */ typedef struct { size_t start; unsigned count; union { const double *numbers; const PureSpan *texts; } column[16]; /* Where the run is in the list's tree, for the next one. */ const void *path[16]; uint8_t taken[16]; unsigned depth; } PureRun; /* A list holds up to PURE_LIST_ITEMS items, a run up to PURE_LIST_RUN. */ enum { PURE_LIST_ITEMS = 1 << 24, PURE_LIST_RUN = 32 }; PureList *pure_list_new(unsigned fields, const uint8_t *text_fields); void pure_list_free(PureList *); /* Let every item go (retired where a shared copy may read it). */ void pure_list_clear(PureList *); size_t pure_list_count(const PureList *); /* Share the items as they are with a read-only copy (for readers on other * threads), without copying them: from then on the list copies the nodes it * changes, and nodes and texts it lets go go to retired instead of being * freed, since the copy may still read them. The copy is freed with * pure_list_free, on any thread, when its last reference goes * (pure_list_hold takes one more). Only between events (no change waits to * be committed or undone). */ PureList *pure_list_share(PureList *, PureRetired *retired); void pure_list_hold(PureList *copy); /* Whether copy shares list's items as they are now. */ bool pure_list_current(const PureList *copy, const PureList *list); /* Which list, and its version: the same pair means the same items. */ void pure_list_stamp(const PureList *, uint64_t *id, uint64_t *version); /* Free what was retired while no copy that shared it remains. */ void pure_retired_free(PureRetired *); /* Insert a copy of cells (text bytes are copied) before position at. A NULL * log means the change is not undone. */ PureResult pure_list_insert(PureList *, size_t at, const PureCell *cells, PureUndo *); PureResult pure_list_remove(PureList *, size_t at, PureUndo *); PureResult pure_list_set(PureList *, size_t at, unsigned field, PureCell value, PureUndo *); PureCell pure_list_get(const PureList *, size_t at, unsigned field); /* The run holding position at (false past the end), and the run after * run (false at the end): for reading item after item without finding each. * Valid until the list changes. */ bool pure_list_run(const PureList *, size_t at, PureRun *); bool pure_list_next(const PureList *, PureRun *); /* In a list ordered by field (a keyed list): the first position whose item's * field does not order below key (numbers by value, texts by bytes), and * whether that item's field is key. */ size_t pure_list_seek(const PureList *, unsigned field, PureCell key, bool *found); /* The list's items ordered by field, as a keyed list keeps them: *out is NULL * when they already are, or a new list in that order with moved[position * before] = position after for every item. CONFLICT when two items have the * same key (nothing is made). */ PureResult pure_list_sorted(const PureList *, unsigned field, PureList **out, size_t *moved); /* A list may keep a stored copy in a draft: header bytes, then each item's * fields in order (a number as its binary64 bits, little-endian; a text as a * u32le length and its bytes). Every change splices the draft as well, and a * change the draft refuses (such as its size limit) does not happen. Undoing * an event changes only the list: the caller restores the draft's version. */ void pure_list_mirror(PureList *, PureDraft *, size_t header); /* Store every item after the header (the draft holds just the header). */ PureResult pure_list_write(PureList *); /* Append the items stored in bytes; each field is checked. Before mirroring. */ PureResult pure_list_read(PureList *, const unsigned char *bytes, size_t size); /* Undo the changes logged after mark (a count taken earlier), newest first. */ void pure_undo_rollback(PureUndo *, size_t mark); void pure_undo_commit(PureUndo *); void pure_undo_free(PureUndo *); #endif