X-Git-Url: https://git.ozlabs.org/?p=ccan;a=blobdiff_plain;f=ccan%2Ftdb%2Ftest%2Frun-traverse-in-transaction.c;h=c7079cf6828eb39deb3665950c5913684f6a0b2c;hp=58ff750bb89ab493b4a6476352e0f285350b57f2;hb=a153d09b979182e8586d4501ea687bcdd466dabc;hpb=b3804e47471640f1f8c15f5013a78bdbeb12f69d diff --git a/ccan/tdb/test/run-traverse-in-transaction.c b/ccan/tdb/test/run-traverse-in-transaction.c index 58ff750b..c7079cf6 100644 --- a/ccan/tdb/test/run-traverse-in-transaction.c +++ b/ccan/tdb/test/run-traverse-in-transaction.c @@ -1,4 +1,6 @@ #define _XOPEN_SOURCE 500 +#include "lock-tracking.h" +#define fcntl fcntl_with_lockcheck #include #include #include @@ -10,10 +12,11 @@ #include #include #include +#undef fcntl_with_lockcheck #include #include #include -#include "external-transaction.h" +#include "external-agent.h" static struct agent *agent; @@ -58,21 +61,25 @@ int main(int argc, char *argv[]) ok1(tdb_store(tdb, key, data, TDB_INSERT) == 0); - ok1(external_agent_operation(agent, TRANSACTION, tdb_name(tdb))); + ok1(external_agent_operation(agent, OPEN, tdb_name(tdb)) == SUCCESS); ok1(tdb_transaction_start(tdb) == 0); - ok1(!external_agent_operation(agent, TRANSACTION, tdb_name(tdb))); + ok1(external_agent_operation(agent, TRANSACTION_START, tdb_name(tdb)) + == WOULD_HAVE_BLOCKED); tdb_traverse(tdb, traverse, NULL); /* That should *not* release the transaction lock! */ - ok1(!external_agent_operation(agent, TRANSACTION, tdb_name(tdb))); + ok1(external_agent_operation(agent, TRANSACTION_START, tdb_name(tdb)) + == WOULD_HAVE_BLOCKED); tdb_traverse_read(tdb, traverse, NULL); /* That should *not* release the transaction lock! */ - ok1(!external_agent_operation(agent, TRANSACTION, tdb_name(tdb))); + ok1(external_agent_operation(agent, TRANSACTION_START, tdb_name(tdb)) + == WOULD_HAVE_BLOCKED); ok1(tdb_transaction_commit(tdb) == 0); /* Now we should be fine. */ - ok1(external_agent_operation(agent, TRANSACTION, tdb_name(tdb))); + ok1(external_agent_operation(agent, TRANSACTION_START, tdb_name(tdb)) + == SUCCESS); tdb_close(tdb);