WorkerStatus.h

#ifndef ROSE_BinaryAnalysis_ModelChecker_WorkerStatus_H
#define ROSE_BinaryAnalysis_ModelChecker_WorkerStatus_H
#include <featureTests.h>
#ifdef ROSE_ENABLE_MODEL_CHECKER
 
#include <Rose/BinaryAnalysis/ModelChecker/BasicTypes.h>
 
#include <Rose/Progress.h>
#include <boost/filesystem.hpp>
 
namespace Rose {
namespace BinaryAnalysis {
namespace ModelChecker {
 
class WorkerStatus {
public:
    using Ptr = WorkerStatusPtr;
 
private:
    boost::filesystem::path fileName_;
    int fd_ = -1;
 
    struct Status {
        WorkerState state = WorkerState::STARTING;      // current state
        time_t stateChange = 0;                         // time of last state change
        Progress::Ptr progress;                         // progress reports
        uint64_t pathHash = 0;                          // if working, the current path
    };
 
    std::vector<Status> workers_;
    time_t lastFileUpdate_ = 0;                         // last time that file was updated
 
    static constexpr time_t fileUpdatePeriod_ = 1;      // update the file every so many seconds
    static constexpr size_t workersPerLine_ = 4;        // number of worker information per line
    static constexpr size_t barWidth_ = 20;             // width of the bar that says how long since a state change
 
protected:
    WorkerStatus(const boost::filesystem::path &fileName);
 
public:
    ~WorkerStatus();
 
public:
    static Ptr instance(const boost::filesystem::path &fileName);
 
    void insert(size_t workerIdx, const Progress::Ptr&);
 
    void setState(size_t workerIdx, WorkerState, uint64_t pathHash);
 
    const boost::filesystem::path& fileName() const;
 
    void updateFile();
 
    void updateFileNow();
};
 
} // namespace
} // namespace
} // namespace
 
#endif
#endif