#include <DatabaseOutputReactor.hpp>
Inherits pion::platform::Reactor.
Definition at line 37 of file DatabaseOutputReactor.hpp.
Public Member Functions | |
| DatabaseOutputReactor (void) | |
| constructs a new DatabaseOutputReactor object | |
| virtual | ~DatabaseOutputReactor () |
| virtual destructor: this class is meant to be extended | |
| 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) |
| called by the ReactorEngine to start Event processing | |
| virtual void | stop (void) |
| called by the ReactorEngine to stop Event processing | |
| void | setLogger (PionLogger log_ptr) |
| sets the logger to be used | |
| PionLogger | getLogger (void) |
| returns the logger currently in use | |
| void pion::plugins::DatabaseOutputReactor::process | ( | const pion::platform::EventPtr & | e | ) | [virtual] |
processes an Event by writing it to a database and delivering it to the output connections
| e | pointer to the Event to process |
Reimplemented from pion::platform::Reactor.
Definition at line 151 of file DatabaseOutputReactor.cpp.
References pion::platform::Reactor::deliverEvent().
| void pion::plugins::DatabaseOutputReactor::query | ( | std::ostream & | out, | |
| const QueryBranches & | branches, | |||
| const QueryParams & | qp | |||
| ) | [virtual] |
handle an HTTP query (from QueryService)
| out | the ostream to write the statistics info into | |
| branches | URI stem path branches for the HTTP request | |
| qp | query parameters or pairs passed in the HTTP request |
Definition at line 89 of file DatabaseOutputReactor.cpp.
References pion::platform::Reactor::writeBeginReactorXML(), pion::platform::Reactor::writeEndReactorXML(), and pion::platform::Reactor::writeStatsOnlyXML().
| void pion::plugins::DatabaseOutputReactor::setConfig | ( | const pion::platform::Vocabulary & | v, | |
| const xmlNodePtr | config_ptr | |||
| ) | [virtual] |
sets configuration parameters for this Reactor
| v | the Vocabulary that this Reactor will use to describe Terms | |
| config_ptr | pointer to a list of XML nodes containing Reactor configuration parameters |
Reimplemented from pion::platform::Reactor.
Definition at line 41 of file DatabaseOutputReactor.cpp.
References pion::platform::Reactor::ConfigWriteLock, pion::platform::PlatformPlugin::getDatabaseManager(), pion::platform::Reactor::m_is_running, start(), and stop().
| void pion::plugins::DatabaseOutputReactor::updateDatabases | ( | void | ) | [virtual] |
this updates the Databases that are used by this Reactor; it should be called whenever any Database's configuration is updated
Reimplemented from pion::platform::Reactor.
Definition at line 82 of file DatabaseOutputReactor.cpp.
References pion::platform::Reactor::ConfigWriteLock.
| void pion::plugins::DatabaseOutputReactor::updateVocabulary | ( | const pion::platform::Vocabulary & | v | ) | [virtual] |
this updates the Vocabulary information used by this Reactor; it should be called whenever the global Vocabulary is updated
| v | the Vocabulary that this Reactor will use to describe Terms |
Reimplemented from pion::platform::Reactor.
Definition at line 73 of file DatabaseOutputReactor.cpp.
References pion::platform::Reactor::ConfigWriteLock.
1.4.7