]>
Commit | Line | Data |
---|---|---|
1 | // Copyright (c) 2009-2010 Satoshi Nakamoto | |
2 | // Copyright (c) 2009-2014 The Bitcoin Core developers | |
3 | // Distributed under the MIT software license, see the accompanying | |
4 | // file COPYING or http://www.opensource.org/licenses/mit-license.php. | |
5 | ||
6 | #if defined(HAVE_CONFIG_H) | |
7 | #include "config/bitcoin-config.h" | |
8 | #endif | |
9 | ||
10 | #include "init.h" | |
11 | #include "sodium.h" | |
12 | ||
13 | #include "addrman.h" | |
14 | #include "amount.h" | |
15 | #include "checkpoints.h" | |
16 | #include "compat/sanity.h" | |
17 | #include "consensus/validation.h" | |
18 | #include "key.h" | |
19 | #include "main.h" | |
20 | #include "miner.h" | |
21 | #include "net.h" | |
22 | #include "rpcserver.h" | |
23 | #include "script/standard.h" | |
24 | #include "scheduler.h" | |
25 | #include "txdb.h" | |
26 | #include "ui_interface.h" | |
27 | #include "util.h" | |
28 | #include "utilmoneystr.h" | |
29 | #include "validationinterface.h" | |
30 | #ifdef ENABLE_WALLET | |
31 | #include "wallet/wallet.h" | |
32 | #include "wallet/walletdb.h" | |
33 | #endif | |
34 | ||
35 | #include <stdint.h> | |
36 | #include <stdio.h> | |
37 | ||
38 | #ifndef WIN32 | |
39 | #include <signal.h> | |
40 | #endif | |
41 | ||
42 | #include <boost/algorithm/string/predicate.hpp> | |
43 | #include <boost/algorithm/string/replace.hpp> | |
44 | #include <boost/bind.hpp> | |
45 | #include <boost/filesystem.hpp> | |
46 | #include <boost/function.hpp> | |
47 | #include <boost/interprocess/sync/file_lock.hpp> | |
48 | #include <boost/thread.hpp> | |
49 | #include <openssl/crypto.h> | |
50 | ||
51 | #include "libsnark/common/profiling.hpp" | |
52 | ||
53 | using namespace std; | |
54 | ||
55 | extern void ThreadSendAlert(); | |
56 | ||
57 | ZCJoinSplit* pzcashParams = NULL; | |
58 | ||
59 | #ifdef ENABLE_WALLET | |
60 | CWallet* pwalletMain = NULL; | |
61 | #endif | |
62 | bool fFeeEstimatesInitialized = false; | |
63 | ||
64 | #ifdef WIN32 | |
65 | // Win32 LevelDB doesn't use filedescriptors, and the ones used for | |
66 | // accessing block files don't count towards the fd_set size limit | |
67 | // anyway. | |
68 | #define MIN_CORE_FILEDESCRIPTORS 0 | |
69 | #else | |
70 | #define MIN_CORE_FILEDESCRIPTORS 150 | |
71 | #endif | |
72 | ||
73 | /** Used to pass flags to the Bind() function */ | |
74 | enum BindFlags { | |
75 | BF_NONE = 0, | |
76 | BF_EXPLICIT = (1U << 0), | |
77 | BF_REPORT_ERROR = (1U << 1), | |
78 | BF_WHITELIST = (1U << 2), | |
79 | }; | |
80 | ||
81 | static const char* FEE_ESTIMATES_FILENAME="fee_estimates.dat"; | |
82 | CClientUIInterface uiInterface; // Declared but not defined in ui_interface.h | |
83 | ||
84 | ////////////////////////////////////////////////////////////////////////////// | |
85 | // | |
86 | // Shutdown | |
87 | // | |
88 | ||
89 | // | |
90 | // Thread management and startup/shutdown: | |
91 | // | |
92 | // The network-processing threads are all part of a thread group | |
93 | // created by AppInit() or the Qt main() function. | |
94 | // | |
95 | // A clean exit happens when StartShutdown() or the SIGTERM | |
96 | // signal handler sets fRequestShutdown, which triggers | |
97 | // the DetectShutdownThread(), which interrupts the main thread group. | |
98 | // DetectShutdownThread() then exits, which causes AppInit() to | |
99 | // continue (it .joins the shutdown thread). | |
100 | // Shutdown() is then | |
101 | // called to clean up database connections, and stop other | |
102 | // threads that should only be stopped after the main network-processing | |
103 | // threads have exited. | |
104 | // | |
105 | // Note that if running -daemon the parent process returns from AppInit2 | |
106 | // before adding any threads to the threadGroup, so .join_all() returns | |
107 | // immediately and the parent exits from main(). | |
108 | // | |
109 | // Shutdown for Qt is very similar, only it uses a QTimer to detect | |
110 | // fRequestShutdown getting set, and then does the normal Qt | |
111 | // shutdown thing. | |
112 | // | |
113 | ||
114 | volatile bool fRequestShutdown = false; | |
115 | ||
116 | void StartShutdown() | |
117 | { | |
118 | fRequestShutdown = true; | |
119 | } | |
120 | bool ShutdownRequested() | |
121 | { | |
122 | return fRequestShutdown; | |
123 | } | |
124 | ||
125 | class CCoinsViewErrorCatcher : public CCoinsViewBacked | |
126 | { | |
127 | public: | |
128 | CCoinsViewErrorCatcher(CCoinsView* view) : CCoinsViewBacked(view) {} | |
129 | bool GetCoins(const uint256 &txid, CCoins &coins) const { | |
130 | try { | |
131 | return CCoinsViewBacked::GetCoins(txid, coins); | |
132 | } catch(const std::runtime_error& e) { | |
133 | uiInterface.ThreadSafeMessageBox(_("Error reading from database, shutting down."), "", CClientUIInterface::MSG_ERROR); | |
134 | LogPrintf("Error reading from database: %s\n", e.what()); | |
135 | // Starting the shutdown sequence and returning false to the caller would be | |
136 | // interpreted as 'entry not found' (as opposed to unable to read data), and | |
137 | // could lead to invalid interpretation. Just exit immediately, as we can't | |
138 | // continue anyway, and all writes should be atomic. | |
139 | abort(); | |
140 | } | |
141 | } | |
142 | // Writes do not need similar protection, as failure to write is handled by the caller. | |
143 | }; | |
144 | ||
145 | static CCoinsViewDB *pcoinsdbview = NULL; | |
146 | static CCoinsViewErrorCatcher *pcoinscatcher = NULL; | |
147 | ||
148 | void Shutdown() | |
149 | { | |
150 | LogPrintf("%s: In progress...\n", __func__); | |
151 | static CCriticalSection cs_Shutdown; | |
152 | TRY_LOCK(cs_Shutdown, lockShutdown); | |
153 | if (!lockShutdown) | |
154 | return; | |
155 | ||
156 | /// Note: Shutdown() must be able to handle cases in which AppInit2() failed part of the way, | |
157 | /// for example if the data directory was found to be locked. | |
158 | /// Be sure that anything that writes files or flushes caches only does this if the respective | |
159 | /// module was initialized. | |
160 | RenameThread("bitcoin-shutoff"); | |
161 | mempool.AddTransactionsUpdated(1); | |
162 | StopRPCThreads(); | |
163 | #ifdef ENABLE_WALLET | |
164 | if (pwalletMain) | |
165 | pwalletMain->Flush(false); | |
166 | GenerateBitcoins(false, NULL, 0); | |
167 | #endif | |
168 | StopNode(); | |
169 | UnregisterNodeSignals(GetNodeSignals()); | |
170 | ||
171 | if (fFeeEstimatesInitialized) | |
172 | { | |
173 | boost::filesystem::path est_path = GetDataDir() / FEE_ESTIMATES_FILENAME; | |
174 | CAutoFile est_fileout(fopen(est_path.string().c_str(), "wb"), SER_DISK, CLIENT_VERSION); | |
175 | if (!est_fileout.IsNull()) | |
176 | mempool.WriteFeeEstimates(est_fileout); | |
177 | else | |
178 | LogPrintf("%s: Failed to write fee estimates to %s\n", __func__, est_path.string()); | |
179 | fFeeEstimatesInitialized = false; | |
180 | } | |
181 | ||
182 | { | |
183 | LOCK(cs_main); | |
184 | if (pcoinsTip != NULL) { | |
185 | FlushStateToDisk(); | |
186 | } | |
187 | delete pcoinsTip; | |
188 | pcoinsTip = NULL; | |
189 | delete pcoinscatcher; | |
190 | pcoinscatcher = NULL; | |
191 | delete pcoinsdbview; | |
192 | pcoinsdbview = NULL; | |
193 | delete pblocktree; | |
194 | pblocktree = NULL; | |
195 | } | |
196 | #ifdef ENABLE_WALLET | |
197 | if (pwalletMain) | |
198 | pwalletMain->Flush(true); | |
199 | #endif | |
200 | #ifndef WIN32 | |
201 | try { | |
202 | boost::filesystem::remove(GetPidFile()); | |
203 | } catch (const boost::filesystem::filesystem_error& e) { | |
204 | LogPrintf("%s: Unable to remove pidfile: %s\n", __func__, e.what()); | |
205 | } | |
206 | #endif | |
207 | UnregisterAllValidationInterfaces(); | |
208 | #ifdef ENABLE_WALLET | |
209 | delete pwalletMain; | |
210 | pwalletMain = NULL; | |
211 | #endif | |
212 | ECC_Stop(); | |
213 | LogPrintf("%s: done\n", __func__); | |
214 | } | |
215 | ||
216 | /** | |
217 | * Signal handlers are very limited in what they are allowed to do, so: | |
218 | */ | |
219 | void HandleSIGTERM(int) | |
220 | { | |
221 | fRequestShutdown = true; | |
222 | } | |
223 | ||
224 | void HandleSIGHUP(int) | |
225 | { | |
226 | fReopenDebugLog = true; | |
227 | } | |
228 | ||
229 | bool static InitError(const std::string &str) | |
230 | { | |
231 | uiInterface.ThreadSafeMessageBox(str, "", CClientUIInterface::MSG_ERROR); | |
232 | return false; | |
233 | } | |
234 | ||
235 | bool static InitWarning(const std::string &str) | |
236 | { | |
237 | uiInterface.ThreadSafeMessageBox(str, "", CClientUIInterface::MSG_WARNING); | |
238 | return true; | |
239 | } | |
240 | ||
241 | bool static Bind(const CService &addr, unsigned int flags) { | |
242 | if (!(flags & BF_EXPLICIT) && IsLimited(addr)) | |
243 | return false; | |
244 | std::string strError; | |
245 | if (!BindListenPort(addr, strError, (flags & BF_WHITELIST) != 0)) { | |
246 | if (flags & BF_REPORT_ERROR) | |
247 | return InitError(strError); | |
248 | return false; | |
249 | } | |
250 | return true; | |
251 | } | |
252 | ||
253 | void OnRPCStopped() | |
254 | { | |
255 | cvBlockChange.notify_all(); | |
256 | LogPrint("rpc", "RPC stopped.\n"); | |
257 | } | |
258 | ||
259 | void OnRPCPreCommand(const CRPCCommand& cmd) | |
260 | { | |
261 | // Observe safe mode | |
262 | string strWarning = GetWarnings("rpc"); | |
263 | if (strWarning != "" && !GetBoolArg("-disablesafemode", false) && | |
264 | !cmd.okSafeMode) | |
265 | throw JSONRPCError(RPC_FORBIDDEN_BY_SAFE_MODE, string("Safe mode: ") + strWarning); | |
266 | } | |
267 | ||
268 | std::string HelpMessage(HelpMessageMode mode) | |
269 | { | |
270 | const bool showDebug = GetBoolArg("-help-debug", false); | |
271 | ||
272 | // When adding new options to the categories, please keep and ensure alphabetical ordering. | |
273 | // Do not translate _(...) -help-debug options, Many technical terms, and only a very small audience, so is unnecessary stress to translators | |
274 | ||
275 | string strUsage = HelpMessageGroup(_("Options:")); | |
276 | strUsage += HelpMessageOpt("-?", _("This help message")); | |
277 | strUsage += HelpMessageOpt("-alerts", strprintf(_("Receive and display P2P network alerts (default: %u)"), DEFAULT_ALERTS)); | |
278 | strUsage += HelpMessageOpt("-alertnotify=<cmd>", _("Execute command when a relevant alert is received or we see a really long fork (%s in cmd is replaced by message)")); | |
279 | strUsage += HelpMessageOpt("-blocknotify=<cmd>", _("Execute command when the best block changes (%s in cmd is replaced by block hash)")); | |
280 | strUsage += HelpMessageOpt("-checkblocks=<n>", strprintf(_("How many blocks to check at startup (default: %u, 0 = all)"), 288)); | |
281 | strUsage += HelpMessageOpt("-checklevel=<n>", strprintf(_("How thorough the block verification of -checkblocks is (0-4, default: %u)"), 3)); | |
282 | strUsage += HelpMessageOpt("-conf=<file>", strprintf(_("Specify configuration file (default: %s)"), "zcash.conf")); | |
283 | if (mode == HMM_BITCOIND) | |
284 | { | |
285 | #if !defined(WIN32) | |
286 | strUsage += HelpMessageOpt("-daemon", _("Run in the background as a daemon and accept commands")); | |
287 | #endif | |
288 | } | |
289 | strUsage += HelpMessageOpt("-datadir=<dir>", _("Specify data directory")); | |
290 | strUsage += HelpMessageOpt("-dbcache=<n>", strprintf(_("Set database cache size in megabytes (%d to %d, default: %d)"), nMinDbCache, nMaxDbCache, nDefaultDbCache)); | |
291 | strUsage += HelpMessageOpt("-loadblock=<file>", _("Imports blocks from external blk000??.dat file") + " " + _("on startup")); | |
292 | strUsage += HelpMessageOpt("-maxorphantx=<n>", strprintf(_("Keep at most <n> unconnectable transactions in memory (default: %u)"), DEFAULT_MAX_ORPHAN_TRANSACTIONS)); | |
293 | strUsage += HelpMessageOpt("-par=<n>", strprintf(_("Set the number of script verification threads (%u to %d, 0 = auto, <0 = leave that many cores free, default: %d)"), | |
294 | -(int)boost::thread::hardware_concurrency(), MAX_SCRIPTCHECK_THREADS, DEFAULT_SCRIPTCHECK_THREADS)); | |
295 | #ifndef WIN32 | |
296 | strUsage += HelpMessageOpt("-pid=<file>", strprintf(_("Specify pid file (default: %s)"), "zcashd.pid")); | |
297 | #endif | |
298 | strUsage += HelpMessageOpt("-prune=<n>", strprintf(_("Reduce storage requirements by pruning (deleting) old blocks. This mode disables wallet support and is incompatible with -txindex. " | |
299 | "Warning: Reverting this setting requires re-downloading the entire blockchain. " | |
300 | "(default: 0 = disable pruning blocks, >%u = target size in MiB to use for block files)"), MIN_DISK_SPACE_FOR_BLOCK_FILES / 1024 / 1024)); | |
301 | strUsage += HelpMessageOpt("-reindex", _("Rebuild block chain index from current blk000??.dat files on startup")); | |
302 | #if !defined(WIN32) | |
303 | strUsage += HelpMessageOpt("-sysperms", _("Create new files with system default permissions, instead of umask 077 (only effective with disabled wallet functionality)")); | |
304 | #endif | |
305 | strUsage += HelpMessageOpt("-txindex", strprintf(_("Maintain a full transaction index, used by the getrawtransaction rpc call (default: %u)"), 0)); | |
306 | ||
307 | strUsage += HelpMessageGroup(_("Connection options:")); | |
308 | strUsage += HelpMessageOpt("-addnode=<ip>", _("Add a node to connect to and attempt to keep the connection open")); | |
309 | strUsage += HelpMessageOpt("-banscore=<n>", strprintf(_("Threshold for disconnecting misbehaving peers (default: %u)"), 100)); | |
310 | strUsage += HelpMessageOpt("-bantime=<n>", strprintf(_("Number of seconds to keep misbehaving peers from reconnecting (default: %u)"), 86400)); | |
311 | strUsage += HelpMessageOpt("-bind=<addr>", _("Bind to given address and always listen on it. Use [host]:port notation for IPv6")); | |
312 | strUsage += HelpMessageOpt("-connect=<ip>", _("Connect only to the specified node(s)")); | |
313 | strUsage += HelpMessageOpt("-discover", _("Discover own IP addresses (default: 1 when listening and no -externalip or -proxy)")); | |
314 | strUsage += HelpMessageOpt("-dns", _("Allow DNS lookups for -addnode, -seednode and -connect") + " " + _("(default: 1)")); | |
315 | strUsage += HelpMessageOpt("-dnsseed", _("Query for peer addresses via DNS lookup, if low on addresses (default: 1 unless -connect)")); | |
316 | strUsage += HelpMessageOpt("-externalip=<ip>", _("Specify your own public address")); | |
317 | strUsage += HelpMessageOpt("-forcednsseed", strprintf(_("Always query for peer addresses via DNS lookup (default: %u)"), 0)); | |
318 | strUsage += HelpMessageOpt("-listen", _("Accept connections from outside (default: 1 if no -proxy or -connect)")); | |
319 | strUsage += HelpMessageOpt("-maxconnections=<n>", strprintf(_("Maintain at most <n> connections to peers (default: %u)"), 125)); | |
320 | strUsage += HelpMessageOpt("-maxreceivebuffer=<n>", strprintf(_("Maximum per-connection receive buffer, <n>*1000 bytes (default: %u)"), 5000)); | |
321 | strUsage += HelpMessageOpt("-maxsendbuffer=<n>", strprintf(_("Maximum per-connection send buffer, <n>*1000 bytes (default: %u)"), 1000)); | |
322 | strUsage += HelpMessageOpt("-onion=<ip:port>", strprintf(_("Use separate SOCKS5 proxy to reach peers via Tor hidden services (default: %s)"), "-proxy")); | |
323 | strUsage += HelpMessageOpt("-onlynet=<net>", _("Only connect to nodes in network <net> (ipv4, ipv6 or onion)")); | |
324 | strUsage += HelpMessageOpt("-permitbaremultisig", strprintf(_("Relay non-P2SH multisig (default: %u)"), 1)); | |
325 | strUsage += HelpMessageOpt("-port=<port>", strprintf(_("Listen for connections on <port> (default: %u or testnet: %u)"), 8233, 18233)); | |
326 | strUsage += HelpMessageOpt("-proxy=<ip:port>", _("Connect through SOCKS5 proxy")); | |
327 | strUsage += HelpMessageOpt("-proxyrandomize", strprintf(_("Randomize credentials for every proxy connection. This enables Tor stream isolation (default: %u)"), 1)); | |
328 | strUsage += HelpMessageOpt("-seednode=<ip>", _("Connect to a node to retrieve peer addresses, and disconnect")); | |
329 | strUsage += HelpMessageOpt("-timeout=<n>", strprintf(_("Specify connection timeout in milliseconds (minimum: 1, default: %d)"), DEFAULT_CONNECT_TIMEOUT)); | |
330 | #ifdef USE_UPNP | |
331 | #if USE_UPNP | |
332 | strUsage += HelpMessageOpt("-upnp", _("Use UPnP to map the listening port (default: 1 when listening)")); | |
333 | #else | |
334 | strUsage += HelpMessageOpt("-upnp", strprintf(_("Use UPnP to map the listening port (default: %u)"), 0)); | |
335 | #endif | |
336 | #endif | |
337 | strUsage += HelpMessageOpt("-whitebind=<addr>", _("Bind to given address and whitelist peers connecting to it. Use [host]:port notation for IPv6")); | |
338 | strUsage += HelpMessageOpt("-whitelist=<netmask>", _("Whitelist peers connecting from the given netmask or IP address. Can be specified multiple times.") + | |
339 | " " + _("Whitelisted peers cannot be DoS banned and their transactions are always relayed, even if they are already in the mempool, useful e.g. for a gateway")); | |
340 | ||
341 | ||
342 | #ifdef ENABLE_WALLET | |
343 | strUsage += HelpMessageGroup(_("Wallet options:")); | |
344 | strUsage += HelpMessageOpt("-disablewallet", _("Do not load the wallet and disable wallet RPC calls")); | |
345 | strUsage += HelpMessageOpt("-keypool=<n>", strprintf(_("Set key pool size to <n> (default: %u)"), 100)); | |
346 | if (showDebug) | |
347 | strUsage += HelpMessageOpt("-mintxfee=<amt>", strprintf("Fees (in BTC/Kb) smaller than this are considered zero fee for transaction creation (default: %s)", | |
348 | FormatMoney(CWallet::minTxFee.GetFeePerK()))); | |
349 | strUsage += HelpMessageOpt("-paytxfee=<amt>", strprintf(_("Fee (in BTC/kB) to add to transactions you send (default: %s)"), FormatMoney(payTxFee.GetFeePerK()))); | |
350 | strUsage += HelpMessageOpt("-rescan", _("Rescan the block chain for missing wallet transactions") + " " + _("on startup")); | |
351 | strUsage += HelpMessageOpt("-salvagewallet", _("Attempt to recover private keys from a corrupt wallet.dat") + " " + _("on startup")); | |
352 | strUsage += HelpMessageOpt("-sendfreetransactions", strprintf(_("Send transactions as zero-fee transactions if possible (default: %u)"), 0)); | |
353 | strUsage += HelpMessageOpt("-spendzeroconfchange", strprintf(_("Spend unconfirmed change when sending transactions (default: %u)"), 1)); | |
354 | strUsage += HelpMessageOpt("-txconfirmtarget=<n>", strprintf(_("If paytxfee is not set, include enough fee so transactions begin confirmation on average within n blocks (default: %u)"), DEFAULT_TX_CONFIRM_TARGET)); | |
355 | strUsage += HelpMessageOpt("-maxtxfee=<amt>", strprintf(_("Maximum total fees to use in a single wallet transaction; setting this too low may abort large transactions (default: %s)"), | |
356 | FormatMoney(maxTxFee))); | |
357 | strUsage += HelpMessageOpt("-upgradewallet", _("Upgrade wallet to latest format") + " " + _("on startup")); | |
358 | strUsage += HelpMessageOpt("-wallet=<file>", _("Specify wallet file (within data directory)") + " " + strprintf(_("(default: %s)"), "wallet.dat")); | |
359 | strUsage += HelpMessageOpt("-walletbroadcast", _("Make the wallet broadcast transactions") + " " + strprintf(_("(default: %u)"), true)); | |
360 | strUsage += HelpMessageOpt("-walletnotify=<cmd>", _("Execute command when a wallet transaction changes (%s in cmd is replaced by TxID)")); | |
361 | strUsage += HelpMessageOpt("-zapwallettxes=<mode>", _("Delete all wallet transactions and only recover those parts of the blockchain through -rescan on startup") + | |
362 | " " + _("(1 = keep tx meta data e.g. account owner and payment request information, 2 = drop tx meta data)")); | |
363 | ||
364 | #endif | |
365 | ||
366 | strUsage += HelpMessageGroup(_("Debugging/Testing options:")); | |
367 | if (showDebug) | |
368 | { | |
369 | strUsage += HelpMessageOpt("-checkpoints", strprintf("Only accept block chain matching built-in checkpoints (default: %u)", 1)); | |
370 | strUsage += HelpMessageOpt("-dblogsize=<n>", strprintf("Flush database activity from memory pool to disk log every <n> megabytes (default: %u)", 100)); | |
371 | strUsage += HelpMessageOpt("-disablesafemode", strprintf("Disable safemode, override a real safe mode event (default: %u)", 0)); | |
372 | strUsage += HelpMessageOpt("-testsafemode", strprintf("Force safe mode (default: %u)", 0)); | |
373 | strUsage += HelpMessageOpt("-dropmessagestest=<n>", "Randomly drop 1 of every <n> network messages"); | |
374 | strUsage += HelpMessageOpt("-fuzzmessagestest=<n>", "Randomly fuzz 1 of every <n> network messages"); | |
375 | strUsage += HelpMessageOpt("-flushwallet", strprintf("Run a thread to flush wallet periodically (default: %u)", 1)); | |
376 | strUsage += HelpMessageOpt("-stopafterblockimport", strprintf("Stop running after importing blocks from disk (default: %u)", 0)); | |
377 | } | |
378 | string debugCategories = "addrman, alert, bench, coindb, db, lock, rand, rpc, selectcoins, mempool, net, proxy, prune"; // Don't translate these and qt below | |
379 | if (mode == HMM_BITCOIN_QT) | |
380 | debugCategories += ", qt"; | |
381 | strUsage += HelpMessageOpt("-debug=<category>", strprintf(_("Output debugging information (default: %u, supplying <category> is optional)"), 0) + ". " + | |
382 | _("If <category> is not supplied, output all debugging information.") + _("<category> can be:") + " " + debugCategories + "."); | |
383 | #ifdef ENABLE_WALLET | |
384 | strUsage += HelpMessageOpt("-gen", strprintf(_("Generate coins (default: %u)"), 0)); | |
385 | strUsage += HelpMessageOpt("-genproclimit=<n>", strprintf(_("Set the number of threads for coin generation if enabled (-1 = all cores, default: %d)"), 1)); | |
386 | #endif | |
387 | strUsage += HelpMessageOpt("-help-debug", _("Show all debugging options (usage: --help -help-debug)")); | |
388 | strUsage += HelpMessageOpt("-logips", strprintf(_("Include IP addresses in debug output (default: %u)"), 0)); | |
389 | strUsage += HelpMessageOpt("-logtimestamps", strprintf(_("Prepend debug output with timestamp (default: %u)"), 1)); | |
390 | if (showDebug) | |
391 | { | |
392 | strUsage += HelpMessageOpt("-limitfreerelay=<n>", strprintf("Continuously rate-limit free transactions to <n>*1000 bytes per minute (default: %u)", 15)); | |
393 | strUsage += HelpMessageOpt("-relaypriority", strprintf("Require high priority for relaying free or low-fee transactions (default: %u)", 0)); | |
394 | strUsage += HelpMessageOpt("-maxsigcachesize=<n>", strprintf("Limit size of signature cache to <n> entries (default: %u)", 50000)); | |
395 | } | |
396 | strUsage += HelpMessageOpt("-minrelaytxfee=<amt>", strprintf(_("Fees (in BTC/Kb) smaller than this are considered zero fee for relaying (default: %s)"), FormatMoney(::minRelayTxFee.GetFeePerK()))); | |
397 | strUsage += HelpMessageOpt("-printtoconsole", _("Send trace/debug info to console instead of debug.log file")); | |
398 | if (showDebug) | |
399 | { | |
400 | strUsage += HelpMessageOpt("-printpriority", strprintf("Log transaction priority and fee per kB when mining blocks (default: %u)", 0)); | |
401 | strUsage += HelpMessageOpt("-privdb", strprintf("Sets the DB_PRIVATE flag in the wallet db environment (default: %u)", 1)); | |
402 | strUsage += HelpMessageOpt("-regtest", "Enter regression test mode, which uses a special chain in which blocks can be solved instantly. " | |
403 | "This is intended for regression testing tools and app development."); | |
404 | } | |
405 | strUsage += HelpMessageOpt("-shrinkdebugfile", _("Shrink debug.log file on client startup (default: 1 when no -debug)")); | |
406 | strUsage += HelpMessageOpt("-testnet", _("Use the test network")); | |
407 | ||
408 | strUsage += HelpMessageGroup(_("Node relay options:")); | |
409 | strUsage += HelpMessageOpt("-datacarrier", strprintf(_("Relay and mine data carrier transactions (default: %u)"), 1)); | |
410 | strUsage += HelpMessageOpt("-datacarriersize", strprintf(_("Maximum size of data in data carrier transactions we relay and mine (default: %u)"), MAX_OP_RETURN_RELAY)); | |
411 | ||
412 | strUsage += HelpMessageGroup(_("Block creation options:")); | |
413 | strUsage += HelpMessageOpt("-blockminsize=<n>", strprintf(_("Set minimum block size in bytes (default: %u)"), 0)); | |
414 | strUsage += HelpMessageOpt("-blockmaxsize=<n>", strprintf(_("Set maximum block size in bytes (default: %d)"), DEFAULT_BLOCK_MAX_SIZE)); | |
415 | strUsage += HelpMessageOpt("-blockprioritysize=<n>", strprintf(_("Set maximum size of high-priority/low-fee transactions in bytes (default: %d)"), DEFAULT_BLOCK_PRIORITY_SIZE)); | |
416 | ||
417 | strUsage += HelpMessageGroup(_("RPC server options:")); | |
418 | strUsage += HelpMessageOpt("-server", _("Accept command line and JSON-RPC commands")); | |
419 | strUsage += HelpMessageOpt("-rest", strprintf(_("Accept public REST requests (default: %u)"), 0)); | |
420 | strUsage += HelpMessageOpt("-rpcbind=<addr>", _("Bind to given address to listen for JSON-RPC connections. Use [host]:port notation for IPv6. This option can be specified multiple times (default: bind to all interfaces)")); | |
421 | strUsage += HelpMessageOpt("-rpcuser=<user>", _("Username for JSON-RPC connections")); | |
422 | strUsage += HelpMessageOpt("-rpcpassword=<pw>", _("Password for JSON-RPC connections")); | |
423 | strUsage += HelpMessageOpt("-rpcport=<port>", strprintf(_("Listen for JSON-RPC connections on <port> (default: %u or testnet: %u)"), 8232, 18232)); | |
424 | strUsage += HelpMessageOpt("-rpcallowip=<ip>", _("Allow JSON-RPC connections from specified source. Valid for <ip> are a single IP (e.g. 1.2.3.4), a network/netmask (e.g. 1.2.3.4/255.255.255.0) or a network/CIDR (e.g. 1.2.3.4/24). This option can be specified multiple times")); | |
425 | strUsage += HelpMessageOpt("-rpcthreads=<n>", strprintf(_("Set the number of threads to service RPC calls (default: %d)"), 4)); | |
426 | strUsage += HelpMessageOpt("-rpckeepalive", strprintf(_("RPC support for HTTP persistent connections (default: %d)"), 1)); | |
427 | ||
428 | strUsage += HelpMessageGroup(_("RPC SSL options: (see the Bitcoin Wiki for SSL setup instructions)")); | |
429 | strUsage += HelpMessageOpt("-rpcssl", _("Use OpenSSL (https) for JSON-RPC connections")); | |
430 | strUsage += HelpMessageOpt("-rpcsslcertificatechainfile=<file.cert>", strprintf(_("Server certificate file (default: %s)"), "server.cert")); | |
431 | strUsage += HelpMessageOpt("-rpcsslprivatekeyfile=<file.pem>", strprintf(_("Server private key (default: %s)"), "server.pem")); | |
432 | strUsage += HelpMessageOpt("-rpcsslciphers=<ciphers>", strprintf(_("Acceptable ciphers (default: %s)"), "TLSv1.2+HIGH:TLSv1+HIGH:!SSLv2:!aNULL:!eNULL:!3DES:@STRENGTH")); | |
433 | ||
434 | if (mode == HMM_BITCOIN_QT) | |
435 | { | |
436 | strUsage += HelpMessageGroup(_("UI Options:")); | |
437 | if (showDebug) { | |
438 | strUsage += HelpMessageOpt("-allowselfsignedrootcertificates", "Allow self signed root certificates (default: 0)"); | |
439 | } | |
440 | strUsage += HelpMessageOpt("-choosedatadir", _("Choose data directory on startup (default: 0)")); | |
441 | strUsage += HelpMessageOpt("-lang=<lang>", _("Set language, for example \"de_DE\" (default: system locale)")); | |
442 | strUsage += HelpMessageOpt("-min", _("Start minimized")); | |
443 | strUsage += HelpMessageOpt("-rootcertificates=<file>", _("Set SSL root certificates for payment request (default: -system-)")); | |
444 | strUsage += HelpMessageOpt("-splash", _("Show splash screen on startup (default: 1)")); | |
445 | } | |
446 | ||
447 | return strUsage; | |
448 | } | |
449 | ||
450 | std::string LicenseInfo() | |
451 | { | |
452 | return FormatParagraph(strprintf(_("Copyright (C) 2009-%i The Bitcoin Core Developers"), COPYRIGHT_YEAR)) + "\n" + | |
453 | FormatParagraph(strprintf(_("Copyright (C) 2015-%i The Zcash Developers"), COPYRIGHT_YEAR)) + "\n" + | |
454 | "\n" + | |
455 | FormatParagraph(_("This is experimental software.")) + "\n" + | |
456 | "\n" + | |
457 | FormatParagraph(_("Distributed under the MIT software license, see the accompanying file COPYING or <http://www.opensource.org/licenses/mit-license.php>.")) + "\n" + | |
458 | "\n" + | |
459 | FormatParagraph(_("This product includes software developed by the OpenSSL Project for use in the OpenSSL Toolkit <https://www.openssl.org/> and cryptographic software written by Eric Young and UPnP software written by Thomas Bernard.")) + | |
460 | "\n"; | |
461 | } | |
462 | ||
463 | static void BlockNotifyCallback(const uint256& hashNewTip) | |
464 | { | |
465 | std::string strCmd = GetArg("-blocknotify", ""); | |
466 | ||
467 | boost::replace_all(strCmd, "%s", hashNewTip.GetHex()); | |
468 | boost::thread t(runCommand, strCmd); // thread runs free | |
469 | } | |
470 | ||
471 | struct CImportingNow | |
472 | { | |
473 | CImportingNow() { | |
474 | assert(fImporting == false); | |
475 | fImporting = true; | |
476 | } | |
477 | ||
478 | ~CImportingNow() { | |
479 | assert(fImporting == true); | |
480 | fImporting = false; | |
481 | } | |
482 | }; | |
483 | ||
484 | ||
485 | // If we're using -prune with -reindex, then delete block files that will be ignored by the | |
486 | // reindex. Since reindexing works by starting at block file 0 and looping until a blockfile | |
487 | // is missing, do the same here to delete any later block files after a gap. Also delete all | |
488 | // rev files since they'll be rewritten by the reindex anyway. This ensures that vinfoBlockFile | |
489 | // is in sync with what's actually on disk by the time we start downloading, so that pruning | |
490 | // works correctly. | |
491 | void CleanupBlockRevFiles() | |
492 | { | |
493 | using namespace boost::filesystem; | |
494 | map<string, path> mapBlockFiles; | |
495 | ||
496 | // Glob all blk?????.dat and rev?????.dat files from the blocks directory. | |
497 | // Remove the rev files immediately and insert the blk file paths into an | |
498 | // ordered map keyed by block file index. | |
499 | LogPrintf("Removing unusable blk?????.dat and rev?????.dat files for -reindex with -prune\n"); | |
500 | path blocksdir = GetDataDir() / "blocks"; | |
501 | for (directory_iterator it(blocksdir); it != directory_iterator(); it++) { | |
502 | if (is_regular_file(*it) && | |
503 | it->path().filename().string().length() == 12 && | |
504 | it->path().filename().string().substr(8,4) == ".dat") | |
505 | { | |
506 | if (it->path().filename().string().substr(0,3) == "blk") | |
507 | mapBlockFiles[it->path().filename().string().substr(3,5)] = it->path(); | |
508 | else if (it->path().filename().string().substr(0,3) == "rev") | |
509 | remove(it->path()); | |
510 | } | |
511 | } | |
512 | ||
513 | // Remove all block files that aren't part of a contiguous set starting at | |
514 | // zero by walking the ordered map (keys are block file indices) by | |
515 | // keeping a separate counter. Once we hit a gap (or if 0 doesn't exist) | |
516 | // start removing block files. | |
517 | int nContigCounter = 0; | |
518 | BOOST_FOREACH(const PAIRTYPE(string, path)& item, mapBlockFiles) { | |
519 | if (atoi(item.first) == nContigCounter) { | |
520 | nContigCounter++; | |
521 | continue; | |
522 | } | |
523 | remove(item.second); | |
524 | } | |
525 | } | |
526 | ||
527 | void ThreadImport(std::vector<boost::filesystem::path> vImportFiles) | |
528 | { | |
529 | RenameThread("bitcoin-loadblk"); | |
530 | // -reindex | |
531 | if (fReindex) { | |
532 | CImportingNow imp; | |
533 | int nFile = 0; | |
534 | while (true) { | |
535 | CDiskBlockPos pos(nFile, 0); | |
536 | if (!boost::filesystem::exists(GetBlockPosFilename(pos, "blk"))) | |
537 | break; // No block files left to reindex | |
538 | FILE *file = OpenBlockFile(pos, true); | |
539 | if (!file) | |
540 | break; // This error is logged in OpenBlockFile | |
541 | LogPrintf("Reindexing block file blk%05u.dat...\n", (unsigned int)nFile); | |
542 | LoadExternalBlockFile(file, &pos); | |
543 | nFile++; | |
544 | } | |
545 | pblocktree->WriteReindexing(false); | |
546 | fReindex = false; | |
547 | LogPrintf("Reindexing finished\n"); | |
548 | // To avoid ending up in a situation without genesis block, re-try initializing (no-op if reindexing worked): | |
549 | InitBlockIndex(); | |
550 | } | |
551 | ||
552 | // hardcoded $DATADIR/bootstrap.dat | |
553 | boost::filesystem::path pathBootstrap = GetDataDir() / "bootstrap.dat"; | |
554 | if (boost::filesystem::exists(pathBootstrap)) { | |
555 | FILE *file = fopen(pathBootstrap.string().c_str(), "rb"); | |
556 | if (file) { | |
557 | CImportingNow imp; | |
558 | boost::filesystem::path pathBootstrapOld = GetDataDir() / "bootstrap.dat.old"; | |
559 | LogPrintf("Importing bootstrap.dat...\n"); | |
560 | LoadExternalBlockFile(file); | |
561 | RenameOver(pathBootstrap, pathBootstrapOld); | |
562 | } else { | |
563 | LogPrintf("Warning: Could not open bootstrap file %s\n", pathBootstrap.string()); | |
564 | } | |
565 | } | |
566 | ||
567 | // -loadblock= | |
568 | BOOST_FOREACH(boost::filesystem::path &path, vImportFiles) { | |
569 | FILE *file = fopen(path.string().c_str(), "rb"); | |
570 | if (file) { | |
571 | CImportingNow imp; | |
572 | LogPrintf("Importing blocks file %s...\n", path.string()); | |
573 | LoadExternalBlockFile(file); | |
574 | } else { | |
575 | LogPrintf("Warning: Could not open blocks file %s\n", path.string()); | |
576 | } | |
577 | } | |
578 | ||
579 | if (GetBoolArg("-stopafterblockimport", false)) { | |
580 | LogPrintf("Stopping after block import\n"); | |
581 | StartShutdown(); | |
582 | } | |
583 | } | |
584 | ||
585 | /** Sanity checks | |
586 | * Ensure that Bitcoin is running in a usable environment with all | |
587 | * necessary library support. | |
588 | */ | |
589 | bool InitSanityCheck(void) | |
590 | { | |
591 | if(!ECC_InitSanityCheck()) { | |
592 | InitError("OpenSSL appears to lack support for elliptic curve cryptography. For more " | |
593 | "information, visit https://en.bitcoin.it/wiki/OpenSSL_and_EC_Libraries"); | |
594 | return false; | |
595 | } | |
596 | if (!glibc_sanity_test() || !glibcxx_sanity_test()) | |
597 | return false; | |
598 | ||
599 | return true; | |
600 | } | |
601 | ||
602 | ||
603 | static void ZC_LoadParams() | |
604 | { | |
605 | struct timeval tv_start, tv_end; | |
606 | float elapsed; | |
607 | ||
608 | boost::filesystem::path pk_path = ZC_GetParamsDir() / "z7-proving.key"; | |
609 | boost::filesystem::path vk_path = ZC_GetParamsDir() / "z7-verifying.key"; | |
610 | ||
611 | pzcashParams = ZCJoinSplit::Unopened(); | |
612 | ||
613 | LogPrintf("Loading verifying key from %s\n", vk_path.string().c_str()); | |
614 | gettimeofday(&tv_start, 0); | |
615 | ||
616 | pzcashParams->loadVerifyingKey(vk_path.string()); | |
617 | ||
618 | gettimeofday(&tv_end, 0); | |
619 | elapsed = float(tv_end.tv_sec-tv_start.tv_sec) + (tv_end.tv_usec-tv_start.tv_usec)/float(1000000); | |
620 | LogPrintf("Loaded verifying key in %fs seconds.\n", elapsed); | |
621 | ||
622 | pzcashParams->setProvingKeyPath(pk_path.string()); | |
623 | } | |
624 | ||
625 | /** Initialize bitcoin. | |
626 | * @pre Parameters should be parsed and config file should be read. | |
627 | */ | |
628 | bool AppInit2(boost::thread_group& threadGroup, CScheduler& scheduler) | |
629 | { | |
630 | // ********************************************************* Step 1: setup | |
631 | #ifdef _MSC_VER | |
632 | // Turn off Microsoft heap dump noise | |
633 | _CrtSetReportMode(_CRT_WARN, _CRTDBG_MODE_FILE); | |
634 | _CrtSetReportFile(_CRT_WARN, CreateFileA("NUL", GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, 0)); | |
635 | #endif | |
636 | #if _MSC_VER >= 1400 | |
637 | // Disable confusing "helpful" text message on abort, Ctrl-C | |
638 | _set_abort_behavior(0, _WRITE_ABORT_MSG | _CALL_REPORTFAULT); | |
639 | #endif | |
640 | #ifdef WIN32 | |
641 | // Enable Data Execution Prevention (DEP) | |
642 | // Minimum supported OS versions: WinXP SP3, WinVista >= SP1, Win Server 2008 | |
643 | // A failure is non-critical and needs no further attention! | |
644 | #ifndef PROCESS_DEP_ENABLE | |
645 | // We define this here, because GCCs winbase.h limits this to _WIN32_WINNT >= 0x0601 (Windows 7), | |
646 | // which is not correct. Can be removed, when GCCs winbase.h is fixed! | |
647 | #define PROCESS_DEP_ENABLE 0x00000001 | |
648 | #endif | |
649 | typedef BOOL (WINAPI *PSETPROCDEPPOL)(DWORD); | |
650 | PSETPROCDEPPOL setProcDEPPol = (PSETPROCDEPPOL)GetProcAddress(GetModuleHandleA("Kernel32.dll"), "SetProcessDEPPolicy"); | |
651 | if (setProcDEPPol != NULL) setProcDEPPol(PROCESS_DEP_ENABLE); | |
652 | ||
653 | // Initialize Windows Sockets | |
654 | WSADATA wsadata; | |
655 | int ret = WSAStartup(MAKEWORD(2,2), &wsadata); | |
656 | if (ret != NO_ERROR || LOBYTE(wsadata.wVersion ) != 2 || HIBYTE(wsadata.wVersion) != 2) | |
657 | { | |
658 | return InitError(strprintf("Error: Winsock library failed to start (WSAStartup returned error %d)", ret)); | |
659 | } | |
660 | #endif | |
661 | #ifndef WIN32 | |
662 | ||
663 | if (GetBoolArg("-sysperms", false)) { | |
664 | #ifdef ENABLE_WALLET | |
665 | if (!GetBoolArg("-disablewallet", false)) | |
666 | return InitError("Error: -sysperms is not allowed in combination with enabled wallet functionality"); | |
667 | #endif | |
668 | } else { | |
669 | umask(077); | |
670 | } | |
671 | ||
672 | // Clean shutdown on SIGTERM | |
673 | struct sigaction sa; | |
674 | sa.sa_handler = HandleSIGTERM; | |
675 | sigemptyset(&sa.sa_mask); | |
676 | sa.sa_flags = 0; | |
677 | sigaction(SIGTERM, &sa, NULL); | |
678 | sigaction(SIGINT, &sa, NULL); | |
679 | ||
680 | // Reopen debug.log on SIGHUP | |
681 | struct sigaction sa_hup; | |
682 | sa_hup.sa_handler = HandleSIGHUP; | |
683 | sigemptyset(&sa_hup.sa_mask); | |
684 | sa_hup.sa_flags = 0; | |
685 | sigaction(SIGHUP, &sa_hup, NULL); | |
686 | ||
687 | #if defined (__SVR4) && defined (__sun) | |
688 | // ignore SIGPIPE on Solaris | |
689 | signal(SIGPIPE, SIG_IGN); | |
690 | #endif | |
691 | #endif | |
692 | ||
693 | // ********************************************************* Step 2: parameter interactions | |
694 | const CChainParams& chainparams = Params(); | |
695 | ||
696 | // Set this early so that parameter interactions go to console | |
697 | fPrintToConsole = GetBoolArg("-printtoconsole", false); | |
698 | fLogTimestamps = GetBoolArg("-logtimestamps", true); | |
699 | fLogIPs = GetBoolArg("-logips", false); | |
700 | ||
701 | // when specifying an explicit binding address, you want to listen on it | |
702 | // even when -connect or -proxy is specified | |
703 | if (mapArgs.count("-bind")) { | |
704 | if (SoftSetBoolArg("-listen", true)) | |
705 | LogPrintf("%s: parameter interaction: -bind set -> setting -listen=1\n", __func__); | |
706 | } | |
707 | if (mapArgs.count("-whitebind")) { | |
708 | if (SoftSetBoolArg("-listen", true)) | |
709 | LogPrintf("%s: parameter interaction: -whitebind set -> setting -listen=1\n", __func__); | |
710 | } | |
711 | ||
712 | if (mapArgs.count("-connect") && mapMultiArgs["-connect"].size() > 0) { | |
713 | // when only connecting to trusted nodes, do not seed via DNS, or listen by default | |
714 | if (SoftSetBoolArg("-dnsseed", false)) | |
715 | LogPrintf("%s: parameter interaction: -connect set -> setting -dnsseed=0\n", __func__); | |
716 | if (SoftSetBoolArg("-listen", false)) | |
717 | LogPrintf("%s: parameter interaction: -connect set -> setting -listen=0\n", __func__); | |
718 | } | |
719 | ||
720 | if (mapArgs.count("-proxy")) { | |
721 | // to protect privacy, do not listen by default if a default proxy server is specified | |
722 | if (SoftSetBoolArg("-listen", false)) | |
723 | LogPrintf("%s: parameter interaction: -proxy set -> setting -listen=0\n", __func__); | |
724 | // to protect privacy, do not use UPNP when a proxy is set. The user may still specify -listen=1 | |
725 | // to listen locally, so don't rely on this happening through -listen below. | |
726 | if (SoftSetBoolArg("-upnp", false)) | |
727 | LogPrintf("%s: parameter interaction: -proxy set -> setting -upnp=0\n", __func__); | |
728 | // to protect privacy, do not discover addresses by default | |
729 | if (SoftSetBoolArg("-discover", false)) | |
730 | LogPrintf("%s: parameter interaction: -proxy set -> setting -discover=0\n", __func__); | |
731 | } | |
732 | ||
733 | if (!GetBoolArg("-listen", DEFAULT_LISTEN)) { | |
734 | // do not map ports or try to retrieve public IP when not listening (pointless) | |
735 | if (SoftSetBoolArg("-upnp", false)) | |
736 | LogPrintf("%s: parameter interaction: -listen=0 -> setting -upnp=0\n", __func__); | |
737 | if (SoftSetBoolArg("-discover", false)) | |
738 | LogPrintf("%s: parameter interaction: -listen=0 -> setting -discover=0\n", __func__); | |
739 | } | |
740 | ||
741 | if (mapArgs.count("-externalip")) { | |
742 | // if an explicit public IP is specified, do not try to find others | |
743 | if (SoftSetBoolArg("-discover", false)) | |
744 | LogPrintf("%s: parameter interaction: -externalip set -> setting -discover=0\n", __func__); | |
745 | } | |
746 | ||
747 | if (GetBoolArg("-salvagewallet", false)) { | |
748 | // Rewrite just private keys: rescan to find transactions | |
749 | if (SoftSetBoolArg("-rescan", true)) | |
750 | LogPrintf("%s: parameter interaction: -salvagewallet=1 -> setting -rescan=1\n", __func__); | |
751 | } | |
752 | ||
753 | // -zapwallettx implies a rescan | |
754 | if (GetBoolArg("-zapwallettxes", false)) { | |
755 | if (SoftSetBoolArg("-rescan", true)) | |
756 | LogPrintf("%s: parameter interaction: -zapwallettxes=<mode> -> setting -rescan=1\n", __func__); | |
757 | } | |
758 | ||
759 | // Make sure enough file descriptors are available | |
760 | int nBind = std::max((int)mapArgs.count("-bind") + (int)mapArgs.count("-whitebind"), 1); | |
761 | nMaxConnections = GetArg("-maxconnections", 125); | |
762 | nMaxConnections = std::max(std::min(nMaxConnections, (int)(FD_SETSIZE - nBind - MIN_CORE_FILEDESCRIPTORS)), 0); | |
763 | int nFD = RaiseFileDescriptorLimit(nMaxConnections + MIN_CORE_FILEDESCRIPTORS); | |
764 | if (nFD < MIN_CORE_FILEDESCRIPTORS) | |
765 | return InitError(_("Not enough file descriptors available.")); | |
766 | if (nFD - MIN_CORE_FILEDESCRIPTORS < nMaxConnections) | |
767 | nMaxConnections = nFD - MIN_CORE_FILEDESCRIPTORS; | |
768 | ||
769 | // if using block pruning, then disable txindex | |
770 | // also disable the wallet (for now, until SPV support is implemented in wallet) | |
771 | if (GetArg("-prune", 0)) { | |
772 | if (GetBoolArg("-txindex", false)) | |
773 | return InitError(_("Prune mode is incompatible with -txindex.")); | |
774 | #ifdef ENABLE_WALLET | |
775 | if (!GetBoolArg("-disablewallet", false)) { | |
776 | if (SoftSetBoolArg("-disablewallet", true)) | |
777 | LogPrintf("%s : parameter interaction: -prune -> setting -disablewallet=1\n", __func__); | |
778 | else | |
779 | return InitError(_("Can't run with a wallet in prune mode.")); | |
780 | } | |
781 | #endif | |
782 | } | |
783 | ||
784 | // ********************************************************* Step 3: parameter-to-internal-flags | |
785 | ||
786 | fDebug = !mapMultiArgs["-debug"].empty(); | |
787 | // Special-case: if -debug=0/-nodebug is set, turn off debugging messages | |
788 | const vector<string>& categories = mapMultiArgs["-debug"]; | |
789 | if (GetBoolArg("-nodebug", false) || find(categories.begin(), categories.end(), string("0")) != categories.end()) | |
790 | fDebug = false; | |
791 | ||
792 | // Check for -debugnet | |
793 | if (GetBoolArg("-debugnet", false)) | |
794 | InitWarning(_("Warning: Unsupported argument -debugnet ignored, use -debug=net.")); | |
795 | // Check for -socks - as this is a privacy risk to continue, exit here | |
796 | if (mapArgs.count("-socks")) | |
797 | return InitError(_("Error: Unsupported argument -socks found. Setting SOCKS version isn't possible anymore, only SOCKS5 proxies are supported.")); | |
798 | // Check for -tor - as this is a privacy risk to continue, exit here | |
799 | if (GetBoolArg("-tor", false)) | |
800 | return InitError(_("Error: Unsupported argument -tor found, use -onion.")); | |
801 | ||
802 | if (GetBoolArg("-benchmark", false)) | |
803 | InitWarning(_("Warning: Unsupported argument -benchmark ignored, use -debug=bench.")); | |
804 | ||
805 | // Checkmempool and checkblockindex default to true in regtest mode | |
806 | mempool.setSanityCheck(GetBoolArg("-checkmempool", chainparams.DefaultConsistencyChecks())); | |
807 | fCheckBlockIndex = GetBoolArg("-checkblockindex", chainparams.DefaultConsistencyChecks()); | |
808 | fCheckpointsEnabled = GetBoolArg("-checkpoints", true); | |
809 | ||
810 | // -par=0 means autodetect, but nScriptCheckThreads==0 means no concurrency | |
811 | nScriptCheckThreads = GetArg("-par", DEFAULT_SCRIPTCHECK_THREADS); | |
812 | if (nScriptCheckThreads <= 0) | |
813 | nScriptCheckThreads += boost::thread::hardware_concurrency(); | |
814 | if (nScriptCheckThreads <= 1) | |
815 | nScriptCheckThreads = 0; | |
816 | else if (nScriptCheckThreads > MAX_SCRIPTCHECK_THREADS) | |
817 | nScriptCheckThreads = MAX_SCRIPTCHECK_THREADS; | |
818 | ||
819 | fServer = GetBoolArg("-server", false); | |
820 | ||
821 | // block pruning; get the amount of disk space (in MB) to allot for block & undo files | |
822 | int64_t nSignedPruneTarget = GetArg("-prune", 0) * 1024 * 1024; | |
823 | if (nSignedPruneTarget < 0) { | |
824 | return InitError(_("Prune cannot be configured with a negative value.")); | |
825 | } | |
826 | nPruneTarget = (uint64_t) nSignedPruneTarget; | |
827 | if (nPruneTarget) { | |
828 | if (nPruneTarget < MIN_DISK_SPACE_FOR_BLOCK_FILES) { | |
829 | return InitError(strprintf(_("Prune configured below the minimum of %d MB. Please use a higher number."), MIN_DISK_SPACE_FOR_BLOCK_FILES / 1024 / 1024)); | |
830 | } | |
831 | LogPrintf("Prune configured to target %uMiB on disk for block and undo files.\n", nPruneTarget / 1024 / 1024); | |
832 | fPruneMode = true; | |
833 | } | |
834 | ||
835 | #ifdef ENABLE_WALLET | |
836 | bool fDisableWallet = GetBoolArg("-disablewallet", false); | |
837 | #endif | |
838 | ||
839 | nConnectTimeout = GetArg("-timeout", DEFAULT_CONNECT_TIMEOUT); | |
840 | if (nConnectTimeout <= 0) | |
841 | nConnectTimeout = DEFAULT_CONNECT_TIMEOUT; | |
842 | ||
843 | // Fee-per-kilobyte amount considered the same as "free" | |
844 | // If you are mining, be careful setting this: | |
845 | // if you set it to zero then | |
846 | // a transaction spammer can cheaply fill blocks using | |
847 | // 1-satoshi-fee transactions. It should be set above the real | |
848 | // cost to you of processing a transaction. | |
849 | if (mapArgs.count("-minrelaytxfee")) | |
850 | { | |
851 | CAmount n = 0; | |
852 | if (ParseMoney(mapArgs["-minrelaytxfee"], n) && n > 0) | |
853 | ::minRelayTxFee = CFeeRate(n); | |
854 | else | |
855 | return InitError(strprintf(_("Invalid amount for -minrelaytxfee=<amount>: '%s'"), mapArgs["-minrelaytxfee"])); | |
856 | } | |
857 | ||
858 | #ifdef ENABLE_WALLET | |
859 | if (mapArgs.count("-mintxfee")) | |
860 | { | |
861 | CAmount n = 0; | |
862 | if (ParseMoney(mapArgs["-mintxfee"], n) && n > 0) | |
863 | CWallet::minTxFee = CFeeRate(n); | |
864 | else | |
865 | return InitError(strprintf(_("Invalid amount for -mintxfee=<amount>: '%s'"), mapArgs["-mintxfee"])); | |
866 | } | |
867 | if (mapArgs.count("-paytxfee")) | |
868 | { | |
869 | CAmount nFeePerK = 0; | |
870 | if (!ParseMoney(mapArgs["-paytxfee"], nFeePerK)) | |
871 | return InitError(strprintf(_("Invalid amount for -paytxfee=<amount>: '%s'"), mapArgs["-paytxfee"])); | |
872 | if (nFeePerK > nHighTransactionFeeWarning) | |
873 | InitWarning(_("Warning: -paytxfee is set very high! This is the transaction fee you will pay if you send a transaction.")); | |
874 | payTxFee = CFeeRate(nFeePerK, 1000); | |
875 | if (payTxFee < ::minRelayTxFee) | |
876 | { | |
877 | return InitError(strprintf(_("Invalid amount for -paytxfee=<amount>: '%s' (must be at least %s)"), | |
878 | mapArgs["-paytxfee"], ::minRelayTxFee.ToString())); | |
879 | } | |
880 | } | |
881 | if (mapArgs.count("-maxtxfee")) | |
882 | { | |
883 | CAmount nMaxFee = 0; | |
884 | if (!ParseMoney(mapArgs["-maxtxfee"], nMaxFee)) | |
885 | return InitError(strprintf(_("Invalid amount for -maxtxfee=<amount>: '%s'"), mapArgs["-maptxfee"])); | |
886 | if (nMaxFee > nHighTransactionMaxFeeWarning) | |
887 | InitWarning(_("Warning: -maxtxfee is set very high! Fees this large could be paid on a single transaction.")); | |
888 | maxTxFee = nMaxFee; | |
889 | if (CFeeRate(maxTxFee, 1000) < ::minRelayTxFee) | |
890 | { | |
891 | return InitError(strprintf(_("Invalid amount for -maxtxfee=<amount>: '%s' (must be at least the minrelay fee of %s to prevent stuck transactions)"), | |
892 | mapArgs["-maxtxfee"], ::minRelayTxFee.ToString())); | |
893 | } | |
894 | } | |
895 | nTxConfirmTarget = GetArg("-txconfirmtarget", DEFAULT_TX_CONFIRM_TARGET); | |
896 | bSpendZeroConfChange = GetBoolArg("-spendzeroconfchange", true); | |
897 | fSendFreeTransactions = GetBoolArg("-sendfreetransactions", false); | |
898 | ||
899 | std::string strWalletFile = GetArg("-wallet", "wallet.dat"); | |
900 | #endif // ENABLE_WALLET | |
901 | ||
902 | fIsBareMultisigStd = GetBoolArg("-permitbaremultisig", true); | |
903 | nMaxDatacarrierBytes = GetArg("-datacarriersize", nMaxDatacarrierBytes); | |
904 | ||
905 | fAlerts = GetBoolArg("-alerts", DEFAULT_ALERTS); | |
906 | ||
907 | // ********************************************************* Step 4: application initialization: dir lock, daemonize, pidfile, debug log | |
908 | ||
909 | // Initialize libsodium | |
910 | if (sodium_init() == -1) { | |
911 | return false; | |
912 | } | |
913 | ||
914 | // Initialize elliptic curve code | |
915 | ECC_Start(); | |
916 | ||
917 | // Sanity check | |
918 | if (!InitSanityCheck()) | |
919 | return InitError(_("Initialization sanity check failed. Bitcoin Core is shutting down.")); | |
920 | ||
921 | std::string strDataDir = GetDataDir().string(); | |
922 | #ifdef ENABLE_WALLET | |
923 | // Wallet file must be a plain filename without a directory | |
924 | if (strWalletFile != boost::filesystem::basename(strWalletFile) + boost::filesystem::extension(strWalletFile)) | |
925 | return InitError(strprintf(_("Wallet %s resides outside data directory %s"), strWalletFile, strDataDir)); | |
926 | #endif | |
927 | // Make sure only a single Bitcoin process is using the data directory. | |
928 | boost::filesystem::path pathLockFile = GetDataDir() / ".lock"; | |
929 | FILE* file = fopen(pathLockFile.string().c_str(), "a"); // empty lock file; created if it doesn't exist. | |
930 | if (file) fclose(file); | |
931 | ||
932 | try { | |
933 | static boost::interprocess::file_lock lock(pathLockFile.string().c_str()); | |
934 | if (!lock.try_lock()) | |
935 | return InitError(strprintf(_("Cannot obtain a lock on data directory %s. Bitcoin Core is probably already running."), strDataDir)); | |
936 | } catch(const boost::interprocess::interprocess_exception& e) { | |
937 | return InitError(strprintf(_("Cannot obtain a lock on data directory %s. Bitcoin Core is probably already running.") + " %s.", strDataDir, e.what())); | |
938 | } | |
939 | ||
940 | #ifndef WIN32 | |
941 | CreatePidFile(GetPidFile(), getpid()); | |
942 | #endif | |
943 | if (GetBoolArg("-shrinkdebugfile", !fDebug)) | |
944 | ShrinkDebugFile(); | |
945 | LogPrintf("\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n\n"); | |
946 | LogPrintf("Bitcoin version %s (%s)\n", FormatFullVersion(), CLIENT_DATE); | |
947 | LogPrintf("Using OpenSSL version %s\n", SSLeay_version(SSLEAY_VERSION)); | |
948 | #ifdef ENABLE_WALLET | |
949 | LogPrintf("Using BerkeleyDB version %s\n", DbEnv::version(0, 0, 0)); | |
950 | #endif | |
951 | if (!fLogTimestamps) | |
952 | LogPrintf("Startup time: %s\n", DateTimeStrFormat("%Y-%m-%d %H:%M:%S", GetTime())); | |
953 | LogPrintf("Default data directory %s\n", GetDefaultDataDir().string()); | |
954 | LogPrintf("Using data directory %s\n", strDataDir); | |
955 | LogPrintf("Using config file %s\n", GetConfigFile().string()); | |
956 | LogPrintf("Using at most %i connections (%i file descriptors available)\n", nMaxConnections, nFD); | |
957 | std::ostringstream strErrors; | |
958 | ||
959 | LogPrintf("Using %u threads for script verification\n", nScriptCheckThreads); | |
960 | if (nScriptCheckThreads) { | |
961 | for (int i=0; i<nScriptCheckThreads-1; i++) | |
962 | threadGroup.create_thread(&ThreadScriptCheck); | |
963 | } | |
964 | ||
965 | // Start the lightweight task scheduler thread | |
966 | CScheduler::Function serviceLoop = boost::bind(&CScheduler::serviceQueue, &scheduler); | |
967 | threadGroup.create_thread(boost::bind(&TraceThread<CScheduler::Function>, "scheduler", serviceLoop)); | |
968 | ||
969 | // Initialize Zcash circuit parameters | |
970 | ZC_LoadParams(); | |
971 | // These must be disabled for now, they are buggy and we probably don't | |
972 | // want any of libsnark's profiling in production anyway. | |
973 | libsnark::inhibit_profiling_info = true; | |
974 | libsnark::inhibit_profiling_counters = true; | |
975 | ||
976 | /* Start the RPC server already. It will be started in "warmup" mode | |
977 | * and not really process calls already (but it will signify connections | |
978 | * that the server is there and will be ready later). Warmup mode will | |
979 | * be disabled when initialisation is finished. | |
980 | */ | |
981 | if (fServer) | |
982 | { | |
983 | uiInterface.InitMessage.connect(SetRPCWarmupStatus); | |
984 | RPCServer::OnStopped(&OnRPCStopped); | |
985 | RPCServer::OnPreCommand(&OnRPCPreCommand); | |
986 | StartRPCThreads(); | |
987 | } | |
988 | ||
989 | int64_t nStart; | |
990 | ||
991 | // ********************************************************* Step 5: verify wallet database integrity | |
992 | #ifdef ENABLE_WALLET | |
993 | if (!fDisableWallet) { | |
994 | LogPrintf("Using wallet %s\n", strWalletFile); | |
995 | uiInterface.InitMessage(_("Verifying wallet...")); | |
996 | ||
997 | std::string warningString; | |
998 | std::string errorString; | |
999 | ||
1000 | if (!CWallet::Verify(strWalletFile, warningString, errorString)) | |
1001 | return false; | |
1002 | ||
1003 | if (!warningString.empty()) | |
1004 | InitWarning(warningString); | |
1005 | if (!errorString.empty()) | |
1006 | return InitError(warningString); | |
1007 | ||
1008 | } // (!fDisableWallet) | |
1009 | #endif // ENABLE_WALLET | |
1010 | // ********************************************************* Step 6: network initialization | |
1011 | ||
1012 | RegisterNodeSignals(GetNodeSignals()); | |
1013 | ||
1014 | if (mapArgs.count("-onlynet")) { | |
1015 | std::set<enum Network> nets; | |
1016 | BOOST_FOREACH(std::string snet, mapMultiArgs["-onlynet"]) { | |
1017 | enum Network net = ParseNetwork(snet); | |
1018 | if (net == NET_UNROUTABLE) | |
1019 | return InitError(strprintf(_("Unknown network specified in -onlynet: '%s'"), snet)); | |
1020 | nets.insert(net); | |
1021 | } | |
1022 | for (int n = 0; n < NET_MAX; n++) { | |
1023 | enum Network net = (enum Network)n; | |
1024 | if (!nets.count(net)) | |
1025 | SetLimited(net); | |
1026 | } | |
1027 | } | |
1028 | ||
1029 | if (mapArgs.count("-whitelist")) { | |
1030 | BOOST_FOREACH(const std::string& net, mapMultiArgs["-whitelist"]) { | |
1031 | CSubNet subnet(net); | |
1032 | if (!subnet.IsValid()) | |
1033 | return InitError(strprintf(_("Invalid netmask specified in -whitelist: '%s'"), net)); | |
1034 | CNode::AddWhitelistedRange(subnet); | |
1035 | } | |
1036 | } | |
1037 | ||
1038 | proxyType addrProxy; | |
1039 | bool fProxy = false; | |
1040 | if (mapArgs.count("-proxy")) { | |
1041 | addrProxy = proxyType(CService(mapArgs["-proxy"], 9050), GetBoolArg("-proxyrandomize", true)); | |
1042 | if (!addrProxy.IsValid()) | |
1043 | return InitError(strprintf(_("Invalid -proxy address: '%s'"), mapArgs["-proxy"])); | |
1044 | ||
1045 | SetProxy(NET_IPV4, addrProxy); | |
1046 | SetProxy(NET_IPV6, addrProxy); | |
1047 | SetNameProxy(addrProxy); | |
1048 | fProxy = true; | |
1049 | } | |
1050 | ||
1051 | // -onion can override normal proxy, -noonion disables connecting to .onion entirely | |
1052 | if (!(mapArgs.count("-onion") && mapArgs["-onion"] == "0") && | |
1053 | (fProxy || mapArgs.count("-onion"))) { | |
1054 | proxyType addrOnion; | |
1055 | if (!mapArgs.count("-onion")) | |
1056 | addrOnion = addrProxy; | |
1057 | else | |
1058 | addrOnion = proxyType(CService(mapArgs["-onion"], 9050), GetBoolArg("-proxyrandomize", true)); | |
1059 | if (!addrOnion.IsValid()) | |
1060 | return InitError(strprintf(_("Invalid -onion address: '%s'"), mapArgs["-onion"])); | |
1061 | SetProxy(NET_TOR, addrOnion); | |
1062 | SetReachable(NET_TOR); | |
1063 | } | |
1064 | ||
1065 | // see Step 2: parameter interactions for more information about these | |
1066 | fListen = GetBoolArg("-listen", DEFAULT_LISTEN); | |
1067 | fDiscover = GetBoolArg("-discover", true); | |
1068 | fNameLookup = GetBoolArg("-dns", true); | |
1069 | ||
1070 | bool fBound = false; | |
1071 | if (fListen) { | |
1072 | if (mapArgs.count("-bind") || mapArgs.count("-whitebind")) { | |
1073 | BOOST_FOREACH(std::string strBind, mapMultiArgs["-bind"]) { | |
1074 | CService addrBind; | |
1075 | if (!Lookup(strBind.c_str(), addrBind, GetListenPort(), false)) | |
1076 | return InitError(strprintf(_("Cannot resolve -bind address: '%s'"), strBind)); | |
1077 | fBound |= Bind(addrBind, (BF_EXPLICIT | BF_REPORT_ERROR)); | |
1078 | } | |
1079 | BOOST_FOREACH(std::string strBind, mapMultiArgs["-whitebind"]) { | |
1080 | CService addrBind; | |
1081 | if (!Lookup(strBind.c_str(), addrBind, 0, false)) | |
1082 | return InitError(strprintf(_("Cannot resolve -whitebind address: '%s'"), strBind)); | |
1083 | if (addrBind.GetPort() == 0) | |
1084 | return InitError(strprintf(_("Need to specify a port with -whitebind: '%s'"), strBind)); | |
1085 | fBound |= Bind(addrBind, (BF_EXPLICIT | BF_REPORT_ERROR | BF_WHITELIST)); | |
1086 | } | |
1087 | } | |
1088 | else { | |
1089 | struct in_addr inaddr_any; | |
1090 | inaddr_any.s_addr = INADDR_ANY; | |
1091 | fBound |= Bind(CService(in6addr_any, GetListenPort()), BF_NONE); | |
1092 | fBound |= Bind(CService(inaddr_any, GetListenPort()), !fBound ? BF_REPORT_ERROR : BF_NONE); | |
1093 | } | |
1094 | if (!fBound) | |
1095 | return InitError(_("Failed to listen on any port. Use -listen=0 if you want this.")); | |
1096 | } | |
1097 | ||
1098 | if (mapArgs.count("-externalip")) { | |
1099 | BOOST_FOREACH(string strAddr, mapMultiArgs["-externalip"]) { | |
1100 | CService addrLocal(strAddr, GetListenPort(), fNameLookup); | |
1101 | if (!addrLocal.IsValid()) | |
1102 | return InitError(strprintf(_("Cannot resolve -externalip address: '%s'"), strAddr)); | |
1103 | AddLocal(CService(strAddr, GetListenPort(), fNameLookup), LOCAL_MANUAL); | |
1104 | } | |
1105 | } | |
1106 | ||
1107 | BOOST_FOREACH(string strDest, mapMultiArgs["-seednode"]) | |
1108 | AddOneShot(strDest); | |
1109 | ||
1110 | // ********************************************************* Step 7: load block chain | |
1111 | ||
1112 | fReindex = GetBoolArg("-reindex", false); | |
1113 | ||
1114 | // Upgrading to 0.8; hard-link the old blknnnn.dat files into /blocks/ | |
1115 | boost::filesystem::path blocksDir = GetDataDir() / "blocks"; | |
1116 | if (!boost::filesystem::exists(blocksDir)) | |
1117 | { | |
1118 | boost::filesystem::create_directories(blocksDir); | |
1119 | bool linked = false; | |
1120 | for (unsigned int i = 1; i < 10000; i++) { | |
1121 | boost::filesystem::path source = GetDataDir() / strprintf("blk%04u.dat", i); | |
1122 | if (!boost::filesystem::exists(source)) break; | |
1123 | boost::filesystem::path dest = blocksDir / strprintf("blk%05u.dat", i-1); | |
1124 | try { | |
1125 | boost::filesystem::create_hard_link(source, dest); | |
1126 | LogPrintf("Hardlinked %s -> %s\n", source.string(), dest.string()); | |
1127 | linked = true; | |
1128 | } catch (const boost::filesystem::filesystem_error& e) { | |
1129 | // Note: hardlink creation failing is not a disaster, it just means | |
1130 | // blocks will get re-downloaded from peers. | |
1131 | LogPrintf("Error hardlinking blk%04u.dat: %s\n", i, e.what()); | |
1132 | break; | |
1133 | } | |
1134 | } | |
1135 | if (linked) | |
1136 | { | |
1137 | fReindex = true; | |
1138 | } | |
1139 | } | |
1140 | ||
1141 | // cache size calculations | |
1142 | int64_t nTotalCache = (GetArg("-dbcache", nDefaultDbCache) << 20); | |
1143 | nTotalCache = std::max(nTotalCache, nMinDbCache << 20); // total cache cannot be less than nMinDbCache | |
1144 | nTotalCache = std::min(nTotalCache, nMaxDbCache << 20); // total cache cannot be greated than nMaxDbcache | |
1145 | int64_t nBlockTreeDBCache = nTotalCache / 8; | |
1146 | if (nBlockTreeDBCache > (1 << 21) && !GetBoolArg("-txindex", false)) | |
1147 | nBlockTreeDBCache = (1 << 21); // block tree db cache shouldn't be larger than 2 MiB | |
1148 | nTotalCache -= nBlockTreeDBCache; | |
1149 | int64_t nCoinDBCache = std::min(nTotalCache / 2, (nTotalCache / 4) + (1 << 23)); // use 25%-50% of the remainder for disk cache | |
1150 | nTotalCache -= nCoinDBCache; | |
1151 | nCoinCacheUsage = nTotalCache; // the rest goes to in-memory cache | |
1152 | LogPrintf("Cache configuration:\n"); | |
1153 | LogPrintf("* Using %.1fMiB for block index database\n", nBlockTreeDBCache * (1.0 / 1024 / 1024)); | |
1154 | LogPrintf("* Using %.1fMiB for chain state database\n", nCoinDBCache * (1.0 / 1024 / 1024)); | |
1155 | LogPrintf("* Using %.1fMiB for in-memory UTXO set\n", nCoinCacheUsage * (1.0 / 1024 / 1024)); | |
1156 | ||
1157 | bool fLoaded = false; | |
1158 | while (!fLoaded) { | |
1159 | bool fReset = fReindex; | |
1160 | std::string strLoadError; | |
1161 | ||
1162 | uiInterface.InitMessage(_("Loading block index...")); | |
1163 | ||
1164 | nStart = GetTimeMillis(); | |
1165 | do { | |
1166 | try { | |
1167 | UnloadBlockIndex(); | |
1168 | delete pcoinsTip; | |
1169 | delete pcoinsdbview; | |
1170 | delete pcoinscatcher; | |
1171 | delete pblocktree; | |
1172 | ||
1173 | pblocktree = new CBlockTreeDB(nBlockTreeDBCache, false, fReindex); | |
1174 | pcoinsdbview = new CCoinsViewDB(nCoinDBCache, false, fReindex); | |
1175 | pcoinscatcher = new CCoinsViewErrorCatcher(pcoinsdbview); | |
1176 | pcoinsTip = new CCoinsViewCache(pcoinscatcher); | |
1177 | ||
1178 | if (fReindex) { | |
1179 | pblocktree->WriteReindexing(true); | |
1180 | //If we're reindexing in prune mode, wipe away unusable block files and all undo data files | |
1181 | if (fPruneMode) | |
1182 | CleanupBlockRevFiles(); | |
1183 | } | |
1184 | ||
1185 | if (!LoadBlockIndex()) { | |
1186 | strLoadError = _("Error loading block database"); | |
1187 | break; | |
1188 | } | |
1189 | ||
1190 | // If the loaded chain has a wrong genesis, bail out immediately | |
1191 | // (we're likely using a testnet datadir, or the other way around). | |
1192 | if (!mapBlockIndex.empty() && mapBlockIndex.count(chainparams.GetConsensus().hashGenesisBlock) == 0) | |
1193 | return InitError(_("Incorrect or no genesis block found. Wrong datadir for network?")); | |
1194 | ||
1195 | // Initialize the block index (no-op if non-empty database was already loaded) | |
1196 | if (!InitBlockIndex()) { | |
1197 | strLoadError = _("Error initializing block database"); | |
1198 | break; | |
1199 | } | |
1200 | ||
1201 | // Check for changed -txindex state | |
1202 | if (fTxIndex != GetBoolArg("-txindex", false)) { | |
1203 | strLoadError = _("You need to rebuild the database using -reindex to change -txindex"); | |
1204 | break; | |
1205 | } | |
1206 | ||
1207 | // Check for changed -prune state. What we are concerned about is a user who has pruned blocks | |
1208 | // in the past, but is now trying to run unpruned. | |
1209 | if (fHavePruned && !fPruneMode) { | |
1210 | strLoadError = _("You need to rebuild the database using -reindex to go back to unpruned mode. This will redownload the entire blockchain"); | |
1211 | break; | |
1212 | } | |
1213 | ||
1214 | uiInterface.InitMessage(_("Verifying blocks...")); | |
1215 | if (fHavePruned && GetArg("-checkblocks", 288) > MIN_BLOCKS_TO_KEEP) { | |
1216 | LogPrintf("Prune: pruned datadir may not have more than %d blocks; -checkblocks=%d may fail\n", | |
1217 | MIN_BLOCKS_TO_KEEP, GetArg("-checkblocks", 288)); | |
1218 | } | |
1219 | if (!CVerifyDB().VerifyDB(pcoinsdbview, GetArg("-checklevel", 3), | |
1220 | GetArg("-checkblocks", 288))) { | |
1221 | strLoadError = _("Corrupted block database detected"); | |
1222 | break; | |
1223 | } | |
1224 | } catch (const std::exception& e) { | |
1225 | if (fDebug) LogPrintf("%s\n", e.what()); | |
1226 | strLoadError = _("Error opening block database"); | |
1227 | break; | |
1228 | } | |
1229 | ||
1230 | fLoaded = true; | |
1231 | } while(false); | |
1232 | ||
1233 | if (!fLoaded) { | |
1234 | // first suggest a reindex | |
1235 | if (!fReset) { | |
1236 | bool fRet = uiInterface.ThreadSafeMessageBox( | |
1237 | strLoadError + ".\n\n" + _("Do you want to rebuild the block database now?"), | |
1238 | "", CClientUIInterface::MSG_ERROR | CClientUIInterface::BTN_ABORT); | |
1239 | if (fRet) { | |
1240 | fReindex = true; | |
1241 | fRequestShutdown = false; | |
1242 | } else { | |
1243 | LogPrintf("Aborted block database rebuild. Exiting.\n"); | |
1244 | return false; | |
1245 | } | |
1246 | } else { | |
1247 | return InitError(strLoadError); | |
1248 | } | |
1249 | } | |
1250 | } | |
1251 | ||
1252 | // As LoadBlockIndex can take several minutes, it's possible the user | |
1253 | // requested to kill the GUI during the last operation. If so, exit. | |
1254 | // As the program has not fully started yet, Shutdown() is possibly overkill. | |
1255 | if (fRequestShutdown) | |
1256 | { | |
1257 | LogPrintf("Shutdown requested. Exiting.\n"); | |
1258 | return false; | |
1259 | } | |
1260 | LogPrintf(" block index %15dms\n", GetTimeMillis() - nStart); | |
1261 | ||
1262 | boost::filesystem::path est_path = GetDataDir() / FEE_ESTIMATES_FILENAME; | |
1263 | CAutoFile est_filein(fopen(est_path.string().c_str(), "rb"), SER_DISK, CLIENT_VERSION); | |
1264 | // Allowed to fail as this file IS missing on first startup. | |
1265 | if (!est_filein.IsNull()) | |
1266 | mempool.ReadFeeEstimates(est_filein); | |
1267 | fFeeEstimatesInitialized = true; | |
1268 | ||
1269 | ||
1270 | // ********************************************************* Step 8: load wallet | |
1271 | #ifdef ENABLE_WALLET | |
1272 | if (fDisableWallet) { | |
1273 | pwalletMain = NULL; | |
1274 | LogPrintf("Wallet disabled!\n"); | |
1275 | } else { | |
1276 | ||
1277 | // needed to restore wallet transaction meta data after -zapwallettxes | |
1278 | std::vector<CWalletTx> vWtx; | |
1279 | ||
1280 | if (GetBoolArg("-zapwallettxes", false)) { | |
1281 | uiInterface.InitMessage(_("Zapping all transactions from wallet...")); | |
1282 | ||
1283 | pwalletMain = new CWallet(strWalletFile); | |
1284 | DBErrors nZapWalletRet = pwalletMain->ZapWalletTx(vWtx); | |
1285 | if (nZapWalletRet != DB_LOAD_OK) { | |
1286 | uiInterface.InitMessage(_("Error loading wallet.dat: Wallet corrupted")); | |
1287 | return false; | |
1288 | } | |
1289 | ||
1290 | delete pwalletMain; | |
1291 | pwalletMain = NULL; | |
1292 | } | |
1293 | ||
1294 | uiInterface.InitMessage(_("Loading wallet...")); | |
1295 | ||
1296 | nStart = GetTimeMillis(); | |
1297 | bool fFirstRun = true; | |
1298 | pwalletMain = new CWallet(strWalletFile); | |
1299 | DBErrors nLoadWalletRet = pwalletMain->LoadWallet(fFirstRun); | |
1300 | if (nLoadWalletRet != DB_LOAD_OK) | |
1301 | { | |
1302 | if (nLoadWalletRet == DB_CORRUPT) | |
1303 | strErrors << _("Error loading wallet.dat: Wallet corrupted") << "\n"; | |
1304 | else if (nLoadWalletRet == DB_NONCRITICAL_ERROR) | |
1305 | { | |
1306 | string msg(_("Warning: error reading wallet.dat! All keys read correctly, but transaction data" | |
1307 | " or address book entries might be missing or incorrect.")); | |
1308 | InitWarning(msg); | |
1309 | } | |
1310 | else if (nLoadWalletRet == DB_TOO_NEW) | |
1311 | strErrors << _("Error loading wallet.dat: Wallet requires newer version of Bitcoin Core") << "\n"; | |
1312 | else if (nLoadWalletRet == DB_NEED_REWRITE) | |
1313 | { | |
1314 | strErrors << _("Wallet needed to be rewritten: restart Bitcoin Core to complete") << "\n"; | |
1315 | LogPrintf("%s", strErrors.str()); | |
1316 | return InitError(strErrors.str()); | |
1317 | } | |
1318 | else | |
1319 | strErrors << _("Error loading wallet.dat") << "\n"; | |
1320 | } | |
1321 | ||
1322 | if (GetBoolArg("-upgradewallet", fFirstRun)) | |
1323 | { | |
1324 | int nMaxVersion = GetArg("-upgradewallet", 0); | |
1325 | if (nMaxVersion == 0) // the -upgradewallet without argument case | |
1326 | { | |
1327 | LogPrintf("Performing wallet upgrade to %i\n", FEATURE_LATEST); | |
1328 | nMaxVersion = CLIENT_VERSION; | |
1329 | pwalletMain->SetMinVersion(FEATURE_LATEST); // permanently upgrade the wallet immediately | |
1330 | } | |
1331 | else | |
1332 | LogPrintf("Allowing wallet upgrade up to %i\n", nMaxVersion); | |
1333 | if (nMaxVersion < pwalletMain->GetVersion()) | |
1334 | strErrors << _("Cannot downgrade wallet") << "\n"; | |
1335 | pwalletMain->SetMaxVersion(nMaxVersion); | |
1336 | } | |
1337 | ||
1338 | if (fFirstRun) | |
1339 | { | |
1340 | // Create new keyUser and set as default key | |
1341 | RandAddSeedPerfmon(); | |
1342 | ||
1343 | CPubKey newDefaultKey; | |
1344 | if (pwalletMain->GetKeyFromPool(newDefaultKey)) { | |
1345 | pwalletMain->SetDefaultKey(newDefaultKey); | |
1346 | if (!pwalletMain->SetAddressBook(pwalletMain->vchDefaultKey.GetID(), "", "receive")) | |
1347 | strErrors << _("Cannot write default address") << "\n"; | |
1348 | } | |
1349 | ||
1350 | pwalletMain->SetBestChain(chainActive.GetLocator()); | |
1351 | } | |
1352 | ||
1353 | LogPrintf("%s", strErrors.str()); | |
1354 | LogPrintf(" wallet %15dms\n", GetTimeMillis() - nStart); | |
1355 | ||
1356 | RegisterValidationInterface(pwalletMain); | |
1357 | ||
1358 | CBlockIndex *pindexRescan = chainActive.Tip(); | |
1359 | if (GetBoolArg("-rescan", false)) | |
1360 | pindexRescan = chainActive.Genesis(); | |
1361 | else | |
1362 | { | |
1363 | CWalletDB walletdb(strWalletFile); | |
1364 | CBlockLocator locator; | |
1365 | if (walletdb.ReadBestBlock(locator)) | |
1366 | pindexRescan = FindForkInGlobalIndex(chainActive, locator); | |
1367 | else | |
1368 | pindexRescan = chainActive.Genesis(); | |
1369 | } | |
1370 | if (chainActive.Tip() && chainActive.Tip() != pindexRescan) | |
1371 | { | |
1372 | uiInterface.InitMessage(_("Rescanning...")); | |
1373 | LogPrintf("Rescanning last %i blocks (from block %i)...\n", chainActive.Height() - pindexRescan->nHeight, pindexRescan->nHeight); | |
1374 | nStart = GetTimeMillis(); | |
1375 | pwalletMain->ScanForWalletTransactions(pindexRescan, true); | |
1376 | LogPrintf(" rescan %15dms\n", GetTimeMillis() - nStart); | |
1377 | pwalletMain->SetBestChain(chainActive.GetLocator()); | |
1378 | nWalletDBUpdated++; | |
1379 | ||
1380 | // Restore wallet transaction metadata after -zapwallettxes=1 | |
1381 | if (GetBoolArg("-zapwallettxes", false) && GetArg("-zapwallettxes", "1") != "2") | |
1382 | { | |
1383 | CWalletDB walletdb(strWalletFile); | |
1384 | ||
1385 | BOOST_FOREACH(const CWalletTx& wtxOld, vWtx) | |
1386 | { | |
1387 | uint256 hash = wtxOld.GetTxid(); | |
1388 | std::map<uint256, CWalletTx>::iterator mi = pwalletMain->mapWallet.find(hash); | |
1389 | if (mi != pwalletMain->mapWallet.end()) | |
1390 | { | |
1391 | const CWalletTx* copyFrom = &wtxOld; | |
1392 | CWalletTx* copyTo = &mi->second; | |
1393 | copyTo->mapValue = copyFrom->mapValue; | |
1394 | copyTo->vOrderForm = copyFrom->vOrderForm; | |
1395 | copyTo->nTimeReceived = copyFrom->nTimeReceived; | |
1396 | copyTo->nTimeSmart = copyFrom->nTimeSmart; | |
1397 | copyTo->fFromMe = copyFrom->fFromMe; | |
1398 | copyTo->strFromAccount = copyFrom->strFromAccount; | |
1399 | copyTo->nOrderPos = copyFrom->nOrderPos; | |
1400 | copyTo->WriteToDisk(&walletdb); | |
1401 | } | |
1402 | } | |
1403 | } | |
1404 | } | |
1405 | pwalletMain->SetBroadcastTransactions(GetBoolArg("-walletbroadcast", true)); | |
1406 | } // (!fDisableWallet) | |
1407 | #else // ENABLE_WALLET | |
1408 | LogPrintf("No wallet support compiled in!\n"); | |
1409 | #endif // !ENABLE_WALLET | |
1410 | ||
1411 | // ********************************************************* Step 9: data directory maintenance | |
1412 | ||
1413 | // if pruning, unset the service bit and perform the initial blockstore prune | |
1414 | // after any wallet rescanning has taken place. | |
1415 | if (fPruneMode) { | |
1416 | LogPrintf("Unsetting NODE_NETWORK on prune mode\n"); | |
1417 | nLocalServices &= ~NODE_NETWORK; | |
1418 | if (!fReindex) { | |
1419 | uiInterface.InitMessage(_("Pruning blockstore...")); | |
1420 | PruneAndFlush(); | |
1421 | } | |
1422 | } | |
1423 | ||
1424 | // ********************************************************* Step 10: import blocks | |
1425 | ||
1426 | if (mapArgs.count("-blocknotify")) | |
1427 | uiInterface.NotifyBlockTip.connect(BlockNotifyCallback); | |
1428 | ||
1429 | uiInterface.InitMessage(_("Activating best chain...")); | |
1430 | // scan for better chains in the block chain database, that are not yet connected in the active best chain | |
1431 | CValidationState state; | |
1432 | if (!ActivateBestChain(state)) | |
1433 | strErrors << "Failed to connect best block"; | |
1434 | ||
1435 | std::vector<boost::filesystem::path> vImportFiles; | |
1436 | if (mapArgs.count("-loadblock")) | |
1437 | { | |
1438 | BOOST_FOREACH(string strFile, mapMultiArgs["-loadblock"]) | |
1439 | vImportFiles.push_back(strFile); | |
1440 | } | |
1441 | threadGroup.create_thread(boost::bind(&ThreadImport, vImportFiles)); | |
1442 | if (chainActive.Tip() == NULL) { | |
1443 | LogPrintf("Waiting for genesis block to be imported...\n"); | |
1444 | while (!fRequestShutdown && chainActive.Tip() == NULL) | |
1445 | MilliSleep(10); | |
1446 | } | |
1447 | ||
1448 | // ********************************************************* Step 11: start node | |
1449 | ||
1450 | if (!CheckDiskSpace()) | |
1451 | return false; | |
1452 | ||
1453 | if (!strErrors.str().empty()) | |
1454 | return InitError(strErrors.str()); | |
1455 | ||
1456 | RandAddSeedPerfmon(); | |
1457 | ||
1458 | //// debug print | |
1459 | LogPrintf("mapBlockIndex.size() = %u\n", mapBlockIndex.size()); | |
1460 | LogPrintf("nBestHeight = %d\n", chainActive.Height()); | |
1461 | #ifdef ENABLE_WALLET | |
1462 | LogPrintf("setKeyPool.size() = %u\n", pwalletMain ? pwalletMain->setKeyPool.size() : 0); | |
1463 | LogPrintf("mapWallet.size() = %u\n", pwalletMain ? pwalletMain->mapWallet.size() : 0); | |
1464 | LogPrintf("mapAddressBook.size() = %u\n", pwalletMain ? pwalletMain->mapAddressBook.size() : 0); | |
1465 | #endif | |
1466 | ||
1467 | StartNode(threadGroup, scheduler); | |
1468 | ||
1469 | // Monitor the chain, and alert if we get blocks much quicker or slower than expected | |
1470 | int64_t nPowTargetSpacing = Params().GetConsensus().nPowTargetSpacing; | |
1471 | CScheduler::Function f = boost::bind(&PartitionCheck, &IsInitialBlockDownload, | |
1472 | boost::ref(cs_main), boost::cref(pindexBestHeader), nPowTargetSpacing); | |
1473 | scheduler.scheduleEvery(f, nPowTargetSpacing); | |
1474 | ||
1475 | #ifdef ENABLE_WALLET | |
1476 | // Generate coins in the background | |
1477 | if (pwalletMain) | |
1478 | GenerateBitcoins(GetBoolArg("-gen", false), pwalletMain, GetArg("-genproclimit", 1)); | |
1479 | #endif | |
1480 | ||
1481 | // ********************************************************* Step 11: finished | |
1482 | ||
1483 | SetRPCWarmupFinished(); | |
1484 | uiInterface.InitMessage(_("Done loading")); | |
1485 | ||
1486 | #ifdef ENABLE_WALLET | |
1487 | if (pwalletMain) { | |
1488 | // Add wallet transactions that aren't already in a block to mapTransactions | |
1489 | pwalletMain->ReacceptWalletTransactions(); | |
1490 | ||
1491 | // Run a thread to flush wallet periodically | |
1492 | threadGroup.create_thread(boost::bind(&ThreadFlushWalletDB, boost::ref(pwalletMain->strWalletFile))); | |
1493 | } | |
1494 | #endif | |
1495 | ||
1496 | // SENDALERT | |
1497 | threadGroup.create_thread(boost::bind(ThreadSendAlert)); | |
1498 | ||
1499 | return !fRequestShutdown; | |
1500 | } |