6f86ee9cae
This adds a -whitelist option to specify subnet ranges from which peers that connect are whitelisted. In addition, there is a -whitebind option which works like -bind, except peers connecting to it are also whitelisted (allowing a separate listen port for trusted connections). Being whitelisted has two effects (for now): * They are immune to DoS disconnection/banning. * Transactions they broadcast (which are valid) are always relayed, even if they were already in the mempool. This means that a node can function as a gateway for a local network, and that rebroadcasts from the local network will work as expected. Whitelisting replaces the magic exemption localhost had for DoS disconnection (local addresses are still never banned, though), which implied hidden service connects (from a localhost Tor node) were incorrectly immune to DoS disconnection as well. This old behaviour is removed for that reason, but can be restored using -whitelist=127.0.0.1 or -whitelist=::1 can be specified. -whitebind is safer to use in case non-trusted localhost connections are expected (like hidden services).
388 lines
15 KiB
C++
388 lines
15 KiB
C++
// Copyright (c) 2009-2014 The Bitcoin developers
|
|
// Distributed under the MIT/X11 software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#include "rpcserver.h"
|
|
|
|
#include "main.h"
|
|
#include "net.h"
|
|
#include "netbase.h"
|
|
#include "protocol.h"
|
|
#include "sync.h"
|
|
#include "util.h"
|
|
|
|
#include <boost/foreach.hpp>
|
|
#include "json/json_spirit_value.h"
|
|
|
|
using namespace json_spirit;
|
|
using namespace std;
|
|
|
|
Value getconnectioncount(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() != 0)
|
|
throw runtime_error(
|
|
"getconnectioncount\n"
|
|
"\nReturns the number of connections to other nodes.\n"
|
|
"\nbResult:\n"
|
|
"n (numeric) The connection count\n"
|
|
"\nExamples:\n"
|
|
+ HelpExampleCli("getconnectioncount", "")
|
|
+ HelpExampleRpc("getconnectioncount", "")
|
|
);
|
|
|
|
LOCK(cs_vNodes);
|
|
return (int)vNodes.size();
|
|
}
|
|
|
|
Value ping(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() != 0)
|
|
throw runtime_error(
|
|
"ping\n"
|
|
"\nRequests that a ping be sent to all other nodes, to measure ping time.\n"
|
|
"Results provided in getpeerinfo, pingtime and pingwait fields are decimal seconds.\n"
|
|
"Ping command is handled in queue with all other commands, so it measures processing backlog, not just network ping.\n"
|
|
"\nExamples:\n"
|
|
+ HelpExampleCli("ping", "")
|
|
+ HelpExampleRpc("ping", "")
|
|
);
|
|
|
|
// Request that each node send a ping during next message processing pass
|
|
LOCK(cs_vNodes);
|
|
BOOST_FOREACH(CNode* pNode, vNodes) {
|
|
pNode->fPingQueued = true;
|
|
}
|
|
|
|
return Value::null;
|
|
}
|
|
|
|
static void CopyNodeStats(std::vector<CNodeStats>& vstats)
|
|
{
|
|
vstats.clear();
|
|
|
|
LOCK(cs_vNodes);
|
|
vstats.reserve(vNodes.size());
|
|
BOOST_FOREACH(CNode* pnode, vNodes) {
|
|
CNodeStats stats;
|
|
pnode->copyStats(stats);
|
|
vstats.push_back(stats);
|
|
}
|
|
}
|
|
|
|
Value getpeerinfo(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() != 0)
|
|
throw runtime_error(
|
|
"getpeerinfo\n"
|
|
"\nReturns data about each connected network node as a json array of objects.\n"
|
|
"\nbResult:\n"
|
|
"[\n"
|
|
" {\n"
|
|
" \"addr\":\"host:port\", (string) The ip address and port of the peer\n"
|
|
" \"addrlocal\":\"ip:port\", (string) local address\n"
|
|
" \"services\":\"00000001\", (string) The services\n"
|
|
" \"lastsend\": ttt, (numeric) The time in seconds since epoch (Jan 1 1970 GMT) of the last send\n"
|
|
" \"lastrecv\": ttt, (numeric) The time in seconds since epoch (Jan 1 1970 GMT) of the last receive\n"
|
|
" \"bytessent\": n, (numeric) The total bytes sent\n"
|
|
" \"bytesrecv\": n, (numeric) The total bytes received\n"
|
|
" \"conntime\": ttt, (numeric) The connection time in seconds since epoch (Jan 1 1970 GMT)\n"
|
|
" \"pingtime\": n, (numeric) ping time\n"
|
|
" \"pingwait\": n, (numeric) ping wait\n"
|
|
" \"version\": v, (numeric) The peer version, such as 7001\n"
|
|
" \"subver\": \"/Satoshi:0.8.5/\", (string) The string version\n"
|
|
" \"inbound\": true|false, (boolean) Inbound (true) or Outbound (false)\n"
|
|
" \"startingheight\": n, (numeric) The starting height (block) of the peer\n"
|
|
" \"banscore\": n, (numeric) The ban score (stats.nMisbehavior)\n"
|
|
" \"syncnode\" : true|false (booleamn) if sync node\n"
|
|
" }\n"
|
|
" ,...\n"
|
|
"}\n"
|
|
|
|
"\nExamples:\n"
|
|
+ HelpExampleCli("getpeerinfo", "")
|
|
+ HelpExampleRpc("getpeerinfo", "")
|
|
);
|
|
|
|
vector<CNodeStats> vstats;
|
|
CopyNodeStats(vstats);
|
|
|
|
Array ret;
|
|
|
|
BOOST_FOREACH(const CNodeStats& stats, vstats) {
|
|
Object obj;
|
|
CNodeStateStats statestats;
|
|
bool fStateStats = GetNodeStateStats(stats.nodeid, statestats);
|
|
obj.push_back(Pair("addr", stats.addrName));
|
|
if (!(stats.addrLocal.empty()))
|
|
obj.push_back(Pair("addrlocal", stats.addrLocal));
|
|
obj.push_back(Pair("services", strprintf("%08x", stats.nServices)));
|
|
obj.push_back(Pair("lastsend", stats.nLastSend));
|
|
obj.push_back(Pair("lastrecv", stats.nLastRecv));
|
|
obj.push_back(Pair("bytessent", stats.nSendBytes));
|
|
obj.push_back(Pair("bytesrecv", stats.nRecvBytes));
|
|
obj.push_back(Pair("conntime", stats.nTimeConnected));
|
|
obj.push_back(Pair("pingtime", stats.dPingTime));
|
|
if (stats.dPingWait > 0.0)
|
|
obj.push_back(Pair("pingwait", stats.dPingWait));
|
|
obj.push_back(Pair("version", stats.nVersion));
|
|
// Use the sanitized form of subver here, to avoid tricksy remote peers from
|
|
// corrupting or modifiying the JSON output by putting special characters in
|
|
// their ver message.
|
|
obj.push_back(Pair("subver", stats.cleanSubVer));
|
|
obj.push_back(Pair("inbound", stats.fInbound));
|
|
obj.push_back(Pair("startingheight", stats.nStartingHeight));
|
|
if (fStateStats) {
|
|
obj.push_back(Pair("banscore", statestats.nMisbehavior));
|
|
}
|
|
obj.push_back(Pair("syncnode", stats.fSyncNode));
|
|
obj.push_back(Pair("whitelisted", stats.fWhitelisted));
|
|
|
|
ret.push_back(obj);
|
|
}
|
|
|
|
return ret;
|
|
}
|
|
|
|
Value addnode(const Array& params, bool fHelp)
|
|
{
|
|
string strCommand;
|
|
if (params.size() == 2)
|
|
strCommand = params[1].get_str();
|
|
if (fHelp || params.size() != 2 ||
|
|
(strCommand != "onetry" && strCommand != "add" && strCommand != "remove"))
|
|
throw runtime_error(
|
|
"addnode \"node\" \"add|remove|onetry\"\n"
|
|
"\nAttempts add or remove a node from the addnode list.\n"
|
|
"Or try a connection to a node once.\n"
|
|
"\nArguments:\n"
|
|
"1. \"node\" (string, required) The node (see getpeerinfo for nodes)\n"
|
|
"2. \"command\" (string, required) 'add' to add a node to the list, 'remove' to remove a node from the list, 'onetry' to try a connection to the node once\n"
|
|
"\nExamples:\n"
|
|
+ HelpExampleCli("addnode", "\"192.168.0.6:22556\" \"onetry\"")
|
|
+ HelpExampleRpc("addnode", "\"192.168.0.6:22556\", \"onetry\"")
|
|
);
|
|
|
|
string strNode = params[0].get_str();
|
|
|
|
if (strCommand == "onetry")
|
|
{
|
|
CAddress addr;
|
|
ConnectNode(addr, strNode.c_str());
|
|
return Value::null;
|
|
}
|
|
|
|
LOCK(cs_vAddedNodes);
|
|
vector<string>::iterator it = vAddedNodes.begin();
|
|
for(; it != vAddedNodes.end(); it++)
|
|
if (strNode == *it)
|
|
break;
|
|
|
|
if (strCommand == "add")
|
|
{
|
|
if (it != vAddedNodes.end())
|
|
throw JSONRPCError(RPC_CLIENT_NODE_ALREADY_ADDED, "Error: Node already added");
|
|
vAddedNodes.push_back(strNode);
|
|
}
|
|
else if(strCommand == "remove")
|
|
{
|
|
if (it == vAddedNodes.end())
|
|
throw JSONRPCError(RPC_CLIENT_NODE_NOT_ADDED, "Error: Node has not been added.");
|
|
vAddedNodes.erase(it);
|
|
}
|
|
|
|
return Value::null;
|
|
}
|
|
|
|
Value getaddednodeinfo(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() < 1 || params.size() > 2)
|
|
throw runtime_error(
|
|
"getaddednodeinfo dns ( \"node\" )\n"
|
|
"\nReturns information about the given added node, or all added nodes\n"
|
|
"(note that onetry addnodes are not listed here)\n"
|
|
"If dns is false, only a list of added nodes will be provided,\n"
|
|
"otherwise connected information will also be available.\n"
|
|
"\nArguments:\n"
|
|
"1. dns (boolean, required) If false, only a list of added nodes will be provided, otherwise connected information will also be available.\n"
|
|
"2. \"node\" (string, optional) If provided, return information about this specific node, otherwise all nodes are returned.\n"
|
|
"\nResult:\n"
|
|
"[\n"
|
|
" {\n"
|
|
" \"addednode\" : \"192.168.0.201\", (string) The node ip address\n"
|
|
" \"connected\" : true|false, (boolean) If connected\n"
|
|
" \"addresses\" : [\n"
|
|
" {\n"
|
|
" \"address\" : \"192.168.0.201:22556\", (string) The Dogecoin server host and port\n"
|
|
" \"connected\" : \"outbound\" (string) connection, inbound or outbound\n"
|
|
" }\n"
|
|
" ,...\n"
|
|
" ]\n"
|
|
" }\n"
|
|
" ,...\n"
|
|
"]\n"
|
|
"\nExamples:\n"
|
|
+ HelpExampleCli("getaddednodeinfo", "true")
|
|
+ HelpExampleCli("getaddednodeinfo", "true \"192.168.0.201\"")
|
|
+ HelpExampleRpc("getaddednodeinfo", "true, \"192.168.0.201\"")
|
|
);
|
|
|
|
bool fDns = params[0].get_bool();
|
|
|
|
list<string> laddedNodes(0);
|
|
if (params.size() == 1)
|
|
{
|
|
LOCK(cs_vAddedNodes);
|
|
BOOST_FOREACH(string& strAddNode, vAddedNodes)
|
|
laddedNodes.push_back(strAddNode);
|
|
}
|
|
else
|
|
{
|
|
string strNode = params[1].get_str();
|
|
LOCK(cs_vAddedNodes);
|
|
BOOST_FOREACH(string& strAddNode, vAddedNodes)
|
|
if (strAddNode == strNode)
|
|
{
|
|
laddedNodes.push_back(strAddNode);
|
|
break;
|
|
}
|
|
if (laddedNodes.size() == 0)
|
|
throw JSONRPCError(RPC_CLIENT_NODE_NOT_ADDED, "Error: Node has not been added.");
|
|
}
|
|
|
|
Array ret;
|
|
if (!fDns)
|
|
{
|
|
BOOST_FOREACH(string& strAddNode, laddedNodes)
|
|
{
|
|
Object obj;
|
|
obj.push_back(Pair("addednode", strAddNode));
|
|
ret.push_back(obj);
|
|
}
|
|
return ret;
|
|
}
|
|
|
|
list<pair<string, vector<CService> > > laddedAddreses(0);
|
|
BOOST_FOREACH(string& strAddNode, laddedNodes)
|
|
{
|
|
vector<CService> vservNode(0);
|
|
if(Lookup(strAddNode.c_str(), vservNode, Params().GetDefaultPort(), fNameLookup, 0))
|
|
laddedAddreses.push_back(make_pair(strAddNode, vservNode));
|
|
else
|
|
{
|
|
Object obj;
|
|
obj.push_back(Pair("addednode", strAddNode));
|
|
obj.push_back(Pair("connected", false));
|
|
Array addresses;
|
|
obj.push_back(Pair("addresses", addresses));
|
|
}
|
|
}
|
|
|
|
LOCK(cs_vNodes);
|
|
for (list<pair<string, vector<CService> > >::iterator it = laddedAddreses.begin(); it != laddedAddreses.end(); it++)
|
|
{
|
|
Object obj;
|
|
obj.push_back(Pair("addednode", it->first));
|
|
|
|
Array addresses;
|
|
bool fConnected = false;
|
|
BOOST_FOREACH(CService& addrNode, it->second)
|
|
{
|
|
bool fFound = false;
|
|
Object node;
|
|
node.push_back(Pair("address", addrNode.ToString()));
|
|
BOOST_FOREACH(CNode* pnode, vNodes)
|
|
if (pnode->addr == addrNode)
|
|
{
|
|
fFound = true;
|
|
fConnected = true;
|
|
node.push_back(Pair("connected", pnode->fInbound ? "inbound" : "outbound"));
|
|
break;
|
|
}
|
|
if (!fFound)
|
|
node.push_back(Pair("connected", "false"));
|
|
addresses.push_back(node);
|
|
}
|
|
obj.push_back(Pair("connected", fConnected));
|
|
obj.push_back(Pair("addresses", addresses));
|
|
ret.push_back(obj);
|
|
}
|
|
|
|
return ret;
|
|
}
|
|
|
|
Value getnettotals(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() > 0)
|
|
throw runtime_error(
|
|
"getnettotals\n"
|
|
"\nReturns information about network traffic, including bytes in, bytes out,\n"
|
|
"and current time.\n"
|
|
"\nResult:\n"
|
|
"{\n"
|
|
" \"totalbytesrecv\": n, (numeric) Total bytes received\n"
|
|
" \"totalbytessent\": n, (numeric) Total bytes sent\n"
|
|
" \"timemillis\": t (numeric) Total cpu time\n"
|
|
"}\n"
|
|
"\nExamples:\n"
|
|
+ HelpExampleCli("getnettotals", "")
|
|
+ HelpExampleRpc("getnettotals", "")
|
|
);
|
|
|
|
Object obj;
|
|
obj.push_back(Pair("totalbytesrecv", CNode::GetTotalBytesRecv()));
|
|
obj.push_back(Pair("totalbytessent", CNode::GetTotalBytesSent()));
|
|
obj.push_back(Pair("timemillis", GetTimeMillis()));
|
|
return obj;
|
|
}
|
|
|
|
Value getnetworkinfo(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() != 0)
|
|
throw runtime_error(
|
|
"getnetworkinfo\n"
|
|
"Returns an object containing various state info regarding P2P networking.\n"
|
|
"\nResult:\n"
|
|
"{\n"
|
|
" \"version\": xxxxx, (numeric) the server version\n"
|
|
" \"protocolversion\": xxxxx, (numeric) the protocol version\n"
|
|
" \"timeoffset\": xxxxx, (numeric) the time offset\n"
|
|
" \"connections\": xxxxx, (numeric) the number of connections\n"
|
|
" \"proxy\": \"host:port\", (string, optional) the proxy used by the server\n"
|
|
" \"relayfee\": x.xxxx, (numeric) minimum relay fee for non-free transactions in btc/kb\n"
|
|
" \"localaddresses\": [, (array) list of local addresses\n"
|
|
" \"address\": \"xxxx\", (string) network address\n"
|
|
" \"port\": xxx, (numeric) network port\n"
|
|
" \"score\": xxx (numeric) relative score\n"
|
|
" ]\n"
|
|
"}\n"
|
|
"\nExamples:\n"
|
|
+ HelpExampleCli("getnetworkinfo", "")
|
|
+ HelpExampleRpc("getnetworkinfo", "")
|
|
);
|
|
|
|
proxyType proxy;
|
|
GetProxy(NET_IPV4, proxy);
|
|
|
|
Object obj;
|
|
obj.push_back(Pair("version", (int)CLIENT_VERSION));
|
|
obj.push_back(Pair("protocolversion",(int)PROTOCOL_VERSION));
|
|
obj.push_back(Pair("timeoffset", GetTimeOffset()));
|
|
obj.push_back(Pair("connections", (int)vNodes.size()));
|
|
obj.push_back(Pair("proxy", (proxy.IsValid() ? proxy.ToStringIPPort() : string())));
|
|
obj.push_back(Pair("relayfee", ValueFromAmount(CTransaction::nMinRelayTxFee)));
|
|
Array localAddresses;
|
|
{
|
|
LOCK(cs_mapLocalHost);
|
|
BOOST_FOREACH(const PAIRTYPE(CNetAddr, LocalServiceInfo) &item, mapLocalHost)
|
|
{
|
|
Object rec;
|
|
rec.push_back(Pair("address", item.first.ToString()));
|
|
rec.push_back(Pair("port", item.second.nPort));
|
|
rec.push_back(Pair("score", item.second.nScore));
|
|
localAddresses.push_back(rec);
|
|
}
|
|
}
|
|
obj.push_back(Pair("localaddresses", localAddresses));
|
|
return obj;
|
|
}
|