refs #5372 Added evictor pointer to checkpointer. This was needed to remove...

refs #5372 Added evictor pointer to checkpointer.  This was needed to remove some of the dependency on the cachetable in checkpointer methods.

git-svn-id: file:///svn/toku/tokudb@47539 c7de825b-a66e-492c-adef-691d508d4ae1

ft/cachetable-internal.h

@@ -311,7 +311,7 @@ class cachefile_list {
 //
 class checkpointer {
 public:
-    void init(CACHETABLE _ct, TOKULOGGER _logger, cachefile_list *files);
+    void init(CACHETABLE _ct, TOKULOGGER _logger, evictor *_ev, cachefile_list *files);
     void destroy();
     int set_checkpoint_period(uint32_t new_period);
     uint32_t get_checkpoint_period();
@@ -333,6 +333,7 @@ class checkpointer {
     cachefile_list *m_cf_list;
     // <CER> TEMP?
     CACHETABLE m_ct;
+    evictor *m_ev;
     
     // variable used by the checkpoint thread to know
     // when all work induced by cloning on client threads is done

ft/cachetable.cc

@@ -210,7 +210,7 @@ int toku_create_cachetable(CACHETABLE *result, long size_limit, LSN UU(initial_l
     ct->checkpointing_kibbutz = toku_kibbutz_create(checkpointing_nworkers);
     // must be done after creating ct_kibbutz
     ct->ev.init(size_limit, &ct->list, ct->ct_kibbutz, EVICTION_PERIOD);
-    ct->cp.init(ct, logger, &ct->cf_list);
+    ct->cp.init(ct, logger, &ct->ev, &ct->cf_list);
     ct->cl.init(1, &ct->list, ct); // by default, start with one iteration
     ct->env_dir = toku_xstrdup(".");
     *result = ct;
@@ -4168,9 +4168,11 @@ ENSURE_POD(checkpointer);
 //
 void checkpointer::init(CACHETABLE _ct, 
                         TOKULOGGER _logger,
+                        evictor *_ev,
                         cachefile_list *files) {
     m_ct = _ct;
     m_logger = _logger;
+    m_ev = _ev;
     m_cf_list = files;
     bjm_init(&m_checkpoint_clones_bjm);
     
@@ -4426,7 +4428,7 @@ void checkpointer::checkpoint_pending_pairs() {
         // if still pending, clear the pending bit and write out the node
         pair_lock(p);
         m_ct->list.read_list_unlock();
-        write_pair_for_checkpoint_thread(&m_ct->ev, p);
+        write_pair_for_checkpoint_thread(m_ev, p);
         pair_unlock(p);
         m_ct->list.read_list_lock();
     }

ft/tests/cachetable-checkpointer-class.cc

@@ -82,7 +82,7 @@ void checkpointer_test::test_begin_checkpoint() {
     cachetable ctbl;
     ctbl.list.init();
     
-    m_cp.init(&ctbl, NULL, &cfl);
+    m_cp.init(&ctbl, NULL, &ctbl.ev, &cfl);
 
     // 1. Call checkpoint with NO cachefiles.
     r = m_cp.begin_checkpoint();
@@ -289,7 +289,7 @@ void checkpointer_test::test_end_checkpoint() {
     cf.for_checkpoint = true;
     create_dummy_functions(&cf);
     
-    m_cp.init(&ctbl, NULL, &cfl);
+    m_cp.init(&ctbl, NULL, &ctbl.ev, &cfl);
     m_cp.m_cf_list->m_head = &cf;
 
     // 2. Add data before running checkpoint.