mock_daemon Class Reference

#include <daemon.h>

Collaboration diagram for mock_daemon:

Public Types
typedef cryptonote::t_cryptonote_protocol_handler< cryptonote::core >	t_protocol_raw
typedef nodetool::node_server< t_protocol_raw >	t_node_server

Public Member Functions
	mock_daemon (cryptonote::core *core, boost::program_options::variables_map const &vm)
virtual	~mock_daemon ()
mock_daemon *	set_start_p2p (bool fl)
mock_daemon *	set_start_zmq (bool fl)
void	init ()
void	deinit ()
void	run ()
bool	run_main ()
void	stop ()
void	stop_p2p ()
void	stop_rpc ()
void	init_and_run ()
void	stop_and_deinit ()
void	try_init_and_run (boost::optional< unsigned > initial_port=boost::none)
void	mine_blocks (size_t num_blocks, const std::string &miner_address)
void	start_mining (const std::string &miner_address, uint64_t threads_count=1, bool do_background_mining=false, bool ignore_battery=true)
void	stop_mining ()
uint64_t	get_height ()
void	load_params (boost::program_options::variables_map const &vm)
std::string	zmq_addr () const
std::string	rpc_addr () const
std::string	p2p_addr () const
cryptonote::network_type	nettype () const
cryptonote::core *	core () const

Static Public Member Functions
static void	init_options (boost::program_options::options_description &option_spec)
static void	default_options (boost::program_options::variables_map &vm)
static void	set_ports (boost::program_options::variables_map &vm, unsigned initial_port)

Public Attributes
cryptonote::core *	m_core
t_protocol_raw	m_protocol
mock_rpc_daemon	m_rpc_server
t_node_server	m_server
cryptonote::network_type	m_network_type
epee::net_utils::http::http_simple_client	m_http_client
bool	m_start_p2p
bool	m_start_zmq
boost::program_options::variables_map	m_vm
std::string	m_p2p_bind_port
std::string	m_rpc_bind_port
std::string	m_zmq_bind_port
std::atomic< bool >	m_stopped
std::atomic< bool >	m_terminated
std::atomic< bool >	m_deinitalized
boost::thread	m_run_thread

Static Public Attributes
static constexpr const std::chrono::seconds	rpc_timeout = std::chrono::seconds(60)

Detailed Description

Definition at line 74 of file daemon.h.

Member Typedef Documentation

t_node_server

typedef nodetool::node_server<t_protocol_raw> mock_daemon::t_node_server

Definition at line 77 of file daemon.h.

t_protocol_raw

typedef cryptonote::t_cryptonote_protocol_handler<cryptonote::core> mock_daemon::t_protocol_raw

Definition at line 76 of file daemon.h.

Constructor & Destructor Documentation

mock_daemon()

mock_daemon::mock_daemon ( cryptonote::core * core, boost::program_options::variables_map const & vm )

inline

