123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734 | // Hash table (aka Dictionary) Implementation
// Hash keys and values are stored *by value*
// The hash insertion/lookup implementation is based on Lua's tables,
// which use a chained scatter with Brent's variation.
#include <assert.h>
#include <gc.h>
#include <stdarg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/param.h>
#include "c_strings.h"
#include "datatypes.h"
#include "lists.h"
#include "memory.h"
#include "metamethods.h"
#include "pointers.h"
#include "siphash.h"
#include "structs.h"
#include "tables.h"
#include "text.h"
#include "types.h"
#include "util.h"
// Helper accessors for type functions/values:
#define HASH_KEY(t, k) (generic_hash((k), type->TableInfo.key) % ((t).bucket_info->count))
#define EQUAL_KEYS(x, y) (generic_equal((x), (y), type->TableInfo.key))
#define END_OF_CHAIN UINT32_MAX
#define GET_ENTRY(t, i) ((t).entries.data + (t).entries.stride * (i))
static TypeInfo_t MemoryPointer = {
.size = sizeof(void *),
.align = __alignof__(void *),
.tag = PointerInfo,
.PointerInfo =
{
.sigil = "@",
.pointed = &Memory$info,
},
.metamethods = Pointer$metamethods,
};
const TypeInfo_t CStrToVoidStarTable = {
.size = sizeof(Table_t),
.align = __alignof__(Table_t),
.tag = TableInfo,
.TableInfo = {.key = &CString$info, .value = &MemoryPointer},
.metamethods = Table$metamethods,
};
PUREFUNC static INLINE size_t entry_size(const TypeInfo_t *info) {
size_t size = (size_t)info->TableInfo.key->size;
if (info->TableInfo.value->align > 1 && size % (size_t)info->TableInfo.value->align)
size += (size_t)info->TableInfo.value->align - (size % (size_t)info->TableInfo.value->align); // padding
size += (size_t)info->TableInfo.value->size;
if (info->TableInfo.key->align > 1 && size % (size_t)info->TableInfo.key->align)
size += (size_t)info->TableInfo.key->align - (size % (size_t)info->TableInfo.key->align); // padding
return size;
}
PUREFUNC static INLINE size_t value_offset(const TypeInfo_t *info) {
size_t offset = (size_t)info->TableInfo.key->size;
if ((size_t)info->TableInfo.value->align > 1 && offset % (size_t)info->TableInfo.value->align)
offset += (size_t)info->TableInfo.value->align - (offset % (size_t)info->TableInfo.value->align); // padding
return offset;
}
static void maybe_copy_on_write(Table_t *t, const TypeInfo_t *type) {
if (t->entries.data_refcount != 0) List$compact(&t->entries, (int64_t)entry_size(type));
if (t->bucket_info && t->bucket_info->data_refcount != 0) {
size_t size = sizeof(bucket_info_t) + sizeof(bucket_t[t->bucket_info->count]);
t->bucket_info = memcpy(GC_MALLOC(size), t->bucket_info, size);
t->bucket_info->data_refcount = 0;
}
}
// Return address of value or NULL
PUREFUNC public void *Table$get_raw(Table_t t, const void *key, const TypeInfo_t *type) {
assert(type->tag == TableInfo);
if (!key || !t.bucket_info) return NULL;
uint64_t hash = HASH_KEY(t, key);
bucket_t *buckets = t.bucket_info->buckets;
for (uint64_t i = hash; buckets[i].occupied; i = buckets[i].next_bucket) {
void *entry = GET_ENTRY(t, buckets[i].index);
if (EQUAL_KEYS(entry, key)) {
return entry + value_offset(type);
}
if (buckets[i].next_bucket == END_OF_CHAIN) break;
}
return NULL;
}
PUREFUNC public void *Table$get(Table_t t, const void *key, const TypeInfo_t *type) {
assert(type->tag == TableInfo);
for (const Table_t *iter = &t; iter; iter = iter->fallback) {
void *ret = Table$get_raw(*iter, key, type);
if (ret) return ret;
}
return NULL;
}
static void Table$set_bucket(Table_t *t, const void *entry, int32_t index, const TypeInfo_t *type) {
assert(t->bucket_info);
const void *key = entry;
bucket_t *buckets = t->bucket_info->buckets;
uint64_t hash = HASH_KEY(*t, key);
bucket_t *bucket = &buckets[hash];
if (!bucket->occupied) {
// Empty space:
bucket->occupied = 1;
bucket->index = index;
bucket->next_bucket = END_OF_CHAIN;
return;
}
while (buckets[t->bucket_info->last_free].occupied) {
assert(t->bucket_info->last_free > 0);
--t->bucket_info->last_free;
}
uint64_t collided_hash = HASH_KEY(*t, GET_ENTRY(*t, bucket->index));
if (collided_hash != hash) { // Collided with a mid-chain entry
// Find chain predecessor
uint64_t predecessor = collided_hash;
while (buckets[predecessor].next_bucket != hash)
predecessor = buckets[predecessor].next_bucket;
// Move mid-chain entry to free space and update predecessor
buckets[predecessor].next_bucket = t->bucket_info->last_free;
buckets[t->bucket_info->last_free] = *bucket;
bucket->occupied = 1;
bucket->index = index;
bucket->next_bucket = END_OF_CHAIN;
} else { // Collided with the start of a chain, put the new entry in chain
// position #2
buckets[t->bucket_info->last_free] =
(bucket_t){.occupied = 1, .index = index, .next_bucket = bucket->next_bucket};
bucket->next_bucket = t->bucket_info->last_free;
}
}
static void hashmap_resize_buckets(Table_t *t, uint32_t new_capacity, const TypeInfo_t *type) {
if (unlikely(new_capacity > TABLE_MAX_BUCKETS))
fail("Table has exceeded the maximum table size (2^31) and cannot grow "
"further!");
size_t alloc_size = sizeof(bucket_info_t) + sizeof(bucket_t[new_capacity]);
t->bucket_info = GC_MALLOC_ATOMIC(alloc_size);
memset(t->bucket_info->buckets, 0, sizeof(bucket_t[new_capacity]));
t->bucket_info->count = new_capacity;
t->bucket_info->last_free = new_capacity - 1;
// Rehash:
for (int64_t i = 0; i < (int64_t)Table$length(*t); i++) {
Table$set_bucket(t, GET_ENTRY(*t, i), i, type);
}
}
// Return address of value
#ifdef __GNUC__
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wstack-protector"
#endif
public
void *Table$reserve(Table_t *t, const void *key, const void *value, const TypeInfo_t *type) {
assert(type->tag == TableInfo);
if (!t || !key) return NULL;
t->hash = 0;
int64_t key_size = type->TableInfo.key->size, value_size = type->TableInfo.value->size;
if (!t->bucket_info || t->bucket_info->count == 0) {
hashmap_resize_buckets(t, 8, type);
} else {
// Check if we are clobbering a value:
void *value_home = Table$get_raw(*t, key, type);
if (value_home) { // Update existing slot
// Ensure that `value_home` is still inside t->entries, even if COW occurs
ptrdiff_t offset = value_home - t->entries.data;
maybe_copy_on_write(t, type);
value_home = t->entries.data + offset;
if (value && value_size > 0) memcpy(value_home, value, (size_t)value_size);
return value_home;
}
}
// Otherwise add a new entry:
// Resize buckets if necessary
if (t->entries.length >= t->bucket_info->count) {
// Current resize policy: +50% at a time:
uint32_t newsize = MAX(8, (uint32_t)(3 * t->bucket_info->count) / 2);
if (unlikely(newsize > TABLE_MAX_BUCKETS)) newsize = TABLE_MAX_BUCKETS;
hashmap_resize_buckets(t, newsize, type);
}
if (!value && value_size > 0) {
for (Table_t *iter = t->fallback; iter; iter = iter->fallback) {
value = Table$get_raw(*iter, key, type);
if (value) break;
}
}
maybe_copy_on_write(t, type);
char buf[entry_size(type)];
memset(buf, 0, sizeof(buf));
memcpy(buf, key, (size_t)key_size);
if (value && value_size > 0) memcpy(buf + value_offset(type), value, (size_t)value_size);
else if (value_size > 0) memset(buf + value_offset(type), 0, (size_t)value_size);
List$insert(&t->entries, buf, I(0), (int64_t)entry_size(type));
int64_t entry_index = (int64_t)t->entries.length - 1;
void *entry = GET_ENTRY(*t, entry_index);
Table$set_bucket(t, entry, entry_index, type);
return entry + value_offset(type);
}
#ifdef __GNUC__
#pragma GCC diagnostic pop
#endif
public
void Table$set(Table_t *t, const void *key, const void *value, const TypeInfo_t *type) {
assert(type->tag == TableInfo);
(void)Table$reserve(t, key, value, type);
}
public
void Table$remove(Table_t *t, const void *key, const TypeInfo_t *type) {
assert(type->tag == TableInfo);
if (!t || Table$length(*t) == 0) return;
// TODO: this work doesn't need to be done if the key is already missing
maybe_copy_on_write(t, type);
// If unspecified, pop the last key:
if (!key) key = GET_ENTRY(*t, (int64_t)t->entries.length - 1);
// Steps: look up the bucket for the removed key
// If missing, then return immediately
// Swap last key/value into the removed bucket's index1
// Zero out the last key/value and decrement the count
// Find the last key/value's bucket and update its index1
// Look up the bucket for the removed key
// If bucket is first in chain:
// Move bucket->next to bucket's spot
// zero out bucket->next's old spot
// maybe update lastfree_index1 to second-in-chain's index
// Else:
// set prev->next = bucket->next
// zero out bucket
// maybe update lastfree_index1 to removed bucket's index
uint64_t hash = HASH_KEY(*t, key);
bucket_t *bucket, *prev = NULL;
for (uint64_t i = hash; t->bucket_info->buckets[i].occupied; i = t->bucket_info->buckets[i].next_bucket) {
if (EQUAL_KEYS(GET_ENTRY(*t, t->bucket_info->buckets[i].index), key)) {
bucket = &t->bucket_info->buckets[i];
goto found_it;
}
if (t->bucket_info->buckets[i].next_bucket == END_OF_CHAIN) return;
prev = &t->bucket_info->buckets[i];
}
return;
found_it:;
assert(bucket->occupied);
t->hash = 0;
// Always remove the last entry. If we need to remove some other entry,
// swap the other entry into the last position and then remove the last
// entry. This disturbs the ordering of the table, but keeps removal O(1)
// instead of O(N)
int64_t last_entry = (int64_t)t->entries.length - 1;
if (bucket->index != last_entry) {
// Find the bucket that points to the last entry's index:
uint64_t i = HASH_KEY(*t, GET_ENTRY(*t, last_entry));
while (t->bucket_info->buckets[i].index != last_entry)
i = t->bucket_info->buckets[i].next_bucket;
// Update the bucket to point to the last entry's new home (the space
// where the removed entry currently sits):
t->bucket_info->buckets[i].index = bucket->index;
// Clobber the entry being removed (in the middle of the list) with
// the last entry:
memcpy(GET_ENTRY(*t, bucket->index), GET_ENTRY(*t, last_entry), entry_size(type));
}
// Last entry is being removed, so clear it out to be safe:
memset(GET_ENTRY(*t, last_entry), 0, entry_size(type));
List$remove_at(&t->entries, I((int64_t)t->entries.length), I(1), (int64_t)entry_size(type));
int64_t bucket_to_clear;
if (prev) { // Middle (or end) of a chain
bucket_to_clear = (bucket - t->bucket_info->buckets);
prev->next_bucket = bucket->next_bucket;
} else if (bucket->next_bucket != END_OF_CHAIN) { // Start of a chain
bucket_to_clear = bucket->next_bucket;
*bucket = t->bucket_info->buckets[bucket_to_clear];
} else { // Empty chain
bucket_to_clear = (bucket - t->bucket_info->buckets);
}
t->bucket_info->buckets[bucket_to_clear] = (bucket_t){0};
if (bucket_to_clear > t->bucket_info->last_free) t->bucket_info->last_free = bucket_to_clear;
}
CONSTFUNC public void *Table$entry(Table_t t, int64_t n) {
if (n < 1 || n > (int64_t)Table$length(t)) return NULL;
return GET_ENTRY(t, n - 1);
}
public
void Table$clear(Table_t *t) {
*t = EMPTY_TABLE;
}
public
Table_t Table$sorted(Table_t t, const TypeInfo_t *type) {
Closure_t cmp = (Closure_t){.fn = generic_compare, .userdata = (void *)type->TableInfo.key};
List_t entries = List$sorted(t.entries, cmp, (int64_t)entry_size(type));
return Table$from_entries(entries, type);
}
PUREFUNC public bool Table$equal(const void *vx, const void *vy, const TypeInfo_t *type) {
if (vx == vy) return true;
Table_t *x = (Table_t *)vx, *y = (Table_t *)vy;
if (x->hash && y->hash && x->hash != y->hash) return false;
assert(type->tag == TableInfo);
if (x->entries.length != y->entries.length) return false;
if ((x->fallback != NULL) != (y->fallback != NULL)) return false;
const TypeInfo_t *value_type = type->TableInfo.value;
size_t offset = value_offset(type);
for (int64_t i = 0; i < (int64_t)x->entries.length; i++) {
void *x_key = x->entries.data + i * x->entries.stride;
void *y_value = Table$get_raw(*y, x_key, type);
if (!y_value) return false;
if (value_type->size > 0) {
void *x_value = x_key + offset;
if (!generic_equal(y_value, x_value, value_type)) return false;
}
}
return true;
}
PUREFUNC public int32_t Table$compare(const void *vx, const void *vy, const TypeInfo_t *type) {
if (vx == vy) return 0;
Table_t *x = (Table_t *)vx, *y = (Table_t *)vy;
assert(type->tag == TableInfo);
__typeof(type->TableInfo) table = type->TableInfo;
// Sort empty tables before non-empty tables:
if (x->entries.length == 0 || y->entries.length == 0) return ((x->entries.length > 0) - (y->entries.length > 0));
// Table comparison rules:
// - If two tables have different keys, then compare as if comparing a
// sorted list of the keys of the two tables:
// `x.keys.sorted() <> y.keys.sorted()`
// - Otherwise, compare as if comparing lists of values for the sorted key
// lists:
// `[x[k] for k in x.keys.sorted()] <> [y[k] for k in y.keys.sorted()]`
//
// We can do this in _linear_ time if we find the smallest `k` such that
// `x[k] != y[k]`, as well as the largest key in `x` and `y`.
void *mismatched_key = NULL, *max_x_key = NULL;
for (int64_t i = 0; i < (int64_t)x->entries.length; i++) {
void *key = x->entries.data + x->entries.stride * i;
if (max_x_key == NULL || generic_compare(key, max_x_key, table.key) > 0) max_x_key = key;
void *x_value = key + value_offset(type);
void *y_value = Table$get_raw(*y, key, type);
if (!y_value || (table.value->size > 0 && !generic_equal(x_value, y_value, table.value))) {
if (mismatched_key == NULL || generic_compare(key, mismatched_key, table.key) < 0) mismatched_key = key;
}
}
// If the keys are not all equal, we gotta check to see if there exists a
// `y[k]` such that `k` is smaller than all keys that `x` has and `y` doesn't:
void *max_y_key = NULL;
for (int64_t i = 0; i < (int64_t)y->entries.length; i++) {
void *key = y->entries.data + y->entries.stride * i;
if (max_y_key == NULL || generic_compare(key, max_y_key, table.key) > 0) max_y_key = key;
void *y_value = key + value_offset(type);
void *x_value = Table$get_raw(*x, key, type);
if (!x_value || (table.value->size > 0 && !generic_equal(x_value, y_value, table.value))) {
if (mismatched_key == NULL || generic_compare(key, mismatched_key, table.key) < 0) mismatched_key = key;
}
}
if (mismatched_key) {
void *x_value = Table$get_raw(*x, mismatched_key, type);
void *y_value = Table$get_raw(*y, mismatched_key, type);
if (x_value && y_value) {
return generic_compare(x_value, y_value, table.value);
} else if (y_value) {
// The smallest mismatched key is in Y, but not X.
// In this case, we should judge if the key is smaller than *any*
// key in X or if it's bigger than *every* key in X.
// Example 1:
// x={10, 20, 30} > y={10, 20, 25, 30}
// The smallest mismatched key is `25`, and we know that `x` is
// larger than `y` because `30 > 25`.
// Example 2:
// x={10, 20, 30} > y={10, 20, 30, 999}
// The smallest mismatched key is `999`, and we know that `x` is
// smaller than `y` because `30 < 999`.
return max_x_key ? generic_compare(max_x_key, mismatched_key, table.key) : -1;
} else {
assert(x_value);
// The smallest mismatched key is in X, but not Y. The same logic
// above applies, but reversed.
return max_y_key ? -generic_compare(max_y_key, mismatched_key, table.key) : 1;
}
}
assert(x->entries.length == y->entries.length);
// Assuming keys are the same, compare values:
if (table.value->size > 0) {
for (int64_t i = 0; i < (int64_t)x->entries.length; i++) {
void *key = x->entries.data + x->entries.stride * i;
void *x_value = key + value_offset(type);
void *y_value = Table$get_raw(*y, key, type);
int32_t diff = generic_compare(x_value, y_value, table.value);
if (diff != 0) return diff;
}
}
if (!x->fallback != !y->fallback) {
return (!x->fallback) - (!y->fallback);
} else if (x->fallback && y->fallback) {
return generic_compare(x->fallback, y->fallback, type);
}
return 0;
}
PUREFUNC public uint64_t Table$hash(const void *obj, const TypeInfo_t *type) {
assert(type->tag == TableInfo);
Table_t *t = (Table_t *)obj;
if (t->hash != 0) return t->hash;
// Table hashes are computed as:
// hash(t.length, (xor: t.keys), (xor: t.values), t.fallback)
// Where fallback and default hash to zero if absent
__typeof(type->TableInfo) table = type->TableInfo;
uint64_t keys_hash = 0, values_hash = 0;
size_t offset = value_offset(type);
if (table.value->size > 0) {
for (int64_t i = 0; i < (int64_t)t->entries.length; i++) {
keys_hash ^= generic_hash(t->entries.data + i * t->entries.stride, table.key);
values_hash ^= generic_hash(t->entries.data + i * t->entries.stride + offset, table.value);
}
} else {
for (int64_t i = 0; i < (int64_t)t->entries.length; i++)
keys_hash ^= generic_hash(t->entries.data + i * t->entries.stride, table.key);
}
volatile struct {
int64_t length;
uint64_t keys_hash, values_hash, fallback_hash;
} components = {
(int64_t)t->entries.length,
keys_hash,
values_hash,
t->fallback ? Table$hash(t->fallback, type) : 0,
};
t->hash = siphash24((void *)&components, sizeof(components));
if unlikely (t->hash == 0) t->hash = 1234567;
return t->hash;
}
public
Text_t Table$as_text(const void *obj, bool colorize, const TypeInfo_t *type) {
Table_t *t = (Table_t *)obj;
assert(type->tag == TableInfo);
__typeof(type->TableInfo) table = type->TableInfo;
if (!t) {
return table.value->size > 0 ? Text$concat(Text("{"), generic_as_text(NULL, false, table.key), Text(":"),
generic_as_text(NULL, false, table.value), Text("}"))
: Text$concat(Text("{"), generic_as_text(NULL, false, table.key), Text("}"));
}
int64_t val_off = (int64_t)value_offset(type);
Text_t text = Text("{");
for (int64_t i = 0, length = (int64_t)Table$length(*t); i < length; i++) {
if (i > 0) text = Text$concat(text, Text(", "));
void *entry = GET_ENTRY(*t, i);
text = Text$concat(text, generic_as_text(entry, colorize, table.key));
if (table.value->size > 0)
text = Text$concat(text, Text(": "), generic_as_text(entry + val_off, colorize, table.value));
}
if (t->fallback) {
text = Text$concat(text, Text("; fallback="), Table$as_text(t->fallback, colorize, type));
}
text = Text$concat(text, Text("}"));
return text;
}
public
Table_t Table$from_entries(List_t entries, const TypeInfo_t *type) {
assert(type->tag == TableInfo);
if (entries.length == 0) return (Table_t){};
Table_t t = EMPTY_TABLE;
int64_t length = (int64_t)entries.length + (int64_t)entries.length / 4;
size_t alloc_size = sizeof(bucket_info_t) + sizeof(bucket_t[length]);
t.bucket_info = GC_MALLOC_ATOMIC(alloc_size);
memset(t.bucket_info->buckets, 0, sizeof(bucket_t[length]));
t.bucket_info->count = length;
t.bucket_info->last_free = length - 1;
size_t offset = value_offset(type);
for (int64_t i = 0; i < (int64_t)entries.length; i++) {
void *key = entries.data + i * entries.stride;
Table$set(&t, key, key + offset, type);
}
return t;
}
// "set intersection" in formal terms
public
Table_t Table$intersection(Table_t a, Table_t b, const TypeInfo_t *type) {
// Return a table such that t[k]==a[k] for all k such that a.has(k), b.has(k),
// and a[k]==b[k]
Table_t result = EMPTY_TABLE;
const size_t offset = value_offset(type);
for (Table_t *t = &a; t; t = t->fallback) {
for (int64_t i = 0; i < (int64_t)Table$length(*t); i++) {
void *key = GET_ENTRY(*t, i);
void *a_value = key + offset;
void *b_value = Table$get(b, key, type);
if (b_value && (type->TableInfo.value->size == 0 || generic_equal(a_value, b_value, type->TableInfo.value)))
Table$set(&result, key, a_value, type);
}
}
return result;
}
// "set union" in formal terms
public
Table_t Table$with(Table_t a, Table_t b, const TypeInfo_t *type) {
// return a table such that t[k]==b[k] for all k such that b.has(k), and
// t[k]==a[k] for all k such that a.has(k) and not b.has(k)
Table_t result = EMPTY_TABLE;
const size_t offset = value_offset(type);
for (Table_t *t = &a; t; t = t->fallback) {
for (int64_t i = 0; i < (int64_t)Table$length(*t); i++) {
void *key = GET_ENTRY(*t, i);
Table$set(&result, key, key + offset, type);
}
}
for (Table_t *t = &b; t; t = t->fallback) {
for (int64_t i = 0; i < (int64_t)Table$length(*t); i++) {
void *key = GET_ENTRY(*t, i);
Table$set(&result, key, key + offset, type);
}
}
return result;
}
// "disjunctive union" or "symmetric difference" in formal terms
public
Table_t Table$difference(Table_t a, Table_t b, const TypeInfo_t *type) {
// return a table with elements in `a` or `b`, but not both
Table_t result = EMPTY_TABLE;
const size_t offset = value_offset(type);
for (Table_t *t = &a; t; t = t->fallback) {
for (int64_t i = 0; i < (int64_t)Table$length(*t); i++) {
void *key = GET_ENTRY(*t, i);
if (Table$get(b, key, type) == NULL) Table$set(&result, key, key + offset, type);
}
}
for (Table_t *t = &b; t; t = t->fallback) {
for (int64_t i = 0; i < (int64_t)Table$length(*t); i++) {
void *key = GET_ENTRY(*t, i);
if (Table$get(a, key, type) == NULL) Table$set(&result, key, key + offset, type);
}
}
return result;
}
// "without" is "set difference" in formal terms
public
Table_t Table$without(Table_t a, Table_t b, const TypeInfo_t *type) {
// Return a table such that t[k]==a[k] for all k such that not b.has(k) or
// b[k] != a[k]
Table_t result = EMPTY_TABLE;
const size_t offset = value_offset(type);
for (Table_t *t = &a; t; t = t->fallback) {
for (int64_t i = 0; i < (int64_t)Table$length(*t); i++) {
void *key = GET_ENTRY(*t, i);
void *a_value = key + offset;
void *b_value = Table$get(b, key, type);
if (!b_value
|| (type->TableInfo.value->size > 0 && !generic_equal(a_value, b_value, type->TableInfo.value)))
Table$set(&result, key, a_value, type);
}
}
return result;
}
public
Table_t Table$with_fallback(Table_t t, OptionalTable_t fallback) {
if (fallback.entries.length <= 0) {
t.fallback = NULL;
return t;
} else {
TABLE_INCREF(fallback);
t.fallback = GC_MALLOC(sizeof(Table_t));
*t.fallback = fallback;
return t;
}
}
PUREFUNC public bool Table$is_subset_of(Table_t a, Table_t b, bool strict, const TypeInfo_t *type) {
if (a.entries.length > b.entries.length || (strict && a.entries.length == b.entries.length)) return false;
for (int64_t i = 0; i < (int64_t)Table$length(a); i++) {
void *found = Table$get_raw(b, GET_ENTRY(a, i), type);
if (!found) return false;
}
return true;
}
PUREFUNC public bool Table$is_superset_of(Table_t a, Table_t b, bool strict, const TypeInfo_t *type) {
return Table$is_subset_of(b, a, strict, type);
}
PUREFUNC public void *Table$str_get(Table_t t, const char *key) {
void **ret = Table$get(t, &key, &CStrToVoidStarTable);
return ret ? *ret : NULL;
}
PUREFUNC public void *Table$str_get_raw(Table_t t, const char *key) {
void **ret = Table$get_raw(t, &key, &CStrToVoidStarTable);
return ret ? *ret : NULL;
}
public
void *Table$str_reserve(Table_t *t, const char *key, const void *value) {
return Table$reserve(t, &key, &value, &CStrToVoidStarTable);
}
public
void Table$str_set(Table_t *t, const char *key, const void *value) {
Table$set(t, &key, &value, &CStrToVoidStarTable);
}
public
void Table$str_remove(Table_t *t, const char *key) {
return Table$remove(t, &key, &CStrToVoidStarTable);
}
CONSTFUNC public void *Table$str_entry(Table_t t, int64_t n) {
return Table$entry(t, n);
}
PUREFUNC public bool Table$is_none(const void *obj, const TypeInfo_t *info) {
(void)info;
return ((Table_t *)obj)->entries.data == NULL;
}
public
void Table$serialize(const void *obj, FILE *out, Table_t *pointers, const TypeInfo_t *type) {
Table_t *t = (Table_t *)obj;
int64_t len = (int64_t)t->entries.length;
Int64$serialize(&len, out, pointers, &Int64$info);
size_t offset = value_offset(type);
for (int64_t i = 0; i < len; i++) {
_serialize(t->entries.data + i * t->entries.stride, out, pointers, type->TableInfo.key);
if (type->TableInfo.value->size > 0)
_serialize(t->entries.data + i * t->entries.stride + offset, out, pointers, type->TableInfo.value);
}
assert(fputc(t->fallback != NULL ? 1 : 0, out) != EOF);
if (t->fallback) Table$serialize(t->fallback, out, pointers, type);
}
public
void Table$deserialize(FILE *in, void *outval, List_t *pointers, const TypeInfo_t *type) {
int64_t len;
Int64$deserialize(in, &len, pointers, &Int$info);
Table_t t = EMPTY_TABLE;
char keybuf[256], valbuf[256];
char *key =
(size_t)type->TableInfo.key->size <= sizeof(keybuf) ? keybuf : GC_MALLOC((size_t)type->TableInfo.key->size);
char *value =
(size_t)type->TableInfo.value->size <= sizeof(valbuf) ? valbuf : GC_MALLOC((size_t)type->TableInfo.value->size);
for (int64_t i = 0; i < len; i++) {
_deserialize(in, key, pointers, type->TableInfo.key);
if (type->TableInfo.value->size > 0) _deserialize(in, value, pointers, type->TableInfo.value);
Table$set(&t, key, value, type);
}
if (fgetc(in) != 0) {
t.fallback = GC_MALLOC(sizeof(Table_t));
Table$deserialize(in, t.fallback, pointers, type);
}
*(Table_t *)outval = t;
}
public
const TypeInfo_t Present$$info = {.size = 0,
.align = 0,
.tag = StructInfo,
.metamethods = Struct$metamethods,
.StructInfo.name = "Present",
.StructInfo.num_fields = 0};
public
const Present$$type PRESENT = {};
|