// ==============================================================
/*                                                                */
//   File      : struct_man.c
//   Purpose   :
/*                                                                */
//   Institute of Microbiology (Technical University Munich)
//   http://www.arb-home.de/
 /*                                                                */
 // ==============================================================


#include <aisc.h>
#include <struct_man.h>

#include <stdio.h>
#include <stdlib.h>
#include <string.h>

// AISC_MKPT_PROMOTE:struct aisc_hash_node;

// ---------------------
//      hash tables


#define CORE
#define HASH_SIZE 103123
#define TRF_HASH_SIZE 103123

struct aisc_hash_node {
    char           *key;
    long            data;
    aisc_hash_node *next;
};


static aisc_hash_node **aisc_init_hash(int size) {
    struct aisc_hash_node **tab;
    tab = (aisc_hash_node **) calloc(sizeof(aisc_hash_node *), size);
    tab[0] = (aisc_hash_node *) calloc(sizeof(aisc_hash_node), 1);
    tab[0]->data = size;
    tab[0]->key = (char *)strdup("len_of_hash_table_(c) oliver_strunk 1.3.93");
    return tab;
}

static int aisc_hash(const char *key, int size) {
    unsigned int i, len, x;
    len = strlen(key);
    x = 0;
    for (i=0; i<len; i++) {
        x = x<<2 ^ key[i];
    }
    x = x%size;
    return x;
}

static void aisc_free_key(aisc_hash_node **table, char *key) {
    if (table && table[0]) {
        long size = table[0]->data;
        long i    = aisc_hash(key, (int)size);

        aisc_hash_node *hn, *hhn;
        for (hn = hhn = table[i]; hn; hn = hn->next) {
            if (strcmp(key, hn->key)) {
                hhn = hn;
                continue;
            }
            if (hn != hhn)
                hhn->next = hn->next;
            else {
                table[i] = hhn->next;
            }
            free(hn->key);
            free(hn);
            break;
        }
    }
}

static void aisc_free_hash(aisc_hash_node **table) {
    long end = table[0]->data;
    for (long i=0; i<end; i++) {
        aisc_hash_node *hn, *hnn;
        for (hn = table[i]; hn; hn=hnn) {
            hnn = hn->next;
            free(hn->key);
            free(hn);
        }
    }
    free(table);
}


static void aisc_insert_hash(aisc_hash_node **table, char *key, long data) {
    long            size = table[0]->data;
    long            i    = aisc_hash(key, (int)size);

    aisc_hash_node *hnl  = 0;
    aisc_hash_node *hn;
    for (hn=table[i]; hn; hn=hn->next) {
        hnl = hn;
        if (strcmp(key, hn->key) == 0) {
            hn->data = data;
            return;
        }
    }
    hn = (aisc_hash_node *)calloc(sizeof(aisc_hash_node), 1);
    hn->key = (char *)strdup(key);
    hn->data = data;
    if (hnl) {
        hnl->next = hn;
    }
    else {
        table[i] = hn;
    }
}

long aisc_read_hash(aisc_hash_node **table, const char *key) {
    if (table && table[0]) {
        long size = table[0]->data;
        long i = aisc_hash(key, (int)size);
        for (aisc_hash_node *hn=table[i]; hn; hn=hn->next) {
            if (strcmp(key, hn->key) == 0) return hn->data;
        }
    }
    return 0;
}

// ----------------------
//      link control

const char *aisc_link(dllpublic_ext *father, dllheader_ext *object) {
    if (!object) {
        CORE;
        return "Object is (NULL)";
    }
    if (object->mh.parent) {
        CORE;
        return "Object already linked";
    }
    if (!father) {
        CORE;
        return "Parent is (NULL)";
    }
    if (father->key != object->mh.key) {
        CORE;
        return "Parent key doesn't match Object key";
    }
    if (object->mh.ident) {
        if (strlen(object->mh.ident) <= 0) {
            CORE;
            return "Too short ident";
        }
        if (father->hash) {
            if (aisc_read_hash((aisc_hash_node **)father->hash, object->mh.ident)) {
                CORE;
                return "Object already in list";
            }
            else {
                aisc_insert_hash((aisc_hash_node **)father->hash, object->mh.ident, (long)object);
            }
        }
        else {
            father->hash = (long)aisc_init_hash(HASH_SIZE);
            aisc_insert_hash((aisc_hash_node **)father->hash, object->mh.ident, (long)object);
        }
    }
    object->next = object->previous = NULL;
    if (!father->first) {
        father->cnt   = 1;
        father->first = object;
        father->last  = object;
    }
    else {
        father->cnt++;
        object->previous   = father->last;
        father->last->next = object;
        father->last       = object;
    }
    object->mh.parent = father;
    return 0;
}



