---

/home/pauldt/projects/IDEA/IDEA-ALL/IDEA-DEV/TimingService/Includes/TimingService.hh

Go to the documentation of this file.

// -*- Mode: c++ -*-
//   File: $CVSROOT/IdeaCore/TimingService/TimingService.hh
//   Info: $CVSROOT/IdeaCore/Copyright.txt
//   CVS: $Id: TimingService.hh,v 1.3 2005/07/11 18:17:05 rijsman Exp $
//  Purpose: 

#ifndef TIMING_SERVICE_H
#define TIMING_SERVICE_H

#include "TimeBasics.hh"

#include "TimingServiceStopper.hh"

#include <ace/Task.h>
#include <map>

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

  typedef std::multimap< Time, int, EarliestTimeFirst> Time2IntMap;

  class SharedTimingService;

  class TimingService:
    public ACE_Task_Base
  {
  public:
    TimingService( int tscale = 1, 
                   bool warp = false, 
                   const Time& offset = Time(0,0), 
                   const std::string& poolName = "TimingService" );
    ~TimingService();
    SharedTimingService* getSharedTimingService() const;
    int run( bool wait = true );
    void spin();
    void stopSpinning();
  private:
    enum TimerActionType 
      {
        TIMER_ACTION_UNINITIALIZED=0,
        SET_TIMER,
        RESET_TIMER,
        CANCEL_TIMER,
        TIMER_ACTION_LIMIT
      };
    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); 
    int svc(void);
    int createSharedTimingService();
    void setTimer( int agent, const Time& simulationTime );
    void cancelTimer();
    bool serverInsertTimer(); 
    bool serverCheckWarping();
    bool serverHandleWakeup();
    bool serverCancelTimer();
    bool serverSetActiveTimer(bool reset);
    bool serverReactorRequest( TimerActionType action, int agent, const Time& simulationTime );
    void serverFailure();

    SharedTimingService* m_SharedTimingService;

    bool m_ServerFailed;       
    bool m_ServerRunning;      
    bool m_ServerThreadDone;   
    bool m_WarpEnabled;

    int m_EventTimerId;
    int m_TimeScale;

    Time m_EarliestWakeUpTime; 
    Time m_Offset;
    Time m_TimerDataNextEvent;

    TimingServiceStopper m_Stopper;
  };

}

#endif // TIMING_SERVICE_H

---

Contact information © IDEA