Job.h

Go to the documentation of this file.

#ifndef JOB_H
#define JOB_H
 
#include <time.h>
#include <ostream>
#include "Utility/Types.h"
 
class tcPeriodicJobThread;
 
class tcJob
{
public:
    tcJob(const char* apName);
    virtual ~tcJob();
 
    enum teStatus
    {
        eeStopped,
        eeScheduled,
        eeRunning,
        eeFailed,
    };
 
    class tcStats
    {
    public:
        struct timespec msStartLast;
        struct timespec msStopLast;
        teStatus meStatus;
    };
 
    const char* getName() const { return mpName; }
 
    void attachThread(tcPeriodicJobThread* apThread);
    void detachThread();
    virtual int  getPeriodMs() const { return mnPeriodMs; }
    virtual uint64  getNextRunTimeMs() const;
    int doExecute();
    virtual teStatus status() const { return mcStats.meStatus; }
 
protected:
    virtual int execute() = 0;
    tcPeriodicJobThread* mpThread;
    int mnPeriodMs;
    uint64 mnLastRunMs;
    tcStats mcStats;
    uint64 timespecToMs(const struct timespec arT) const { return (uint64)(arT.tv_sec) * 1000
            + (arT.tv_nsec) / 1000000 ; }
    void enterExecute();
    void exitExecute();
 
private:
    const char* mpName;
};
 
// should be in some common utility header...
std::ostream& operator <<(std::ostream& arS, const struct timespec& arT);
 
#endif // JOB_H