/usr/include/bitcoin/session.hpp is in libbitcoin-dev 2.0-2.4.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 | /*
* Copyright (c) 2011-2013 libbitcoin developers (see AUTHORS)
*
* This file is part of libbitcoin.
*
* libbitcoin is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License with
* additional permissions to the one published by the Free Software
* Foundation, either version 3 of the License, or (at your option)
* any later version. For more information see LICENSE.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef LIBBITCOIN_SESSION_HPP
#define LIBBITCOIN_SESSION_HPP
#include <set>
#include <bitcoin/network/hosts.hpp>
#include <bitcoin/network/handshake.hpp>
#include <bitcoin/network/network.hpp>
#include <bitcoin/network/protocol.hpp>
#include <bitcoin/blockchain/blockchain.hpp>
#include <bitcoin/poller.hpp>
#include <bitcoin/transaction_pool.hpp>
namespace libbitcoin {
struct session_params
{
handshake& handshake_;
protocol& protocol_;
blockchain& blockchain_;
poller& poller_;
transaction_pool& transaction_pool_;
};
/**
* Provides a circular buffer of expiring items.
*
* The pumpkin_buffer is used to store transaction inventory hashes
* from the network to avoid re-requesting (and wasting bandwidth).
* Typically the network goes mad over new tx hashes and several nodes
* will notify you at once. This class avoids that.
*
* As transactions come at a fairly constant rate, we can cheat and make
* the items in this structure expire by using a circular buffer that
* overwrites old entries.
*
* Thanks copumpkin.
*/
template <typename Item>
class pumpkin_buffer
{
public:
pumpkin_buffer(size_t max_size)
: max_size_(max_size), pointer_(0) {}
void store(const Item& item)
{
// Fill it up
if (expiry_.size() < max_size_)
{
lookup_.insert(item);
expiry_.push_back(item);
return;
}
// Otherwise we overwrite old entries
BITCOIN_ASSERT(expiry_.size() == max_size_);
BITCOIN_ASSERT(pointer_ < expiry_.size());
// First remove it from the hash lookup set
const Item& erase_item = expiry_[pointer_];
size_t number_erased = lookup_.erase(erase_item);
BITCOIN_ASSERT(number_erased == 1);
// Insert new item and overwrite it in circular buffer
lookup_.insert(item);
expiry_[pointer_] = item;
// Cycle pointer around
pointer_++;
if (pointer_ == expiry_.size())
pointer_ = 0;
}
bool exists(const Item& item)
{
return lookup_.find(item) != lookup_.end();
}
private:
std::set<Item> lookup_;
std::vector<Item> expiry_;
size_t max_size_;
size_t pointer_;
};
class session
{
public:
typedef std::function<void (const std::error_code&)> completion_handler;
session(threadpool& pool, const session_params& params);
void start(completion_handler handle_complete);
void stop(completion_handler handle_complete);
private:
void new_channel(const std::error_code& ec, channel_ptr node);
void set_start_height(const std::error_code& ec, size_t fork_point,
const blockchain::block_list& new_blocks,
const blockchain::block_list& replaced_blocks);
void inventory(const std::error_code& ec,
const inventory_type& packet, channel_ptr node);
void get_data(const std::error_code& ec,
const get_data_type& packet, channel_ptr node);
void get_blocks(const std::error_code& ec,
const get_blocks_type& packet, channel_ptr node);
void new_tx_inventory(const hash_digest& tx_hash, channel_ptr node);
void request_tx_data(bool tx_exists,
const hash_digest& tx_hash, channel_ptr node);
io_service::strand strand_;
handshake& handshake_;
protocol& protocol_;
blockchain& chain_;
poller& poll_;
transaction_pool& tx_pool_;
pumpkin_buffer<hash_digest> grabbed_invs_;
};
} // namespace libbitcoin
#endif
|