[t:4545], add cachetable test

#ident "$Id: cachetable-simple-verify.c 39504 2012-02-03 16:19:33Z zardosht $"

#ident "Copyright (c) 2007-2011 Tokutek Inc.  All rights reserved."

#include "includes.h"

#include "test.h"

BOOL flush_called;

BOOL pf_req_called;

BOOL pf_called;

static UU() void

flush (CACHEFILE f __attribute__((__unused__)),

       int UU(fd),

       CACHEKEY k  __attribute__((__unused__)),

       void *v     __attribute__((__unused__)),

       void *e     __attribute__((__unused__)),

       PAIR_ATTR s      __attribute__((__unused__)),

       PAIR_ATTR* new_size      __attribute__((__unused__)),

       BOOL w      __attribute__((__unused__)),

       BOOL keep   __attribute__((__unused__)),

       BOOL c      __attribute__((__unused__))

       ) {

    flush_called = TRUE;

    *new_size = make_pair_attr(8);

}

static BOOL pf_req_callback(void* UU(brtnode_pv), void* UU(read_extraargs)) {

  pf_req_called = TRUE;

  assert(flush_called);

  return TRUE;

}

static int pf_callback(void* UU(brtnode_pv), void* UU(read_extraargs), int UU(fd), PAIR_ATTR* sizep) {

   assert(pf_req_called);

   assert(flush_called);

   pf_called = TRUE;

  *sizep = make_pair_attr(8);

  return 0;

}

static void

cachetable_test (void) {

  const int test_limit = 12;

  int r;

  CACHETABLE ct;

  r = toku_create_cachetable(&ct, test_limit, ZERO_LSN, NULL_LOGGER); assert(r == 0);

  char fname1[] = __FILE__ "test1.dat";

  unlink(fname1);

  CACHEFILE f1;

  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);

  wc.flush_callback = flush;

  r = toku_cachetable_get_and_pin(f1, make_blocknum(1), 1, &v1, &s1, wc, def_fetch, pf_req_callback, pf_callback, NULL);

  r = toku_cachetable_unpin(f1, make_blocknum(1), 1, CACHETABLE_DIRTY, make_pair_attr(8));

  flush_called = FALSE;

  pf_req_called = FALSE;

  pf_called = FALSE;

  r = toku_cachetable_begin_checkpoint(ct, NULL);

  assert_zero(r);

  r = toku_cachetable_get_and_pin(f1, make_blocknum(1), 1, &v1, &s1, wc, def_fetch, pf_req_callback, pf_callback, NULL);

  assert_zero(r);

  r = toku_cachetable_unpin(f1, make_blocknum(1), 1, CACHETABLE_DIRTY, make_pair_attr(8));

  assert_zero(r);

  r = toku_cachetable_end_checkpoint(

        ct, 

        NULL, 

        fake_ydb_lock,

        fake_ydb_unlock,

        NULL,

        NULL

        );

  assert_zero(r);

  assert(pf_req_called);

  assert(flush_called);

  assert(pf_called);

  toku_cachetable_verify(ct);

  r = toku_cachefile_close(&f1, 0, FALSE, ZERO_LSN); assert(r == 0 && f1 == 0);

  r = toku_cachetable_close(&ct); lazy_assert_zero(r);

}

int

test_main(int argc, const char *argv[]) {

  default_parse_args(argc, argv);

  cachetable_test();

  return 0;

}