nmdb/be-qdbm.c

   1
   2 #if BE_ENABLE_QDBM
   3
   4 #include <depot.h>      /* QDBM's Depot API */
   5 #include <stdlib.h>
   6
   7 #include "be.h"
   8
   9
  10 int qdbm_set(struct db_conn *db, const unsigned char *key, size_t ksize,
  11                 unsigned char *val, size_t vsize);
  12 int qdbm_get(struct db_conn *db, const unsigned char *key, size_t ksize,
  13                 unsigned char *val, size_t *vsize);
  14 int qdbm_del(struct db_conn *db, const unsigned char *key, size_t ksize);
  15 int qdbm_close(struct db_conn *db);
  16
  17
  18 struct db_conn *qdbm_open(const char *name, int flags)
  19 {
  20         int f;
  21         struct db_conn *db;
  22         DEPOT *qdbm_db;
  23
  24         f = DP_OREADER | DP_OWRITER | DP_ONOLCK | DP_OCREAT;
  25         qdbm_db = dpopen(name, f, 0);
  26         if (qdbm_db == NULL)
  27                 return NULL;
  28
  29         db = malloc(sizeof(struct db_conn));
  30         if (db == NULL) {
  31                 dpclose(qdbm_db);
  32                 return NULL;
  33         }
  34
  35         db->conn = qdbm_db;
  36         db->set = qdbm_set;
  37         db->get = qdbm_get;
  38         db->del = qdbm_del;
  39         db->firstkey = NULL;
  40         db->nextkey = NULL;
  41         db->close = qdbm_close;
  42
  43         return db;
  44 }
  45
  46
  47 int qdbm_close(struct db_conn *db)
  48 {
  49         int rv;
  50
  51         rv = dpclose(db->conn);
  52         free(db);
  53         return rv;
  54 }
  55
  56
  57 int qdbm_set(struct db_conn *db, const unsigned char *key, size_t ksize,
  58                 unsigned char *val, size_t vsize)
  59 {
  60         return dpput(db->conn, (char *) key, ksize,
  61                         (char *) val, vsize, DP_DOVER);
  62 }
  63
  64
  65 int qdbm_get(struct db_conn *db, const unsigned char *key, size_t ksize,
  66                 unsigned char *val, size_t *vsize)
  67 {
  68         int rv;
  69
  70         rv = dpgetwb(db->conn, (char *) key, ksize, 0, *vsize, (char *) val);
  71         if (rv >= 0) {
  72                 *vsize = rv;
  73                 return 1;
  74         } else {
  75                 return 0;
  76         }
  77 }
  78
  79 int qdbm_del(struct db_conn *db, const unsigned char *key, size_t ksize)
  80 {
  81         return dpout(db->conn, (char *) key, ksize);
  82 }
  83
  84 #else
  85
  86 #include <stddef.h>     /* NULL */
  87
  88 struct db_conn *qdbm_open(const char *name, int flags)
  89 {
  90         return NULL;
  91 }
  92
  93 #endif
  94