Add utils.h and moved batch operations into their own files

1 files changed, 0 insertions, 184 deletions

diff --git a/src/lib/batch.c b/src/lib/batch.c
deleted file mode 100644
index 0534daf..0000000
--- a/src/lib/batch.c
+++ /dev/null
@@ -1,184 +0,0 @@
-#include <stdio.h>
-#include <string.h>
-#include <stdlib.h>
-#include <threads.h>
-
-#include "mdb.h"
-
-// TODO: move these functions into seperate files
-
-static int setkey_helper(void *thr_data);
-static int delkey_helper(void *thr_data);
-static int *clone(int n);
-static tablist_t *copytab(tablist_t *dst, tablist_t *src);
-static void dellist(tablist_t *list);
-
-extern int setkey(tablist_t **, int, char *);
-extern int delkey(tablist_t *, int, char *);
-
-tablist_t *setkey_copy;
-char *setkey_str;
-
-mtx_t setkey_mtx;
-int setkeys(tablist_t **list, int id, char **pairs, int len)
-{
-  if (id < -1 || pairs == NULL || len <= 0)
-    return -1;
-  if (mtx_init(&setkey_mtx, mtx_plain) != thrd_success)
-    return -2;
-  int rc = 0;
-  setkey_copy = calloc((*list)[0].len, sizeof(tablist_t));
-  copytab(setkey_copy, *list);
-
-  for (int i = 0; i < len; ++i) {
-    setkey_str = pairs[i];
-    if (id == -1) {
-      thrd_t *thrds = calloc((*list)[0].len, sizeof(thrd_t));
-      for (int i = 0; i < setkey_copy[0].len; ++i)
-        thrd_create(&thrds[i], setkey_helper, clone(i));
-      for (int i = 0; i < setkey_copy[0].len; ++i) {
-        if (rc)
-          thrd_join(thrds[i], NULL);
-        else
-          thrd_join(thrds[i], &rc);
-      }
-      free(thrds);
-    }
-    else
-     rc = setkey_helper(clone(id));
-  }
-
-  if (!rc) {
-    if (setkey_copy[0].len > (*list)[0].len)
-      *list = realloc(*list, setkey_copy[0].len * sizeof(tablist_t));
-    dellist(*list);
-    copytab(*list, setkey_copy);
-  }
-  mtx_destroy(&setkey_mtx);
-  dellist(setkey_copy);
-  free(setkey_copy);
-  return rc;
-}
-
-tablist_t *delkey_copy;
-char **delkeys_keys;
-int keys_len;
-
-mtx_t delkey_mtx;
-int delkeys(tablist_t *list, int id, char **keys, int len)
-{
-  if (id < -1 || len < 0)
-    return -1;
-  if (mtx_init(&delkey_mtx, mtx_plain) != thrd_success)
-    return -2;
-  int rc = 0;
-  delkey_copy = calloc(list[0].len, sizeof(tablist_t));
-  copytab(delkey_copy, list);
-  delkeys_keys = keys;
-  keys_len = len;
-
-  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, clone(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(clone(id));
-
-  if (!rc) {
-    dellist(list);
-    memmove(list, delkey_copy, delkey_copy[0].len * sizeof(tablist_t));
-  } else
-    dellist(delkey_copy);
-  mtx_destroy(&delkey_mtx);
-  free(delkey_copy);
-  return rc;
-}
-
-static int setkey_helper(void *thr_data)
-{
-  int rc;
-  int *id = (int *) thr_data;
-  
-  mtx_lock(&setkey_mtx);
-  rc = setkey(&setkey_copy, *id, setkey_str);
-  mtx_unlock(&setkey_mtx);
-  
-  free(id);
-  return rc;
-}
-
-static int delkey_helper(void *thr_data)
-{
-  int rc = 0;
-  int *id = (int *) thr_data;
-
-  mtx_lock(&delkey_mtx);
-  if (keys_len > 0 && delkeys_keys != NULL)
-    for (int i = 0; i < keys_len; ++i) {
-      if (delkeys_keys[i] == NULL)
-        return -3;
-      rc = delkey(delkey_copy, *id, delkeys_keys[i]);
-    }
-  else {
-    tablist_t *indexes = getkeys(delkey_copy, *id, NULL, 0);
-    for (int i = 0; indexes[0].tab[i].flag; ++i)
-      rc = delkey(delkey_copy, *id, indexes[0].tab[i].key);
-    free(indexes);
-  }
-  mtx_unlock(&delkey_mtx);
-
-  free(id);
-  return rc;
-}
-
-static int *clone(int n)
-{
-  int *c = calloc(1, sizeof(int));
-  *c = n;
-  return c;
-}
-
-static tablist_t *copytab(tablist_t *dst, tablist_t *src)
-{
-  if (dst == NULL)
-    return NULL;
-  dst[0].len = src[0].len;
-  for (int i = 0; i < src[0].len; ++i) {
-    for (int j = 0; j < TABLEN; ++j) {
-      dst[i].tab[j] = (tabidx_t) { NULL, 0, { 0 } };
-      if (src[i].tab[j].flag) {
-        switch (src[i].tab[j].flag) {
-          case 3:
-            dst[i].tab[j].value.str =
-              calloc(strlen(src[i].tab[j].value.str) + 1, sizeof(char));
-            strcpy(dst[i].tab[j].value.str, src[i].tab[j].value.str);
-            break;
-          default:
-            dst[i].tab[j].value = src[i].tab[j].value;
-            break;
-        }
-        dst[i].tab[j].flag = src[i].tab[j].flag;
-        dst[i].tab[j].key = calloc(strlen(src[i].tab[j].key) + 1, sizeof(char));
-        strcpy(dst[i].tab[j].key, src[i].tab[j].key);
-      }
-    }
-  }
-  return dst;
-}
-
-static void dellist(tablist_t *list)
-{
-  for (int i = 0; i < list[0].len; ++i) {
-    tablist_t *indexes = getkeys(list, i, NULL, 0);
-    for (int j = 0; indexes[0].tab[j].flag; ++j)
-      delkey(list, i, indexes[0].tab[j].key);
-    free(indexes);
-  }
-}