X-Git-Url: http://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Ftdb2%2Fprivate.h;h=26ca7b3081b279d5d5db07fadee5a712e3bdd27a;hb=b3ae89992ecaffed31dcc2e912539c289478801a;hp=96f23e92c364bb2cb91a699290d48fcf406ffe2e;hpb=6bc8ea012391198bc3898ae2937558b60dd55906;p=ccan diff --git a/ccan/tdb2/private.h b/ccan/tdb2/private.h index 96f23e92..26ca7b30 100644 --- a/ccan/tdb2/private.h +++ b/ccan/tdb2/private.h @@ -463,6 +463,12 @@ enum TDB_ERROR tdb_read_convert(struct tdb_context *tdb, tdb_off_t off, void tdb_inc_seqnum(struct tdb_context *tdb); /* lock.c: */ +/* Print message because another tdb owns a lock we want. */ +enum TDB_ERROR owner_conflict(struct tdb_context *tdb, const char *call); + +/* If we fork, we no longer really own locks. */ +bool check_lock_pid(struct tdb_context *tdb, const char *call, bool log); + /* Lock/unlock a range of hashes. */ enum TDB_ERROR tdb_lock_hashes(struct tdb_context *tdb, tdb_off_t hash_lock, tdb_len_t hash_range, @@ -631,10 +637,18 @@ struct tdb_context { #define TDB1_BYTEREV(x) (((((x)&0xff)<<24)|((x)&0xFF00)<<8)|(((x)>>8)&0xFF00)|((x)>>24)) +/* tdb1_check.c: */ +int tdb1_check(struct tdb_context *tdb, + enum TDB_ERROR (*check)(TDB_DATA key, TDB_DATA data, void *), + void *private_data); + + /* tdb1_open.c: */ int tdb1_new_database(struct tdb_context *tdb, - struct tdb_attribute_tdb1_hashsize *hashsize); -enum TDB_ERROR tdb1_open(struct tdb_context *tdb); + struct tdb_attribute_tdb1_hashsize *hashsize, + struct tdb_attribute_tdb1_max_dead *max_dead); +enum TDB_ERROR tdb1_open(struct tdb_context *tdb, + struct tdb_attribute_tdb1_max_dead *max_dead); /* tdb1_io.c: */ enum TDB_ERROR tdb1_probe_length(struct tdb_context *tdb); @@ -658,6 +672,9 @@ int tdb1_traverse(struct tdb_context *tdb, int (*)(struct tdb_context *, TDB_DATA, TDB_DATA, void *), void *private_data); +/* tdb1_summary.c: */ +char *tdb1_summary(struct tdb_context *tdb); + /* tdb1_tdb.c: */ int tdb1_store(struct tdb_context *tdb, TDB_DATA key, TDB_DATA dbuf, int flag); enum TDB_ERROR tdb1_fetch(struct tdb_context *tdb, TDB_DATA key, @@ -670,12 +687,19 @@ enum TDB_ERROR tdb1_parse_record(struct tdb_context *tdb, TDB_DATA key, TDB_DATA data, void *private_data), void *private_data); +void tdb1_increment_seqnum_nonblock(struct tdb_context *tdb); +int tdb1_get_seqnum(struct tdb_context *tdb); +int tdb1_wipe_all(struct tdb_context *tdb); /* tdb1_transaction.c: */ int tdb1_transaction_start(struct tdb_context *tdb); int tdb1_transaction_prepare_commit(struct tdb_context *tdb); int tdb1_transaction_commit(struct tdb_context *tdb); +/* tdb1_traverse.c: */ +TDB_DATA tdb1_firstkey(struct tdb_context *tdb); +TDB_DATA tdb1_nextkey(struct tdb_context *tdb, TDB_DATA key); + /* tdb.c: */ enum TDB_ERROR COLD tdb_logerr(struct tdb_context *tdb, enum TDB_ERROR ecode,