Skip to content

Commit 24e16b0

Browse files
committed
Update peak for global memory tracker even if it is blocked
1 parent a596576 commit 24e16b0

1 file changed

Lines changed: 2 additions & 1 deletion

File tree

src/Common/MemoryTracker.cpp

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -255,8 +255,9 @@ AllocationTrace MemoryTracker::allocImpl(Int64 size, bool throw_if_memory_exceed
255255
if (level == VariableContext::Global)
256256
{
257257
/// For global memory tracker always update memory usage.
258-
amount.fetch_add(size, std::memory_order_relaxed);
258+
Int64 will_be = amount.fetch_add(size, std::memory_order_relaxed);
259259
rss.fetch_add(size, std::memory_order_relaxed);
260+
updatePeak(will_be, /*log_memory_usage=*/ false);
260261

261262
auto metric_loaded = metric.load(std::memory_order_relaxed);
262263
if (metric_loaded != CurrentMetrics::end())

0 commit comments

Comments
 (0)