X-Git-Url: http://git.ozlabs.org/?p=ccan;a=blobdiff_plain;f=ccan%2Ftdb2%2Fprivate.h;h=cc791b0bb4e3da3226c22862b21d03e32304e931;hp=0a030d6e317e368fbf0d057a21ece3b28fd8a624;hb=dc9da1e34fe6a9d113fd57e116ebbc6d5bd54819;hpb=b8903ca2acfa193d6a1cf496ab25c26b06f22424 diff --git a/ccan/tdb2/private.h b/ccan/tdb2/private.h index 0a030d6e..cc791b0b 100644 --- a/ccan/tdb2/private.h +++ b/ccan/tdb2/private.h @@ -358,24 +358,26 @@ struct tdb_context { /* mmap read only? */ int mmap_flags; - /* Error code for last tdb error. */ - enum TDB_ERROR ecode; - /* the flags passed to tdb_open, for tdb_reopen. */ uint32_t flags; /* Logging function */ - void (*logfn)(struct tdb_context *tdb, - enum tdb_log_level level, - void *log_private, - const char *message); - void *log_private; + void (*log_fn)(struct tdb_context *tdb, + enum tdb_log_level level, + const char *message, + void *data); + void *log_data; /* Hash function. */ - uint64_t (*khash)(const void *key, size_t len, uint64_t seed, void *); - void *hash_priv; + uint64_t (*hash_fn)(const void *key, size_t len, uint64_t seed, void *); + void *hash_data; uint64_t hash_seed; + /* low level (fnctl) lock functions. */ + int (*lock_fn)(int fd, int rw, off_t off, off_t len, bool w, void *); + int (*unlock_fn)(int fd, int rw, off_t off, off_t len, void *); + void *lock_data; + /* Set if we are in a transaction. */ struct tdb_transaction *transaction; @@ -386,7 +388,8 @@ struct tdb_context { /* IO methods: changes for transactions. */ const struct tdb_methods *methods; - struct tdb_attribute_stats *stats; + /* Our statistics. */ + struct tdb_attribute_stats stats; /* Direct access information */ struct tdb_access_hdr *access; @@ -412,8 +415,6 @@ struct tdb_methods { internal prototypes */ /* hash.c: */ -void tdb_hash_init(struct tdb_context *tdb); - tdb_bool_err first_in_hash(struct tdb_context *tdb, struct traverse_info *tinfo, TDB_DATA *kbuf, size_t *dlen); @@ -532,14 +533,6 @@ enum TDB_ERROR tdb_read_convert(struct tdb_context *tdb, tdb_off_t off, /* Bump the seqnum (caller checks for tdb->flags & TDB_SEQNUM) */ void tdb_inc_seqnum(struct tdb_context *tdb); -/* Adds a stat, if it's in range. */ -void add_stat_(struct tdb_context *tdb, uint64_t *stat, size_t val); -#define add_stat(tdb, statname, val) \ - do { \ - if (unlikely((tdb)->stats)) \ - add_stat_((tdb), &(tdb)->stats->statname, (val)); \ - } while (0) - /* lock.c: */ /* Lock/unlock a range of hashes. */ enum TDB_ERROR tdb_lock_hashes(struct tdb_context *tdb, @@ -584,6 +577,10 @@ bool tdb_has_expansion_lock(struct tdb_context *tdb); /* If it needs recovery, grab all the locks and do it. */ enum TDB_ERROR tdb_lock_and_recover(struct tdb_context *tdb); +/* Default lock and unlock functions. */ +int tdb_fcntl_lock(int fd, int rw, off_t off, off_t len, bool waitflag, void *); +int tdb_fcntl_unlock(int fd, int rw, off_t off, off_t len, void *); + /* transaction.c: */ enum TDB_ERROR tdb_transaction_recover(struct tdb_context *tdb); tdb_bool_err tdb_needs_recovery(struct tdb_context *tdb);