| 629 | } |
| 630 | |
| 631 | bolt::memory::MemoryPool* Task::addMergeSourcePool( |
| 632 | const core::PlanNodeId& planNodeId, |
| 633 | uint32_t pipelineId, |
| 634 | uint32_t sourceId) { |
| 635 | std::lock_guard<std::timed_mutex> l(mutex_); |
| 636 | auto* nodePool = getOrAddNodePool(planNodeId); |
| 637 | childPools_.push_back(nodePool->addLeafChild( |
| 638 | fmt::format( |
| 639 | "mergeExchangeClient.{}.{}.{}", planNodeId, pipelineId, sourceId), |
| 640 | true, |
| 641 | createExchangeClientReclaimer())); |
| 642 | return childPools_.back().get(); |
| 643 | } |
| 644 | |
| 645 | bolt::memory::MemoryPool* Task::addExchangeClientPool( |
| 646 | const core::PlanNodeId& planNodeId, |
no test coverage detected