ScriptedAlgorithmWatchdog.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: 2026 fuddlesworth
// SPDX-License-Identifier: LGPL-2.1-or-later
 
#pragma once
 
#include <phosphortiles_export.h>
 
#include <chrono>
#include <condition_variable>
#include <cstdint>
#include <mutex>
#include <thread>
#include <unordered_map>
 
namespace PhosphorTiles {
 
class ScriptedAlgorithm;
 
class PHOSPHORTILES_EXPORT ScriptedAlgorithmWatchdog
{
public:
    ScriptedAlgorithmWatchdog();
    ~ScriptedAlgorithmWatchdog();
 
    void arm(ScriptedAlgorithm* algo, int timeoutMs);
 
    void disarm(ScriptedAlgorithm* algo);
 
    void unregister(ScriptedAlgorithm* algo);
 
    // Non-copyable, non-movable — ownership is shared via std::shared_ptr
    // (see class comment above for rationale). Move would invalidate the
    // mutex / condvar / std::thread members.
    ScriptedAlgorithmWatchdog(const ScriptedAlgorithmWatchdog&) = delete;
    ScriptedAlgorithmWatchdog& operator=(const ScriptedAlgorithmWatchdog&) = delete;
    ScriptedAlgorithmWatchdog(ScriptedAlgorithmWatchdog&&) = delete;
    ScriptedAlgorithmWatchdog& operator=(ScriptedAlgorithmWatchdog&&) = delete;
 
private:
    struct Entry
    {
        std::chrono::steady_clock::time_point deadline;
        uint64_t generation = 0; 
    };
 
    void threadMain();
 
    std::mutex m_mutex;
    std::condition_variable m_cv;
    std::unordered_map<ScriptedAlgorithm*, Entry> m_entries;
    bool m_shutdown = false;
    std::thread m_thread;
};
 
} // namespace PhosphorTiles