platform/reactors/DatabaseOutputReactor.hpp

// ------------------------------------------------------------------------
// Pion is a development platform for building Reactors that process Events
// ------------------------------------------------------------------------
// Copyright (C) 2007-2009 Atomic Labs, Inc.  (http://www.atomiclabs.com)
//
// Pion is free software: you can redistribute it and/or modify it under the
// terms of the GNU Affero General Public License as published by the Free
// Software Foundation, either version 3 of the License, or (at your option)
// any later version.
//
// Pion is distributed in the hope that it will be useful, but WITHOUT ANY
// WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
// FOR A PARTICULAR PURPOSE.  See the GNU Affero General Public License for
// more details.
//
// You should have received a copy of the GNU Affero General Public License
// along with Pion.  If not, see <http://www.gnu.org/licenses/>.
//

#ifndef __PION_DATABASEOUTPUTREACTOR_HEADER__
#define __PION_DATABASEOUTPUTREACTOR_HEADER__

#include <pion/PionConfig.hpp>
#include <pion/PionLogger.hpp>
#include <pion/platform/Event.hpp>
#include <pion/platform/Reactor.hpp>
#include <pion/platform/DatabaseInserter.hpp>


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


class DatabaseOutputReactor :
    public pion::platform::Reactor
{
public:

    DatabaseOutputReactor(void)
        : pion::platform::Reactor(TYPE_STORAGE),
        m_logger(PION_GET_LOGGER("pion.DatabaseOutputReactor"))
    {}

    virtual ~DatabaseOutputReactor() { stop(); }

    virtual void setConfig(const pion::platform::Vocabulary& v, const xmlNodePtr config_ptr);

    virtual void updateVocabulary(const pion::platform::Vocabulary& v);

    virtual void updateDatabases(void);

    virtual void process(const pion::platform::EventPtr& e);

    virtual void query(std::ostream& out, const QueryBranches& branches,
        const QueryParams& qp);

    virtual void start(void);

    virtual void stop(void);

    inline void setLogger(PionLogger log_ptr) { 
        m_logger = log_ptr;
        m_inserter->setLogger(log_ptr);
    }

    inline PionLogger getLogger(void) { return m_logger; }


private:

    static const std::string                DATABASE_ELEMENT_NAME;

    static const std::string                TABLE_ELEMENT_NAME;

    static const std::string                FIELD_ELEMENT_NAME;

    static const std::string                EVENTS_QUEUED_ELEMENT_NAME;

    static const std::string                KEY_CACHE_SIZE_ELEMENT_NAME;

    PionLogger                              m_logger;

    typedef boost::scoped_ptr<pion::platform::DatabaseInserter>     DatabaseInserterPtr;

    DatabaseInserterPtr                     m_inserter;
};


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

#endif

---