diff options
author | Antonin Kral <a.kral@bobek.cz> | 2012-05-10 06:57:57 +0200 |
---|---|---|
committer | Antonin Kral <a.kral@bobek.cz> | 2012-05-10 06:57:57 +0200 |
commit | 8813daaab256108f7aa6300875e8562d031f2c2f (patch) | |
tree | 06daade9022f76b2775d23f4613817365a2ded99 /s/d_migrate.cpp | |
parent | d72a59184a3d51b17b30ed20fe656421bd4d2248 (diff) | |
parent | 61619b3142c1de8f60f91964ff2656054d4f11a6 (diff) | |
download | mongodb-8813daaab256108f7aa6300875e8562d031f2c2f.tar.gz |
Merge tag 'upstream/2.0.5'
Upstream version 2.0.5
Diffstat (limited to 's/d_migrate.cpp')
-rw-r--r-- | s/d_migrate.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/s/d_migrate.cpp b/s/d_migrate.cpp index e24a02d..731761f 100644 --- a/s/d_migrate.cpp +++ b/s/d_migrate.cpp @@ -1445,13 +1445,13 @@ namespace mongo { bool didAnything = false; if ( xfer["deleted"].isABSONObj() ) { - writelock lk(ns); - Client::Context cx(ns); - RemoveSaver rs( "moveChunk" , ns , "removedDuring" ); BSONObjIterator i( xfer["deleted"].Obj() ); while ( i.more() ) { + writelock lk(ns); + Client::Context cx(ns); + BSONObj id = i.next().Obj(); // do not apply deletes if they do not belong to the chunk being migrated @@ -1472,11 +1472,11 @@ namespace mongo { } if ( xfer["reload"].isABSONObj() ) { - writelock lk(ns); - Client::Context cx(ns); - BSONObjIterator i( xfer["reload"].Obj() ); while ( i.more() ) { + writelock lk(ns); + Client::Context cx(ns); + BSONObj it = i.next().Obj(); Helpers::upsert( ns , it ); |