Merge #12977: Refactor g_wallet_init_interface to const reference

6ec78f1 wallet: Refactor g_wallet_init_interface to const reference (João Barbosa)
1936125 wallet: Make WalletInitInterface members const (João Barbosa)

Pull request description:

Tree-SHA512: c382156a38d4c6beaa6c48f911d7b314542b9500d88724b2b3029dae4491cb1e60e10628f6632d1366818ccf343f494650b3171593b5450149544ba198f49bb5
This commit is contained in:
Wladimir J. van der Laan 2018-04-17 15:57:52 +02:00
commit 434150aef7
No known key found for this signature in database
GPG key ID: 1E4AED62986CD25D
4 changed files with 48 additions and 50 deletions

View file

@ -76,19 +76,18 @@ std::unique_ptr<PeerLogicValidation> peerLogic;
class DummyWalletInit : public WalletInitInterface { class DummyWalletInit : public WalletInitInterface {
public: public:
std::string GetHelpString(bool showDebug) override {return std::string{};} std::string GetHelpString(bool showDebug) const override {return std::string{};}
bool ParameterInteraction() override {return true;} bool ParameterInteraction() const override {return true;}
void RegisterRPC(CRPCTable &) override {} void RegisterRPC(CRPCTable &) const override {}
bool Verify() override {return true;} bool Verify() const override {return true;}
bool Open() override {LogPrintf("No wallet support compiled in!\n"); return true;} bool Open() const override {LogPrintf("No wallet support compiled in!\n"); return true;}
void Start(CScheduler& scheduler) override {} void Start(CScheduler& scheduler) const override {}
void Flush() override {} void Flush() const override {}
void Stop() override {} void Stop() const override {}
void Close() override {} void Close() const override {}
}; };
static DummyWalletInit g_dummy_wallet_init; const WalletInitInterface& g_wallet_init_interface = DummyWalletInit();
WalletInitInterface* const g_wallet_init_interface = &g_dummy_wallet_init;
#endif #endif
#if ENABLE_ZMQ #if ENABLE_ZMQ
@ -204,7 +203,7 @@ void Shutdown()
StopREST(); StopREST();
StopRPC(); StopRPC();
StopHTTPServer(); StopHTTPServer();
g_wallet_init_interface->Flush(); g_wallet_init_interface.Flush();
StopMapPort(); StopMapPort();
// Because these depend on each-other, we make sure that neither can be // Because these depend on each-other, we make sure that neither can be
@ -262,7 +261,7 @@ void Shutdown()
pcoinsdbview.reset(); pcoinsdbview.reset();
pblocktree.reset(); pblocktree.reset();
} }
g_wallet_init_interface->Stop(); g_wallet_init_interface.Stop();
#if ENABLE_ZMQ #if ENABLE_ZMQ
if (pzmqNotificationInterface) { if (pzmqNotificationInterface) {
@ -282,7 +281,7 @@ void Shutdown()
UnregisterAllValidationInterfaces(); UnregisterAllValidationInterfaces();
GetMainSignals().UnregisterBackgroundSignalScheduler(); GetMainSignals().UnregisterBackgroundSignalScheduler();
GetMainSignals().UnregisterWithMempoolSignals(mempool); GetMainSignals().UnregisterWithMempoolSignals(mempool);
g_wallet_init_interface->Close(); g_wallet_init_interface.Close();
globalVerifyHandle.reset(); globalVerifyHandle.reset();
ECC_Stop(); ECC_Stop();
LogPrintf("%s: done\n", __func__); LogPrintf("%s: done\n", __func__);
@ -425,7 +424,7 @@ std::string HelpMessage(HelpMessageMode mode)
strUsage += HelpMessageOpt("-whitelist=<IP address or network>", _("Whitelist peers connecting from the given IP address (e.g. 1.2.3.4) or CIDR notated network (e.g. 1.2.3.0/24). Can be specified multiple times.") + strUsage += HelpMessageOpt("-whitelist=<IP address or network>", _("Whitelist peers connecting from the given IP address (e.g. 1.2.3.4) or CIDR notated network (e.g. 1.2.3.0/24). Can be specified multiple times.") +
" " + _("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")); " " + _("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"));
strUsage += g_wallet_init_interface->GetHelpString(showDebug); strUsage += g_wallet_init_interface.GetHelpString(showDebug);
#if ENABLE_ZMQ #if ENABLE_ZMQ
strUsage += HelpMessageGroup(_("ZeroMQ notification options:")); strUsage += HelpMessageGroup(_("ZeroMQ notification options:"));
@ -1098,7 +1097,7 @@ bool AppInitParameterInteraction()
return InitError(strprintf("acceptnonstdtxn is not currently supported for %s chain", chainparams.NetworkIDString())); return InitError(strprintf("acceptnonstdtxn is not currently supported for %s chain", chainparams.NetworkIDString()));
nBytesPerSigOp = gArgs.GetArg("-bytespersigop", nBytesPerSigOp); nBytesPerSigOp = gArgs.GetArg("-bytespersigop", nBytesPerSigOp);
if (!g_wallet_init_interface->ParameterInteraction()) return false; if (!g_wallet_init_interface.ParameterInteraction()) return false;
fIsBareMultisigStd = gArgs.GetBoolArg("-permitbaremultisig", DEFAULT_PERMIT_BAREMULTISIG); fIsBareMultisigStd = gArgs.GetBoolArg("-permitbaremultisig", DEFAULT_PERMIT_BAREMULTISIG);
fAcceptDatacarrier = gArgs.GetBoolArg("-datacarrier", DEFAULT_ACCEPT_DATACARRIER); fAcceptDatacarrier = gArgs.GetBoolArg("-datacarrier", DEFAULT_ACCEPT_DATACARRIER);
@ -1264,7 +1263,7 @@ bool AppInitMain()
* available in the GUI RPC console even if external calls are disabled. * available in the GUI RPC console even if external calls are disabled.
*/ */
RegisterAllCoreRPCCommands(tableRPC); RegisterAllCoreRPCCommands(tableRPC);
g_wallet_init_interface->RegisterRPC(tableRPC); g_wallet_init_interface.RegisterRPC(tableRPC);
/* Start the RPC server already. It will be started in "warmup" mode /* Start the RPC server already. It will be started in "warmup" mode
* and not really process calls already (but it will signify connections * and not really process calls already (but it will signify connections
@ -1281,7 +1280,7 @@ bool AppInitMain()
int64_t nStart; int64_t nStart;
// ********************************************************* Step 5: verify wallet database integrity // ********************************************************* Step 5: verify wallet database integrity
if (!g_wallet_init_interface->Verify()) return false; if (!g_wallet_init_interface.Verify()) return false;
// ********************************************************* Step 6: network initialization // ********************************************************* Step 6: network initialization
// Note that we absolutely cannot open any actual connections // Note that we absolutely cannot open any actual connections
@ -1600,7 +1599,7 @@ bool AppInitMain()
fFeeEstimatesInitialized = true; fFeeEstimatesInitialized = true;
// ********************************************************* Step 8: load wallet // ********************************************************* Step 8: load wallet
if (!g_wallet_init_interface->Open()) return false; if (!g_wallet_init_interface.Open()) return false;
// ********************************************************* Step 9: data directory maintenance // ********************************************************* Step 9: data directory maintenance
@ -1746,7 +1745,7 @@ bool AppInitMain()
SetRPCWarmupFinished(); SetRPCWarmupFinished();
uiInterface.InitMessage(_("Done loading")); uiInterface.InitMessage(_("Done loading"));
g_wallet_init_interface->Start(scheduler); g_wallet_init_interface.Start(scheduler);
return true; return true;
} }

View file

@ -13,7 +13,7 @@ class CScheduler;
class CWallet; class CWallet;
class WalletInitInterface; class WalletInitInterface;
extern WalletInitInterface* const g_wallet_init_interface; extern const WalletInitInterface& g_wallet_init_interface;
namespace boost namespace boost
{ {

View file

@ -18,39 +18,38 @@ class WalletInit : public WalletInitInterface {
public: public:
//! Return the wallets help message. //! Return the wallets help message.
std::string GetHelpString(bool showDebug) override; std::string GetHelpString(bool showDebug) const override;
//! Wallets parameter interaction //! Wallets parameter interaction
bool ParameterInteraction() override; bool ParameterInteraction() const override;
//! Register wallet RPCs. //! Register wallet RPCs.
void RegisterRPC(CRPCTable &tableRPC) override; void RegisterRPC(CRPCTable &tableRPC) const override;
//! Responsible for reading and validating the -wallet arguments and verifying the wallet database. //! Responsible for reading and validating the -wallet arguments and verifying the wallet database.
// This function will perform salvage on the wallet if requested, as long as only one wallet is // This function will perform salvage on the wallet if requested, as long as only one wallet is
// being loaded (WalletParameterInteraction forbids -salvagewallet, -zapwallettxes or -upgradewallet with multiwallet). // being loaded (WalletParameterInteraction forbids -salvagewallet, -zapwallettxes or -upgradewallet with multiwallet).
bool Verify() override; bool Verify() const override;
//! Load wallet databases. //! Load wallet databases.
bool Open() override; bool Open() const override;
//! Complete startup of wallets. //! Complete startup of wallets.
void Start(CScheduler& scheduler) override; void Start(CScheduler& scheduler) const override;
//! Flush all wallets in preparation for shutdown. //! Flush all wallets in preparation for shutdown.
void Flush() override; void Flush() const override;
//! Stop all wallets. Wallets will be flushed first. //! Stop all wallets. Wallets will be flushed first.
void Stop() override; void Stop() const override;
//! Close all wallets. //! Close all wallets.
void Close() override; void Close() const override;
}; };
static WalletInit g_wallet_init; const WalletInitInterface& g_wallet_init_interface = WalletInit();
WalletInitInterface* const g_wallet_init_interface = &g_wallet_init;
std::string WalletInit::GetHelpString(bool showDebug) std::string WalletInit::GetHelpString(bool showDebug) const
{ {
std::string strUsage = HelpMessageGroup(_("Wallet options:")); std::string strUsage = HelpMessageGroup(_("Wallet options:"));
strUsage += HelpMessageOpt("-addresstype", strprintf("What type of addresses to use (\"legacy\", \"p2sh-segwit\", or \"bech32\", default: \"%s\")", FormatOutputType(DEFAULT_ADDRESS_TYPE))); strUsage += HelpMessageOpt("-addresstype", strprintf("What type of addresses to use (\"legacy\", \"p2sh-segwit\", or \"bech32\", default: \"%s\")", FormatOutputType(DEFAULT_ADDRESS_TYPE)));
@ -92,7 +91,7 @@ std::string WalletInit::GetHelpString(bool showDebug)
return strUsage; return strUsage;
} }
bool WalletInit::ParameterInteraction() bool WalletInit::ParameterInteraction() const
{ {
if (gArgs.GetBoolArg("-disablewallet", DEFAULT_DISABLE_WALLET)) { if (gArgs.GetBoolArg("-disablewallet", DEFAULT_DISABLE_WALLET)) {
for (const std::string& wallet : gArgs.GetArgs("-wallet")) { for (const std::string& wallet : gArgs.GetArgs("-wallet")) {
@ -220,7 +219,7 @@ bool WalletInit::ParameterInteraction()
return true; return true;
} }
void WalletInit::RegisterRPC(CRPCTable &t) void WalletInit::RegisterRPC(CRPCTable &t) const
{ {
if (gArgs.GetBoolArg("-disablewallet", DEFAULT_DISABLE_WALLET)) { if (gArgs.GetBoolArg("-disablewallet", DEFAULT_DISABLE_WALLET)) {
return; return;
@ -229,7 +228,7 @@ void WalletInit::RegisterRPC(CRPCTable &t)
RegisterWalletRPCCommands(t); RegisterWalletRPCCommands(t);
} }
bool WalletInit::Verify() bool WalletInit::Verify() const
{ {
if (gArgs.GetBoolArg("-disablewallet", DEFAULT_DISABLE_WALLET)) { if (gArgs.GetBoolArg("-disablewallet", DEFAULT_DISABLE_WALLET)) {
return true; return true;
@ -304,7 +303,7 @@ bool WalletInit::Verify()
return true; return true;
} }
bool WalletInit::Open() bool WalletInit::Open() const
{ {
if (gArgs.GetBoolArg("-disablewallet", DEFAULT_DISABLE_WALLET)) { if (gArgs.GetBoolArg("-disablewallet", DEFAULT_DISABLE_WALLET)) {
LogPrintf("Wallet disabled!\n"); LogPrintf("Wallet disabled!\n");
@ -322,28 +321,28 @@ bool WalletInit::Open()
return true; return true;
} }
void WalletInit::Start(CScheduler& scheduler) void WalletInit::Start(CScheduler& scheduler) const
{ {
for (CWalletRef pwallet : vpwallets) { for (CWalletRef pwallet : vpwallets) {
pwallet->postInitProcess(scheduler); pwallet->postInitProcess(scheduler);
} }
} }
void WalletInit::Flush() void WalletInit::Flush() const
{ {
for (CWalletRef pwallet : vpwallets) { for (CWalletRef pwallet : vpwallets) {
pwallet->Flush(false); pwallet->Flush(false);
} }
} }
void WalletInit::Stop() void WalletInit::Stop() const
{ {
for (CWalletRef pwallet : vpwallets) { for (CWalletRef pwallet : vpwallets) {
pwallet->Flush(true); pwallet->Flush(true);
} }
} }
void WalletInit::Close() void WalletInit::Close() const
{ {
for (CWalletRef pwallet : vpwallets) { for (CWalletRef pwallet : vpwallets) {
delete pwallet; delete pwallet;

View file

@ -13,23 +13,23 @@ class CRPCTable;
class WalletInitInterface { class WalletInitInterface {
public: public:
/** Get wallet help string */ /** Get wallet help string */
virtual std::string GetHelpString(bool showDebug) = 0; virtual std::string GetHelpString(bool showDebug) const = 0;
/** Check wallet parameter interaction */ /** Check wallet parameter interaction */
virtual bool ParameterInteraction() = 0; virtual bool ParameterInteraction() const = 0;
/** Register wallet RPC*/ /** Register wallet RPC*/
virtual void RegisterRPC(CRPCTable &) = 0; virtual void RegisterRPC(CRPCTable &) const = 0;
/** Verify wallets */ /** Verify wallets */
virtual bool Verify() = 0; virtual bool Verify() const = 0;
/** Open wallets*/ /** Open wallets*/
virtual bool Open() = 0; virtual bool Open() const = 0;
/** Start wallets*/ /** Start wallets*/
virtual void Start(CScheduler& scheduler) = 0; virtual void Start(CScheduler& scheduler) const = 0;
/** Flush Wallets*/ /** Flush Wallets*/
virtual void Flush() = 0; virtual void Flush() const = 0;
/** Stop Wallets*/ /** Stop Wallets*/
virtual void Stop() = 0; virtual void Stop() const = 0;
/** Close wallets */ /** Close wallets */
virtual void Close() = 0; virtual void Close() const = 0;
virtual ~WalletInitInterface() {} virtual ~WalletInitInterface() {}
}; };