37 #include <unordered_set> 38 #include <boost/thread/recursive_mutex.hpp> 39 #include <boost/uuid/uuid.hpp> 41 #undef ELECTRONEUM_DEFAULT_LOG_CATEGORY 42 #define ELECTRONEUM_DEFAULT_LOG_CATEGORY "cn.block_queue" 46 struct block_complete_entry;
55 std::vector<cryptonote::block_complete_entry>
blocks;
60 boost::posix_time::ptime
time;
85 void reset_next_span_time(boost::posix_time::ptime t = boost::posix_time::microsec_clock::universal_time());
97 bool foreach(std::function<
bool(
const span&)> f)
const;
102 void erase_block(block_map::iterator j);
107 mutable boost::recursive_mutex mutex;
108 std::unordered_set<crypto::hash> requested_hashes;
109 std::unordered_set<crypto::hash> have_blocks;
size_t get_data_size() const
uint64_t get_next_needed_height(uint64_t blockchain_height) const
std::pair< uint64_t, uint64_t > reserve_span(uint64_t first_block_height, uint64_t last_block_height, uint64_t max_blocks, const boost::uuids::uuid &connection_id, uint32_t pruning_seed, uint64_t blockchain_height, const std::vector< crypto::hash > &block_hashes, boost::posix_time::ptime time=boost::posix_time::microsec_clock::universal_time())
bool has_unpruned_height(uint64_t block_height, uint64_t blockchain_height, uint32_t pruning_seed) const
size_t get_num_filled_spans() const
uint64_t start_block_height
void flush_spans(const boost::uuids::uuid &connection_id, bool all=false)
bool operator<(const span &s) const
struct hash_func hashes[]
size_t get_num_filled_spans_prefix() const
void reset_next_span_time(boost::posix_time::ptime t=boost::posix_time::microsec_clock::universal_time())
std::set< span > block_map
float get_download_rate(const boost::uuids::uuid &connection_id) const
std::vector< crypto::hash > hashes
void remove_spans(const boost::uuids::uuid &connection_id, uint64_t start_block_height)
Holds cryptonote related classes and helpers.
span(uint64_t start_block_height, std::vector< cryptonote::block_complete_entry > blocks, const boost::uuids::uuid &connection_id, float rate, size_t size)
void flush_stale_spans(const std::set< boost::uuids::uuid > &live_connections)
std::string get_overview(uint64_t blockchain_height) const
void add_blocks(uint64_t height, std::vector< cryptonote::block_complete_entry > bcel, const boost::uuids::uuid &connection_id, float rate, size_t size)
bool have(const crypto::hash &hash) const
boost::posix_time::ptime time
float get_speed(const boost::uuids::uuid &connection_id) const
unsigned __int64 uint64_t
std::pair< uint64_t, uint64_t > get_next_span_if_scheduled(std::vector< crypto::hash > &hashes, boost::uuids::uuid &connection_id, boost::posix_time::ptime &time) const
bool get_next_span(uint64_t &height, std::vector< cryptonote::block_complete_entry > &bcel, boost::uuids::uuid &connection_id, bool filled=true) const
bool remove_span(uint64_t start_block_height, std::vector< crypto::hash > *hashes=NULL)
bool has_spans(const boost::uuids::uuid &connection_id) const
const T & move(const T &t)
uint64_t get_max_block_height() const
boost::uuids::uuid connection_id
crypto::hash get_last_known_hash(const boost::uuids::uuid &connection_id) const
bool has_next_span(const boost::uuids::uuid &connection_id, bool &filled, boost::posix_time::ptime &time) const
bool requested(const crypto::hash &hash) const
void set_span_hashes(uint64_t start_height, const boost::uuids::uuid &connection_id, std::vector< crypto::hash > hashes)
span(uint64_t start_block_height, uint64_t nblocks, const boost::uuids::uuid &connection_id, boost::posix_time::ptime time)
std::vector< cryptonote::block_complete_entry > blocks