diff options
Diffstat (limited to 'lib/top_block.cpp')
-rw-r--r-- | lib/top_block.cpp | 37 |
1 files changed, 0 insertions, 37 deletions
diff --git a/lib/top_block.cpp b/lib/top_block.cpp index 714ff4a..4d2f956 100644 --- a/lib/top_block.cpp +++ b/lib/top_block.cpp @@ -3,8 +3,6 @@ #include "element_impl.hpp" #include <gras/top_block.hpp> #include <boost/thread/thread.hpp> //sleep -#include <boost/foreach.hpp> -#include <boost/format.hpp> using namespace gras; @@ -139,41 +137,6 @@ bool TopBlock::wait(const double timeout) return (*this)->token.unique(); } -///////////////////////// Stats gathering interface //////////////////////// - -struct GetStatsReceiver : Theron::Receiver -{ - GetStatsReceiver(void) - { - this->RegisterHandler(this, &GetStatsReceiver::handle_get_stats); - } - - void handle_get_stats(const GetStatsMessage &message, const Theron::Address) - { - this->messages.push_back(message); - } - - std::vector<GetStatsMessage> messages; -}; - -std::string TopBlock::get_stats_xml(void) -{ - GetStatsReceiver receiver; - (*this)->executor->post_all(GetStatsMessage(), receiver); - std::string xml; - xml += str(boost::format(" <now>%ull</now>\n") % time_now()); - xml += str(boost::format(" <tps>%ull</tps>\n") % time_tps()); - BOOST_FOREACH(const GetStatsMessage &message, receiver.messages) - { - std::string block_xml; - block_xml += str(boost::format(" <id>%s</id>\n") % message.block_id); - block_xml += str(boost::format(" <start_time>%llu</start_time>\n") % message.stats.start_time); - block_xml += str(boost::format(" <stop_time>%llu</stop_time>\n") % message.stats.stop_time); - xml += str(boost::format(" <block>\n%s</block>\n") % block_xml); - } - return str(boost::format("<gras_stats>\n%s</gras_stats>") % xml); -} - ///////////////////////// Deprecated interfaces //////////////////////// void TopBlock::start(const size_t max_items) |