---

/home/pauldt/projects/IDEA/IDEA-ALL/IDEA-DEV/Core/Agent/Includes/AgentRelay.hh

Go to the documentation of this file.

// -*- Mode: c++ -*-
//      CVS: $Id: AgentRelay.hh,v 1.4 2005/12/30 22:05:31 rijsman Exp $
//      Tag: $name$
//     Info: $CVSROOT/IDEA-DEV/COPYRIGHT

#ifndef _H_AGENT_RELAY
#define _H_AGENT_RELAY

#include "MessageHandle.hh"
#include "ThreadTools.hh"
#include "TimeBasics.hh"
#include "Utilities.hh"

namespace IDEA 
{
  class AgentTimingService;
  class ComRelay;
  class MessageFactory;
  class MessageObserver;
  class PslDatabase;
  class PslToken;
  class Reactor;

  class AgentRelay 
  {     
    friend class AgentImpl;
    friend class ComRelay;
  public:
    AgentRelay( const AgentTimingService* ats,
                const PslDatabase* db );
    AgentRelay( const AgentTimingService* ats );
    ~AgentRelay();
    void stop();
    const PslDatabase* getDatabase() const;
    void initialize();
    void registerComRelay( ComRelay* relay, const std::string& name, bool deleteInstance );
    void registerReactor( Reactor* reactor, const std::string& object, const std::string& timeline, const std::string& token, bool deleteInstance );
    void registerShutdown( const std::string& objectClass, const std::string& attribute, const std::string& predicate );
    Reactor* setDefaultReactor( Reactor* reactor, bool deleteInstance  );
    Reactor* getDefaultReactor() const;
    void sendStart( const PslToken* token ) const;
    void sendStop( const PslToken* token ) const;
    void sendValue( const PslToken* token, int index ) const;
    void sendStatus( const PslToken* token ) const;
    void receiveStart( MessageHandle msg ) const;
    void receiveStop( MessageHandle msg ) const;
    void receiveTelemetry( MessageHandle msg ) const ;
    void receiveObject( MessageHandle msg ) const ;
    void receiveValue( MessageHandle msg ) const;
    void receiveStatus( MessageHandle msg ) const;
    void receiveUserDefined( MessageHandle msg ) const;
    void sendMessage( MessageHandle message, const ComRelay* comRelay, bool isSubMessage = false ) const;
    MessageFactory* setMessageFactory( MessageFactory* factory, bool deleteInstance  );
    const ComRelay* getComRelay( const std::string& key ) const;
    const AgentTimingService* getAgentTimingService() const;
  private:
    void receiveMessage( MessageHandle msg, Reactor* reactor ) const;
    AgentRelay( const AgentRelay & );
    AgentRelay & operator=( const AgentRelay & );
    static std::string createKey( const std::string& str1, const std::string& str2, const std::string& str3 );
    const ComRelay* getComRelay( const PslToken* token ) const;
    Reactor* getReactor( MessageHandle msg ) const;
    void shutDown();

    typedef std::set< MessageObserver* > MessageObserverSet;

    typedef std::map< std::string, MessageObserver* > String2MessageObserverMap; 
    typedef std::set< std::string > StringSet;
    typedef std::map< std::string, StringSet > String2StringSetMap;

    void registerMessageObserver( MessageObserver* observer, const std::string& key, String2MessageObserverMap& container, bool deleteInstance );

    MessageObserver* getMessageObserver( const std::string& key, const String2MessageObserverMap& container ) const;

    MessageObserverSet m_DeleteObservers; 
    String2MessageObserverMap m_RegisteredComRelay; 
    String2MessageObserverMap m_RegisteredReactors; 
    MessageFactory* m_MessageFactory; 
    bool m_DeleteMessageFactory; 
    bool m_DeleteDefaultReactor;
    Reactor* m_DefaultReactor;

    Reactor* m_ShutdownReactor;
    
    const AgentTimingService* m_AgentTimingService;
    const PslDatabase* m_Database;
    std::string m_Name;
    ComRelay* m_Boomerang;
  };
} //namespace IDEA

#endif //_H_AGENT_RELAY

---

Contact information © IDEA