141 lines
4.0 KiB
C++
141 lines
4.0 KiB
C++
/*
|
|
|
|
Copyright (c) 2006-2018, Arvid Norberg
|
|
All rights reserved.
|
|
|
|
Redistribution and use in source and binary forms, with or without
|
|
modification, are permitted provided that the following conditions
|
|
are met:
|
|
|
|
* Redistributions of source code must retain the above copyright
|
|
notice, this list of conditions and the following disclaimer.
|
|
* Redistributions in binary form must reproduce the above copyright
|
|
notice, this list of conditions and the following disclaimer in
|
|
the documentation and/or other materials provided with the distribution.
|
|
* Neither the name of the author nor the names of its
|
|
contributors may be used to endorse or promote products derived
|
|
from this software without specific prior written permission.
|
|
|
|
THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
|
AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
|
|
LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
|
CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
|
SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
|
INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
|
CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
|
ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
|
POSSIBILITY OF SUCH DAMAGE.
|
|
|
|
*/
|
|
|
|
#ifndef RPC_MANAGER_HPP
|
|
#define RPC_MANAGER_HPP
|
|
|
|
#include <unordered_map>
|
|
#include <cstdint>
|
|
|
|
#include "libtorrent/aux_/disable_warnings_push.hpp"
|
|
#include <boost/pool/pool.hpp>
|
|
#include "libtorrent/aux_/disable_warnings_pop.hpp"
|
|
|
|
#include <libtorrent/socket.hpp>
|
|
#include <libtorrent/time.hpp>
|
|
#include <libtorrent/kademlia/node_id.hpp>
|
|
#include <libtorrent/kademlia/observer.hpp>
|
|
#include <libtorrent/aux_/listen_socket_handle.hpp>
|
|
|
|
namespace libtorrent { class entry; }
|
|
|
|
namespace libtorrent {
|
|
namespace dht {
|
|
|
|
struct dht_settings;
|
|
struct dht_logger;
|
|
struct socket_manager;
|
|
|
|
struct TORRENT_EXTRA_EXPORT null_observer : observer
|
|
{
|
|
null_observer(std::shared_ptr<traversal_algorithm> a
|
|
, udp::endpoint const& ep, node_id const& id)
|
|
: observer(std::move(a), ep, id) {}
|
|
void reply(msg const&) override { flags |= flag_done; }
|
|
};
|
|
|
|
class routing_table;
|
|
|
|
class TORRENT_EXTRA_EXPORT rpc_manager
|
|
{
|
|
public:
|
|
|
|
rpc_manager(node_id const& our_id
|
|
, dht_settings const& settings
|
|
, routing_table& table
|
|
, aux::listen_socket_handle const& sock
|
|
, socket_manager* sock_man
|
|
, dht_logger* log);
|
|
~rpc_manager();
|
|
|
|
void unreachable(udp::endpoint const& ep);
|
|
|
|
// returns true if the node needs a refresh
|
|
// if so, id is assigned the node id to refresh
|
|
bool incoming(msg const&, node_id* id);
|
|
time_duration tick();
|
|
|
|
bool invoke(entry& e, udp::endpoint const& target
|
|
, observer_ptr o);
|
|
|
|
void add_our_id(entry& e);
|
|
|
|
#if TORRENT_USE_ASSERTS
|
|
size_t allocation_size() const;
|
|
#endif
|
|
#if TORRENT_USE_INVARIANT_CHECKS
|
|
void check_invariant() const;
|
|
#endif
|
|
|
|
template <typename T, typename... Args>
|
|
std::shared_ptr<T> allocate_observer(Args&&... args)
|
|
{
|
|
void* ptr = allocate_observer();
|
|
if (ptr == nullptr) return std::shared_ptr<T>();
|
|
|
|
auto deleter = [this](observer* o)
|
|
{
|
|
o->~observer();
|
|
free_observer(o);
|
|
};
|
|
return std::shared_ptr<T>(new (ptr) T(std::forward<Args>(args)...), deleter);
|
|
}
|
|
|
|
int num_allocated_observers() const { return m_allocated_observers; }
|
|
|
|
void update_node_id(node_id const& id) { m_our_id = id; }
|
|
|
|
private:
|
|
|
|
void* allocate_observer();
|
|
void free_observer(void* ptr);
|
|
|
|
mutable boost::pool<> m_pool_allocator;
|
|
|
|
std::unordered_multimap<int, observer_ptr> m_transactions;
|
|
|
|
aux::listen_socket_handle m_sock;
|
|
socket_manager* m_sock_man;
|
|
#ifndef TORRENT_DISABLE_LOGGING
|
|
dht_logger* m_log;
|
|
#endif
|
|
dht_settings const& m_settings;
|
|
routing_table& m_table;
|
|
node_id m_our_id;
|
|
std::uint32_t m_allocated_observers:31;
|
|
std::uint32_t m_destructing:1;
|
|
};
|
|
|
|
} } // namespace libtorrent::dht
|
|
|
|
#endif
|