forked from premiere/premiere-libtorrent
added some static and const in node.cpp and minor cleanup in rpc_manager.cpp
This commit is contained in:
parent
0221f6e8a6
commit
80f5edc500
|
@ -821,7 +821,7 @@ void node::incoming_request(msg const& m, entry& e)
|
|||
// mirror back the other node's external port
|
||||
reply["p"] = m.addr.port();
|
||||
|
||||
string_view query = top_level[0].string_value();
|
||||
string_view const query = top_level[0].string_value();
|
||||
|
||||
if (m_observer && m_observer->on_dht_request(query, m, e))
|
||||
return;
|
||||
|
@ -1094,7 +1094,7 @@ void node::incoming_request(msg const& m, entry& e)
|
|||
}
|
||||
else if (query == "get")
|
||||
{
|
||||
key_desc_t msg_desc[] = {
|
||||
static key_desc_t const msg_desc[] = {
|
||||
{"seq", bdecode_node::int_t, 0, key_desc_t::optional},
|
||||
{"target", bdecode_node::string_t, 20, 0},
|
||||
{"want", bdecode_node::list_t, 0, key_desc_t::optional},
|
||||
|
@ -1220,7 +1220,7 @@ void node::write_nodes_entries(sha1_hash const& info_hash
|
|||
|
||||
node::protocol_descriptor const& node::map_protocol_to_descriptor(udp protocol)
|
||||
{
|
||||
static std::array<protocol_descriptor, 2> descriptors =
|
||||
static std::array<protocol_descriptor, 2> const descriptors =
|
||||
{{
|
||||
{udp::v4(), "n4", "nodes"},
|
||||
{udp::v6(), "n6", "nodes6"}
|
||||
|
|
|
@ -47,7 +47,6 @@ POSSIBILITY OF SUCH DAMAGE.
|
|||
#include <libtorrent/kademlia/dht_settings.hpp>
|
||||
|
||||
#include <libtorrent/socket_io.hpp> // for print_endpoint
|
||||
#include <libtorrent/hasher.hpp>
|
||||
#include <libtorrent/aux_/time.hpp> // for aux::time_now
|
||||
#include <libtorrent/aux_/aligned_union.hpp>
|
||||
|
||||
|
@ -241,7 +240,7 @@ void rpc_manager::unreachable(udp::endpoint const& ep)
|
|||
observer_ptr o = i->second;
|
||||
#ifndef TORRENT_DISABLE_LOGGING
|
||||
m_log->log(dht_logger::rpc_manager, "[%u] found transaction [ tid: %d ]"
|
||||
, o->algorithm()->id(), int(i->first));
|
||||
, o->algorithm()->id(), i->first);
|
||||
#endif
|
||||
i = m_transactions.erase(i);
|
||||
o->timeout();
|
||||
|
|
Loading…
Reference in New Issue