X-Git-Url: http://git.ozlabs.org/?a=blobdiff_plain;ds=sidebyside;f=ccan%2Ftdb2%2Fprivate.h;h=c95c7e05e59181f9d67c8131c7d813353a4c99af;hb=e37b906781eeddb89d2ba6c5c39e9d20e4111c18;hp=4e7fc8ffeccaba5e2ab13348cf02a23bcbbb15bf;hpb=bb4d59ee1e914df9f8066e59a9c9a6604e581c40;p=ccan diff --git a/ccan/tdb2/private.h b/ccan/tdb2/private.h index 4e7fc8ff..c95c7e05 100644 --- a/ccan/tdb2/private.h +++ b/ccan/tdb2/private.h @@ -75,7 +75,7 @@ typedef uint64_t tdb_off_t; /* Packing errors into pointers and v.v. */ #define TDB_PTR_IS_ERR(ptr) \ - unlikely((void *)(ptr) >= (void *)(long)TDB_ERR_LAST) + unlikely((unsigned long)(ptr) >= (unsigned long)TDB_ERR_LAST) #define TDB_PTR_ERR(p) ((enum TDB_ERROR)(long)(p)) #define TDB_ERR_PTR(err) ((void *)(long)(err)) @@ -246,7 +246,9 @@ struct tdb_header { uint64_t features_used; /* Features all writers understand */ uint64_t features_offered; /* Features offered */ - tdb_off_t reserved[24]; + uint64_t seqnum; /* Sequence number for TDB_SEQNUM */ + + tdb_off_t reserved[23]; /* Top level hash table. */ tdb_off_t hashtable[1ULL << TDB_TOPLEVEL_HASH_BITS]; @@ -333,6 +335,7 @@ struct tdb_file { int fd; /* Lock information */ + pid_t locker; struct tdb_lock allrecord_lock; size_t num_lockrecs; struct tdb_lock *lockrecs; @@ -388,6 +391,9 @@ struct tdb_context { /* Direct access information */ struct tdb_access_hdr *access; + /* Last error we returned. */ + enum TDB_ERROR last_error; + /* The actual file information */ struct tdb_file *file; }; @@ -523,6 +529,9 @@ enum TDB_ERROR tdb_write_convert(struct tdb_context *tdb, tdb_off_t off, enum TDB_ERROR tdb_read_convert(struct tdb_context *tdb, tdb_off_t off, void *rec, size_t len); +/* 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) \ @@ -541,7 +550,7 @@ enum TDB_ERROR tdb_unlock_hashes(struct tdb_context *tdb, tdb_len_t hash_range, int ltype); /* For closing the file. */ -void tdb_unlock_all(struct tdb_context *tdb); +void tdb_lock_cleanup(struct tdb_context *tdb); /* Lock/unlock a particular free bucket. */ enum TDB_ERROR tdb_lock_free_bucket(struct tdb_context *tdb, tdb_off_t b_off,