From b85727c6339b86534aa78ee758a293137d85f300 Mon Sep 17 00:00:00 2001 From: Arvid Norberg Date: Fri, 28 Oct 2011 23:08:52 +0000 Subject: [PATCH] another channel state fix --- src/session_impl.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/session_impl.cpp b/src/session_impl.cpp index 37d3df62d..8b0f5b72e 100644 --- a/src/session_impl.cpp +++ b/src/session_impl.cpp @@ -2667,8 +2667,8 @@ namespace aux { peer_connection* p = m_next_disk_peer->get(); ++m_next_disk_peer; if (m_next_disk_peer == m_connections.end()) m_next_disk_peer = m_connections.begin(); - if (p->m_channel_state[peer_connection::download_channel] - != peer_info::bw_disk) continue; + if ((p->m_channel_state[peer_connection::download_channel] + & peer_info::bw_disk) == 0) continue; p->on_disk(); } @@ -5600,8 +5600,8 @@ namespace aux { TORRENT_ASSERT(unique_peers.find(i->get()) == unique_peers.end()); unique_peers.insert(i->get()); - 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[0] & peer_info::bw_disk) ++disk_queue[0]; + if ((*i)->m_channel_state[1] & peer_info::bw_disk) ++disk_queue[1]; peer_connection* p = i->get(); TORRENT_ASSERT(!p->is_disconnecting());