Method getBuffer

bolt/exec/OutputBufferManager.cpp:41–49

}

std::shared_ptr<OutputBuffer> OutputBufferManager::getBuffer(
    const std::string& taskId) {
  return buffers_.withLock([&](auto& buffers) {
    auto it = buffers.find(taskId);
    BOLT_CHECK(
        it != buffers.end(), "Output buffers for task not found: {}", taskId);
    return it->second;
  });
}

std::shared_ptr<OutputBuffer> OutputBufferManager::getBufferIfExists(
    const std::string& taskId) {