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.
115 lines
2.4 KiB
115 lines
2.4 KiB
//
|
|
// Created by mwo on 16/05/17.
|
|
//
|
|
|
|
#ifndef XMRBLOCKS_CURRENTBLOCKCHAINSTATUS_H
|
|
#define XMRBLOCKS_CURRENTBLOCKCHAINSTATUS_H
|
|
|
|
#include "MicroCore.h"
|
|
|
|
#include <boost/algorithm/string.hpp>
|
|
|
|
#include <iostream>
|
|
#include <memory>
|
|
#include <thread>
|
|
#include <mutex>
|
|
#include <atomic>
|
|
|
|
namespace xmreg
|
|
{
|
|
|
|
using namespace std;
|
|
|
|
namespace bf = boost::filesystem;
|
|
|
|
struct CurrentBlockchainStatus
|
|
{
|
|
|
|
struct Emission
|
|
{
|
|
uint64_t coinbase;
|
|
uint64_t fee;
|
|
uint64_t blk_no;
|
|
|
|
inline uint64_t
|
|
checksum() const
|
|
{
|
|
return coinbase + fee + blk_no;
|
|
}
|
|
|
|
operator
|
|
std::string() const
|
|
{
|
|
return to_string(blk_no) + "," + to_string(coinbase)
|
|
+ "," + to_string(fee) + "," + to_string(checksum());
|
|
}
|
|
};
|
|
|
|
static bf::path blockchain_path;
|
|
|
|
static cryptonote::network_type nettype;
|
|
|
|
static string output_file;
|
|
|
|
static string deamon_url;
|
|
|
|
// how many blocks to read before thread goes to sleep
|
|
static uint64_t blockchain_chunk_size;
|
|
|
|
// gap from what we store total_emission_atomic and
|
|
// current blockchain height. We dont want to store
|
|
// what is on, e.g., top block, as this can get messy
|
|
// if the block gets orphaned or blockchain reorganization
|
|
// occurs. So the top 3 blocks (default number) will always
|
|
// be calculated in flight and added to what we have so far.
|
|
static uint64_t blockchain_chunk_gap;
|
|
|
|
// current blockchain height and
|
|
// hash of top block
|
|
static atomic<uint64_t> current_height;
|
|
|
|
|
|
static atomic<Emission> total_emission_atomic;
|
|
|
|
|
|
static boost::thread m_thread;
|
|
|
|
static atomic<bool> is_running;
|
|
|
|
// make object for accessing the blockchain here
|
|
static MicroCore* mcore;
|
|
static Blockchain* core_storage;
|
|
|
|
static void
|
|
start_monitor_blockchain_thread();
|
|
|
|
static void
|
|
set_blockchain_variables(MicroCore* _mcore,
|
|
Blockchain* _core_storage);
|
|
|
|
static void
|
|
update_current_emission_amount();
|
|
|
|
static Emission
|
|
calculate_emission_in_blocks(uint64_t start_blk, uint64_t end_blk);
|
|
|
|
static bool
|
|
save_current_emission_amount();
|
|
|
|
static bool
|
|
load_current_emission_amount();
|
|
|
|
static Emission
|
|
get_emission();
|
|
|
|
static bf::path
|
|
get_output_file_path();
|
|
|
|
static bool
|
|
is_thread_running();
|
|
};
|
|
|
|
}
|
|
|
|
#endif //XMRBLOCKS_CURRENTBLOCKCHAINSTATUS_H
|