1bcdc6a3bSJan Kneschke #include <string.h> 2bcdc6a3bSJan Kneschke #include <stdio.h> 3bcdc6a3bSJan Kneschke #include <stdlib.h> 4bcdc6a3bSJan Kneschke #include <limits.h> 5bcdc6a3bSJan Kneschke 6bcdc6a3bSJan Kneschke #include <errno.h> 7bcdc6a3bSJan Kneschke #include <assert.h> 8bcdc6a3bSJan Kneschke 9bcdc6a3bSJan Kneschke #include "array.h" 10bcdc6a3bSJan Kneschke #include "buffer.h" 11bcdc6a3bSJan Kneschke 12bcdc6a3bSJan Kneschke array *array_init(void) { 13bcdc6a3bSJan Kneschke array *a; 14bcdc6a3bSJan Kneschke 15bcdc6a3bSJan Kneschke a = calloc(1, sizeof(*a)); 16bcdc6a3bSJan Kneschke assert(a); 17bcdc6a3bSJan Kneschke 18bcdc6a3bSJan Kneschke a->next_power_of_2 = 1; 19bcdc6a3bSJan Kneschke 20bcdc6a3bSJan Kneschke return a; 21bcdc6a3bSJan Kneschke } 22bcdc6a3bSJan Kneschke 23bcdc6a3bSJan Kneschke void array_free(array *a) { 24bcdc6a3bSJan Kneschke size_t i; 25bcdc6a3bSJan Kneschke if (!a) return; 26bcdc6a3bSJan Kneschke 27bcdc6a3bSJan Kneschke for (i = 0; i < a->size; i++) { 28bcdc6a3bSJan Kneschke if (a->data[i]) a->data[i]->free(a->data[i]); 29bcdc6a3bSJan Kneschke } 30bcdc6a3bSJan Kneschke 31bcdc6a3bSJan Kneschke if (a->data) free(a->data); 32bcdc6a3bSJan Kneschke if (a->sorted) free(a->sorted); 33bcdc6a3bSJan Kneschke 34bcdc6a3bSJan Kneschke free(a); 35bcdc6a3bSJan Kneschke } 36bcdc6a3bSJan Kneschke 37bcdc6a3bSJan Kneschke void array_reset(array *a) { 38bcdc6a3bSJan Kneschke size_t i; 39bcdc6a3bSJan Kneschke if (!a) return; 40bcdc6a3bSJan Kneschke 41bcdc6a3bSJan Kneschke for (i = 0; i < a->used; i++) { 42bcdc6a3bSJan Kneschke a->data[i]->reset(a->data[i]); 43bcdc6a3bSJan Kneschke } 44bcdc6a3bSJan Kneschke 45bcdc6a3bSJan Kneschke a->used = 0; 46bcdc6a3bSJan Kneschke } 47bcdc6a3bSJan Kneschke 48bcdc6a3bSJan Kneschke static int array_get_index(array *a, const char *key, size_t keylen, int *rndx) { 49bcdc6a3bSJan Kneschke int ndx = -1; 50bcdc6a3bSJan Kneschke int i, pos = 0; 51bcdc6a3bSJan Kneschke 52bcdc6a3bSJan Kneschke if (key == NULL) return -1; 53bcdc6a3bSJan Kneschke 54bcdc6a3bSJan Kneschke /* try to find the string */ 55bcdc6a3bSJan Kneschke for (i = pos = a->next_power_of_2 / 2; ; i >>= 1) { 56bcdc6a3bSJan Kneschke int cmp; 57bcdc6a3bSJan Kneschke 58bcdc6a3bSJan Kneschke if (pos < 0) { 59bcdc6a3bSJan Kneschke pos += i; 60bcdc6a3bSJan Kneschke } else if (pos >= (int)a->used) { 61bcdc6a3bSJan Kneschke pos -= i; 62bcdc6a3bSJan Kneschke } else { 63bcdc6a3bSJan Kneschke cmp = buffer_caseless_compare(key, keylen, a->data[a->sorted[pos]]->key->ptr, a->data[a->sorted[pos]]->key->used); 64bcdc6a3bSJan Kneschke 65bcdc6a3bSJan Kneschke if (cmp == 0) { 66bcdc6a3bSJan Kneschke /* found */ 67bcdc6a3bSJan Kneschke ndx = a->sorted[pos]; 68bcdc6a3bSJan Kneschke break; 69bcdc6a3bSJan Kneschke } else if (cmp < 0) { 70bcdc6a3bSJan Kneschke pos -= i; 71bcdc6a3bSJan Kneschke } else { 72bcdc6a3bSJan Kneschke pos += i; 73bcdc6a3bSJan Kneschke } 74bcdc6a3bSJan Kneschke } 75bcdc6a3bSJan Kneschke if (i == 0) break; 76bcdc6a3bSJan Kneschke } 77bcdc6a3bSJan Kneschke 78bcdc6a3bSJan Kneschke if (rndx) *rndx = pos; 79bcdc6a3bSJan Kneschke 80bcdc6a3bSJan Kneschke return ndx; 81bcdc6a3bSJan Kneschke } 82bcdc6a3bSJan Kneschke 83bcdc6a3bSJan Kneschke data_unset *array_get_element(array *a, const char *key) { 84bcdc6a3bSJan Kneschke int ndx; 85bcdc6a3bSJan Kneschke 86bcdc6a3bSJan Kneschke if (-1 != (ndx = array_get_index(a, key, strlen(key) + 1, NULL))) { 87bcdc6a3bSJan Kneschke /* found, leave here */ 88bcdc6a3bSJan Kneschke 89bcdc6a3bSJan Kneschke return a->data[ndx]; 90bcdc6a3bSJan Kneschke } 91bcdc6a3bSJan Kneschke 92bcdc6a3bSJan Kneschke return NULL; 93bcdc6a3bSJan Kneschke } 94bcdc6a3bSJan Kneschke 95bcdc6a3bSJan Kneschke data_unset *array_get_unused_element(array *a, data_type_t t) { 96bcdc6a3bSJan Kneschke data_unset *ds = NULL; 97bcdc6a3bSJan Kneschke 98bcdc6a3bSJan Kneschke UNUSED(t); 99bcdc6a3bSJan Kneschke 100bcdc6a3bSJan Kneschke if (a->size == 0) return NULL; 101bcdc6a3bSJan Kneschke 102bcdc6a3bSJan Kneschke if (a->used == a->size) return NULL; 103bcdc6a3bSJan Kneschke 104bcdc6a3bSJan Kneschke if (a->data[a->used]) { 105bcdc6a3bSJan Kneschke ds = a->data[a->used]; 106bcdc6a3bSJan Kneschke 107bcdc6a3bSJan Kneschke a->data[a->used] = NULL; 108bcdc6a3bSJan Kneschke } 109bcdc6a3bSJan Kneschke 110bcdc6a3bSJan Kneschke return ds; 111bcdc6a3bSJan Kneschke } 112bcdc6a3bSJan Kneschke 113bcdc6a3bSJan Kneschke int array_insert_unique(array *a, data_unset *str) { 114bcdc6a3bSJan Kneschke int ndx = -1; 115bcdc6a3bSJan Kneschke int pos = 0; 116bcdc6a3bSJan Kneschke size_t j; 117bcdc6a3bSJan Kneschke 118bcdc6a3bSJan Kneschke /* generate unique index if neccesary */ 119bcdc6a3bSJan Kneschke if (str->key->used == 0) { 120bcdc6a3bSJan Kneschke buffer_copy_long(str->key, a->unique_ndx++); 121bcdc6a3bSJan Kneschke } 122bcdc6a3bSJan Kneschke 123bcdc6a3bSJan Kneschke /* try to find the string */ 124bcdc6a3bSJan Kneschke 125bcdc6a3bSJan Kneschke if (-1 != (ndx = array_get_index(a, str->key->ptr, str->key->used, &pos))) { 126bcdc6a3bSJan Kneschke /* found, leave here */ 127bcdc6a3bSJan Kneschke if (a->data[ndx]->type == str->type) { 128bcdc6a3bSJan Kneschke str->insert_dup(a->data[ndx], str); 129bcdc6a3bSJan Kneschke } else { 130bcdc6a3bSJan Kneschke fprintf(stderr, "a\n"); 131bcdc6a3bSJan Kneschke } 132bcdc6a3bSJan Kneschke return 0; 133bcdc6a3bSJan Kneschke } 134bcdc6a3bSJan Kneschke 135bcdc6a3bSJan Kneschke /* insert */ 136bcdc6a3bSJan Kneschke 137bcdc6a3bSJan Kneschke if (a->used+1 > INT_MAX) { 138bcdc6a3bSJan Kneschke /* we can't handle more then INT_MAX entries: see array_get_index() */ 139bcdc6a3bSJan Kneschke return -1; 140bcdc6a3bSJan Kneschke } 141bcdc6a3bSJan Kneschke 142bcdc6a3bSJan Kneschke if (a->size == 0) { 143bcdc6a3bSJan Kneschke a->size = 16; 144bcdc6a3bSJan Kneschke a->data = malloc(sizeof(*a->data) * a->size); 145bcdc6a3bSJan Kneschke a->sorted = malloc(sizeof(*a->sorted) * a->size); 146bcdc6a3bSJan Kneschke assert(a->data); 147bcdc6a3bSJan Kneschke assert(a->sorted); 148bcdc6a3bSJan Kneschke for (j = a->used; j < a->size; j++) a->data[j] = NULL; 149bcdc6a3bSJan Kneschke } else if (a->size == a->used) { 150bcdc6a3bSJan Kneschke a->size += 16; 151bcdc6a3bSJan Kneschke a->data = realloc(a->data, sizeof(*a->data) * a->size); 152bcdc6a3bSJan Kneschke a->sorted = realloc(a->sorted, sizeof(*a->sorted) * a->size); 153bcdc6a3bSJan Kneschke assert(a->data); 154bcdc6a3bSJan Kneschke assert(a->sorted); 155bcdc6a3bSJan Kneschke for (j = a->used; j < a->size; j++) a->data[j] = NULL; 156bcdc6a3bSJan Kneschke } 157bcdc6a3bSJan Kneschke 158bcdc6a3bSJan Kneschke ndx = (int) a->used; 159bcdc6a3bSJan Kneschke 160bcdc6a3bSJan Kneschke a->data[a->used++] = str; 161bcdc6a3bSJan Kneschke 162bcdc6a3bSJan Kneschke if (pos != ndx && 163bcdc6a3bSJan Kneschke ((pos < 0) || 164bcdc6a3bSJan Kneschke buffer_caseless_compare(str->key->ptr, str->key->used, a->data[a->sorted[pos]]->key->ptr, a->data[a->sorted[pos]]->key->used) > 0)) { 165bcdc6a3bSJan Kneschke pos++; 166bcdc6a3bSJan Kneschke } 167bcdc6a3bSJan Kneschke 168bcdc6a3bSJan Kneschke /* move everything on step to the right */ 169bcdc6a3bSJan Kneschke if (pos != ndx) { 170bcdc6a3bSJan Kneschke memmove(a->sorted + (pos + 1), a->sorted + (pos), (ndx - pos) * sizeof(*a->sorted)); 171bcdc6a3bSJan Kneschke } 172bcdc6a3bSJan Kneschke 173bcdc6a3bSJan Kneschke /* insert */ 174bcdc6a3bSJan Kneschke a->sorted[pos] = ndx; 175bcdc6a3bSJan Kneschke 176bcdc6a3bSJan Kneschke if (a->next_power_of_2 == (size_t)ndx) a->next_power_of_2 <<= 1; 177bcdc6a3bSJan Kneschke 178bcdc6a3bSJan Kneschke return 0; 179bcdc6a3bSJan Kneschke } 180bcdc6a3bSJan Kneschke 181*9e75ba00SJan Kneschke void array_print_indent(int depth) { 182*9e75ba00SJan Kneschke int i; 183*9e75ba00SJan Kneschke for (i = 0; i < depth; i ++) { 184*9e75ba00SJan Kneschke fprintf(stderr, " "); 185*9e75ba00SJan Kneschke } 186*9e75ba00SJan Kneschke } 187*9e75ba00SJan Kneschke 188*9e75ba00SJan Kneschke int array_print(array *a, int depth) { 189bcdc6a3bSJan Kneschke size_t i; 190bcdc6a3bSJan Kneschke 191bcdc6a3bSJan Kneschke for (i = 0; i < a->used; i++) { 192*9e75ba00SJan Kneschke array_print_indent(depth); 193bcdc6a3bSJan Kneschke fprintf(stderr, "%d: ", i); 194*9e75ba00SJan Kneschke a->data[i]->print(a->data[i], depth + 1); 195bcdc6a3bSJan Kneschke fprintf(stderr, "\n"); 196bcdc6a3bSJan Kneschke } 197bcdc6a3bSJan Kneschke 198bcdc6a3bSJan Kneschke return 0; 199bcdc6a3bSJan Kneschke } 200bcdc6a3bSJan Kneschke 201bcdc6a3bSJan Kneschke #ifdef DEBUG_ARRAY 202bcdc6a3bSJan Kneschke int main (int argc, char **argv) { 203bcdc6a3bSJan Kneschke array *a; 204bcdc6a3bSJan Kneschke data_string *ds; 205bcdc6a3bSJan Kneschke data_count *dc; 206bcdc6a3bSJan Kneschke 207bcdc6a3bSJan Kneschke UNUSED(argc); 208bcdc6a3bSJan Kneschke UNUSED(argv); 209bcdc6a3bSJan Kneschke 210bcdc6a3bSJan Kneschke a = array_init(); 211bcdc6a3bSJan Kneschke 212bcdc6a3bSJan Kneschke ds = data_string_init(); 213bcdc6a3bSJan Kneschke buffer_copy_string(ds->key, "abc"); 214bcdc6a3bSJan Kneschke buffer_copy_string(ds->value, "alfrag"); 215bcdc6a3bSJan Kneschke 216bcdc6a3bSJan Kneschke array_insert_unique(a, (data_unset *)ds); 217bcdc6a3bSJan Kneschke 218bcdc6a3bSJan Kneschke ds = data_string_init(); 219bcdc6a3bSJan Kneschke buffer_copy_string(ds->key, "abc"); 220bcdc6a3bSJan Kneschke buffer_copy_string(ds->value, "hameplman"); 221bcdc6a3bSJan Kneschke 222bcdc6a3bSJan Kneschke array_insert_unique(a, (data_unset *)ds); 223bcdc6a3bSJan Kneschke 224bcdc6a3bSJan Kneschke ds = data_string_init(); 225bcdc6a3bSJan Kneschke buffer_copy_string(ds->key, "123"); 226bcdc6a3bSJan Kneschke buffer_copy_string(ds->value, "alfrag"); 227bcdc6a3bSJan Kneschke 228bcdc6a3bSJan Kneschke array_insert_unique(a, (data_unset *)ds); 229bcdc6a3bSJan Kneschke 230bcdc6a3bSJan Kneschke dc = data_count_init(); 231bcdc6a3bSJan Kneschke buffer_copy_string(dc->key, "def"); 232bcdc6a3bSJan Kneschke 233bcdc6a3bSJan Kneschke array_insert_unique(a, (data_unset *)dc); 234bcdc6a3bSJan Kneschke 235bcdc6a3bSJan Kneschke dc = data_count_init(); 236bcdc6a3bSJan Kneschke buffer_copy_string(dc->key, "def"); 237bcdc6a3bSJan Kneschke 238bcdc6a3bSJan Kneschke array_insert_unique(a, (data_unset *)dc); 239bcdc6a3bSJan Kneschke 240*9e75ba00SJan Kneschke array_print(a, 0); 241bcdc6a3bSJan Kneschke 242bcdc6a3bSJan Kneschke array_free(a); 243bcdc6a3bSJan Kneschke 244bcdc6a3bSJan Kneschke fprintf(stderr, "%d\n", 245bcdc6a3bSJan Kneschke buffer_caseless_compare(CONST_STR_LEN("Content-Type"), CONST_STR_LEN("Content-type"))); 246bcdc6a3bSJan Kneschke 247bcdc6a3bSJan Kneschke return 0; 248bcdc6a3bSJan Kneschke } 249bcdc6a3bSJan Kneschke #endif 250