mirror of
https://github.com/bitcoin/bitcoin.git
synced 2025-01-25 10:43:19 -03:00
Merge pull request #5681
8a893c9
Includes: Do not include main.h from any other header (Jorge Timón)eca0b1e
Includes: MOVEONLY: move more method definitions out of wallet.h (Jorge Timón)26c16d9
Includes: Refactor: Move CValidationInterface and CMainSignals out of main (Jorge Timón)
This commit is contained in:
commit
8d2fbfa491
17 changed files with 221 additions and 160 deletions
|
@ -138,6 +138,7 @@ BITCOIN_CORE_H = \
|
||||||
utilmoneystr.h \
|
utilmoneystr.h \
|
||||||
utilstrencodings.h \
|
utilstrencodings.h \
|
||||||
utiltime.h \
|
utiltime.h \
|
||||||
|
validationinterface.h \
|
||||||
version.h \
|
version.h \
|
||||||
wallet/crypter.h \
|
wallet/crypter.h \
|
||||||
wallet/walletdb.h \
|
wallet/walletdb.h \
|
||||||
|
@ -191,6 +192,7 @@ libbitcoin_server_a_SOURCES = \
|
||||||
timedata.cpp \
|
timedata.cpp \
|
||||||
txdb.cpp \
|
txdb.cpp \
|
||||||
txmempool.cpp \
|
txmempool.cpp \
|
||||||
|
validationinterface.cpp \
|
||||||
$(JSON_H) \
|
$(JSON_H) \
|
||||||
$(BITCOIN_CORE_H)
|
$(BITCOIN_CORE_H)
|
||||||
|
|
||||||
|
|
77
src/main.cpp
77
src/main.cpp
|
@ -5,9 +5,9 @@
|
||||||
|
|
||||||
#include "main.h"
|
#include "main.h"
|
||||||
|
|
||||||
#include "arith_uint256.h"
|
|
||||||
#include "addrman.h"
|
#include "addrman.h"
|
||||||
#include "alert.h"
|
#include "alert.h"
|
||||||
|
#include "arith_uint256.h"
|
||||||
#include "chainparams.h"
|
#include "chainparams.h"
|
||||||
#include "checkpoints.h"
|
#include "checkpoints.h"
|
||||||
#include "checkqueue.h"
|
#include "checkqueue.h"
|
||||||
|
@ -21,6 +21,7 @@
|
||||||
#include "undo.h"
|
#include "undo.h"
|
||||||
#include "util.h"
|
#include "util.h"
|
||||||
#include "utilmoneystr.h"
|
#include "utilmoneystr.h"
|
||||||
|
#include "validationinterface.h"
|
||||||
|
|
||||||
#include <sstream>
|
#include <sstream>
|
||||||
|
|
||||||
|
@ -156,68 +157,6 @@ namespace {
|
||||||
set<int> setDirtyFileInfo;
|
set<int> setDirtyFileInfo;
|
||||||
} // anon namespace
|
} // anon namespace
|
||||||
|
|
||||||
//////////////////////////////////////////////////////////////////////////////
|
|
||||||
//
|
|
||||||
// dispatching functions
|
|
||||||
//
|
|
||||||
|
|
||||||
// These functions dispatch to one or all registered wallets
|
|
||||||
|
|
||||||
namespace {
|
|
||||||
|
|
||||||
struct CMainSignals {
|
|
||||||
/** Notifies listeners of updated transaction data (transaction, and optionally the block it is found in. */
|
|
||||||
boost::signals2::signal<void (const CTransaction &, const CBlock *)> SyncTransaction;
|
|
||||||
/** Notifies listeners of an erased transaction (currently disabled, requires transaction replacement). */
|
|
||||||
boost::signals2::signal<void (const uint256 &)> EraseTransaction;
|
|
||||||
/** Notifies listeners of an updated transaction without new data (for now: a coinbase potentially becoming visible). */
|
|
||||||
boost::signals2::signal<void (const uint256 &)> UpdatedTransaction;
|
|
||||||
/** Notifies listeners of a new active block chain. */
|
|
||||||
boost::signals2::signal<void (const CBlockLocator &)> SetBestChain;
|
|
||||||
/** Notifies listeners about an inventory item being seen on the network. */
|
|
||||||
boost::signals2::signal<void (const uint256 &)> Inventory;
|
|
||||||
/** Tells listeners to broadcast their data. */
|
|
||||||
boost::signals2::signal<void ()> Broadcast;
|
|
||||||
/** Notifies listeners of a block validation result */
|
|
||||||
boost::signals2::signal<void (const CBlock&, const CValidationState&)> BlockChecked;
|
|
||||||
} g_signals;
|
|
||||||
|
|
||||||
} // anon namespace
|
|
||||||
|
|
||||||
void RegisterValidationInterface(CValidationInterface* pwalletIn) {
|
|
||||||
g_signals.SyncTransaction.connect(boost::bind(&CValidationInterface::SyncTransaction, pwalletIn, _1, _2));
|
|
||||||
g_signals.EraseTransaction.connect(boost::bind(&CValidationInterface::EraseFromWallet, pwalletIn, _1));
|
|
||||||
g_signals.UpdatedTransaction.connect(boost::bind(&CValidationInterface::UpdatedTransaction, pwalletIn, _1));
|
|
||||||
g_signals.SetBestChain.connect(boost::bind(&CValidationInterface::SetBestChain, pwalletIn, _1));
|
|
||||||
g_signals.Inventory.connect(boost::bind(&CValidationInterface::Inventory, pwalletIn, _1));
|
|
||||||
g_signals.Broadcast.connect(boost::bind(&CValidationInterface::ResendWalletTransactions, pwalletIn));
|
|
||||||
g_signals.BlockChecked.connect(boost::bind(&CValidationInterface::BlockChecked, pwalletIn, _1, _2));
|
|
||||||
}
|
|
||||||
|
|
||||||
void UnregisterValidationInterface(CValidationInterface* pwalletIn) {
|
|
||||||
g_signals.BlockChecked.disconnect(boost::bind(&CValidationInterface::BlockChecked, pwalletIn, _1, _2));
|
|
||||||
g_signals.Broadcast.disconnect(boost::bind(&CValidationInterface::ResendWalletTransactions, pwalletIn));
|
|
||||||
g_signals.Inventory.disconnect(boost::bind(&CValidationInterface::Inventory, pwalletIn, _1));
|
|
||||||
g_signals.SetBestChain.disconnect(boost::bind(&CValidationInterface::SetBestChain, pwalletIn, _1));
|
|
||||||
g_signals.UpdatedTransaction.disconnect(boost::bind(&CValidationInterface::UpdatedTransaction, pwalletIn, _1));
|
|
||||||
g_signals.EraseTransaction.disconnect(boost::bind(&CValidationInterface::EraseFromWallet, pwalletIn, _1));
|
|
||||||
g_signals.SyncTransaction.disconnect(boost::bind(&CValidationInterface::SyncTransaction, pwalletIn, _1, _2));
|
|
||||||
}
|
|
||||||
|
|
||||||
void UnregisterAllValidationInterfaces() {
|
|
||||||
g_signals.BlockChecked.disconnect_all_slots();
|
|
||||||
g_signals.Broadcast.disconnect_all_slots();
|
|
||||||
g_signals.Inventory.disconnect_all_slots();
|
|
||||||
g_signals.SetBestChain.disconnect_all_slots();
|
|
||||||
g_signals.UpdatedTransaction.disconnect_all_slots();
|
|
||||||
g_signals.EraseTransaction.disconnect_all_slots();
|
|
||||||
g_signals.SyncTransaction.disconnect_all_slots();
|
|
||||||
}
|
|
||||||
|
|
||||||
void SyncWithWallets(const CTransaction &tx, const CBlock *pblock) {
|
|
||||||
g_signals.SyncTransaction(tx, pblock);
|
|
||||||
}
|
|
||||||
|
|
||||||
//////////////////////////////////////////////////////////////////////////////
|
//////////////////////////////////////////////////////////////////////////////
|
||||||
//
|
//
|
||||||
// Registration of network node signals.
|
// Registration of network node signals.
|
||||||
|
@ -1897,7 +1836,7 @@ bool ConnectBlock(const CBlock& block, CValidationState& state, CBlockIndex* pin
|
||||||
|
|
||||||
// Watch for changes to the previous coinbase transaction.
|
// Watch for changes to the previous coinbase transaction.
|
||||||
static uint256 hashPrevBestCoinBase;
|
static uint256 hashPrevBestCoinBase;
|
||||||
g_signals.UpdatedTransaction(hashPrevBestCoinBase);
|
GetMainSignals().UpdatedTransaction(hashPrevBestCoinBase);
|
||||||
hashPrevBestCoinBase = block.vtx[0].GetHash();
|
hashPrevBestCoinBase = block.vtx[0].GetHash();
|
||||||
|
|
||||||
int64_t nTime4 = GetTimeMicros(); nTimeCallbacks += nTime4 - nTime3;
|
int64_t nTime4 = GetTimeMicros(); nTimeCallbacks += nTime4 - nTime3;
|
||||||
|
@ -1956,7 +1895,7 @@ bool static FlushStateToDisk(CValidationState &state, FlushStateMode mode) {
|
||||||
return state.Abort("Failed to write to coin database");
|
return state.Abort("Failed to write to coin database");
|
||||||
// Update best block in wallet (so we can detect restored wallets).
|
// Update best block in wallet (so we can detect restored wallets).
|
||||||
if (mode != FLUSH_STATE_IF_NEEDED) {
|
if (mode != FLUSH_STATE_IF_NEEDED) {
|
||||||
g_signals.SetBestChain(chainActive.GetLocator());
|
GetMainSignals().SetBestChain(chainActive.GetLocator());
|
||||||
}
|
}
|
||||||
nLastWrite = GetTimeMicros();
|
nLastWrite = GetTimeMicros();
|
||||||
}
|
}
|
||||||
|
@ -2080,7 +2019,7 @@ bool static ConnectTip(CValidationState &state, CBlockIndex *pindexNew, CBlock *
|
||||||
CCoinsViewCache view(pcoinsTip);
|
CCoinsViewCache view(pcoinsTip);
|
||||||
CInv inv(MSG_BLOCK, pindexNew->GetBlockHash());
|
CInv inv(MSG_BLOCK, pindexNew->GetBlockHash());
|
||||||
bool rv = ConnectBlock(*pblock, state, pindexNew, view);
|
bool rv = ConnectBlock(*pblock, state, pindexNew, view);
|
||||||
g_signals.BlockChecked(*pblock, state);
|
GetMainSignals().BlockChecked(*pblock, state);
|
||||||
if (!rv) {
|
if (!rv) {
|
||||||
if (state.IsInvalid())
|
if (state.IsInvalid())
|
||||||
InvalidBlockFound(pindexNew, state);
|
InvalidBlockFound(pindexNew, state);
|
||||||
|
@ -3471,7 +3410,7 @@ void static ProcessGetData(CNode* pfrom)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Track requests for our stuff.
|
// Track requests for our stuff.
|
||||||
g_signals.Inventory(inv.hash);
|
GetMainSignals().Inventory(inv.hash);
|
||||||
|
|
||||||
if (inv.type == MSG_BLOCK || inv.type == MSG_FILTERED_BLOCK)
|
if (inv.type == MSG_BLOCK || inv.type == MSG_FILTERED_BLOCK)
|
||||||
break;
|
break;
|
||||||
|
@ -3765,7 +3704,7 @@ bool static ProcessMessage(CNode* pfrom, string strCommand, CDataStream& vRecv,
|
||||||
}
|
}
|
||||||
|
|
||||||
// Track requests for our stuff
|
// Track requests for our stuff
|
||||||
g_signals.Inventory(inv.hash);
|
GetMainSignals().Inventory(inv.hash);
|
||||||
|
|
||||||
if (pfrom->nSendSize > (SendBufferSize() * 2)) {
|
if (pfrom->nSendSize > (SendBufferSize() * 2)) {
|
||||||
Misbehaving(pfrom->GetId(), 50);
|
Misbehaving(pfrom->GetId(), 50);
|
||||||
|
@ -4536,7 +4475,7 @@ bool SendMessages(CNode* pto, bool fSendTrickle)
|
||||||
// transactions become unconfirmed and spams other nodes.
|
// transactions become unconfirmed and spams other nodes.
|
||||||
if (!fReindex && !fImporting && !IsInitialBlockDownload())
|
if (!fReindex && !fImporting && !IsInitialBlockDownload())
|
||||||
{
|
{
|
||||||
g_signals.Broadcast();
|
GetMainSignals().Broadcast();
|
||||||
}
|
}
|
||||||
|
|
||||||
//
|
//
|
||||||
|
|
26
src/main.h
26
src/main.h
|
@ -133,15 +133,6 @@ extern CBlockIndex *pindexBestHeader;
|
||||||
/** Minimum disk space required - used in CheckDiskSpace() */
|
/** Minimum disk space required - used in CheckDiskSpace() */
|
||||||
static const uint64_t nMinDiskSpace = 52428800;
|
static const uint64_t nMinDiskSpace = 52428800;
|
||||||
|
|
||||||
/** Register a wallet to receive updates from core */
|
|
||||||
void RegisterValidationInterface(CValidationInterface* pwalletIn);
|
|
||||||
/** Unregister a wallet from core */
|
|
||||||
void UnregisterValidationInterface(CValidationInterface* pwalletIn);
|
|
||||||
/** Unregister all wallets from core */
|
|
||||||
void UnregisterAllValidationInterfaces();
|
|
||||||
/** Push an updated transaction to all registered wallets */
|
|
||||||
void SyncWithWallets(const CTransaction& tx, const CBlock* pblock = NULL);
|
|
||||||
|
|
||||||
/** Register with a network node to receive its signals */
|
/** Register with a network node to receive its signals */
|
||||||
void RegisterNodeSignals(CNodeSignals& nodeSignals);
|
void RegisterNodeSignals(CNodeSignals& nodeSignals);
|
||||||
/** Unregister a network node */
|
/** Unregister a network node */
|
||||||
|
@ -152,7 +143,7 @@ void UnregisterNodeSignals(CNodeSignals& nodeSignals);
|
||||||
* block is made active. Note that it does not, however, guarantee that the
|
* block is made active. Note that it does not, however, guarantee that the
|
||||||
* specific block passed to it has been checked for validity!
|
* specific block passed to it has been checked for validity!
|
||||||
*
|
*
|
||||||
* @param[out] state This may be set to an Error state if any error occurred processing it, including during validation/connection/etc of otherwise unrelated blocks during reorganisation; or it may be set to an Invalid state if pblock is itself invalid (but this is not guaranteed even when the block is checked). If you want to *possibly* get feedback on whether pblock is valid, you must also install a CValidationInterface - this will have its BlockChecked method called whenever *any* block completes validation.
|
* @param[out] state This may be set to an Error state if any error occurred processing it, including during validation/connection/etc of otherwise unrelated blocks during reorganisation; or it may be set to an Invalid state if pblock is itself invalid (but this is not guaranteed even when the block is checked). If you want to *possibly* get feedback on whether pblock is valid, you must also install a CValidationInterface (see validationinterface.h) - this will have its BlockChecked method called whenever *any* block completes validation.
|
||||||
* @param[in] pfrom The node which we are receiving the block from; it is added to mapBlockSource and may be penalised if the block is invalid.
|
* @param[in] pfrom The node which we are receiving the block from; it is added to mapBlockSource and may be penalised if the block is invalid.
|
||||||
* @param[in] pblock The block we want to process.
|
* @param[in] pblock The block we want to process.
|
||||||
* @param[out] dbp If pblock is stored to disk (or already there), this will be set to its location.
|
* @param[out] dbp If pblock is stored to disk (or already there), this will be set to its location.
|
||||||
|
@ -512,19 +503,4 @@ extern CCoinsViewCache *pcoinsTip;
|
||||||
/** Global variable that points to the active block tree (protected by cs_main) */
|
/** Global variable that points to the active block tree (protected by cs_main) */
|
||||||
extern CBlockTreeDB *pblocktree;
|
extern CBlockTreeDB *pblocktree;
|
||||||
|
|
||||||
|
|
||||||
class CValidationInterface {
|
|
||||||
protected:
|
|
||||||
virtual void SyncTransaction(const CTransaction &tx, const CBlock *pblock) {};
|
|
||||||
virtual void EraseFromWallet(const uint256 &hash) {};
|
|
||||||
virtual void SetBestChain(const CBlockLocator &locator) {};
|
|
||||||
virtual void UpdatedTransaction(const uint256 &hash) {};
|
|
||||||
virtual void Inventory(const uint256 &hash) {};
|
|
||||||
virtual void ResendWalletTransactions() {};
|
|
||||||
virtual void BlockChecked(const CBlock&, const CValidationState&) {};
|
|
||||||
friend void ::RegisterValidationInterface(CValidationInterface*);
|
|
||||||
friend void ::UnregisterValidationInterface(CValidationInterface*);
|
|
||||||
friend void ::UnregisterAllValidationInterfaces();
|
|
||||||
};
|
|
||||||
|
|
||||||
#endif // BITCOIN_MAIN_H
|
#endif // BITCOIN_MAIN_H
|
||||||
|
|
|
@ -10,6 +10,8 @@
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
#include "wallet/wallet.h"
|
#include "wallet/wallet.h"
|
||||||
|
|
||||||
|
#include <boost/foreach.hpp>
|
||||||
|
|
||||||
#include <QFont>
|
#include <QFont>
|
||||||
#include <QDebug>
|
#include <QDebug>
|
||||||
|
|
||||||
|
|
|
@ -10,6 +10,7 @@
|
||||||
|
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
#include "chainparams.h"
|
#include "chainparams.h"
|
||||||
|
#include "main.h"
|
||||||
#include "ui_interface.h"
|
#include "ui_interface.h"
|
||||||
#include "util.h"
|
#include "util.h"
|
||||||
#include "wallet/wallet.h"
|
#include "wallet/wallet.h"
|
||||||
|
|
|
@ -17,6 +17,7 @@
|
||||||
|
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
#include "coincontrol.h"
|
#include "coincontrol.h"
|
||||||
|
#include "main.h"
|
||||||
#include "ui_interface.h"
|
#include "ui_interface.h"
|
||||||
#include "wallet/wallet.h"
|
#include "wallet/wallet.h"
|
||||||
|
|
||||||
|
|
|
@ -12,6 +12,7 @@
|
||||||
|
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
#include "init.h"
|
#include "init.h"
|
||||||
|
#include "main.h" // For strMessageMagic
|
||||||
#include "wallet/wallet.h"
|
#include "wallet/wallet.h"
|
||||||
|
|
||||||
#include <string>
|
#include <string>
|
||||||
|
|
|
@ -5,11 +5,14 @@
|
||||||
#include "transactionrecord.h"
|
#include "transactionrecord.h"
|
||||||
|
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
|
#include "main.h"
|
||||||
#include "timedata.h"
|
#include "timedata.h"
|
||||||
#include "wallet/wallet.h"
|
#include "wallet/wallet.h"
|
||||||
|
|
||||||
#include <stdint.h>
|
#include <stdint.h>
|
||||||
|
|
||||||
|
#include <boost/foreach.hpp>
|
||||||
|
|
||||||
/* Return positive answer if transaction should be shown in list.
|
/* Return positive answer if transaction should be shown in list.
|
||||||
*/
|
*/
|
||||||
bool TransactionRecord::showTransaction(const CWalletTx &wtx)
|
bool TransactionRecord::showTransaction(const CWalletTx &wtx)
|
||||||
|
|
|
@ -6,6 +6,7 @@
|
||||||
#include "rpcclient.h"
|
#include "rpcclient.h"
|
||||||
|
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
|
#include "main.h"
|
||||||
#include "wallet/wallet.h"
|
#include "wallet/wallet.h"
|
||||||
|
|
||||||
#include "test/test_bitcoin.h"
|
#include "test/test_bitcoin.h"
|
||||||
|
|
|
@ -5,6 +5,7 @@
|
||||||
|
|
||||||
#include "txdb.h"
|
#include "txdb.h"
|
||||||
|
|
||||||
|
#include "main.h"
|
||||||
#include "pow.h"
|
#include "pow.h"
|
||||||
#include "uint256.h"
|
#include "uint256.h"
|
||||||
|
|
||||||
|
|
|
@ -6,15 +6,17 @@
|
||||||
#ifndef BITCOIN_TXDB_H
|
#ifndef BITCOIN_TXDB_H
|
||||||
#define BITCOIN_TXDB_H
|
#define BITCOIN_TXDB_H
|
||||||
|
|
||||||
|
#include "coins.h"
|
||||||
#include "leveldbwrapper.h"
|
#include "leveldbwrapper.h"
|
||||||
#include "main.h"
|
|
||||||
|
|
||||||
#include <map>
|
#include <map>
|
||||||
#include <string>
|
#include <string>
|
||||||
#include <utility>
|
#include <utility>
|
||||||
#include <vector>
|
#include <vector>
|
||||||
|
|
||||||
class CCoins;
|
class CBlockFileInfo;
|
||||||
|
class CBlockIndex;
|
||||||
|
class CDiskTxPos;
|
||||||
class uint256;
|
class uint256;
|
||||||
|
|
||||||
//! -dbcache default (MiB)
|
//! -dbcache default (MiB)
|
||||||
|
|
47
src/validationinterface.cpp
Normal file
47
src/validationinterface.cpp
Normal file
|
@ -0,0 +1,47 @@
|
||||||
|
// Copyright (c) 2009-2010 Satoshi Nakamoto
|
||||||
|
// Copyright (c) 2009-2014 The Bitcoin Core developers
|
||||||
|
// Distributed under the MIT software license, see the accompanying
|
||||||
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
||||||
|
|
||||||
|
#include "validationinterface.h"
|
||||||
|
|
||||||
|
static CMainSignals g_signals;
|
||||||
|
|
||||||
|
CMainSignals& GetMainSignals()
|
||||||
|
{
|
||||||
|
return g_signals;
|
||||||
|
}
|
||||||
|
|
||||||
|
void RegisterValidationInterface(CValidationInterface* pwalletIn) {
|
||||||
|
g_signals.SyncTransaction.connect(boost::bind(&CValidationInterface::SyncTransaction, pwalletIn, _1, _2));
|
||||||
|
g_signals.EraseTransaction.connect(boost::bind(&CValidationInterface::EraseFromWallet, pwalletIn, _1));
|
||||||
|
g_signals.UpdatedTransaction.connect(boost::bind(&CValidationInterface::UpdatedTransaction, pwalletIn, _1));
|
||||||
|
g_signals.SetBestChain.connect(boost::bind(&CValidationInterface::SetBestChain, pwalletIn, _1));
|
||||||
|
g_signals.Inventory.connect(boost::bind(&CValidationInterface::Inventory, pwalletIn, _1));
|
||||||
|
g_signals.Broadcast.connect(boost::bind(&CValidationInterface::ResendWalletTransactions, pwalletIn));
|
||||||
|
g_signals.BlockChecked.connect(boost::bind(&CValidationInterface::BlockChecked, pwalletIn, _1, _2));
|
||||||
|
}
|
||||||
|
|
||||||
|
void UnregisterValidationInterface(CValidationInterface* pwalletIn) {
|
||||||
|
g_signals.BlockChecked.disconnect(boost::bind(&CValidationInterface::BlockChecked, pwalletIn, _1, _2));
|
||||||
|
g_signals.Broadcast.disconnect(boost::bind(&CValidationInterface::ResendWalletTransactions, pwalletIn));
|
||||||
|
g_signals.Inventory.disconnect(boost::bind(&CValidationInterface::Inventory, pwalletIn, _1));
|
||||||
|
g_signals.SetBestChain.disconnect(boost::bind(&CValidationInterface::SetBestChain, pwalletIn, _1));
|
||||||
|
g_signals.UpdatedTransaction.disconnect(boost::bind(&CValidationInterface::UpdatedTransaction, pwalletIn, _1));
|
||||||
|
g_signals.EraseTransaction.disconnect(boost::bind(&CValidationInterface::EraseFromWallet, pwalletIn, _1));
|
||||||
|
g_signals.SyncTransaction.disconnect(boost::bind(&CValidationInterface::SyncTransaction, pwalletIn, _1, _2));
|
||||||
|
}
|
||||||
|
|
||||||
|
void UnregisterAllValidationInterfaces() {
|
||||||
|
g_signals.BlockChecked.disconnect_all_slots();
|
||||||
|
g_signals.Broadcast.disconnect_all_slots();
|
||||||
|
g_signals.Inventory.disconnect_all_slots();
|
||||||
|
g_signals.SetBestChain.disconnect_all_slots();
|
||||||
|
g_signals.UpdatedTransaction.disconnect_all_slots();
|
||||||
|
g_signals.EraseTransaction.disconnect_all_slots();
|
||||||
|
g_signals.SyncTransaction.disconnect_all_slots();
|
||||||
|
}
|
||||||
|
|
||||||
|
void SyncWithWallets(const CTransaction &tx, const CBlock *pblock) {
|
||||||
|
g_signals.SyncTransaction(tx, pblock);
|
||||||
|
}
|
62
src/validationinterface.h
Normal file
62
src/validationinterface.h
Normal file
|
@ -0,0 +1,62 @@
|
||||||
|
// Copyright (c) 2009-2010 Satoshi Nakamoto
|
||||||
|
// Copyright (c) 2009-2014 The Bitcoin Core developers
|
||||||
|
// Distributed under the MIT software license, see the accompanying
|
||||||
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
||||||
|
|
||||||
|
#ifndef BITCOIN_VALIDATIONINTERFACE_H
|
||||||
|
#define BITCOIN_VALIDATIONINTERFACE_H
|
||||||
|
|
||||||
|
#include <boost/signals2/signal.hpp>
|
||||||
|
|
||||||
|
class CBlock;
|
||||||
|
class CBlockLocator;
|
||||||
|
class CTransaction;
|
||||||
|
class CValidationInterface;
|
||||||
|
class CValidationState;
|
||||||
|
class uint256;
|
||||||
|
|
||||||
|
// These functions dispatch to one or all registered wallets
|
||||||
|
|
||||||
|
/** Register a wallet to receive updates from core */
|
||||||
|
void RegisterValidationInterface(CValidationInterface* pwalletIn);
|
||||||
|
/** Unregister a wallet from core */
|
||||||
|
void UnregisterValidationInterface(CValidationInterface* pwalletIn);
|
||||||
|
/** Unregister all wallets from core */
|
||||||
|
void UnregisterAllValidationInterfaces();
|
||||||
|
/** Push an updated transaction to all registered wallets */
|
||||||
|
void SyncWithWallets(const CTransaction& tx, const CBlock* pblock = NULL);
|
||||||
|
|
||||||
|
class CValidationInterface {
|
||||||
|
protected:
|
||||||
|
virtual void SyncTransaction(const CTransaction &tx, const CBlock *pblock) {};
|
||||||
|
virtual void EraseFromWallet(const uint256 &hash) {};
|
||||||
|
virtual void SetBestChain(const CBlockLocator &locator) {};
|
||||||
|
virtual void UpdatedTransaction(const uint256 &hash) {};
|
||||||
|
virtual void Inventory(const uint256 &hash) {};
|
||||||
|
virtual void ResendWalletTransactions() {};
|
||||||
|
virtual void BlockChecked(const CBlock&, const CValidationState&) {};
|
||||||
|
friend void ::RegisterValidationInterface(CValidationInterface*);
|
||||||
|
friend void ::UnregisterValidationInterface(CValidationInterface*);
|
||||||
|
friend void ::UnregisterAllValidationInterfaces();
|
||||||
|
};
|
||||||
|
|
||||||
|
struct CMainSignals {
|
||||||
|
/** Notifies listeners of updated transaction data (transaction, and optionally the block it is found in. */
|
||||||
|
boost::signals2::signal<void (const CTransaction &, const CBlock *)> SyncTransaction;
|
||||||
|
/** Notifies listeners of an erased transaction (currently disabled, requires transaction replacement). */
|
||||||
|
boost::signals2::signal<void (const uint256 &)> EraseTransaction;
|
||||||
|
/** Notifies listeners of an updated transaction without new data (for now: a coinbase potentially becoming visible). */
|
||||||
|
boost::signals2::signal<void (const uint256 &)> UpdatedTransaction;
|
||||||
|
/** Notifies listeners of a new active block chain. */
|
||||||
|
boost::signals2::signal<void (const CBlockLocator &)> SetBestChain;
|
||||||
|
/** Notifies listeners about an inventory item being seen on the network. */
|
||||||
|
boost::signals2::signal<void (const uint256 &)> Inventory;
|
||||||
|
/** Tells listeners to broadcast their data. */
|
||||||
|
boost::signals2::signal<void ()> Broadcast;
|
||||||
|
/** Notifies listeners of a block validation result */
|
||||||
|
boost::signals2::signal<void (const CBlock&, const CValidationState&)> BlockChecked;
|
||||||
|
};
|
||||||
|
|
||||||
|
CMainSignals& GetMainSignals();
|
||||||
|
|
||||||
|
#endif // BITCOIN_VALIDATIONINTERFACE_H
|
|
@ -6,10 +6,11 @@
|
||||||
#include "amount.h"
|
#include "amount.h"
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
#include "core_io.h"
|
#include "core_io.h"
|
||||||
#include "rpcserver.h"
|
|
||||||
#include "init.h"
|
#include "init.h"
|
||||||
|
#include "main.h"
|
||||||
#include "net.h"
|
#include "net.h"
|
||||||
#include "netbase.h"
|
#include "netbase.h"
|
||||||
|
#include "rpcserver.h"
|
||||||
#include "timedata.h"
|
#include "timedata.h"
|
||||||
#include "util.h"
|
#include "util.h"
|
||||||
#include "utilmoneystr.h"
|
#include "utilmoneystr.h"
|
||||||
|
|
|
@ -8,6 +8,7 @@
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
#include "checkpoints.h"
|
#include "checkpoints.h"
|
||||||
#include "coincontrol.h"
|
#include "coincontrol.h"
|
||||||
|
#include "main.h"
|
||||||
#include "net.h"
|
#include "net.h"
|
||||||
#include "script/script.h"
|
#include "script/script.h"
|
||||||
#include "script/sign.h"
|
#include "script/sign.h"
|
||||||
|
@ -817,6 +818,18 @@ CAmount CWallet::GetDebit(const CTxIn &txin, const isminefilter& filter) const
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
isminetype CWallet::IsMine(const CTxOut& txout) const
|
||||||
|
{
|
||||||
|
return ::IsMine(*this, txout.scriptPubKey);
|
||||||
|
}
|
||||||
|
|
||||||
|
CAmount CWallet::GetCredit(const CTxOut& txout, const isminefilter& filter) const
|
||||||
|
{
|
||||||
|
if (!MoneyRange(txout.nValue))
|
||||||
|
throw std::runtime_error("CWallet::GetCredit(): value out of range");
|
||||||
|
return ((IsMine(txout) & filter) ? txout.nValue : 0);
|
||||||
|
}
|
||||||
|
|
||||||
bool CWallet::IsChange(const CTxOut& txout) const
|
bool CWallet::IsChange(const CTxOut& txout) const
|
||||||
{
|
{
|
||||||
// TODO: fix handling of 'change' outputs. The assumption is that any
|
// TODO: fix handling of 'change' outputs. The assumption is that any
|
||||||
|
@ -839,6 +852,62 @@ bool CWallet::IsChange(const CTxOut& txout) const
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
CAmount CWallet::GetChange(const CTxOut& txout) const
|
||||||
|
{
|
||||||
|
if (!MoneyRange(txout.nValue))
|
||||||
|
throw std::runtime_error("CWallet::GetChange(): value out of range");
|
||||||
|
return (IsChange(txout) ? txout.nValue : 0);
|
||||||
|
}
|
||||||
|
|
||||||
|
bool CWallet::IsMine(const CTransaction& tx) const
|
||||||
|
{
|
||||||
|
BOOST_FOREACH(const CTxOut& txout, tx.vout)
|
||||||
|
if (IsMine(txout))
|
||||||
|
return true;
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
bool CWallet::IsFromMe(const CTransaction& tx) const
|
||||||
|
{
|
||||||
|
return (GetDebit(tx, ISMINE_ALL) > 0);
|
||||||
|
}
|
||||||
|
|
||||||
|
CAmount CWallet::GetDebit(const CTransaction& tx, const isminefilter& filter) const
|
||||||
|
{
|
||||||
|
CAmount nDebit = 0;
|
||||||
|
BOOST_FOREACH(const CTxIn& txin, tx.vin)
|
||||||
|
{
|
||||||
|
nDebit += GetDebit(txin, filter);
|
||||||
|
if (!MoneyRange(nDebit))
|
||||||
|
throw std::runtime_error("CWallet::GetDebit(): value out of range");
|
||||||
|
}
|
||||||
|
return nDebit;
|
||||||
|
}
|
||||||
|
|
||||||
|
CAmount CWallet::GetCredit(const CTransaction& tx, const isminefilter& filter) const
|
||||||
|
{
|
||||||
|
CAmount nCredit = 0;
|
||||||
|
BOOST_FOREACH(const CTxOut& txout, tx.vout)
|
||||||
|
{
|
||||||
|
nCredit += GetCredit(txout, filter);
|
||||||
|
if (!MoneyRange(nCredit))
|
||||||
|
throw std::runtime_error("CWallet::GetCredit(): value out of range");
|
||||||
|
}
|
||||||
|
return nCredit;
|
||||||
|
}
|
||||||
|
|
||||||
|
CAmount CWallet::GetChange(const CTransaction& tx) const
|
||||||
|
{
|
||||||
|
CAmount nChange = 0;
|
||||||
|
BOOST_FOREACH(const CTxOut& txout, tx.vout)
|
||||||
|
{
|
||||||
|
nChange += GetChange(txout);
|
||||||
|
if (!MoneyRange(nChange))
|
||||||
|
throw std::runtime_error("CWallet::GetChange(): value out of range");
|
||||||
|
}
|
||||||
|
return nChange;
|
||||||
|
}
|
||||||
|
|
||||||
int64_t CWalletTx::GetTxTime() const
|
int64_t CWalletTx::GetTxTime() const
|
||||||
{
|
{
|
||||||
int64_t n = nTimeSmart;
|
int64_t n = nTimeSmart;
|
||||||
|
|
|
@ -7,12 +7,14 @@
|
||||||
#define BITCOIN_WALLET_H
|
#define BITCOIN_WALLET_H
|
||||||
|
|
||||||
#include "amount.h"
|
#include "amount.h"
|
||||||
#include "primitives/block.h"
|
|
||||||
#include "primitives/transaction.h"
|
|
||||||
#include "key.h"
|
#include "key.h"
|
||||||
#include "keystore.h"
|
#include "keystore.h"
|
||||||
#include "main.h"
|
#include "primitives/block.h"
|
||||||
|
#include "primitives/transaction.h"
|
||||||
|
#include "tinyformat.h"
|
||||||
#include "ui_interface.h"
|
#include "ui_interface.h"
|
||||||
|
#include "utilstrencodings.h"
|
||||||
|
#include "validationinterface.h"
|
||||||
#include "wallet/crypter.h"
|
#include "wallet/crypter.h"
|
||||||
#include "wallet/wallet_ismine.h"
|
#include "wallet/wallet_ismine.h"
|
||||||
#include "wallet/walletdb.h"
|
#include "wallet/walletdb.h"
|
||||||
|
@ -48,10 +50,12 @@ static const CAmount nHighTransactionMaxFeeWarning = 100 * nHighTransactionFeeWa
|
||||||
static const unsigned int MAX_FREE_TRANSACTION_CREATE_SIZE = 1000;
|
static const unsigned int MAX_FREE_TRANSACTION_CREATE_SIZE = 1000;
|
||||||
|
|
||||||
class CAccountingEntry;
|
class CAccountingEntry;
|
||||||
|
class CBlockIndex;
|
||||||
class CCoinControl;
|
class CCoinControl;
|
||||||
class COutput;
|
class COutput;
|
||||||
class CReserveKey;
|
class CReserveKey;
|
||||||
class CScript;
|
class CScript;
|
||||||
|
class CTxMemPool;
|
||||||
class CWalletTx;
|
class CWalletTx;
|
||||||
|
|
||||||
/** (client) version numbers for particular wallet features */
|
/** (client) version numbers for particular wallet features */
|
||||||
|
@ -640,68 +644,16 @@ public:
|
||||||
|
|
||||||
isminetype IsMine(const CTxIn& txin) const;
|
isminetype IsMine(const CTxIn& txin) const;
|
||||||
CAmount GetDebit(const CTxIn& txin, const isminefilter& filter) const;
|
CAmount GetDebit(const CTxIn& txin, const isminefilter& filter) const;
|
||||||
isminetype IsMine(const CTxOut& txout) const
|
isminetype IsMine(const CTxOut& txout) const;
|
||||||
{
|
CAmount GetCredit(const CTxOut& txout, const isminefilter& filter) const;
|
||||||
return ::IsMine(*this, txout.scriptPubKey);
|
|
||||||
}
|
|
||||||
CAmount GetCredit(const CTxOut& txout, const isminefilter& filter) const
|
|
||||||
{
|
|
||||||
if (!MoneyRange(txout.nValue))
|
|
||||||
throw std::runtime_error("CWallet::GetCredit(): value out of range");
|
|
||||||
return ((IsMine(txout) & filter) ? txout.nValue : 0);
|
|
||||||
}
|
|
||||||
bool IsChange(const CTxOut& txout) const;
|
bool IsChange(const CTxOut& txout) const;
|
||||||
CAmount GetChange(const CTxOut& txout) const
|
CAmount GetChange(const CTxOut& txout) const;
|
||||||
{
|
bool IsMine(const CTransaction& tx) const;
|
||||||
if (!MoneyRange(txout.nValue))
|
|
||||||
throw std::runtime_error("CWallet::GetChange(): value out of range");
|
|
||||||
return (IsChange(txout) ? txout.nValue : 0);
|
|
||||||
}
|
|
||||||
bool IsMine(const CTransaction& tx) const
|
|
||||||
{
|
|
||||||
BOOST_FOREACH(const CTxOut& txout, tx.vout)
|
|
||||||
if (IsMine(txout))
|
|
||||||
return true;
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
/** should probably be renamed to IsRelevantToMe */
|
/** should probably be renamed to IsRelevantToMe */
|
||||||
bool IsFromMe(const CTransaction& tx) const
|
bool IsFromMe(const CTransaction& tx) const;
|
||||||
{
|
CAmount GetDebit(const CTransaction& tx, const isminefilter& filter) const;
|
||||||
return (GetDebit(tx, ISMINE_ALL) > 0);
|
CAmount GetCredit(const CTransaction& tx, const isminefilter& filter) const;
|
||||||
}
|
CAmount GetChange(const CTransaction& tx) const;
|
||||||
CAmount GetDebit(const CTransaction& tx, const isminefilter& filter) const
|
|
||||||
{
|
|
||||||
CAmount nDebit = 0;
|
|
||||||
BOOST_FOREACH(const CTxIn& txin, tx.vin)
|
|
||||||
{
|
|
||||||
nDebit += GetDebit(txin, filter);
|
|
||||||
if (!MoneyRange(nDebit))
|
|
||||||
throw std::runtime_error("CWallet::GetDebit(): value out of range");
|
|
||||||
}
|
|
||||||
return nDebit;
|
|
||||||
}
|
|
||||||
CAmount GetCredit(const CTransaction& tx, const isminefilter& filter) const
|
|
||||||
{
|
|
||||||
CAmount nCredit = 0;
|
|
||||||
BOOST_FOREACH(const CTxOut& txout, tx.vout)
|
|
||||||
{
|
|
||||||
nCredit += GetCredit(txout, filter);
|
|
||||||
if (!MoneyRange(nCredit))
|
|
||||||
throw std::runtime_error("CWallet::GetCredit(): value out of range");
|
|
||||||
}
|
|
||||||
return nCredit;
|
|
||||||
}
|
|
||||||
CAmount GetChange(const CTransaction& tx) const
|
|
||||||
{
|
|
||||||
CAmount nChange = 0;
|
|
||||||
BOOST_FOREACH(const CTxOut& txout, tx.vout)
|
|
||||||
{
|
|
||||||
nChange += GetChange(txout);
|
|
||||||
if (!MoneyRange(nChange))
|
|
||||||
throw std::runtime_error("CWallet::GetChange(): value out of range");
|
|
||||||
}
|
|
||||||
return nChange;
|
|
||||||
}
|
|
||||||
void SetBestChain(const CBlockLocator& loc);
|
void SetBestChain(const CBlockLocator& loc);
|
||||||
|
|
||||||
DBErrors LoadWallet(bool& fFirstRunRet);
|
DBErrors LoadWallet(bool& fFirstRunRet);
|
||||||
|
|
|
@ -6,6 +6,7 @@
|
||||||
#include "wallet/walletdb.h"
|
#include "wallet/walletdb.h"
|
||||||
|
|
||||||
#include "base58.h"
|
#include "base58.h"
|
||||||
|
#include "main.h"
|
||||||
#include "protocol.h"
|
#include "protocol.h"
|
||||||
#include "serialize.h"
|
#include "serialize.h"
|
||||||
#include "sync.h"
|
#include "sync.h"
|
||||||
|
|
Loading…
Add table
Reference in a new issue