2 Unix SMB/CIFS implementation.
3 Database interface wrapper around red-black trees
4 Copyright (C) Volker Lendecke 2007
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/>.
28 struct db_rbt_ctx *db_ctx;
29 struct db_rbt_node *node;
32 /* The structure that ends up in the tree */
35 struct rb_node rb_node;
36 size_t keysize, valuesize;
39 * key and value are appended implicitly, "data" is only here as a
40 * target for offsetof()
47 * dissect a db_rbt_node into its implicit key and value parts
50 static void db_rbt_parse_node(struct db_rbt_node *node,
51 TDB_DATA *key, TDB_DATA *value)
53 key->dptr = ((uint8 *)node) + offsetof(struct db_rbt_node, data);
54 key->dsize = node->keysize;
55 value->dptr = key->dptr + node->keysize;
56 value->dsize = node->valuesize;
59 static NTSTATUS db_rbt_store(struct db_record *rec, TDB_DATA data, int flag)
61 struct db_rbt_rec *rec_priv = talloc_get_type_abort(
62 rec->private_data, struct db_rbt_rec);
64 struct db_rbt_node *node;
67 struct rb_node * parent;
69 TDB_DATA this_key, this_val;
71 if (rec_priv->node != NULL) {
74 * The record was around previously
77 db_rbt_parse_node(rec_priv->node, &this_key, &this_val);
79 SMB_ASSERT(this_key.dsize == rec->key.dsize);
80 SMB_ASSERT(memcmp(this_key.dptr, rec->key.dptr,
81 this_key.dsize) == 0);
83 if (this_val.dsize >= data.dsize) {
85 * The new value fits into the old space
87 memcpy(this_val.dptr, data.dptr, data.dsize);
88 rec_priv->node->valuesize = data.dsize;
93 * We need to delete the key from the tree and start fresh,
94 * there's not enough space in the existing record
97 rb_erase(&rec_priv->node->rb_node, &rec_priv->db_ctx->tree);
98 SAFE_FREE(rec_priv->node);
101 node = (struct db_rbt_node *)SMB_MALLOC(
102 offsetof(struct db_rbt_node, data) + rec->key.dsize
106 return NT_STATUS_NO_MEMORY;
109 ZERO_STRUCT(node->rb_node);
111 node->keysize = rec->key.dsize;
112 node->valuesize = data.dsize;
114 db_rbt_parse_node(node, &this_key, &this_val);
116 memcpy(this_key.dptr, rec->key.dptr, node->keysize);
117 memcpy(this_val.dptr, data.dptr, node->valuesize);
120 p = &rec_priv->db_ctx->tree.rb_node;
123 struct db_rbt_node *r;
124 TDB_DATA search_key, search_val;
129 r = (struct db_rbt_node *)
130 ((char *)(*p) - offsetof(struct db_rbt_node, rb_node));
132 db_rbt_parse_node(r, &search_key, &search_val);
134 res = memcmp(this_key.dptr, search_key.dptr,
135 MIN(this_key.dsize, search_key.dsize));
139 && (this_key.dsize < search_key.dsize))) {
144 && (this_key.dsize > search_key.dsize))) {
148 smb_panic("someone messed with the tree");
152 rb_link_node(&node->rb_node, parent, p);
153 rb_insert_color(&node->rb_node, &rec_priv->db_ctx->tree);
158 static NTSTATUS db_rbt_delete(struct db_record *rec)
160 struct db_rbt_rec *rec_priv = talloc_get_type_abort(
161 rec->private_data, struct db_rbt_rec);
163 if (rec_priv->node == NULL) {
167 rb_erase(&rec_priv->node->rb_node, &rec_priv->db_ctx->tree);
168 SAFE_FREE(rec_priv->node);
173 static struct db_record *db_rbt_fetch_locked(struct db_context *db_ctx,
177 struct db_rbt_ctx *ctx = talloc_get_type_abort(
178 db_ctx->private_data, struct db_rbt_ctx);
180 struct db_rbt_rec *rec_priv;
181 struct db_record *result;
184 result = talloc(mem_ctx, struct db_record);
186 if (result == NULL) {
190 rec_priv = talloc(result, struct db_rbt_rec);
192 if (rec_priv == NULL) {
197 rec_priv->db_ctx = ctx;
199 result->store = db_rbt_store;
200 result->delete_rec = db_rbt_delete;
201 result->private_data = rec_priv;
203 n = ctx->tree.rb_node;
206 struct db_rbt_node *r;
207 TDB_DATA search_key, search_val;
210 r = (struct db_rbt_node *)
211 ((char *)n - offsetof(struct db_rbt_node, rb_node));
213 db_rbt_parse_node(r, &search_key, &search_val);
215 res = memcmp(key.dptr, search_key.dptr,
216 MIN(key.dsize, search_key.dsize));
219 || ((res == 0) && (key.dsize < search_key.dsize))) {
223 || ((res == 0) && (key.dsize > search_key.dsize))) {
228 result->key = search_key;
229 result->value = search_val;
234 result->key.dsize = key.dsize;
235 result->key.dptr = (uint8_t *)talloc_memdup(
236 result, key.dptr, key.dsize);
238 if (result->key.dptr == NULL) {
243 rec_priv->node = NULL;
244 result->value.dsize = 0;
245 result->value.dptr = NULL;
249 static int db_rbt_fetch(struct db_context *db, TALLOC_CTX *mem_ctx,
250 TDB_DATA key, TDB_DATA *data)
252 struct db_record *rec;
254 if (!(rec = db->fetch_locked(db, mem_ctx, key))) {
258 data->dsize = rec->value.dsize;
259 data->dptr = (uint8 *)talloc_memdup(mem_ctx, rec->value.dptr,
266 static int db_rbt_traverse(struct db_context *db,
267 int (*f)(struct db_record *db,
274 static int db_rbt_get_seqnum(struct db_context *db)
279 struct db_context *db_open_rbt(TALLOC_CTX *mem_ctx)
281 struct db_context *result;
283 result = talloc(mem_ctx, struct db_context);
285 if (result == NULL) {
289 result->private_data = TALLOC_ZERO_P(result, struct db_rbt_ctx);
291 if (result->private_data == NULL) {
296 result->fetch_locked = db_rbt_fetch_locked;
297 result->fetch = db_rbt_fetch;
298 result->traverse = db_rbt_traverse;
299 result->traverse_read = db_rbt_traverse;
300 result->get_seqnum = db_rbt_get_seqnum;