Function WatcherThread

src/Utils/Config/ConfigFileWatcher.cpp:81–129

}

void WatcherThread() {
    const std::filesystem::path configPath(g_configPath);
    const std::filesystem::path dirPath = configPath.parent_path();
    const std::string targetFileName = configPath.filename().string();

    OSTPlatform::DirectoryWatch::Watch watch;
    if (!watch.Open(dirPath.string(), 4096)) {
        LOG_WARN("Failed to open config watch directory: {}", dirPath.string());
        return;
    }
    if (!watch.IssueRead()) {
        return;
    }

    LOG_INFO("Watching config file: {}", g_configPath);

    OSTPlatform::DirectoryWatch::Watch* watchPtr = &watch;
    std::vector<OSTPlatform::DirectoryWatch::Watch*> watches{watchPtr};

    auto drainEvent = [&]() {
        bool changed = ContainsConfigChange(watch.Drain(), targetFileName);
        watch.IssueRead();
        return changed;
    };

    while (g_running) {
        auto waitResult = OSTPlatform::DirectoryWatch::WaitAny(watches, 1000);

        if (!g_running) break;
        if (waitResult.status == OSTPlatform::DirectoryWatch::WaitStatus::Timeout) continue;
        if (waitResult.status != OSTPlatform::DirectoryWatch::WaitStatus::Signaled) continue;

        bool changed = drainEvent();
        while (g_running) {
            auto debounceResult = OSTPlatform::DirectoryWatch::WaitAny(watches, kDebounceMs);
            if (!g_running) break;
            if (debounceResult.status == OSTPlatform::DirectoryWatch::WaitStatus::Timeout) break;
            if (debounceResult.status != OSTPlatform::DirectoryWatch::WaitStatus::Signaled) break;
            changed = drainEvent() || changed;
        }

        if (changed) {
            ReloadConfig();
        }
    }

    watch.Cancel();
    LOG_INFO("Config watcher stopped");
}

} // namespace