lib/dbwrap/dbwrap_rbt.c

   1 /*
   2    Unix SMB/CIFS implementation.
   3    Database interface wrapper around red-black trees
   4    Copyright (C) Volker Lendecke 2007, 2008
   5
   6    This program is free software; you can redistribute it and/or modify
   7    it under the terms of the GNU General Public License as published by
   8    the Free Software Foundation; either version 3 of the License, or
   9    (at your option) any later version.
  10
  11    This program is distributed in the hope that it will be useful,
  12    but WITHOUT ANY WARRANTY; without even the implied warranty of
  13    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  14    GNU General Public License for more details.
  15
  16    You should have received a copy of the GNU General Public License
  17    along with this program.  If not, see <http://www.gnu.org/licenses/>.
  18 */
  19
  20 #include "includes.h"
  21 #include "dbwrap/dbwrap.h"
  22 #include "dbwrap/dbwrap_private.h"
  23 #include "dbwrap/dbwrap_rbt.h"
  24 #include "../lib/util/rbtree.h"
  25
  26 #define DBWRAP_RBT_ALIGN(_size_) (((_size_)+15)&~15)
  27
  28 struct db_rbt_ctx {
  29         struct rb_root tree;
  30 };
  31
  32 struct db_rbt_rec {
  33         struct db_rbt_node *node;
  34 };
  35
  36 /* The structure that ends up in the tree */
  37
  38 struct db_rbt_node {
  39         struct rb_node rb_node;
  40         size_t keysize, valuesize;
  41
  42         /*
  43          * key and value are appended implicitly, "data" is only here as a
  44          * target for offsetof()
  45          */
  46
  47         char data[1];
  48 };
  49
  50 /*
  51  * Hide the ugly pointer calculations in a function
  52  */
  53
  54 static struct db_rbt_node *db_rbt2node(struct rb_node *node)
  55 {
  56         return (struct db_rbt_node *)
  57                 ((char *)node - offsetof(struct db_rbt_node, rb_node));
  58 }
  59
  60 /*
  61  * Compare two keys
  62  */
  63
  64 static int db_rbt_compare(TDB_DATA a, TDB_DATA b)
  65 {
  66         int res;
  67
  68         res = memcmp(a.dptr, b.dptr, MIN(a.dsize, b.dsize));
  69
  70         if ((res < 0) || ((res == 0) && (a.dsize < b.dsize))) {
  71                 return -1;
  72         }
  73         if ((res > 0) || ((res == 0) && (a.dsize > b.dsize))) {
  74                 return 1;
  75         }
  76         return 0;
  77 }
  78
  79 /*
  80  * dissect a db_rbt_node into its implicit key and value parts
  81  */
  82
  83 static void db_rbt_parse_node(struct db_rbt_node *node,
  84                               TDB_DATA *key, TDB_DATA *value)
  85 {
  86         key->dptr = ((uint8_t *)node) + offsetof(struct db_rbt_node, data);
  87         key->dsize = node->keysize;
  88         value->dptr = key->dptr + node->keysize;
  89         value->dsize = node->valuesize;
  90 }
  91
  92 static NTSTATUS db_rbt_store(struct db_record *rec, TDB_DATA data, int flag)
  93 {
  94         struct db_rbt_ctx *db_ctx = talloc_get_type_abort(
  95                 rec->db->private_data, struct db_rbt_ctx);
  96         struct db_rbt_rec *rec_priv = (struct db_rbt_rec *)rec->private_data;
  97         struct db_rbt_node *node;
  98
  99         struct rb_node ** p;
 100         struct rb_node * parent;
 101
 102         TDB_DATA this_key, this_val;
 103
 104         if (rec_priv->node != NULL) {
 105
 106                 /*
 107                  * The record was around previously
 108                  */
 109
 110                 db_rbt_parse_node(rec_priv->node, &this_key, &this_val);
 111
 112                 SMB_ASSERT(this_key.dsize == rec->key.dsize);
 113                 SMB_ASSERT(memcmp(this_key.dptr, rec->key.dptr,
 114                                   this_key.dsize) == 0);
 115
 116                 if (this_val.dsize >= data.dsize) {
 117                         /*
 118                          * The new value fits into the old space
 119                          */
 120                         memcpy(this_val.dptr, data.dptr, data.dsize);
 121                         rec_priv->node->valuesize = data.dsize;
 122                         return NT_STATUS_OK;
 123                 }
 124         }
 125
 126         node = (struct db_rbt_node *)talloc_size(db_ctx,
 127                 offsetof(struct db_rbt_node, data) + rec->key.dsize
 128                 + data.dsize);
 129
 130         if (node == NULL) {
 131                 return NT_STATUS_NO_MEMORY;
 132         }
 133
 134         if (rec_priv->node != NULL) {
 135                 /*
 136                  * We need to delete the key from the tree and start fresh,
 137                  * there's not enough space in the existing record
 138                  */
 139
 140                 rb_erase(&rec_priv->node->rb_node, &db_ctx->tree);
 141
 142                 /*
 143                  * Keep the existing node around for a while: If the record
 144                  * existed before, we reference the key data in there.
 145                  */
 146         }
 147
 148         ZERO_STRUCT(node->rb_node);
 149
 150         node->keysize = rec->key.dsize;
 151         node->valuesize = data.dsize;
 152
 153         db_rbt_parse_node(node, &this_key, &this_val);
 154
 155         memcpy(this_key.dptr, rec->key.dptr, node->keysize);
 156         TALLOC_FREE(rec_priv->node);
 157         rec_priv->node = node;
 158
 159         memcpy(this_val.dptr, data.dptr, node->valuesize);
 160
 161         parent = NULL;
 162         p = &db_ctx->tree.rb_node;
 163
 164         while (*p) {
 165                 struct db_rbt_node *r;
 166                 TDB_DATA search_key, search_val;
 167                 int res;
 168
 169                 parent = (*p);
 170
 171                 r = db_rbt2node(*p);
 172
 173                 db_rbt_parse_node(r, &search_key, &search_val);
 174
 175                 res = db_rbt_compare(this_key, search_key);
 176
 177                 if (res == -1) {
 178                         p = &(*p)->rb_left;
 179                 }
 180                 else if (res == 1) {
 181                         p = &(*p)->rb_right;
 182                 }
 183                 else {
 184                         smb_panic("someone messed with the tree");
 185                 }
 186         }
 187
 188         rb_link_node(&node->rb_node, parent, p);
 189         rb_insert_color(&node->rb_node, &db_ctx->tree);
 190
 191         return NT_STATUS_OK;
 192 }
 193
 194 static NTSTATUS db_rbt_delete(struct db_record *rec)
 195 {
 196         struct db_rbt_ctx *db_ctx = talloc_get_type_abort(
 197                 rec->db->private_data, struct db_rbt_ctx);
 198         struct db_rbt_rec *rec_priv = (struct db_rbt_rec *)rec->private_data;
 199
 200         if (rec_priv->node == NULL) {
 201                 return NT_STATUS_OK;
 202         }
 203
 204         rb_erase(&rec_priv->node->rb_node, &db_ctx->tree);
 205         TALLOC_FREE(rec_priv->node);
 206
 207         return NT_STATUS_OK;
 208 }
 209 struct db_rbt_search_result {
 210         TDB_DATA key;
 211         TDB_DATA val;
 212         struct db_rbt_node* node;
 213 };
 214
 215 static bool db_rbt_search_internal(struct db_context *db, TDB_DATA key,
 216                                    struct db_rbt_search_result *result)
 217 {
 218         struct db_rbt_ctx *ctx = talloc_get_type_abort(
 219                 db->private_data, struct db_rbt_ctx);
 220
 221         struct rb_node *n;
 222         bool found = false;
 223         struct db_rbt_node *r = NULL;
 224         TDB_DATA search_key, search_val;
 225
 226         n = ctx->tree.rb_node;
 227
 228         while (n != NULL) {
 229                 int res;
 230
 231                 r = db_rbt2node(n);
 232
 233                 db_rbt_parse_node(r, &search_key, &search_val);
 234
 235                 res = db_rbt_compare(key, search_key);
 236
 237                 if (res == -1) {
 238                         n = n->rb_left;
 239                 }
 240                 else if (res == 1) {
 241                         n = n->rb_right;
 242                 }
 243                 else {
 244                         found = true;
 245                         break;
 246                 }
 247         }
 248         if (result != NULL) {
 249                 if (found) {
 250                         result->key = search_key;
 251                         result->val = search_val;
 252                         result->node = r;
 253                 } else {
 254                         ZERO_STRUCT(*result);
 255                 }
 256         }
 257         return found;
 258 }
 259
 260 static struct db_record *db_rbt_fetch_locked(struct db_context *db_ctx,
 261                                              TALLOC_CTX *mem_ctx,
 262                                              TDB_DATA key)
 263 {
 264         struct db_rbt_rec *rec_priv;
 265         struct db_record *result;
 266         size_t size;
 267         bool found;
 268         struct db_rbt_search_result res;
 269
 270         found = db_rbt_search_internal(db_ctx, key, &res);
 271
 272         /*
 273          * In this low-level routine, play tricks to reduce the number of
 274          * tallocs to one. Not recommened for general use, but here it pays
 275          * off.
 276          */
 277
 278         size = DBWRAP_RBT_ALIGN(sizeof(struct db_record))
 279                 + sizeof(struct db_rbt_rec);
 280
 281         if (!found) {
 282                 /*
 283                  * We need to keep the key around for later store
 284                  */
 285                 size += key.dsize;
 286         }
 287
 288         result = (struct db_record *)talloc_size(mem_ctx, size);
 289         if (result == NULL) {
 290                 return NULL;
 291         }
 292
 293         rec_priv = (struct db_rbt_rec *)
 294                 ((char *)result + DBWRAP_RBT_ALIGN(sizeof(struct db_record)));
 295
 296         result->store = db_rbt_store;
 297         result->delete_rec = db_rbt_delete;
 298         result->private_data = rec_priv;
 299
 300         rec_priv->node = res.node;
 301         result->value  = res.val;
 302
 303         if (found) {
 304                 result->key = res.key;
 305         }
 306         else {
 307                 result->key.dptr = (uint8_t *)
 308                         ((char *)rec_priv + sizeof(*rec_priv));
 309                 result->key.dsize = key.dsize;
 310                 memcpy(result->key.dptr, key.dptr, key.dsize);
 311         }
 312
 313         return result;
 314 }
 315
 316 static int db_rbt_exists(struct db_context *db, TDB_DATA key)
 317 {
 318         return db_rbt_search_internal(db, key, NULL);
 319 }
 320
 321 static int db_rbt_wipe(struct db_context *db)
 322 {
 323         struct db_rbt_ctx *old_ctx = talloc_get_type_abort(
 324                 db->private_data, struct db_rbt_ctx);
 325         struct db_rbt_ctx *new_ctx = talloc_zero(db, struct db_rbt_ctx);
 326         if (new_ctx == NULL) {
 327                 return -1;
 328         }
 329         db->private_data = new_ctx;
 330         talloc_free(old_ctx);
 331         return 0;
 332 }
 333
 334 static NTSTATUS db_rbt_parse_record(struct db_context *db, TDB_DATA key,
 335                                     void (*parser)(TDB_DATA key, TDB_DATA data,
 336                                                    void *private_data),
 337                                     void *private_data)
 338 {
 339         struct db_rbt_search_result res;
 340         bool found = db_rbt_search_internal(db, key, &res);
 341
 342         if (!found) {
 343                 return NT_STATUS_NOT_FOUND;
 344         }
 345         parser(res.key, res.val, private_data);
 346         return NT_STATUS_OK;
 347 }
 348
 349 static int db_rbt_traverse_internal(struct rb_node *n,
 350                                     int (*f)(struct db_record *db,
 351                                              void *private_data),
 352                                     void *private_data, uint32_t* count)
 353 {
 354         struct db_rbt_node *r;
 355         struct db_record rec;
 356         int ret;
 357
 358         if (n == NULL) {
 359                 return 0;
 360         }
 361
 362         ret = db_rbt_traverse_internal(n->rb_left, f, private_data, count);
 363         if (ret != 0) {
 364                 return ret;
 365         }
 366
 367         r = db_rbt2node(n);
 368         ZERO_STRUCT(rec);
 369         db_rbt_parse_node(r, &rec.key, &rec.value);
 370
 371         ret = f(&rec, private_data);
 372         (*count) ++;
 373         if (ret != 0) {
 374                 return ret;
 375         }
 376
 377         return db_rbt_traverse_internal(n->rb_right, f, private_data, count);
 378 }
 379
 380 static int db_rbt_traverse(struct db_context *db,
 381                            int (*f)(struct db_record *db,
 382                                     void *private_data),
 383                            void *private_data)
 384 {
 385         struct db_rbt_ctx *ctx = talloc_get_type_abort(
 386                 db->private_data, struct db_rbt_ctx);
 387         uint32_t count = 0;
 388
 389         int ret =  db_rbt_traverse_internal(ctx->tree.rb_node, f, private_data, &count);
 390         if (ret != 0) {
 391                 return -1;
 392         }
 393         if (count > INT_MAX) {
 394                 return -1;
 395         }
 396         return count;
 397 }
 398
 399 static int db_rbt_get_seqnum(struct db_context *db)
 400 {
 401         return 0;
 402 }
 403
 404 static int db_rbt_trans_dummy(struct db_context *db)
 405 {
 406         /*
 407          * Transactions are pretty pointless in-memory, just return success.
 408          */
 409         return 0;
 410 }
 411
 412 static void db_rbt_id(struct db_context *db, const uint8_t **id, size_t *idlen)
 413 {
 414         *id = (uint8_t *)db;
 415         *idlen = sizeof(struct db_context *);
 416 }
 417
 418 struct db_context *db_open_rbt(TALLOC_CTX *mem_ctx)
 419 {
 420         struct db_context *result;
 421
 422         result = talloc(mem_ctx, struct db_context);
 423
 424         if (result == NULL) {
 425                 return NULL;
 426         }
 427
 428         result->private_data = talloc_zero(result, struct db_rbt_ctx);
 429
 430         if (result->private_data == NULL) {
 431                 TALLOC_FREE(result);
 432                 return NULL;
 433         }
 434
 435         result->fetch_locked = db_rbt_fetch_locked;
 436         result->try_fetch_locked = NULL;
 437         result->traverse = db_rbt_traverse;
 438         result->traverse_read = db_rbt_traverse;
 439         result->get_seqnum = db_rbt_get_seqnum;
 440         result->transaction_start = db_rbt_trans_dummy;
 441         result->transaction_commit = db_rbt_trans_dummy;
 442         result->transaction_cancel = db_rbt_trans_dummy;
 443         result->exists = db_rbt_exists;
 444         result->wipe = db_rbt_wipe;
 445         result->parse_record = db_rbt_parse_record;
 446         result->lock_order = 0;
 447         result->id = db_rbt_id;
 448         result->stored_callback = NULL;
 449
 450         return result;
 451 }