---

/home/pauldt/projects/IDEA/IDEA-ALL/IDEA-DEV/Modules/SharedTimingService/Includes/SharedTimingServiceImpl.hh

Go to the documentation of this file.

// -*- Mode: c++ -*-
//     File: $Source: /home/cvs/ISG-Repository/IDEA-DEV/Modules/SharedTimingService/Includes/SharedTimingServiceImpl.hh,v $
//      Tag: $Name: DR_01_11_06 $
//      CVS: $Id: SharedTimingServiceImpl.hh,v 1.9 2005/12/30 22:46:05 rijsman Exp $
//     Info: $CVSROOT/IDEA-DEV/COPYRIGHT

#ifndef IDEA_AGENT_TIMING_SERVICE_IMPL_H
#define IDEA_AGENT_TIMING_SERVICE_IMPL_H

#include <map>

#include "AgentTimingServiceImpl.hh"
#include "SharedTimingService.hh"

namespace IDEA
{
  struct CompareFunc
  {
    bool operator()( const Time& lhs, const Time& rhs ) const
    {
      return lhs < rhs;
    }
  };

  class SharedTimingServiceImpl:
    public AgentTimingServiceImpl,
    public ACE_Task_Base
  {
  public:
    SharedTimingServiceImpl( const std::string& name, const std::string& poolName );
    ~SharedTimingServiceImpl();
    RecursiveThreadMutex& getMutex();
    bool getNextScheduledTime( Time& time );
    void setCancellableEventTimer(const Time& time);
    void cancelEventTimer();
    void setRebootTimer(const Time& time);
    void cancelRebootTimer();
    void setNonCancellableEventTimer(const Time& time);
    void cancelAllTimers(); // for graceful shutdown
    bool isInitialized() const; 
    Time getCurrentTime();
    Time getElapsedTime();
    Time getTimeOfDay();
    void setAgentNotActive(); 
    void setAgentActive();
   void incrementTransitMessages(int numOfMsgs=1);
    void decrementTransitMessages(int numOfMsgs=1);
    void cancelTimer( const Time& time );
    void incrementNonWarpableCommands();
    void decrementNonWarpableCommands();
    int activate(long flags=THR_NEW_LWP|THR_JOINABLE|THR_INHERIT_SCHED, int n_threads=1, int force_active=0, long priority=ACE_DEFAULT_THREAD_PRIORITY, int grp_id=-1, ACE_Task_Base *task=0, ACE_hthread_t thread_handles[]=0, void *stack[]=0, size_t stack_size[]=0, ACE_thread_t thread_ids[]=0); 
  protected:
     enum TimerType
       {
         TYPE_OF_TIMER_UNINITIALIZED=0,
         CANCELLABLE_EVENT_TIMER,
         NON_CANCELLABLE_EVENT_TIMER,
         NON_CANCELLABLE_AND_CANCELLABLE_EVENT_TIMERS,
         REBOOT_TIMER,
         CANCELLABLE_EVENT_AND_REBOOT_TIMERS,
         NON_CANCELLABLE_EVENT_AND_REBOOT_TIMERS,
         NON_CANCELLABLE_AND_CANCELLABLE_EVENT_AND_REBOOT_TIMERS,
         TYPE_OF_TIMER_LIMIT
       };

    typedef std::map< Time, TimerType, CompareFunc > AgentTimerMap;

    typedef AgentTimerMap::iterator AgentTimerMapIter;

    AgentTimerMap m_AgentTimerMap;
  private:
    bool getNextEvent( Time& time, int& type );
    void setTimer( const Time& time );
    void insertTimerInMap(const Time& time, TimerType timerType);
    void deleteTimerInMap(Time time, TimerType timerType);
    int svc();
  
    Time m_EventTime;  // state variable used for lookup (during cancellation)

    bool m_EventTimeScheduled;  // set to true if an eventTime appears in the map
    Time m_RebootTime; // state variable used for lookup (during cancellation)

    RecursiveThreadMutex m_Mutex;

    int m_NonWarpableCommands;

    int m_AgentIdFromTimingService;
    SharedTimingService* m_SharedTimingService; 

    bool m_CallBackThreadDone;

    ProcessSemaphore m_SemaphoreForCallback;

    bool m_Initialized;
  
  };

}

#endif 

---

Contact information © IDEA