diff options
Diffstat (limited to 'storage/tokudb/PerconaFT/ft/tests/cachetable-simple-read-pin-nonblocking.cc')
-rw-r--r-- | storage/tokudb/PerconaFT/ft/tests/cachetable-simple-read-pin-nonblocking.cc | 13 |
1 files changed, 4 insertions, 9 deletions
diff --git a/storage/tokudb/PerconaFT/ft/tests/cachetable-simple-read-pin-nonblocking.cc b/storage/tokudb/PerconaFT/ft/tests/cachetable-simple-read-pin-nonblocking.cc index ebe05e50883..fdca6ef27ce 100644 --- a/storage/tokudb/PerconaFT/ft/tests/cachetable-simple-read-pin-nonblocking.cc +++ b/storage/tokudb/PerconaFT/ft/tests/cachetable-simple-read-pin-nonblocking.cc @@ -75,9 +75,8 @@ static int sleep_pf_callback(void* UU(ftnode_pv), void* UU(disk_data), void* UU( static void *run_expensive_pf(void *arg) { void* v1; - long s1; CACHETABLE_WRITE_CALLBACK wc = def_write_callback(NULL); - int r = toku_cachetable_get_and_pin_nonblocking(f1, make_blocknum(1), 1, &v1, &s1, wc, sleep_fetch, sleep_pf_req_callback, sleep_pf_callback, PL_READ, NULL, NULL); + int r = toku_cachetable_get_and_pin_nonblocking(f1, make_blocknum(1), 1, &v1, wc, sleep_fetch, sleep_pf_req_callback, sleep_pf_callback, PL_READ, NULL, NULL); assert(r == TOKUDB_TRY_AGAIN); assert(pf_called); return arg; @@ -85,9 +84,8 @@ static void *run_expensive_pf(void *arg) { static void *run_expensive_fetch(void *arg) { void* v1; - long s1; CACHETABLE_WRITE_CALLBACK wc = def_write_callback(NULL); - int r = toku_cachetable_get_and_pin_nonblocking(f1, make_blocknum(1), 1, &v1, &s1, wc, sleep_fetch, sleep_pf_req_callback, sleep_pf_callback, PL_READ, NULL, NULL); + int r = toku_cachetable_get_and_pin_nonblocking(f1, make_blocknum(1), 1, &v1, wc, sleep_fetch, sleep_pf_req_callback, sleep_pf_callback, PL_READ, NULL, NULL); assert(fetch_called); assert(r == TOKUDB_TRY_AGAIN); return arg; @@ -106,7 +104,6 @@ run_test (void) { r = toku_cachetable_openf(&f1, ct, fname1, O_RDWR|O_CREAT, S_IRWXU|S_IRWXG|S_IRWXO); assert(r == 0); void* v1; - long s1; CACHETABLE_WRITE_CALLBACK wc = def_write_callback(NULL); toku_pthread_t fetch_tid; @@ -118,7 +115,6 @@ run_test (void) { make_blocknum(1), 1, &v1, - &s1, wc, sleep_fetch, def_pf_req_callback, @@ -133,9 +129,9 @@ run_test (void) { assert_zero(r); // call with may_modify_node = false twice, make sure we can get it - r = toku_cachetable_get_and_pin_nonblocking(f1, make_blocknum(1), 1, &v1, &s1, wc, sleep_fetch, def_pf_req_callback, def_pf_callback, PL_READ, NULL, NULL); + r = toku_cachetable_get_and_pin_nonblocking(f1, make_blocknum(1), 1, &v1, wc, sleep_fetch, def_pf_req_callback, def_pf_callback, PL_READ, NULL, NULL); assert_zero(r); - r = toku_cachetable_get_and_pin_nonblocking(f1, make_blocknum(1), 1, &v1, &s1, wc, sleep_fetch, def_pf_req_callback, def_pf_callback, PL_READ, NULL, NULL); + r = toku_cachetable_get_and_pin_nonblocking(f1, make_blocknum(1), 1, &v1, wc, sleep_fetch, def_pf_req_callback, def_pf_callback, PL_READ, NULL, NULL); assert_zero(r); r = toku_test_cachetable_unpin(f1, make_blocknum(1), 1, CACHETABLE_CLEAN, make_pair_attr(8)); assert(r==0); @@ -151,7 +147,6 @@ run_test (void) { make_blocknum(1), 1, &v1, - &s1, wc, sleep_fetch, def_pf_req_callback, |