mirror of
https://github.com/dashpay/dash.git
synced 2024-12-27 21:12:48 +01:00
0e4b317555
The new class is accessed via the Params() method and holds most things that vary between main, test and regtest networks. The regtest mode has two purposes, one is to run the bitcoind/bitcoinj comparison tool which compares two separate implementations of the Bitcoin protocol looking for divergence. The other is that when run, you get a local node which can mine a single block instantly, which is highly convenient for testing apps during development as there's no need to wait 10 minutes for a block on the testnet.
388 lines
14 KiB
C++
388 lines
14 KiB
C++
// Copyright (c) 2010 Satoshi Nakamoto
|
|
// Copyright (c) 2009-2012 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 "chainparams.h"
|
|
#include "main.h"
|
|
#include "db.h"
|
|
#include "init.h"
|
|
#include "bitcoinrpc.h"
|
|
|
|
using namespace json_spirit;
|
|
using namespace std;
|
|
|
|
// Key used by getwork/getblocktemplate miners.
|
|
// Allocated in InitRPCMining, free'd in ShutdownRPCMining
|
|
static CReserveKey* pMiningKey = NULL;
|
|
|
|
void InitRPCMining()
|
|
{
|
|
// getwork/getblocktemplate mining rewards paid here:
|
|
pMiningKey = new CReserveKey(pwalletMain);
|
|
}
|
|
|
|
void ShutdownRPCMining()
|
|
{
|
|
delete pMiningKey; pMiningKey = NULL;
|
|
}
|
|
|
|
Value getgenerate(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() != 0)
|
|
throw runtime_error(
|
|
"getgenerate\n"
|
|
"Returns true or false.");
|
|
|
|
return GetBoolArg("-gen", false);
|
|
}
|
|
|
|
|
|
Value setgenerate(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() < 1 || params.size() > 2)
|
|
throw runtime_error(
|
|
"setgenerate <generate> [genproclimit]\n"
|
|
"<generate> is true or false to turn generation on or off.\n"
|
|
"Generation is limited to [genproclimit] processors, -1 is unlimited.");
|
|
|
|
bool fGenerate = true;
|
|
if (params.size() > 0)
|
|
fGenerate = params[0].get_bool();
|
|
|
|
if (params.size() > 1)
|
|
{
|
|
int nGenProcLimit = params[1].get_int();
|
|
mapArgs["-genproclimit"] = itostr(nGenProcLimit);
|
|
if (nGenProcLimit == 0)
|
|
fGenerate = false;
|
|
}
|
|
mapArgs["-gen"] = (fGenerate ? "1" : "0");
|
|
|
|
GenerateBitcoins(fGenerate, pwalletMain);
|
|
return Value::null;
|
|
}
|
|
|
|
|
|
Value gethashespersec(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() != 0)
|
|
throw runtime_error(
|
|
"gethashespersec\n"
|
|
"Returns a recent hashes per second performance measurement while generating.");
|
|
|
|
if (GetTimeMillis() - nHPSTimerStart > 8000)
|
|
return (boost::int64_t)0;
|
|
return (boost::int64_t)dHashesPerSec;
|
|
}
|
|
|
|
|
|
Value getmininginfo(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() != 0)
|
|
throw runtime_error(
|
|
"getmininginfo\n"
|
|
"Returns an object containing mining-related information.");
|
|
|
|
Object obj;
|
|
obj.push_back(Pair("blocks", (int)nBestHeight));
|
|
obj.push_back(Pair("currentblocksize", (uint64_t)nLastBlockSize));
|
|
obj.push_back(Pair("currentblocktx", (uint64_t)nLastBlockTx));
|
|
obj.push_back(Pair("difficulty", (double)GetDifficulty()));
|
|
obj.push_back(Pair("errors", GetWarnings("statusbar")));
|
|
obj.push_back(Pair("generate", GetBoolArg("-gen", false)));
|
|
obj.push_back(Pair("genproclimit", (int)GetArg("-genproclimit", -1)));
|
|
obj.push_back(Pair("hashespersec", gethashespersec(params, false)));
|
|
obj.push_back(Pair("pooledtx", (uint64_t)mempool.size()));
|
|
obj.push_back(Pair("testnet", TestNet()));
|
|
return obj;
|
|
}
|
|
|
|
|
|
Value getwork(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() > 1)
|
|
throw runtime_error(
|
|
"getwork [data]\n"
|
|
"If [data] is not specified, returns formatted hash data to work on:\n"
|
|
" \"midstate\" : precomputed hash state after hashing the first half of the data (DEPRECATED)\n" // deprecated
|
|
" \"data\" : block data\n"
|
|
" \"hash1\" : formatted hash buffer for second hash (DEPRECATED)\n" // deprecated
|
|
" \"target\" : little endian hash target\n"
|
|
"If [data] is specified, tries to solve the block and returns true if it was successful.");
|
|
|
|
if (vNodes.empty())
|
|
throw JSONRPCError(RPC_CLIENT_NOT_CONNECTED, "Bitcoin is not connected!");
|
|
|
|
if (IsInitialBlockDownload())
|
|
throw JSONRPCError(RPC_CLIENT_IN_INITIAL_DOWNLOAD, "Bitcoin is downloading blocks...");
|
|
|
|
typedef map<uint256, pair<CBlock*, CScript> > mapNewBlock_t;
|
|
static mapNewBlock_t mapNewBlock; // FIXME: thread safety
|
|
static vector<CBlockTemplate*> vNewBlockTemplate;
|
|
|
|
if (params.size() == 0)
|
|
{
|
|
// Update block
|
|
static unsigned int nTransactionsUpdatedLast;
|
|
static CBlockIndex* pindexPrev;
|
|
static int64 nStart;
|
|
static CBlockTemplate* pblocktemplate;
|
|
if (pindexPrev != pindexBest ||
|
|
(nTransactionsUpdated != nTransactionsUpdatedLast && GetTime() - nStart > 60))
|
|
{
|
|
if (pindexPrev != pindexBest)
|
|
{
|
|
// Deallocate old blocks since they're obsolete now
|
|
mapNewBlock.clear();
|
|
BOOST_FOREACH(CBlockTemplate* pblocktemplate, vNewBlockTemplate)
|
|
delete pblocktemplate;
|
|
vNewBlockTemplate.clear();
|
|
}
|
|
|
|
// Clear pindexPrev so future getworks make a new block, despite any failures from here on
|
|
pindexPrev = NULL;
|
|
|
|
// Store the pindexBest used before CreateNewBlock, to avoid races
|
|
nTransactionsUpdatedLast = nTransactionsUpdated;
|
|
CBlockIndex* pindexPrevNew = pindexBest;
|
|
nStart = GetTime();
|
|
|
|
// Create new block
|
|
pblocktemplate = CreateNewBlock(*pMiningKey);
|
|
if (!pblocktemplate)
|
|
throw JSONRPCError(RPC_OUT_OF_MEMORY, "Out of memory");
|
|
vNewBlockTemplate.push_back(pblocktemplate);
|
|
|
|
// Need to update only after we know CreateNewBlock succeeded
|
|
pindexPrev = pindexPrevNew;
|
|
}
|
|
CBlock* pblock = &pblocktemplate->block; // pointer for convenience
|
|
|
|
// Update nTime
|
|
UpdateTime(*pblock, pindexPrev);
|
|
pblock->nNonce = 0;
|
|
|
|
// Update nExtraNonce
|
|
static unsigned int nExtraNonce = 0;
|
|
IncrementExtraNonce(pblock, pindexPrev, nExtraNonce);
|
|
|
|
// Save
|
|
mapNewBlock[pblock->hashMerkleRoot] = make_pair(pblock, pblock->vtx[0].vin[0].scriptSig);
|
|
|
|
// Pre-build hash buffers
|
|
char pmidstate[32];
|
|
char pdata[128];
|
|
char phash1[64];
|
|
FormatHashBuffers(pblock, pmidstate, pdata, phash1);
|
|
|
|
uint256 hashTarget = CBigNum().SetCompact(pblock->nBits).getuint256();
|
|
|
|
Object result;
|
|
result.push_back(Pair("midstate", HexStr(BEGIN(pmidstate), END(pmidstate)))); // deprecated
|
|
result.push_back(Pair("data", HexStr(BEGIN(pdata), END(pdata))));
|
|
result.push_back(Pair("hash1", HexStr(BEGIN(phash1), END(phash1)))); // deprecated
|
|
result.push_back(Pair("target", HexStr(BEGIN(hashTarget), END(hashTarget))));
|
|
return result;
|
|
}
|
|
else
|
|
{
|
|
// Parse parameters
|
|
vector<unsigned char> vchData = ParseHex(params[0].get_str());
|
|
if (vchData.size() != 128)
|
|
throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid parameter");
|
|
CBlock* pdata = (CBlock*)&vchData[0];
|
|
|
|
// Byte reverse
|
|
for (int i = 0; i < 128/4; i++)
|
|
((unsigned int*)pdata)[i] = ByteReverse(((unsigned int*)pdata)[i]);
|
|
|
|
// Get saved block
|
|
if (!mapNewBlock.count(pdata->hashMerkleRoot))
|
|
return false;
|
|
CBlock* pblock = mapNewBlock[pdata->hashMerkleRoot].first;
|
|
|
|
pblock->nTime = pdata->nTime;
|
|
pblock->nNonce = pdata->nNonce;
|
|
pblock->vtx[0].vin[0].scriptSig = mapNewBlock[pdata->hashMerkleRoot].second;
|
|
pblock->hashMerkleRoot = pblock->BuildMerkleTree();
|
|
|
|
return CheckWork(pblock, *pwalletMain, *pMiningKey);
|
|
}
|
|
}
|
|
|
|
|
|
Value getblocktemplate(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() > 1)
|
|
throw runtime_error(
|
|
"getblocktemplate [params]\n"
|
|
"Returns data needed to construct a block to work on:\n"
|
|
" \"version\" : block version\n"
|
|
" \"previousblockhash\" : hash of current highest block\n"
|
|
" \"transactions\" : contents of non-coinbase transactions that should be included in the next block\n"
|
|
" \"coinbaseaux\" : data that should be included in coinbase\n"
|
|
" \"coinbasevalue\" : maximum allowable input to coinbase transaction, including the generation award and transaction fees\n"
|
|
" \"target\" : hash target\n"
|
|
" \"mintime\" : minimum timestamp appropriate for next block\n"
|
|
" \"curtime\" : current timestamp\n"
|
|
" \"mutable\" : list of ways the block template may be changed\n"
|
|
" \"noncerange\" : range of valid nonces\n"
|
|
" \"sigoplimit\" : limit of sigops in blocks\n"
|
|
" \"sizelimit\" : limit of block size\n"
|
|
" \"bits\" : compressed target of next block\n"
|
|
" \"height\" : height of the next block\n"
|
|
"See https://en.bitcoin.it/wiki/BIP_0022 for full specification.");
|
|
|
|
std::string strMode = "template";
|
|
if (params.size() > 0)
|
|
{
|
|
const Object& oparam = params[0].get_obj();
|
|
const Value& modeval = find_value(oparam, "mode");
|
|
if (modeval.type() == str_type)
|
|
strMode = modeval.get_str();
|
|
else if (modeval.type() == null_type)
|
|
{
|
|
/* Do nothing */
|
|
}
|
|
else
|
|
throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid mode");
|
|
}
|
|
|
|
if (strMode != "template")
|
|
throw JSONRPCError(RPC_INVALID_PARAMETER, "Invalid mode");
|
|
|
|
if (vNodes.empty())
|
|
throw JSONRPCError(RPC_CLIENT_NOT_CONNECTED, "Bitcoin is not connected!");
|
|
|
|
if (IsInitialBlockDownload())
|
|
throw JSONRPCError(RPC_CLIENT_IN_INITIAL_DOWNLOAD, "Bitcoin is downloading blocks...");
|
|
|
|
// Update block
|
|
static unsigned int nTransactionsUpdatedLast;
|
|
static CBlockIndex* pindexPrev;
|
|
static int64 nStart;
|
|
static CBlockTemplate* pblocktemplate;
|
|
if (pindexPrev != pindexBest ||
|
|
(nTransactionsUpdated != nTransactionsUpdatedLast && GetTime() - nStart > 5))
|
|
{
|
|
// Clear pindexPrev so future calls make a new block, despite any failures from here on
|
|
pindexPrev = NULL;
|
|
|
|
// Store the pindexBest used before CreateNewBlock, to avoid races
|
|
nTransactionsUpdatedLast = nTransactionsUpdated;
|
|
CBlockIndex* pindexPrevNew = pindexBest;
|
|
nStart = GetTime();
|
|
|
|
// Create new block
|
|
if(pblocktemplate)
|
|
{
|
|
delete pblocktemplate;
|
|
pblocktemplate = NULL;
|
|
}
|
|
pblocktemplate = CreateNewBlock(*pMiningKey);
|
|
if (!pblocktemplate)
|
|
throw JSONRPCError(RPC_OUT_OF_MEMORY, "Out of memory");
|
|
|
|
// Need to update only after we know CreateNewBlock succeeded
|
|
pindexPrev = pindexPrevNew;
|
|
}
|
|
CBlock* pblock = &pblocktemplate->block; // pointer for convenience
|
|
|
|
// Update nTime
|
|
UpdateTime(*pblock, pindexPrev);
|
|
pblock->nNonce = 0;
|
|
|
|
Array transactions;
|
|
map<uint256, int64_t> setTxIndex;
|
|
int i = 0;
|
|
BOOST_FOREACH (CTransaction& tx, pblock->vtx)
|
|
{
|
|
uint256 txHash = tx.GetHash();
|
|
setTxIndex[txHash] = i++;
|
|
|
|
if (tx.IsCoinBase())
|
|
continue;
|
|
|
|
Object entry;
|
|
|
|
CDataStream ssTx(SER_NETWORK, PROTOCOL_VERSION);
|
|
ssTx << tx;
|
|
entry.push_back(Pair("data", HexStr(ssTx.begin(), ssTx.end())));
|
|
|
|
entry.push_back(Pair("hash", txHash.GetHex()));
|
|
|
|
Array deps;
|
|
BOOST_FOREACH (const CTxIn &in, tx.vin)
|
|
{
|
|
if (setTxIndex.count(in.prevout.hash))
|
|
deps.push_back(setTxIndex[in.prevout.hash]);
|
|
}
|
|
entry.push_back(Pair("depends", deps));
|
|
|
|
int index_in_template = i - 1;
|
|
entry.push_back(Pair("fee", pblocktemplate->vTxFees[index_in_template]));
|
|
entry.push_back(Pair("sigops", pblocktemplate->vTxSigOps[index_in_template]));
|
|
|
|
transactions.push_back(entry);
|
|
}
|
|
|
|
Object aux;
|
|
aux.push_back(Pair("flags", HexStr(COINBASE_FLAGS.begin(), COINBASE_FLAGS.end())));
|
|
|
|
uint256 hashTarget = CBigNum().SetCompact(pblock->nBits).getuint256();
|
|
|
|
static Array aMutable;
|
|
if (aMutable.empty())
|
|
{
|
|
aMutable.push_back("time");
|
|
aMutable.push_back("transactions");
|
|
aMutable.push_back("prevblock");
|
|
}
|
|
|
|
Object result;
|
|
result.push_back(Pair("version", pblock->nVersion));
|
|
result.push_back(Pair("previousblockhash", pblock->hashPrevBlock.GetHex()));
|
|
result.push_back(Pair("transactions", transactions));
|
|
result.push_back(Pair("coinbaseaux", aux));
|
|
result.push_back(Pair("coinbasevalue", (int64_t)pblock->vtx[0].vout[0].nValue));
|
|
result.push_back(Pair("target", hashTarget.GetHex()));
|
|
result.push_back(Pair("mintime", (int64_t)pindexPrev->GetMedianTimePast()+1));
|
|
result.push_back(Pair("mutable", aMutable));
|
|
result.push_back(Pair("noncerange", "00000000ffffffff"));
|
|
result.push_back(Pair("sigoplimit", (int64_t)MAX_BLOCK_SIGOPS));
|
|
result.push_back(Pair("sizelimit", (int64_t)MAX_BLOCK_SIZE));
|
|
result.push_back(Pair("curtime", (int64_t)pblock->nTime));
|
|
result.push_back(Pair("bits", HexBits(pblock->nBits)));
|
|
result.push_back(Pair("height", (int64_t)(pindexPrev->nHeight+1)));
|
|
|
|
return result;
|
|
}
|
|
|
|
Value submitblock(const Array& params, bool fHelp)
|
|
{
|
|
if (fHelp || params.size() < 1 || params.size() > 2)
|
|
throw runtime_error(
|
|
"submitblock <hex data> [optional-params-obj]\n"
|
|
"[optional-params-obj] parameter is currently ignored.\n"
|
|
"Attempts to submit new block to network.\n"
|
|
"See https://en.bitcoin.it/wiki/BIP_0022 for full specification.");
|
|
|
|
vector<unsigned char> blockData(ParseHex(params[0].get_str()));
|
|
CDataStream ssBlock(blockData, SER_NETWORK, PROTOCOL_VERSION);
|
|
CBlock pblock;
|
|
try {
|
|
ssBlock >> pblock;
|
|
}
|
|
catch (std::exception &e) {
|
|
throw JSONRPCError(RPC_DESERIALIZATION_ERROR, "Block decode failed");
|
|
}
|
|
|
|
CValidationState state;
|
|
bool fAccepted = ProcessBlock(state, NULL, &pblock);
|
|
if (!fAccepted)
|
|
return "rejected"; // TODO: report validation state
|
|
|
|
return Value::null;
|
|
}
|