| chunk_diff.hpp | chunk_diff.hpp | |||
|---|---|---|---|---|
| skipping to change at line 287 | skipping to change at line 287 | |||
| // | // | |||
| // We don't want to send a giant $or query to the server, so ju st get all the chunks | // We don't want to send a giant $or query to the server, so ju st get all the chunks | |||
| // | // | |||
| queryB.append( "ns", _ns ); | queryB.append( "ns", _ns ); | |||
| } | } | |||
| BSONObj query = queryB.obj(); | BSONObj query = queryB.obj(); | |||
| LOG(2) << "major version query from " << *_maxVersion << " and over | ||||
| " | ||||
| << _maxShardVersions->size() << " shards is " << query << en | ||||
| dl; | ||||
| // | // | |||
| // NOTE: IT IS IMPORTANT FOR CONSISTENCY THAT WE SORT BY ASC VERSIO N, TO HANDLE | // NOTE: IT IS IMPORTANT FOR CONSISTENCY THAT WE SORT BY ASC VERSIO N, TO HANDLE | |||
| // CURSOR YIELDING BETWEEN CHUNKS BEING MIGRATED. | // CURSOR YIELDING BETWEEN CHUNKS BEING MIGRATED. | |||
| // | // | |||
| Query queryObj(query); | Query queryObj(query); | |||
| queryObj.sort(BSON( "lastmod" << 1 )); | queryObj.sort(BSON( "lastmod" << 1 )); | |||
| return Query( query ); | LOG(2) << "major version query from " << *_maxVersion << " and over | |||
| " | ||||
| << _maxShardVersions->size() << " shards is " << queryObj << | ||||
| endl; | ||||
| return queryObj; | ||||
| } | } | |||
| } // namespace mongo | } // namespace mongo | |||
| End of changes. 2 change blocks. | ||||
| 6 lines changed or deleted | 6 lines changed or added | |||