some missing commitIfNeeded SERVER-2657 180

3 files changed, 5 insertions, 0 deletions

diff --git a/db/cloner.cpp b/db/cloner.cpp
index 7f6d49f315d..fe57463a493 100644
--- a/db/cloner.cpp
+++ b/db/cloner.cpp
@@ -244,6 +244,7 @@ namespace mongo {
             string temp = ctx.db()->name + ".system.indexes";
             copy( temp.c_str() , temp.c_str() , /*isindex*/true , logForRepl , false , true , BSON( "ns" << ns ) );
         }
+        getDur().commitIfNeeded();
         return true;
     }
 
diff --git a/db/repl.cpp b/db/repl.cpp
index 272e545c496..62891f1614f 100644
--- a/db/repl.cpp
+++ b/db/repl.cpp
@@ -1426,6 +1426,8 @@ namespace mongo {
                         break;
                     }
                     op = oplogReader.next();
+
+                    RARELY getDur().commitIfNeeded();
                 }
             }
         }
diff --git a/db/repl/rs_sync.cpp b/db/repl/rs_sync.cpp
index fc676138515..151f407a17e 100644
--- a/db/repl/rs_sync.cpp
+++ b/db/repl/rs_sync.cpp
@@ -143,6 +143,8 @@ namespace mongo {
                     // simple progress metering
                     log() << "replSet initialSyncOplogApplication " << n << rsLog;
                 }
+                
+                RARELY getDur().commitIfNeeded();
             }
             catch (DBException& e) {
                 if( e.getCode() == 11000 || e.getCode() == 11001 ) {