platform/services/XMLLogService.hpp

// ------------------------------------------------------------------
// pion-net: a C++ framework for building lightweight HTTP interfaces
// ------------------------------------------------------------------
// Copyright (C) 2010 Atomic Labs, Inc.  (http://www.atomiclabs.com)
//
// Distributed under the Boost Software License, Version 1.0.
// See http://www.boost.org/LICENSE_1_0.txt
//

#ifndef __PION_XMLLOGSERVICE_HEADER__
#define __PION_XMLLOGSERVICE_HEADER__

#include <boost/thread/mutex.hpp>
#include <boost/scoped_ptr.hpp>
#include <boost/tuple/tuple.hpp>
#include <pion/PionLogger.hpp>
#include <pion/net/WebService.hpp>
#include <pion/net/HTTPResponseWriter.hpp>
#include "PlatformConfig.hpp"
#include "PlatformService.hpp"
#include <string>
#include <list>
#include <deque>
#include <queue>


namespace pion {        // begin namespace pion
namespace plugins {     // begin namespace plugins

    
class XMLLogServiceAppender
    : public PionLogAppender
{
public:
    // default constructor and destructor
    XMLLogServiceAppender(void);
    virtual ~XMLLogServiceAppender() {}
    
    inline void setMaxEvents(unsigned int n) { m_max_events = n; }
    
    void writeLogEvents(pion::net::HTTPResponseWriterPtr& writer);

    void acknowledgeEvent(std::string id);

    void acknowledgeAllEvents(void);


private:
    static const unsigned int               DEFAULT_MAX_EVENTS;
    
    unsigned int                            m_max_events;
    
    unsigned int                            m_num_events;

    std::list<std::string>                  m_log_events;

    typedef std::map<std::string, std::string>  LOG_QUEUE;
    LOG_QUEUE                               m_log_event_queue;

    boost::mutex                            m_log_mutex;

public:
    // member functions inherited from the Appender interface class
    virtual void close() {}
protected:
    virtual void append(const log4cplus::spi::InternalLoggingEvent& event);

private:
    log4cplus::LogLevelManager      m_log_level_manager;
};


class XMLLogService :
    public pion::server::PlatformService
{
public:
    // default constructor and destructor
    XMLLogService(void);
    virtual ~XMLLogService();
    
    virtual void operator()(pion::net::HTTPRequestPtr& request,
                            pion::net::TCPConnectionPtr& tcp_conn);

    inline XMLLogServiceAppender& getLogAppender(void) {
        return dynamic_cast<XMLLogServiceAppender&>(*m_log_appender_ptr);
    }

    std::string getPermissionType(void) const { return XML_LOG_SERVICE_PERMISSION_TYPE; }

private:
    PionLogAppenderPtr  m_log_appender_ptr;

    static const std::string            XML_LOG_SERVICE_PERMISSION_TYPE;
};

    
}   // end namespace plugins
}   // end namespace pion

#endif

---