summaryrefslogtreecommitdiff
path: root/s/d_migrate.cpp
diff options
context:
space:
mode:
authorAntonin Kral <a.kral@bobek.cz>2012-05-10 06:57:57 +0200
committerAntonin Kral <a.kral@bobek.cz>2012-05-10 06:57:57 +0200
commit8813daaab256108f7aa6300875e8562d031f2c2f (patch)
tree06daade9022f76b2775d23f4613817365a2ded99 /s/d_migrate.cpp
parentd72a59184a3d51b17b30ed20fe656421bd4d2248 (diff)
parent61619b3142c1de8f60f91964ff2656054d4f11a6 (diff)
downloadmongodb-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.cpp12
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 );