[t:4967] remove the ydb lock from end checkpoint. note_unpin_by_checkpoint...

[t:4967] remove the ydb lock from end checkpoint. note_unpin_by_checkpoint removes an ft reference, which is protected by the ft's ref lock.


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

ft/cachetable.c

@@ -194,7 +194,6 @@ static inline void ctpair_destroy(PAIR p) {
 
 // The cachetable is as close to an ENV as we get.
 // There are 3 locks, must be taken in this order
-// TODO: review the removal of this mutex, since it is only ever held when the ydb lock is held
 //      cachetable_mutex
 //      cachefiles_mutex
 struct cachetable {
@@ -3505,7 +3504,6 @@ int toku_cachetable_get_checkpointing_user_data_status (void) {
 
 int
 toku_cachetable_end_checkpoint(CACHETABLE ct, TOKULOGGER logger,
-                               void (*ydb_lock)(void), void (*ydb_unlock)(void),
                                void (*testcallback_f)(void*),  void * testextra) {
     // Requires:   The big checkpoint lock must be held (see checkpoint.c).
     // Algorithm:  Write all pending nodes to disk
@@ -3609,9 +3607,7 @@ toku_cachetable_end_checkpoint(CACHETABLE ct, TOKULOGGER logger,
             // checking for function existing so that this function
             // can be called from cachetable tests
             if (cf->note_unpin_by_checkpoint) {
-                ydb_lock();
                 int r = cf->note_unpin_by_checkpoint(cf, cf->userdata);
-                ydb_unlock();
                 if (r!=0) {
                     retval = r;
                     goto panic;

ft/cachetable.h

@@ -68,7 +68,6 @@ char * toku_cachefile_fname_in_cwd (CACHEFILE cf);
 // TODO: #1510  Add comments on how these behave
 int toku_cachetable_begin_checkpoint (CACHETABLE ct, TOKULOGGER);
 int toku_cachetable_end_checkpoint(CACHETABLE ct, TOKULOGGER logger, 
-                                   void (*ydb_lock)(void), void (*ydb_unlock)(void),
                                    void (*testcallback_f)(void*),  void * testextra);
 
 // Shuts down checkpoint thread

ft/checkpoint.c

@@ -295,7 +295,7 @@ toku_checkpoint(CACHETABLE ct, TOKULOGGER logger,
     if (r==0) {
         if (callback_f) 
             callback_f(extra);      // callback is called with checkpoint_safe_lock still held
-        r = toku_cachetable_end_checkpoint(ct, logger, ydb_lock, ydb_unlock, callback2_f, extra2);
+        r = toku_cachetable_end_checkpoint(ct, logger, callback2_f, extra2);
     }
     SET_CHECKPOINT_FOOTPRINT(50);
     if (r==0 && logger) {

ft/tests/cachetable-3969.c

@@ -80,8 +80,6 @@ run_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-4545.c

@@ -71,8 +71,6 @@ cachetable_test (void) {
   r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-checkpoint-pinned-nodes.c

@@ -99,8 +99,6 @@ cachetable_test (void) {
   r = toku_cachetable_end_checkpoint(
       ct, 
       NULL, 
-      fake_ydb_lock,
-      fake_ydb_unlock,
       NULL,
       NULL
       );

ft/tests/cachetable-checkpoint-prefetched-nodes.c

@@ -98,8 +98,6 @@ cachetable_test (void) {
   r = toku_cachetable_end_checkpoint(
       ct, 
       NULL, 
-      fake_ydb_lock,
-      fake_ydb_unlock,
       NULL,
       NULL
       );

ft/tests/cachetable-cleaner-checkpoint.c

@@ -87,8 +87,6 @@ cachetable_test (void) {
   r = toku_cachetable_end_checkpoint(
       ct, 
       NULL, 
-      fake_ydb_lock,
-      fake_ydb_unlock,
       NULL,
       NULL
       );

ft/tests/cachetable-cleaner-checkpoint2.c

@@ -87,8 +87,6 @@ cachetable_test (void) {
   r = toku_cachetable_end_checkpoint(
       ct, 
       NULL, 
-      fake_ydb_lock,
-      fake_ydb_unlock,
       NULL,
       NULL
       );

ft/tests/cachetable-cleaner-thread-empty-cachetable.c

@@ -28,8 +28,6 @@ cachetable_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct,
         NULL,
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-clone-checkpoint.c

@@ -44,8 +44,6 @@ static void *run_end_checkpoint(void *arg) {
     int r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-clone-partial-fetch-pinned-node.c

@@ -92,8 +92,6 @@ cachetable_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-clone-partial-fetch.c

@@ -92,8 +92,6 @@ cachetable_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-clone-pin-nonblocking.c

@@ -72,8 +72,6 @@ cachetable_test (enum cachetable_dirty dirty, BOOL cloneable) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-clone-unpin-remove.c

@@ -81,8 +81,6 @@ cachetable_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-pin-checkpoint.c

@@ -274,8 +274,6 @@ static void *checkpoints(void *arg) {
         r = toku_cachetable_end_checkpoint(
             ct, 
             NULL, 
-            fake_ydb_lock,
-            fake_ydb_unlock,
             NULL,
             NULL
             );

ft/tests/cachetable-pin-nonblocking-checkpoint-clean.c

@@ -59,8 +59,6 @@ run_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-put-checkpoint.c

@@ -402,8 +402,6 @@ static void *checkpoints(void *arg) {
         r = toku_cachetable_end_checkpoint(
             ct, 
             NULL, 
-            fake_ydb_lock,
-            fake_ydb_unlock,
             NULL,
             NULL
             );

ft/tests/cachetable-simple-clone.c

@@ -130,8 +130,6 @@ test_clean (enum cachetable_dirty dirty, BOOL cloneable) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-    fake_ydb_lock,
-    fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-simple-clone2.c

@@ -77,8 +77,6 @@ test_clean (enum cachetable_dirty dirty, BOOL cloneable) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-    fake_ydb_lock,
-    fake_ydb_unlock,
         NULL,
         NULL
     );

ft/tests/cachetable-simple-maybe-get-pin.c

@@ -58,8 +58,6 @@ cachetable_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-simple-pin-dep-nodes.c

@@ -147,8 +147,6 @@ cachetable_test (BOOL write_first, BOOL write_second, BOOL start_checkpoint) {
         r = toku_cachetable_end_checkpoint(
             ct, 
             NULL, 
-            fake_ydb_lock,
-            fake_ydb_unlock,
             NULL,
             NULL
             );

ft/tests/cachetable-simple-pin-nonblocking.c

@@ -113,8 +113,6 @@ run_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-simple-pin.c

@@ -94,8 +94,6 @@ run_test (void) {
     r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/cachetable-simple-put-dep-nodes.c

@@ -155,8 +155,6 @@ cachetable_test (BOOL write_first, BOOL write_second, BOOL start_checkpoint) {
         r = toku_cachetable_end_checkpoint(
             ct, 
             NULL, 
-            fake_ydb_lock,
-            fake_ydb_unlock,
             NULL,
             NULL
             );

ft/tests/cachetable-simple-unpin-remove-checkpoint.c

@@ -45,8 +45,6 @@ cachetable_test (void) {
   r = toku_cachetable_end_checkpoint(
       ct, 
       NULL, 
-      fake_ydb_lock,
-      fake_ydb_unlock,
       NULL,
       NULL
       );

ft/tests/cachetable-unpin-remove-and-checkpoint.c

@@ -16,8 +16,6 @@ static void *run_end_chkpt(void *arg) {
     int r = toku_cachetable_end_checkpoint(
         ct, 
         NULL, 
-        fake_ydb_lock,
-        fake_ydb_unlock,
         NULL,
         NULL
         );

ft/tests/test4302.c

@@ -155,8 +155,6 @@ cachetable_test (void) {
   r = toku_cachetable_end_checkpoint(
       ct, 
       NULL, 
-      fake_ydb_lock,
-      fake_ydb_unlock,
       NULL,
       NULL
       );