Split CWallet::AddToWallet into AddToWallet and LoadToWallet.
This removes the fFromLoadWallet flag in AddToWallet. These were already effectively two methods.
This commit is contained in:
parent
bbcb8fd884
commit
00f09c920c
5 changed files with 127 additions and 124 deletions
|
@ -310,7 +310,7 @@ UniValue importprunedfunds(const UniValue& params, bool fHelp)
|
||||||
|
|
||||||
if (pwalletMain->IsMine(tx)) {
|
if (pwalletMain->IsMine(tx)) {
|
||||||
CWalletDB walletdb(pwalletMain->strWalletFile, "r+", false);
|
CWalletDB walletdb(pwalletMain->strWalletFile, "r+", false);
|
||||||
pwalletMain->AddToWallet(wtx, false, &walletdb);
|
pwalletMain->AddToWallet(wtx, &walletdb);
|
||||||
return NullUniValue;
|
return NullUniValue;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -48,7 +48,7 @@ BOOST_AUTO_TEST_CASE(acc_orderupgrade)
|
||||||
pwalletMain->AddAccountingEntry(ae, walletdb);
|
pwalletMain->AddAccountingEntry(ae, walletdb);
|
||||||
|
|
||||||
wtx.mapValue["comment"] = "z";
|
wtx.mapValue["comment"] = "z";
|
||||||
pwalletMain->AddToWallet(wtx, false, &walletdb);
|
pwalletMain->AddToWallet(wtx, &walletdb);
|
||||||
vpwtx.push_back(&pwalletMain->mapWallet[wtx.GetHash()]);
|
vpwtx.push_back(&pwalletMain->mapWallet[wtx.GetHash()]);
|
||||||
vpwtx[0]->nTimeReceived = (unsigned int)1333333335;
|
vpwtx[0]->nTimeReceived = (unsigned int)1333333335;
|
||||||
vpwtx[0]->nOrderPos = -1;
|
vpwtx[0]->nOrderPos = -1;
|
||||||
|
@ -90,7 +90,7 @@ BOOST_AUTO_TEST_CASE(acc_orderupgrade)
|
||||||
--tx.nLockTime; // Just to change the hash :)
|
--tx.nLockTime; // Just to change the hash :)
|
||||||
*static_cast<CTransaction*>(&wtx) = CTransaction(tx);
|
*static_cast<CTransaction*>(&wtx) = CTransaction(tx);
|
||||||
}
|
}
|
||||||
pwalletMain->AddToWallet(wtx, false, &walletdb);
|
pwalletMain->AddToWallet(wtx, &walletdb);
|
||||||
vpwtx.push_back(&pwalletMain->mapWallet[wtx.GetHash()]);
|
vpwtx.push_back(&pwalletMain->mapWallet[wtx.GetHash()]);
|
||||||
vpwtx[1]->nTimeReceived = (unsigned int)1333333336;
|
vpwtx[1]->nTimeReceived = (unsigned int)1333333336;
|
||||||
|
|
||||||
|
@ -100,7 +100,7 @@ BOOST_AUTO_TEST_CASE(acc_orderupgrade)
|
||||||
--tx.nLockTime; // Just to change the hash :)
|
--tx.nLockTime; // Just to change the hash :)
|
||||||
*static_cast<CTransaction*>(&wtx) = CTransaction(tx);
|
*static_cast<CTransaction*>(&wtx) = CTransaction(tx);
|
||||||
}
|
}
|
||||||
pwalletMain->AddToWallet(wtx, false, &walletdb);
|
pwalletMain->AddToWallet(wtx, &walletdb);
|
||||||
vpwtx.push_back(&pwalletMain->mapWallet[wtx.GetHash()]);
|
vpwtx.push_back(&pwalletMain->mapWallet[wtx.GetHash()]);
|
||||||
vpwtx[2]->nTimeReceived = (unsigned int)1333333329;
|
vpwtx[2]->nTimeReceived = (unsigned int)1333333329;
|
||||||
vpwtx[2]->nOrderPos = -1;
|
vpwtx[2]->nOrderPos = -1;
|
||||||
|
|
|
@ -741,28 +741,10 @@ void CWallet::MarkDirty()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
bool CWallet::AddToWallet(const CWalletTx& wtxIn, bool fFromLoadWallet, CWalletDB* pwalletdb)
|
bool CWallet::AddToWallet(const CWalletTx& wtxIn, CWalletDB* pwalletdb)
|
||||||
{
|
{
|
||||||
uint256 hash = wtxIn.GetHash();
|
uint256 hash = wtxIn.GetHash();
|
||||||
|
|
||||||
if (fFromLoadWallet)
|
|
||||||
{
|
|
||||||
mapWallet[hash] = wtxIn;
|
|
||||||
CWalletTx& wtx = mapWallet[hash];
|
|
||||||
wtx.BindWallet(this);
|
|
||||||
wtxOrdered.insert(make_pair(wtx.nOrderPos, TxPair(&wtx, (CAccountingEntry*)0)));
|
|
||||||
AddToSpends(hash);
|
|
||||||
BOOST_FOREACH(const CTxIn& txin, wtx.vin) {
|
|
||||||
if (mapWallet.count(txin.prevout.hash)) {
|
|
||||||
CWalletTx& prevtx = mapWallet[txin.prevout.hash];
|
|
||||||
if (prevtx.nIndex == -1 && !prevtx.hashUnset()) {
|
|
||||||
MarkConflicted(prevtx.hashBlock, wtx.GetHash());
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
LOCK(cs_wallet);
|
LOCK(cs_wallet);
|
||||||
// Inserts only if not already there, returns tx inserted or tx found
|
// Inserts only if not already there, returns tx inserted or tx found
|
||||||
pair<map<uint256, CWalletTx>::iterator, bool> ret = mapWallet.insert(make_pair(hash, wtxIn));
|
pair<map<uint256, CWalletTx>::iterator, bool> ret = mapWallet.insert(make_pair(hash, wtxIn));
|
||||||
|
@ -872,7 +854,27 @@ bool CWallet::AddToWallet(const CWalletTx& wtxIn, bool fFromLoadWallet, CWalletD
|
||||||
boost::thread t(runCommand, strCmd); // thread runs free
|
boost::thread t(runCommand, strCmd); // thread runs free
|
||||||
}
|
}
|
||||||
|
|
||||||
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
bool CWallet::LoadToWallet(const CWalletTx& wtxIn)
|
||||||
|
{
|
||||||
|
uint256 hash = wtxIn.GetHash();
|
||||||
|
|
||||||
|
mapWallet[hash] = wtxIn;
|
||||||
|
CWalletTx& wtx = mapWallet[hash];
|
||||||
|
wtx.BindWallet(this);
|
||||||
|
wtxOrdered.insert(make_pair(wtx.nOrderPos, TxPair(&wtx, (CAccountingEntry*)0)));
|
||||||
|
AddToSpends(hash);
|
||||||
|
BOOST_FOREACH(const CTxIn& txin, wtx.vin) {
|
||||||
|
if (mapWallet.count(txin.prevout.hash)) {
|
||||||
|
CWalletTx& prevtx = mapWallet[txin.prevout.hash];
|
||||||
|
if (prevtx.nIndex == -1 && !prevtx.hashUnset()) {
|
||||||
|
MarkConflicted(prevtx.hashBlock, wtx.GetHash());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -913,7 +915,7 @@ bool CWallet::AddToWalletIfInvolvingMe(const CTransaction& tx, const CBlock* pbl
|
||||||
// this is safe, as in case of a crash, we rescan the necessary blocks on startup through our SetBestChain-mechanism
|
// this is safe, as in case of a crash, we rescan the necessary blocks on startup through our SetBestChain-mechanism
|
||||||
CWalletDB walletdb(strWalletFile, "r+", false);
|
CWalletDB walletdb(strWalletFile, "r+", false);
|
||||||
|
|
||||||
return AddToWallet(wtx, false, &walletdb);
|
return AddToWallet(wtx, &walletdb);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
|
@ -2456,7 +2458,7 @@ bool CWallet::CommitTransaction(CWalletTx& wtxNew, CReserveKey& reservekey)
|
||||||
|
|
||||||
// Add tx to wallet, because if it has change it's also ours,
|
// Add tx to wallet, because if it has change it's also ours,
|
||||||
// otherwise just for transaction history.
|
// otherwise just for transaction history.
|
||||||
AddToWallet(wtxNew, false, pwalletdb);
|
AddToWallet(wtxNew, pwalletdb);
|
||||||
|
|
||||||
// Notify that old coins are spent
|
// Notify that old coins are spent
|
||||||
set<CWalletTx*> setCoins;
|
set<CWalletTx*> setCoins;
|
||||||
|
|
|
@ -729,7 +729,8 @@ public:
|
||||||
bool GetAccountPubkey(CPubKey &pubKey, std::string strAccount, bool bForceNew = false);
|
bool GetAccountPubkey(CPubKey &pubKey, std::string strAccount, bool bForceNew = false);
|
||||||
|
|
||||||
void MarkDirty();
|
void MarkDirty();
|
||||||
bool AddToWallet(const CWalletTx& wtxIn, bool fFromLoadWallet, CWalletDB* pwalletdb);
|
bool AddToWallet(const CWalletTx& wtxIn, CWalletDB* pwalletdb);
|
||||||
|
bool LoadToWallet(const CWalletTx& wtxIn);
|
||||||
void SyncTransaction(const CTransaction& tx, const CBlockIndex *pindex, const CBlock* pblock);
|
void SyncTransaction(const CTransaction& tx, const CBlockIndex *pindex, const CBlock* pblock);
|
||||||
bool AddToWalletIfInvolvingMe(const CTransaction& tx, const CBlock* pblock, bool fUpdate);
|
bool AddToWalletIfInvolvingMe(const CTransaction& tx, const CBlock* pblock, bool fUpdate);
|
||||||
int ScanForWalletTransactions(CBlockIndex* pindexStart, bool fUpdate = false);
|
int ScanForWalletTransactions(CBlockIndex* pindexStart, bool fUpdate = false);
|
||||||
|
|
|
@ -400,7 +400,7 @@ ReadKeyValue(CWallet* pwallet, CDataStream& ssKey, CDataStream& ssValue,
|
||||||
if (wtx.nOrderPos == -1)
|
if (wtx.nOrderPos == -1)
|
||||||
wss.fAnyUnordered = true;
|
wss.fAnyUnordered = true;
|
||||||
|
|
||||||
pwallet->AddToWallet(wtx, true, NULL);
|
pwallet->LoadToWallet(wtx);
|
||||||
}
|
}
|
||||||
else if (strType == "acentry")
|
else if (strType == "acentry")
|
||||||
{
|
{
|
||||||
|
|
Loading…
Reference in a new issue