/* * nghttp3 * * Copyright (c) 2019 nghttp3 contributors * Copyright (c) 2017 ngtcp2 contributors * Copyright (c) 2012 nghttp2 contributors * * Permission is hereby granted, free of charge, to any person obtaining * a copy of this software and associated documentation files (the * "Software"), to deal in the Software without restriction, including * without limitation the rights to use, copy, modify, merge, publish, * distribute, sublicense, and/or sell copies of the Software, and to * permit persons to whom the Software is furnished to do so, subject to * the following conditions: * * The above copyright notice and this permission notice shall be * included in all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE * LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION * OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */ #include "nghttp3_map.h" #include #include #include #include "nghttp3_conv.h" #define NGHTTP3_INITIAL_TABLE_LENBITS 4 void nghttp3_map_init(nghttp3_map *map, const nghttp3_mem *mem) { map->mem = mem; map->hashbits = 0; map->table = NULL; map->size = 0; } void nghttp3_map_free(nghttp3_map *map) { if (!map) { return; } nghttp3_mem_free(map->mem, map->table); } int nghttp3_map_each(const nghttp3_map *map, int (*func)(void *data, void *ptr), void *ptr) { int rv; size_t i; nghttp3_map_bucket *bkt; size_t tablelen; if (map->size == 0) { return 0; } tablelen = 1u << map->hashbits; for (i = 0; i < tablelen; ++i) { bkt = &map->table[i]; if (bkt->data == NULL) { continue; } rv = func(bkt->data, ptr); if (rv != 0) { return rv; } } return 0; } static size_t hash(nghttp3_map_key_type key, size_t bits) { return (size_t)((key * 11400714819323198485llu) >> (64 - bits)); } static void map_bucket_swap(nghttp3_map_bucket *a, nghttp3_map_bucket *b) { nghttp3_map_bucket c = *a; *a = *b; *b = c; } #ifndef WIN32 void nghttp3_map_print_distance(const nghttp3_map *map) { size_t i; size_t idx; nghttp3_map_bucket *bkt; size_t tablelen; if (map->size == 0) { return; } tablelen = 1u << map->hashbits; for (i = 0; i < tablelen; ++i) { bkt = &map->table[i]; if (bkt->data == NULL) { fprintf(stderr, "@%zu \n", i); continue; } idx = hash(bkt->key, map->hashbits); fprintf(stderr, "@%zu hash=%zu key=%" PRIu64 " base=%zu distance=%u\n", i, hash(bkt->key, map->hashbits), bkt->key, idx, bkt->psl); } } #endif /* !defined(WIN32) */ static int insert(nghttp3_map_bucket *table, size_t hashbits, nghttp3_map_key_type key, void *data) { size_t idx = hash(key, hashbits); nghttp3_map_bucket b = {0, key, data}, *bkt; size_t mask = (1u << hashbits) - 1; for (;;) { bkt = &table[idx]; if (bkt->data == NULL) { *bkt = b; return 0; } if (b.psl > bkt->psl) { map_bucket_swap(bkt, &b); } else if (bkt->key == key) { /* TODO This check is just a waste after first swap or if this function is called from map_resize. That said, there is no difference with or without this conditional in performance wise. */ return NGHTTP3_ERR_INVALID_ARGUMENT; } ++b.psl; idx = (idx + 1) & mask; } } static int map_resize(nghttp3_map *map, size_t new_hashbits) { size_t i; nghttp3_map_bucket *new_table; nghttp3_map_bucket *bkt; size_t tablelen; int rv; (void)rv; new_table = nghttp3_mem_calloc(map->mem, 1u << new_hashbits, sizeof(nghttp3_map_bucket)); if (new_table == NULL) { return NGHTTP3_ERR_NOMEM; } if (map->size) { tablelen = 1u << map->hashbits; for (i = 0; i < tablelen; ++i) { bkt = &map->table[i]; if (bkt->data == NULL) { continue; } rv = insert(new_table, new_hashbits, bkt->key, bkt->data); assert(0 == rv); } } nghttp3_mem_free(map->mem, map->table); map->hashbits = new_hashbits; map->table = new_table; return 0; } int nghttp3_map_insert(nghttp3_map *map, nghttp3_map_key_type key, void *data) { int rv; assert(data); /* Load factor is 0.75 */ /* Under the very initial condition, that is map->size == 0 and map->hashbits == 0, 4 > 3 still holds nicely. */ if ((map->size + 1) * 4 > (1u << map->hashbits) * 3) { if (map->hashbits) { rv = map_resize(map, map->hashbits + 1); if (rv != 0) { return rv; } } else { rv = map_resize(map, NGHTTP3_INITIAL_TABLE_LENBITS); if (rv != 0) { return rv; } } } rv = insert(map->table, map->hashbits, key, data); if (rv != 0) { return rv; } ++map->size; return 0; } void *nghttp3_map_find(const nghttp3_map *map, nghttp3_map_key_type key) { size_t idx; nghttp3_map_bucket *bkt; size_t psl = 0; size_t mask; if (map->size == 0) { return NULL; } idx = hash(key, map->hashbits); mask = (1u << map->hashbits) - 1; for (;;) { bkt = &map->table[idx]; if (bkt->data == NULL || psl > bkt->psl) { return NULL; } if (bkt->key == key) { return bkt->data; } ++psl; idx = (idx + 1) & mask; } } int nghttp3_map_remove(nghttp3_map *map, nghttp3_map_key_type key) { size_t idx; nghttp3_map_bucket *b, *bkt; size_t psl = 0; size_t mask; if (map->size == 0) { return NGHTTP3_ERR_INVALID_ARGUMENT; } idx = hash(key, map->hashbits); mask = (1u << map->hashbits) - 1; for (;;) { bkt = &map->table[idx]; if (bkt->data == NULL || psl > bkt->psl) { return NGHTTP3_ERR_INVALID_ARGUMENT; } if (bkt->key == key) { b = bkt; idx = (idx + 1) & mask; for (;;) { bkt = &map->table[idx]; if (bkt->data == NULL || bkt->psl == 0) { b->data = NULL; break; } --bkt->psl; *b = *bkt; b = bkt; idx = (idx + 1) & mask; } --map->size; return 0; } ++psl; idx = (idx + 1) & mask; } } void nghttp3_map_clear(nghttp3_map *map) { if (map->size == 0) { return; } memset(map->table, 0, sizeof(*map->table) * (1u << map->hashbits)); map->size = 0; } size_t nghttp3_map_size(const nghttp3_map *map) { return map->size; }