LogServer.h

// -------------------------------------------------------------------------
#ifndef LogServer_H_
#define LogServer_H_
// -------------------------------------------------------------------------
#include <list>
#include <string>
#include <memory>
#include <cc++/socket.h>
#include "Mutex.h"
#include "UniXML.h"
#include "DebugStream.h"
#include "ThreadCreator.h"
class LogSession;
class LogAgregator;
class NullLogSession;
// -------------------------------------------------------------------------
// -------------------------------------------------------------------------
class LogServer
{
    public:

        LogServer( std::shared_ptr<DebugStream> log );
        LogServer( std::shared_ptr<LogAgregator> log );
        ~LogServer();

        inline void setSessionTimeout( timeout_t msec )
        {
            sessTimeout = msec;
        }
        inline void setCmdTimeout( timeout_t msec )
        {
            cmdTimeout = msec;
        }
        inline void setOutTimeout( timeout_t msec )
        {
            outTimeout = msec;
        }
        inline void setSessionLog( Debug::type t )
        {
            sessLogLevel = t;
        }
        inline void setMaxSessionCount( int num )
        {
            sessMaxCount = num;
        }

        void run( const std::string& addr, ost::tpport_t port, bool thread = true );

        inline bool isRunning()
        {
            return (thr && thr->isRunning());
        }

        void init( const std::string& prefix, xmlNode* cnode = 0 );

        static std::string help_print( const std::string& prefix );

    protected:
        LogServer();

        void work();
        void sessionFinished( std::shared_ptr<LogSession> s );

    private:
        typedef std::list< std::shared_ptr<LogSession> > SessionList;
        SessionList slist;
        UniSetTypes::uniset_rwmutex mutSList;

        timeout_t timeout;
        timeout_t sessTimeout;
        timeout_t cmdTimeout;
        timeout_t outTimeout;
        Debug::type sessLogLevel;
        int sessMaxCount;

        std::atomic_bool cancelled;
        DebugStream mylog;
        std::shared_ptr< ThreadCreator<LogServer> > thr;

        std::shared_ptr<ost::TCPSocket> tcp;
        std::shared_ptr<DebugStream> elog;
        std::shared_ptr<NullLogSession> nullsess;
};
// -------------------------------------------------------------------------
#endif // LogServer_H_
// -------------------------------------------------------------------------