2 This file is part of PulseAudio.
4 Copyright 2009 Lennart Poettering
6 PulseAudio is free software; you can redistribute it and/or modify
7 it under the terms of the GNU Lesser General Public License as
8 published by the Free Software Foundation; either version 2.1 of the
9 License, or (at your option) any later version.
11 PulseAudio is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 Lesser General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public
17 License along with PulseAudio; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
30 /* Some versions of tdb lack inclusion of signal.h in the header files but use sigatomic_t */
34 #include <pulse/xmalloc.h>
35 #include <pulsecore/core-util.h>
36 #include <pulsecore/log.h>
40 #define MAKE_TDB_CONTEXT(x) ((struct tdb_context*) (x))
42 static inline TDB_DATA
* datum_to_tdb(TDB_DATA
*to
, const pa_datum
*from
) {
46 to
->dptr
= from
->data
;
47 to
->dsize
= from
->size
;
52 static inline pa_datum
* datum_from_tdb(pa_datum
*to
, const TDB_DATA
*from
) {
56 to
->data
= from
->dptr
;
57 to
->size
= from
->dsize
;
62 void pa_datum_free(pa_datum
*d
) {
65 free(d
->data
); /* tdb uses raw malloc/free hence we should do that here, too */
69 pa_database
* pa_database_open(const char *fn
, pa_bool_t for_write
) {
70 struct tdb_context
*c
;
75 path
= pa_sprintf_malloc("%s.tdb", fn
);
77 c
= tdb_open(path
, 0, TDB_NOSYNC
|TDB_NOLOCK
,
78 (for_write
? O_RDWR
|O_CREAT
: O_RDONLY
)|O_NOCTTY
85 pa_log_debug("Opened TDB database '%s'", path
);
95 return (pa_database
*) c
;
98 void pa_database_close(pa_database
*db
) {
101 tdb_close(MAKE_TDB_CONTEXT(db
));
104 pa_datum
* pa_database_get(pa_database
*db
, const pa_datum
*key
, pa_datum
* data
) {
105 TDB_DATA tdb_key
, tdb_data
;
111 tdb_data
= tdb_fetch(MAKE_TDB_CONTEXT(db
), *datum_to_tdb(&tdb_key
, key
));
113 return tdb_data
.dptr
?
114 datum_from_tdb(data
, &tdb_data
) :
118 int pa_database_set(pa_database
*db
, const pa_datum
*key
, const pa_datum
* data
, pa_bool_t overwrite
) {
119 TDB_DATA tdb_key
, tdb_data
;
125 return tdb_store(MAKE_TDB_CONTEXT(db
),
126 *datum_to_tdb(&tdb_key
, key
),
127 *datum_to_tdb(&tdb_data
, data
),
128 overwrite
? TDB_REPLACE
: TDB_INSERT
) != 0 ? -1 : 0;
131 int pa_database_unset(pa_database
*db
, const pa_datum
*key
) {
137 return tdb_delete(MAKE_TDB_CONTEXT(db
), *datum_to_tdb(&tdb_key
, key
)) != 0 ? -1 : 0;
140 int pa_database_clear(pa_database
*db
) {
143 return tdb_wipe_all(MAKE_TDB_CONTEXT(db
)) != 0 ? -1 : 0;
146 signed pa_database_size(pa_database
*db
) {
154 tdb_key
= tdb_firstkey(MAKE_TDB_CONTEXT(db
));
156 while (tdb_key
.dptr
) {
161 next
= tdb_nextkey(MAKE_TDB_CONTEXT(db
), tdb_key
);
169 pa_datum
* pa_database_first(pa_database
*db
, pa_datum
*key
, pa_datum
*data
) {
170 TDB_DATA tdb_key
, tdb_data
;
175 tdb_key
= tdb_firstkey(MAKE_TDB_CONTEXT(db
));
181 tdb_data
= tdb_fetch(MAKE_TDB_CONTEXT(db
), tdb_key
);
183 if (!tdb_data
.dptr
) {
188 datum_from_tdb(data
, &tdb_data
);
191 datum_from_tdb(key
, &tdb_key
);
196 pa_datum
* pa_database_next(pa_database
*db
, const pa_datum
*key
, pa_datum
*next
, pa_datum
*data
) {
197 TDB_DATA tdb_key
, tdb_data
;
202 tdb_key
= tdb_nextkey(MAKE_TDB_CONTEXT(db
), *datum_to_tdb(&tdb_key
, key
));
208 tdb_data
= tdb_fetch(MAKE_TDB_CONTEXT(db
), tdb_key
);
210 if (!tdb_data
.dptr
) {
215 datum_from_tdb(data
, &tdb_data
);
218 datum_from_tdb(next
, &tdb_key
);
223 int pa_database_sync(pa_database
*db
) {