---

/home/pauldt/projects/IDEA/IDEA-ALL/IDEA-DEV/Modules/IPC/MetaTimingService/Includes/IPCCommunicationRelay.hh

Go to the documentation of this file.

// -*- Mode: c++ -*-
//      CVS: $Id: IPCCommunicationRelay.hh,v 1.5 2005/12/30 22:37:18 rijsman Exp $
//      Tag: $name$
//     Info: $CVSROOT/IDEA-DEV/COPYRIGHT

#ifndef IPC_COMMUNICATION_RELAY_HEADER
#define IPC_COMMUNICATION_RELAY_HEADER

#include "Singleton.hh"
#include "MetaCommunicationRelay.hh"
#include "ThreadTools.hh"

namespace IDEA
{
  typedef struct
  {
    int warpAtSeconds;
    int warpAtNanoSeconds;
    int warpToSeconds;
    int warpToNanoSeconds;
    const char* timeScale;
  } WarpStructure;


#define warpMsg_IPC "WarpMsg" 
#define warpFmt_IPC "{int,int,int,int,string}"

#define syncMsg_IPC "SyncMsg" 
#define syncFmt_IPC "{int,int,int,int,string}"

  typedef struct
  {
    const char* name;
  } RegisterStructure;

#define registerMsg_IPC "RegisterMsg" 
#define registerFmt_IPC "{string}"

  class IPCCommunicationRelayListener:
    public Singleton< IPCCommunicationRelayListener >,
    public ACE_Task_Base
  {
    friend class Singleton< IPCCommunicationRelayListener >;
  public:
    ~IPCCommunicationRelayListener();
    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); 

    void shutDown();

    bool isActive() const { return m_Active; }

    int getListenMilliSeconds() const { return m_ListenMilliSeconds; }
  private:
    IPCCommunicationRelayListener( int listenMilliSeconds = 100 );
    int svc( void );

    int m_ListenMilliSeconds;
    bool m_Active;
  };

  class SharedTimingService;
  class IPCCommunicationRelay:
    public MetaCommunicationRelay
  {
  public:
    IPCCommunicationRelay( const std::string& name = "IPCCommunicationRelay" );
    ~IPCCommunicationRelay();
    void synchronize( const Time& pivot, int timescale ) const;
    void warp( const Time& at, const Time& warpTo, double timescale ) const;
  private:
    void activateExtended();
    void connect() const;
    void defineMessages() const;
    void subscribeMessages();

    bool m_Active;
  };

}

#endif // IPC_COMMUNICATION_RELAY_HEADER
  

---

Contact information © IDEA