fix tests
This commit is contained in:
@@ -117,7 +117,7 @@ struct dht_server
|
||||
, boost::bind(&incoming_packet, _1, _2, &bytes_transferred, &ec, &done));
|
||||
while (!done)
|
||||
{
|
||||
m_ios.poll_one();
|
||||
m_ios.run_one();
|
||||
m_ios.reset();
|
||||
}
|
||||
|
||||
|
@@ -119,7 +119,7 @@ struct peer_server
|
||||
m_acceptor.async_accept(socket, from, boost::bind(&new_connection, _1, &ec, &done));
|
||||
while (!done)
|
||||
{
|
||||
m_ios.poll_one();
|
||||
m_ios.run_one();
|
||||
m_ios.reset();
|
||||
}
|
||||
|
||||
|
@@ -135,6 +135,7 @@ void test_proxy(proxy_settings::proxy_type proxy_type, int flags)
|
||||
addp.dht_nodes.push_back(std::pair<std::string, int>("127.0.0.1", dht_port));
|
||||
torrent_handle h = s->add_torrent(addp);
|
||||
|
||||
printf("connect_peer: 127.0.0.1:%d\n", peer_port);
|
||||
h.connect_peer(tcp::endpoint(address_v4::from_string("127.0.0.1"), peer_port));
|
||||
|
||||
rejected_trackers.clear();
|
||||
|
Reference in New Issue
Block a user