---

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

Go to the documentation of this file.

// -*- Mode: c++ -*-
//     File: $Source: /home/cvs/ISG-Repository/IDEA-DEV/TimingService/Includes/SharedTimingService.hh,v $
//      Tag: $Name: DR_01_11_06 $
//      CVS: $Id: SharedTimingService.hh,v 1.5 2005/07/15 22:24:40 rijsman Exp $
//     Info: $CVSROOT/IDEA-DEV/COPYRIGHT

#ifndef SHARED_TIMING_SERVICE_H
#define SHARED_TIMING_SERVICE_H

#include <ace/Shared_Memory_MM.h>
#include <ace/Malloc.h>
#include "ace/PI_Malloc.h"
#include "ace/Auto_Ptr.h"

#include "ThreadTools.hh"
#include "TimeBasics.hh"

#define MAX_NO_OF_AGENTS 16
#define MAX_AGENT_NAME_LENGTH 256

namespace IDEA
{
  typedef ACE_Malloc_T< ACE_SHARED_MEMORY_POOL, ProcessMutex, ACE_PI_Control_Block  >  SharedMemoryAllocator;

  class SharedTimingService:
    public ACE_Task_Base
  {
    friend class TimingService;
    friend class MetaTimingService;
  public:
    enum Action
      {
        UNINITIALIZED = 0,
        WAKEUP_DELETE, // was DUE_TO_WAKEUP
        CANCEL_DELETE, // was DUE_TO_CANCEL
        INSERT,        // was DUE_TO_INSERT
        CHECK_WARPING
      };

    SharedTimingService( int tscale, bool warp, const Time& offset );
    ~SharedTimingService();
    void synchronize( const Time& time, int ts );
    static SharedTimingService* findInstance();
    int registerAgent( const std::string& aName );   
    void unregisterAgent(int aId);
    void setTimer( int agentId, const Time& time);
    void cancelTimer( int agentId, const Time& time);
    Time getCurrentTime(); 
    Time getElapsedTime() const;
    const Time& getPivotDate() const;
    void setAgentActive( int agentId);
    void setAgentNotActive( int agentId);
    void incrementTransitMessages( int agentId, int numOfMsgs);
    void decrementTransitMessages( int agentId, int numOfMsgs);
    Time getRelativeTime(const Time & tym) const;
    int getTimeScale() const;
    int getTransitMessageCount();
    int getActiveAgentCount();
    const SharedTimingService::Action& getAction() const;
    int getActionRequesterId() const;
    const Time& getActionTime() const;
    const bool isWarpingEnabled();
    char* getRegisteredAgentName( int agentId);
    static void setSharedMemoryPoolName( const std::string& name );
    static std::string& getSharedMemoryPoolName();
    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); 
    ThreadSemaphore& getWakeupHandlerSemaphore() { return  m_WakeupHandlerSemaphore; }
    ProcessSemaphore& getServerSemaphore() { return m_ServerSemaphore; }
    ProcessSemaphore& getServerDoneSemaphore() { return m_ServerDoneSemaphore; }
    void setScaleDate( const Time& scaleDate );
    bool warp( const Time& nextEvent );
    const Time& getMinimumWarp() const;
    const Time& getWarpPadding() const;
    void setMinimumWarp( const Time& t );
    void setWarpPadding( const Time& t );
  private:
    Time getNow() const;
    void initializePivotDate();
    static SharedTimingService* constructInstance( int tscale = 1, bool warp = false, const Time& offset= Time::getZero() );
    static void releaseInstance();
    static SharedMemoryAllocator* getAllocator();
    SharedTimingService();                          
    SharedTimingService(const SharedTimingService &); // copy constructor
    SharedTimingService & operator=(const SharedTimingService &); // assignment operator
    void requestWarpCheck( int agentId );
    int svc();
    static std::string s_SharedMemoryPoolName;
    ThreadSemaphore m_WakeupHandlerSemaphore;

    ProcessSemaphore m_ServerSemaphore;
    ProcessSemaphore m_ServerDoneSemaphore;
    ProcessMutex m_TimingServiceMutex;
    ProcessMutex m_TimeBaseMutex;
    char m_RegisteredAgentNames[MAX_NO_OF_AGENTS][MAX_AGENT_NAME_LENGTH];
    int m_AgentIdCounter;
    Time m_LastWarpedToTime;   
    Time m_ScaleDate; 
    Time m_PivotDate;   
    int m_TimeScale;        
    double m_InverseTimeScale; 
    int m_ActiveAgentCounter;  
    const bool m_WarpingEnabled;    
    int m_TransitMessageCounter; 
    Action m_ServerAction; 
    int m_ServerActionRequester;  
    Time m_ServerActionTime;          
    Time m_MinimumWarp;
    Time m_WarpPadding;
    bool m_WakeupHandlerThreadDone;
  };

}



#endif // SHARED_TIMING_SERVICE_H

---

Contact information © IDEA