sync libtorrent 1991

This commit is contained in:
Marcos Pinto 2008-02-10 04:36:19 +00:00
commit 40ac3d1ad1
10 changed files with 62 additions and 13 deletions

View file

@ -139,9 +139,12 @@ public:
void timeout() {} void timeout() {}
void reply(msg const& r) void reply(msg const& r)
{ {
m_rpc.invoke(messages::announce_peer, r.addr observer_ptr o(new (m_rpc.allocator().malloc()) announce_observer(
, observer_ptr(new (m_rpc.allocator().malloc()) announce_observer( m_rpc.allocator(), m_info_hash, m_listen_port, r.write_token));
m_rpc.allocator(), m_info_hash, m_listen_port, r.write_token))); #ifndef NDEBUG
o->m_in_constructor = false;
#endif
m_rpc.invoke(messages::announce_peer, r.addr, o);
m_fun(r.peers, m_info_hash); m_fun(r.peers, m_info_hash);
} }
void abort() {} void abort() {}

View file

@ -56,9 +56,16 @@ struct observer : boost::noncopyable
: sent(time_now()) : sent(time_now())
, pool_allocator(p) , pool_allocator(p)
, m_refs(0) , m_refs(0)
{} {
#ifndef NDEBUG
m_in_constructor = true;
#endif
}
virtual ~observer() {} virtual ~observer()
{
TORRENT_ASSERT(!m_in_constructor);
}
// these two callbacks lets the observer add // these two callbacks lets the observer add
// information to the message before it's sent // information to the message before it's sent
@ -79,6 +86,9 @@ struct observer : boost::noncopyable
udp::endpoint target_addr; udp::endpoint target_addr;
ptime sent; ptime sent;
#ifndef NDEBUG
bool m_in_constructor;
#endif
private: private:
boost::pool<>& pool_allocator; boost::pool<>& pool_allocator;
// reference counter for intrusive_ptr // reference counter for intrusive_ptr

View file

@ -101,6 +101,9 @@ closest_nodes::closest_nodes(
void closest_nodes::invoke(node_id const& id, udp::endpoint addr) void closest_nodes::invoke(node_id const& id, udp::endpoint addr)
{ {
observer_ptr o(new (m_rpc.allocator().malloc()) closest_nodes_observer(this, id, m_target)); observer_ptr o(new (m_rpc.allocator().malloc()) closest_nodes_observer(this, id, m_target));
#ifndef NDEBUG
o->m_in_constructor = false;
#endif
m_rpc.invoke(messages::find_node, addr, o); m_rpc.invoke(messages::find_node, addr, o);
} }

View file

@ -110,6 +110,9 @@ void find_data::invoke(node_id const& id, asio::ip::udp::endpoint addr)
} }
observer_ptr o(new (m_rpc.allocator().malloc()) find_data_observer(this, id, m_target)); observer_ptr o(new (m_rpc.allocator().malloc()) find_data_observer(this, id, m_target));
#ifndef NDEBUG
o->m_in_constructor = false;
#endif
m_rpc.invoke(messages::get_peers, addr, o); m_rpc.invoke(messages::get_peers, addr, o);
} }

View file

@ -274,8 +274,11 @@ namespace
for (std::vector<node_entry>::const_iterator i = v.begin() for (std::vector<node_entry>::const_iterator i = v.begin()
, end(v.end()); i != end; ++i) , end(v.end()); i != end; ++i)
{ {
rpc.invoke(messages::get_peers, i->addr, observer_ptr( observer_ptr o(new (rpc.allocator().malloc()) get_peers_observer(ih, listen_port, rpc, f));
new (rpc.allocator().malloc()) get_peers_observer(ih, listen_port, rpc, f))); #ifndef NDEBUG
o->m_in_constructor = false;
#endif
rpc.invoke(messages::get_peers, i->addr, o);
nodes = true; nodes = true;
} }
} }
@ -291,6 +294,9 @@ void node_impl::add_node(udp::endpoint node)
// ping the node, and if we get a reply, it // ping the node, and if we get a reply, it
// will be added to the routing table // will be added to the routing table
observer_ptr o(new (m_rpc.allocator().malloc()) null_observer(m_rpc.allocator())); observer_ptr o(new (m_rpc.allocator().malloc()) null_observer(m_rpc.allocator()));
#ifndef NDEBUG
o->m_in_constructor = false;
#endif
m_rpc.invoke(messages::ping, node, o); m_rpc.invoke(messages::ping, node, o);
} }

View file

