diff --git a/docs/todo.html b/docs/todo.html
index 9cd4fb345..ad40ec188 100644
--- a/docs/todo.html
+++ b/docs/todo.html
@@ -21,10 +21,10 @@
relevance 4 | ../src/session_impl.cpp:663 | in order to support SSL over uTP, the utp_socket manager either needs to be able to receive packets on multiple ports, or we need to peek into the first few bytes the payload stream of a socket to determine whether or not it's an SSL connection. (The former is simpler but won't do as well with NATs) |
in order to support SSL over uTP, the utp_socket manager either
needs to be able to receive packets on multiple ports, or we need to
peek into the first few bytes the payload stream of a socket to determine
@@ -72,11 +72,11 @@ do as well with NATs)../src/session_impl.cpp:663relevance 3 | ../src/torrent.cpp:6068 | if peer is a really good peer, maybe we shouldn't disconnect it |
|
if peer is a really good peer, maybe we shouldn't disconnect it../src/torrent.cpp:6068 return false;
+ | ||
relevance 3 | ../src/torrent.cpp:6090 | if peer is a really good peer, maybe we shouldn't disconnect it |
if peer is a really good peer, maybe we shouldn't disconnect it../src/torrent.cpp:6090 return false;
}
TORRENT_ASSERT(m_connections.find(p) == m_connections.end());
m_connections.insert(p);
@@ -235,162 +235,7 @@ when it doesn't have any of the file do the following../src/web_peer_co
{
// we should not try this server again.
t->remove_web_seed(this);
- | ||
relevance 3 | ../src/kademlia/node.cpp:327 | if uTP is enabled, we should say "implied_port": 1 |
if uTP is enabled, we should say "implied_port": 1../src/kademlia/node.cpp:327 , end(v.end()); i != end; ++i)
- {
-#ifdef TORRENT_DHT_VERBOSE_LOGGING
- TORRENT_LOG(node) << " announce-distance: " << (160 - distance_exp(ih, i->first.id));
-#endif
-
- void* ptr = node.m_rpc.allocate_observer();
- if (ptr == 0) return;
- observer_ptr o(new (ptr) announce_observer(algo, i->first.ep(), i->first.id));
-#if defined TORRENT_DEBUG || TORRENT_RELEASE_ASSERTS
- o->m_in_constructor = false;
-#endif
- entry e;
- e["y"] = "q";
- e["q"] = "announce_peer";
- entry& a = e["a"];
- a["info_hash"] = ih.to_string();
- a["port"] = listen_port;
- a["token"] = i->second;
- a["seed"] = int(seed);
- node.m_rpc.invoke(e, i->first.ep(), o);
- }
- }
-}
-
-void node_impl::add_router_node(udp::endpoint router)
-{
-#ifdef TORRENT_DHT_VERBOSE_LOGGING
- TORRENT_LOG(node) << "adding router node: " << router;
-#endif
- m_table.add_router_node(router);
-}
-
-void node_impl::add_node(udp::endpoint node)
-{
- // ping the node, and if we get a reply, it
- // will be added to the routing table
- void* ptr = m_rpc.allocate_observer();
- if (ptr == 0) return;
-
- // create a dummy traversal_algorithm
- // this is unfortunately necessary for the observer
- // to free itself from the pool when it's being released
- boost::intrusive_ptr<traversal_algorithm> algo(
- new traversal_algorithm(*this, (node_id::min)()));
- observer_ptr o(new (ptr) null_observer(algo, node, node_id(0)));
-#if defined TORRENT_DEBUG || TORRENT_RELEASE_ASSERTS
- o->m_in_constructor = false;
-#endif
- entry e;
- e["y"] = "q";
- | ||
relevance 2 | ../src/torrent.cpp:8258 | will pick_pieces ever return an empty set? |
will pick_pieces ever return an empty set?../src/torrent.cpp:8258 if (added_request)
- {
- peers_with_requests.insert(peers_with_requests.begin(), &c);
- if (i->first_requested == min_time()) i->first_requested = now;
-
- if (!c.can_request_time_critical())
- {
- peers.erase(p);
- }
- else
- {
- // resort p, since it will have a higher download_queue_time now
- while (p != peers.end()-1 && (*p)->download_queue_time() > (*(p+1))->download_queue_time())
- {
- std::iter_swap(p, p+1);
- ++p;
- }
- }
- }
-
- } while (!interesting_blocks.empty());
-
- peers.insert(peers.begin(), ignore_peers.begin(), ignore_peers.end());
- ignore_peers.clear();
- }
-
- // commit all the time critical requests
- for (std::set<peer_connection*>::iterator i = peers_with_requests.begin()
- , end(peers_with_requests.end()); i != end; ++i)
- {
- (*i)->send_block_requests();
- }
- }
-
- std::set<std::string> torrent::web_seeds(web_seed_entry::type_t type) const
- {
- TORRENT_ASSERT(m_ses.is_network_thread());
- std::set<std::string> ret;
- for (std::list<web_seed_entry>::const_iterator i = m_web_seeds.begin()
- , end(m_web_seeds.end()); i != end; ++i)
- {
- if (i->peer_info.banned) continue;
- if (i->type != type) continue;
- ret.insert(i->url);
- }
- return ret;
- }
-
- void torrent::remove_web_seed(std::string const& url, web_seed_entry::type_t type)
- {
- std::list<web_seed_entry>::iterator i = std::find_if(m_web_seeds.begin(), m_web_seeds.end()
- | ||
relevance 2 | ../src/utp_stream.cpp:1874 | we might want to do something else here as well, to resend the packet immediately without it being an MTU probe |
we might want to do something else here
-as well, to resend the packet immediately without
-it being an MTU probe../src/utp_stream.cpp:1874// if ((rand() % 100) > 0)
-#endif
- m_sm->send_packet(udp::endpoint(m_remote_address, m_port)
- , (char const*)h, p->size, ec
- , p->mtu_probe ? utp_socket_manager::dont_fragment : 0);
-
- ++m_out_packets;
- m_sm->inc_stats_counter(utp_socket_manager::packets_out);
-
- if (ec == error::message_size)
- {
-#if TORRENT_UTP_LOG
- UTP_LOGV("%8p: error sending packet: %s\n", this, ec.message().c_str());
-#endif
- // if we fail even though this is not a probe, we're screwed
- // since we'd have to repacketize
- TORRENT_ASSERT(p->mtu_probe);
- m_mtu_ceiling = p->size - 1;
- if (m_mtu_floor > m_mtu_ceiling) m_mtu_floor = m_mtu_ceiling;
- update_mtu_limits();
- p->mtu_probe = false;
- if (m_mtu_seq == m_ack_nr)
- m_mtu_seq = 0;
- ec.clear();
-
-#if TORRENT_UTP_LOG
- UTP_LOGV("%8p: re-sending\n", this);
-#endif
- m_sm->send_packet(udp::endpoint(m_remote_address, m_port)
- , (char const*)h, p->size, ec, 0);
- }
-
- if (ec == error::would_block || ec == error::try_again)
- {
-#if TORRENT_UTP_LOG
- UTP_LOGV("%8p: socket stalled\n", this);
-#endif
- if (!m_stalled)
- {
- m_stalled = true;
- m_sm->subscribe_writable(this);
- }
- }
- else if (ec)
- {
- TORRENT_ASSERT(stack_alloced != bool(payload_size));
- if (payload_size) free(p);
- m_error = ec;
- m_state = UTP_STATE_ERROR_WAIT;
- test_socket_state();
- return false;
- | ||
relevance 2 | ../src/web_peer_connection.cpp:546 | create a mapping of file-index to redirection URLs. Use that to form URLs instead. Support to reconnect to a new server without destructing this peer_connection |
create a mapping of file-index to redirection URLs. Use that to form URLs instead. Support to reconnect to a new server without destructing this peer_connection../src/web_peer_connection.cpp:546 t->remove_web_seed(this);
+ | ||
relevance 2 | ../src/web_peer_connection.cpp:546 | create a mapping of file-index to redirection URLs. Use that to form URLs instead. Support to reconnect to a new server without destructing this peer_connection |
create a mapping of file-index to redirection URLs. Use that to form URLs instead. Support to reconnect to a new server without destructing this peer_connection../src/web_peer_connection.cpp:546 t->remove_web_seed(this);
disconnect(errors::missing_location, 2);
#ifdef TORRENT_DEBUG
TORRENT_ASSERT(m_statistics.last_payload_downloaded()
@@ -441,7 +286,7 @@ it being an MTU probe../src/utp_stream.cpp:1874relevance 2 | ../src/kademlia/node.cpp:68 | make this configurable in dht_settings |
|
make this configurable in dht_settings../src/kademlia/node.cpp:68#include "libtorrent/kademlia/rpc_manager.hpp"
+ | ||
relevance 2 | ../src/kademlia/node.cpp:68 | make this configurable in dht_settings |
make this configurable in dht_settings../src/kademlia/node.cpp:68#include "libtorrent/kademlia/rpc_manager.hpp"
#include "libtorrent/kademlia/routing_table.hpp"
#include "libtorrent/kademlia/node.hpp"
#include "libtorrent/kademlia/dht_observer.hpp"
@@ -492,7 +337,7 @@ void purge_peers(std::set<peer_entry>& peers)
void nop() {}
- | ||
relevance 1 | ../src/http_seed_connection.cpp:117 | in chunked encoding mode, this assert won't hold. the chunk headers should be subtracted from the receive_buffer_size |
in chunked encoding mode, this assert won't hold.
+ | ||
relevance 1 | ../src/http_seed_connection.cpp:117 | in chunked encoding mode, this assert won't hold. the chunk headers should be subtracted from the receive_buffer_size |
in chunked encoding mode, this assert won't hold.
the chunk headers should be subtracted from the receive_buffer_size../src/http_seed_connection.cpp:117 boost::optional<piece_block_progress>
http_seed_connection::downloading_piece_progress() const
{
@@ -544,7 +389,7 @@ the chunk headers should be subtracted from the receive_buffer_size../s
std::string request;
request.reserve(400);
- | ||
relevance 1 | ../src/peer_connection.cpp:2570 | peers should really be corked/uncorked outside of all completed disk operations |
peers should really be corked/uncorked outside of
+ | ||
relevance 1 | ../src/peer_connection.cpp:2570 | peers should really be corked/uncorked outside of all completed disk operations |
peers should really be corked/uncorked outside of
all completed disk operations../src/peer_connection.cpp:2570 }
if (is_disconnecting()) return;
@@ -596,8 +441,8 @@ all completed disk operations../src/peer_connection.cpp:2570 | ||
relevance 1 | ../src/session_impl.cpp:5553 | report the proper address of the router as the source IP of this understanding of our external address, instead of the empty address |
report the proper address of the router as the source IP of
-this understanding of our external address, instead of the empty address../src/session_impl.cpp:5553 void session_impl::on_port_mapping(int mapping, address const& ip, int port
+ | ||
relevance 1 | ../src/session_impl.cpp:5543 | report the proper address of the router as the source IP of this understanding of our external address, instead of the empty address |
report the proper address of the router as the source IP of
+this understanding of our external address, instead of the empty address../src/session_impl.cpp:5543 void session_impl::on_port_mapping(int mapping, address const& ip, int port
, error_code const& ec, int map_transport)
{
TORRENT_ASSERT(is_network_thread());
@@ -648,60 +493,9 @@ this understanding of our external address, instead of the empty address | ||
relevance 1 | ../src/session_impl.cpp:5763 | report errors as alerts |
report errors as alerts../src/session_impl.cpp:5763 }
-
- void session_impl::add_dht_router(std::pair<std::string, int> const& node)
- {
-#if defined TORRENT_ASIO_DEBUGGING
- add_outstanding_async("session_impl::on_dht_router_name_lookup");
-#endif
- char port[7];
- snprintf(port, sizeof(port), "%d", node.second);
- tcp::resolver::query q(node.first, port);
- m_host_resolver.async_resolve(q,
- boost::bind(&session_impl::on_dht_router_name_lookup, this, _1, _2));
- }
-
- void session_impl::on_dht_router_name_lookup(error_code const& e
- , tcp::resolver::iterator host)
- {
-#if defined TORRENT_ASIO_DEBUGGING
- complete_async("session_impl::on_dht_router_name_lookup");
-#endif
- if (e) return;
- while (host != tcp::resolver::iterator())
- {
- // router nodes should be added before the DHT is started (and bootstrapped)
- udp::endpoint ep(host->endpoint().address(), host->endpoint().port());
- if (m_dht) m_dht->add_router_node(ep);
- m_dht_router_nodes.push_back(ep);
- ++host;
- }
- }
-#endif
-
- void session_impl::maybe_update_udp_mapping(int nat, int local_port, int external_port)
- {
- int local, external, protocol;
- if (nat == 0 && m_natpmp.get())
- {
- if (m_udp_mapping[nat] != -1)
- {
- if (m_natpmp->get_mapping(m_udp_mapping[nat], local, external, protocol))
- {
- // we already have a mapping. If it's the same, don't do anything
- if (local == local_port && external == external_port && protocol == natpmp::udp)
- return;
- }
- m_natpmp->delete_mapping(m_udp_mapping[nat]);
- }
- m_udp_mapping[nat] = m_natpmp->add_mapping(natpmp::udp
- , local_port, external_port);
- return;
- }
- | ||
relevance 1 | ../src/session_impl.cpp:6234 | we only need to do this if our global IPv4 address has changed since the DHT (currently) only supports IPv4. Since restarting the DHT is kind of expensive, it would be nice to not do it unnecessarily |
we only need to do this if our global IPv4 address has changed
+ | ||
relevance 1 | ../src/session_impl.cpp:6247 | we only need to do this if our global IPv4 address has changed since the DHT (currently) only supports IPv4. Since restarting the DHT is kind of expensive, it would be nice to not do it unnecessarily |
we only need to do this if our global IPv4 address has changed
since the DHT (currently) only supports IPv4. Since restarting the DHT
-is kind of expensive, it would be nice to not do it unnecessarily../src/session_impl.cpp:6234 void session_impl::set_external_address(address const& ip
+is kind of expensive, it would be nice to not do it unnecessarily../src/session_impl.cpp:6247 void session_impl::set_external_address(address const& ip
, int source_type, address const& source)
{
#if defined TORRENT_VERBOSE_LOGGING
@@ -752,11 +546,11 @@ is kind of expensive, it would be nice to not do it unnecessarily../src
#ifdef TORRENT_DISK_STATS
TORRENT_ASSERT(m_buffer_allocations >= 0);
- | ||
relevance 1 | ../src/torrent.cpp:1043 | make this depend on the error and on the filesystem the files are being downloaded to. If the error is no_space_left_on_device and the filesystem doesn't support sparse files, only zero the priorities of the pieces that are at the tails of all files, leaving everything up to the highest written piece in each file |
make this depend on the error and on the filesystem the
+ | ||
relevance 1 | ../src/torrent.cpp:1044 | make this depend on the error and on the filesystem the files are being downloaded to. If the error is no_space_left_on_device and the filesystem doesn't support sparse files, only zero the priorities of the pieces that are at the tails of all files, leaving everything up to the highest written piece in each file |
make this depend on the error and on the filesystem the
files are being downloaded to. If the error is no_space_left_on_device
and the filesystem doesn't support sparse files, only zero the priorities
of the pieces that are at the tails of all files, leaving everything
-up to the highest written piece in each file../src/torrent.cpp:1043 if (c) c->disconnect(errors::no_memory);
+up to the highest written piece in each file../src/torrent.cpp:1044 if (c) c->disconnect(errors::no_memory);
return;
}
@@ -807,8 +601,8 @@ up to the highest written piece in each file../src/torrent.cpp:1043 | ||
relevance 1 | ../src/torrent.cpp:5330 | save the send_stats state instead of throwing them away it may pose an issue when downgrading though |
save the send_stats state instead of throwing them away
-it may pose an issue when downgrading though../src/torrent.cpp:5330 ? (1 << k) : 0;
+ | ||
relevance 1 | ../src/torrent.cpp:5352 | save the send_stats state instead of throwing them away it may pose an issue when downgrading though |
save the send_stats state instead of throwing them away
+it may pose an issue when downgrading though../src/torrent.cpp:5352 ? (1 << k) : 0;
bitmask.append(1, v);
TORRENT_ASSERT(bits == 8 || j == num_bitmask_bytes - 1);
}
@@ -859,9 +653,9 @@ it may pose an issue when downgrading though../src/torrent.cpp:5330 | ||
relevance 1 | ../src/torrent.cpp:6236 | should disconnect all peers that have the pieces we have not just seeds. It would be pretty expensive to check all pieces for all peers though |
should disconnect all peers that have the pieces we have
+ | ||
relevance 1 | ../src/torrent.cpp:6258 | should disconnect all peers that have the pieces we have not just seeds. It would be pretty expensive to check all pieces for all peers though |
should disconnect all peers that have the pieces we have
not just seeds. It would be pretty expensive to check all pieces
-for all peers though../src/torrent.cpp:6236 TORRENT_ASSERT(m_state != torrent_status::finished && m_state != torrent_status::seeding);
+for all peers though../src/torrent.cpp:6258 TORRENT_ASSERT(m_state != torrent_status::finished && m_state != torrent_status::seeding);
set_state(torrent_status::finished);
set_queue_position(-1);
@@ -912,7 +706,7 @@ for all peers though../src/torrent.cpp:6236relevance 1 | ../src/torrent_info.cpp:181 | we might save constructing a std::string if this would take a char const* instead |
|
we might save constructing a std::string if this would take a char const* instead../src/torrent_info.cpp:181 {
+ | ||
relevance 1 | ../src/torrent_info.cpp:181 | we might save constructing a std::string if this would take a char const* instead |
we might save constructing a std::string if this would take a char const* instead../src/torrent_info.cpp:181 {
tmp_path += i[0];
tmp_path += i[1];
tmp_path += i[2];
@@ -963,7 +757,7 @@ for all peers though../src/torrent.cpp:6236relevance 1 | ../src/torrent_info.cpp:401 | this logic should be a separate step done once the torrent is loaded, and the original filenames should be preserved! |
|
this logic should be a separate step
+ | ||
relevance 1 | ../src/torrent_info.cpp:401 | this logic should be a separate step done once the torrent is loaded, and the original filenames should be preserved! |
this logic should be a separate step
done once the torrent is loaded, and the original
filenames should be preserved!../src/torrent_info.cpp:401
while (*s1 != 0 || *s2 != 0)
@@ -1016,7 +810,7 @@ filenames should be preserved!../src/torrent_info.cpp:401 | ||
relevance 1 | ../src/torrent_info.cpp:437 | once the filename renaming is removed from here this check can be removed as well |
once the filename renaming is removed from here
+ | ||
relevance 1 | ../src/torrent_info.cpp:437 | once the filename renaming is removed from here this check can be removed as well |
once the filename renaming is removed from here
this check can be removed as well../src/torrent_info.cpp:437 // increase the counter
int cnt = 0;
if (!files.insert(e.path).second)
@@ -1068,7 +862,7 @@ this check can be removed as well../src/torrent_info.cpp:437 | ||
relevance 1 | ../src/kademlia/node.cpp:793 | find_node should write directly to the response entry |
find_node should write directly to the response entry../src/kademlia/node.cpp:793 {
+ | ||
relevance 1 | ../src/kademlia/node.cpp:797 | find_node should write directly to the response entry |
find_node should write directly to the response entry../src/kademlia/node.cpp:797 {
TORRENT_LOG(node) << " values: " << reply["values"].list().size();
}
#endif
@@ -1119,7 +913,7 @@ this check can be removed as well../src/torrent_info.cpp:437 | ||
relevance 1 | ../include/libtorrent/ip_voter.hpp:100 | instead, have one instance per possible subnet, global IPv4, global IPv6, loopback, 192.168.x.x, 10.x.x.x, etc. |
instead, have one instance per possible subnet, global IPv4, global IPv6, loopback, 192.168.x.x, 10.x.x.x, etc.../include/libtorrent/ip_voter.hpp:100 bloom_filter<32> m_external_address_voters;
+ | ||
relevance 1 | ../include/libtorrent/ip_voter.hpp:100 | instead, have one instance per possible subnet, global IPv4, global IPv6, loopback, 192.168.x.x, 10.x.x.x, etc. |
instead, have one instance per possible subnet, global IPv4, global IPv6, loopback, 192.168.x.x, 10.x.x.x, etc.../include/libtorrent/ip_voter.hpp:100 bloom_filter<32> m_external_address_voters;
std::vector<external_ip_t> m_external_addresses;
address m_external_address;
};
@@ -1146,58 +940,7 @@ this check can be removed as well../src/torrent_info.cpp:437 | ||
relevance 1 | ../include/libtorrent/utp_stream.hpp:378 | implement blocking write. Low priority since it's not used (yet) |
implement blocking write. Low priority since it's not used (yet)../include/libtorrent/utp_stream.hpp:378 for (typename Mutable_Buffers::const_iterator i = buffers.begin()
- , end(buffers.end()); i != end; ++i)
- {
- using asio::buffer_cast;
- using asio::buffer_size;
- add_read_buffer(buffer_cast<void*>(*i), buffer_size(*i));
-#if defined TORRENT_DEBUG || TORRENT_RELEASE_ASSERTS
- buf_size += buffer_size(*i);
-#endif
- }
- std::size_t ret = read_some(true);
- TORRENT_ASSERT(ret <= buf_size);
- TORRENT_ASSERT(ret > 0);
- return ret;
- }
-
- template <class Const_Buffers>
- std::size_t write_some(Const_Buffers const& buffers, error_code& ec)
- {
- TORRENT_ASSERT(false && "not implemented!");
- return 0;
- }
-
-#ifndef BOOST_NO_EXCEPTIONS
- template <class Mutable_Buffers>
- std::size_t read_some(Mutable_Buffers const& buffers)
- {
- error_code ec;
- std::size_t ret = read_some(buffers, ec);
- if (ec)
- boost::throw_exception(boost::system::system_error(ec));
- return ret;
- }
-
- template <class Const_Buffers>
- std::size_t write_some(Const_Buffers const& buffers)
- {
- error_code ec;
- std::size_t ret = write_some(buffers, ec);
- if (ec)
- boost::throw_exception(boost::system::system_error(ec));
- return ret;
- }
-#endif
-
- template <class Handler>
- void async_write_some(boost::asio::null_buffers const& buffers, Handler const& handler)
- {
- TORRENT_ASSERT(false);
- }
-
- | ||
relevance 1 | ../include/libtorrent/web_peer_connection.hpp:126 | if we make this be a disk_buffer_holder instead we would save a copy sometimes use allocate_disk_receive_buffer and release_disk_receive_buffer |
if we make this be a disk_buffer_holder instead
+ | ||
relevance 1 | ../include/libtorrent/web_peer_connection.hpp:126 | if we make this be a disk_buffer_holder instead we would save a copy sometimes use allocate_disk_receive_buffer and release_disk_receive_buffer |
if we make this be a disk_buffer_holder instead
we would save a copy sometimes
use allocate_disk_receive_buffer and release_disk_receive_buffer../include/libtorrent/web_peer_connection.hpp:126
bool maybe_harvest_block();
@@ -1250,7 +993,7 @@ use allocate_disk_receive_buffer and release_disk_receive_buffer../incl
};
}
- | ||
relevance 0 | ../src/bt_peer_connection.cpp:625 | this could be optimized using knuth morris pratt |
this could be optimized using knuth morris pratt../src/bt_peer_connection.cpp:625 {
+ | ||
relevance 0 | ../src/bt_peer_connection.cpp:625 | this could be optimized using knuth morris pratt |
this could be optimized using knuth morris pratt../src/bt_peer_connection.cpp:625 {
disconnect(errors::no_memory);
return;
}
@@ -1301,12 +1044,12 @@ use allocate_disk_receive_buffer and release_disk_receive_buffer../incl
// }
// no complete sync
- | ||
relevance 0 | ../src/bt_peer_connection.cpp:2089 | if we're finished, send upload_only message |
if we're finished, send upload_only message../src/bt_peer_connection.cpp:2089 if (msg[5 + k / 8] & (0x80 >> (k % 8))) bitfield_string[k] = '1';
+ | ||
relevance 0 | ../src/bt_peer_connection.cpp:2089 | if we're finished, send upload_only message |
if we're finished, send upload_only message../src/bt_peer_connection.cpp:2089 if (msg[5 + k / 8] & (0x80 >> (k % 8))) bitfield_string[k] = '1';
else bitfield_string[k] = '0';
}
peer_log("==> BITFIELD [ %s ]", bitfield_string.c_str());
#endif
-#if defined TORRENT_DEBUG || TORRENT_RELEASE_ASSERTS
+#if TORRENT_USE_ASSERTS
m_sent_bitfield = true;
#endif
@@ -1352,7 +1095,7 @@ use allocate_disk_receive_buffer and release_disk_receive_buffer../incl
std::back_insert_iterator<std::string> out(remote_address);
detail::write_address(remote().address(), out);
handshake["yourip"] = remote_address;
- | ||
relevance 0 | ../src/bt_peer_connection.cpp:3329 | move the erasing into the loop above remove all payload ranges that has been sent |
move the erasing into the loop above
+ | ||
relevance 0 | ../src/bt_peer_connection.cpp:3329 | move the erasing into the loop above remove all payload ranges that has been sent |
move the erasing into the loop above
remove all payload ranges that has been sent../src/bt_peer_connection.cpp:3329 for (std::vector<range>::iterator i = m_payloads.begin();
i != m_payloads.end(); ++i)
{
@@ -1404,7 +1147,7 @@ remove all payload ranges that has been sent../src/bt_peer_connection.c
TORRENT_ASSERT(m_sent_handshake);
}
- | ||
relevance 0 | ../src/file.cpp:1370 | is there any way to pre-fetch data from a file on windows? |
is there any way to pre-fetch data from a file on windows?../src/file.cpp:1370
+ | ||
relevance 0 | ../src/file.cpp:1381 | is there any way to pre-fetch data from a file on windows? |
is there any way to pre-fetch data from a file on windows?../src/file.cpp:1381
void file::init_file()
{
if (m_page_size != 0) return;
@@ -1455,7 +1198,7 @@ remove all payload ranges that has been sent../src/bt_peer_connection.c
#ifdef TORRENT_DEBUG
if (m_open_mode & no_buffer)
{
- | ||
relevance 0 | ../src/http_tracker_connection.cpp:99 | support authentication (i.e. user name and password) in the URL |
support authentication (i.e. user name and password) in the URL../src/http_tracker_connection.cpp:99 , aux::session_impl const& ses
+ | ||
relevance 0 | ../src/http_tracker_connection.cpp:99 | support authentication (i.e. user name and password) in the URL |
support authentication (i.e. user name and password) in the URL../src/http_tracker_connection.cpp:99 , aux::session_impl const& ses
, proxy_settings const& ps
, std::string const& auth
#if TORRENT_USE_I2P
@@ -1506,21 +1249,21 @@ remove all payload ranges that has been sent../src/bt_peer_connection.c
if (arguments_start != std::string::npos)
url += "&";
else
- | ||
relevance 0 | ../src/i2p_stream.cpp:204 | move this to proxy_base and use it in all proxies |
move this to proxy_base and use it in all proxies../src/i2p_stream.cpp:204
+ | ||
relevance 0 | ../src/i2p_stream.cpp:204 | move this to proxy_base and use it in all proxies |
move this to proxy_base and use it in all proxies../src/i2p_stream.cpp:204
i2p_stream::i2p_stream(io_service& io_service)
: proxy_base(io_service)
, m_id(0)
, m_command(cmd_create_session)
, m_state(0)
{
-#if defined TORRENT_DEBUG || TORRENT_RELEASE_ASSERTS
+#if TORRENT_USE_ASSERTS
m_magic = 0x1337;
#endif
}
i2p_stream::~i2p_stream()
{
-#if defined TORRENT_DEBUG || TORRENT_RELEASE_ASSERTS
+#if TORRENT_USE_ASSERTS
TORRENT_ASSERT(m_magic == 0x1337);
m_magic = 0;
#endif
@@ -1557,7 +1300,7 @@ remove all payload ranges that has been sent../src/bt_peer_connection.c
void i2p_stream::connected(error_code const& e, boost::shared_ptr<handler_type> h)
{
TORRENT_ASSERT(m_magic == 0x1337);
- | ||
relevance 0 | ../src/packet_buffer.cpp:176 | use compare_less_wrap for this comparison as well |
use compare_less_wrap for this comparison as well../src/packet_buffer.cpp:176 while (new_size < size)
+ | ||
relevance 0 | ../src/packet_buffer.cpp:176 | use compare_less_wrap for this comparison as well |
use compare_less_wrap for this comparison as well../src/packet_buffer.cpp:176 while (new_size < size)
new_size <<= 1;
void** new_storage = (void**)malloc(sizeof(void*) * new_size);
@@ -1608,7 +1351,7 @@ remove all payload ranges that has been sent../src/bt_peer_connection.c
if (m_storage[m_last & mask]) break;
++m_last;
m_last &= 0xffff;
- | ||
relevance 0 | ../src/peer_connection.cpp:2733 | this might need something more so that once we have the metadata we can construct a full bitfield |
this might need something more
+ | ||
relevance 0 | ../src/peer_connection.cpp:2733 | this might need something more so that once we have the metadata we can construct a full bitfield |
this might need something more
so that once we have the metadata
we can construct a full bitfield../src/peer_connection.cpp:2733
#ifdef TORRENT_VERBOSE_LOGGING
@@ -1661,7 +1404,7 @@ we can construct a full bitfield../src/peer_connection.cpp:2733 | ||
relevance 0 | ../src/peer_connection.cpp:2864 | sort the allowed fast set in priority order |
sort the allowed fast set in priority order../src/peer_connection.cpp:2864 // this piece index later
+ | ||
relevance 0 | ../src/peer_connection.cpp:2864 | sort the allowed fast set in priority order |
sort the allowed fast set in priority order../src/peer_connection.cpp:2864 // this piece index later
m_allowed_fast.push_back(index);
// if the peer has the piece and we want
@@ -1706,13 +1449,13 @@ we can construct a full bitfield../src/peer_connection.cpp:2733 | ||
relevance 0 | ../src/peer_connection.cpp:4584 | peers should really be corked/uncorked outside of all completed disk operations |
peers should really be corked/uncorked outside of
+ | ||
relevance 0 | ../src/peer_connection.cpp:4584 | peers should really be corked/uncorked outside of all completed disk operations |
peers should really be corked/uncorked outside of
all completed disk operations../src/peer_connection.cpp:4584 // this means we're in seed mode and we haven't yet
// verified this piece (r.piece)
t->filesystem().async_read_and_hash(r, boost::bind(&peer_connection::on_disk_read_complete
@@ -1764,7 +1507,7 @@ all completed disk operations../src/peer_connection.cpp:4584 | ||
relevance 0 | ../src/policy.cpp:857 | only allow _one_ connection to use this override at a time |
only allow _one_ connection to use this
+ | ||
relevance 0 | ../src/policy.cpp:857 | only allow _one_ connection to use this override at a time |
only allow _one_ connection to use this
override at a time../src/policy.cpp:857 " external: " << external.external_address(m_peers[candidate]->address()) <<
" t: " << (session_time - m_peers[candidate]->last_connected) <<
" ]\n";
@@ -1816,7 +1559,7 @@ override at a time../src/policy.cpp:857relevance 0 | ../src/policy.cpp:1902 | how do we deal with our external address changing? Pass in a force-update maybe? and keep a version number in policy |
|
how do we deal with our external address changing? Pass in a force-update maybe? and keep a version number in policy../src/policy.cpp:1902#endif
+ | ||
relevance 0 | ../src/policy.cpp:1902 | how do we deal with our external address changing? Pass in a force-update maybe? and keep a version number in policy |
how do we deal with our external address changing? Pass in a force-update maybe? and keep a version number in policy../src/policy.cpp:1902#endif
, on_parole(false)
, banned(false)
#ifndef TORRENT_DISABLE_DHT
@@ -1826,7 +1569,7 @@ override at a time../src/policy.cpp:857 | ||
relevance 0 | ../src/session_impl.cpp:1764 | recalculate all connect candidates for all torrents |
recalculate all connect candidates for all torrents../src/session_impl.cpp:1764 // #error closing the udp socket here means that
+ | ||
relevance 0 | ../src/session_impl.cpp:1764 | recalculate all connect candidates for all torrents |
recalculate all connect candidates for all torrents../src/session_impl.cpp:1764 // #error closing the udp socket here means that
// the uTP connections cannot be closed gracefully
m_udp_socket.close();
m_external_udp_port = 0;
@@ -1918,7 +1661,7 @@ override at a time../src/policy.cpp:857relevance 0 | ../src/session_impl.cpp:3227 | have a separate list for these connections, instead of having to loop through all of them |
|
have a separate list for these connections, instead of having to loop through all of them../src/session_impl.cpp:3227 // --------------------------------------------------------------
+ | ||
relevance 0 | ../src/session_impl.cpp:3227 | have a separate list for these connections, instead of having to loop through all of them |
have a separate list for these connections, instead of having to loop through all of them../src/session_impl.cpp:3227 // --------------------------------------------------------------
if (!m_paused) m_auto_manage_time_scaler--;
if (m_auto_manage_time_scaler < 0)
{
@@ -1969,20 +1712,20 @@ override at a time../src/policy.cpp:857relevance 0 | ../src/session_impl.cpp:4317 | allow extensions to sort torrents for queuing |
|
allow extensions to sort torrents for queuing../src/session_impl.cpp:4317 else if (!t->is_paused())
+ | ||
relevance 0 | ../src/session_impl.cpp:4307 | allow extensions to sort torrents for queuing |
allow extensions to sort torrents for queuing../src/session_impl.cpp:4307 if (t->is_auto_managed() && !t->has_error())
+ {
+ TORRENT_ASSERT(t->m_resume_data_loaded || !t->valid_metadata());
+ // this torrent is auto managed, add it to
+ // the list (depending on if it's a seed or not)
+ if (t->is_finished())
+ seeds.push_back(t);
+ else
+ downloaders.push_back(t);
+ }
+ else if (!t->is_paused())
{
TORRENT_ASSERT(t->m_resume_data_loaded || !t->valid_metadata());
--hard_limit;
- if (is_active(t, settings()))
- {
- // this is not an auto managed torrent,
- // if it's running and active, decrease the
- // counters.
- if (t->is_finished())
- --num_seeds;
- else
- --num_downloaders;
- }
}
}
@@ -2020,9 +1763,9 @@ override at a time../src/policy.cpp:857relevance 0 | ../src/session_impl.cpp:4473 | use a lower limit than m_settings.connections_limit to allocate the to 10% or so of connection slots for incoming connections |
|
use a lower limit than m_settings.connections_limit
+ | ||
relevance 0 | ../src/session_impl.cpp:4463 | use a lower limit than m_settings.connections_limit to allocate the to 10% or so of connection slots for incoming connections |
use a lower limit than m_settings.connections_limit
to allocate the to 10% or so of connection slots for incoming
-connections../src/session_impl.cpp:4473 {
+connections../src/session_impl.cpp:4463 {
if (m_boost_connections > max_connections)
{
m_boost_connections -= max_connections;
@@ -2073,7 +1816,7 @@ connections../src/session_impl.cpp:4473relevance 0 | ../src/session_impl.cpp:4507 | make this bias configurable |
|
make this bias configurable../src/session_impl.cpp:4507 | ||
relevance 0 | ../src/session_impl.cpp:4508 | also take average_peers into account, to create a bias for downloading torrents with < average peers |
also take average_peers into account, to create a bias for downloading torrents with < average peers../src/session_impl.cpp:4508 average_peers = num_downloads_peers / num_downloads;
+ | ||
relevance 0 | ../src/session_impl.cpp:4497 | make this bias configurable |
make this bias configurable../src/session_impl.cpp:4497 | ||
relevance 0 | ../src/session_impl.cpp:4498 | also take average_peers into account, to create a bias for downloading torrents with < average peers |
also take average_peers into account, to create a bias for downloading torrents with < average peers../src/session_impl.cpp:4498 average_peers = num_downloads_peers / num_downloads;
if (m_next_connect_torrent == m_torrents.end())
m_next_connect_torrent = m_torrents.begin();
@@ -2124,7 +1867,7 @@ connections../src/session_impl.cpp:4473relevance 0 | ../src/session_impl.cpp:4652 | make configurable |
|
make configurable../src/session_impl.cpp:4652
+ | ||
relevance 0 | ../src/session_impl.cpp:4642 | make configurable |
make configurable../src/session_impl.cpp:4642
#ifdef TORRENT_DEBUG
for (std::vector<peer_connection*>::const_iterator i = peers.begin()
, end(peers.end()), prev(peers.end()); i != end; ++i)
@@ -2157,7 +1900,7 @@ connections../src/session_impl.cpp:4473relevance 0 | ../src/session_impl.cpp:4666 | make configurable |
|
make configurable../src/session_impl.cpp:4666 >= (*i)->uploaded_in_last_round() * 1000
+ | ||
relevance 0 | ../src/session_impl.cpp:4656 | make configurable |
make configurable../src/session_impl.cpp:4656 >= (*i)->uploaded_in_last_round() * 1000
* (1 + t2->priority()) / total_milliseconds(unchoke_interval));
}
prev = i;
@@ -2208,7 +1951,7 @@ connections../src/session_impl.cpp:4473 | ||
relevance 0 | ../src/storage.cpp:324 | if the read fails, set error and exit immediately |
if the read fails, set error and exit immediately../src/storage.cpp:324 if (m_storage->disk_pool()) block_size = m_storage->disk_pool()->block_size();
+ | ||
relevance 0 | ../src/storage.cpp:324 | if the read fails, set error and exit immediately |
if the read fails, set error and exit immediately../src/storage.cpp:324 if (m_storage->disk_pool()) block_size = m_storage->disk_pool()->block_size();
int size = slot_size;
int num_blocks = (size + block_size - 1) / block_size;
@@ -2259,7 +2002,7 @@ connections../src/session_impl.cpp:4473relevance 0 | ../src/storage.cpp:358 | if the read fails, set error and exit immediately |
|
if the read fails, set error and exit immediately../src/storage.cpp:358 {
+ | ||
relevance 0 | ../src/storage.cpp:358 | if the read fails, set error and exit immediately |
if the read fails, set error and exit immediately../src/storage.cpp:358 {
ph.h.update((char const*)bufs[i].iov_base, bufs[i].iov_len);
small_piece_size -= bufs[i].iov_len;
}
@@ -2310,7 +2053,7 @@ connections../src/session_impl.cpp:4473relevance 0 | ../src/storage.cpp:629 | make this more generic to not just work if files have been renamed, but also if they have been merged into a single file for instance maybe use the same format as .torrent files and reuse some code from torrent_info |
|
make this more generic to not just work if files have been
+ | ||
relevance 0 | ../src/storage.cpp:629 | make this more generic to not just work if files have been renamed, but also if they have been merged into a single file for instance maybe use the same format as .torrent files and reuse some code from torrent_info |
make this more generic to not just work if files have been
renamed, but also if they have been merged into a single file for instance
maybe use the same format as .torrent files and reuse some code from torrent_info../src/storage.cpp:629 for (;;)
{
@@ -2363,9 +2106,9 @@ maybe use the same format as .torrent files and reuse some code from torrent_inf
for (int i = 0; i < file_sizes_ent->list_size(); ++i)
{
- | ||
relevance 0 | ../src/storage.cpp:1246 | what if file_base is used to merge several virtual files into a single physical file? We should probably disable this if file_base is used. This is not a widely used feature though |
what if file_base is used to merge several virtual files
+ | ||
relevance 0 | ../src/storage.cpp:1263 | what if file_base is used to merge several virtual files into a single physical file? We should probably disable this if file_base is used. This is not a widely used feature though |
what if file_base is used to merge several virtual files
into a single physical file? We should probably disable this
-if file_base is used. This is not a widely used feature though../src/storage.cpp:1246 int bytes_transferred = 0;
+if file_base is used. This is not a widely used feature though../src/storage.cpp:1263 int bytes_transferred = 0;
// if the file is opened in no_buffer mode, and the
// read is unaligned, we need to fall back on a slow
// special read that reads aligned buffers and copies
@@ -2377,7 +2120,7 @@ if file_base is used. This is not a widely used feature though../src/st
{
bytes_transferred = (int)(this->*op.unaligned_op)(file_handle, adjusted_offset
, tmp_bufs, num_tmp_bufs, ec);
- if ((op.mode & file::rw_mask) == file::read_write
+ if ((op.mode & file::rw_mask) != file::read_only
&& adjusted_offset + bytes_transferred >= files().file_size(file_index)
&& (file_handle->pos_alignment() > 0 || file_handle->size_alignment() > 0))
{
@@ -2416,12 +2159,12 @@ if file_base is used. This is not a widely used feature though../src/st
// makes unaligned requests (and the disk cache is disabled or fully utilized
// for write cache).
- | ||
relevance 0 | ../src/torrent.cpp:1245 | is verify_peer_cert called once per certificate in the chain, and this function just tells us which depth we're at right now? If so, the comment makes sense. any certificate that isn't the leaf (i.e. the one presented by the peer) should be accepted automatically, given preverified is true. The leaf certificate need to be verified to make sure its DN matches the info-hash |
is verify_peer_cert called once per certificate in the chain, and
+ | ||
relevance 0 | ../src/torrent.cpp:1246 | is verify_peer_cert called once per certificate in the chain, and this function just tells us which depth we're at right now? If so, the comment makes sense. any certificate that isn't the leaf (i.e. the one presented by the peer) should be accepted automatically, given preverified is true. The leaf certificate need to be verified to make sure its DN matches the info-hash |
is verify_peer_cert called once per certificate in the chain, and
this function just tells us which depth we're at right now? If so, the comment
makes sense.
any certificate that isn't the leaf (i.e. the one presented by the peer)
should be accepted automatically, given preverified is true. The leaf certificate
-need to be verified to make sure its DN matches the info-hash../src/torrent.cpp:1245 if (pp) p->add_extension(pp);
+need to be verified to make sure its DN matches the info-hash../src/torrent.cpp:1246 if (pp) p->add_extension(pp);
}
// if files are checked for this torrent, call the extension
@@ -2472,12 +2215,12 @@ need to be verified to make sure its DN matches the info-hash../src/tor
{
#if defined(TORRENT_VERBOSE_LOGGING) || defined(TORRENT_LOGGING)
match = true;
- | ||
relevance 0 | ../src/torrent.cpp:5063 | make this more generic to not just work if files have been renamed, but also if they have been merged into a single file for instance maybe use the same format as .torrent files and reuse some code from torrent_info The mapped_files needs to be read both in the network thread and in the disk thread, since they both have their own mapped files structures which are kept in sync |
make this more generic to not just work if files have been
+ | ||
relevance 0 | ../src/torrent.cpp:5085 | make this more generic to not just work if files have been renamed, but also if they have been merged into a single file for instance maybe use the same format as .torrent files and reuse some code from torrent_info The mapped_files needs to be read both in the network thread and in the disk thread, since they both have their own mapped files structures which are kept in sync |
make this more generic to not just work if files have been
renamed, but also if they have been merged into a single file for instance
maybe use the same format as .torrent files and reuse some code from torrent_info
The mapped_files needs to be read both in the network thread
and in the disk thread, since they both have their own mapped files structures
-which are kept in sync../src/torrent.cpp:5063 if (m_seed_mode) m_verified.resize(m_torrent_file->num_pieces(), false);
+which are kept in sync../src/torrent.cpp:5085 if (m_seed_mode) m_verified.resize(m_torrent_file->num_pieces(), false);
super_seeding(rd.dict_find_int_value("super_seeding", 0));
m_last_scrape = rd.dict_find_int_value("last_scrape", 0);
@@ -2528,12 +2271,12 @@ which are kept in sync../src/torrent.cpp:5063relevance 0 | ../src/torrent.cpp:5199 | if this is a merkle torrent and we can't restore the tree, we need to wipe all the bits in the have array, but not necessarily we might want to do a full check to see if we have all the pieces. This is low priority since almost no one uses merkle torrents |
|
if this is a merkle torrent and we can't
+ | ||
relevance 0 | ../src/torrent.cpp:5221 | if this is a merkle torrent and we can't restore the tree, we need to wipe all the bits in the have array, but not necessarily we might want to do a full check to see if we have all the pieces. This is low priority since almost no one uses merkle torrents |
if this is a merkle torrent and we can't
restore the tree, we need to wipe all the
bits in the have array, but not necessarily
we might want to do a full check to see if we have
all the pieces. This is low priority since almost
-no one uses merkle torrents../src/torrent.cpp:5199 add_web_seed(url, web_seed_entry::http_seed);
+no one uses merkle torrents../src/torrent.cpp:5221 add_web_seed(url, web_seed_entry::http_seed);
}
}
@@ -2558,7 +2301,7 @@ no one uses merkle torrents../src/torrent.cpp:5199 | ||
relevance 0 | ../src/torrent.cpp:5387 | make this more generic to not just work if files have been renamed, but also if they have been merged into a single file for instance. using file_base |
make this more generic to not just work if files have been
+ | ||
relevance 0 | ../src/torrent.cpp:5409 | make this more generic to not just work if files have been renamed, but also if they have been merged into a single file for instance. using file_base |
make this more generic to not just work if files have been
renamed, but also if they have been merged into a single file for instance.
-using file_base../src/torrent.cpp:5387 entry::string_type& pieces = ret["pieces"].string();
+using file_base../src/torrent.cpp:5409 entry::string_type& pieces = ret["pieces"].string();
pieces.resize(m_torrent_file->num_pieces());
if (is_seed())
{
@@ -2637,10 +2380,10 @@ using file_base../src/torrent.cpp:5387relevance 0 | ../src/torrent.cpp:7937 | go through the pieces we have and count the total number of downloaders we have. Only count peers that are interested in us since some peers might not send have messages for pieces we have it num_interested == 0, we need to pick a new piece |
|
go through the pieces we have and count the total number
+ | ||
relevance 0 | ../src/torrent.cpp:7962 | go through the pieces we have and count the total number of downloaders we have. Only count peers that are interested in us since some peers might not send have messages for pieces we have it num_interested == 0, we need to pick a new piece |
go through the pieces we have and count the total number
of downloaders we have. Only count peers that are interested in us
since some peers might not send have messages for pieces we have
-it num_interested == 0, we need to pick a new piece../src/torrent.cpp:7937 }
+it num_interested == 0, we need to pick a new piece../src/torrent.cpp:7962 }
rarest_pieces.clear();
rarest_rarity = pp.peer_count;
@@ -2691,7 +2434,7 @@ it num_interested == 0, we need to pick a new piece../src/torrent.cpp:7
{
m_picker->get_availability(avail_vec);
}
- | ||
relevance 0 | ../src/udp_tracker_connection.cpp:550 | it would be more efficient to not use a string here. however, the problem is that some trackers will respond with actual strings. For example i2p trackers |
it would be more efficient to not use a string here.
+ | ||
relevance 0 | ../src/udp_tracker_connection.cpp:550 | it would be more efficient to not use a string here. however, the problem is that some trackers will respond with actual strings. For example i2p trackers |
it would be more efficient to not use a string here.
however, the problem is that some trackers will respond
with actual strings. For example i2p trackers../src/udp_tracker_connection.cpp:550 }
@@ -2744,11 +2487,11 @@ with actual strings. For example i2p trackers../src/udp_tracker_connect
{
restart_read_timeout();
int action = detail::read_int32(buf);
- | ||
relevance 0 | ../src/utp_stream.cpp:1581 | this loop may not be very efficient |
this loop may not be very efficient../src/utp_stream.cpp:1581 TORRENT_ASSERT(p->header_size >= sizeof(utp_header) + sack_size + 2);
- memmove(ptr, ptr + sack_size + 2, p->size - p->header_size);
- p->header_size -= sack_size + 2;
- p->size -= sack_size + 2;
-}
+ | ||
relevance 0 | ../src/utp_stream.cpp:1604 | this loop may not be very efficient |
this loop may not be very efficient../src/utp_stream.cpp:1604
+private:
+
+ char* m_buf;
+};
// sends a packet, pulls data from the write buffer (if there's any)
// if ack is true, we need to send a packet regardless of if there's
@@ -2795,7 +2538,7 @@ bool utp_socket_impl::send_pkt(int flags)
if (sack > 32) sack = 32;
}
- | ||
relevance 0 | ../src/kademlia/routing_table.cpp:293 | instad of refreshing a bucket by using find_nodes, ping each node periodically |
instad of refreshing a bucket by using find_nodes,
+ | ||
relevance 0 | ../src/kademlia/routing_table.cpp:293 | instad of refreshing a bucket by using find_nodes, ping each node periodically |
instad of refreshing a bucket by using find_nodes,
ping each node periodically../src/kademlia/routing_table.cpp:293 os << "]\n";
}
}
@@ -2847,7 +2590,7 @@ bool compare_bucket_refresh(routing_table_node const& lhs, routing_table_nod
node_id mask = generate_prefix_mask(num_bits);
// target = (target & ~mask) | (root & mask)
- | ||
relevance 0 | ../include/libtorrent/config.hpp:326 | Make this count Unicode characters instead of bytes on windows |
Make this count Unicode characters instead of bytes on windows../include/libtorrent/config.hpp:326
+ | ||
relevance 0 | ../include/libtorrent/config.hpp:326 | Make this count Unicode characters instead of bytes on windows |
Make this count Unicode characters instead of bytes on windows../include/libtorrent/config.hpp:326
// ==== eCS(OS/2) ===
#elif defined __OS2__
#define TORRENT_OS2
@@ -2898,7 +2641,7 @@ bool compare_bucket_refresh(routing_table_node const& lhs, routing_table_nod
#include <stdarg.h>
// internal
- | ||
relevance 0 | ../include/libtorrent/peer_connection.hpp:729 | make this private |
make this private../include/libtorrent/peer_connection.hpp:729 void set_soft_packet_size(int size) { m_soft_packet_size = size; }
+ | ||
relevance 0 | ../include/libtorrent/peer_connection.hpp:729 | make this private |
make this private../include/libtorrent/peer_connection.hpp:729 void set_soft_packet_size(int size) { m_soft_packet_size = size; }
// if allow_encrypted is false, and the torrent 'ih' turns out
// to be an encrypted torrent (AES-256 encrypted) the peer will
@@ -2949,7 +2692,7 @@ bool compare_bucket_refresh(routing_table_node const& lhs, routing_table_nod
// we have choked the upload to the peer
bool m_choked:1;
- | ||
relevance 0 | ../include/libtorrent/peer_connection.hpp:810 | make these private as well |
make these private as well../include/libtorrent/peer_connection.hpp:810
+ | ||
relevance 0 | ../include/libtorrent/peer_connection.hpp:810 | make these private as well |
make these private as well../include/libtorrent/peer_connection.hpp:810
// when this is set, the peer_connection socket is
// corked, similar to the linux TCP feature TCP_CORK.
// we won't send anything to the actual socket, just
@@ -3000,7 +2743,7 @@ bool compare_bucket_refresh(routing_table_node const& lhs, routing_table_nod
sliding_average<20> m_send_rate;
private:
- | ||
relevance 0 | ../include/libtorrent/proxy_base.hpp:166 | it would be nice to remember the bind port and bind once we know where the proxy is m_sock.bind(endpoint, ec); |
it would be nice to remember the bind port and bind once we know where the proxy is
+ | ||
relevance 0 | ../include/libtorrent/proxy_base.hpp:166 | it would be nice to remember the bind port and bind once we know where the proxy is m_sock.bind(endpoint, ec); |
it would be nice to remember the bind port and bind once we know where the proxy is
m_sock.bind(endpoint, ec);../include/libtorrent/proxy_base.hpp:166 {
return m_sock.get_option(opt, ec);
}
@@ -3052,7 +2795,7 @@ m_sock.bind(endpoint, ec);../include/libtorrent/proxy_base.hpp:166
m_sock.close(ec);
m_resolver.cancel();
}
- | ||
relevance 0 | ../include/libtorrent/stat.hpp:113 | this is 4 bytes of padding! |
this is 4 bytes of padding!../include/libtorrent/stat.hpp:113
+ | ||
relevance 0 | ../include/libtorrent/stat.hpp:113 | this is 4 bytes of padding! |
this is 4 bytes of padding!../include/libtorrent/stat.hpp:113
int counter() const { return m_counter; }
void clear()
@@ -3103,10 +2846,7 @@ m_sock.bind(endpoint, ec);../include/libtorrent/proxy_base.hpp:166
#endif
}
- | ||
relevance 0 | ../include/libtorrent/torrent.hpp:1349 | there's space for another 2 bits here |
there's space for another 2 bits here../include/libtorrent/torrent.hpp:1349 // session_impl's m_state_update list, this bit is set
- // to never add the same torrent twice
- bool m_in_state_updates:1;
-
+ | ||
relevance 0 | ../include/libtorrent/torrent.hpp:1351 | there's space for another bit here |
there's space for another bit here../include/libtorrent/torrent.hpp:1351
// these represent whether or not this torrent is counted
// in the total counters of active seeds and downloads
// in the session.
@@ -3123,6 +2863,9 @@ m_sock.bind(endpoint, ec);../include/libtorrent/proxy_base.hpp:166
// more blocks to disk!
bool m_deleted:1;
+ // set to true while moving the storage
+ bool m_moving_storage:1;
+
// ----
@@ -3154,7 +2897,7 @@ m_sock.bind(endpoint, ec);../include/libtorrent/proxy_base.hpp:166
// if this is true, libtorrent may pause and resume
// this torrent depending on queuing rules. Torrents
- | ||
relevance 0 | ../include/libtorrent/torrent_info.hpp:123 | include the number of peers received from this tracker, at last announce |
include the number of peers received from this tracker, at last announce../include/libtorrent/torrent_info.hpp:123
+ | ||
relevance 0 | ../include/libtorrent/torrent_info.hpp:123 | include the number of peers received from this tracker, at last announce |
include the number of peers received from this tracker, at last announce../include/libtorrent/torrent_info.hpp:123
// if this tracker failed the last time it was contacted
// this error code specifies what error occurred
error_code last_error;
@@ -3205,7 +2948,7 @@ m_sock.bind(endpoint, ec);../include/libtorrent/proxy_base.hpp:166
// flags for the source bitmask, each indicating where
// we heard about this tracker
enum tracker_source
- | ||
relevance 0 | ../include/libtorrent/upnp.hpp:121 | support using the windows API for UPnP operations as well |
support using the windows API for UPnP operations as well../include/libtorrent/upnp.hpp:121 {
+ | ||
relevance 0 | ../include/libtorrent/upnp.hpp:121 | support using the windows API for UPnP operations as well |
support using the windows API for UPnP operations as well../include/libtorrent/upnp.hpp:121 {
virtual const char* name() const BOOST_SYSTEM_NOEXCEPT;
virtual std::string message(int ev) const BOOST_SYSTEM_NOEXCEPT;
virtual boost::system::error_condition default_error_condition(int ev) const BOOST_SYSTEM_NOEXCEPT
@@ -3256,4 +2999,55 @@ public:
// is -1, which means failure. There will not be any error alert notification for
// mappings that fail with a -1 return value.
int add_mapping(protocol_type p, int external_port, int local_port);
+ | ||
relevance 0 | ../include/libtorrent/utp_stream.hpp:378 | implement blocking write. Low priority since it's not used (yet) |
implement blocking write. Low priority since it's not used (yet)../include/libtorrent/utp_stream.hpp:378 for (typename Mutable_Buffers::const_iterator i = buffers.begin()
+ , end(buffers.end()); i != end; ++i)
+ {
+ using asio::buffer_cast;
+ using asio::buffer_size;
+ add_read_buffer(buffer_cast<void*>(*i), buffer_size(*i));
+#if TORRENT_USE_ASSERTS
+ buf_size += buffer_size(*i);
+#endif
+ }
+ std::size_t ret = read_some(true);
+ TORRENT_ASSERT(ret <= buf_size);
+ TORRENT_ASSERT(ret > 0);
+ return ret;
+ }
+
+ template <class Const_Buffers>
+ std::size_t write_some(Const_Buffers const& buffers, error_code& ec)
+ {
+ TORRENT_ASSERT(false && "not implemented!");
+ return 0;
+ }
+
+#ifndef BOOST_NO_EXCEPTIONS
+ template <class Mutable_Buffers>
+ std::size_t read_some(Mutable_Buffers const& buffers)
+ {
+ error_code ec;
+ std::size_t ret = read_some(buffers, ec);
+ if (ec)
+ boost::throw_exception(boost::system::system_error(ec));
+ return ret;
+ }
+
+ template <class Const_Buffers>
+ std::size_t write_some(Const_Buffers const& buffers)
+ {
+ error_code ec;
+ std::size_t ret = write_some(buffers, ec);
+ if (ec)
+ boost::throw_exception(boost::system::system_error(ec));
+ return ret;
+ }
+#endif
+
+ template <class Handler>
+ void async_write_some(boost::asio::null_buffers const& buffers, Handler const& handler)
+ {
+ TORRENT_ASSERT(false);
+ }
+
| ||