From 0ad0c09511a04ebe837f2acb859d47f2aa4e038a Mon Sep 17 00:00:00 2001
From: Antonin Kral <a.kral@bobek.cz>
Date: Fri, 24 Sep 2010 19:01:03 +0200
Subject: Imported Upstream version 1.6.3

---
 s/d_migrate.cpp | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

(limited to 's/d_migrate.cpp')

diff --git a/s/d_migrate.cpp b/s/d_migrate.cpp
index fac63af..b8ee78e 100644
--- a/s/d_migrate.cpp
+++ b/s/d_migrate.cpp
@@ -107,7 +107,8 @@ namespace mongo {
 
         int loops = 0;
         Timer t;
-        while ( t.seconds() < 600 ){ // 10 minutes
+        while ( t.seconds() < 900 ){ // 15 minutes
+            assert( dbMutex.getState() == 0 );
             sleepmillis( 20 );
             
             set<CursorId> now;
@@ -519,6 +520,7 @@ namespace mongo {
             
             // 4. 
             for ( int i=0; i<86400; i++ ){ // don't want a single chunk move to take more than a day
+                assert( dbMutex.getState() == 0 );
                 sleepsecs( 1 ); 
                 ScopedDbConnection conn( to );
                 BSONObj res;
@@ -537,6 +539,8 @@ namespace mongo {
 
                 if ( res["state"].String() == "steady" )
                     break;
+
+                killCurrentOp.checkForInterrupt();
             }
             timing.done(4);
 
-- 
cgit v1.2.3