X-Git-Url: http://git.asbjorn.biz/?p=swftools.git;a=blobdiff_plain;f=lib%2Fq.c;h=1d27b4238ce810113c649a33ac0668096bb4b8ba;hp=5ade500188a8a3d8763d6e0a080c6ca5d744aa03;hb=fec1ab31707e68c2396b186e0e4928632402d649;hpb=c27172590efa648cdb4ba244fdca07b9d64c4c01 diff --git a/lib/q.c b/lib/q.c index 5ade500..1d27b42 100644 --- a/lib/q.c +++ b/lib/q.c @@ -21,6 +21,7 @@ #include #include +#include #include #include #include @@ -47,6 +48,21 @@ char*qstrndup(const char*string, int len) { return strdup_n(string, len); } +char* allocprintf(const char*format, ...) +{ + va_list arglist1; + va_start(arglist1, format); + char dummy; + int l = vsnprintf(&dummy, 1, format, arglist1); + va_end(arglist1); + + va_list arglist2; + va_start(arglist2, format); + char*buf = malloc(l+1); + vsnprintf(buf, l+1, format, arglist2); + va_end(arglist2); + return buf; +} // ------------------------------- mem_t -------------------------------------- @@ -68,7 +84,9 @@ static int mem_put_(mem_t*m,const void*data, int length, int null) int n = m->pos; m->pos += length + (null?1:0); if(m->pos > m->len) { - m->len = (m->pos+63)&~63; + int v1 = (m->pos+63)&~63; + int v2 = m->len + m->len / 2; + m->len = v1>v2?v1:v2; m->buffer = m->buffer?(char*)rfx_realloc(m->buffer,m->len):(char*)rfx_alloc(m->len); } assert(n+length <= m->len); @@ -85,6 +103,15 @@ int mem_putstring(mem_t*m,string_t str) { return mem_put_(m, str.str, str.len, 1); } +int mem_get(mem_t*m, void*data, int length) +{ + if(m->read_pos + length > m->pos) { + length = m->pos - m->read_pos; + } + memcpy(data, m->buffer+m->read_pos, length); + m->read_pos += length; + return length; +} // ------------------------------- ringbuffer_t ------------------------------- @@ -170,35 +197,62 @@ void ringbuffer_clear(ringbuffer_t*r) // ------------------------------- heap_t ------------------------------- -void heap_init(heap_t*h,int n,int elem_size, int(*compare)(const void *, const void *)) +void heap_init(heap_t*h,int elem_size, int(*compare)(const void *, const void *)) { memset(h, 0, sizeof(heap_t)); - h->max_size = n; h->size = 0; h->elem_size = elem_size; h->compare = compare; - h->elements = (void**)rfx_calloc(n*sizeof(void*)); - h->data = (char*)rfx_calloc(h->max_size*h->elem_size); + h->elements = 0; + h->max_size = 0; +} +heap_t* heap_new(int elem_size, int(*compare)(const void *, const void *)) +{ + heap_t*h = malloc(sizeof(heap_t)); + heap_init(h, elem_size, compare); + return h; +} +heap_t* heap_clone(heap_t*o) +{ + heap_t*h = malloc(sizeof(heap_t)); + memcpy(h, o, sizeof(heap_t)); + h->elements = rfx_alloc(sizeof(void*)*h->size); + int t; + for(t=0;tsize;t++) { + h->elements[t] = rfx_alloc(h->elem_size); + memcpy(h->elements[t], o->elements[t], h->elem_size); + } + return h; } void heap_clear(heap_t*h) { + int t; + for(t=0;tsize;t++) { + rfx_free(h->elements[t]); + h->elements[t]=0; + } rfx_free(h->elements); - rfx_free(h->data); +} +void heap_destroy(heap_t*h) +{ + heap_clear(h); + free(h); } -#define HEAP_NODE_SMALLER(h,node1,node2) ((h)->compare((node1),(node2))>0) +#define HEAP_NODE_LARGER(h,node1,node2) ((h)->compare((node1),(node2))>0) +#define HEAP_NODE_SMALLER(h,node1,node2) ((h)->compare((node1),(node2))<0) static void up(heap_t*h, int node) { void*node_p = h->elements[node]; int parent = node; + int tmp = node; do { node = parent; if(!node) break; parent = (node-1)/2; h->elements[node] = h->elements[parent]; - } while(HEAP_NODE_SMALLER(h,h->elements[parent], node_p)); - + } while(HEAP_NODE_SMALLER(h, h->elements[parent], node_p)); h->elements[node] = node_p; } static void down(heap_t*h, int node) @@ -223,20 +277,32 @@ static void down(heap_t*h, int node) void heap_put(heap_t*h, void*e) { int pos = h->size++; - memcpy(&h->data[pos*h->elem_size],e,h->elem_size); - h->elements[pos] = &h->data[pos]; + void*data = rfx_alloc(h->elem_size); + memcpy(data,e,h->elem_size); + + if(pos>=h->max_size) { + h->max_size = h->max_size<15?15:(h->max_size+1)*2-1; + h->elements = (void**)rfx_realloc(h->elements, h->max_size*sizeof(void*)); + assert(posmax_size); + } + + h->elements[pos] = data; up(h, pos); } int heap_size(heap_t*h) { return h->size; } -void* heap_max(heap_t*h) +void* heap_peek(heap_t*h) { + if(!h || !h->size) + return 0; return h->elements[0]; } void* heap_chopmax(heap_t*h) { + if(!h->size) + return 0; void*p = h->elements[0]; h->elements[0] = h->elements[--h->size]; down(h,0); @@ -255,7 +321,7 @@ void heap_dump(heap_t*h, FILE*fi) } void** heap_flatten(heap_t*h) { - void**nodes = (void**)rfx_alloc(h->size*sizeof(void*)); + void**nodes = (void**)rfx_alloc((h->size+1)*sizeof(void*)); void**p = nodes; while(h->size) { @@ -264,17 +330,208 @@ void** heap_flatten(heap_t*h) printf("\n");*/ *p++ = heap_chopmax(h); } + *p++ = 0; return nodes; } +// ------------------------------- trie -------------------------------------- + +trie_t*trie_new() +{ + return (trie_t*)rfx_calloc(sizeof(trie_t)); +} +static char _trie_put(trielayer_t**t, unsigned const char*id, void*data) +{ + if(!*t) { + (*t) = rfx_calloc(sizeof(trielayer_t)); + (*t)->rest = (unsigned char*)strdup(id); + (*t)->data = data; + return 0; + } + if((*t)->rest && (*t)->rest[0]) { + // make room: shift whatever's currently in here one node down + _trie_put(&(*t)->row[(*t)->rest[0]], (*t)->rest+1, (*t)->data); + (*t)->rest = 0; + } + if(id[0]) { + return _trie_put(&(*t)->row[id[0]], id+1, data); + } else { + char overwrite = 0; + if((*t)->rest) + overwrite = 1; + (*t)->rest = strdup(""); + (*t)->data = data; + return overwrite; + } +} +static char _trie_remove(trielayer_t*t, unsigned const char*id) +{ + while(t) { + if(t->rest && !strcmp(t->rest, id)) { + free(t->rest); + t->rest = 0; + return 1; + } + if(!*id) + return 0; + t = t->row[*id++]; + } + return 0; +} + +static void trie_rollback_removes(trie_t*t, unsigned const char*id, void*data); +static void trie_rollback_adds(trie_t*t, unsigned const char*id, void*data); + +void trie_put(trie_t*t, unsigned const char*id, void*data) +{ + if(!t->rollback) { + _trie_put(&t->start, id, data); + } else { + char contains = trie_contains(t, id); + void*olddata = contains?trie_lookup(t, id):0; + _trie_put(&t->start, id, data); + if(contains) { + trie_rollback_adds(t, id, olddata); + } + trie_rollback_removes(t, id, data); + } +} +char trie_remove(trie_t*t, unsigned const char*id) +{ + if(!t->rollback) { + return _trie_remove(t->start, id); + } else { + void*olddata = trie_lookup(t, id); + char exists = _trie_remove(t->start, id); + if(exists) { + trie_rollback_adds(t, id, olddata); + } + return exists; + } +} +int trie_contains(trie_t*trie, unsigned const char*id) +{ + trielayer_t*t = trie->start; + while(t) { + if(t->rest && !strcmp(t->rest, id)) + return 1; + if(!*id) + return 0; + t = t->row[*id++]; + } + return 0; +} +void* trie_lookup(trie_t*trie, unsigned const char*id) +{ + trielayer_t*t = trie->start; + while(t) { + if(t->rest && !strcmp(t->rest, id)) + return t->data; + if(!*id) + return 0; + t = t->row[*id++]; + } + return 0; +} + +typedef struct _triememory { + const unsigned char*key; + void*data; + char del; // 0/1 + struct _triememory*next; +} triememory_t; + +typedef struct _trierollback { + triememory_t*ops; + struct _trierollback*prev; +} trierollback_t; + +static void trie_rollback_adds(trie_t*t, unsigned const char*id, void*data) +{ + trierollback_t*rollback = (trierollback_t*)t->rollback; + triememory_t*m = (triememory_t*)rfx_calloc(sizeof(triememory_t)); + m->key = id; + m->data = data; + m->del = 0; + m->next = rollback->ops; + rollback->ops = m; +} +static void trie_rollback_removes(trie_t*t, unsigned const char*id, void*data) +{ + trierollback_t*rollback = (trierollback_t*)t->rollback; + triememory_t*m = (triememory_t*)rfx_calloc(sizeof(triememory_t)); + m->key = id; + m->data = data; + m->del = 1; + m->next = rollback->ops; + rollback->ops = m; +} + +void _trie_dump(trielayer_t*t, char*buffer, int pos) +{ + int i; + for(i=0;i<256;i++) { + if(t->row[i]) { + buffer[pos]=i; + _trie_dump(t->row[i], buffer, pos+1); + } + } + if(t->rest) { + buffer[pos]=0; + printf("%s%s %08x\n", buffer, t->rest, t->data); + } +} + +void trie_dump(trie_t*t) +{ + char buffer[256]; + _trie_dump(t->start, buffer, 0); +} + + +void trie_remember(trie_t*t) +{ + trierollback_t*old = (trierollback_t*)t->rollback; + t->rollback = (trierollback_t*)rfx_calloc(sizeof(trierollback_t)); + ((trierollback_t*)t->rollback)->prev = old; +} + +void trie_rollback(trie_t*t) +{ + trierollback_t*rollback = (trierollback_t*)t->rollback; + if(!rollback) { + fprintf(stderr, "Internal error: can't roll back this trie any further\n"); + return; + } + t->rollback = ((trierollback_t*)t->rollback)->prev; + + triememory_t*op = rollback->ops; + while(op) { + triememory_t*next = op->next; + if(op->del) { + if(!_trie_remove(t->start, op->key)) { + fprintf(stderr, "Internal error: can't delete key %s in trie during rollback\n", op->key); + } + } else { + if(_trie_put(&t->start, op->key, op->data)) { + fprintf(stderr, "Internal error: overwrote key %s in trie during rollback\n", op->key); + } + } + free(op); + op = next; + } +} + + // ------------------------------- crc32 -------------------------------------- -static unsigned int*crc32 = 0; +static unsigned int crc32[256]; +static char crc32_initialized=0; static void crc32_init(void) { int t; - if(crc32) + if(crc32_initialized) return; - crc32= (unsigned int*)rfx_alloc(sizeof(unsigned int)*256); + crc32_initialized = 1; for(t=0; t<256; t++) { unsigned int c = t; int s; @@ -318,16 +575,95 @@ string_t string_new2(const char*text) s.str = text; return s; } +string_t* string_new3(const char*text, int len) +{ + if(!text) { + string_t*s = malloc(sizeof(string_t)); + s->len = 0; + s->str = 0; + return s; + } else { + string_t*s = malloc(sizeof(string_t)+len+1); + s->len = len; + s->str = (const char*)(s+1); + memcpy((char*)s->str, text, len); + ((char*)s->str)[len]=0; + return s; + } +} +string_t* string_new4(const char*text) +{ + int l = strlen(text); + return string_new3(text, l); +} + +void string_free(string_t*s) +{ + if(!s) + return; + s->len = 0; + if((string_t*)(s->str) == s+1) { + s->str = 0; + rfx_free(s); + } else { + rfx_free((char*)(s->str)); + s->str = 0; + rfx_free(s); + } +} char* string_cstr(string_t*str) { return strdup_n(str->str, str->len); } -unsigned int string_hash(string_t*str) +char* string_escape(string_t*str) +{ + int t; + int len = 0; + for(t=0;tlen;t++) { + if(str->str[t]<0x20) + len+=3; + else + len++; + } + char*s = malloc(len+1); + char*p=s; + for(t=0;tlen;t++) { + if(str->str[t]<0x20) { + *p++ ='\\'; + unsigned char c = str->str[t]; + *p++ = "0123456789abcdef"[c>>4]; + *p++ = "0123456789abcdef"[c&0x0f]; + } else { + *p++ = str->str[t]; + } + } + *p++ = 0; + assert(p == &s[len+1]); + return s; +} + +unsigned int crc32_add_byte(unsigned int checksum, unsigned char b) +{ + crc32_init(); + return checksum>>8 ^ crc32[(b^checksum)&0xff]; +} +unsigned int crc32_add_string(unsigned int checksum, const char*s) +{ + crc32_init(); + if(!s) + return checksum; + while(*s) { + checksum = checksum>>8 ^ crc32[(*s^checksum)&0xff]; + s++; + } + return checksum; +} + +unsigned int string_hash(const string_t*str) { int t; unsigned int checksum = 0; - if(!crc32) - crc32_init(); + crc32_init(); for(t=0;tlen;t++) { checksum = checksum>>8 ^ crc32[(str->str[t]^checksum)&0xff]; } @@ -337,8 +673,7 @@ unsigned int string_hash2(const char*str) { unsigned int checksum = 0; const char*p = str; - if(!crc32) - crc32_init(); + crc32_init(); while(*p) { checksum = checksum>>8 ^ crc32[(*p^checksum)&0xff]; p++; @@ -503,6 +838,110 @@ void stringarray_destroy(stringarray_t*sa) rfx_free(sa); } +// ------------------------------- type_t ------------------------------- + +char ptr_equals(const void*o1, const void*o2) +{ + return o1==o2; +} +unsigned int ptr_hash(const void*o) +{ + return string_hash3((const char*)&o, sizeof(o)); +} +void* ptr_dup(const void*o) +{ + return (void*)o; +} +void ptr_free(void*o) +{ + return; +} + +char charptr_equals(const void*o1, const void*o2) +{ + if(!o1 || !o2) + return o1==o2; + return !strcmp(o1,o2); +} +unsigned int charptr_hash(const void*o) +{ + if(!o) + return 0; + return string_hash2(o); +} +void* charptr_dup(const void*o) +{ + if(!o) + return 0; + return strdup(o); +} +void charptr_free(void*o) +{ + if(o) { + rfx_free(o); + } +} + +char stringstruct_equals(const void*o1, const void*o2) +{ + if(!o1 || !o2) + return o1==o2; + string_t*s1 = (string_t*)o1; + string_t*s2 = (string_t*)o2; + int l = s1->lenlen?s1->len:s2->len; + int r = memcmp(s1->str, s2->str, l); + if(r) + return 0; + else + return s1->len==s2->len; +} +unsigned int stringstruct_hash(const void*o) +{ + if(!o) return 0; + return string_hash(o); +} +string_t*string_dup3(string_t*o) +{ + if(!o) return 0; + if(!o->str) { + string_t*s = malloc(sizeof(string_t)); + s->str=0; + s->len=0; + return s; + } + string_t*s = rfx_alloc(sizeof(string_t)+o->len+1); + s->len = o->len; + s->str = (const char*)(s+1); + memcpy((char*)s->str, o->str, s->len); + ((char*)s->str)[s->len]=0; + return s; +} +void stringstruct_free(void*o) +{ + if(o) + string_free(o); +} + +type_t ptr_type = { + equals: ptr_equals, + hash: ptr_hash, + dup: ptr_dup, + free: ptr_free, +}; + +type_t charptr_type = { + equals: charptr_equals, + hash: charptr_hash, + dup: charptr_dup, + free: charptr_free, +}; + +type_t stringstruct_type = { + equals: stringstruct_equals, + hash: stringstruct_hash, + dup: (dup_func)string_dup3, + free: stringstruct_free, +}; // ------------------------------- dictionary_t ------------------------------- @@ -515,16 +954,54 @@ static int max(int x, int y) { dict_t*dict_new() { dict_t*d = rfx_alloc(sizeof(dict_t)); - dict_init(d); + dict_init(d, INITIAL_SIZE); + return d; +} +dict_t*dict_new2(type_t*t) +{ + dict_t*d = rfx_alloc(sizeof(dict_t)); + dict_init(d, INITIAL_SIZE); + d->key_type = t; return d; } -void dict_init(dict_t*h) +void dict_init(dict_t*h, int size) +{ + memset(h, 0, sizeof(dict_t)); + h->hashsize = size; + h->slots = h->hashsize?(dictentry_t**)rfx_calloc(sizeof(dictentry_t*)*h->hashsize):0; + h->num = 0; + h->key_type = &charptr_type; +} +void dict_init2(dict_t*h, type_t*t, int size) { memset(h, 0, sizeof(dict_t)); - h->hashsize = INITIAL_SIZE; + h->hashsize = size; h->slots = h->hashsize?(dictentry_t**)rfx_calloc(sizeof(dictentry_t*)*h->hashsize):0; h->num = 0; + h->key_type = t; } + +dict_t*dict_clone(dict_t*o) +{ + dict_t*h = rfx_alloc(sizeof(dict_t)); + memcpy(h, o, sizeof(dict_t)); + h->slots = h->hashsize?(dictentry_t**)rfx_calloc(sizeof(dictentry_t*)*h->hashsize):0; + int t; + for(t=0;thashsize;t++) { + dictentry_t*e = o->slots[t]; + while(e) { + dictentry_t*n = (dictentry_t*)rfx_alloc(sizeof(dictentry_t)); + memcpy(n, e, sizeof(dictentry_t)); + n->key = h->key_type->dup(e->key); + n->data = e->data; + n->next = h->slots[t]; + h->slots[t] = n; + e = e->next; + } + } + return h; +} + static void dict_expand(dict_t*h, int newlen) { assert(h->hashsize < newlen); @@ -545,34 +1022,29 @@ static void dict_expand(dict_t*h, int newlen) h->slots = newslots; h->hashsize = newlen; } -void dict_put(dict_t*h, string_t s, void* data) + +dictentry_t* dict_put(dict_t*h, const void*key, void* data) { - /* TODO: should we look for duplicates here? */ - unsigned int hash = string_hash(&s); + unsigned int hash = h->key_type->hash(key); dictentry_t*e = (dictentry_t*)rfx_alloc(sizeof(dictentry_t)); + + if(!h->hashsize) + dict_expand(h, 1); - unsigned int hash2 = string_hash(&s) % h->hashsize; - char*sdata = rfx_alloc(s.len); - memcpy(sdata, s.str, s.len); - e->s = sdata; - e->len = s.len; + unsigned int hash2 = hash % h->hashsize; + + e->key = h->key_type->dup(key); e->hash = hash; //for resizing e->next = h->slots[hash2]; e->data = data; h->slots[hash2] = e; h->num++; + return e; } void dict_put2(dict_t*h, const char*s, void*data) { - string_t s2; - string_set(&s2, s); - dict_put(h, s2, data); -} -void dict_put3(dict_t*h, const char* s, int len, void*data) -{ - string_t s3; - string_set2(&s3, s, len); - dict_put(h, s3, data); + assert(h->key_type == &charptr_type); + dict_put(h, s, data); } void dict_dump(dict_t*h, FILE*fi, const char*prefix) { @@ -580,9 +1052,11 @@ void dict_dump(dict_t*h, FILE*fi, const char*prefix) for(t=0;thashsize;t++) { dictentry_t*e = h->slots[t]; while(e) { - char*s = strdup_n(e->s, e->len); - fprintf(fi, "%s%s=%08x\n", prefix, e->s, e->data); - rfx_free(s); + if(h->key_type!=&charptr_type) { + fprintf(fi, "%s%08x=%08x\n", prefix, e->key, e->data); + } else { + fprintf(fi, "%s%s=%08x\n", prefix, e->key, e->data); + } e = e->next; } } @@ -592,18 +1066,20 @@ int dict_count(dict_t*h) { return h->num; } -void* dict_lookup4(dict_t*h, const char*s, int len, const void*data) + +static inline dictentry_t* dict_do_lookup(dict_t*h, const void*key) { - if(!h->num) + if(!h->num) { return 0; + } - unsigned int ohash = string_hash2(s); + unsigned int ohash = h->key_type->hash(key); unsigned int hash = ohash % h->hashsize; /* check first entry for match */ dictentry_t*e = h->slots[hash]; - if(e && e->len == len && !memcmp(e->s, s, len)) { - return e->data; + if(e && h->key_type->equals(e->key, key)) { + return e; } else if(e) { e = e->next; } @@ -619,47 +1095,57 @@ void* dict_lookup4(dict_t*h, const char*s, int len, const void*data) dict_expand(h, newsize); hash = ohash % h->hashsize; e = h->slots[hash]; + if(e && h->key_type->equals(e->key, key)) { + // omit move to front + return e; + } else if(e) { + e = e->next; + } } /* check subsequent entries for a match */ + dictentry_t*last = h->slots[hash]; while(e) { - if(e->len == len && !memcmp(e->s, s, len) && (!data || data==e->data)) { - return e->data; + if(h->key_type->equals(e->key, key)) { + /* move to front- makes a difference of about 10% in most applications */ + last->next = e->next; + e->next = h->slots[hash]; + h->slots[hash] = e; + return e; } + last=e; e = e->next; } return 0; } -void* dict_lookup3(dict_t*h, const char*s, const void*data) +void* dict_lookup(dict_t*h, const void*key) { - int l = strlen(s); - return dict_lookup4(h, s, l, data); -} -void* dict_lookup2(dict_t*h, const char*s, int len) -{ - return dict_lookup4(h, s, len, 0); + dictentry_t*e = dict_do_lookup(h, key); + if(e) + return e->data; + return 0; } -void* dict_lookup(dict_t*h, const char*s) +char dict_contains(dict_t*h, const void*key) { - int l = strlen(s); - return dict_lookup2(h, s, l); + dictentry_t*e = dict_do_lookup(h, key); + return !!e; } -char dict_del(dict_t*h, const char*s) + +char dict_del(dict_t*h, const void*key) { if(!h->num) return 0; - unsigned int hash = string_hash2(s) % h->hashsize; - int l = strlen(s); + unsigned int hash = h->key_type->hash(key) % h->hashsize; dictentry_t*head = h->slots[hash]; dictentry_t*e = head, *prev=0; while(e) { - if(e->len ==l && !memcmp(e->s, s, l)) { + if(h->key_type->equals(e->key, key)) { dictentry_t*next = e->next; - rfx_free((void*)e->s); + h->key_type->free(e->key); memset(e, 0, sizeof(dictentry_t)); rfx_free(e); if(e == head) { - h->slots[hash] = 0; + h->slots[hash] = next; } else { assert(prev); prev->next = next; @@ -673,16 +1159,16 @@ char dict_del(dict_t*h, const char*s) return 0; } -static dictentry_t* dict_get_all(dict_t*h, const char*s) +dictentry_t* dict_get_slot(dict_t*h, const void*key) { if(!h->num) return 0; - unsigned int ohash = string_hash2(s); + unsigned int ohash = h->key_type->hash(key); unsigned int hash = ohash % h->hashsize; return h->slots[hash]; } -void dict_foreach_keyvalue(dict_t*h, void (*runFunction)(void*data, const char*key, void*val), void*data) +void dict_foreach_keyvalue(dict_t*h, void (*runFunction)(void*data, const void*key, void*val), void*data) { int t; for(t=0;thashsize;t++) { @@ -690,9 +1176,7 @@ void dict_foreach_keyvalue(dict_t*h, void (*runFunction)(void*data, const char*k while(e) { dictentry_t*next = e->next; if(runFunction) { - char*s = strdup_n(e->s, e->len); //append \0 - runFunction(data, s, e->data); - rfx_free(s); + runFunction(data, e->key, e->data); } e = e->next; } @@ -713,33 +1197,49 @@ void dict_foreach_value(dict_t*h, void (*runFunction)(void*)) } } -void dict_free_all(dict_t*h, void (*freeFunction)(void*)) +void dict_free_all(dict_t*h, char free_keys, void (*free_data_function)(void*)) { int t; for(t=0;thashsize;t++) { dictentry_t*e = h->slots[t]; while(e) { dictentry_t*next = e->next; - rfx_free((void*)e->s); - if(freeFunction) { - freeFunction(e->data); + if(free_keys) { + h->key_type->free(e->key); + } + if(free_data_function) { + free_data_function(e->data); } memset(e, 0, sizeof(dictentry_t)); rfx_free(e); e = next; } + h->slots[t]=0; } rfx_free(h->slots); memset(h, 0, sizeof(dict_t)); } +void dict_clear_shallow(dict_t*h) +{ + dict_free_all(h, 0, 0); +} + void dict_clear(dict_t*h) { - dict_free_all(h, 0); + dict_free_all(h, 1, 0); +} + +void dict_destroy_shallow(dict_t*dict) +{ + dict_clear_shallow(dict); + rfx_free(dict); } void dict_destroy(dict_t*dict) { + if(!dict) + return; dict_clear(dict); rfx_free(dict); } @@ -756,7 +1256,7 @@ void map_init(map_t*map) map_internal_t*m; map->internal = (map_internal_t*)rfx_calloc(sizeof(map_internal_t)); m = (map_internal_t*)map->internal; - dict_init(&m->d); + dict_init(&m->d, INITIAL_SIZE); } void map_put(map_t*map, string_t t1, string_t t2) { @@ -776,7 +1276,7 @@ static void freestring(void*data) { rfx_free(data); } -static void dumpmapentry(void*data, const char*key, void*value) +static void dumpmapentry(void*data, const void*key, void*value) { FILE*fi = (FILE*)data; fprintf(fi, "%s=%s\n", key, (char*)value); @@ -790,7 +1290,7 @@ void map_dump(map_t*map, FILE*fi, const char*prefix) void map_clear(map_t*map) { map_internal_t*m = (map_internal_t*)map->internal; - dict_free_all(&m->d, freestring); + dict_free_all(&m->d, 1, freestring); rfx_free(m); } void map_destroy(map_t*map) @@ -807,31 +1307,27 @@ array_t* array_new() { d->entry2pos = dict_new(); return d; } -void array_free(array_t*array) { - dict_destroy(array->entry2pos); - array->entry2pos; - if(array->d) { - free(array->d);array->d = 0; - } - free(array); +array_t* array_new2(type_t*type) { + array_t*d = malloc(sizeof(array_t)); + memset(d, 0, sizeof(array_t)); + d->entry2pos = dict_new2(type); + return d; } -const char*array_getkey(array_t*array, int nr) { +void*array_getkey(array_t*array, int nr) { if(nr > array->num || nr<0) { printf("error: reference to element %d in array[%d]\n", nr, array->num); - *(int*)0 = 0; return 0; } return array->d[nr].name; } -char*array_getvalue(array_t*array, int nr) { +void*array_getvalue(array_t*array, int nr) { if(nr > array->num || nr<0) { printf("error: reference to element %d in array[%d]\n", nr, array->num); - *(int*)0 = 0; return 0; } return array->d[nr].data; } -int array_append(array_t*array, const char*name, const void*data) { +int array_append(array_t*array, const void*name, void*data) { while(array->size <= array->num) { array->size += 64; if(!array->d) { @@ -840,40 +1336,37 @@ int array_append(array_t*array, const char*name, const void*data) { array->d = realloc(array->d, sizeof(array_entry_t)*array->size); } } + + dictentry_t*e = dict_put(array->entry2pos, name, (void*)(ptroff_t)(array->num+1)); + if(name) { - array->d[array->num].name = strdup(name); + array->d[array->num].name = e->key; } else { array->d[array->num].name = 0; } array->d[array->num].data = (void*)data; - dict_put2(array->entry2pos, name, (void*)(ptroff_t)(array->num+1)); return array->num++; } -int array_find(array_t*array, const char*name) +int array_find(array_t*array, const void*name) { - if(!name) - name = ""; int pos = (int)(ptroff_t)dict_lookup(array->entry2pos, name); return pos-1; } -int array_find2(array_t*array, const char*name, void*data) +int array_find2(array_t*array, const void*name, void*data) { - if(!name) - name = ""; - int len= strlen(name); - - dictentry_t*e = dict_get_all(array->entry2pos, name); + dict_t*h= array->entry2pos; + dictentry_t*e = dict_get_slot(array->entry2pos, name); while(e) { int index = ((int)(ptroff_t)e->data) - 1; - if(e->len == len && !memcmp(e->s, name, len) && array->d[index].data == data) { + if(h->key_type->equals(e->key, name) && array->d[index].data == data) { return index; } e = e->next; } return -1; } -int array_update(array_t*array, const char*name, void*data) { +int array_update(array_t*array, const void*name, void*data) { int pos = array_find(array, name); if(pos>=0) { array->d[pos].data = data; @@ -881,12 +1374,19 @@ int array_update(array_t*array, const char*name, void*data) { } return array_append(array, name, data); } -int array_append_if_new(array_t*array, const char*name, void*data) { +int array_append_if_new(array_t*array, const void*name, void*data) { int pos = array_find(array, name); if(pos>=0) return pos; return array_append(array, name, data); } +void array_free(array_t*array) { + dict_destroy(array->entry2pos); + if(array->d) { + free(array->d);array->d = 0; + } + free(array); +} // ------------------------------- list_t -------------------------------------- @@ -902,20 +1402,35 @@ typedef struct _commonlist { listinfo_t info[0]; } commonlist_t; -int list_length(void*_list) +int list_length_(void*_list) { commonlist_t*l = (commonlist_t*)_list; if(!l) return 0; return l->info[0].size; } +void list_concat_(void*_l1, void*_l2) +{ + commonlist_t**l1 = (commonlist_t**)_l1; + commonlist_t**l2 = (commonlist_t**)_l2; + + if(!*l1) { + *l1 = *l2; + } else if(*l2) { + (*l1)->info[0].last->next = *l2; + (*l1)->info[0].last = (*l2)->info[0].last; + (*l1)->info[0].size += (*l2)->info[0].size; + } + *l2 = 0; +} void list_append_(void*_list, void*entry) { commonlist_t**list = (commonlist_t**)_list; commonlist_t* n = 0; if(!*list) { - n = malloc(sizeof(commonlist_t)+sizeof(listinfo_t)); + n = (commonlist_t*)malloc(sizeof(commonlist_t)+sizeof(listinfo_t)); *list = n; + (*list)->info[0].size = 0; } else { n = malloc(sizeof(commonlist_t)); (*list)->info[0].last->next = n; @@ -925,6 +1440,23 @@ void list_append_(void*_list, void*entry) (*list)->info[0].last = n; (*list)->info[0].size++; } +/* notice: prepending uses slighly more space than appending */ +void list_prepend_(void*_list, void*entry) +{ + commonlist_t**list = (commonlist_t**)_list; + commonlist_t* n = (commonlist_t*)malloc(sizeof(commonlist_t)+sizeof(listinfo_t)); + int size = 0; + commonlist_t* last = 0; + if(*list) { + last = (*list)->info[0].last; + size = (*list)->info[0].size; + } + n->next = *list; + n->entry = entry; + *list = n; + (*list)->info[0].last = last; + (*list)->info[0].size = size+1; +} void list_free_(void*_list) { commonlist_t**list = (commonlist_t**)_list; @@ -936,3 +1468,31 @@ void list_free_(void*_list) } *list = 0; } +void list_deep_free_(void*_list) +{ + commonlist_t**list = (commonlist_t**)_list; + commonlist_t*l = *list; + while(l) { + commonlist_t*next = l->next; + if(l->entry) { + free(l->entry);l->entry=0; + } + free(l); + l = next; + } + *list = 0; +} +void*list_clone_(void*_list) +{ + commonlist_t*l = *(commonlist_t**)_list; + + void*dest = 0; + while(l) { + commonlist_t*next = l->next; + list_append_(&dest, l->entry); + l = next; + } + return dest; + +} +