---

/home/pauldt/projects/IDEA/IDEA-ALL/IDEA-DEV/Modules/IPC/ComRelay/Includes/IPCRelay.hh

Go to the documentation of this file.

// -*- Mode: c++ -*-
//     File: $Source: /home/cvs/ISG-Repository/IDEA-DEV/Modules/IPC/ComRelay/Includes/IPCRelay.hh,v $
//      Tag: $Name: DR_01_11_06 $
//      CVS: $Id: IPCRelay.hh,v 1.6 2005/12/30 22:37:18 rijsman Exp $
//     Info: $CVSROOT/Idea3/Copyright.txt
#ifndef HEADER_INTER_PROCESS_PROTOCOL_COMMUNICATION_RELAY_HEADER
#define HEADER_INTER_PROCESS_PROTOCOL_COMMUNICATION_RELAY_HEADER

#include "ComRelay.hh"

namespace IDEA
{
  typedef struct
  {
    int identifier;
    int nrSubMessages;
    int* subMessages;
    int parent;
    const char* source;
    const char* sourceClass;
    const char* sourceTimeline;
    const char* sourceToken;
    const char* parameters;
    const char* target;
    const char* targetClass;
    const char* targetTimeline;
    int externalTokenId;
    int earliestStart;
    int latestStart;
    int earliestEnd;
    int latestEnd;
  } IPCStartStructure;

#define startMsg_IPC "StartMsg" 
#define startFmt_IPC "{int,int,<int: 1>,int,string,string,string,string,string,string,string,string,int,int,int,int,int}"

  typedef struct
  {
    int identifier;
    int nrSubMessages;
    int* subMessages;
    int parent;
    const char* source;
    const char* sourceClass;
    const char* sourceTimeline;
    const char* sourceToken;
    const char* target;
    const char* targetClass;
    const char* targetTimeline;
    int externalTokenId;
    const char* value;
  } IPCStopStructure;

#define stopMsg_IPC "StopMsg" 
#define stopFmt_IPC "{int,int,<int: 1>,int,string,string,string,string,string,string,string,int,string}" 
  typedef struct
  {
    int identifier;
    int nrSubMessages;
    int* subMessages;
    int parent;
    const char* source;
    const char* sourceClass;
    const char* sourceTimeline;
    const char* sourceToken;
    const char* target;
    const char* targetClass;
    const char* targetTimeline;
    int externalTokenId;
    const char* value;
    int index;
  } IPCValueStructure;

#define valueMsg_IPC "ValueMsg" 
#define valueFmt_IPC "{int,int,<int: 1>,int,string,string,string,string,string,string,string,int,string,int}" 
  typedef struct
  {
    int identifier;
    int nrSubMessages;
    int* subMessages;
    int parent;
    const char* source;
    const char* sourceClass;
    const char* sourceTimeline;
    const char* sourceToken;
    const char* target;
    const char* targetClass;
    const char* targetTimeline;
    int externalTokenId;
    const char* value;
  } IPCStatusStructure;

#define statusMsg_IPC "StatusMsg" 
#define statusFmt_IPC "{int,int,<int: 1>,int,string,string,string,string,string,string,string,int,string}" 
  typedef struct
  {
    int identifier;
    int nrSubMessages;
    int* subMessages;
    int parent;
    const char* source;
    const char* sourceClass;
    const char* sourceTimeline;
    const char* sourceToken;
    const char* target;
    const char* targetClass;
    const char* targetTimeline;
    const char* objectName;
    const char* objectClass;
    const char* objectToken;
    const char* parameters;
  } IPCObjectStructure;

#define objectMsg_IPC "ObjectMsg" 
#define objectFmt_IPC "{int,int,<int: 1>,int,string,string,string,string,string,string,string,string,string,string,string}" 
  typedef struct
  {
    int identifier;
    int nrSubMessages;
    int* subMessages;
    int parent;
    const char* source;
    const char* sourceClass;
    const char* sourceTimeline;
    const char* sourceToken;
    const char* target;
    const char* targetClass;
    const char* targetTimeline;
    const char* value;
    int index;
  } IPCTelemetryStructure;

#define telemetryMsg_IPC "TelemetryMsg" 
#define telemetryFmt_IPC "{int,int,<int: 1>,int,string,string,string,string,string,string,string,string,int}" 
#define LISTEN_TIMEOUT_MSEC 100

  class IPCRelayListener:
    public Singleton<IPCRelayListener>,
    public ACE_Task_Base
  {
    friend class Singleton<IPCRelayListener>;
  public:
    ~IPCRelayListener();
    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; }
  protected:
    IPCRelayListener( int listenMilliSeconds = LISTEN_TIMEOUT_MSEC );
  private:
    int svc( void );

    int m_ListenMilliSeconds;
    bool m_Active;
  };

  class IPCRelay:
    public ComRelay
  {
  public:
    IPCRelay( const AgentRelay* agentRelay,
              const std::string& name = "IPCRelay");

    virtual ~IPCRelay();
    virtual void receivedStartMessage( const MessageHandle& msg);
    virtual void receivedStopMessage( const MessageHandle& msg );
    virtual void receivedValueMessage( const MessageHandle& msg );
    virtual void receivedStatusMessage( const MessageHandle& msg );
    virtual void receivedObjectMessage( const MessageHandle& msg );
    virtual void receivedTelemetryMessage( const MessageHandle& msg );
  protected:
    virtual int connect();
    virtual bool defineUserDefinedMessages() { return true; }
    virtual bool subscribeUserDefinedMessages() { return true; }

    virtual void updateStartMessage( const Time& time, const StartMessageData* data );
    virtual void updateStopMessage( const Time& time, const StopMessageData* data );
    virtual void updateValueMessage( const Time& time, const ValueMessageData* data );
    virtual void updateStatusMessage( const Time& time, const StatusMessageData* data );
    virtual void updateObjectMessage( const Time& time, const ObjectMessageData* data );
    virtual void updateTelemetryMessage( const Time& time, const TelemetryMessageData* data  );
  private:
    int initialize();
  
  
    bool defineMessages();
    bool subscribeMessages();
  };


}

#endif //HEADER_INTER_PROCESS_PROTOCOL_COMMUNICATION_RELAY_HEADER

---

Contact information © IDEA