1 // Copyright (c) 2009-2010 Satoshi Nakamoto
2 // Copyright (c) 2009-2012 The Bitcoin developers
3 // Distributed under the MIT/X11 software license, see the accompanying
4 // file COPYING or http://www.opensource.org/licenses/mit-license.php.
10 #include "ui_interface.h"
11 #include <boost/filesystem.hpp>
12 #include <boost/filesystem/fstream.hpp>
19 using namespace boost;
22 unsigned int nWalletDBUpdated;
32 void CDBEnv::EnvShutdown()
38 int ret = dbenv.close(0);
40 printf("EnvShutdown exception: %s (%d)\n", DbEnv::strerror(ret), ret);
42 DbEnv(0).remove(strPath.c_str(), 0);
45 CDBEnv::CDBEnv() : dbenv(DB_CXX_NO_EXCEPTIONS)
61 bool CDBEnv::Open(boost::filesystem::path pathEnv_)
70 filesystem::path pathDataDir = pathEnv;
71 strPath = pathDataDir.string();
72 filesystem::path pathLogDir = pathDataDir / "database";
73 filesystem::create_directory(pathLogDir);
74 filesystem::path pathErrorFile = pathDataDir / "db.log";
75 printf("dbenv.open LogDir=%s ErrorFile=%s\n", pathLogDir.string().c_str(), pathErrorFile.string().c_str());
77 unsigned int nEnvFlags = 0;
78 if (GetBoolArg("-privdb", true))
79 nEnvFlags |= DB_PRIVATE;
81 int nDbCache = GetArg("-dbcache", 25);
82 dbenv.set_lg_dir(pathLogDir.string().c_str());
83 dbenv.set_cachesize(nDbCache / 1024, (nDbCache % 1024)*1048576, 1);
84 dbenv.set_lg_bsize(1048576);
85 dbenv.set_lg_max(10485760);
87 // Bugfix: Bump lk_max_locks default to 537000, to safely handle reorgs with up to 5 blocks reversed
88 // dbenv.set_lk_max_locks(10000);
89 dbenv.set_lk_max_locks(537000);
91 dbenv.set_lk_max_objects(10000);
92 dbenv.set_errfile(fopen(pathErrorFile.string().c_str(), "a")); /// debug
93 dbenv.set_flags(DB_AUTO_COMMIT, 1);
94 dbenv.set_flags(DB_TXN_WRITE_NOSYNC, 1);
95 #ifdef DB_LOG_AUTO_REMOVE
96 dbenv.log_set_config(DB_LOG_AUTO_REMOVE, 1);
98 int ret = dbenv.open(strPath.c_str(),
109 return error("CDB() : error %s (%d) opening database environment", DbEnv::strerror(ret), ret);
114 // Check that the number of locks is sufficient (to prevent chain fork possibility, read http://bitcoin.org/may15 for more info)
116 if (!dbenv.get_lk_max_locks(&nMaxLocks))
118 int nBlocks, nDeepReorg;
119 std::string strMessage;
121 nBlocks = nMaxLocks / 48768;
122 nDeepReorg = (nBlocks - 1) / 2;
124 printf("Final lk_max_locks is %lu, sufficient for (worst case) %d block%s in a single transaction (up to a %d-deep reorganization)\n", (unsigned long)nMaxLocks, nBlocks, (nBlocks == 1) ? "" : "s", nDeepReorg);
128 strMessage = strprintf(_("Warning: DB_CONFIG has set_lk_max_locks %lu, which may be too low for a single block. If this limit is reached, NovaCoin may stop working."), (unsigned long)nMaxLocks);
130 strMessage = strprintf(_("Warning: DB_CONFIG has set_lk_max_locks %lu, which may be too low for a common blockchain reorganization. If this limit is reached, NovaCoin may stop working."), (unsigned long)nMaxLocks);
132 strMiscWarning = strMessage;
133 printf("*** %s\n", strMessage.c_str());
140 void CDBEnv::MakeMock()
143 throw runtime_error("CDBEnv::MakeMock(): already initialized");
146 throw runtime_error("CDBEnv::MakeMock(): during shutdown");
148 printf("CDBEnv::MakeMock()\n");
150 dbenv.set_cachesize(1, 0, 1);
151 dbenv.set_lg_bsize(10485760*4);
152 dbenv.set_lg_max(10485760);
153 dbenv.set_lk_max_locks(10000);
154 dbenv.set_lk_max_objects(10000);
155 dbenv.set_flags(DB_AUTO_COMMIT, 1);
156 #ifdef DB_LOG_IN_MEMORY
157 dbenv.log_set_config(DB_LOG_IN_MEMORY, 1);
159 int ret = dbenv.open(NULL,
169 throw runtime_error(strprintf("CDBEnv::MakeMock(): error %d opening database environment", ret));
175 CDBEnv::VerifyResult CDBEnv::Verify(std::string strFile, bool (*recoverFunc)(CDBEnv& dbenv, std::string strFile))
178 assert(mapFileUseCount.count(strFile) == 0);
181 int result = db.verify(strFile.c_str(), NULL, NULL, 0);
184 else if (recoverFunc == NULL)
188 bool fRecovered = (*recoverFunc)(*this, strFile);
189 return (fRecovered ? RECOVER_OK : RECOVER_FAIL);
192 bool CDBEnv::Salvage(std::string strFile, bool fAggressive,
193 std::vector<CDBEnv::KeyValPair >& vResult)
196 assert(mapFileUseCount.count(strFile) == 0);
198 u_int32_t flags = DB_SALVAGE;
199 if (fAggressive) flags |= DB_AGGRESSIVE;
201 stringstream strDump;
204 int result = db.verify(strFile.c_str(), NULL, &strDump, flags);
207 printf("ERROR: db salvage failed\n");
211 // Format of bdb dump is ascii lines:
220 while (!strDump.eof() && strLine != "HEADER=END")
221 getline(strDump, strLine); // Skip past header
223 std::string keyHex, valueHex;
224 while (!strDump.eof() && keyHex != "DATA=END")
226 getline(strDump, keyHex);
227 if (keyHex != "DATA_END")
229 getline(strDump, valueHex);
230 vResult.push_back(make_pair(ParseHex(keyHex),ParseHex(valueHex)));
234 return (result == 0);
238 void CDBEnv::CheckpointLSN(std::string strFile)
240 dbenv.txn_checkpoint(0, 0, 0);
243 dbenv.lsn_reset(strFile.c_str(), 0);
247 CDB::CDB(const char *pszFile, const char* pszMode) :
248 pdb(NULL), activeTxn(NULL)
254 fReadOnly = (!strchr(pszMode, '+') && !strchr(pszMode, 'w'));
255 bool fCreate = strchr(pszMode, 'c');
256 unsigned int nFlags = DB_THREAD;
262 if (!bitdb.Open(GetDataDir()))
263 throw runtime_error("env open failed");
266 ++bitdb.mapFileUseCount[strFile];
267 pdb = bitdb.mapDb[strFile];
270 pdb = new Db(&bitdb.dbenv, 0);
272 bool fMockDb = bitdb.IsMock();
275 DbMpoolFile*mpf = pdb->get_mpf();
276 ret = mpf->set_flags(DB_MPOOL_NOFILE, 1);
278 throw runtime_error(strprintf("CDB() : failed to configure for no temp file backing for database %s", pszFile));
281 ret = pdb->open(NULL, // Txn pointer
282 fMockDb ? NULL : pszFile, // Filename
283 "main", // Logical db name
284 DB_BTREE, // Database type
292 --bitdb.mapFileUseCount[strFile];
294 throw runtime_error(strprintf("CDB() : can't open database file %s, error %d", pszFile, ret));
297 if (fCreate && !Exists(string("version")))
299 bool fTmp = fReadOnly;
301 WriteVersion(CLIENT_VERSION);
305 bitdb.mapDb[strFile] = pdb;
310 static bool IsChainFile(std::string strFile)
312 if (strFile == "blkindex.dat")
327 // Flush database activity from memory pool to disk log
328 unsigned int nMinutes = 0;
331 if (IsChainFile(strFile))
333 if (IsChainFile(strFile) && IsInitialBlockDownload())
336 bitdb.dbenv.txn_checkpoint(nMinutes ? GetArg("-dblogsize", 100)*1024 : 0, nMinutes, 0);
340 --bitdb.mapFileUseCount[strFile];
344 void CDBEnv::CloseDb(const string& strFile)
348 if (mapDb[strFile] != NULL)
350 // Close the database handle
351 Db* pdb = mapDb[strFile];
354 mapDb[strFile] = NULL;
359 bool CDBEnv::RemoveDb(const string& strFile)
361 this->CloseDb(strFile);
364 int rc = dbenv.dbremove(NULL, strFile.c_str(), NULL, DB_AUTO_COMMIT);
368 bool CDB::Rewrite(const string& strFile, const char* pszSkip)
374 if (!bitdb.mapFileUseCount.count(strFile) || bitdb.mapFileUseCount[strFile] == 0)
376 // Flush log data to the dat file
377 bitdb.CloseDb(strFile);
378 bitdb.CheckpointLSN(strFile);
379 bitdb.mapFileUseCount.erase(strFile);
381 bool fSuccess = true;
382 printf("Rewriting %s...\n", strFile.c_str());
383 string strFileRes = strFile + ".rewrite";
384 { // surround usage of db with extra {}
385 CDB db(strFile.c_str(), "r");
386 Db* pdbCopy = new Db(&bitdb.dbenv, 0);
388 int ret = pdbCopy->open(NULL, // Txn pointer
389 strFileRes.c_str(), // Filename
390 "main", // Logical db name
391 DB_BTREE, // Database type
396 printf("Cannot create database file %s\n", strFileRes.c_str());
400 Dbc* pcursor = db.GetCursor();
404 CDataStream ssKey(SER_DISK, CLIENT_VERSION);
405 CDataStream ssValue(SER_DISK, CLIENT_VERSION);
406 int ret = db.ReadAtCursor(pcursor, ssKey, ssValue, DB_NEXT);
407 if (ret == DB_NOTFOUND)
419 strncmp(&ssKey[0], pszSkip, std::min(ssKey.size(), strlen(pszSkip))) == 0)
421 if (strncmp(&ssKey[0], "\x07version", 8) == 0)
425 ssValue << CLIENT_VERSION;
427 Dbt datKey(&ssKey[0], ssKey.size());
428 Dbt datValue(&ssValue[0], ssValue.size());
429 int ret2 = pdbCopy->put(NULL, &datKey, &datValue, DB_NOOVERWRITE);
436 bitdb.CloseDb(strFile);
437 if (pdbCopy->close(0))
444 Db dbA(&bitdb.dbenv, 0);
445 if (dbA.remove(strFile.c_str(), NULL, 0))
447 Db dbB(&bitdb.dbenv, 0);
448 if (dbB.rename(strFileRes.c_str(), NULL, strFile.c_str(), 0))
452 printf("Rewriting of %s FAILED!\n", strFileRes.c_str());
462 void CDBEnv::Flush(bool fShutdown)
464 int64 nStart = GetTimeMillis();
465 // Flush log data to the actual data file
466 // on all files that are not in use
467 printf("Flush(%s)%s\n", fShutdown ? "true" : "false", fDbEnvInit ? "" : " db not started");
472 map<string, int>::iterator mi = mapFileUseCount.begin();
473 while (mi != mapFileUseCount.end())
475 string strFile = (*mi).first;
476 int nRefCount = (*mi).second;
477 printf("%s refcount=%d\n", strFile.c_str(), nRefCount);
480 // Move log data to the dat file
482 printf("%s checkpoint\n", strFile.c_str());
483 dbenv.txn_checkpoint(0, 0, 0);
484 if (!IsChainFile(strFile) || fDetachDB) {
485 printf("%s detach\n", strFile.c_str());
487 dbenv.lsn_reset(strFile.c_str(), 0);
489 printf("%s closed\n", strFile.c_str());
490 mapFileUseCount.erase(mi++);
495 printf("DBFlush(%s)%s ended %15"PRI64d"ms\n", fShutdown ? "true" : "false", fDbEnvInit ? "" : " db not started", GetTimeMillis() - nStart);
499 if (mapFileUseCount.empty())
501 dbenv.log_archive(&listp, DB_ARCH_REMOVE);
516 pathAddr = GetDataDir() / "peers.dat";
519 bool CAddrDB::Write(const CAddrMan& addr)
521 // Generate random temporary filename
522 unsigned short randv = 0;
523 RAND_bytes((unsigned char *)&randv, sizeof(randv));
524 std::string tmpfn = strprintf("peers.dat.%04x", randv);
526 // serialize addresses, checksum data up to that point, then append csum
527 CDataStream ssPeers(SER_DISK, CLIENT_VERSION);
528 ssPeers << FLATDATA(pchMessageStart);
530 uint256 hash = Hash(ssPeers.begin(), ssPeers.end());
533 // open temp output file, and associate with CAutoFile
534 boost::filesystem::path pathTmp = GetDataDir() / tmpfn;
535 FILE *file = fopen(pathTmp.string().c_str(), "wb");
536 CAutoFile fileout = CAutoFile(file, SER_DISK, CLIENT_VERSION);
538 return error("CAddrman::Write() : open failed");
540 // Write and commit header, data
544 catch (std::exception &e) {
545 return error("CAddrman::Write() : I/O error");
550 // replace existing peers.dat, if any, with new peers.dat.XXXX
551 if (!RenameOver(pathTmp, pathAddr))
552 return error("CAddrman::Write() : Rename-into-place failed");
557 bool CAddrDB::Read(CAddrMan& addr)
559 // open input file, and associate with CAutoFile
560 FILE *file = fopen(pathAddr.string().c_str(), "rb");
561 CAutoFile filein = CAutoFile(file, SER_DISK, CLIENT_VERSION);
563 return error("CAddrman::Read() : open failed");
565 // use file size to size memory buffer
566 int fileSize = GetFilesize(filein);
567 int dataSize = fileSize - sizeof(uint256);
568 //Don't try to resize to a negative number if file is small
569 if ( dataSize < 0 ) dataSize = 0;
570 vector<unsigned char> vchData;
571 vchData.resize(dataSize);
574 // read data and checksum from file
576 filein.read((char *)&vchData[0], dataSize);
579 catch (std::exception &e) {
580 return error("CAddrman::Read() 2 : I/O error or stream data corrupted");
584 CDataStream ssPeers(vchData, SER_DISK, CLIENT_VERSION);
586 // verify stored checksum matches input data
587 uint256 hashTmp = Hash(ssPeers.begin(), ssPeers.end());
588 if (hashIn != hashTmp)
589 return error("CAddrman::Read() : checksum mismatch; data corrupted");
591 unsigned char pchMsgTmp[4];
593 // de-serialize file header (pchMessageStart magic number) and
594 ssPeers >> FLATDATA(pchMsgTmp);
596 // verify the network matches ours
597 if (memcmp(pchMsgTmp, pchMessageStart, sizeof(pchMsgTmp)))
598 return error("CAddrman::Read() : invalid network magic number");
600 // de-serialize address data into one CAddrMan object
603 catch (std::exception &e) {
604 return error("CAddrman::Read() : I/O error or stream data corrupted");