summaryrefslogtreecommitdiff
path: root/src/lib/delkeys.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/lib/delkeys.c')
-rw-r--r--src/lib/delkeys.c112
1 files changed, 0 insertions, 112 deletions
diff --git a/src/lib/delkeys.c b/src/lib/delkeys.c
deleted file mode 100644
index a828e8d..0000000
--- a/src/lib/delkeys.c
+++ /dev/null
@@ -1,112 +0,0 @@
-#include <threads.h>
-#include <stdlib.h>
-#include <string.h>
-
-#include "mdb.h"
-#include "utils.h"
-
-static int delkey_helper(void *thr_data);
-static int delkey(tablist_t *, int, char *);
-static struct params *pass(mtx_t *mtx, tablist_t *list, char **keys, int len, int id);
-
-
-struct params {
- mtx_t *mtx;
- tablist_t *copy;
- char **keys;
- int len;
- int id;
-};
-
-
-int delkeys(tablist_t *list, int id, char **keys, int len)
-{
- mtx_t mtx;
- if (id >= list[0].len || id < -1 || len < 0)
- return -1;
- if (mtx_init(&mtx, mtx_plain) != thrd_success)
- return -2;
- int rc = 0;
- tablist_t *delkey_copy = calloc(list[0].len, sizeof(tablist_t));
- copytab(delkey_copy, list);
-
- if (id == -1) {
- thrd_t *thrds = calloc(list[0].len, sizeof(thrd_t));
- for (int i = 0; i < delkey_copy[0].len; ++i)
- thrd_create(&thrds[i], delkey_helper, pass(&mtx, delkey_copy, keys, len, i));
- for (int i = 0; i < delkey_copy[0].len; ++i) {
- if (rc)
- thrd_join(thrds[i], NULL);
- else
- thrd_join(thrds[i], &rc);
- }
- free(thrds);
- } else
- rc = delkey_helper(pass(&mtx, delkey_copy, keys, len, id));
-
- if (!rc) {
- dellist(list);
- memmove(list, delkey_copy, delkey_copy[0].len * sizeof(tablist_t));
- } else
- dellist(delkey_copy);
- mtx_destroy(&mtx);
- free(delkey_copy);
- return rc;
-}
-
-static int delkey_helper(void *thr_data)
-{
- int rc = 0;
- struct params *p = (struct params *) thr_data;
-
- mtx_lock(p->mtx);
- if (p->len > 0 && p->keys != NULL)
- for (int i = 0; i < p->len; ++i) {
- if (p->keys[i] == NULL) {
- mtx_unlock(p->mtx);
- free(p);
- return -3;
- }
- rc = delkey(p->copy, p->id, p->keys[i]);
- }
- else {
- tablist_t *indexes = getkeys(p->copy, p->id, NULL, 0);
- for (int i = 0; indexes[0].tab[i].flag; ++i)
- rc = delkey(p->copy, p->id, indexes[0].tab[i].key);
- free(indexes);
- }
- mtx_unlock(p->mtx);
-
- free(p);
- return rc;
-}
-
-static int delkey(tablist_t *list, int id, char *key)
-{
- int idx = hash(key);
- if (list[id].tab[idx].key == NULL)
- return 1;
- while (strcmp(list[id].tab[idx].key, key) && idx < TABLEN)
- idx++;
- if (idx >= TABLEN)
- return 2;
- free(list[id].tab[idx].key);
- list[id].tab[idx].key = NULL;
- if (list[id].tab[idx].flag == 3) {
- free(list[id].tab[idx].value.str);
- list[id].tab[idx].value.str = NULL;
- }
- list[id].tab[idx].flag = 0;
- return 0;
-}
-
-static struct params *pass(mtx_t *mtx, tablist_t *list, char **keys, int len, int id)
-{
- struct params *p = calloc(1, sizeof(struct params));
- p->mtx = mtx;
- p->copy = list;
- p->keys = keys;
- p->len = len;
- p->id = id;
- return p;
-}