You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
1121 lines
40 KiB
1121 lines
40 KiB
// Copyright (c) 2014-2020, The Monero Project
|
|
//
|
|
// All rights reserved.
|
|
//
|
|
// Redistribution and use in source and binary forms, with or without modification, are
|
|
// permitted provided that the following conditions are met:
|
|
//
|
|
// 1. Redistributions of source code must retain the above copyright notice, this list of
|
|
// conditions and the following disclaimer.
|
|
//
|
|
// 2. 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.
|
|
//
|
|
// 3. Neither the name of the copyright holder 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 HOLDER 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.
|
|
//
|
|
// Parts of this file are originally copyright (c) 2012-2013 The Cryptonote developers
|
|
|
|
#pragma once
|
|
|
|
#include <ctime>
|
|
|
|
#include <boost/function.hpp>
|
|
#include <boost/program_options/options_description.hpp>
|
|
#include <boost/program_options/variables_map.hpp>
|
|
|
|
#include "cryptonote_basic/fwd.h"
|
|
#include "cryptonote_core/i_core_events.h"
|
|
#include "cryptonote_protocol/cryptonote_protocol_handler_common.h"
|
|
#include "cryptonote_protocol/enums.h"
|
|
#include "storages/portable_storage_template_helper.h"
|
|
#include "common/download.h"
|
|
#include "common/command_line.h"
|
|
#include "tx_pool.h"
|
|
#include "blockchain.h"
|
|
#include "cryptonote_basic/miner.h"
|
|
#include "cryptonote_basic/connection_context.h"
|
|
#include "warnings.h"
|
|
#include "crypto/hash.h"
|
|
#include "span.h"
|
|
#include "rpc/fwd.h"
|
|
|
|
PUSH_WARNINGS
|
|
DISABLE_VS_WARNINGS(4355)
|
|
|
|
namespace cryptonote
|
|
{
|
|
struct test_options {
|
|
const std::pair<uint8_t, uint64_t> *hard_forks;
|
|
const size_t long_term_block_weight_window;
|
|
};
|
|
|
|
extern const command_line::arg_descriptor<std::string, false, true, 2> arg_data_dir;
|
|
extern const command_line::arg_descriptor<bool, false> arg_testnet_on;
|
|
extern const command_line::arg_descriptor<bool, false> arg_stagenet_on;
|
|
extern const command_line::arg_descriptor<bool, false> arg_regtest_on;
|
|
extern const command_line::arg_descriptor<difficulty_type> arg_fixed_difficulty;
|
|
extern const command_line::arg_descriptor<bool> arg_offline;
|
|
extern const command_line::arg_descriptor<size_t> arg_block_download_max_size;
|
|
extern const command_line::arg_descriptor<bool> arg_sync_pruned_blocks;
|
|
|
|
/************************************************************************/
|
|
/* */
|
|
/************************************************************************/
|
|
|
|
/**
|
|
* @brief handles core cryptonote functionality
|
|
*
|
|
* This class coordinates cryptonote functionality including, but not
|
|
* limited to, communication among the Blockchain, the transaction pool,
|
|
* any miners, and the network.
|
|
*/
|
|
class core final: public i_miner_handler, public i_core_events
|
|
{
|
|
public:
|
|
|
|
/**
|
|
* @brief constructor
|
|
*
|
|
* sets member variables into a usable state
|
|
*
|
|
* @param pprotocol pre-constructed protocol object to store and use
|
|
*/
|
|
core(i_cryptonote_protocol* pprotocol);
|
|
|
|
/**
|
|
* @copydoc Blockchain::handle_get_objects
|
|
*
|
|
* @note see Blockchain::handle_get_objects()
|
|
* @param context connection context associated with the request
|
|
*/
|
|
bool handle_get_objects(NOTIFY_REQUEST_GET_OBJECTS::request& arg, NOTIFY_RESPONSE_GET_OBJECTS::request& rsp, cryptonote_connection_context& context);
|
|
|
|
/**
|
|
* @brief calls various idle routines
|
|
*
|
|
* @note see miner::on_idle and tx_memory_pool::on_idle
|
|
*
|
|
* @return true
|
|
*/
|
|
bool on_idle();
|
|
|
|
/**
|
|
* @brief handles an incoming transaction
|
|
*
|
|
* Parses an incoming transaction and, if nothing is obviously wrong,
|
|
* passes it along to the transaction pool
|
|
*
|
|
* @param tx_blob the tx to handle
|
|
* @param tvc metadata about the transaction's validity
|
|
* @param tx_relay how the transaction was received
|
|
* @param relayed whether or not the transaction was relayed to us
|
|
*
|
|
* @return true if the transaction was accepted, false otherwise
|
|
*/
|
|
bool handle_incoming_tx(const tx_blob_entry& tx_blob, tx_verification_context& tvc, relay_method tx_relay, bool relayed);
|
|
|
|
/**
|
|
* @brief handles a list of incoming transactions
|
|
*
|
|
* Parses incoming transactions and, if nothing is obviously wrong,
|
|
* passes them along to the transaction pool
|
|
*
|
|
* @pre `tx_blobs.size() == tvc.size()`
|
|
*
|
|
* @param tx_blobs the txs to handle
|
|
* @param tvc metadata about the transactions' validity
|
|
* @param tx_relay how the transaction was received.
|
|
* @param relayed whether or not the transactions were relayed to us
|
|
*
|
|
* @return true if the transactions were accepted, false otherwise
|
|
*/
|
|
bool handle_incoming_txs(epee::span<const tx_blob_entry> tx_blobs, epee::span<tx_verification_context> tvc, relay_method tx_relay, bool relayed);
|
|
|
|
/**
|
|
* @brief handles a list of incoming transactions
|
|
*
|
|
* Parses incoming transactions and, if nothing is obviously wrong,
|
|
* passes them along to the transaction pool
|
|
*
|
|
* @param tx_blobs the txs to handle
|
|
* @param tvc metadata about the transactions' validity
|
|
* @param tx_relay how the transaction was received.
|
|
* @param relayed whether or not the transactions were relayed to us
|
|
*
|
|
* @return true if the transactions were accepted, false otherwise
|
|
*/
|
|
bool handle_incoming_txs(const std::vector<tx_blob_entry>& tx_blobs, std::vector<tx_verification_context>& tvc, relay_method tx_relay, bool relayed)
|
|
{
|
|
tvc.resize(tx_blobs.size());
|
|
return handle_incoming_txs(epee::to_span(tx_blobs), epee::to_mut_span(tvc), tx_relay, relayed);
|
|
}
|
|
|
|
/**
|
|
* @brief handles an incoming block
|
|
*
|
|
* periodic update to checkpoints is triggered here
|
|
* Attempts to add the block to the Blockchain and, on success,
|
|
* optionally updates the miner's block template.
|
|
*
|
|
* @param block_blob the block to be added
|
|
* @param block the block to be added, or NULL
|
|
* @param bvc return-by-reference metadata context about the block's validity
|
|
* @param update_miner_blocktemplate whether or not to update the miner's block template
|
|
*
|
|
* @return false if loading new checkpoints fails, or the block is not
|
|
* added, otherwise true
|
|
*/
|
|
bool handle_incoming_block(const blobdata& block_blob, const block *b, block_verification_context& bvc, bool update_miner_blocktemplate = true);
|
|
|
|
/**
|
|
* @copydoc Blockchain::prepare_handle_incoming_blocks
|
|
*
|
|
* @note see Blockchain::prepare_handle_incoming_blocks
|
|
*/
|
|
bool prepare_handle_incoming_blocks(const std::vector<block_complete_entry> &blocks_entry, std::vector<block> &blocks);
|
|
|
|
/**
|
|
* @copydoc Blockchain::cleanup_handle_incoming_blocks
|
|
*
|
|
* @note see Blockchain::cleanup_handle_incoming_blocks
|
|
*/
|
|
bool cleanup_handle_incoming_blocks(bool force_sync = false);
|
|
|
|
/**
|
|
* @brief check the size of a block against the current maximum
|
|
*
|
|
* @param block_blob the block to check
|
|
*
|
|
* @return whether or not the block is too big
|
|
*/
|
|
bool check_incoming_block_size(const blobdata& block_blob) const;
|
|
|
|
/**
|
|
* @brief get the cryptonote protocol instance
|
|
*
|
|
* @return the instance
|
|
*/
|
|
i_cryptonote_protocol* get_protocol(){return m_pprotocol;}
|
|
|
|
//-------------------- i_miner_handler -----------------------
|
|
|
|
/**
|
|
* @brief stores and relays a block found by a miner
|
|
*
|
|
* Updates the miner's target block, attempts to store the found
|
|
* block in Blockchain, and -- on success -- relays that block to
|
|
* the network.
|
|
*
|
|
* @param b the block found
|
|
* @param bvc returns the block verification flags
|
|
*
|
|
* @return true if the block was added to the main chain, otherwise false
|
|
*/
|
|
virtual bool handle_block_found(block& b, block_verification_context &bvc);
|
|
|
|
/**
|
|
* @copydoc Blockchain::create_block_template
|
|
*
|
|
* @note see Blockchain::create_block_template
|
|
*/
|
|
virtual bool get_block_template(block& b, const account_public_address& adr, difficulty_type& diffic, uint64_t& height, uint64_t& expected_reward, const blobdata& ex_nonce, uint64_t &seed_height, crypto::hash &seed_hash);
|
|
virtual bool get_block_template(block& b, const crypto::hash *prev_block, const account_public_address& adr, difficulty_type& diffic, uint64_t& height, uint64_t& expected_reward, const blobdata& ex_nonce, uint64_t &seed_height, crypto::hash &seed_hash);
|
|
|
|
/**
|
|
* @brief called when a transaction is relayed.
|
|
* @note Should only be invoked from `levin_notify`.
|
|
*/
|
|
virtual void on_transactions_relayed(epee::span<const cryptonote::blobdata> tx_blobs, relay_method tx_relay) final;
|
|
|
|
|
|
/**
|
|
* @brief gets the miner instance
|
|
*
|
|
* @return a reference to the miner instance
|
|
*/
|
|
miner& get_miner(){return m_miner;}
|
|
|
|
/**
|
|
* @brief gets the miner instance (const)
|
|
*
|
|
* @return a const reference to the miner instance
|
|
*/
|
|
const miner& get_miner()const{return m_miner;}
|
|
|
|
/**
|
|
* @brief adds command line options to the given options set
|
|
*
|
|
* As of now, there are no command line options specific to core,
|
|
* so this function simply returns.
|
|
*
|
|
* @param desc return-by-reference the command line options set to add to
|
|
*/
|
|
static void init_options(boost::program_options::options_description& desc);
|
|
|
|
/**
|
|
* @brief initializes the core as needed
|
|
*
|
|
* This function initializes the transaction pool, the Blockchain, and
|
|
* a miner instance with parameters given on the command line (or defaults)
|
|
*
|
|
* @param vm command line parameters
|
|
* @param test_options configuration options for testing
|
|
* @param get_checkpoints if set, will be called to get checkpoints data, must return checkpoints data pointer and size or nullptr if there ain't any checkpoints for specific network type
|
|
*
|
|
* @return false if one of the init steps fails, otherwise true
|
|
*/
|
|
bool init(const boost::program_options::variables_map& vm, const test_options *test_options = NULL, const GetCheckpointsCallback& get_checkpoints = nullptr);
|
|
|
|
/**
|
|
* @copydoc Blockchain::reset_and_set_genesis_block
|
|
*
|
|
* @note see Blockchain::reset_and_set_genesis_block
|
|
*/
|
|
bool set_genesis_block(const block& b);
|
|
|
|
/**
|
|
* @brief performs safe shutdown steps for core and core components
|
|
*
|
|
* Uninitializes the miner instance, transaction pool, and Blockchain
|
|
*
|
|
* @return true
|
|
*/
|
|
bool deinit();
|
|
|
|
/**
|
|
* @brief sets to drop blocks downloaded (for testing)
|
|
*/
|
|
void test_drop_download();
|
|
|
|
/**
|
|
* @brief sets to drop blocks downloaded below a certain height
|
|
*
|
|
* @param height height below which to drop blocks
|
|
*/
|
|
void test_drop_download_height(uint64_t height);
|
|
|
|
/**
|
|
* @brief gets whether or not to drop blocks (for testing)
|
|
*
|
|
* @return whether or not to drop blocks
|
|
*/
|
|
bool get_test_drop_download() const;
|
|
|
|
/**
|
|
* @brief gets whether or not to drop blocks
|
|
*
|
|
* If the current blockchain height <= our block drop threshold
|
|
* and test drop blocks is set, return true
|
|
*
|
|
* @return see above
|
|
*/
|
|
bool get_test_drop_download_height() const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_current_blockchain_height
|
|
*
|
|
* @note see Blockchain::get_current_blockchain_height()
|
|
*/
|
|
uint64_t get_current_blockchain_height() const;
|
|
|
|
/**
|
|
* @brief get the hash and height of the most recent block
|
|
*
|
|
* @param height return-by-reference height of the block
|
|
* @param top_id return-by-reference hash of the block
|
|
*/
|
|
void get_blockchain_top(uint64_t& height, crypto::hash& top_id) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_blocks(uint64_t, size_t, std::vector<std::pair<cryptonote::blobdata,block>>&, std::vector<transaction>&) const
|
|
*
|
|
* @note see Blockchain::get_blocks(uint64_t, size_t, std::vector<std::pair<cryptonote::blobdata,block>>&, std::vector<transaction>&) const
|
|
*/
|
|
bool get_blocks(uint64_t start_offset, size_t count, std::vector<std::pair<cryptonote::blobdata,block>>& blocks, std::vector<cryptonote::blobdata>& txs) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_blocks(uint64_t, size_t, std::vector<std::pair<cryptonote::blobdata,block>>&) const
|
|
*
|
|
* @note see Blockchain::get_blocks(uint64_t, size_t, std::vector<std::pair<cryptonote::blobdata,block>>&) const
|
|
*/
|
|
bool get_blocks(uint64_t start_offset, size_t count, std::vector<std::pair<cryptonote::blobdata,block>>& blocks) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_blocks(uint64_t, size_t, std::vector<std::pair<cryptonote::blobdata,block>>&) const
|
|
*
|
|
* @note see Blockchain::get_blocks(uint64_t, size_t, std::vector<std::pair<cryptonote::blobdata,block>>&) const
|
|
*/
|
|
bool get_blocks(uint64_t start_offset, size_t count, std::vector<block>& blocks) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_blocks(const t_ids_container&, t_blocks_container&, t_missed_container&) const
|
|
*
|
|
* @note see Blockchain::get_blocks(const t_ids_container&, t_blocks_container&, t_missed_container&) const
|
|
*/
|
|
template<class t_ids_container, class t_blocks_container, class t_missed_container>
|
|
bool get_blocks(const t_ids_container& block_ids, t_blocks_container& blocks, t_missed_container& missed_bs) const
|
|
{
|
|
return m_blockchain_storage.get_blocks(block_ids, blocks, missed_bs);
|
|
}
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_block_id_by_height
|
|
*
|
|
* @note see Blockchain::get_block_id_by_height
|
|
*/
|
|
crypto::hash get_block_id_by_height(uint64_t height) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_transactions
|
|
*
|
|
* @note see Blockchain::get_transactions
|
|
*/
|
|
bool get_transactions(const std::vector<crypto::hash>& txs_ids, std::vector<cryptonote::blobdata>& txs, std::vector<crypto::hash>& missed_txs) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_transactions
|
|
*
|
|
* @note see Blockchain::get_transactions
|
|
*/
|
|
bool get_split_transactions_blobs(const std::vector<crypto::hash>& txs_ids, std::vector<std::tuple<crypto::hash, cryptonote::blobdata, crypto::hash, cryptonote::blobdata>>& txs, std::vector<crypto::hash>& missed_txs) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_transactions
|
|
*
|
|
* @note see Blockchain::get_transactions
|
|
*/
|
|
bool get_transactions(const std::vector<crypto::hash>& txs_ids, std::vector<transaction>& txs, std::vector<crypto::hash>& missed_txs) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_block_by_hash
|
|
*
|
|
* @note see Blockchain::get_block_by_hash
|
|
*/
|
|
bool get_block_by_hash(const crypto::hash &h, block &blk, bool *orphan = NULL) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_alternative_blocks
|
|
*
|
|
* @note see Blockchain::get_alternative_blocks(std::vector<block>&) const
|
|
*/
|
|
bool get_alternative_blocks(std::vector<block>& blocks) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_alternative_blocks_count
|
|
*
|
|
* @note see Blockchain::get_alternative_blocks_count() const
|
|
*/
|
|
size_t get_alternative_blocks_count() const;
|
|
|
|
/**
|
|
* @brief set the pointer to the cryptonote protocol object to use
|
|
*
|
|
* @param pprotocol the pointer to set ours as
|
|
*/
|
|
void set_cryptonote_protocol(i_cryptonote_protocol* pprotocol);
|
|
|
|
/**
|
|
* @copydoc Blockchain::set_checkpoints
|
|
*
|
|
* @note see Blockchain::set_checkpoints()
|
|
*/
|
|
void set_checkpoints(checkpoints&& chk_pts);
|
|
|
|
/**
|
|
* @brief set the file path to read from when loading checkpoints
|
|
*
|
|
* @param path the path to set ours as
|
|
*/
|
|
void set_checkpoints_file_path(const std::string& path);
|
|
|
|
/**
|
|
* @brief set whether or not we enforce DNS checkpoints
|
|
*
|
|
* @param enforce_dns enforce DNS checkpoints or not
|
|
*/
|
|
void set_enforce_dns_checkpoints(bool enforce_dns);
|
|
|
|
/**
|
|
* @brief set a listener for txes being added to the txpool
|
|
*
|
|
* @param callable to notify, or empty function to disable.
|
|
*/
|
|
void set_txpool_listener(boost::function<void(std::vector<txpool_event>)> zmq_pub);
|
|
|
|
/**
|
|
* @brief set whether or not to enable or disable DNS checkpoints
|
|
*
|
|
* @param disble whether to disable DNS checkpoints
|
|
*/
|
|
void disable_dns_checkpoints(bool disable = true) { m_disable_dns_checkpoints = disable; }
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::have_tx
|
|
*
|
|
* @note see tx_memory_pool::have_tx
|
|
*/
|
|
bool pool_has_tx(const crypto::hash &txid) const;
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::get_transactions
|
|
* @param include_sensitive_txes include private transactions
|
|
*
|
|
* @note see tx_memory_pool::get_transactions
|
|
*/
|
|
bool get_pool_transactions(std::vector<transaction>& txs, bool include_sensitive_txes = false) const;
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::get_txpool_backlog
|
|
* @param include_sensitive_txes include private transactions
|
|
*
|
|
* @note see tx_memory_pool::get_txpool_backlog
|
|
*/
|
|
bool get_txpool_backlog(std::vector<tx_backlog_entry>& backlog, bool include_sensitive_txes = false) const;
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::get_transactions
|
|
* @param include_sensitive_txes include private transactions
|
|
*
|
|
* @note see tx_memory_pool::get_transactions
|
|
*/
|
|
bool get_pool_transaction_hashes(std::vector<crypto::hash>& txs, bool include_sensitive_txes = false) const;
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::get_transactions
|
|
* @param include_sensitive_txes include private transactions
|
|
*
|
|
* @note see tx_memory_pool::get_transactions
|
|
*/
|
|
bool get_pool_transaction_stats(struct txpool_stats& stats, bool include_sensitive_txes = false) const;
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::get_transaction
|
|
*
|
|
* @note see tx_memory_pool::get_transaction
|
|
*/
|
|
bool get_pool_transaction(const crypto::hash& id, cryptonote::blobdata& tx, relay_category tx_category) const;
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::get_pool_transactions_and_spent_keys_info
|
|
* @param include_sensitive_txes include private transactions
|
|
*
|
|
* @note see tx_memory_pool::get_pool_transactions_and_spent_keys_info
|
|
*/
|
|
bool get_pool_transactions_and_spent_keys_info(std::vector<tx_info>& tx_infos, std::vector<spent_key_image_info>& key_image_infos, bool include_sensitive_txes = false) const;
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::get_pool_for_rpc
|
|
*
|
|
* @note see tx_memory_pool::get_pool_for_rpc
|
|
*/
|
|
bool get_pool_for_rpc(std::vector<cryptonote::rpc::tx_in_pool>& tx_infos, cryptonote::rpc::key_images_with_tx_hashes& key_image_infos) const;
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::get_transactions_count
|
|
* @param include_sensitive_txes include private transactions
|
|
*
|
|
* @note see tx_memory_pool::get_transactions_count
|
|
*/
|
|
size_t get_pool_transactions_count(bool include_sensitive_txes = false) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_total_transactions
|
|
*
|
|
* @note see Blockchain::get_total_transactions
|
|
*/
|
|
size_t get_blockchain_total_transactions() const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::have_block
|
|
*
|
|
* @note see Blockchain::have_block
|
|
*/
|
|
bool have_block(const crypto::hash& id) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_short_chain_history
|
|
*
|
|
* @note see Blockchain::get_short_chain_history
|
|
*/
|
|
bool get_short_chain_history(std::list<crypto::hash>& ids) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::find_blockchain_supplement(const std::list<crypto::hash>&, NOTIFY_RESPONSE_CHAIN_ENTRY::request&) const
|
|
*
|
|
* @note see Blockchain::find_blockchain_supplement(const std::list<crypto::hash>&, NOTIFY_RESPONSE_CHAIN_ENTRY::request&) const
|
|
*/
|
|
bool find_blockchain_supplement(const std::list<crypto::hash>& qblock_ids, bool clip_pruned, NOTIFY_RESPONSE_CHAIN_ENTRY::request& resp) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::find_blockchain_supplement(const uint64_t, const std::list<crypto::hash>&, std::vector<std::pair<cryptonote::blobdata, std::vector<cryptonote::blobdata> > >&, uint64_t&, uint64_t&, size_t) const
|
|
*
|
|
* @note see Blockchain::find_blockchain_supplement(const uint64_t, const std::list<crypto::hash>&, std::vector<std::pair<cryptonote::blobdata, std::vector<transaction> > >&, uint64_t&, uint64_t&, size_t) const
|
|
*/
|
|
bool find_blockchain_supplement(const uint64_t req_start_block, const std::list<crypto::hash>& qblock_ids, std::vector<std::pair<std::pair<cryptonote::blobdata, crypto::hash>, std::vector<std::pair<crypto::hash, cryptonote::blobdata> > > >& blocks, uint64_t& total_height, uint64_t& start_height, bool pruned, bool get_miner_tx_hash, size_t max_count) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_tx_outputs_gindexs
|
|
*
|
|
* @note see Blockchain::get_tx_outputs_gindexs
|
|
*/
|
|
bool get_tx_outputs_gindexs(const crypto::hash& tx_id, std::vector<uint64_t>& indexs) const;
|
|
bool get_tx_outputs_gindexs(const crypto::hash& tx_id, size_t n_txes, std::vector<std::vector<uint64_t>>& indexs) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_tail_id
|
|
*
|
|
* @note see Blockchain::get_tail_id
|
|
*/
|
|
crypto::hash get_tail_id() const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_block_cumulative_difficulty
|
|
*
|
|
* @note see Blockchain::get_block_cumulative_difficulty
|
|
*/
|
|
difficulty_type get_block_cumulative_difficulty(uint64_t height) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_outs
|
|
*
|
|
* @note see Blockchain::get_outs
|
|
*/
|
|
bool get_outs(const COMMAND_RPC_GET_OUTPUTS_BIN::request& req, COMMAND_RPC_GET_OUTPUTS_BIN::response& res) const;
|
|
|
|
/**
|
|
* @copydoc Blockchain::get_output_distribution
|
|
*
|
|
* @brief get per block distribution of outputs of a given amount
|
|
*/
|
|
bool get_output_distribution(uint64_t amount, uint64_t from_height, uint64_t to_height, uint64_t &start_height, std::vector<uint64_t> &distribution, uint64_t &base) const;
|
|
|
|
/**
|
|
* @copydoc miner::pause
|
|
*
|
|
* @note see miner::pause
|
|
*/
|
|
void pause_mine();
|
|
|
|
/**
|
|
* @copydoc miner::resume
|
|
*
|
|
* @note see miner::resume
|
|
*/
|
|
void resume_mine();
|
|
|
|
/**
|
|
* @brief gets the Blockchain instance
|
|
*
|
|
* @return a reference to the Blockchain instance
|
|
*/
|
|
Blockchain& get_blockchain_storage(){return m_blockchain_storage;}
|
|
|
|
/**
|
|
* @brief gets the Blockchain instance (const)
|
|
*
|
|
* @return a const reference to the Blockchain instance
|
|
*/
|
|
const Blockchain& get_blockchain_storage()const{return m_blockchain_storage;}
|
|
|
|
/**
|
|
* @copydoc tx_memory_pool::print_pool
|
|
*
|
|
* @note see tx_memory_pool::print_pool
|
|
*/
|
|
std::string print_pool(bool short_format) const;
|
|
|
|
/**
|
|
* @copydoc miner::on_synchronized
|
|
*
|
|
* @note see miner::on_synchronized
|
|
*/
|
|
void on_synchronized();
|
|
|
|
/**
|
|
* @copydoc Blockchain::safesyncmode
|
|
*
|
|
* 2note see Blockchain::safesyncmode
|
|
*/
|
|
void safesyncmode(const bool onoff);
|
|
|
|
/**
|
|
* @brief sets the target blockchain height
|
|
*
|
|
* @param target_blockchain_height the height to set
|
|
*/
|
|
void set_target_blockchain_height(uint64_t target_blockchain_height);
|
|
|
|
/**
|
|
* @brief gets the target blockchain height
|
|
*
|
|
* @param target_blockchain_height the target height
|
|
*/
|
|
virtual uint64_t get_target_blockchain_height() const override;
|
|
|
|
/**
|
|
* @brief returns the newest hardfork version known to the blockchain
|
|
*
|
|
* @return the version
|
|
*/
|
|
uint8_t get_ideal_hard_fork_version() const;
|
|
|
|
/**
|
|
* @brief return the ideal hard fork version for a given block height
|
|
*
|
|
* @return what it says above
|
|
*/
|
|
uint8_t get_ideal_hard_fork_version(uint64_t height) const;
|
|
|
|
/**
|
|
* @brief return the hard fork version for a given block height
|
|
*
|
|
* @return what it says above
|
|
*/
|
|
uint8_t get_hard_fork_version(uint64_t height) const;
|
|
|
|
/**
|
|
* @brief return the earliest block a given version may activate
|
|
*
|
|
* @return what it says above
|
|
*/
|
|
uint64_t get_earliest_ideal_height_for_version(uint8_t version) const;
|
|
|
|
/**
|
|
* @brief gets start_time
|
|
*
|
|
*/
|
|
std::time_t get_start_time() const;
|
|
|
|
/**
|
|
* @brief tells the Blockchain to update its checkpoints
|
|
*
|
|
* This function will check if enough time has passed since the last
|
|
* time checkpoints were updated and tell the Blockchain to update
|
|
* its checkpoints if it is time. If updating checkpoints fails,
|
|
* the daemon is told to shut down.
|
|
*
|
|
* @note see Blockchain::update_checkpoints()
|
|
*/
|
|
bool update_checkpoints(const bool skip_dns = false);
|
|
|
|
/**
|
|
* @brief tells the daemon to wind down operations and stop running
|
|
*
|
|
* Currently this function raises SIGTERM, allowing the installed signal
|
|
* handlers to do the actual stopping.
|
|
*/
|
|
void graceful_exit();
|
|
|
|
/**
|
|
* @brief stops the daemon running
|
|
*
|
|
* @note see graceful_exit()
|
|
*/
|
|
void stop();
|
|
|
|
/**
|
|
* @copydoc Blockchain::have_tx_keyimg_as_spent
|
|
*
|
|
* @note see Blockchain::have_tx_keyimg_as_spent
|
|
*/
|
|
bool is_key_image_spent(const crypto::key_image& key_im) const;
|
|
|
|
/**
|
|
* @brief check if multiple key images are spent
|
|
*
|
|
* plural version of is_key_image_spent()
|
|
*
|
|
* @param key_im list of key images to check
|
|
* @param spent return-by-reference result for each image checked
|
|
*
|
|
* @return true
|
|
*/
|
|
bool are_key_images_spent(const std::vector<crypto::key_image>& key_im, std::vector<bool> &spent) const;
|
|
|
|
/**
|
|
* @brief check if multiple key images are spent in the transaction pool
|
|
*
|
|
* @param key_im list of key images to check
|
|
* @param spent return-by-reference result for each image checked
|
|
*
|
|
* @return true
|
|
*/
|
|
bool are_key_images_spent_in_pool(const std::vector<crypto::key_image>& key_im, std::vector<bool> &spent) const;
|
|
|
|
/**
|
|
* @brief get the number of blocks to sync in one go
|
|
*
|
|
* @return the number of blocks to sync in one go
|
|
*/
|
|
size_t get_block_sync_size(uint64_t height) const;
|
|
|
|
/**
|
|
* @brief get the sum of coinbase tx amounts between blocks
|
|
*
|
|
* @return the number of blocks to sync in one go
|
|
*/
|
|
std::pair<boost::multiprecision::uint128_t, boost::multiprecision::uint128_t> get_coinbase_tx_sum(const uint64_t start_offset, const size_t count);
|
|
|
|
/**
|
|
* @brief get the network type we're on
|
|
*
|
|
* @return which network are we on?
|
|
*/
|
|
network_type get_nettype() const { return m_nettype; };
|
|
|
|
/**
|
|
* @brief check whether an update is known to be available or not
|
|
*
|
|
* This does not actually trigger a check, but returns the result
|
|
* of the last check
|
|
*
|
|
* @return whether an update is known to be available or not
|
|
*/
|
|
bool is_update_available() const { return m_update_available; }
|
|
|
|
/**
|
|
* @brief get whether fluffy blocks are enabled
|
|
*
|
|
* @return whether fluffy blocks are enabled
|
|
*/
|
|
bool fluffy_blocks_enabled() const { return m_fluffy_blocks_enabled; }
|
|
|
|
/**
|
|
* @brief check a set of hashes against the precompiled hash set
|
|
*
|
|
* @return number of usable blocks
|
|
*/
|
|
uint64_t prevalidate_block_hashes(uint64_t height, const std::vector<crypto::hash> &hashes, const std::vector<uint64_t> &weights);
|
|
|
|
/**
|
|
* @brief get free disk space on the blockchain partition
|
|
*
|
|
* @return free space in bytes
|
|
*/
|
|
uint64_t get_free_space() const;
|
|
|
|
/**
|
|
* @brief get whether the core is running offline
|
|
*
|
|
* @return whether the core is running offline
|
|
*/
|
|
bool offline() const { return m_offline; }
|
|
|
|
/**
|
|
* @brief get the blockchain pruning seed
|
|
*
|
|
* @return the blockchain pruning seed
|
|
*/
|
|
uint32_t get_blockchain_pruning_seed() const;
|
|
|
|
/**
|
|
* @brief prune the blockchain
|
|
*
|
|
* @param pruning_seed the seed to use to prune the chain (0 for default, highly recommended)
|
|
*
|
|
* @return true iff success
|
|
*/
|
|
bool prune_blockchain(uint32_t pruning_seed = 0);
|
|
|
|
/**
|
|
* @brief incrementally prunes blockchain
|
|
*
|
|
* @return true on success, false otherwise
|
|
*/
|
|
bool update_blockchain_pruning();
|
|
|
|
/**
|
|
* @brief checks the blockchain pruning if enabled
|
|
*
|
|
* @return true on success, false otherwise
|
|
*/
|
|
bool check_blockchain_pruning();
|
|
|
|
/**
|
|
* @brief checks whether a given block height is included in the precompiled block hash area
|
|
*
|
|
* @param height the height to check for
|
|
*/
|
|
bool is_within_compiled_block_hash_area(uint64_t height) const;
|
|
|
|
/**
|
|
* @brief checks whether block weights are known for the given range
|
|
*/
|
|
bool has_block_weights(uint64_t height, uint64_t nblocks) const;
|
|
|
|
/**
|
|
* @brief flushes the bad txs cache
|
|
*/
|
|
void flush_bad_txs_cache();
|
|
|
|
/**
|
|
* @brief flushes the invalid block cache
|
|
*/
|
|
void flush_invalid_blocks();
|
|
|
|
/**
|
|
* @brief returns the set of transactions in the txpool which are not in the argument
|
|
*
|
|
* @param hashes hashes of transactions to exclude from the result
|
|
*
|
|
* @return true iff success, false otherwise
|
|
*/
|
|
bool get_txpool_complement(const std::vector<crypto::hash> &hashes, std::vector<cryptonote::blobdata> &txes);
|
|
|
|
private:
|
|
|
|
/**
|
|
* @copydoc add_new_tx(transaction&, tx_verification_context&, bool)
|
|
*
|
|
* @param tx_hash the transaction's hash
|
|
* @param blob the transaction as a blob
|
|
* @param tx_weight the weight of the transaction
|
|
* @param tx_relay how the transaction was received
|
|
* @param relayed whether or not the transaction was relayed to us
|
|
*
|
|
*/
|
|
bool add_new_tx(transaction& tx, const crypto::hash& tx_hash, const cryptonote::blobdata &blob, size_t tx_weight, tx_verification_context& tvc, relay_method tx_relay, bool relayed);
|
|
|
|
/**
|
|
* @brief add a new transaction to the transaction pool
|
|
*
|
|
* Adds a new transaction to the transaction pool.
|
|
*
|
|
* @param tx the transaction to add
|
|
* @param tvc return-by-reference metadata about the transaction's verification process
|
|
* @param tx_relay how the transaction was received
|
|
* @param relayed whether or not the transaction was relayed to us
|
|
*
|
|
* @return true if the transaction is already in the transaction pool,
|
|
* is already in a block on the Blockchain, or is successfully added
|
|
* to the transaction pool
|
|
*/
|
|
bool add_new_tx(transaction& tx, tx_verification_context& tvc, relay_method tx_relay, bool relayed);
|
|
|
|
/**
|
|
* @copydoc Blockchain::add_new_block
|
|
*
|
|
* @note see Blockchain::add_new_block
|
|
*/
|
|
bool add_new_block(const block& b, block_verification_context& bvc);
|
|
|
|
/**
|
|
* @brief load any core state stored on disk
|
|
*
|
|
* currently does nothing, but may have state to load in the future.
|
|
*
|
|
* @return true
|
|
*/
|
|
bool load_state_data();
|
|
|
|
/**
|
|
* @copydoc parse_tx_from_blob(transaction&, crypto::hash&, crypto::hash&, const blobdata&) const
|
|
*
|
|
* @note see parse_tx_from_blob(transaction&, crypto::hash&, crypto::hash&, const blobdata&) const
|
|
*/
|
|
bool parse_tx_from_blob(transaction& tx, crypto::hash& tx_hash, const blobdata& blob) const;
|
|
|
|
/**
|
|
* @brief check a transaction's syntax
|
|
*
|
|
* For now this does nothing, but it may check something about the tx
|
|
* in the future.
|
|
*
|
|
* @param tx the transaction to check
|
|
*
|
|
* @return true
|
|
*/
|
|
bool check_tx_syntax(const transaction& tx) const;
|
|
|
|
/**
|
|
* @brief validates some simple properties of a transaction
|
|
*
|
|
* Currently checks: tx has inputs,
|
|
* tx inputs all of supported type(s),
|
|
* tx outputs valid (type, key, amount),
|
|
* input and output total amounts don't overflow,
|
|
* output amount <= input amount,
|
|
* tx not too large,
|
|
* each input has a different key image.
|
|
*
|
|
* @param tx the transaction to check
|
|
* @param keeped_by_block if the transaction has been in a block
|
|
*
|
|
* @return true if all the checks pass, otherwise false
|
|
*/
|
|
bool check_tx_semantic(const transaction& tx, bool keeped_by_block) const;
|
|
void set_semantics_failed(const crypto::hash &tx_hash);
|
|
|
|
bool handle_incoming_tx_pre(const tx_blob_entry& tx_blob, tx_verification_context& tvc, cryptonote::transaction &tx, crypto::hash &tx_hash);
|
|
bool handle_incoming_tx_post(const tx_blob_entry& tx_blob, tx_verification_context& tvc, cryptonote::transaction &tx, crypto::hash &tx_hash);
|
|
struct tx_verification_batch_info { const cryptonote::transaction *tx; crypto::hash tx_hash; tx_verification_context &tvc; bool &result; };
|
|
bool handle_incoming_tx_accumulated_batch(std::vector<tx_verification_batch_info> &tx_info, bool keeped_by_block);
|
|
|
|
/**
|
|
* @copydoc miner::on_block_chain_update
|
|
*
|
|
* @note see miner::on_block_chain_update
|
|
*
|
|
* @return true
|
|
*/
|
|
bool update_miner_block_template();
|
|
|
|
/**
|
|
* @brief act on a set of command line options given
|
|
*
|
|
* @param vm the command line options
|
|
*
|
|
* @return true
|
|
*/
|
|
bool handle_command_line(const boost::program_options::variables_map& vm);
|
|
|
|
/**
|
|
* @brief verify that each input key image in a transaction is unique
|
|
*
|
|
* @param tx the transaction to check
|
|
*
|
|
* @return false if any key image is repeated, otherwise true
|
|
*/
|
|
bool check_tx_inputs_keyimages_diff(const transaction& tx) const;
|
|
|
|
/**
|
|
* @brief verify that each ring uses distinct members
|
|
*
|
|
* @param tx the transaction to check
|
|
*
|
|
* @return false if any ring uses duplicate members, true otherwise
|
|
*/
|
|
bool check_tx_inputs_ring_members_diff(const transaction& tx) const;
|
|
|
|
/**
|
|
* @brief verify that each input key image in a transaction is in
|
|
* the valid domain
|
|
*
|
|
* @param tx the transaction to check
|
|
*
|
|
* @return false if any key image is not in the valid domain, otherwise true
|
|
*/
|
|
bool check_tx_inputs_keyimages_domain(const transaction& tx) const;
|
|
|
|
/**
|
|
* @brief attempts to relay any transactions in the mempool which need it
|
|
*
|
|
* @return true
|
|
*/
|
|
bool relay_txpool_transactions();
|
|
|
|
/**
|
|
* @brief checks DNS versions
|
|
*
|
|
* @return true on success, false otherwise
|
|
*/
|
|
bool check_updates();
|
|
|
|
/**
|
|
* @brief checks free disk space
|
|
*
|
|
* @return true on success, false otherwise
|
|
*/
|
|
bool check_disk_space();
|
|
|
|
/**
|
|
* @brief checks block rate, and warns if it's too slow
|
|
*
|
|
* @return true on success, false otherwise
|
|
*/
|
|
bool check_block_rate();
|
|
|
|
/**
|
|
* @brief recalculate difficulties after the last difficulty checklpoint to circumvent the annoying 'difficulty drift' bug
|
|
*
|
|
* @return true
|
|
*/
|
|
bool recalculate_difficulties();
|
|
|
|
bool m_test_drop_download = true; //!< whether or not to drop incoming blocks (for testing)
|
|
|
|
uint64_t m_test_drop_download_height = 0; //!< height under which to drop incoming blocks, if doing so
|
|
|
|
tx_memory_pool m_mempool; //!< transaction pool instance
|
|
Blockchain m_blockchain_storage; //!< Blockchain instance
|
|
|
|
i_cryptonote_protocol* m_pprotocol; //!< cryptonote protocol instance
|
|
|
|
epee::critical_section m_incoming_tx_lock; //!< incoming transaction lock
|
|
|
|
//m_miner and m_miner_addres are probably temporary here
|
|
miner m_miner; //!< miner instance
|
|
|
|
std::string m_config_folder; //!< folder to look in for configs and other files
|
|
|
|
cryptonote_protocol_stub m_protocol_stub; //!< cryptonote protocol stub instance
|
|
|
|
epee::math_helper::once_a_time_seconds<60*60*12, false> m_store_blockchain_interval; //!< interval for manual storing of Blockchain, if enabled
|
|
epee::math_helper::once_a_time_seconds<60*60*2, true> m_fork_moaner; //!< interval for checking HardFork status
|
|
epee::math_helper::once_a_time_seconds<60*2, false> m_txpool_auto_relayer; //!< interval for checking re-relaying txpool transactions
|
|
epee::math_helper::once_a_time_seconds<60*60*12, true> m_check_updates_interval; //!< interval for checking for new versions
|
|
epee::math_helper::once_a_time_seconds<60*10, true> m_check_disk_space_interval; //!< interval for checking for disk space
|
|
epee::math_helper::once_a_time_seconds<90, false> m_block_rate_interval; //!< interval for checking block rate
|
|
epee::math_helper::once_a_time_seconds<60*60*5, true> m_blockchain_pruning_interval; //!< interval for incremental blockchain pruning
|
|
epee::math_helper::once_a_time_seconds<60*60*24*7, false> m_diff_recalc_interval; //!< interval for recalculating difficulties
|
|
|
|
std::atomic<bool> m_starter_message_showed; //!< has the "daemon will sync now" message been shown?
|
|
|
|
uint64_t m_target_blockchain_height; //!< blockchain height target
|
|
|
|
network_type m_nettype; //!< which network are we on?
|
|
|
|
std::atomic<bool> m_update_available;
|
|
|
|
std::string m_checkpoints_path; //!< path to json checkpoints file
|
|
time_t m_last_dns_checkpoints_update; //!< time when dns checkpoints were last updated
|
|
time_t m_last_json_checkpoints_update; //!< time when json checkpoints were last updated
|
|
|
|
std::atomic_flag m_checkpoints_updating; //!< set if checkpoints are currently updating to avoid multiple threads attempting to update at once
|
|
bool m_disable_dns_checkpoints;
|
|
|
|
size_t block_sync_size;
|
|
|
|
time_t start_time;
|
|
|
|
std::unordered_set<crypto::hash> bad_semantics_txes[2];
|
|
boost::mutex bad_semantics_txes_lock;
|
|
|
|
enum {
|
|
UPDATES_DISABLED,
|
|
UPDATES_NOTIFY,
|
|
UPDATES_DOWNLOAD,
|
|
UPDATES_UPDATE,
|
|
} check_updates_level;
|
|
|
|
tools::download_async_handle m_update_download;
|
|
size_t m_last_update_length;
|
|
boost::mutex m_update_mutex;
|
|
|
|
bool m_fluffy_blocks_enabled;
|
|
bool m_offline;
|
|
|
|
/* `boost::function` is used because the implementation never allocates if
|
|
the callable object has a single `std::shared_ptr` or `std::weap_ptr`
|
|
internally. Whereas, the libstdc++ `std::function` will allocate. */
|
|
|
|
std::shared_ptr<tools::Notify> m_block_rate_notify;
|
|
boost::function<void(std::vector<txpool_event>)> m_zmq_pub;
|
|
};
|
|
}
|
|
|
|
POP_WARNINGS
|