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 "Debug.h"
#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 );

            timeout_t getTimeInterval( uniset::TimerId timerid ) const;

            timeout_t getTimeLeft( uniset::TimerId timerid ) const;
 
        protected:

            virtual std::string getTimerName( int id ) const;

            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);
                    curTimeMS = 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
#if __cplusplus < 201103L
                    : public std::unary_function<TimerInfo, bool>
#endif
            {
                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() const;
 
        private:
            TimersList tlst;

            mutable uniset::uniset_rwmutex lstMutex;
            PassiveTimer tmLast;
 
            Debug::type loglevel = { Debug::LEVEL3 };
    };
    // -------------------------------------------------------------------------
} // end of uniset namespace
//--------------------------------------------------------------------------
#endif