summaryrefslogtreecommitdiff
path: root/lib/top_block.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'lib/top_block.cpp')
-rw-r--r--lib/top_block.cpp37
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)