Page MenuHomePhabricator
Differential D6418 Diff 21018 src/interfaces/node.cpp

Changeset View

Standalone View

View Options

src/interfaces/node.cpp

Show First 20 Lines • Show All 114 Lines • ▼ Show 20 Lines public:
StopMapPort(); StopMapPort();
} }
} }
void setupServerArgs() override { return SetupServerArgs(); } void setupServerArgs() override { return SetupServerArgs(); }
bool getProxy(Network net, proxyType &proxy_info) override { bool getProxy(Network net, proxyType &proxy_info) override {
return GetProxy(net, proxy_info); return GetProxy(net, proxy_info);
} }
size_t getNodeCount(CConnman::NumConnections flags) override { size_t getNodeCount(CConnman::NumConnections flags) override {
return g_connman ? g_connman->GetNodeCount(flags) : 0; return m_context.connman ? m_context.connman->GetNodeCount(flags)
: 0;
} }
bool getNodesStats(NodesStats &stats) override { bool getNodesStats(NodesStats &stats) override {
stats.clear(); stats.clear();
if (g_connman) { if (m_context.connman) {
std::vector<CNodeStats> stats_temp; std::vector<CNodeStats> stats_temp;
g_connman->GetNodeStats(stats_temp); m_context.connman->GetNodeStats(stats_temp);
stats.reserve(stats_temp.size()); stats.reserve(stats_temp.size());
for (auto &node_stats_temp : stats_temp) { for (auto &node_stats_temp : stats_temp) {
stats.emplace_back(std::move(node_stats_temp), false, stats.emplace_back(std::move(node_stats_temp), false,
CNodeStateStats()); CNodeStateStats());
} }
// Try to retrieve the CNodeStateStats for each node. // Try to retrieve the CNodeStateStats for each node.
TRY_LOCK(::cs_main, lockMain); TRY_LOCK(::cs_main, lockMain);
if (lockMain) { if (lockMain) {
for (auto &node_stats : stats) { for (auto &node_stats : stats) {
std::get<1>(node_stats) = std::get<1>(node_stats) =
GetNodeStateStats(std::get<0>(node_stats).nodeid, GetNodeStateStats(std::get<0>(node_stats).nodeid,
std::get<2>(node_stats)); std::get<2>(node_stats));
} }
} }
return true; return true;
} }
return false; return false;
} }
bool getBanned(banmap_t &banmap) override { bool getBanned(banmap_t &banmap) override {
if (g_banman) { if (m_context.banman) {
g_banman->GetBanned(banmap); m_context.banman->GetBanned(banmap);
return true; return true;
} }
return false; return false;
} }
bool ban(const CNetAddr &net_addr, BanReason reason, bool ban(const CNetAddr &net_addr, BanReason reason,
int64_t ban_time_offset) override { int64_t ban_time_offset) override {
if (g_banman) { if (m_context.banman) {
g_banman->Ban(net_addr, reason, ban_time_offset); m_context.banman->Ban(net_addr, reason, ban_time_offset);
return true; return true;
} }
return false; return false;
} }
bool unban(const CSubNet &ip) override { bool unban(const CSubNet &ip) override {
if (g_banman) { if (m_context.banman) {
g_banman->Unban(ip); m_context.banman->Unban(ip);
return true; return true;
} }
return false; return false;
} }
bool disconnect(const CNetAddr &net_addr) override { bool disconnect(const CNetAddr &net_addr) override {
if (g_connman) { if (m_context.connman) {
return g_connman->DisconnectNode(net_addr); return m_context.connman->DisconnectNode(net_addr);
} }
return false; return false;
} }
bool disconnect(NodeId id) override { bool disconnect(NodeId id) override {
if (g_connman) { if (m_context.connman) {
return g_connman->DisconnectNode(id); return m_context.connman->DisconnectNode(id);
} }
return false; return false;
} }
int64_t getTotalBytesRecv() override { int64_t getTotalBytesRecv() override {
return g_connman ? g_connman->GetTotalBytesRecv() : 0; return m_context.connman ? m_context.connman->GetTotalBytesRecv()
: 0;
} }
int64_t getTotalBytesSent() override { int64_t getTotalBytesSent() override {
return g_connman ? g_connman->GetTotalBytesSent() : 0; return m_context.connman ? m_context.connman->GetTotalBytesSent()
: 0;
} }
size_t getMempoolSize() override { return g_mempool.size(); } size_t getMempoolSize() override { return g_mempool.size(); }
size_t getMempoolDynamicUsage() override { size_t getMempoolDynamicUsage() override {
return g_mempool.DynamicMemoryUsage(); return g_mempool.DynamicMemoryUsage();
} }
bool getHeaderTip(int &height, int64_t &block_time) override { bool getHeaderTip(int &height, int64_t &block_time) override {
LOCK(::cs_main); LOCK(::cs_main);
if (::pindexBestHeader) { if (::pindexBestHeader) {
Show All 24 Lines public:
return GuessVerificationProgress(Params().TxData(), tip); return GuessVerificationProgress(Params().TxData(), tip);
} }
bool isInitialBlockDownload() override { bool isInitialBlockDownload() override {
return ::ChainstateActive().IsInitialBlockDownload(); return ::ChainstateActive().IsInitialBlockDownload();
} }
bool getReindex() override { return ::fReindex; } bool getReindex() override { return ::fReindex; }
bool getImporting() override { return ::fImporting; } bool getImporting() override { return ::fImporting; }
void setNetworkActive(bool active) override { void setNetworkActive(bool active) override {
if (g_connman) { if (m_context.connman) {
g_connman->SetNetworkActive(active); m_context.connman->SetNetworkActive(active);
} }
} }
bool getNetworkActive() override { bool getNetworkActive() override {
return g_connman && g_connman->GetNetworkActive(); return m_context.connman && m_context.connman->GetNetworkActive();
} }
CFeeRate estimateSmartFee() override { return g_mempool.estimateFee(); } CFeeRate estimateSmartFee() override { return g_mempool.estimateFee(); }
CFeeRate getDustRelayFee() override { return ::dustRelayFee; } CFeeRate getDustRelayFee() override { return ::dustRelayFee; }
UniValue executeRpc(Config &config, const std::string &command, UniValue executeRpc(Config &config, const std::string &command,
const UniValue &params, const UniValue &params,
const std::string &uri) override { const std::string &uri) override {
JSONRPCRequest req; JSONRPCRequest req;
req.params = params; req.params = params;
▲ Show 20 Lines • Show All 101 Lines • Show Last 20 Lines