topic.hpp

Go to the documentation of this file.

#ifndef __LOGOG_TOPIC_HPP__
#define __LOGOG_TOPIC_HPP__

namespace logog
{

class Topic : public Node
{
    friend class TopicLevel;
    friend class TopicGroup;
        friend class FilterDefault;

public:
    Topic( const LOGOG_LEVEL_TYPE level = LOGOG_LEVEL_ALL,
           const LOGOG_CHAR *sFileName = NULL,
           const int nLineNumber = 0,
           const LOGOG_CHAR *sGroup = NULL,
           const LOGOG_CHAR *sCategory = NULL,
           const LOGOG_CHAR *sMessage = NULL,
           const double dTimestamp = 0.0f );

    virtual bool IsTopic() const;

    virtual int Send( const Topic &node );

    virtual int Transmit();

    virtual int Receive( const Topic &node );

    virtual bool CanSubscribeTo( const Node &otherNode );

    virtual bool CanSubscribeCheckTopic( const Topic &other );

    virtual bool PublishTo( Node &subscriber );



    virtual void Format( const LOGOG_CHAR *cFormatMessage, ... );

    const LOGOG_STRING &FileName() const;
    void FileName( const LOGOG_STRING &s );

    const LOGOG_STRING &Message() const;
    void Message( const LOGOG_STRING &s );

    const LOGOG_STRING &Category() const;
    void Category( const LOGOG_STRING &s );

    const LOGOG_STRING &Group() const;
    void Group( const LOGOG_STRING &s );

    int LineNumber() const;
    void LineNumber( const int num );

    LOGOG_LEVEL_TYPE Level() const;
    void Level( LOGOG_LEVEL_TYPE level );

    LOGOG_TIME Timestamp() const;
    void Timestamp( const LOGOG_TIME t );

    TOPIC_FLAGS GetTopicFlags() const;

protected:
    LOGOG_STRING m_vStringProps[ TOPIC_STRING_COUNT ];
    int m_vIntProps[ TOPIC_INT_COUNT ];
    LOGOG_TIME m_tTime;
    TOPIC_FLAGS m_TopicFlags;
};

class Filter : public Topic
{
public:
    Filter( const LOGOG_LEVEL_TYPE level = LOGOG_LEVEL_ALL,
            const LOGOG_CHAR *sFileName = NULL,
            const int nLineNumber = 0,
            const LOGOG_CHAR *sGroup = NULL,
            const LOGOG_CHAR *sCategory = NULL,
            const LOGOG_CHAR *sMessage = NULL,
            const double dTimestamp = 0.0f );
};

class FilterDefault : public Filter
{
        typedef Filter super;
public:
        FilterDefault(const LOGOG_LEVEL_TYPE level);
        int Receive(const Topic &node);
        void Level(LOGOG_LEVEL_TYPE level);
};

extern FilterDefault &GetFilterDefault();

void SetDefaultLevel( LOGOG_LEVEL_TYPE level );

class TopicGroup : public Topic
{
public:
    TopicGroup( const LOGOG_CHAR *sGroup = NULL );

    virtual bool CanSubscribeCheckTopic( const Topic &other );
};

class TopicLevel : public Topic
{
public:
    TopicLevel( const LOGOG_LEVEL_TYPE level );
    virtual bool CanSubscribeCheckTopic( const Topic &other );
};

class TopicSource : public Topic
{
public:
    TopicSource( const LOGOG_LEVEL_TYPE level = LOGOG_LEVEL_ALL,
                 const LOGOG_CHAR *sFileName = NULL,
                 const int nLineNumber = 0,
                 const LOGOG_CHAR *sGroup = NULL,
                 const LOGOG_CHAR *sCategory = NULL,
                 const LOGOG_CHAR *sMessage = NULL,
                 const double dTimestamp = 0.0f );

    virtual bool SubscribeTo( Node & );

    virtual bool UnsubscribeTo( Node & );
    virtual bool CanSubscribe() const;
};

class TopicSink : public Topic
{
public:
    virtual bool IsTopic() const;

    virtual void Initialize();

    virtual bool PublishTo( Node & );

    virtual bool UnpublishTo( Node & );

    virtual bool CanPublish() const;
};
}

#endif // __LOGOG_TOPIC_HPP_