mongodb/mongo
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SERVER-126463 collection cloner function_ref memory bug (#54143)

Browse Source 
GitOrigin-RevId: af65c792309ba4db8677f1ccf8f5f20f94b984d7
This commit is contained in:
Vishnu K 2026-05-21 13:01:08 -04:00 committed by MongoDB Bot
parent 45b22ebdc8
commit e32f3bc2b3
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
src/mongo/db/repl/initial_sync/collection_cloner.cpp
View File

@ -562,11 +562,12 @@ void CollectionCloner::insertDocumentsCallback(const executor::TaskExecutor::Cal
_progressMeter.hit(int(docs.size()));
invariant(_collLoader);
CollectionBulkLoader::ParseRecordIdAndDocFunc fn = (_recordIdsReplicated)
? ([](const BSONObj& doc) {
return std::make_pair(RecordId(doc["r"].Long()), doc["d"].Obj());
})
: ([](const BSONObj& doc) { return std::make_pair(RecordId(0), doc); });
auto fn = [recordIdsReplicated =
_recordIdsReplicated](const BSONObj& doc) -> std::pair<RecordId, BSONObj> {
if (recordIdsReplicated)
return {RecordId(doc["r"].Long()), doc["d"].Obj()};
return {RecordId(0), doc};
};
// The insert must be done within the lock, because CollectionBulkLoader is not
// thread safe.
uassertStatusOK(_collLoader->insertDocuments(docs, fn));