2 #include "tdb1-lock-tracking.h"
3 #define fcntl fcntl_with_lockcheck1
4 #include "tdb2-source.h"
5 #include "tap-interface.h"
6 #undef fcntl_with_lockcheck
9 #include "tdb1-external-agent.h"
12 static struct agent *agent;
14 static bool correct_key(TDB_DATA key)
16 return key.dsize == strlen("hi")
17 && memcmp(key.dptr, "hi", key.dsize) == 0;
20 static bool correct_data(TDB_DATA data)
22 return data.dsize == strlen("world")
23 && memcmp(data.dptr, "world", data.dsize) == 0;
26 static int traverse(struct tdb_context *tdb, TDB_DATA key, TDB_DATA data,
29 ok1(correct_key(key));
30 ok1(correct_data(data));
34 int main(int argc, char *argv[])
36 struct tdb_context *tdb;
38 union tdb_attribute hsize;
40 hsize.base.attr = TDB_ATTRIBUTE_TDB1_HASHSIZE;
41 hsize.base.next = &tap_log_attr;
42 hsize.tdb1_hashsize.hsize = 1024;
45 agent = prepare_external_agent1();
47 err(1, "preparing agent");
49 tdb = tdb_open("run-traverse-in-transaction.tdb1",
50 TDB_VERSION1, O_CREAT|O_TRUNC|O_RDWR,
54 key = tdb_mkdata("hi", strlen("hi"));
55 data = tdb_mkdata("world", strlen("world"));
57 ok1(tdb_store(tdb, key, data, TDB_INSERT) == TDB_SUCCESS);
59 ok1(external_agent_operation1(agent, OPEN, tdb->name) == SUCCESS);
61 ok1(tdb_transaction_start(tdb) == TDB_SUCCESS);
62 ok1(external_agent_operation1(agent, TRANSACTION_START, tdb->name)
63 == WOULD_HAVE_BLOCKED);
64 tdb_traverse(tdb, traverse, NULL);
66 /* That should *not* release the transaction lock! */
67 ok1(external_agent_operation1(agent, TRANSACTION_START, tdb->name)
68 == WOULD_HAVE_BLOCKED);
69 tdb_traverse(tdb, traverse, NULL);
71 /* That should *not* release the transaction lock! */
72 ok1(external_agent_operation1(agent, TRANSACTION_START, tdb->name)
73 == WOULD_HAVE_BLOCKED);
74 ok1(tdb_transaction_commit(tdb) == TDB_SUCCESS);
75 /* Now we should be fine. */
76 ok1(external_agent_operation1(agent, TRANSACTION_START, tdb->name)