const char *aisc_unlink(dllheader_ext *object) {
    dllpublic_ext *father = (dllpublic_ext *)object->mh.parent;

    if (!father) {
        CORE;
        return "Object not linked";
    }
    if (father->hash) {
        aisc_free_key((aisc_hash_node **)father->hash, object->mh.ident);
    }
    if (father->cnt <= 0) {
        CORE;
        return "Parent count is 0";
    }
    if (object->previous) {
        if (object->previous->next != object) {
            CORE;
            return "Fatal Error: Object is a copy, not original";
        }
        object->previous->next = object->next;
    }
    else {
        father->first = object->next;
    }
    if (object->next) {
        object->next->previous = object->previous;
    }
    else {
        father->last = object->previous;
    }
    object->mh.parent = NULL;
    object->previous  = NULL;
    object->next      = NULL;

    father->cnt--;
    if (!father->cnt) {
        if (father->hash) {
            aisc_free_hash((aisc_hash_node **)father->hash);
            father->hash = 0;
        }
    }
    return 0;
}

long aisc_find_lib(dllpublic_ext *parent, char *ident)
{
    if (!parent->hash) return 0;
    if (!ident) return 0;
    return aisc_read_hash((aisc_hash_node **)parent->hash, ident);
}


struct trf_dest_struct {
    struct trf_dest_struct *next;
    long                   *dest;
};

struct trf_struct {
    struct trf_struct      *next;
    long                    new_item;
    long                    old;
    struct trf_dest_struct *dests;
};

static int trf_hash(long p)
{
    return (p+(p>>8))&(TRF_HASH_SIZE-1);
}

static int trf_level = 0;
static struct trf_struct **trf_sp = 0;

void trf_create(long old, long new_item) {
    long i;
    struct trf_struct *ts;
    struct trf_dest_struct *tds, *ntds;
    if (!trf_sp) return;
    i = trf_hash(old);
    for (ts = trf_sp[i]; ts; ts = ts->next) {
        if (ts->old == old) {
            if (ts->new_item && (ts->new_item != new_item)) {
                GBK_terminate("ERROR IN trf_create");
            }
            else {
                ts->new_item = new_item;
                for (tds = ts->dests; tds; tds = ntds) {
                    *tds->dest = new_item;
                    ntds = tds->next;
                    free(tds);
                }
            }
            return;
        }
    }
    ts = (struct trf_struct *)calloc(sizeof(struct trf_struct), 1);
    ts->next = trf_sp[i];
    trf_sp[i] = ts;
    ts->new_item = new_item;
    ts->old = old;
}

void trf_link(long old, long *dest)
{
    long i;
    struct trf_struct *ts, *fts;
    struct trf_dest_struct *tds;
    if (!trf_sp) return;
    i = trf_hash(old);
    fts = 0;
    for (ts = trf_sp[i]; ts; ts = ts->next) {
        if (ts->old == old)     { fts = ts; break; }
    }
    if (!fts) {
        ts = (struct trf_struct *)calloc(sizeof(struct trf_struct), 1);
        ts->next = trf_sp[i];
        trf_sp[i] = ts;
        ts->old = old;
        fts = ts;
    }
    tds = (struct trf_dest_struct *)calloc(sizeof(struct trf_dest_struct), 1);
    tds->next = fts->dests;
    fts->dests = tds;
    tds->dest = dest;
}

void trf_begin() {
    if (trf_level==0) {
        trf_sp = (struct trf_struct **)calloc(sizeof(struct trf_struct *), TRF_HASH_SIZE);
    }
    trf_level ++;
}

void trf_commit(int errors) {
    // if errors == 1 then print errors and CORE
    struct trf_dest_struct *tds, *ntds;
    struct trf_struct *ts, *nts;
    trf_level--;
    if (!trf_level) {
        for (int i = 0; i < TRF_HASH_SIZE; i++) {
            for (ts = trf_sp[i]; ts; ts = nts) {
                if (errors) {
                    if (ts->dests) {
                        GBK_terminate("ERROR IN trf_commit");
                    }
                }
                else {
                    for (tds = ts->dests; tds; tds = ntds) {
                        ntds = tds->next;
                        free(tds);
                    }
                }
                nts = ts->next;
                free(ts);
            }
        }
        free(trf_sp);
        trf_sp = 0;
    }
}