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

Added support for dht-port message. It is currently only logged.

This commit is contained in:
Arvid Norberg 2005-09-14 22:45:22 +00:00
parent 7f890239c4
commit 5a1e064783
2 changed files with 31 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
include/libtorrent/peer_connection.hpp
View File

@ -243,6 +243,8 @@ namespace libtorrent
void on_request(int received);
void on_piece(int received);
void on_cancel(int received);
void on_dht_port(int received);
void on_extension_list(int received);
void on_extended(int received);

31
src/peer_connection.cpp
View File

@ -66,7 +66,8 @@ namespace libtorrent
&peer_connection::on_request,
&peer_connection::on_piece,
&peer_connection::on_cancel,
0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
&peer_connection::on_dht_port,
0, 0, 0, 0, 0, 0, 0, 0, 0, 0,
&peer_connection::on_extension_list,
&peer_connection::on_extended
};
@ -1129,6 +1130,30 @@ namespace libtorrent
#endif
}
// -----------------------------
// --------- DHT PORT ----------
// -----------------------------
void peer_connection::on_dht_port(int received)
{
INVARIANT_CHECK;
assert(received > 0);
if (m_packet_size != 3)
throw protocol_error("'dht_port' message size != 3");
m_statistics.received_bytes(0, received);
if (m_recv_pos < m_packet_size) return;
const char* ptr = &m_recv_buffer[1];
int listen_port = detail::read_uint16(ptr);
#ifdef TORRENT_VERBOSE_LOGGING
using namespace boost::posix_time;
(*m_logger) << to_simple_string(second_clock::universal_time())
<< " <== DHT_PORT [ p: " << listen_port << " ]\n";
#endif
}
// -----------------------------
// ------ EXTENSION LIST -------
// -----------------------------
@ -1422,7 +1447,9 @@ namespace libtorrent
|| packet_type >= num_supported_messages
|| m_message_handler[packet_type] == 0)
{
throw protocol_error("unknown message id");
throw protocol_error("unknown message id: "
+ boost::lexical_cast<std::string>(packet_type)
+ " size: " + boost::lexical_cast<std::string>(m_packet_size));
}
assert(m_message_handler[packet_type] != 0);