122 lines
3.3 KiB
C++
122 lines
3.3 KiB
C++
/*
|
|
|
|
Copyright (c) 2006, 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 <vector>
|
|
#include <map>
|
|
#include <boost/cstdint.hpp>
|
|
#include <boost/pool/pool.hpp>
|
|
|
|
#include <libtorrent/socket.hpp>
|
|
#include <libtorrent/entry.hpp>
|
|
#include <libtorrent/kademlia/node_id.hpp>
|
|
#include <libtorrent/kademlia/logging.hpp>
|
|
#include <libtorrent/kademlia/observer.hpp>
|
|
|
|
#include "libtorrent/ptime.hpp"
|
|
|
|
namespace libtorrent { namespace dht
|
|
{
|
|
|
|
#ifdef TORRENT_DHT_VERBOSE_LOGGING
|
|
TORRENT_DECLARE_LOG(rpc);
|
|
#endif
|
|
|
|
struct null_observer : public observer
|
|
{
|
|
null_observer(boost::intrusive_ptr<traversal_algorithm>& a): observer(a) {}
|
|
virtual void reply(msg const&) { m_done = true; }
|
|
};
|
|
|
|
class routing_table;
|
|
|
|
class rpc_manager
|
|
{
|
|
public:
|
|
typedef bool (*send_fun)(void* userdata, entry const&, udp::endpoint const&, int);
|
|
|
|
rpc_manager(node_id const& our_id
|
|
, routing_table& table, send_fun const& sf
|
|
, void* userdata);
|
|
~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 target
|
|
, observer_ptr o);
|
|
|
|
void add_our_id(entry& e);
|
|
|
|
#ifdef TORRENT_DEBUG
|
|
size_t allocation_size() const;
|
|
void check_invariant() const;
|
|
#endif
|
|
|
|
boost::pool<>& allocator() const
|
|
{ return m_pool_allocator; }
|
|
|
|
private:
|
|
|
|
enum { max_transaction_id = 0x10000 };
|
|
|
|
boost::uint32_t calc_connection_id(udp::endpoint addr);
|
|
|
|
mutable boost::pool<> m_pool_allocator;
|
|
|
|
typedef std::list<observer_ptr> transactions_t;
|
|
transactions_t m_transactions;
|
|
|
|
// this is the next transaction id to be used
|
|
int m_next_transaction_id;
|
|
|
|
send_fun m_send;
|
|
void* m_userdata;
|
|
node_id m_our_id;
|
|
routing_table& m_table;
|
|
ptime m_timer;
|
|
node_id m_random_number;
|
|
bool m_destructing;
|
|
};
|
|
|
|
} } // namespace libtorrent::dht
|
|
|
|
#endif
|
|
|
|
|