forked from premiere/premiere-libtorrent
fixed issue in session_impl::on_disk
This commit is contained in:
parent
91327f71da
commit
d4a9a9ae77
|
@ -2482,7 +2482,7 @@ namespace aux {
|
||||||
// way of limiting it
|
// way of limiting it
|
||||||
int limit = m_connections.size();
|
int limit = m_connections.size();
|
||||||
|
|
||||||
do
|
while (m_next_disk_peer != m_connections.end() && limit > 0 && can_write_to_disk())
|
||||||
{
|
{
|
||||||
--limit;
|
--limit;
|
||||||
peer_connection* p = m_next_disk_peer->get();
|
peer_connection* p = m_next_disk_peer->get();
|
||||||
|
@ -2491,8 +2491,8 @@ namespace aux {
|
||||||
if (p->m_channel_state[peer_connection::download_channel]
|
if (p->m_channel_state[peer_connection::download_channel]
|
||||||
!= peer_info::bw_disk) continue;
|
!= peer_info::bw_disk) continue;
|
||||||
p->on_disk();
|
p->on_disk();
|
||||||
|
}
|
||||||
|
|
||||||
} while (m_next_disk_peer != m_connections.end() && limit > 0 && can_write_to_disk());
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// used to cache the current time
|
// used to cache the current time
|
||||||
|
|
Loading…
Reference in New Issue