2 Unix SMB/CIFS implementation.
3 Database interface wrapper around red-black trees
4 Copyright (C) Volker Lendecke 2007, 2008
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.
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.
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/>.
21 #include "dbwrap/dbwrap.h"
22 #include "dbwrap/dbwrap_private.h"
23 #include "dbwrap/dbwrap_rbt.h"
24 #include "../lib/util/rbtree.h"
26 #define DBWRAP_RBT_ALIGN(_size_) (((_size_)+15)&~15)
33 struct db_rbt_node
*node
;
36 /* The structure that ends up in the tree */
39 struct rb_node rb_node
;
40 size_t keysize
, valuesize
;
44 * Hide the ugly pointer calculations in a function
47 static struct db_rbt_node
*db_rbt2node(struct rb_node
*node
)
49 return (struct db_rbt_node
*)
50 ((char *)node
- offsetof(struct db_rbt_node
, rb_node
));
57 static int db_rbt_compare(TDB_DATA a
, TDB_DATA b
)
61 res
= memcmp(a
.dptr
, b
.dptr
, MIN(a
.dsize
, b
.dsize
));
63 if ((res
< 0) || ((res
== 0) && (a
.dsize
< b
.dsize
))) {
66 if ((res
> 0) || ((res
== 0) && (a
.dsize
> b
.dsize
))) {
73 * dissect a db_rbt_node into its implicit key and value parts
76 static void db_rbt_parse_node(struct db_rbt_node
*node
,
77 TDB_DATA
*key
, TDB_DATA
*value
)
79 size_t key_offset
, value_offset
;
81 key_offset
= DBWRAP_RBT_ALIGN(sizeof(struct db_rbt_node
));
82 key
->dptr
= ((uint8_t *)node
) + key_offset
;
83 key
->dsize
= node
->keysize
;
85 value_offset
= DBWRAP_RBT_ALIGN(node
->keysize
);
86 value
->dptr
= key
->dptr
+ value_offset
;
87 value
->dsize
= node
->valuesize
;
90 static ssize_t
db_rbt_reclen(size_t keylen
, size_t valuelen
)
94 len
= DBWRAP_RBT_ALIGN(sizeof(struct db_rbt_node
));
96 tmp
= DBWRAP_RBT_ALIGN(keylen
);
107 if (len
< valuelen
) {
116 static NTSTATUS
db_rbt_store(struct db_record
*rec
, TDB_DATA data
, int flag
)
118 struct db_rbt_ctx
*db_ctx
= talloc_get_type_abort(
119 rec
->db
->private_data
, struct db_rbt_ctx
);
120 struct db_rbt_rec
*rec_priv
= (struct db_rbt_rec
*)rec
->private_data
;
121 struct db_rbt_node
*node
;
124 struct rb_node
* parent
;
127 TDB_DATA this_key
, this_val
;
129 if (rec_priv
->node
!= NULL
) {
132 * The record was around previously
135 db_rbt_parse_node(rec_priv
->node
, &this_key
, &this_val
);
137 SMB_ASSERT(this_key
.dsize
== rec
->key
.dsize
);
138 SMB_ASSERT(memcmp(this_key
.dptr
, rec
->key
.dptr
,
139 this_key
.dsize
) == 0);
141 if (this_val
.dsize
>= data
.dsize
) {
143 * The new value fits into the old space
145 memcpy(this_val
.dptr
, data
.dptr
, data
.dsize
);
146 rec_priv
->node
->valuesize
= data
.dsize
;
151 reclen
= db_rbt_reclen(rec
->key
.dsize
, data
.dsize
);
153 return NT_STATUS_INSUFFICIENT_RESOURCES
;
156 node
= talloc_size(db_ctx
, reclen
);
158 return NT_STATUS_NO_MEMORY
;
161 if (rec_priv
->node
!= NULL
) {
163 * We need to delete the key from the tree and start fresh,
164 * there's not enough space in the existing record
167 rb_erase(&rec_priv
->node
->rb_node
, &db_ctx
->tree
);
170 * Keep the existing node around for a while: If the record
171 * existed before, we reference the key data in there.
175 ZERO_STRUCT(node
->rb_node
);
177 node
->keysize
= rec
->key
.dsize
;
178 node
->valuesize
= data
.dsize
;
180 db_rbt_parse_node(node
, &this_key
, &this_val
);
182 memcpy(this_key
.dptr
, rec
->key
.dptr
, node
->keysize
);
183 TALLOC_FREE(rec_priv
->node
);
184 rec_priv
->node
= node
;
186 memcpy(this_val
.dptr
, data
.dptr
, node
->valuesize
);
189 p
= &db_ctx
->tree
.rb_node
;
192 struct db_rbt_node
*r
;
193 TDB_DATA search_key
, search_val
;
200 db_rbt_parse_node(r
, &search_key
, &search_val
);
202 res
= db_rbt_compare(this_key
, search_key
);
211 smb_panic("someone messed with the tree");
215 rb_link_node(&node
->rb_node
, parent
, p
);
216 rb_insert_color(&node
->rb_node
, &db_ctx
->tree
);
221 static NTSTATUS
db_rbt_delete(struct db_record
*rec
)
223 struct db_rbt_ctx
*db_ctx
= talloc_get_type_abort(
224 rec
->db
->private_data
, struct db_rbt_ctx
);
225 struct db_rbt_rec
*rec_priv
= (struct db_rbt_rec
*)rec
->private_data
;
227 if (rec_priv
->node
== NULL
) {
231 rb_erase(&rec_priv
->node
->rb_node
, &db_ctx
->tree
);
232 TALLOC_FREE(rec_priv
->node
);
237 static NTSTATUS
db_rbt_store_deny(struct db_record
*rec
, TDB_DATA data
, int flag
)
239 return NT_STATUS_MEDIA_WRITE_PROTECTED
;
242 static NTSTATUS
db_rbt_delete_deny(struct db_record
*rec
)
244 return NT_STATUS_MEDIA_WRITE_PROTECTED
;
247 struct db_rbt_search_result
{
250 struct db_rbt_node
* node
;
253 static bool db_rbt_search_internal(struct db_context
*db
, TDB_DATA key
,
254 struct db_rbt_search_result
*result
)
256 struct db_rbt_ctx
*ctx
= talloc_get_type_abort(
257 db
->private_data
, struct db_rbt_ctx
);
261 struct db_rbt_node
*r
= NULL
;
262 TDB_DATA search_key
, search_val
;
264 n
= ctx
->tree
.rb_node
;
271 db_rbt_parse_node(r
, &search_key
, &search_val
);
273 res
= db_rbt_compare(key
, search_key
);
286 if (result
!= NULL
) {
288 result
->key
= search_key
;
289 result
->val
= search_val
;
292 ZERO_STRUCT(*result
);
298 static struct db_record
*db_rbt_fetch_locked(struct db_context
*db_ctx
,
302 struct db_rbt_rec
*rec_priv
;
303 struct db_record
*result
;
306 struct db_rbt_search_result res
;
308 found
= db_rbt_search_internal(db_ctx
, key
, &res
);
311 * In this low-level routine, play tricks to reduce the number of
312 * tallocs to one. Not recommened for general use, but here it pays
316 size
= DBWRAP_RBT_ALIGN(sizeof(struct db_record
))
317 + sizeof(struct db_rbt_rec
);
321 * We need to keep the key around for later store
326 result
= (struct db_record
*)talloc_size(mem_ctx
, size
);
327 if (result
== NULL
) {
331 rec_priv
= (struct db_rbt_rec
*)
332 ((char *)result
+ DBWRAP_RBT_ALIGN(sizeof(struct db_record
)));
334 result
->store
= db_rbt_store
;
335 result
->delete_rec
= db_rbt_delete
;
336 result
->private_data
= rec_priv
;
338 rec_priv
->node
= res
.node
;
339 result
->value
= res
.val
;
342 result
->key
= res
.key
;
345 result
->key
.dptr
= (uint8_t *)
346 ((char *)rec_priv
+ sizeof(*rec_priv
));
347 result
->key
.dsize
= key
.dsize
;
348 memcpy(result
->key
.dptr
, key
.dptr
, key
.dsize
);
354 static int db_rbt_exists(struct db_context
*db
, TDB_DATA key
)
356 return db_rbt_search_internal(db
, key
, NULL
);
359 static int db_rbt_wipe(struct db_context
*db
)
361 struct db_rbt_ctx
*old_ctx
= talloc_get_type_abort(
362 db
->private_data
, struct db_rbt_ctx
);
363 struct db_rbt_ctx
*new_ctx
= talloc_zero(db
, struct db_rbt_ctx
);
364 if (new_ctx
== NULL
) {
367 db
->private_data
= new_ctx
;
368 talloc_free(old_ctx
);
372 static NTSTATUS
db_rbt_parse_record(struct db_context
*db
, TDB_DATA key
,
373 void (*parser
)(TDB_DATA key
, TDB_DATA data
,
377 struct db_rbt_search_result res
;
378 bool found
= db_rbt_search_internal(db
, key
, &res
);
381 return NT_STATUS_NOT_FOUND
;
383 parser(res
.key
, res
.val
, private_data
);
387 static int db_rbt_traverse_internal(struct db_context
*db
,
389 int (*f
)(struct db_record
*db
,
391 void *private_data
, uint32_t* count
,
394 struct rb_node
*rb_right
;
395 struct rb_node
*rb_left
;
396 struct db_record rec
;
397 struct db_rbt_rec rec_priv
;
404 rb_left
= n
->rb_left
;
405 rb_right
= n
->rb_right
;
407 ret
= db_rbt_traverse_internal(db
, rb_left
, f
, private_data
, count
, rw
);
412 rec_priv
.node
= db_rbt2node(n
);
413 /* n might be altered by the callback function */
418 rec
.private_data
= &rec_priv
;
420 rec
.store
= db_rbt_store
;
421 rec
.delete_rec
= db_rbt_delete
;
423 rec
.store
= db_rbt_store_deny
;
424 rec
.delete_rec
= db_rbt_delete_deny
;
426 db_rbt_parse_node(rec_priv
.node
, &rec
.key
, &rec
.value
);
428 ret
= f(&rec
, private_data
);
434 if (rec_priv
.node
!= NULL
) {
436 * If the current record is still there
437 * we should take the current rb_right.
439 rb_right
= rec_priv
.node
->rb_node
.rb_right
;
442 return db_rbt_traverse_internal(db
, rb_right
, f
, private_data
, count
, rw
);
445 static int db_rbt_traverse(struct db_context
*db
,
446 int (*f
)(struct db_record
*db
,
450 struct db_rbt_ctx
*ctx
= talloc_get_type_abort(
451 db
->private_data
, struct db_rbt_ctx
);
454 int ret
= db_rbt_traverse_internal(db
, ctx
->tree
.rb_node
,
455 f
, private_data
, &count
,
460 if (count
> INT_MAX
) {
466 static int db_rbt_traverse_read(struct db_context
*db
,
467 int (*f
)(struct db_record
*db
,
471 struct db_rbt_ctx
*ctx
= talloc_get_type_abort(
472 db
->private_data
, struct db_rbt_ctx
);
475 int ret
= db_rbt_traverse_internal(db
, ctx
->tree
.rb_node
,
476 f
, private_data
, &count
,
481 if (count
> INT_MAX
) {
487 static int db_rbt_get_seqnum(struct db_context
*db
)
492 static int db_rbt_trans_dummy(struct db_context
*db
)
495 * Transactions are pretty pointless in-memory, just return success.
500 static size_t db_rbt_id(struct db_context
*db
, uint8_t *id
, size_t idlen
)
502 if (idlen
>= sizeof(struct db_context
*)) {
503 memcpy(id
, &db
, sizeof(struct db_context
*));
505 return sizeof(struct db_context
*);
508 struct db_context
*db_open_rbt(TALLOC_CTX
*mem_ctx
)
510 struct db_context
*result
;
512 result
= talloc_zero(mem_ctx
, struct db_context
);
514 if (result
== NULL
) {
518 result
->private_data
= talloc_zero(result
, struct db_rbt_ctx
);
520 if (result
->private_data
== NULL
) {
525 result
->fetch_locked
= db_rbt_fetch_locked
;
526 result
->traverse
= db_rbt_traverse
;
527 result
->traverse_read
= db_rbt_traverse_read
;
528 result
->get_seqnum
= db_rbt_get_seqnum
;
529 result
->transaction_start
= db_rbt_trans_dummy
;
530 result
->transaction_commit
= db_rbt_trans_dummy
;
531 result
->transaction_cancel
= db_rbt_trans_dummy
;
532 result
->exists
= db_rbt_exists
;
533 result
->wipe
= db_rbt_wipe
;
534 result
->parse_record
= db_rbt_parse_record
;
535 result
->id
= db_rbt_id
;
536 result
->name
= "dbwrap rbt";