diff options
author | Eliot Horowitz <eliot@10gen.com> | 2010-07-16 14:39:14 -0400 |
---|---|---|
committer | Eliot Horowitz <eliot@10gen.com> | 2010-07-16 14:39:14 -0400 |
commit | 6d47fb7ea523263597d916b722f09e5924b9689a (patch) | |
tree | 1d95dc62f0ee200b065211a6fc515e731beb3909 | |
parent | dc54ce28609bf39518417b9c60cc2f26c8eb460b (diff) | |
download | mongo-6d47fb7ea523263597d916b722f09e5924b9689a.tar.gz |
handle removes during moveChunk SERVER-1425
-rw-r--r-- | s/d_migrate.cpp | 9 |
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() ){ |