summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEliot Horowitz <eliot@10gen.com>2010-07-16 14:39:14 -0400
committerEliot Horowitz <eliot@10gen.com>2010-07-16 14:39:14 -0400
commit6d47fb7ea523263597d916b722f09e5924b9689a (patch)
tree1d95dc62f0ee200b065211a6fc515e731beb3909
parentdc54ce28609bf39518417b9c60cc2f26c8eb460b (diff)
downloadmongo-6d47fb7ea523263597d916b722f09e5924b9689a.tar.gz
handle removes during moveChunk SERVER-1425
-rw-r--r--s/d_migrate.cpp9
1 files changed, 6 insertions, 3 deletions
diff --git a/s/d_migrate.cpp b/s/d_migrate.cpp
index c0c106b61a9..4d6ac03babf 100644
--- a/s/d_migrate.cpp
+++ b/s/d_migrate.cpp
@@ -674,9 +674,12 @@ namespace mongo {
if ( xfer["deleted"].isABSONObj() ){
writelock lk(ns);
Client::Context cx(ns);
-
- // TODO:
- assert(0);
+
+ BSONObjIterator i( xfer["deleted"].Obj() );
+ while ( i.more() ){
+ BSONObj id = i.next().Obj();
+ Helpers::removeRange( ns , id , id, false , true );
+ }
}
if ( xfer["reload"].isABSONObj() ){