MCPcopy Create free account
hub / github.com/apache/impala / Consume

Method Consume

be/src/runtime/mem-tracker.h:137–152  ·  view source on GitHub ↗

Increases consumption of this tracker and its ancestors by 'bytes'.

Source from the content-addressed store, hash-verified

135
136 /// Increases consumption of this tracker and its ancestors by 'bytes'.
137 void Consume(int64_t bytes) {
138 DCHECK_GE(bytes, 0);
139 DCHECK(!closed_) << label_;
140 if (UNLIKELY(bytes <= 0)) return; // < 0 needed in RELEASE, hits DCHECK in DEBUG
141
142 if (consumption_metric_ != nullptr) {
143 RefreshConsumptionFromMetric();
144 return;
145 }
146 for (MemTracker* tracker : all_trackers_) {
147 tracker->consumption_->Add(bytes);
148 if (tracker->consumption_metric_ == nullptr) {
149 DCHECK_GE(tracker->consumption_->current_value(), 0);
150 }
151 }
152 }
153
154 /// Increases the consumption of this tracker and the ancestors up to (but
155 /// not including) end_tracker. This is useful if we want to move tracking between

Callers 10

QueueInboundCallMethod · 0.45
FindChunkMethod · 0.45
TESTFunction · 0.45
allocateMethod · 0.45
RowBatchMethod · 0.45
AddBatchMethod · 0.45
TakeOverEarlySenderMethod · 0.45
AddEarlySenderMethod · 0.45
AddEarlyClosedSenderMethod · 0.45

Calls 2

AddMethod · 0.45
current_valueMethod · 0.45

Tested by 2

TESTFunction · 0.36