@ -105,6 +105,9 @@ void refresh::invoke(node_id const& nid, udp::endpoint addr)
{ {
observer_ptr o(new (m_rpc.allocator().malloc()) refresh_observer( observer_ptr o(new (m_rpc.allocator().malloc()) refresh_observer(
this, nid, m_target)); this, nid, m_target));
#ifndef NDEBUG
o->m_in_constructor = false;
#endif
m_rpc.invoke(messages::find_node, addr, o); m_rpc.invoke(messages::find_node, addr, o);
} }
@ -156,6 +159,9 @@ void refresh::invoke_pings_or_finish(bool prevent_request)
{ {
observer_ptr o(new (m_rpc.allocator().malloc()) ping_observer( observer_ptr o(new (m_rpc.allocator().malloc()) ping_observer(
this, node.id)); this, node.id));
#ifndef NDEBUG
o->m_in_constructor = false;
#endif
m_rpc.invoke(messages::ping, node.addr, o); m_rpc.invoke(messages::ping, node.addr, o);
++m_active_pings; ++m_active_pings;
++m_leftover_nodes_iterator; ++m_leftover_nodes_iterator;

View file

@ -430,6 +430,9 @@ void rpc_manager::reply_with_ping(msg& m)
io::write_uint16(m_next_transaction_id, out); io::write_uint16(m_next_transaction_id, out);
observer_ptr o(new (allocator().malloc()) null_observer(allocator())); observer_ptr o(new (allocator().malloc()) null_observer(allocator()));
#ifndef NDEBUG
o->m_in_constructor = false;
#endif
TORRENT_ASSERT(!m_transactions[m_next_transaction_id]); TORRENT_ASSERT(!m_transactions[m_next_transaction_id]);
o->sent = time_now(); o->sent = time_now();
o->target_addr = m.addr; o->target_addr = m.addr;

View file

@ -61,8 +61,7 @@ namespace libtorrent
TORRENT_ASSERT(sizeof(m_dh_prime) == DH_size(m_DH)); TORRENT_ASSERT(sizeof(m_dh_prime) == DH_size(m_DH));
DH_generate_key(m_DH); if (DH_generate_key(m_DH) == 0 || m_DH->pub_key == 0)
if (m_DH->pub_key == 0)
{ {
DH_free(m_DH); DH_free(m_DH);
throw std::bad_alloc(); throw std::bad_alloc();

View file

@ -1705,6 +1705,9 @@ namespace libtorrent
TORRENT_ASSERT(block.block_index < t->torrent_file().piece_size(block.piece_index)); TORRENT_ASSERT(block.block_index < t->torrent_file().piece_size(block.piece_index));
TORRENT_ASSERT(!t->picker().is_requested(block) || (t->picker().num_peers(block) > 0)); TORRENT_ASSERT(!t->picker().is_requested(block) || (t->picker().num_peers(block) > 0));
TORRENT_ASSERT(!t->have_piece(block.piece_index)); TORRENT_ASSERT(!t->have_piece(block.piece_index));
TORRENT_ASSERT(std::find(m_download_queue.begin(), m_download_queue.end(), block) == m_download_queue.end());
TORRENT_ASSERT(std::find(m_request_queue.begin(), m_request_queue.end(), block) == m_request_queue.end());
piece_picker::piece_state_t state; piece_picker::piece_state_t state;
peer_speed_t speed = peer_speed(); peer_speed_t speed = peer_speed();

View file

@ -1262,6 +1262,8 @@ namespace detail
{ {
torrent& t = *i->second; torrent& t = *i->second;
if (t.want_more_peers()) if (t.want_more_peers())
{
try
{ {
if (t.try_connect_peer()) if (t.try_connect_peer())
{ {
@ -1269,6 +1271,15 @@ namespace detail
steps_since_last_connect = 0; steps_since_last_connect = 0;
} }
} }
catch (std::bad_alloc&)
{
// we ran out of memory trying to connect to a peer
// lower the global limit to the number of peers
// we already have
m_max_connections = num_connections();
if (m_max_connections < 2) m_max_connections = 2;
}
}
++m_next_connect_torrent; ++m_next_connect_torrent;
++steps_since_last_connect; ++steps_since_last_connect;
++i; ++i;
@ -2406,8 +2417,10 @@ namespace detail
m_buffer_usage_logger << log_time() << " protocol_buffer: " m_buffer_usage_logger << log_time() << " protocol_buffer: "
<< (m_buffer_allocations * send_buffer_size) << std::endl; << (m_buffer_allocations * send_buffer_size) << std::endl;
#endif #endif
return std::make_pair((char*)m_send_buffers.ordered_malloc(num_buffers) std::pair<char*, int> ret((char*)m_send_buffers.ordered_malloc(num_buffers)
, num_buffers * send_buffer_size); , num_buffers * send_buffer_size);
if (ret.first == 0) throw std::bad_alloc();
return ret;
} }
void session_impl::free_buffer(char* buf, int size) void session_impl::free_buffer(char* buf, int size)