LogEngine.h

Go to the documentation of this file.

#ifndef _LOGENGINE_H
#define _LOGENGINE_H

#include "LogAssociation.h"
#include "LogWriter.h"
#include "LogQueue.h"
#include "LoggerRules.h"
#include "utils/Mutex.h"

// Foward declarations
class LogAssociation;
class Rule;

class LogEngine
{

public:
    LogEngine();

    LogEngine( LogQueue& queue );

    virtual ~LogEngine();

    virtual void resetInputs();

    virtual void initialize( void );

    void processEntry( LogEntry* thisEntry );

    void processQueue( const Timespan& timeout );

    virtual void uninitialize( void );

    virtual LogAssociation* addAssociation( LogWriter* writer, Rule* rule );

    virtual void removeAssociation( LogWriter* writer );

    void configAssociatedLogWriters( Logger& sysLogger );

    void lockProcessing()
    {
        mutex_.lock();
    }

    void unlockProcessing()
    {
        mutex_.unlock();
    }


protected:

    LogQueue &queue_;

    Mutex mutex_;

    void cleanupAll( void );

    LoggerAssociationDeque associations_;

};

#endif // LOGENGINE_H