PeriodicJobThread.h

Go to the documentation of this file.

#ifndef PERIODICJOBTHREAD_H
#define PERIODICJOBTHREAD_H
 
#include <limits.h>
#include <time.h>
#include <mqueue.h>
#include <iostream>
 
#include <list>
#include "Utility/Types.h"
#include "Utility/Thread.h"
#include "Utility/Mutex.h"
 
class tcJob;
 
class tcJobSchedule;
 
class tcPeriodicJobThread : public tcThread
{
public:
    tcPeriodicJobThread();
    ~tcPeriodicJobThread();
    void* run();
 
    int addJob(tcJob* apJob);
 
    int removeJob(tcJob* apJob);
 
    void stop();
 
    void printScheduledJobs();
 
    typedef std::list<tcJob*> tlJobList;
private:
    void recomputeTimes();
    void computeNextWakeup();
    uint64 timespecToMs(const struct timespec arT) const { return (uint64)(arT.tv_sec) * 1000
            + (arT.tv_nsec) / 1000000 ; }
    bool msToTimespec(uint64 anMs, struct timespec& arT);
    void sendSimpleMsg(uint32 anVal);
    std::ostream& printTime(const struct timespec& arT, std::ostream& strm=std::cout) const;
    std::ostream& printTime(uint64 anMs, std::ostream& strm=std::cout) const;
    static const uint32 cnMsgQuit=0xDEADBEEF;
    static const uint32 cnMsgRecompute=0xFACE0001;
    tcMutex mcLock;
    tlJobList mlJobs;
    volatile bool mbDone;
    struct timespec msLastTime;
    struct timespec msNextTime;
    char maMqName[NAME_MAX];
    mqd_t mhMsgQ;
};
 
 
std::ostream& operator <<(std::ostream& arS, const struct tcJobSchedule& arJS);
 
#endif // PERIODICJOBTHREAD_H