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

stats fix

This commit is contained in:
Arvid Norberg 2009-04-11 02:19:57 +00:00
parent 370acde32a
commit 1c01c9ce98
2 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/bt_peer_connection.cpp
View File

@ -2119,6 +2119,7 @@ namespace libtorrent
m_sync_hash.reset(new (std::nothrow) sha1_hash(h.final())); m_sync_hash.reset(new (std::nothrow) sha1_hash(h.final()));
if (!m_sync_hash) if (!m_sync_hash)
{ {
m_statistics.received_bytes(0, bytes_transferred);
disconnect("no memory"); disconnect("no memory");
return; return;
} }

9
src/web_peer_connection.cpp
View File

@ -324,6 +324,7 @@ namespace libtorrent
if (error) if (error)
{ {
m_statistics.received_bytes(0, bytes_transferred);
#ifdef TORRENT_VERBOSE_LOGGING #ifdef TORRENT_VERBOSE_LOGGING
(*m_logger) << "*** web_peer_connection error: " (*m_logger) << "*** web_peer_connection error: "
<< error.message() << "\n"; << error.message() << "\n";
@ -350,6 +351,7 @@ namespace libtorrent
if (error) if (error)
{ {
m_statistics.received_bytes(0, bytes_transferred);
#ifdef TORRENT_VERBOSE_LOGGING #ifdef TORRENT_VERBOSE_LOGGING
(*m_logger) << "*** " << std::string(recv_buffer.begin, recv_buffer.end) << "\n"; (*m_logger) << "*** " << std::string(recv_buffer.begin, recv_buffer.end) << "\n";
#endif #endif
@ -389,6 +391,7 @@ namespace libtorrent
m_ses.m_alerts.post_alert(url_seed_alert(t->get_handle(), url() m_ses.m_alerts.post_alert(url_seed_alert(t->get_handle(), url()
, error_msg)); , error_msg));
} }
m_statistics.received_bytes(0, bytes_transferred);
disconnect(error_msg.c_str(), 1); disconnect(error_msg.c_str(), 1);
return; return;
} }
@ -422,6 +425,7 @@ namespace libtorrent
if (location.empty()) if (location.empty())
{ {
m_statistics.received_bytes(0, bytes_transferred);
// we should not try this server again. // we should not try this server again.
t->remove_web_seed(m_url, web_seed_entry::url_seed); t->remove_web_seed(m_url, web_seed_entry::url_seed);
disconnect("got HTTP redirection status without location header", 2); disconnect("got HTTP redirection status without location header", 2);
@ -435,6 +439,7 @@ namespace libtorrent
// add the redirected url and remove the current one // add the redirected url and remove the current one
if (!single_file_request) if (!single_file_request)
{ {
m_statistics.received_bytes(0, bytes_transferred);
TORRENT_ASSERT(!m_file_requests.empty()); TORRENT_ASSERT(!m_file_requests.empty());
int file_index = m_file_requests.front(); int file_index = m_file_requests.front();
@ -502,6 +507,7 @@ namespace libtorrent
if (!success) if (!success)
{ {
m_statistics.received_bytes(0, bytes_transferred);
// we should not try this server again. // we should not try this server again.
t->remove_web_seed(m_url, web_seed_entry::url_seed); t->remove_web_seed(m_url, web_seed_entry::url_seed);
char msg[200]; char msg[200];
@ -519,6 +525,7 @@ namespace libtorrent
range_end = m_parser.content_length(); range_end = m_parser.content_length();
if (range_end == -1) if (range_end == -1)
{ {
m_statistics.received_bytes(0, bytes_transferred);
// we should not try this server again. // we should not try this server again.
t->remove_web_seed(m_url, web_seed_entry::url_seed); t->remove_web_seed(m_url, web_seed_entry::url_seed);
disconnect("no content-length in HTTP response", 2); disconnect("no content-length in HTTP response", 2);
@ -541,6 +548,7 @@ namespace libtorrent
if (m_requests.empty() || m_file_requests.empty()) if (m_requests.empty() || m_file_requests.empty())
{ {
m_statistics.received_bytes(0, bytes_transferred);
disconnect("unexpected HTTP response", 2); disconnect("unexpected HTTP response", 2);
return; return;
} }
@ -572,6 +580,7 @@ namespace libtorrent
if (!range_overlaps_request) if (!range_overlaps_request)
{ {
m_statistics.received_bytes(0, bytes_transferred);
// this means the end of the incoming request ends _before_ the // this means the end of the incoming request ends _before_ the
// first expected byte (fs + m_piece.size()) // first expected byte (fs + m_piece.size())
disconnect("invalid range in HTTP response", 2); disconnect("invalid range in HTTP response", 2);