RTTimerActor.h

/*
 * Licensed Materials - Property of HCL and/or IBM
 * Copyright HCL Technologies Ltd. 2016, 2021. All Rights Reserved.
 * Copyright IBM Corporation 1999, 2016. All Rights Reserved.
 *
 * U.S. Government Users Restricted Rights -  Use, duplication or 
 * disclosure restricted by GSA ADP Schedule.
 */
 
#ifndef __RTTimerActor_h__
#define __RTTimerActor_h__ included
 
#ifdef PRAGMA
#pragma interface
#endif
 
#ifndef __RTActor_h__
#include <RTActor.h>
#endif
 
#ifndef __RTTimerList_h__
#include <RTTimerList.h>
#endif
 
#ifndef __RTTimespec_h__
#include <RTTimespec.h>
#endif
 
#ifndef __RTTiming_h__
#include <RTTiming.h>
#endif
 
#include "RTSyncObject.h"
class RTTimerNode;
 
class RTTimerActor : public RTActor
{
public:
              RTTimerActor( RTController *, RTActorRef * );
    virtual               ~RTTimerActor( void );
 
    RTS_INLINE
    static RTTimerActor * soleInstance( void );
    static void           waitUntilInstanceReady( void );
    virtual void          rtsBehavior( int, int ) override;
 
    RTS_INLINE int        anyPending( void ) const;
    int                   numPending( void ) const;
    int                   nextTimeout( RTTimespec & );
 
    virtual int           designLevel( void ) const override;
 
    static  const RTActorClass     classData;
    virtual const RTActor_class  * getActorData( void ) const override;
 
    friend class RTTracer;
 
    void                  informIn( RTTimerNode * );
    void                  informAt( RTTimerNode * );
    void                  informAgain( RTTimerNode * );
    void                  cancel( RTTimerNode * );
    void                  cancelAll( Timing::Base * );
 
    void                  adjustTimeBegin( void );
    void                  adjustTimeEnd( const RTTimespec & delta,
                     RTController     * originator );
    static void           getRelativeClock( RTTimespec & );
 
protected:
    RTTimerList           pendingAbsolute;
    RTTimerList           pendingRelative;
 
    static RTTimespec     currentOffset;
 
    void                  start( void );
    void                  stop( void );
 
    void                  sendTimeouts( void );
 
    static const RTActor_class rtg_class;
 
private:
    static const RTStateId     rtg_parent_state[];
 
    static RTTimerActor * _soleInstance;
    static RTSyncObject   _syncInstance;
 
    // unavailable methods
    RTTimerActor( const RTTimerActor & );
    RTTimerActor & operator=( const RTTimerActor & );
}; //lint !e1712
 
#if RTS_INLINES
#include <RTTimerActor.inl>
#endif
 
#endif // __RTTimerActor_h__