/home/tobi/workspace/solarpowerlog/src/interfaces/CWorkScheduler.h

Go to the documentation of this file.

/* ----------------------------------------------------------------------------
   solarpowerlog
   Copyright (C) 2009  Tobias Frost

   This file is part of solarpowerlog.

   Solarpowerlog is free software; However, it is dual-licenced
   as described in the file "COPYING".

   For this file (CWorkScheduler.h), the license terms are:

   You can redistribute it and/or  modify it under the terms of the GNU Lesser
   General Public License (LGPL) as published by the Free Software Foundation;
   either version 3 of the License, or (at your option) any later version.

   This program is distributed in the hope that it will be useful, but
   WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
   Lesser General Public License for more details.

   You should have received a copy of the GNU Library General Public
   License along with this proramm; if not, see
   <http://www.gnu.org/licenses/>.
   ----------------------------------------------------------------------------
*/
#ifndef CWORKSCHEDULER_H_
#define CWORKSCHEDULER_H_

#ifdef HAVE_CONFIG_H
#include "config.h"
#include "porting.h"
#endif

#include <time.h>
#include <list>

#include <semaphore.h>
#include <map>

#include <boost/thread/mutex.hpp>

class ICommand;
class ICommandTarget;
class CTimedWork;

using namespace std;


class CWorkScheduler {

     friend class CTimedWork;

public:
     CWorkScheduler();
     virtual ~CWorkScheduler();

     void ScheduleWork(ICommand *Command);

     void ScheduleWork(ICommand *Commmand, struct timespec ts);

     bool DoWork(bool block=false);

private:

     CTimedWork *timedwork;

     list<ICommand*> CommandsDue;

#if 0
     struct timepec_compare
     {
           bool operator()(const struct timespec t1, const struct timespec t2) const
            {
                if(t1.tv_sec < t2.tv_sec) return true;
                if(t1.tv_sec > t2.tv_sec) return false;
                if(t1.tv_nsec < t2.tv_nsec) return true;
                return false;
            };
     };

     multimap<struct timespec, ICommand*, timepec_compare> TimedCommands;
#endif

     ICommand *getnextcmd(void);

private:
     sem_t semaphore;

protected:
     boost::mutex mut;

};

#endif /* CWORKSCHEDULER_H_ */