diff --git a/src/web_peer_connection.cpp b/src/web_peer_connection.cpp index 8945640fb..afb2c59ad 100644 --- a/src/web_peer_connection.cpp +++ b/src/web_peer_connection.cpp @@ -299,7 +299,7 @@ namespace libtorrent if (associated_torrent().expired()) return false; TORRENT_ASSERT(m_block_pos >= front_request.length); m_block_pos -= front_request.length; - cut_receive_buffer(m_body_start, t->block_size() + 1024); + cut_receive_buffer(m_body_start, t->block_size() + 5000); m_body_start = 0; recv_buffer = receive_buffer(); // TORRENT_ASSERT(m_received_body <= range_end - range_start); @@ -615,7 +615,7 @@ namespace libtorrent TORRENT_ASSERT(chunk_size != 0 || chunk_start.left() <= header_size || chunk_start.begin[header_size] == 'H'); // cut out the chunk header from the receive buffer TORRENT_ASSERT(m_body_start + m_chunk_pos < INT_MAX); - cut_receive_buffer(header_size, t->block_size() + 1024, int(m_body_start + m_chunk_pos)); + cut_receive_buffer(header_size, t->block_size() + 5000, int(m_body_start + m_chunk_pos)); recv_buffer = receive_buffer(); recv_buffer.begin += m_body_start; m_chunk_pos += chunk_size; @@ -750,7 +750,7 @@ namespace libtorrent m_received_body += r.length; TORRENT_ASSERT(receive_buffer().begin + m_body_start == recv_buffer.begin); TORRENT_ASSERT(m_received_body <= range_end - range_start); - cut_receive_buffer(m_body_start + r.length, t->block_size() + 1024); + cut_receive_buffer(m_body_start + r.length, t->block_size() + 5000); if (m_chunk_pos > 0) { TORRENT_ASSERT(m_chunk_pos >= r.length); @@ -797,7 +797,7 @@ namespace libtorrent TORRENT_ASSERT(receive_buffer().left() < size_to_cut + 1 || receive_buffer()[size_to_cut] == 'H'); - cut_receive_buffer(size_to_cut, t->block_size() + 1024); + cut_receive_buffer(size_to_cut, t->block_size() + 5000); if (m_chunk_pos > 0) { TORRENT_ASSERT(m_chunk_pos >= size_to_cut); diff --git a/test/setup_transfer.cpp b/test/setup_transfer.cpp index 612252599..cb0230d4a 100644 --- a/test/setup_transfer.cpp +++ b/test/setup_transfer.cpp @@ -105,17 +105,20 @@ bool print_alerts(libtorrent::session& ses, char const* name TEST_CHECK(alert_cast(*i) == 0 || allow_failed_fastresume); peer_error_alert* pea = alert_cast(*i); - TEST_CHECK(pea == 0 - || (!handles.empty() && h.status().is_seeding) - || pea->error.message() == "connecting to peer" - || pea->error.message() == "closing connection to ourself" - || pea->error.message() == "duplicate connection" - || pea->error.message() == "duplicate peer-id" - || pea->error.message() == "upload to upload connection" - || pea->error.message() == "stopping torrent" - || (allow_disconnects && pea->error.message() == "Broken pipe") - || (allow_disconnects && pea->error.message() == "Connection reset by peer") - || (allow_disconnects && pea->error.message() == "End of file.")); + if (pea) + { + fprintf(stderr, "peer error: %s\n", pea->error.message().c_str()); + TEST_CHECK((!handles.empty() && h.status().is_seeding) + || pea->error.message() == "connecting to peer" + || pea->error.message() == "closing connection to ourself" + || pea->error.message() == "duplicate connection" + || pea->error.message() == "duplicate peer-id" + || pea->error.message() == "upload to upload connection" + || pea->error.message() == "stopping torrent" + || (allow_disconnects && pea->error.message() == "Broken pipe") + || (allow_disconnects && pea->error.message() == "Connection reset by peer") + || (allow_disconnects && pea->error.message() == "End of file.")); + } delete *i; } return ret;