wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update transaction timeout test to use repeating read

This commit is contained in:
Lukas Joswiak 2020-10-06 11:28:05 -07:00
parent ff5eafcf42
commit afebd32823
1 changed files with 22 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
bindings/c/test/unit/unit_tests.cpp
View File

@ -623,29 +623,41 @@ TEST_CASE("fdb_transaction_set_option snapshot_read_your_writes_disable") {
TEST_CASE("fdb_transaction_set_option timeout") { TEST_CASE("fdb_transaction_set_option timeout") {
fdb::Transaction tr(db); fdb::Transaction tr(db);
// Set smallest possible timeout, retry until a timeout occurs.
// Timeout of 1 ms should cause transactions to time out even on localhost.
int64_t timeout = 1; int64_t timeout = 1;
fdb_check(tr.set_option(FDB_TR_OPTION_TIMEOUT, (const uint8_t *)&timeout, fdb_check(tr.set_option(FDB_TR_OPTION_TIMEOUT, (const uint8_t *)&timeout,
sizeof(timeout))); sizeof(timeout)));
tr.set((const uint8_t *)"foo", 3, (const uint8_t *)"bar", 3);
fdb::EmptyFuture f1 = tr.commit();
CHECK(wait_future(f1) == 1031); // transaction_timed_out fdb_error_t err;
while (!err) {
fdb::ValueFuture f1 = tr.get((const uint8_t *)"foo", 3, /* snapshot */ false);
err = wait_future(f1);
if (err) {
fdb::EmptyFuture f2 = tr.on_error(err);
err = wait_future(f2);
}
}
CHECK(err == 1031); // transaction_timed_out
} }
TEST_CASE("FDB_DB_OPTION_TRANSACTION_TIMEOUT") { TEST_CASE("FDB_DB_OPTION_TRANSACTION_TIMEOUT") {
// Timeout of 1 ms should cause transactions to time out even on localhost. // Set smallest possible timeout, retry until a timeout occurs.
int64_t timeout = 1; int64_t timeout = 1;
fdb_check(fdb_database_set_option(db, FDB_DB_OPTION_TRANSACTION_TIMEOUT, fdb_check(fdb_database_set_option(db, FDB_DB_OPTION_TRANSACTION_TIMEOUT,
(const uint8_t *)&timeout, (const uint8_t *)&timeout,
sizeof(timeout))); sizeof(timeout)));
fdb::Transaction tr(db); fdb::Transaction tr(db);
tr.set((const uint8_t *)"foo", 3, (const uint8_t *)"bar", 3); fdb_error_t err;
fdb::EmptyFuture f1 = tr.commit(); while (!err) {
fdb::ValueFuture f1 = tr.get((const uint8_t *)"foo", 3, /* snapshot */ false);
CHECK(wait_future(f1) == 1031); // transaction_timed_out err = wait_future(f1);
if (err) {
fdb::EmptyFuture f2 = tr.on_error(err);
err = wait_future(f2);
}
}
CHECK(err == 1031); // transaction_timed_out
// Reset transaction timeout (disable timeout). // Reset transaction timeout (disable timeout).
timeout = 0; timeout = 0;