This repository has been archived by the owner on Feb 1, 2021. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 34
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #63 from project-ecc/dev
Version 0.2.5.7 Contains sync fixes, startup time fixes, ANS service, and performance updates
- Loading branch information
Showing
167 changed files
with
11,131 additions
and
6,090 deletions.
There are no files selected for viewing
Empty file.
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1 @@ | ||
| ./share/genbuild.sh build ./src/build/ |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,208 @@ | ||
| // Copyright (c) 2009-2010 Satoshi Nakamoto | ||
| // Copyright (c) 2009-2016 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 "addrdb.h" | ||
|
|
||
| #include "addrman.h" | ||
| #include "clientversion.h" | ||
| #include "crypto/hash.h" | ||
| #include "init.h" | ||
| #include "random.h" | ||
| #include "streams.h" | ||
| #include "tinyformat.h" | ||
| #include "util/util.h" | ||
|
|
||
| #include <boost/filesystem.hpp> | ||
|
|
||
| CBanDB::CBanDB() { | ||
| pathBanlist = GetDataDir() / "banlist.dat"; | ||
| } | ||
|
|
||
| bool CBanDB::Write(const banmap_t &banSet) { | ||
| // Generate random temporary filename | ||
| unsigned short randv = 0; | ||
| GetRandBytes((uint8_t *)&randv, sizeof(randv)); | ||
| std::string tmpfn = strprintf("banlist.dat.%04x", randv); | ||
|
|
||
| // serialize banlist, checksum data up to that point, then append csum | ||
| CDataStream ssBanlist(SER_DISK, CLIENT_VERSION); | ||
| ssBanlist << FLATDATA(pnetMan->getActivePaymentNetwork()->MessageStart()); | ||
| ssBanlist << banSet; | ||
| uint256 hash = Hash(ssBanlist.begin(), ssBanlist.end()); | ||
| ssBanlist << hash; | ||
|
|
||
| // open temp output file, and associate with CAutoFile | ||
| fs::path pathTmp = GetDataDir() / tmpfn; | ||
| FILE *file = fopen(pathTmp.string().c_str(), "wb"); | ||
| CAutoFile fileout(file, SER_DISK, CLIENT_VERSION); | ||
| if (fileout.IsNull()) | ||
| return error("%s: Failed to open file %s", __func__, pathTmp.string()); | ||
|
|
||
| // Write and commit header, data | ||
| try { | ||
| fileout << ssBanlist; | ||
| } catch (const std::exception &e) { | ||
| return error("%s: Serialize or I/O error - %s", __func__, e.what()); | ||
| } | ||
| FileCommit(fileout.Get()); | ||
| fileout.fclose(); | ||
|
|
||
| // replace existing banlist.dat, if any, with new banlist.dat.XXXX | ||
| if (!RenameOver(pathTmp, pathBanlist)) | ||
| return error("%s: Rename-into-place failed", __func__); | ||
|
|
||
| return true; | ||
| } | ||
|
|
||
| bool CBanDB::Read(banmap_t &banSet) { | ||
| // open input file, and associate with CAutoFile | ||
| FILE *file = fopen(pathBanlist.string().c_str(), "rb"); | ||
| CAutoFile filein(file, SER_DISK, CLIENT_VERSION); | ||
| if (filein.IsNull()) | ||
| return error("%s: Failed to open file %s", __func__, | ||
| pathBanlist.string()); | ||
|
|
||
| // use file size to size memory buffer | ||
| uint64_t fileSize = fs::file_size(pathBanlist); | ||
| uint64_t dataSize = 0; | ||
| // Don't try to resize to a negative number if file is small | ||
| if (fileSize >= sizeof(uint256)) dataSize = fileSize - sizeof(uint256); | ||
| std::vector<uint8_t> vchData; | ||
| vchData.resize(dataSize); | ||
| uint256 hashIn; | ||
|
|
||
| // read data and checksum from file | ||
| try { | ||
| filein.read((char *)&vchData[0], dataSize); | ||
| filein >> hashIn; | ||
| } catch (const std::exception &e) { | ||
| return error("%s: Deserialize or I/O error - %s", __func__, e.what()); | ||
| } | ||
| filein.fclose(); | ||
|
|
||
| CDataStream ssBanlist(vchData, SER_DISK, CLIENT_VERSION); | ||
|
|
||
| // verify stored checksum matches input data | ||
| uint256 hashTmp = Hash(ssBanlist.begin(), ssBanlist.end()); | ||
| if (hashIn != hashTmp) | ||
| return error("%s: Checksum mismatch, data corrupted", __func__); | ||
|
|
||
| uint8_t pchMsgTmp[4]; | ||
| try { | ||
| // de-serialize file header (network specific magic number) and .. | ||
| ssBanlist >> FLATDATA(pchMsgTmp); | ||
|
|
||
| // ... verify the network matches ours | ||
| if (memcmp(pchMsgTmp, std::begin(pnetMan->getActivePaymentNetwork()->MessageStart()), | ||
| sizeof(pchMsgTmp))) { | ||
| return error("%s: Invalid network magic number", __func__); | ||
| } | ||
|
|
||
| // de-serialize ban data | ||
| ssBanlist >> banSet; | ||
| } catch (const std::exception &e) { | ||
| return error("%s: Deserialize or I/O error - %s", __func__, e.what()); | ||
| } | ||
|
|
||
| return true; | ||
| } | ||
|
|
||
| CAddrDB::CAddrDB() { | ||
| pathAddr = GetDataDir() / "peers.dat"; | ||
| } | ||
|
|
||
| bool CAddrDB::Write(const CAddrMan &addr) { | ||
| // Generate random temporary filename | ||
| unsigned short randv = 0; | ||
| GetRandBytes((uint8_t *)&randv, sizeof(randv)); | ||
| std::string tmpfn = strprintf("peers.dat.%04x", randv); | ||
|
|
||
| // serialize addresses, checksum data up to that point, then append csum | ||
| CDataStream ssPeers(SER_DISK, CLIENT_VERSION); | ||
| ssPeers << FLATDATA(pnetMan->getActivePaymentNetwork()->MessageStart()); | ||
| ssPeers << addr; | ||
| uint256 hash = Hash(ssPeers.begin(), ssPeers.end()); | ||
| ssPeers << hash; | ||
|
|
||
| // open temp output file, and associate with CAutoFile | ||
| fs::path pathTmp = GetDataDir() / tmpfn; | ||
| FILE *file = fopen(pathTmp.string().c_str(), "wb"); | ||
| CAutoFile fileout(file, SER_DISK, CLIENT_VERSION); | ||
| if (fileout.IsNull()) | ||
| return error("%s: Failed to open file %s", __func__, pathTmp.string()); | ||
|
|
||
| // Write and commit header, data | ||
| try { | ||
| fileout << ssPeers; | ||
| } catch (const std::exception &e) { | ||
| return error("%s: Serialize or I/O error - %s", __func__, e.what()); | ||
| } | ||
| FileCommit(fileout.Get()); | ||
| fileout.fclose(); | ||
|
|
||
| // replace existing peers.dat, if any, with new peers.dat.XXXX | ||
| if (!RenameOver(pathTmp, pathAddr)) | ||
| return error("%s: Rename-into-place failed", __func__); | ||
|
|
||
| return true; | ||
| } | ||
|
|
||
| bool CAddrDB::Read(CAddrMan &addr) { | ||
| // open input file, and associate with CAutoFile | ||
| FILE *file = fopen(pathAddr.string().c_str(), "rb"); | ||
| CAutoFile filein(file, SER_DISK, CLIENT_VERSION); | ||
| if (filein.IsNull()) | ||
| return error("%s: Failed to open file %s", __func__, pathAddr.string()); | ||
|
|
||
| // use file size to size memory buffer | ||
| uint64_t fileSize = fs::file_size(pathAddr); | ||
| uint64_t dataSize = 0; | ||
| // Don't try to resize to a negative number if file is small | ||
| if (fileSize >= sizeof(uint256)) dataSize = fileSize - sizeof(uint256); | ||
| std::vector<uint8_t> vchData; | ||
| vchData.resize(dataSize); | ||
| uint256 hashIn; | ||
|
|
||
| // read data and checksum from file | ||
| try { | ||
| filein.read((char *)&vchData[0], dataSize); | ||
| filein >> hashIn; | ||
| } catch (const std::exception &e) { | ||
| return error("%s: Deserialize or I/O error - %s", __func__, e.what()); | ||
| } | ||
| filein.fclose(); | ||
|
|
||
| CDataStream ssPeers(vchData, SER_DISK, CLIENT_VERSION); | ||
|
|
||
| // verify stored checksum matches input data | ||
| uint256 hashTmp = Hash(ssPeers.begin(), ssPeers.end()); | ||
| if (hashIn != hashTmp) | ||
| return error("%s: Checksum mismatch, data corrupted", __func__); | ||
|
|
||
| return Read(addr, ssPeers); | ||
| } | ||
|
|
||
| bool CAddrDB::Read(CAddrMan &addr, CDataStream &ssPeers) { | ||
| uint8_t pchMsgTmp[4]; | ||
| try { | ||
| // de-serialize file header (network specific magic number) and .. | ||
| ssPeers >> FLATDATA(pchMsgTmp); | ||
|
|
||
| // ... verify the network matches ours | ||
| if (memcmp(pchMsgTmp, std::begin(pnetMan->getActivePaymentNetwork()->MessageStart()), | ||
| sizeof(pchMsgTmp))) { | ||
| return error("%s: Invalid network magic number", __func__); | ||
| } | ||
|
|
||
| // de-serialize address data into one CAddrMan object | ||
| ssPeers >> addr; | ||
| } catch (const std::exception &e) { | ||
| // de-serialization has failed, ensure addrman is left in a clean state | ||
| addr.Clear(); | ||
| return error("%s: Deserialize or I/O error - %s", __func__, e.what()); | ||
| } | ||
|
|
||
| return true; | ||
| } |
Oops, something went wrong.