premiere
/
premiere-libtorrent
2
2
Fork 1
Code Issues Pull Requests Releases Wiki Activity

DHT instrumentation changes

This commit is contained in:
Arvid Norberg 2008-11-12 03:56:56 +00:00
parent 4eb0df96c2
commit 1b10a3b15f
2 changed files with 11 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
include/libtorrent/kademlia/dht_tracker.hpp
View File

@ -171,6 +171,7 @@ namespace libtorrent { namespace dht
int m_failed_announces; int m_failed_announces;
int m_total_message_input; int m_total_message_input;
int m_az_message_input;
int m_ut_message_input; int m_ut_message_input;
int m_lt_message_input; int m_lt_message_input;
int m_mp_message_input; int m_mp_message_input;

16
src/kademlia/dht_tracker.cpp
View File

@ -194,6 +194,7 @@ namespace libtorrent { namespace dht
m_announces = 0; m_announces = 0;
m_failed_announces = 0; m_failed_announces = 0;
m_total_message_input = 0; m_total_message_input = 0;
m_az_message_input = 0;
m_ut_message_input = 0; m_ut_message_input = 0;
m_lt_message_input = 0; m_lt_message_input = 0;
m_mp_message_input = 0; m_mp_message_input = 0;
@ -330,12 +331,8 @@ namespace libtorrent { namespace dht
#ifdef TORRENT_DHT_VERBOSE_LOGGING #ifdef TORRENT_DHT_VERBOSE_LOGGING
static bool first = true; static bool first = true;
if (first)
{
boost::filesystem::create_directory("libtorrent_logs");
}
std::ofstream st("libtorrent_logs/routing_table_state.txt", std::ios_base::trunc); std::ofstream st("dht_routing_table_state.txt", std::ios_base::trunc);
m_dht.print_state(st); m_dht.print_state(st);
// count torrents // count torrents
@ -345,7 +342,7 @@ namespace libtorrent { namespace dht
int peers = 0; int peers = 0;
std::for_each(m_dht.begin_data(), m_dht.end_data(), count_peers(peers)); std::for_each(m_dht.begin_data(), m_dht.end_data(), count_peers(peers));
std::ofstream pc("libtorrent_logs/dht_stats.log", std::ios_base::app); std::ofstream pc("dht_stats.log", std::ios_base::app);
if (first) if (first)
{ {
first = false; first = false;
@ -385,6 +382,7 @@ namespace libtorrent { namespace dht
<< "\t" << m_announces / float(tick_period) << "\t" << m_announces / float(tick_period)
<< "\t" << m_failed_announces / float(tick_period) << "\t" << m_failed_announces / float(tick_period)
<< "\t" << (m_total_message_input / float(tick_period)) << "\t" << (m_total_message_input / float(tick_period))
<< "\t" << (m_az_message_input / float(tick_period))
<< "\t" << (m_ut_message_input / float(tick_period)) << "\t" << (m_ut_message_input / float(tick_period))
<< "\t" << (m_lt_message_input / float(tick_period)) << "\t" << (m_lt_message_input / float(tick_period))
<< "\t" << (m_mp_message_input / float(tick_period)) << "\t" << (m_mp_message_input / float(tick_period))
@ -402,6 +400,7 @@ namespace libtorrent { namespace dht
m_announces = 0; m_announces = 0;
m_failed_announces = 0; m_failed_announces = 0;
m_total_message_input = 0; m_total_message_input = 0;
m_az_message_input = 0;
m_ut_message_input = 0; m_ut_message_input = 0;
m_lt_message_input = 0; m_lt_message_input = 0;
m_total_in_bytes = 0; m_total_in_bytes = 0;
@ -536,6 +535,11 @@ namespace libtorrent { namespace dht
{ {
log_line << " c: " << client; log_line << " c: " << client;
} }
else if (std::equal(client.begin(), client.begin() + 2, "Az"))
{
++m_az_message_input;
log_line << " c: Azureus";
}
else if (std::equal(client.begin(), client.begin() + 2, "UT")) else if (std::equal(client.begin(), client.begin() + 2, "UT"))
{ {
++m_ut_message_input; ++m_ut_message_input;