summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/document_source_group.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/document_source_group.cpp')
-rw-r--r--src/mongo/db/pipeline/document_source_group.cpp12
1 files changed, 6 insertions, 6 deletions
diff --git a/src/mongo/db/pipeline/document_source_group.cpp b/src/mongo/db/pipeline/document_source_group.cpp
index 7987265b028..51c7ccd3fdc 100644
--- a/src/mongo/db/pipeline/document_source_group.cpp
+++ b/src/mongo/db/pipeline/document_source_group.cpp
@@ -155,10 +155,10 @@ int DocumentSourceGroup::freeMemory() {
int totalMemorySaved = 0;
for (auto&& group : *_groups) {
for (size_t i = 0; i < group.second.size(); i++) {
- auto prevMemUsage = group.second[i]->memUsageForSorter();
+ auto prevMemUsage = group.second[i]->getMemUsage();
group.second[i]->reduceMemoryConsumptionIfAble();
- auto memorySaved = prevMemUsage - group.second[i]->memUsageForSorter();
+ auto memorySaved = prevMemUsage - group.second[i]->getMemUsage();
// Update the memory usage for this AccumulationStatement.
_memoryTracker.accumStatementMemoryBytes[i].currentMemoryBytes -= memorySaved;
// Update the memory usage for this group.
@@ -581,8 +581,8 @@ DocumentSource::GetNextResult DocumentSourceGroup::initialize() {
} else {
for (size_t i = 0; i < group.size(); i++) {
// subtract old mem usage. New usage added back after processing.
- _memoryTracker.memoryUsageBytes -= group[i]->memUsageForSorter();
- oldAccumMemUsage[i] = group[i]->memUsageForSorter();
+ _memoryTracker.memoryUsageBytes -= group[i]->getMemUsage();
+ oldAccumMemUsage[i] = group[i]->getMemUsage();
}
}
@@ -594,9 +594,9 @@ DocumentSource::GetNextResult DocumentSourceGroup::initialize() {
_accumulatedFields[i].expr.argument->evaluate(rootDocument, &pExpCtx->variables),
_doingMerge);
- _memoryTracker.memoryUsageBytes += group[i]->memUsageForSorter();
+ _memoryTracker.memoryUsageBytes += group[i]->getMemUsage();
_memoryTracker.accumStatementMemoryBytes[i].currentMemoryBytes +=
- group[i]->memUsageForSorter() - oldAccumMemUsage[i];
+ group[i]->getMemUsage() - oldAccumMemUsage[i];
}
if (kDebugBuild && !storageGlobalParams.readOnly) {