X-Git-Url: https://git.ozlabs.org/?a=blobdiff_plain;f=ccan%2Ftdb2%2Ftest%2Frun-03-coalesce.c;h=c64b2bc57c0df1f5782f430e89d9d7c809f52f11;hb=79d603a5f73dfbb655d8d08f67eecb5f2da542d5;hp=eaaabf7a6eed02222782e188d10d5d3671a141d6;hpb=476567430be6962625bf399192e20938985232c7;p=ccan diff --git a/ccan/tdb2/test/run-03-coalesce.c b/ccan/tdb2/test/run-03-coalesce.c index eaaabf7a..c64b2bc5 100644 --- a/ccan/tdb2/test/run-03-coalesce.c +++ b/ccan/tdb2/test/run-03-coalesce.c @@ -32,16 +32,19 @@ int main(int argc, char *argv[]) key = tdb_mkdata("hello", 5); /* No coalescing can be done due to EOF */ - layout = new_tdb_layout("run-03-coalesce.tdb"); + layout = new_tdb_layout(); tdb_layout_add_freetable(layout); len = 1024; tdb_layout_add_free(layout, len, 0); - tdb = tdb_layout_get(layout, &tap_log_attr); + tdb_layout_write(layout, &tap_log_attr, "run-03-coalesce.tdb"); + /* NOMMAP is for lockcheck. */ + tdb = tdb_open("run-03-coalesce.tdb", TDB_NOMMAP, O_RDWR, 0, + &tap_log_attr); ok1(tdb_check(tdb, NULL, NULL) == 0); ok1(free_record_length(tdb, layout->elem[1].base.off) == len); /* Figure out which bucket free entry is. */ - b_off = bucket_off(tdb->ftable_off, size_to_bucket(len)); + b_off = bucket_off(tdb->tdb2.ftable_off, size_to_bucket(len)); /* Lock and fail to coalesce. */ ok1(tdb_lock_free_bucket(tdb, b_off, TDB_LOCK_WAIT) == 0); test = layout->elem[1].base.off; @@ -55,16 +58,19 @@ int main(int argc, char *argv[]) tdb_layout_free(layout); /* No coalescing can be done due to used record */ - layout = new_tdb_layout("run-03-coalesce.tdb"); + layout = new_tdb_layout(); tdb_layout_add_freetable(layout); tdb_layout_add_free(layout, 1024, 0); tdb_layout_add_used(layout, key, data, 6); - tdb = tdb_layout_get(layout, &tap_log_attr); + tdb_layout_write(layout, &tap_log_attr, "run-03-coalesce.tdb"); + /* NOMMAP is for lockcheck. */ + tdb = tdb_open("run-03-coalesce.tdb", TDB_NOMMAP, O_RDWR, 0, + &tap_log_attr); ok1(free_record_length(tdb, layout->elem[1].base.off) == 1024); ok1(tdb_check(tdb, NULL, NULL) == 0); /* Figure out which bucket free entry is. */ - b_off = bucket_off(tdb->ftable_off, size_to_bucket(1024)); + b_off = bucket_off(tdb->tdb2.ftable_off, size_to_bucket(1024)); /* Lock and fail to coalesce. */ ok1(tdb_lock_free_bucket(tdb, b_off, TDB_LOCK_WAIT) == 0); test = layout->elem[1].base.off; @@ -78,17 +84,20 @@ int main(int argc, char *argv[]) tdb_layout_free(layout); /* Coalescing can be done due to two free records, then EOF */ - layout = new_tdb_layout("run-03-coalesce.tdb"); + layout = new_tdb_layout(); tdb_layout_add_freetable(layout); tdb_layout_add_free(layout, 1024, 0); tdb_layout_add_free(layout, 2048, 0); - tdb = tdb_layout_get(layout, &tap_log_attr); + tdb_layout_write(layout, &tap_log_attr, "run-03-coalesce.tdb"); + /* NOMMAP is for lockcheck. */ + tdb = tdb_open("run-03-coalesce.tdb", TDB_NOMMAP, O_RDWR, 0, + &tap_log_attr); ok1(free_record_length(tdb, layout->elem[1].base.off) == 1024); ok1(free_record_length(tdb, layout->elem[2].base.off) == 2048); ok1(tdb_check(tdb, NULL, NULL) == 0); /* Figure out which bucket (first) free entry is. */ - b_off = bucket_off(tdb->ftable_off, size_to_bucket(1024)); + b_off = bucket_off(tdb->tdb2.ftable_off, size_to_bucket(1024)); /* Lock and coalesce. */ ok1(tdb_lock_free_bucket(tdb, b_off, TDB_LOCK_WAIT) == 0); test = layout->elem[2].base.off; @@ -104,18 +113,21 @@ int main(int argc, char *argv[]) tdb_layout_free(layout); /* Coalescing can be done due to two free records, then data */ - layout = new_tdb_layout("run-03-coalesce.tdb"); + layout = new_tdb_layout(); tdb_layout_add_freetable(layout); tdb_layout_add_free(layout, 1024, 0); tdb_layout_add_free(layout, 512, 0); tdb_layout_add_used(layout, key, data, 6); - tdb = tdb_layout_get(layout, &tap_log_attr); + tdb_layout_write(layout, &tap_log_attr, "run-03-coalesce.tdb"); + /* NOMMAP is for lockcheck. */ + tdb = tdb_open("run-03-coalesce.tdb", TDB_NOMMAP, O_RDWR, 0, + &tap_log_attr); ok1(free_record_length(tdb, layout->elem[1].base.off) == 1024); ok1(free_record_length(tdb, layout->elem[2].base.off) == 512); ok1(tdb_check(tdb, NULL, NULL) == 0); /* Figure out which bucket free entry is. */ - b_off = bucket_off(tdb->ftable_off, size_to_bucket(1024)); + b_off = bucket_off(tdb->tdb2.ftable_off, size_to_bucket(1024)); /* Lock and coalesce. */ ok1(tdb_lock_free_bucket(tdb, b_off, TDB_LOCK_WAIT) == 0); test = layout->elem[2].base.off; @@ -130,19 +142,22 @@ int main(int argc, char *argv[]) tdb_layout_free(layout); /* Coalescing can be done due to three free records, then EOF */ - layout = new_tdb_layout("run-03-coalesce.tdb"); + layout = new_tdb_layout(); tdb_layout_add_freetable(layout); tdb_layout_add_free(layout, 1024, 0); tdb_layout_add_free(layout, 512, 0); tdb_layout_add_free(layout, 256, 0); - tdb = tdb_layout_get(layout, &tap_log_attr); + tdb_layout_write(layout, &tap_log_attr, "run-03-coalesce.tdb"); + /* NOMMAP is for lockcheck. */ + tdb = tdb_open("run-03-coalesce.tdb", TDB_NOMMAP, O_RDWR, 0, + &tap_log_attr); ok1(free_record_length(tdb, layout->elem[1].base.off) == 1024); ok1(free_record_length(tdb, layout->elem[2].base.off) == 512); ok1(free_record_length(tdb, layout->elem[3].base.off) == 256); ok1(tdb_check(tdb, NULL, NULL) == 0); /* Figure out which bucket free entry is. */ - b_off = bucket_off(tdb->ftable_off, size_to_bucket(1024)); + b_off = bucket_off(tdb->tdb2.ftable_off, size_to_bucket(1024)); /* Lock and coalesce. */ ok1(tdb_lock_free_bucket(tdb, b_off, TDB_LOCK_WAIT) == 0); test = layout->elem[2].base.off;