wornvirtue
/
premiere-libtorrent
forked from premiere/premiere-libtorrent
1
0
Fork 0
Code Pull Requests Activity

transfer stats assert fix

This commit is contained in:
Arvid Norberg 2008-10-09 03:33:53 +00:00
parent 68a89507bc
commit 13554cbd3b
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/bt_peer_connection.cpp
View File

@ -2632,12 +2632,28 @@ namespace libtorrent
if (m_state == read_packet) if (m_state == read_packet)
{ {
TORRENT_ASSERT(recv_buffer == receive_buffer()); TORRENT_ASSERT(recv_buffer == receive_buffer());
if (!t) return; if (!t)
{
m_statistics.received_bytes(0, bytes_transferred);
disconnect("torrent removed", 1);
return;
}
#ifndef NDEBUG
size_type cur_payload_dl = m_statistics.last_payload_downloaded();
size_type cur_protocol_dl = m_statistics.last_protocol_downloaded();
#endif
if (dispatch_message(bytes_transferred)) if (dispatch_message(bytes_transferred))
{ {
m_state = read_packet_size; m_state = read_packet_size;
reset_recv_buffer(5); reset_recv_buffer(5);
} }
#ifndef NDEBUG
TORRENT_ASSERT(m_statistics.last_payload_downloaded() - cur_payload_dl >= 0);
TORRENT_ASSERT(m_statistics.last_protocol_downloaded() - cur_protocol_dl >= 0);
size_type stats_diff = m_statistics.last_payload_downloaded() - cur_payload_dl +
m_statistics.last_protocol_downloaded() - cur_protocol_dl;
TORRENT_ASSERT(stats_diff == bytes_transferred);
#endif
TORRENT_ASSERT(!packet_finished()); TORRENT_ASSERT(!packet_finished());
return; return;
} }