wornvirtue
/
premiere-libtorrent
forked from premiere/premiere-libtorrent
1
0
Fork 0
Code Pull Requests Activity

made the bandwidth test build again

This commit is contained in:
Arvid Norberg 2008-01-31 07:27:29 +00:00
parent 684bade8ea
commit ee0e2ad51a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
test/test_bandwidth_limiter.cpp
View File

@ -113,7 +113,7 @@ struct torrent
++i->priority; ++i->priority;
++i; ++i;
} }
m_bandwidth_queue[channel].insert(i.base(), bw_queue_entry<peer_connection>( m_bandwidth_queue[channel].insert(i.base(), bw_queue_entry<peer_connection, torrent>(
p, block_size, priority)); p, block_size, priority));
} }
} }
@ -130,7 +130,7 @@ struct torrent
m_bandwidth_limit[channel].assign(block_size); m_bandwidth_limit[channel].assign(block_size);
} }
bandwidth_limit m_bandwidth_limit[1]; bandwidth_limit m_bandwidth_limit[1];
typedef std::deque<bw_queue_entry<peer_connection> > queue_t; typedef std::deque<bw_queue_entry<peer_connection, torrent> > queue_t;
queue_t m_bandwidth_queue[1]; queue_t m_bandwidth_queue[1];
bandwidth_manager<peer_connection, torrent>& m_bandwidth_manager; bandwidth_manager<peer_connection, torrent>& m_bandwidth_manager;
}; };
@ -220,7 +220,7 @@ void torrent::expire_bandwidth(int channel, int amount)
queue_t tmp; queue_t tmp;
while (!m_bandwidth_queue[channel].empty()) while (!m_bandwidth_queue[channel].empty())
{ {
bw_queue_entry<peer_connection> qe = m_bandwidth_queue[channel].front(); bw_queue_entry<peer_connection, torrent> qe = m_bandwidth_queue[channel].front();
if (m_bandwidth_limit[channel].max_assignable() == 0) if (m_bandwidth_limit[channel].max_assignable() == 0)
break; break;
m_bandwidth_queue[channel].pop_front(); m_bandwidth_queue[channel].pop_front();