← Back to branch summary

~ubuntu-branches/ubuntu/oneiric/jabberd2/oneiric-security

« back to all changes in this revision

Viewing changes to storage/storage_db.c

  • Committer: Bazaar Package Importer
  • Author(s): Nicolai Spohrer
  • Date: 2008-08-12 16:13:43 UTC
  • mfrom: (1.1.3 upstream) (0.1.2 sid)
  • Revision ID: james.westby@ubuntu.com-20080812161343-6trz3r97dtevxd17
Tags: 2.2.1-1ubuntu1
https://launchpad.net/bugs/257130
* Merge with Debian unstable (LP: #257130), remaining changes:
  - debian/control:
    + Modify Maintainer field as per spec
    + Depend on libdb4.6-dev instead of libdb4.4-dev
    + Added Conflicts and Replaces: ..., jabber for jabberd2
  - debian/rules: Added libtoolize call (jabberd2 ships with
     an older ltmain.sh version that conflicts with the
     current libtool version)
  - debian/init: create /var/run/jabber directory with correct
     permissions
* Dropped changes:
  - Debian already depends on libpq-dev

Show diffs side-by-side

added added

removed removed

Lines of Context:
storage/storage_db.c
 
1
/*
 
2
 * jabberd - Jabber Open Source Server
 
3
 * Copyright (c) 2002 Jeremie Miller, Thomas Muldowney,
 
4
 *                    Ryan Eatmon, Robert Norris
 
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 2 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, write to the Free Software
 
18
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA02111-1307USA
 
19
 */
 
20
 
 
21
/** @file sm/storage_db.c
 
22
  * @brief berkeley db storage module
 
23
  * @author Robert Norris
 
24
  * $Date: 2005/06/02 04:48:25 $
 
25
  * $Revision: 1.26 $
 
26
  */
 
27
 
 
28
/*
 
29
 * !!! we must catch DB_RUNRECOVERY and call _st_db_panic(). I would argue that
 
30
 *     Berkeley should do this for all cases, not just for the process that
 
31
 *     caused the fault, but I'm not sure they see it that way. (I have asked,
 
32
 *     just waiting for a reply)
 
33
 *
 
34
 *     Sleepycat SR#7019 resolved this. There is an unreleased patch available
 
35
 *     (I have a copy) that will be in 4.2 (due in June).
 
36
 */
 
37
 
 
38
#include "sm.h"
 
39
#include <db.h>
 
40
 
 
41
/** internal structure, holds our data */
 
42
typedef struct drvdata_st {
 
43
    DB_ENV *env;
 
44
 
 
45
    char *path;
 
46
    int sync;
 
47
 
 
48
    xht dbs;
 
49
 
 
50
    xht filters;
 
51
} *drvdata_t;
 
52
 
 
53
/** internal structure, holds a single db handle */
 
54
typedef struct dbdata_st {
 
55
    drvdata_t data;
 
56
 
 
57
    DB *db;
 
58
} *dbdata_t;
 
59
 
 
60
/* union for strict alias rules in gcc3 */
 
61
union xhashv {
 
62
  void **val;
 
63
  dbdata_t *dbd_val;
 
64
};
 
65
 
 
66
static st_ret_t _st_db_add_type(st_driver_t drv, const char *type) {
 
67
    drvdata_t data = (drvdata_t) drv->private;
 
68
    dbdata_t dbd;
 
69
    int err;
 
70
    
 
71
    dbd = (dbdata_t) calloc(1, sizeof(struct dbdata_st));
 
72
 
 
73
    dbd->data = data;
 
74
 
 
75
    if((err = db_create(&(dbd->db), data->env, 0)) != 0) {
 
76
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't create db handle: %s", db_strerror(err));
 
77
        free(dbd);
 
78
        return st_FAILED;
 
79
    }
 
80
 
 
81
    if((err = dbd->db->set_flags(dbd->db, DB_DUP)) != 0) {
 
82
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't set database for duplicate storage: %s", db_strerror(err));
 
83
        dbd->db->close(dbd->db, 0);
 
84
        free(dbd);
 
85
        return st_FAILED;
 
86
    }
 
87
 
 
88
    if((err = dbd->db->open(dbd->db, NULL, "sm.db", type, DB_HASH, DB_AUTO_COMMIT | DB_CREATE, 0)) != 0) {
 
89
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't open storage db: %s", db_strerror(err));
 
90
        dbd->db->close(dbd->db, 0);
 
91
        free(dbd);
 
92
        return st_FAILED;
 
93
    }
 
94
 
 
95
    xhash_put(data->dbs, type, dbd);
 
96
 
 
97
    return st_SUCCESS;
 
98
}
 
99
 
 
100
/** make a new cursor (optionally wrapped in a txn) */
 
101
static st_ret_t _st_db_cursor_new(st_driver_t drv, dbdata_t dbd, DBC **cursor, DB_TXN **txnid) {
 
102
    int err;
 
103
 
 
104
    if(txnid != NULL)
 
105
        if((err = dbd->data->env->txn_begin(dbd->data->env, NULL, txnid, DB_TXN_SYNC)) != 0) {
 
106
            log_write(drv->st->sm->log, LOG_ERR, "db: couldn't begin new transaction: %s", db_strerror(err));
 
107
            return st_FAILED;
 
108
        }
 
109
 
 
110
    if(txnid == NULL)
 
111
        err = dbd->db->cursor(dbd->db, NULL, cursor, 0);
 
112
    else
 
113
        err = dbd->db->cursor(dbd->db, *txnid, cursor, 0);
 
114
 
 
115
    if(err != 0) {
 
116
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't create cursor: %s", db_strerror(err));
 
117
        if(txnid != NULL)
 
118
            (*txnid)->abort(*txnid);
 
119
        return st_FAILED;
 
120
    }
 
121
 
 
122
    return st_SUCCESS;
 
123
}
 
124
 
 
125
/** close down a cursor */
 
126
static st_ret_t _st_db_cursor_free(st_driver_t drv, dbdata_t dbd, DBC *cursor, DB_TXN *txnid) {
 
127
    int err;
 
128
 
 
129
    if((err = cursor->c_close(cursor)) != 0) {
 
130
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't close cursor: %s", db_strerror(err));
 
131
        if(txnid != NULL)
 
132
            txnid->abort(txnid);
 
133
        return st_FAILED;
 
134
    }
 
135
 
 
136
    if(txnid != NULL)
 
137
        if((err = txnid->commit(txnid, DB_TXN_SYNC)) != 0) {
 
138
            log_write(drv->st->sm->log, LOG_ERR, "db: couldn't commit transaction: %s", db_strerror(err));
 
139
            return st_FAILED;
 
140
        }
 
141
 
 
142
    return st_SUCCESS;
 
143
}
 
144
 
 
145
static void _st_db_object_serialise(os_object_t o, char **buf, int *len) {
 
146
    char *key, *xml, *xmlstr;
 
147
    void *val;
 
148
    os_type_t ot;
 
149
    int cur = 0, xlen;
 
150
 
 
151
    log_debug(ZONE, "serialising object");
 
152
 
 
153
    *buf = NULL;
 
154
    *len = 0;
 
155
 
 
156
    if(os_object_iter_first(o))
 
157
        do {
 
158
            os_object_iter_get(o, &key, &val, &ot);
 
159
            
 
160
            log_debug(ZONE, "serialising key %s", key);
 
161
 
 
162
            ser_string_set(key, &cur, buf, len);
 
163
            ser_int_set(ot, &cur, buf, len);
 
164
 
 
165
            switch(ot) {
 
166
                case os_type_BOOLEAN:
 
167
                    ser_int_set(((int) val) != 0, &cur, buf, len);
 
168
                    break;
 
169
 
 
170
                case os_type_INTEGER:
 
171
                    ser_int_set((int) val, &cur, buf, len);
 
172
                    break;
 
173
 
 
174
                case os_type_STRING:
 
175
                    ser_string_set((char *) val, &cur, buf, len);
 
176
                    break;
 
177
 
 
178
                case os_type_NAD:
 
179
                    nad_print((nad_t) val, 0, &xml, &xlen);
 
180
                    xmlstr = (char *) malloc(sizeof(char) * (xlen + 1));
 
181
                    sprintf(xmlstr, "%.*s", xlen, xml);
 
182
                    ser_string_set(xmlstr, &cur, buf, len);
 
183
                    free(xmlstr);
 
184
                    break;
 
185
 
 
186
                case os_type_UNKNOWN:
 
187
                    break;
 
188
            }
 
189
        } while(os_object_iter_next(o));
 
190
 
 
191
    *len = cur;
 
192
}
 
193
 
 
194
static os_object_t _st_db_object_deserialise(st_driver_t drv, os_t os, const char *buf, int len) {
 
195
    os_object_t o;
 
196
    int cur;
 
197
    char *key, *sval;
 
198
    int ot;
 
199
    int ival;
 
200
    nad_t nad;
 
201
 
 
202
    log_debug(ZONE, "deserialising object");
 
203
 
 
204
    o = os_object_new(os);
 
205
 
 
206
    cur = 0;
 
207
    while(cur < len) {
 
208
        if(ser_string_get(&key, &cur, buf, len) != 0 || ser_int_get(&ot, &cur, buf, len) != 0) {
 
209
            log_debug(ZONE, "ran off the end of the buffer");
 
210
            return o;
 
211
        }
 
212
 
 
213
        log_debug(ZONE, "deserialising key %s", key);
 
214
 
 
215
        switch((os_type_t) ot) {
 
216
            case os_type_BOOLEAN:
 
217
                ser_int_get(&ival, &cur, buf, len);
 
218
                ival = (ival != 0);
 
219
                os_object_put(o, key, &ival, os_type_BOOLEAN);
 
220
                break;
 
221
 
 
222
            case os_type_INTEGER:
 
223
                ser_int_get(&ival, &cur, buf, len);
 
224
                os_object_put(o, key, &ival, os_type_INTEGER);
 
225
                break;
 
226
 
 
227
            case os_type_STRING:
 
228
                ser_string_get(&sval, &cur, buf, len);
 
229
                os_object_put(o, key, sval, os_type_STRING);
 
230
                free(sval);
 
231
                break;
 
232
 
 
233
            case os_type_NAD:
 
234
                ser_string_get(&sval, &cur, buf, len);
 
235
                nad = nad_parse(drv->st->sm->router->nad_cache, sval, strlen(sval));
 
236
                free(sval);
 
237
                if(nad == NULL) {
 
238
                    log_write(drv->st->sm->log, LOG_ERR, "db: unable to parse stored XML - database corruption?");
 
239
                    return NULL;
 
240
                }
 
241
                os_object_put(o, key, nad, os_type_NAD);
 
242
                nad_free(nad);
 
243
                break;
 
244
  
 
245
           case os_type_UNKNOWN:
 
246
                break;
 
247
        }
 
248
 
 
249
        free(key);
 
250
    }
 
251
 
 
252
    return o;
 
253
}
 
254
 
 
255
static st_ret_t _st_db_put_guts(st_driver_t drv, const char *type, const char *owner, os_t os, dbdata_t dbd, DBC *c, DB_TXN *t) {
 
256
    DBT key, val;
 
257
    os_object_t o;
 
258
    char *buf;
 
259
    int len, err;
 
260
 
 
261
    memset(&key, 0, sizeof(DBT));
 
262
    memset(&val, 0, sizeof(DBT));
 
263
 
 
264
    key.data = (char *) owner;
 
265
    key.size = strlen(owner);
 
266
 
 
267
    if(os_iter_first(os))
 
268
        do {
 
269
            o = os_iter_object(os);
 
270
            _st_db_object_serialise(o, &buf, &len);
 
271
 
 
272
            val.data = buf;
 
273
            val.size = len;
 
274
        
 
275
            if((err = c->c_put(c, &key, &val, DB_KEYLAST)) != 0) {
 
276
                log_write(drv->st->sm->log, LOG_ERR, "db: couldn't store value for type %s owner %s in storage db: %s", type, owner, db_strerror(err));
 
277
                free(buf);
 
278
                return st_FAILED;
 
279
            }
 
280
 
 
281
            free(buf);
 
282
 
 
283
        } while(os_iter_next(os));
 
284
 
 
285
    return st_SUCCESS;
 
286
}
 
287
 
 
288
static st_ret_t _st_db_put(st_driver_t drv, const char *type, const char *owner, os_t os) {
 
289
    drvdata_t data = (drvdata_t) drv->private;
 
290
    dbdata_t dbd = xhash_get(data->dbs, type);
 
291
    DBC *c;
 
292
    DB_TXN *t;
 
293
    st_ret_t ret;
 
294
 
 
295
    if(os_count(os) == 0)
 
296
        return st_SUCCESS;
 
297
 
 
298
    ret = _st_db_cursor_new(drv, dbd, &c, &t);
 
299
    if(ret != st_SUCCESS)
 
300
        return ret;
 
301
 
 
302
    ret = _st_db_put_guts(drv, type, owner, os, dbd, c, t);
 
303
    if(ret != st_SUCCESS) {
 
304
        t->abort(t);
 
305
        _st_db_cursor_free(drv, dbd, c, NULL);
 
306
        return st_FAILED;
 
307
    }
 
308
 
 
309
    return _st_db_cursor_free(drv, dbd, c, t);
 
310
}
 
311
 
 
312
static st_ret_t _st_db_get(st_driver_t drv, const char *type, const char *owner, const char *filter, os_t *os) {
 
313
    drvdata_t data = (drvdata_t) drv->private;
 
314
    dbdata_t dbd = xhash_get(data->dbs, type);
 
315
    DBC *c;
 
316
    DB_TXN *t;
 
317
    st_ret_t ret;
 
318
    DBT key, val;
 
319
    st_filter_t f;
 
320
    int err;
 
321
    os_object_t o;
 
322
    char *cfilter;
 
323
 
 
324
    ret = _st_db_cursor_new(drv, dbd, &c, &t);
 
325
    if(ret != st_SUCCESS)
 
326
        return ret;
 
327
 
 
328
    f = NULL;
 
329
    if(filter != NULL) {
 
330
        f = xhash_get(data->filters, filter);
 
331
        if(f == NULL) {
 
332
            f = storage_filter(filter);
 
333
            cfilter = pstrdup(xhash_pool(data->filters), filter);
 
334
            xhash_put(data->filters, cfilter, (void *) f);
 
335
            pool_cleanup(xhash_pool(data->filters), (pool_cleanup_t) pool_free, f->p);
 
336
        }
 
337
    }
 
338
 
 
339
    memset(&key, 0, sizeof(DBT));
 
340
    memset(&val, 0, sizeof(DBT));
 
341
 
 
342
    key.data = (char *) owner;
 
343
    key.size = strlen(owner);
 
344
 
 
345
    *os = os_new();
 
346
 
 
347
    err = c->c_get(c, &key, &val, DB_SET);
 
348
    while(err == 0) {
 
349
        o = _st_db_object_deserialise(drv, *os, val.data, val.size);
 
350
 
 
351
        if(o != NULL && !storage_match(f, o, *os))
 
352
            os_object_free(o);
 
353
 
 
354
        err = c->c_get(c, &key, &val, DB_NEXT_DUP);
 
355
    }
 
356
 
 
357
    if(err != 0 && err != DB_NOTFOUND) {
 
358
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't move cursor for type %s owner %s in storage db: %s", type, owner, db_strerror(err));
 
359
        t->abort(t);
 
360
        _st_db_cursor_free(drv, dbd, c, NULL);
 
361
        os_free(*os);
 
362
        return st_FAILED;
 
363
    }
 
364
 
 
365
    ret = _st_db_cursor_free(drv, dbd, c, t);
 
366
    if(ret != st_SUCCESS) {
 
367
        os_free(*os);
 
368
        return ret;
 
369
    }
 
370
 
 
371
    if(os_count(*os) == 0) {
 
372
        os_free(*os);
 
373
        return st_NOTFOUND;
 
374
    }
 
375
 
 
376
    return st_SUCCESS;
 
377
}
 
378
 
 
379
static st_ret_t _st_db_delete_guts(st_driver_t drv, const char *type, const char *owner, const char *filter, dbdata_t dbd, DBC *c, DB_TXN *t) {
 
380
    drvdata_t data = (drvdata_t) drv->private;
 
381
    DBT key, val;
 
382
    st_filter_t f;
 
383
    int err;
 
384
    os_t os;
 
385
    os_object_t o;
 
386
    char *cfilter;
 
387
 
 
388
    f = NULL;
 
389
    if(filter != NULL) {
 
390
        f = xhash_get(data->filters, filter);
 
391
        if(f == NULL) {
 
392
            f = storage_filter(filter);
 
393
            cfilter = pstrdup(xhash_pool(data->filters), filter);
 
394
            xhash_put(data->filters, cfilter, (void *) f);
 
395
            pool_cleanup(xhash_pool(data->filters), (pool_cleanup_t) pool_free, f->p);
 
396
        }
 
397
    }
 
398
 
 
399
    memset(&key, 0, sizeof(DBT));
 
400
    memset(&val, 0, sizeof(DBT));
 
401
 
 
402
    key.data = (char *) owner;
 
403
    key.size = strlen(owner);
 
404
 
 
405
    os = os_new();
 
406
 
 
407
    err = c->c_get(c, &key, &val, DB_SET);
 
408
    while(err == 0) {
 
409
        o = _st_db_object_deserialise(drv, os, val.data, val.size);
 
410
 
 
411
        if(o != NULL && storage_match(f, o, os))
 
412
            err = c->c_del(c, 0);
 
413
 
 
414
        if(err == 0)
 
415
            err = c->c_get(c, &key, &val, DB_NEXT_DUP);
 
416
    }
 
417
 
 
418
    os_free(os);
 
419
 
 
420
    if(err != 0 && err != DB_NOTFOUND) {
 
421
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't move cursor for type %s owner %s in storage db: %s", type, owner, db_strerror(err));
 
422
        return st_FAILED;
 
423
    }
 
424
 
 
425
    return st_SUCCESS;
 
426
}
 
427
 
 
428
static st_ret_t _st_db_delete(st_driver_t drv, const char *type, const char *owner, const char *filter) {
 
429
    drvdata_t data = (drvdata_t) drv->private;
 
430
    dbdata_t dbd = xhash_get(data->dbs, type);
 
431
    DBC *c;
 
432
    DB_TXN *t;
 
433
    st_ret_t ret;
 
434
 
 
435
    ret = _st_db_cursor_new(drv, dbd, &c, &t);
 
436
    if(ret != st_SUCCESS)
 
437
        return ret;
 
438
 
 
439
    ret = _st_db_delete_guts(drv, type, owner, filter, dbd, c, t);
 
440
    if(ret != st_SUCCESS) {
 
441
        t->abort(t);
 
442
        _st_db_cursor_free(drv, dbd, c, NULL);
 
443
        return st_FAILED;
 
444
    }
 
445
 
 
446
    return _st_db_cursor_free(drv, dbd, c, t);
 
447
}
 
448
 
 
449
static st_ret_t _st_db_replace(st_driver_t drv, const char *type, const char *owner, const char *filter, os_t os) {
 
450
    drvdata_t data = (drvdata_t) drv->private;
 
451
    dbdata_t dbd = xhash_get(data->dbs, type);
 
452
    DBC *c;
 
453
    DB_TXN *t;
 
454
    st_ret_t ret;
 
455
 
 
456
    ret = _st_db_cursor_new(drv, dbd, &c, &t);
 
457
    if(ret != st_SUCCESS)
 
458
        return ret;
 
459
 
 
460
    ret = _st_db_delete_guts(drv, type, owner, filter, dbd, c, t);
 
461
    if(ret != st_SUCCESS) {
 
462
        t->abort(t);
 
463
        _st_db_cursor_free(drv, dbd, c, NULL);
 
464
        return st_FAILED;
 
465
    }
 
466
 
 
467
    if(os_count(os) == 0)
 
468
        return _st_db_cursor_free(drv, dbd, c, t);
 
469
 
 
470
    ret = _st_db_put_guts(drv, type, owner, os, dbd, c, t);
 
471
    if(ret != st_SUCCESS) {
 
472
        t->abort(t);
 
473
        _st_db_cursor_free(drv, dbd, c, NULL);
 
474
        return st_FAILED;
 
475
    }
 
476
 
 
477
    return _st_db_cursor_free(drv, dbd, c, t);
 
478
}
 
479
 
 
480
static void _st_db_free(st_driver_t drv) {
 
481
    drvdata_t data = (drvdata_t) drv->private;
 
482
    const char *key;
 
483
    dbdata_t dbd;
 
484
    DB_ENV *env;
 
485
    union xhashv xhv;
 
486
 
 
487
    xhv.dbd_val = &dbd;
 
488
    if(xhash_iter_first(data->dbs))
 
489
        do {
 
490
            xhash_iter_get(data->dbs, &key, xhv.val);
 
491
 
 
492
            log_debug(ZONE, "closing %s db", key);
 
493
 
 
494
            dbd->db->close(dbd->db, 0);
 
495
            free(dbd);
 
496
        } while(xhash_iter_next(data->dbs));
 
497
 
 
498
    xhash_free(data->dbs);
 
499
 
 
500
    xhash_free(data->filters);
 
501
 
 
502
    data->env->close(data->env, 0);
 
503
 
 
504
    /* remove db environment files if no longer in use */
 
505
    if (db_env_create(&env, 0) == 0)
 
506
        env->remove(env, data->path, 0);
 
507
 
 
508
    free(data);
 
509
}
 
510
 
 
511
/** panic function */
 
512
static void _st_db_panic(DB_ENV *env, int errval) {
 
513
    log_t log = (log_t) env->app_private;
 
514
 
 
515
    log_write(log, LOG_CRIT, "db: corruption detected! close all jabberd processes and run db_recover");
 
516
 
 
517
    exit(2);
 
518
}
 
519
 
 
520
st_ret_t st_init(st_driver_t drv) {
 
521
    char *path;
 
522
    int err;
 
523
    DB_ENV *env;
 
524
    drvdata_t data;
 
525
 
 
526
    path = config_get_one(drv->st->sm->config, "storage.db.path", 0);
 
527
    if(path == NULL) {
 
528
        log_write(drv->st->sm->log, LOG_ERR, "db: no path specified in config file");
 
529
        return st_FAILED;
 
530
    }
 
531
 
 
532
    if((err = db_env_create(&env, 0)) != 0) {
 
533
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't create environment: %s", db_strerror(err));
 
534
        return st_FAILED;
 
535
    }
 
536
 
 
537
    if((err = env->set_paniccall(env, _st_db_panic)) != 0) {
 
538
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't set panic call: %s", db_strerror(err));
 
539
        return st_FAILED;
 
540
    }
 
541
 
 
542
    /* store the log context in case we panic */
 
543
    env->app_private = drv->st->sm->log;
 
544
 
 
545
    if((err = env->open(env, path, DB_INIT_LOCK | DB_INIT_MPOOL | DB_INIT_LOG | DB_INIT_TXN | DB_CREATE, 0)) != 0) {
 
546
        log_write(drv->st->sm->log, LOG_ERR, "db: couldn't open environment: %s", db_strerror(err));
 
547
        env->close(env, 0);
 
548
        return st_FAILED;
 
549
    }
 
550
 
 
551
    data = (drvdata_t) calloc(1, sizeof(struct drvdata_st));
 
552
 
 
553
    data->env = env;
 
554
    data->path = path;
 
555
 
 
556
    if(config_get_one(drv->st->sm->config, "storage.db.sync", 0) != NULL)
 
557
        data->sync = 1;
 
558
 
 
559
    data->dbs = xhash_new(101);
 
560
 
 
561
    data->filters = xhash_new(17);
 
562
 
 
563
    drv->private = (void *) data;
 
564
 
 
565
    drv->add_type = _st_db_add_type;
 
566
    drv->put = _st_db_put;
 
567
    drv->get = _st_db_get;
 
568
    drv->replace = _st_db_replace;
 
569
    drv->delete = _st_db_delete;
 
570
    drv->free = _st_db_free;
 
571
 
 
572
    return st_SUCCESS;
 
573
}