Method Logs

src/daemon/runtime_manager.cpp:1560–1591

}

nlohmann::json RuntimeManager::Logs(const std::string& vm_id, size_t max_lines) const {
    nlohmann::json lines = nlohmann::json::array();
    if (auto session = FindSession(vm_id)) {
        std::lock_guard<std::mutex> lock(session->console_mutex);
        const size_t start = session->log_lines.size() > max_lines ? session->log_lines.size() - max_lines : 0;
        for (size_t i = start; i < session->log_lines.size(); ++i) {
            lines.push_back(session->log_lines[i]);
        }
        return {{"lines", std::move(lines)}};
    }
    // No live session: tail the on-disk log so the operator can still read
    // crash output. Walk back through current + rotated files until we have
    // enough lines (or run out of files).
    auto record = store_.Get(vm_id);
    if (!record) return {{"lines", lines}};
    const fs::path base = RuntimeLogPath(record->spec.vm_dir);
    std::vector<std::string> collected;
    auto absorb = [&](const fs::path& path) {
        if (collected.size() >= max_lines) return;
        auto chunk = TailLogFile(path, max_lines - collected.size());
        chunk.insert(chunk.end(),
                     std::make_move_iterator(collected.begin()),
                     std::make_move_iterator(collected.end()));
        collected = std::move(chunk);
    };
    absorb(base);
    for (int i = 1; i <= kLogRotateKeep && collected.size() < max_lines; ++i) {
        absorb(base.string() + "." + std::to_string(i));
    }
    for (auto& l : collected) lines.push_back(std::move(l));
    return {{"lines", std::move(lines)}};
}

ProcessResources RuntimeManager::SampleProcessResources(const std::string& vm_id) const {
    auto session = FindSession(vm_id);