daemonize::t_daemon Class Reference

#include <daemon.h>

Public Member Functions
	t_daemon (boost::program_options::variables_map const &vm, uint16_t public_rpc_port=0)
	t_daemon (t_daemon &&other)
t_daemon &	operator= (t_daemon &&other)
	~t_daemon ()
bool	run (bool interactive=false)
void	stop ()

Static Public Member Functions
static void	init_options (boost::program_options::options_description &option_spec)

Detailed Description

Definition at line 40 of file daemon.h.

Constructor & Destructor Documentation

t_daemon() [1/2]

t_daemon::t_daemon	(	boost::program_options::variables_map const &	vm,
		uint16_t	public_rpc_port = 0 )

Definition at line 100 of file daemon.cpp.

  : mp_internals{new t_internals{vm}},
  public_rpc_port(public_rpc_port)
{
  zmq_rpc_bind_port = command_line::get_arg(vm, daemon_args::arg_zmq_rpc_bind_port);
  zmq_rpc_bind_address = command_line::get_arg(vm, daemon_args::arg_zmq_rpc_bind_ip);
  zmq_rpc_disabled = command_line::get_arg(vm, daemon_args::arg_zmq_rpc_disabled);
}

Here is the call graph for this function:

Here is the caller graph for this function:

t_daemon() [2/2]

t_daemon::t_daemon

(

t_daemon &&

other

)

Definition at line 115 of file daemon.cpp.

{
  if (this != &other)
  {
    mp_internals = std::move(other.mp_internals);
    other.mp_internals.reset(nullptr);
    public_rpc_port = other.public_rpc_port;
  }
}

Here is the call graph for this function:

~t_daemon()

t_daemon::~t_daemon ( )

default

Member Function Documentation

init_options()

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

static

Definition at line 93 of file daemon.cpp.

{
  t_core::init_options(option_spec);
  t_p2p::init_options(option_spec);
  t_rpc::init_options(option_spec);
}

Here is the call graph for this function:

Here is the caller graph for this function:

operator=()

t_daemon & t_daemon::operator=

(

t_daemon &&

other

)

Definition at line 126 of file daemon.cpp.

{
  if (this != &other)
  {
    mp_internals = std::move(other.mp_internals);
    other.mp_internals.reset(nullptr);
    public_rpc_port = other.public_rpc_port;
  }
  return *this;
}

Here is the call graph for this function:

run()

bool t_daemon::run

(

bool

interactive = false

)

Definition at line 137 of file daemon.cpp.

{
  if (nullptr == mp_internals)
  {
    throw std::runtime_error{"Can't run stopped daemon"};
  }
 
  std::atomic<bool> stop(false), shutdown(false);
  boost::thread stop_thread = boost::thread([&stop, &shutdown, this] {
    while (!stop)
      epee::misc_utils::sleep_no_w(100);
    if (shutdown)
      this->stop_p2p();
  });
  epee::misc_utils::auto_scope_leave_caller scope_exit_handler = epee::misc_utils::create_scope_leave_handler([&](){
    stop = true;
    stop_thread.join();
  });
  tools::signal_handler::install([&stop, &shutdown](int){ stop = shutdown = true; });
 
  try
  {
    if (!mp_internals->core.run())
      return false;
 
    for(auto& rpc: mp_internals->rpcs)
      rpc->run();
 
    std::unique_ptr<daemonize::t_command_server> rpc_commands;
    if (interactive && mp_internals->rpcs.size())
    {
      // The first three variables are not used when the fourth is false
      rpc_commands.reset(new daemonize::t_command_server(0, 0, boost::none, epee::net_utils::ssl_support_t::e_ssl_support_disabled, false, mp_internals->rpcs.front()->get_server()));
      rpc_commands->start_handling(std::bind(&daemonize::t_daemon::stop_p2p, this));
    }
 
    cryptonote::rpc::DaemonHandler rpc_daemon_handler(mp_internals->core.get(), mp_internals->p2p.get());
    cryptonote::rpc::ZmqServer zmq_server(rpc_daemon_handler);
 
    if (!zmq_rpc_disabled)
    {
      if (!zmq_server.addTCPSocket(zmq_rpc_bind_address, zmq_rpc_bind_port))
      {
        LOG_ERROR(std::string("Failed to add TCP Socket (") + zmq_rpc_bind_address
            + ":" + zmq_rpc_bind_port + ") to ZMQ RPC Server");
 
        if (rpc_commands)
          rpc_commands->stop_handling();
 
        for(auto& rpc : mp_internals->rpcs)
          rpc->stop();
 
        return false;
      }
 
      MINFO("Starting ZMQ server...");
      zmq_server.run();
 
      MINFO(std::string("ZMQ server started at ") + zmq_rpc_bind_address
            + ":" + zmq_rpc_bind_port + ".");
    }
    else
      MINFO("ZMQ server disabled");
 
    if (public_rpc_port > 0)
    {
      MGINFO("Public RPC port " << public_rpc_port << " will be advertised to other peers over P2P");
      mp_internals->p2p.get().set_rpc_port(public_rpc_port);
    }
    
    mp_internals->p2p.run(); // blocks until p2p goes down
 
    if (rpc_commands)
      rpc_commands->stop_handling();
 
    if (!zmq_rpc_disabled)
      zmq_server.stop();
 
    for(auto& rpc : mp_internals->rpcs)
      rpc->stop();
    MGINFO("Node stopped.");
    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:

stop()

void t_daemon::stop

(

)

Definition at line 232 of file daemon.cpp.

{
  if (nullptr == mp_internals)
  {
    throw std::runtime_error{"Can't stop stopped daemon"};
  }
  mp_internals->p2p.stop();
  for(auto& rpc : mp_internals->rpcs)
    rpc->stop();
 
  mp_internals.reset(nullptr); // Ensure resources are cleaned up before we return
}

Here is the caller graph for this function:

---

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/src/daemon/daemon.h
• /home/abuild/rpmbuild/BUILD/electroneum-5.1.3.1-build/electroneum-5.1.3.1/src/daemon/daemon.cpp