LT_Object.h

/*
 * Copyright (c) 2015 Pavel Vainerman.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation, version 2.1.
 *
 * 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 Lesser Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */
// --------------------------------------------------------------------------
//---------------------------------------------------------------------------
#ifndef Object_LT_H_
#define Object_LT_H_
//--------------------------------------------------------------------------
#include <deque>
#include "UniSetTypes.h"
#include "MessageType.h"
#include "PassiveTimer.h"
#include "Exceptions.h"
//---------------------------------------------------------------------------
namespace uniset
{
class UniSetObject;

//---------------------------------------------------------------------------
class LT_Object
{
    public:
        LT_Object();
        virtual ~LT_Object();


        virtual timeout_t askTimer( uniset::TimerId timerid, timeout_t timeMS, clock_t ticks = -1,
                                    uniset::Message::Priority p = uniset::Message::High );


        timeout_t checkTimers( UniSetObject* obj );

        //inline timeout_t getSleepTimeMS(){ return sleepTime; }


        timeout_t getTimeInterval( uniset::TimerId timerid );

        timeout_t getTimeLeft( uniset::TimerId timerid );

    protected:

        virtual std::string getTimerName( int id );

        struct TimerInfo
        {
            TimerInfo() {};
            TimerInfo( uniset::TimerId id, timeout_t timeMS, clock_t cnt, uniset::Message::Priority p ):
                id(id),
                curTimeMS(timeMS),
                priority(p),
                curTick(cnt - 1)
            {
                tmr.setTiming(timeMS);
            };

            inline void reset()
            {
                curTimeMS = tmr.getInterval();
                tmr.reset();
            }

            uniset::TimerId id = { 0 };    
            timeout_t curTimeMS = { 0 };        
            uniset::Message::Priority priority = { uniset::Message::High }; 
            clock_t curTick = { -1 };

            // таймер с меньшим временем ожидания имеет больший приоритет
            bool operator < ( const TimerInfo& ti ) const
            {
                return curTimeMS > ti.curTimeMS;
            }

            PassiveTimer tmr;
        };

        class Timer_eq: public std::unary_function<TimerInfo, bool>
        {
            public:
                Timer_eq(uniset::TimerId t): tid(t) {}

                inline bool operator()(const TimerInfo& ti) const
                {
                    return ( ti.id == tid );
                }

            protected:
                uniset::TimerId tid;
        };

        typedef std::deque<TimerInfo> TimersList;

        timeout_t sleepTime; 
        TimersList getTimersList();

    private:
        TimersList tlst;

        uniset::uniset_rwmutex lstMutex;
        PassiveTimer tmLast;
};
// -------------------------------------------------------------------------
} // end of uniset namespace
//--------------------------------------------------------------------------
#endif