tools::NodeRPCProxy Class Reference

#include <node_rpc_proxy.h>

Public Member Functions
	NodeRPCProxy (epee::net_utils::http::http_simple_client &http_client, boost::recursive_mutex &mutex)
void	invalidate ()
void	set_offline (bool offline)
boost::optional< std::string >	get_rpc_version (uint32_t &version) const
boost::optional< std::string >	get_height (uint64_t &height) const
void	set_height (uint64_t h)
boost::optional< std::string >	get_target_height (uint64_t &height) const
boost::optional< std::string >	get_block_weight_limit (uint64_t &block_weight_limit) const
boost::optional< std::string >	get_earliest_height (uint8_t version, uint64_t &earliest_height) const
boost::optional< std::string >	get_dynamic_base_fee_estimate (uint64_t grace_blocks, uint64_t &fee) const
boost::optional< std::string >	get_fee_quantization_mask (uint64_t &fee_quantization_mask) const

Detailed Description

Definition at line 40 of file node_rpc_proxy.h.

Constructor & Destructor Documentation

NodeRPCProxy()

tools::NodeRPCProxy::NodeRPCProxy	(	epee::net_utils::http::http_simple_client &	http_client,
		boost::recursive_mutex &	mutex )

Definition at line 41 of file node_rpc_proxy.cpp.

  : m_http_client(http_client)
  , m_daemon_rpc_mutex(mutex)
  , m_offline(false)
{
  invalidate();
}

Here is the call graph for this function:

Member Function Documentation

get_block_weight_limit()

boost::optional< std::string > tools::NodeRPCProxy::get_block_weight_limit

(

uint64_t &

block_weight_limit

)

const

Definition at line 132 of file node_rpc_proxy.cpp.

{
  auto res = get_info();
  if (res)
    return res;
  block_weight_limit = m_block_weight_limit;
  return boost::optional<std::string>();
}

get_dynamic_base_fee_estimate()

boost::optional< std::string > tools::NodeRPCProxy::get_dynamic_base_fee_estimate	(	uint64_t	grace_blocks,
		uint64_t &	fee ) const

Definition at line 164 of file node_rpc_proxy.cpp.

{
  uint64_t height;
 
  boost::optional<std::string> result = get_height(height);
  if (result)
    return result;
 
  if (m_offline)
    return boost::optional<std::string>("offline");
  if (m_dynamic_base_fee_estimate_cached_height != height || m_dynamic_base_fee_estimate_grace_blocks != grace_blocks)
  {
    cryptonote::COMMAND_RPC_GET_BASE_FEE_ESTIMATE::request req_t = AUTO_VAL_INIT(req_t);
    cryptonote::COMMAND_RPC_GET_BASE_FEE_ESTIMATE::response resp_t = AUTO_VAL_INIT(resp_t);
 
    m_daemon_rpc_mutex.lock();
    req_t.grace_blocks = grace_blocks;
    bool r = net_utils::invoke_http_json_rpc("/json_rpc", "get_fee_estimate", req_t, resp_t, m_http_client, rpc_timeout);
    m_daemon_rpc_mutex.unlock();
    CHECK_AND_ASSERT_MES(r, std::string("Failed to connect to daemon"), "Failed to connect to daemon");
    CHECK_AND_ASSERT_MES(resp_t.status != CORE_RPC_STATUS_BUSY, resp_t.status, "Failed to connect to daemon");
    CHECK_AND_ASSERT_MES(resp_t.status == CORE_RPC_STATUS_OK, resp_t.status, "Failed to get fee estimate");
    m_dynamic_base_fee_estimate = resp_t.fee;
    m_dynamic_base_fee_estimate_cached_height = height;
    m_dynamic_base_fee_estimate_grace_blocks = grace_blocks;
    m_fee_quantization_mask = resp_t.quantization_mask;
  }
 
  fee = m_dynamic_base_fee_estimate;
  return boost::optional<std::string>();
}

Here is the call graph for this function:

get_earliest_height()

boost::optional< std::string > tools::NodeRPCProxy::get_earliest_height	(	uint8_t	version,
		uint64_t &	earliest_height ) const

Definition at line 141 of file node_rpc_proxy.cpp.

{
  if (m_offline)
    return boost::optional<std::string>("offline");
  if (m_earliest_height[version] == 0)
  {
    cryptonote::COMMAND_RPC_HARD_FORK_INFO::request req_t = AUTO_VAL_INIT(req_t);
    cryptonote::COMMAND_RPC_HARD_FORK_INFO::response resp_t = AUTO_VAL_INIT(resp_t);
 
    m_daemon_rpc_mutex.lock();
    req_t.version = version;
    bool r = net_utils::invoke_http_json_rpc("/json_rpc", "hard_fork_info", req_t, resp_t, m_http_client, rpc_timeout);
    m_daemon_rpc_mutex.unlock();
    CHECK_AND_ASSERT_MES(r, std::string("Failed to connect to daemon"), "Failed to connect to daemon");
    CHECK_AND_ASSERT_MES(resp_t.status != CORE_RPC_STATUS_BUSY, resp_t.status, "Failed to connect to daemon");
    CHECK_AND_ASSERT_MES(resp_t.status == CORE_RPC_STATUS_OK, resp_t.status, "Failed to get hard fork status");
    m_earliest_height[version] = resp_t.earliest_height;
  }
 
  earliest_height = m_earliest_height[version];
  return boost::optional<std::string>();
}