Definition at line 101 of file daemon.h.

      : m_core(core)
      , m_vm(vm)
      , m_start_p2p(false)
      , m_start_zmq(false)
      , m_terminated(false)
      , m_deinitalized(false)
      , m_stopped(false)
      , m_protocol{*core, nullptr, command_line::get_arg(vm, cryptonote::arg_offline)}
      , m_server{m_protocol}
      , m_rpc_server{*core, m_server}
  {
    // Handle circular dependencies
    m_protocol.set_p2p_endpoint(&m_server);
    m_core->set_cryptonote_protocol(&m_protocol);
    load_params(vm);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

~mock_daemon()

mock_daemon::~mock_daemon ( )

virtual

Definition at line 102 of file daemon.cpp.

{
  if(m_http_client.is_connected())
    m_http_client.disconnect();
 
  if (!m_terminated)
  {
    try
    {
      stop();
    }
    catch (...)
    {
      MERROR("Failed to stop");
    }
  }
 
  if (!m_deinitalized)
  {
    deinit();
  }
}

Here is the call graph for this function:

Member Function Documentation

core()

cryptonote::core * mock_daemon::core ( ) const

inline

Definition at line 153 of file daemon.h.

{ return m_core; }

Here is the caller graph for this function:

default_options()

void mock_daemon::default_options ( boost::program_options::variables_map & vm )

static

Definition at line 53 of file daemon.cpp.

{
  std::vector<std::string> exclusive_nodes{"127.0.0.1:65525"};
  tools::options::set_option(vm, nodetool::arg_p2p_add_exclusive_node, po::variable_value(exclusive_nodes, false));
 
  tools::options::set_option(vm, nodetool::arg_p2p_bind_ip, po::variable_value(std::string("127.0.0.1"), false));
  tools::options::set_option(vm, nodetool::arg_no_igd, po::variable_value(true, false));
  tools::options::set_option(vm, cryptonote::arg_offline, po::variable_value(true, false));
  tools::options::set_option(vm, "disable-dns-checkpoints", po::variable_value(true, false));
 
  const char *test_mainnet = getenv("TEST_MAINNET");
  if (!test_mainnet || atoi(test_mainnet) == 0)
  {
    tools::options::set_option(vm, cryptonote::arg_testnet_on, po::variable_value(true, false));
  }
 
  // By default pick non-standard ports to avoid confusion with possibly locally running daemons (mainnet/testnet)
  const char *test_p2p_port = getenv("TEST_P2P_PORT");
  auto p2p_port = std::string(test_p2p_port && strlen(test_p2p_port) > 0 ? test_p2p_port : "61340");
  tools::options::set_option(vm, nodetool::arg_p2p_bind_port, po::variable_value(p2p_port, false));
 
  const char *test_rpc_port = getenv("TEST_RPC_PORT");
  auto rpc_port = std::string(test_rpc_port && strlen(test_rpc_port) > 0 ? test_rpc_port : "61341");
  tools::options::set_option(vm, cryptonote::core_rpc_server::arg_rpc_bind_port, po::variable_value(rpc_port, false));
 
  const char *test_zmq_port = getenv("TEST_ZMQ_PORT");
  auto zmq_port = std::string(test_zmq_port && strlen(test_zmq_port) > 0 ? test_zmq_port : "61342");
  tools::options::set_option(vm, daemon_args::arg_zmq_rpc_bind_port, po::variable_value(zmq_port, false));
 
  po::notify(vm);
}

Here is the call graph for this function:

Here is the caller graph for this function:

deinit()

void mock_daemon::deinit

(

)

Definition at line 143 of file daemon.cpp.

{
  if(m_http_client.is_connected())
    m_http_client.disconnect();
 
  try
  {
    m_rpc_server.deinit();
  }
  catch (...)
  {
    MERROR("Failed to deinitialize RPC server...");
  }
 
  if (m_start_p2p)
  {
    try
    {
      m_server.deinit();
    }
    catch (...)
    {
      MERROR("Failed to deinitialize p2p...");
    }
  }
 
  try
  {
    m_protocol.deinit();
    m_protocol.set_p2p_endpoint(nullptr);
  }
  catch (...)
  {
    MERROR("Failed to stop cryptonote protocol!");
  }
 
  m_deinitalized = true;
}

Here is the caller graph for this function:

get_height()

uint64_t mock_daemon::get_height

(

)

Definition at line 371 of file daemon.cpp.

{
  return m_core->get_blockchain_storage().get_current_blockchain_height();
}

Here is the caller graph for this function:

init()

void mock_daemon::init

(

)

Definition at line 125 of file daemon.cpp.

{
  m_deinitalized = false;
  const auto main_rpc_port = command_line::get_arg(m_vm, cryptonote::core_rpc_server::arg_rpc_bind_port);
  m_rpc_server.nettype(m_network_type);
 
  CHECK_AND_ASSERT_THROW_MES(m_protocol.init(m_vm), "Failed to initialize cryptonote protocol.");
  CHECK_AND_ASSERT_THROW_MES(m_rpc_server.init(m_vm, false, main_rpc_port), "Failed to initialize RPC server.");
 
  if (m_start_p2p)
    CHECK_AND_ASSERT_THROW_MES(m_server.init(m_vm), "Failed to initialize p2p server.");
 
  if(m_http_client.is_connected())
    m_http_client.disconnect();
 
  CHECK_AND_ASSERT_THROW_MES(m_http_client.set_server(rpc_addr(), boost::none, epee::net_utils::ssl_support_t::e_ssl_support_disabled), "RPC client init fail");
}

Here is the call graph for this function:

Here is the caller graph for this function:

init_and_run()

void mock_daemon::init_and_run

(

)

Definition at line 182 of file daemon.cpp.

{
  init();
  run();
}

Here is the call graph for this function:

Here is the caller graph for this function:

init_options()

void mock_daemon::init_options ( boost::program_options::options_description & option_spec )

static

Definition at line 43 of file daemon.cpp.

{
  cryptonote::core::init_options(option_spec);
  t_node_server::init_options(option_spec);
  cryptonote::core_rpc_server::init_options(option_spec);
 
  command_line::add_arg(option_spec, daemon_args::arg_zmq_rpc_bind_ip);
  command_line::add_arg(option_spec, daemon_args::arg_zmq_rpc_bind_port);
}

Here is the call graph for this function:

Here is the caller graph for this function:

load_params()

void mock_daemon::load_params

(

boost::program_options::variables_map const &

vm

)

Definition at line 94 of file daemon.cpp.

{
  m_p2p_bind_port = command_line::get_arg(vm, nodetool::arg_p2p_bind_port);
  m_rpc_bind_port = command_line::get_arg(vm, cryptonote::core_rpc_server::arg_rpc_bind_port);
  m_zmq_bind_port = command_line::get_arg(vm, daemon_args::arg_zmq_rpc_bind_port);
  m_network_type = command_line::get_arg(vm, cryptonote::arg_testnet_on) ? cryptonote::TESTNET : cryptonote::MAINNET;
}

Here is the call graph for this function:

Here is the caller graph for this function:

mine_blocks()

void mock_daemon::mine_blocks	(	size_t	num_blocks,
		const std::string &	miner_address )

Definition at line 312 of file daemon.cpp.

{
  bool blocks_mined = false;
  const uint64_t start_height = get_height();
  const auto mining_timeout = std::chrono::seconds(30);
  MDEBUG("Current height before mining: " << start_height);
 
  start_mining(miner_address);
  auto mining_started = std::chrono::system_clock::now();
 
  while(true) {
    epee::misc_utils::sleep_no_w(100);
    const uint64_t cur_height = get_height();
 
    if (cur_height - start_height >= num_blocks)
    {
      MDEBUG("Cur blocks: " << cur_height << " start: " << start_height);
      blocks_mined = true;
      break;
    }
 
    auto current_time = std::chrono::system_clock::now();
    if (mining_timeout < current_time - mining_started)
    {
      break;
    }
  }
 
  stop_mining();
  CHECK_AND_ASSERT_THROW_MES(blocks_mined, "Mining failed in the time limit");
}

Here is the call graph for this function:

Here is the caller graph for this function:

nettype()

cryptonote::network_type mock_daemon::nettype ( ) const

inline

Definition at line 152 of file daemon.h.

{ return m_network_type; }

p2p_addr()

std::string mock_daemon::p2p_addr ( ) const

inline

Definition at line 151 of file daemon.h.

{ return std::string("127.0.0.1:") + m_p2p_bind_port; }

rpc_addr()

std::string mock_daemon::rpc_addr ( ) const

inline

Definition at line 150 of file daemon.h.

{ return std::string("127.0.0.1:") + m_rpc_bind_port; }

Here is the caller graph for this function:

run()

void mock_daemon::run

(

)

Definition at line 222 of file daemon.cpp.

{
  m_run_thread = boost::thread(boost::bind(&mock_daemon::run_main, this));
}

Here is the call graph for this function:

Here is the caller graph for this function:

run_main()

bool mock_daemon::run_main

(

)

Definition at line 227 of file daemon.cpp.

{
  CHECK_AND_ASSERT_THROW_MES(!m_terminated, "Can't run stopped daemon");
  CHECK_AND_ASSERT_THROW_MES(!m_start_zmq || m_start_p2p, "ZMQ requires P2P");
  boost::thread stop_thread = boost::thread([this] {
    while (!this->m_stopped)
      epee::misc_utils::sleep_no_w(100);
    this->stop_p2p();
  });
 
  epee::misc_utils::auto_scope_leave_caller scope_exit_handler = epee::misc_utils::create_scope_leave_handler([&](){
    m_stopped = true;
    stop_thread.join();
  });
 
  try
  {
    CHECK_AND_ASSERT_THROW_MES(m_rpc_server.run(2, false), "Failed to start RPC");
    cryptonote::rpc::DaemonHandler rpc_daemon_handler(*m_core, m_server);
    cryptonote::rpc::ZmqServer zmq_server(rpc_daemon_handler);
 
    if (m_start_zmq)
    {
      if (!zmq_server.addTCPSocket("127.0.0.1", m_zmq_bind_port))
      {
        MERROR("Failed to add TCP Socket (127.0.0.1:" << m_zmq_bind_port << ") to ZMQ RPC Server");
 
        stop_rpc();
        return false;
      }
 
      MINFO("Starting ZMQ server...");
      zmq_server.run();
 
      MINFO("ZMQ server started at 127.0.0.1: " << m_zmq_bind_port);
    }
 
    if (m_start_p2p)
    {
      m_server.run();  // blocks until p2p goes down
    }
    else
    {
      while (!this->m_stopped)
        epee::misc_utils::sleep_no_w(100);
    }
 
    if (m_start_zmq)
      zmq_server.stop();
 
    stop_rpc();
    return true;
  }
  catch (std::exception const & ex)
  {
    MFATAL("Uncaught exception! " << ex.what());
    return false;
  }
  catch (...)
  {
    MFATAL("Uncaught exception!");
    return false;
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

set_ports()

void mock_daemon::set_ports ( boost::program_options::variables_map & vm, unsigned initial_port )

static

Definition at line 85 of file daemon.cpp.

{
  CHECK_AND_ASSERT_THROW_MES(initial_port < 65535-2, "Invalid port number");
  tools::options::set_option(vm, nodetool::arg_p2p_bind_port, po::variable_value(std::to_string(initial_port), false));
  tools::options::set_option(vm, cryptonote::core_rpc_server::arg_rpc_bind_port, po::variable_value(std::to_string(initial_port + 1), false));
  tools::options::set_option(vm, daemon_args::arg_zmq_rpc_bind_port, po::variable_value(std::to_string(initial_port + 2), false));
  po::notify(vm);
}

Here is the call graph for this function:

Here is the caller graph for this function:

set_start_p2p()

mock_daemon * mock_daemon::set_start_p2p ( bool fl )

inline

Definition at line 128 of file daemon.h.

{ m_start_p2p = fl; return this; }

Here is the call graph for this function:

set_start_zmq()

mock_daemon * mock_daemon::set_start_zmq ( bool fl )

inline

Definition at line 129 of file daemon.h.

{ m_start_zmq = fl; return this; }

Here is the call graph for this function:

start_mining()

void mock_daemon::start_mining	(	const std::string &	miner_address,
		uint64_t	threads_count = 1,
		bool	do_background_mining = false,
		bool	ignore_battery = true )

Definition at line 346 of file daemon.cpp.

{
  cryptonote::COMMAND_RPC_START_MINING::request req;
  req.miner_address = miner_address;
  req.threads_count = threads_count;
  req.do_background_mining = do_background_mining;
  req.ignore_battery = ignore_battery;
 
  cryptonote::COMMAND_RPC_START_MINING::response resp;
  bool r = epee::net_utils::invoke_http_json("/start_mining", req, resp, m_http_client, rpc_timeout);
  CHECK_AND_ASSERT_THROW_MES(r, "RPC error - start mining");
  CHECK_AND_ASSERT_THROW_MES(resp.status != CORE_RPC_STATUS_BUSY, "Daemon busy");
  CHECK_AND_ASSERT_THROW_MES(resp.status == CORE_RPC_STATUS_OK, "Daemon response invalid: " << resp.status);
}

Here is the call graph for this function:

Here is the caller graph for this function:

stop()

void mock_daemon::stop

(

)

Definition at line 292 of file daemon.cpp.

{
  CHECK_AND_ASSERT_THROW_MES(!m_terminated, "Can't stop stopped daemon");
  m_stopped = true;
  m_terminated = true;
  m_run_thread.join();
}

Here is the caller graph for this function:

stop_and_deinit()

void mock_daemon::stop_and_deinit

(

)

Definition at line 188 of file daemon.cpp.

{
  stop();
  deinit();
}

Here is the call graph for this function:

stop_mining()

void mock_daemon::stop_mining

(

)

Definition at line 361 of file daemon.cpp.

{
  cryptonote::COMMAND_RPC_STOP_MINING::request req;
  cryptonote::COMMAND_RPC_STOP_MINING::response resp;
  bool r = epee::net_utils::invoke_http_json("/stop_mining", req, resp, m_http_client, rpc_timeout);
  CHECK_AND_ASSERT_THROW_MES(r, "RPC error - stop mining");
  CHECK_AND_ASSERT_THROW_MES(resp.status != CORE_RPC_STATUS_BUSY, "Daemon busy");
  CHECK_AND_ASSERT_THROW_MES(resp.status == CORE_RPC_STATUS_OK, "Daemon response invalid: " << resp.status);
}

Here is the call graph for this function:

Here is the caller graph for this function:

stop_p2p()

void mock_daemon::stop_p2p

(

)

Definition at line 306 of file daemon.cpp.

{
  if (m_start_p2p)
    m_server.send_stop_signal();
}

Here is the caller graph for this function:

stop_rpc()

void mock_daemon::stop_rpc

(

)

Definition at line 300 of file daemon.cpp.

{
  m_rpc_server.send_stop_signal();
  m_rpc_server.timed_wait_server_stop(5000);
}

Here is the caller graph for this function:

try_init_and_run()

void mock_daemon::try_init_and_run

(

boost::optional< unsigned >

initial_port = boost::none

)

Definition at line 194 of file daemon.cpp.

{
  const unsigned max_attempts = 3;
  for(unsigned attempts=0; attempts < max_attempts; ++attempts)
  {
    if (initial_port)
    {
      set_ports(m_vm, initial_port.get());
      load_params(m_vm);
      MDEBUG("Ports changed, RPC: " << rpc_addr());
    }
 
    try
    {
      init_and_run();
      return;
    }
    catch(const std::exception &e)
    {
      MWARNING("Could not init and start, attempt: " << attempts << ", reason: " << e.what());
      if (attempts + 1 >= max_attempts)
      {
        throw;
      }
    }
  }
}

Here is the call graph for this function:

zmq_addr()

std::string mock_daemon::zmq_addr ( ) const

inline

Definition at line 149 of file daemon.h.

{ return std::string("127.0.0.1:") + m_zmq_bind_port; }

Member Data Documentation

m_core

cryptonote::core* mock_daemon::m_core

Definition at line 81 of file daemon.h.

m_deinitalized

std::atomic<bool> mock_daemon::m_deinitalized

Definition at line 98 of file daemon.h.

m_http_client

epee::net_utils::http::http_simple_client mock_daemon::m_http_client

Definition at line 86 of file daemon.h.

m_network_type

cryptonote::network_type mock_daemon::m_network_type

Definition at line 85 of file daemon.h.

m_p2p_bind_port

std::string mock_daemon::m_p2p_bind_port

Definition at line 92 of file daemon.h.

m_protocol

t_protocol_raw mock_daemon::m_protocol

Definition at line 82 of file daemon.h.

m_rpc_bind_port

std::string mock_daemon::m_rpc_bind_port

Definition at line 93 of file daemon.h.

m_rpc_server

mock_rpc_daemon mock_daemon::m_rpc_server

Definition at line 83 of file daemon.h.

m_run_thread

boost::thread mock_daemon::m_run_thread

Definition at line 99 of file daemon.h.

m_server

t_node_server mock_daemon::m_server

Definition at line 84 of file daemon.h.

m_start_p2p

bool mock_daemon::m_start_p2p

Definition at line 88 of file daemon.h.

m_start_zmq

bool mock_daemon::m_start_zmq

Definition at line 89 of file daemon.h.

m_stopped

std::atomic<bool> mock_daemon::m_stopped

Definition at line 96 of file daemon.h.

m_terminated

std::atomic<bool> mock_daemon::m_terminated

Definition at line 97 of file daemon.h.

m_vm

boost::program_options::variables_map mock_daemon::m_vm

Definition at line 90 of file daemon.h.

m_zmq_bind_port

std::string mock_daemon::m_zmq_bind_port

Definition at line 94 of file daemon.h.

rpc_timeout

const std::chrono::seconds mock_daemon::rpc_timeout = std::chrono::seconds(60)

staticconstexpr

Definition at line 79 of file daemon.h.

---

The documentation for this class was generated from the following files:

• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/tests/trezor/daemon.h
• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/tests/trezor/daemon.cpp