Skip to content

Commit 88c1914

Browse files
committed
limit -> quota
1 parent a63cf9a commit 88c1914

File tree

2 files changed

+10
-2
lines changed

2 files changed

+10
-2
lines changed

ydb/library/yql/dq/actors/compute/dq_compute_memory_quota.h

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,14 @@ namespace NYql::NDq {
7373
});
7474
}
7575

76+
bool AllocateQuota(ui64 bytes) {
77+
return MemoryLimits.MemoryQuotaManager->AllocateQuota(bytes);
78+
}
79+
80+
void FreeQuota(ui64 bytes) {
81+
MemoryLimits.MemoryQuotaManager->FreeQuota(bytes);
82+
}
83+
7684
void TryShrinkMemory(NKikimr::NMiniKQL::TScopedAlloc* alloc) {
7785
if (alloc->GetAllocated() - alloc->GetUsed() > MemoryLimits.MinMemFreeSize) {
7886
alloc->ReleaseFreePages();

ydb/library/yql/dq/actors/compute/dq_sync_compute_actor_base.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -236,8 +236,8 @@ class TDqSyncComputeActorBase: public TDqComputeActorBase<TDerived, TComputeActo
236236
if (this->Task.GetEnableSpilling()) {
237237
TaskRunner->SetSpillerFactory(std::make_shared<TDqSpillerFactory>(execCtx.GetTxId(), NActors::TActivationContext::ActorSystem(), execCtx.GetWakeupCallback(), execCtx.GetErrorCallback()));
238238
TaskRunner->SetMemoryUsageReporter(std::make_shared<NKikimr::NMiniKQL::TMemoryUsageReporter>(
239-
[this](ui64 bytes){ return this->MemoryLimits.MemoryQuotaManager->AllocateQuota(bytes); },
240-
[this](ui64 bytes){ this->MemoryLimits.MemoryQuotaManager->FreeQuota(bytes); }
239+
[this](ui64 bytes){ return this->MemoryQuota->AllocateQuota(bytes); },
240+
[this](ui64 bytes){ this->MemoryQuota->FreeQuota(bytes); }
241241
));
242242
}
243243

0 commit comments

Comments
 (0)