jiigen666/libtorrent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

another channel state fix

Browse Source
This commit is contained in:
Arvid Norberg
2011-10-28 23:08:52 +00:00
parent dfda3c9a95
commit b85727c633
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/session_impl.cpp
View File

@@ -2667,8 +2667,8 @@ namespace aux {
peer_connection* p = m_next_disk_peer->get(); peer_connection* p = m_next_disk_peer->get();
++m_next_disk_peer; ++m_next_disk_peer;
if (m_next_disk_peer == m_connections.end()) m_next_disk_peer = m_connections.begin(); if (m_next_disk_peer == m_connections.end()) m_next_disk_peer = m_connections.begin();
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) == 0) continue;
p->on_disk(); p->on_disk();
} }
@@ -5600,8 +5600,8 @@ namespace aux {
TORRENT_ASSERT(unique_peers.find(i->get()) == unique_peers.end()); TORRENT_ASSERT(unique_peers.find(i->get()) == unique_peers.end());
unique_peers.insert(i->get()); unique_peers.insert(i->get());
if ((*i)->m_channel_state[0] == peer_info::bw_disk) ++disk_queue[0]; if ((*i)->m_channel_state[0] & peer_info::bw_disk) ++disk_queue[0];
if ((*i)->m_channel_state[1] == peer_info::bw_disk) ++disk_queue[1]; if ((*i)->m_channel_state[1] & peer_info::bw_disk) ++disk_queue[1];
peer_connection* p = i->get(); peer_connection* p = i->get();
TORRENT_ASSERT(!p->is_disconnecting()); TORRENT_ASSERT(!p->is_disconnecting());