Here is the call graph for this function:

get_fee_quantization_mask()

boost::optional< std::string > tools::NodeRPCProxy::get_fee_quantization_mask

(

uint64_t &

fee_quantization_mask

)

const

Definition at line 196 of file node_rpc_proxy.cpp.

{
  uint64_t height;
 
  boost::optional<std::string> result = get_height(height);
  if (result)
    return result;
 
  if (m_offline)
    return boost::optional<std::string>("offline");
  if (m_dynamic_base_fee_estimate_cached_height != height)
  {
    cryptonote::COMMAND_RPC_GET_BASE_FEE_ESTIMATE::request req_t = AUTO_VAL_INIT(req_t);
    cryptonote::COMMAND_RPC_GET_BASE_FEE_ESTIMATE::response resp_t = AUTO_VAL_INIT(resp_t);
 
    m_daemon_rpc_mutex.lock();
    req_t.grace_blocks = m_dynamic_base_fee_estimate_grace_blocks;
    bool r = net_utils::invoke_http_json_rpc("/json_rpc", "get_fee_estimate", req_t, resp_t, m_http_client, rpc_timeout);
    m_daemon_rpc_mutex.unlock();
    CHECK_AND_ASSERT_MES(r, std::string("Failed to connect to daemon"), "Failed to connect to daemon");
    CHECK_AND_ASSERT_MES(resp_t.status != CORE_RPC_STATUS_BUSY, resp_t.status, "Failed to connect to daemon");
    CHECK_AND_ASSERT_MES(resp_t.status == CORE_RPC_STATUS_OK, resp_t.status, "Failed to get fee estimate");
    m_dynamic_base_fee_estimate = resp_t.fee;
    m_dynamic_base_fee_estimate_cached_height = height;
    m_fee_quantization_mask = resp_t.quantization_mask;
  }
 
  fee_quantization_mask = m_fee_quantization_mask;
  if (fee_quantization_mask == 0)
  {
    MERROR("Fee quantization mask is 0, forcing to 1");
    fee_quantization_mask = 1;
  }
  return boost::optional<std::string>();
}

Here is the call graph for this function:

get_height()

boost::optional< std::string > tools::NodeRPCProxy::get_height

(

uint64_t &

height

)

const

Definition at line 114 of file node_rpc_proxy.cpp.

{
  auto res = get_info();
  if (res)
    return res;
  height = m_height;
  return boost::optional<std::string>();
}

Here is the caller graph for this function:

get_rpc_version()

boost::optional< std::string > tools::NodeRPCProxy::get_rpc_version

(

uint32_t &

version

)

const

Definition at line 64 of file node_rpc_proxy.cpp.

{
  if (m_offline)
    return boost::optional<std::string>("offline");
  if (m_rpc_version == 0)
  {
    cryptonote::COMMAND_RPC_GET_VERSION::request req_t = AUTO_VAL_INIT(req_t);
    cryptonote::COMMAND_RPC_GET_VERSION::response resp_t = AUTO_VAL_INIT(resp_t);
    m_daemon_rpc_mutex.lock();
    bool r = net_utils::invoke_http_json_rpc("/json_rpc", "get_version", req_t, resp_t, m_http_client, rpc_timeout);
    m_daemon_rpc_mutex.unlock();
    CHECK_AND_ASSERT_MES(r, std::string("Failed to connect to daemon"), "Failed to connect to daemon");
    CHECK_AND_ASSERT_MES(resp_t.status != CORE_RPC_STATUS_BUSY, resp_t.status, "Failed to connect to daemon");
    CHECK_AND_ASSERT_MES(resp_t.status == CORE_RPC_STATUS_OK, resp_t.status, "Failed to get daemon RPC version");
    m_rpc_version = resp_t.version;
  }
  rpc_version = m_rpc_version;
  return boost::optional<std::string>();
}

Here is the call graph for this function:

get_target_height()

boost::optional< std::string > tools::NodeRPCProxy::get_target_height

(

uint64_t &

height

)

const

Definition at line 123 of file node_rpc_proxy.cpp.

{
  auto res = get_info();
  if (res)
    return res;
  height = m_target_height;
  return boost::optional<std::string>();
}

invalidate()

void tools::NodeRPCProxy::invalidate

(

)

Definition at line 49 of file node_rpc_proxy.cpp.

{
  m_height = 0;
  for (size_t n = 0; n < 256; ++n)
    m_earliest_height[n] = 0;
  m_dynamic_base_fee_estimate = 0;
  m_dynamic_base_fee_estimate_cached_height = 0;
  m_dynamic_base_fee_estimate_grace_blocks = 0;
  m_fee_quantization_mask = 1;
  m_rpc_version = 0;
  m_target_height = 0;
  m_block_weight_limit = 0;
  m_get_info_time = 0;
}

Here is the caller graph for this function:

set_height()

void tools::NodeRPCProxy::set_height

(

uint64_t

h

)

Definition at line 84 of file node_rpc_proxy.cpp.

{
  m_height = h;
}

set_offline()

void tools::NodeRPCProxy::set_offline ( bool offline )

inline

Definition at line 46 of file node_rpc_proxy.h.

{ m_offline = offline; }

---

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