diff options
-rw-r--r-- | s/d_migrate.cpp | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/s/d_migrate.cpp b/s/d_migrate.cpp index b8ee78e6625..7ae8c745707 100644 --- a/s/d_migrate.cpp +++ b/s/d_migrate.cpp @@ -49,9 +49,11 @@ namespace mongo { class MoveTimingHelper { public: - MoveTimingHelper( const string& where , const string& ns ) + MoveTimingHelper( const string& where , const string& ns , BSONObj min , BSONObj max ) : _where( where ) , _ns( ns ){ _next = 1; + _b.append( "min" , min ); + _b.append( "max" , max ); } ~MoveTimingHelper(){ @@ -437,7 +439,7 @@ namespace mongo { configServer.init( configdb ); } - MoveTimingHelper timing( "from" , ns ); + MoveTimingHelper timing( "from" , ns , min , max ); Shard fromShard( from ); Shard toShard( to ); @@ -702,13 +704,13 @@ namespace mongo { } void _go(){ - MoveTimingHelper timing( "to" , ns ); - assert( active ); assert( state == READY ); assert( ! min.isEmpty() ); assert( ! max.isEmpty() ); + MoveTimingHelper timing( "to" , ns , min , max ); + ScopedDbConnection conn( from ); conn->getLastError(); // just test connection |