Cypher_Stack/wownero
2
0
Fork 0
mirror of https://git.wownero.com/wownero/wownero.git synced 2024-12-25 02:58:51 +00:00
Code Issues Packages Projects Releases Wiki Activity
4b7ad2b0a7
wownero/src/blockchain_db/berkeleydb/db_bdb.cpp

1894 lines
55 KiB
C++
Raw Normal View History

Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
// Copyright (c) 2014, The Monero Project
// All rights reserved.
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
//
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
// Redistribution and use in source and binary forms, with or without modification, are
// permitted provided that the following conditions are met:
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
//
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
// 1. Redistributions of source code must retain the above copyright notice, this list of
// conditions and the following disclaimer.
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
//
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
// 2. Redistributions in binary form must reproduce the above copyright notice, this list
// of conditions and the following disclaimer in the documentation and/or other
// materials provided with the distribution.
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
//
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
// 3. Neither the name of the copyright holder nor the names of its contributors may be
// used to endorse or promote products derived from this software without specific
// prior written permission.
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
//
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY
// EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
// MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL
// THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
// INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
// STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF
// THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
#include "db_bdb.h"
#include <boost/filesystem.hpp>
#include <memory> // std::unique_ptr
#include <cstring> // memcpy
#include "cryptonote_core/cryptonote_format_utils.h"
#include "crypto/crypto.h"
#include "profile_tools.h"
using epee::string_tools::pod_to_hex;
namespace
{
template <typename T>
inline void throw0(const T &e)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L0(e.what());
throw e;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
template <typename T>
inline void throw1(const T &e)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L1(e.what());
throw e;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
// cursor needs to be closed when it goes out of scope,
// this helps if the function using it throws
struct bdb_cur
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_cur(DbTxn* txn, Db* dbi)
{
if (dbi->cursor(txn, &m_cur, 0))
throw0(cryptonote::DB_ERROR("Error opening db cursor"));
done = false;
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
~bdb_cur()
{
close();
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
operator Dbc*()
{
return m_cur;
}
operator Dbc**()
{
return &m_cur;
}
Dbc* operator->()
{
return m_cur;
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
void close()
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (!done)
{
m_cur->close();
done = true;
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
}
private:
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbc* m_cur;
bool done;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
};
const char* const BDB_BLOCKS = "blocks";
const char* const BDB_BLOCK_TIMESTAMPS = "block_timestamps";
const char* const BDB_BLOCK_HEIGHTS = "block_heights";
const char* const BDB_BLOCK_HASHES = "block_hashes";
const char* const BDB_BLOCK_SIZES = "block_sizes";
const char* const BDB_BLOCK_DIFFS = "block_diffs";
const char* const BDB_BLOCK_COINS = "block_coins";
const char* const BDB_TXS = "txs";
const char* const BDB_TX_UNLOCKS = "tx_unlocks";
const char* const BDB_TX_HEIGHTS = "tx_heights";
const char* const BDB_TX_OUTPUTS = "tx_outputs";
const char* const BDB_OUTPUT_TXS = "output_txs";
const char* const BDB_OUTPUT_INDICES = "output_indices";
const char* const BDB_OUTPUT_AMOUNTS = "output_amounts";
const char* const BDB_OUTPUT_KEYS = "output_keys";
const char* const BDB_SPENT_KEYS = "spent_keys";
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
const int BUFFER_LENGTH = 4 * 1024 * 1024;
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
template<typename T>
struct Dbt_copy: public Dbt
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy(const T &t): t_copy(t)
{
init();
}
Dbt_copy()
{
init();
}
void init()
{
set_data(&t_copy);
set_size(sizeof(T));
set_ulen(sizeof(T));
set_flags(DB_DBT_USERMEM);
}
operator T()
{
return t_copy;
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
private:
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
T t_copy;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
};
template<>
struct Dbt_copy<cryptonote::blobdata>: public Dbt
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy(const cryptonote::blobdata &bd) : m_data(new char[bd.size()])
{
memcpy(m_data.get(), bd.data(), bd.size());
set_data(m_data.get());
set_size(bd.size());
set_ulen(bd.size());
set_flags(DB_DBT_USERMEM);
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
private:
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
std::unique_ptr<char[]> m_data;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
};
struct Dbt_safe : public Dbt
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_safe()
{
set_data(NULL);
set_flags(DB_DBT_MALLOC);
}
~Dbt_safe()
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
void* buf = get_data();
if (buf != NULL)
{
free(buf);
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
}
};
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
} // anonymous namespace
namespace cryptonote
{
void BlockchainBDB::add_block( const block& blk
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
, const size_t& block_size
, const difficulty_type& cumulative_difficulty
, const uint64_t& coins_generated
, const crypto::hash& blk_hash
)
{
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
Dbt_copy<crypto::hash> val_h(blk_hash);
if (m_block_heights->exists(*m_write_txn, &val_h, 0) == 0)
throw1(BLOCK_EXISTS("Attempting to add block that's already in the db"));
if (m_height > 0)
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> parent_key(blk.prev_id);
Dbt_copy<uint32_t> parent_h;
if (m_block_heights->get(*m_write_txn, &parent_key, &parent_h, 0))
{
LOG_PRINT_L3("m_height: " << m_height);
LOG_PRINT_L3("parent_key: " << blk.prev_id);
throw0(DB_ERROR("Failed to get top block hash to check for new block's parent"));
}
uint32_t parent_height = parent_h;
if (parent_height != m_height)
throw0(BLOCK_PARENT_DNE("Top block is not new block's parent"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
}
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> key(m_height + 1);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<blobdata> blob(block_to_blob(blk));
auto res = m_blocks->put(*m_write_txn, &key, &blob, 0);
if (res)
throw0(DB_ERROR("Failed to add block blob to db transaction."));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<size_t> sz(block_size);
if (m_block_sizes->put(*m_write_txn, &key, &sz, 0))
throw0(DB_ERROR("Failed to add block size to db transaction."));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> ts(blk.timestamp);
if (m_block_timestamps->put(*m_write_txn, &key, &ts, 0))
throw0(DB_ERROR("Failed to add block timestamp to db transaction."));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<difficulty_type> diff(cumulative_difficulty);
if (m_block_diffs->put(*m_write_txn, &key, &diff, 0))
throw0(DB_ERROR("Failed to add block cumulative difficulty to db transaction."));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> coinsgen(coins_generated);
if (m_block_coins->put(*m_write_txn, &key, &coinsgen, 0))
throw0(DB_ERROR("Failed to add block total generated coins to db transaction."));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_block_heights->put(*m_write_txn, &val_h, &key, 0))
throw0(DB_ERROR("Failed to add block height by hash to db transaction."));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_block_hashes->put(*m_write_txn, &key, &val_h, 0))
throw0(DB_ERROR("Failed to add block hash to db transaction."));
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::remove_block()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_height == 0)
throw0(BLOCK_DNE ("Attempting to remove block from an empty blockchain"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> k(m_height);
Dbt_copy<crypto::hash> h;
if (m_block_hashes->get(*m_write_txn, &k, &h, 0))
throw1(BLOCK_DNE("Attempting to remove block that's not in the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_blocks->del(*m_write_txn, &k, 0))
throw1(DB_ERROR("Failed to add removal of block to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_block_sizes->del(*m_write_txn, &k, 0))
throw1(DB_ERROR("Failed to add removal of block size to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_block_diffs->del(*m_write_txn, &k, 0))
throw1(DB_ERROR("Failed to add removal of block cumulative difficulty to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_block_coins->del(*m_write_txn, &k, 0))
throw1(DB_ERROR("Failed to add removal of block total generated coins to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_block_timestamps->del(*m_write_txn, &k, 0))
throw1(DB_ERROR("Failed to add removal of block timestamp to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_block_heights->del(*m_write_txn, &h, 0))
throw1(DB_ERROR("Failed to add removal of block height by hash to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_block_hashes->del(*m_write_txn, &k, 0))
throw1(DB_ERROR("Failed to add removal of block hash to db transaction"));
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::add_transaction_data(const crypto::hash& blk_hash, const transaction& tx, const crypto::hash& tx_hash)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> val_h(tx_hash);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_txs->exists(*m_write_txn, &val_h, 0) == 0)
throw1(TX_EXISTS("Attempting to add transaction that's already in the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<blobdata> blob(tx_to_blob(tx));
if (m_txs->put(*m_write_txn, &val_h, &blob, 0))
throw0(DB_ERROR("Failed to add tx blob to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> height(m_height + 1);
if (m_tx_heights->put(*m_write_txn, &val_h, &height, 0))
throw0(DB_ERROR("Failed to add tx block height to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> unlock_time(tx.unlock_time);
if (m_tx_unlocks->put(*m_write_txn, &val_h, &unlock_time, 0))
throw0(DB_ERROR("Failed to add tx unlock time to db transaction"));
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::remove_transaction_data(const crypto::hash& tx_hash, const transaction& tx)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> val_h(tx_hash);
if (m_txs->exists(*m_write_txn, &val_h, 0))
throw1(TX_DNE("Attempting to remove transaction that isn't in the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_txs->del(*m_write_txn, &val_h, 0))
throw1(DB_ERROR("Failed to add removal of tx to db transaction"));
if (m_tx_unlocks->del(*m_write_txn, &val_h, 0))
throw1(DB_ERROR("Failed to add removal of tx unlock time to db transaction"));
if (m_tx_heights->del(*m_write_txn, &val_h, 0))
throw1(DB_ERROR("Failed to add removal of tx block height to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
remove_tx_outputs(tx_hash, tx);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_tx_outputs->del(*m_write_txn, &val_h, 0))
throw1(DB_ERROR("Failed to add removal of tx outputs to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::add_output(const crypto::hash& tx_hash, const tx_out& tx_output, const uint64_t& local_index)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> k(m_num_outputs + 1);
Dbt_copy<crypto::hash> v(tx_hash);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_output_txs->put(*m_write_txn, &k, &v, 0))
throw0(DB_ERROR("Failed to add output tx hash to db transaction"));
if (m_tx_outputs->put(*m_write_txn, &v, &k, 0))
throw0(DB_ERROR("Failed to add tx output index to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> val_local_index(local_index);
if (m_output_indices->put(*m_write_txn, &k, &val_local_index, 0))
throw0(DB_ERROR("Failed to add tx output index to db transaction"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> val_amount(tx_output.amount);
if (m_output_amounts->put(*m_write_txn, &val_amount, &k, 0))
throw0(DB_ERROR("Failed to add output amount to db transaction."));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (tx_output.target.type() == typeid(txout_to_key))
{
Dbt_copy<crypto::public_key> val_pubkey(boost::get<txout_to_key>(tx_output.target).key);
if (m_output_keys->put(*m_write_txn, &k, &val_pubkey, 0))
throw0(DB_ERROR("Failed to add output pubkey to db transaction"));
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_num_outputs++;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::remove_tx_outputs(const crypto::hash& tx_hash, const transaction& tx)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_cur cur(*m_write_txn, m_tx_outputs);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> k(tx_hash);
Dbt_copy<uint32_t> v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
throw0(DB_ERROR("Attempting to remove a tx's outputs, but none found."));
}
else if (result)
{
throw0(DB_ERROR("DB error attempting to get an output"));
}
else
{
db_recno_t num_elems = 0;
cur->count(&num_elems, 0);
for (uint64_t i = 0; i < num_elems; ++i)
{
const tx_out tx_output = tx.vout[i];
remove_output(v, tx_output.amount);
if (i < num_elems - 1)
{
cur->get(&k, &v, DB_NEXT_DUP);
}
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
}
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
cur.close();
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
// TODO: probably remove this function
void BlockchainBDB::remove_output(const tx_out& tx_output)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__ << " (unused version - does nothing)");
return;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::remove_output(const uint64_t& out_index, const uint64_t amount)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
Dbt_copy<uint32_t> k(out_index);
auto result = m_output_indices->del(*m_write_txn, &k, 0);
if (result == DB_NOTFOUND)
{
LOG_PRINT_L0("Unexpected: global output index not found in m_output_indices");
}
else if (result)
{
throw1(DB_ERROR("Error adding removal of output tx index to db transaction"));
}
result = m_output_txs->del(*m_write_txn, &k, 0);
// if (result != 0 && result != DB_NOTFOUND)
// throw1(DB_ERROR("Error adding removal of output tx hash to db transaction"));
if (result == DB_NOTFOUND)
{
LOG_PRINT_L0("Unexpected: global output index not found in m_output_txs");
}
else if (result)
{
throw1(DB_ERROR("Error adding removal of output tx hash to db transaction"));
}
result = m_output_keys->del(*m_write_txn, &k, 0);
if (result == DB_NOTFOUND)
{
LOG_PRINT_L0("Unexpected: global output index not found in m_output_keys");
}
else if (result)
throw1(DB_ERROR("Error adding removal of output pubkey to db transaction"));
remove_amount_output_index(amount, out_index);
m_num_outputs--;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::remove_amount_output_index(const uint64_t amount, const uint64_t global_output_index)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_cur cur(*m_write_txn, m_output_amounts);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> k(amount);
Dbt_copy<uint32_t> v;
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but amount not found"));
else if (result)
throw0(DB_ERROR("DB error attempting to get an output"));
db_recno_t num_elems = 0;
cur->count(&num_elems, 0);
uint64_t amount_output_index = 0;
uint64_t goi = 0;
bool found_index = false;
for (uint64_t i = 0; i < num_elems; ++i)
{
goi = v;
if (goi == global_output_index)
{
amount_output_index = i;
found_index = true;
break;
}
cur->get(&k, &v, DB_NEXT_DUP);
}
if (found_index)
{
// found the amount output index
// now delete it
result = cur->del(0);
if (result)
throw0(DB_ERROR(std::string("Error deleting amount output index ").append(boost::lexical_cast<std::string>(amount_output_index)).c_str()));
}
else
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// not found
throw1(OUTPUT_DNE("Failed to find amount output index"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
}
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
cur.close();
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::add_spent_key(const crypto::key_image& k_image)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::key_image> val_key(k_image);
if (m_spent_keys->exists(*m_write_txn, &val_key, 0) == 0)
throw1(KEY_IMAGE_EXISTS("Attempting to add spent key image that's already in the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<char> val('\0');
if (m_spent_keys->put(*m_write_txn, &val_key, &val, 0))
throw1(DB_ERROR("Error adding spent key image to db transaction."));
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::remove_spent_key(const crypto::key_image& k_image)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::key_image> k(k_image);
auto result = m_spent_keys->del(*m_write_txn, &k, 0);
if (result != 0 && result != DB_NOTFOUND)
throw1(DB_ERROR("Error adding removal of key image to db transaction"));
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
blockchain_db: add a few const
2015-05-27 18:03:46 +00:00
blobdata BlockchainBDB::output_to_blob(const tx_out& output) const
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
blobdata b;
if (!t_serializable_object_to_blob(output, b))
throw1(DB_ERROR("Error serializing output to blob"));
return b;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
tx_out BlockchainBDB::output_from_blob(const blobdata& blob) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
std::stringstream ss;
ss << blob;
binary_archive<false> ba(ss);
tx_out o;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (!(::serialization::serialize(ba, o)))
throw1(DB_ERROR("Error deserializing tx output blob"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return o;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_output_global_index(const uint64_t& amount, const uint64_t& index) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainLMDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_cur cur(txn, m_output_amounts);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> k(amount);
Dbt_copy<uint32_t> v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but amount not found"));
else if (result)
throw0(DB_ERROR("DB error attempting to get an output"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
db_recno_t num_elems;
cur->count(&num_elems, 0);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (num_elems <= index)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but output not found"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
for (uint64_t i = 0; i < index; ++i)
{
cur->get(&k, &v, DB_NEXT_DUP);
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
uint64_t glob_index = v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
cur.close();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return glob_index;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::check_open() const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
if (!m_open)
throw0(DB_ERROR("DB operation attempted on a not-open DB instance"));
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
BlockchainBDB::~BlockchainBDB()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
if(m_buffer != NULL)
free(m_buffer);
m_buffer = NULL;
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_open)
{
close();
}
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
BlockchainBDB::BlockchainBDB(bool batch_transactions)
{
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
m_buffer = malloc(BUFFER_LENGTH);
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
// initialize folder to something "safe" just in case
// someone accidentally misuses this class...
m_folder = "thishsouldnotexistbecauseitisgibberish";
m_open = false;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_batch_transactions = batch_transactions;
m_write_txn = nullptr;
m_height = 0;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
BerkeleyDB implementation of BlockchainDB seems to be working!
2015-03-18 02:12:09 +00:00
void BlockchainBDB::open(const std::string& filename, const int db_flags)
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_open)
throw0(DB_OPEN_FAILURE("Attempted to open db, but it's already open"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
boost::filesystem::path direc(filename);
if (boost::filesystem::exists(direc))
{
if (!boost::filesystem::is_directory(direc))
throw0(DB_OPEN_FAILURE("DB needs a directory path, but a file was passed"));
}
else
{
if (!boost::filesystem::create_directory(direc))
throw0(DB_OPEN_FAILURE(std::string("Failed to create directory ").append(filename).c_str()));
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_folder = filename;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
try
{
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
//Create BerkeleyDB environment
m_env = new DbEnv(0); // no flags needed for DbEnv
uint32_t db_env_open_flags = DB_CREATE | DB_INIT_MPOOL | DB_INIT_LOCK
| DB_INIT_LOG | DB_INIT_TXN | DB_RECOVER
| DB_THREAD;
// last parameter left 0, files will be created with default rw access
m_env->open(filename.c_str(), db_env_open_flags, 0);
// begin transaction to init dbs
bdb_txn_safe txn;
m_env->txn_begin(NULL, txn, 0);
// create Dbs in the environment
m_blocks = new Db(m_env, 0);
m_block_heights = new Db(m_env, 0);
m_block_hashes = new Db(m_env, 0);
m_block_timestamps = new Db(m_env, 0);
m_block_sizes = new Db(m_env, 0);
m_block_diffs = new Db(m_env, 0);
m_block_coins = new Db(m_env, 0);
m_txs = new Db(m_env, 0);
m_tx_unlocks = new Db(m_env, 0);
m_tx_heights = new Db(m_env, 0);
m_tx_outputs = new Db(m_env, 0);
m_output_txs = new Db(m_env, 0);
m_output_indices = new Db(m_env, 0);
m_output_amounts = new Db(m_env, 0);
m_output_keys = new Db(m_env, 0);
m_spent_keys = new Db(m_env, 0);
// Tell DB about Dbs that need duplicate support
// Note: no need to tell about sorting,
// as the default is insertion order, which we want
m_tx_outputs->set_flags(DB_DUP);
m_output_amounts->set_flags(DB_DUP);
// Tell DB about fixed-size values.
m_block_hashes->set_re_len(sizeof(crypto::hash));
m_block_timestamps->set_re_len(sizeof(uint64_t));
m_block_sizes->set_re_len(sizeof(size_t)); // should really store block size as uint64_t...
m_block_diffs->set_re_len(sizeof(difficulty_type));
m_block_coins->set_re_len(sizeof(uint64_t));
m_output_txs->set_re_len(sizeof(crypto::hash));
m_output_indices->set_re_len(sizeof(uint64_t));
m_output_keys->set_re_len(sizeof(crypto::public_key));
//TODO: Find out if we need to do Db::set_flags(DB_RENUMBER)
// for the RECNO databases. We shouldn't as we're only
// inserting/removing from the end, but we'll see.
// open Dbs in the environment
// m_tx_outputs and m_output_amounts must be DB_HASH or DB_BTREE
// because they need duplicate entry support. The rest are DB_RECNO,
// as it seems that will be the most performant choice.
m_blocks->open(txn, BDB_BLOCKS, NULL, DB_RECNO, DB_CREATE, 0);
m_block_timestamps->open(txn, BDB_BLOCK_TIMESTAMPS, NULL, DB_RECNO, DB_CREATE, 0);
m_block_heights->open(txn, BDB_BLOCK_HEIGHTS, NULL, DB_HASH, DB_CREATE, 0);
m_block_hashes->open(txn, BDB_BLOCK_HASHES, NULL, DB_RECNO, DB_CREATE, 0);
m_block_sizes->open(txn, BDB_BLOCK_SIZES, NULL, DB_RECNO, DB_CREATE, 0);
m_block_diffs->open(txn, BDB_BLOCK_DIFFS, NULL, DB_RECNO, DB_CREATE, 0);
m_block_coins->open(txn, BDB_BLOCK_COINS, NULL, DB_RECNO, DB_CREATE, 0);
m_txs->open(txn, BDB_TXS, NULL, DB_HASH, DB_CREATE, 0);
m_tx_unlocks->open(txn, BDB_TX_UNLOCKS, NULL, DB_HASH, DB_CREATE, 0);
m_tx_heights->open(txn, BDB_TX_HEIGHTS, NULL, DB_HASH, DB_CREATE, 0);
m_tx_outputs->open(txn, BDB_TX_OUTPUTS, NULL, DB_HASH, DB_CREATE, 0);
m_output_txs->open(txn, BDB_OUTPUT_TXS, NULL, DB_RECNO, DB_CREATE, 0);
m_output_indices->open(txn, BDB_OUTPUT_INDICES, NULL, DB_RECNO, DB_CREATE, 0);
m_output_amounts->open(txn, BDB_OUTPUT_AMOUNTS, NULL, DB_HASH, DB_CREATE, 0);
m_output_keys->open(txn, BDB_OUTPUT_KEYS, NULL, DB_RECNO, DB_CREATE, 0);
m_spent_keys->open(txn, BDB_SPENT_KEYS, NULL, DB_HASH, DB_CREATE, 0);
DB_BTREE_STAT* stats;
// DB_FAST_STAT can apparently cause an incorrect number of records
// to be returned. The flag should be set to 0 instead if this proves
// to be the case.
m_blocks->stat(txn, &stats, DB_FAST_STAT);
m_height = stats->bt_nkeys;
delete stats;
// see above comment about DB_FAST_STAT
m_output_indices->stat(txn, &stats, DB_FAST_STAT);
m_num_outputs = stats->bt_nkeys;
delete stats;
txn.commit();
}
catch (const std::exception& e)
{
throw0(DB_OPEN_FAILURE(e.what()));
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_open = true;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::close()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
this->sync();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// FIXME: not yet thread safe!!! Use with care.
m_open = false;
m_env->close(DB_FORCESYNC);
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::sync()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
try
{
m_blocks->sync(0);
m_block_heights->sync(0);
m_block_hashes->sync(0);
m_block_timestamps->sync(0);
m_block_sizes->sync(0);
m_block_diffs->sync(0);
m_block_coins->sync(0);
m_txs->sync(0);
m_tx_unlocks->sync(0);
m_tx_heights->sync(0);
m_tx_outputs->sync(0);
m_output_txs->sync(0);
m_output_indices->sync(0);
m_output_amounts->sync(0);
m_output_keys->sync(0);
m_spent_keys->sync(0);
}
catch (const std::exception& e)
{
throw0(DB_ERROR(std::string("Failed to sync database: ").append(e.what()).c_str()));
}
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::reset()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainLMDB::" << __func__);
// TODO: this
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
std::vector<std::string> BlockchainBDB::get_filenames() const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
std::vector<std::string> filenames;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
char *fname, *dbname;
const char **pfname, **pdbname;
BerkeleyDB Blockchain building, not working yet Everything except actually *using* BlockchainBDB is wired up, but the db itself is not yet working. Some error about user mem not large enough. I think I know what this error means, but I can't determine the cause. Notes: BerkeleyDB does not allow 0-indexing in its recno type databases, so block numbers *in the database* will be 1-indexed. Modifications to indexing have been made as needed.
2015-03-16 13:14:51 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
pfname = (const char **)&fname;
pdbname = (const char **)&dbname;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_blocks->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_block_heights->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_block_hashes->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_block_timestamps->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_block_sizes->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_block_diffs->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_block_coins->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_txs->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_tx_unlocks->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_tx_heights->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_tx_outputs->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_output_txs->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_output_indices->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_output_amounts->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_output_keys->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_spent_keys->get_dbname(pfname, pdbname);
filenames.push_back(fname);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
std::vector<std::string> full_paths;
BerkeleyDB Blockchain building, not working yet Everything except actually *using* BlockchainBDB is wired up, but the db itself is not yet working. Some error about user mem not large enough. I think I know what this error means, but I can't determine the cause. Notes: BerkeleyDB does not allow 0-indexing in its recno type databases, so block numbers *in the database* will be 1-indexed. Modifications to indexing have been made as needed.
2015-03-16 13:14:51 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
for (auto& filename : filenames)
{
boost::filesystem::path p(m_folder);
p /= filename;
full_paths.push_back(p.string());
}
BerkeleyDB Blockchain building, not working yet Everything except actually *using* BlockchainBDB is wired up, but the db itself is not yet working. Some error about user mem not large enough. I think I know what this error means, but I can't determine the cause. Notes: BerkeleyDB does not allow 0-indexing in its recno type databases, so block numbers *in the database* will be 1-indexed. Modifications to indexing have been made as needed.
2015-03-16 13:14:51 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return full_paths;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
}
std::string BlockchainBDB::get_db_name() const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return std::string("BerkeleyDB");
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
// TODO: this?
bool BlockchainBDB::lock()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
return false;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
// TODO: this?
void BlockchainBDB::unlock()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
bool BlockchainBDB::block_exists(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> key(h);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
auto get_result = m_block_heights->exists(txn, &key, 0);
if (get_result == DB_NOTFOUND)
{
txn.commit();
LOG_PRINT_L3("Block with hash " << epee::string_tools::pod_to_hex(h) << " not found in db");
return false;
}
else if (get_result)
throw0(DB_ERROR("DB error attempting to fetch block index from hash"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
return true;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
block BlockchainBDB::get_block(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return get_block_from_height(get_block_height(h));
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_block_height(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> key(h);
Dbt_copy<uint64_t> result;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
auto get_result = m_block_heights->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
throw1(BLOCK_DNE("Attempted to retrieve non-existent block height"));
else if (get_result)
throw0(DB_ERROR("Error attempting to retrieve a block height from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB Blockchain building, not working yet Everything except actually *using* BlockchainBDB is wired up, but the db itself is not yet working. Some error about user mem not large enough. I think I know what this error means, but I can't determine the cause. Notes: BerkeleyDB does not allow 0-indexing in its recno type databases, so block numbers *in the database* will be 1-indexed. Modifications to indexing have been made as needed.
2015-03-16 13:14:51 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return (uint64_t)result - 1;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
block_header BlockchainBDB::get_block_header(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// block_header object is automatically cast from block object
return get_block(h);
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
block BlockchainBDB::get_block_from_height(const uint64_t& height) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> key(height + 1);
Dbt_safe result;
auto get_result = m_blocks->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
{
throw0(DB_ERROR(std::string("Attempt to get block from height ").append(boost::lexical_cast<std::string>(height)).append(" failed -- block not in db").c_str()));
}
else if (get_result)
throw0(DB_ERROR("Error attempting to retrieve a block from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
blobdata bd;
bd.assign(reinterpret_cast<char*>(result.get_data()), result.get_size());
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
block b;
if (!parse_and_validate_block_from_blob(bd, b))
throw0(DB_ERROR("Failed to parse block from blob retrieved from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return b;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_block_timestamp(const uint64_t& height) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> key(height + 1);
Dbt_copy<uint64_t> result;
auto get_result = m_block_timestamps->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
{
throw0(DB_ERROR(std::string("Attempt to get timestamp from height ").append(boost::lexical_cast<std::string>(height)).append(" failed -- timestamp not in db").c_str()));
}
else if (get_result)
throw0(DB_ERROR("Error attempting to retrieve a timestamp from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
return result;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_top_block_timestamp() const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// if no blocks, return 0
if (m_height == 0)
{
return 0;
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return get_block_timestamp(m_height - 1);
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
size_t BlockchainBDB::get_block_size(const uint64_t& height) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> key(height + 1);
Dbt_copy<size_t> result;
auto get_result = m_block_sizes->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
{
throw0(DB_ERROR(std::string("Attempt to get block size from height ").append(boost::lexical_cast<std::string>(height)).append(" failed -- block size not in db").c_str()));
}
else if (get_result)
throw0(DB_ERROR("Error attempting to retrieve a block size from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
return result;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
difficulty_type BlockchainBDB::get_block_cumulative_difficulty(const uint64_t& height) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__ << " height: " << height);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> key(height + 1);
Dbt_copy<difficulty_type> result;
auto get_result = m_block_diffs->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
{
throw0(DB_ERROR(std::string("Attempt to get cumulative difficulty from height ").append(boost::lexical_cast<std::string>(height)).append(" failed -- difficulty not in db").c_str()));
}
else if (get_result)
throw0(DB_ERROR("Error attempting to retrieve a cumulative difficulty from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
return result;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
difficulty_type BlockchainBDB::get_block_difficulty(const uint64_t& height) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
difficulty_type diff1 = 0;
difficulty_type diff2 = 0;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
diff1 = get_block_cumulative_difficulty(height);
if (height != 0)
{
diff2 = get_block_cumulative_difficulty(height - 1);
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return diff1 - diff2;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_block_already_generated_coins(const uint64_t& height) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> key(height + 1);
Dbt_copy<uint64_t> result;
auto get_result = m_block_coins->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
{
throw0(DB_ERROR(std::string("Attempt to get generated coins from height ").append(boost::lexical_cast<std::string>(height)).append(" failed -- block size not in db").c_str()));
}
else if (get_result)
throw0(DB_ERROR("Error attempting to retrieve a total generated coins from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
return result;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
crypto::hash BlockchainBDB::get_block_hash_from_height(const uint64_t& height) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> key(height + 1);
Dbt_copy<crypto::hash> result;
auto get_result = m_block_hashes->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
{
throw0(BLOCK_DNE(std::string("Attempt to get hash from height ").append(boost::lexical_cast<std::string>(height)).append(" failed -- hash not in db").c_str()));
}
else if (get_result)
throw0(DB_ERROR("Error attempting to retrieve a block hash from the db."));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
return result;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
std::vector<block> BlockchainBDB::get_blocks_range(const uint64_t& h1, const uint64_t& h2) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
std::vector<block> v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
for (uint64_t height = h1; height <= h2; ++height)
{
v.push_back(get_block_from_height(height));
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return v;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
std::vector<crypto::hash> BlockchainBDB::get_hashes_range(const uint64_t& h1, const uint64_t& h2) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
std::vector<crypto::hash> v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
for (uint64_t height = h1; height <= h2; ++height)
{
v.push_back(get_block_hash_from_height(height));
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return v;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
crypto::hash BlockchainBDB::top_block_hash() const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
if (m_height > 0)
{
return get_block_hash_from_height(m_height - 1);
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return null_hash;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
block BlockchainBDB::get_top_block() const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (m_height > 0)
{
return get_block_from_height(m_height - 1);
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
block b;
return b;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::height() const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return m_height;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
bool BlockchainBDB::tx_exists(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> key(h);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
TIME_MEASURE_START(time1);
auto get_result = m_txs->exists(txn, &key, 0);
TIME_MEASURE_FINISH(time1);
time_tx_exists += time1;
if (get_result == DB_NOTFOUND)
{
txn.commit();
LOG_PRINT_L1("transaction with hash " << epee::string_tools::pod_to_hex(h) << " not found in db");
return false;
}
else if (get_result)
throw0(DB_ERROR("DB error attempting to fetch transaction from hash"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return true;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_tx_unlock_time(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainLMDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> key(h);
Dbt_copy<uint64_t> result;
auto get_result = m_tx_unlocks->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
throw1(TX_DNE(std::string("tx unlock time with hash ").append(epee::string_tools::pod_to_hex(h)).append(" not found in db").c_str()));
else if (get_result)
throw0(DB_ERROR("DB error attempting to fetch tx unlock time from hash"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return result;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
transaction BlockchainBDB::get_tx(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> key(h);
Dbt_safe result;
auto get_result = m_txs->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
throw1(TX_DNE(std::string("tx with hash ").append(epee::string_tools::pod_to_hex(h)).append(" not found in db").c_str()));
else if (get_result)
throw0(DB_ERROR("DB error attempting to fetch tx from hash"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
blobdata bd;
bd.assign(reinterpret_cast<char*>(result.get_data()), result.get_size());
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
transaction tx;
if (!parse_and_validate_tx_from_blob(bd, tx))
throw0(DB_ERROR("Failed to parse tx from blob retrieved from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return tx;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_tx_count() const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
DB_BTREE_STAT* stats;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// DB_FAST_STAT can apparently cause an incorrect number of records
// to be returned. The flag should be set to 0 instead if this proves
// to be the case.
m_txs->stat(txn, &stats, DB_FAST_STAT);
auto num_txs = stats->bt_nkeys;
delete stats;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return num_txs;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
std::vector<transaction> BlockchainBDB::get_tx_list(const std::vector<crypto::hash>& hlist) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
std::vector<transaction> v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
for (auto& h : hlist)
{
v.push_back(get_tx(h));
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return v;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_tx_block_height(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> key(h);
Dbt_copy<uint64_t> result;
auto get_result = m_tx_heights->get(txn, &key, &result, 0);
if (get_result == DB_NOTFOUND)
{
throw1(TX_DNE(std::string("tx height with hash ").append(epee::string_tools::pod_to_hex(h)).append(" not found in db").c_str()));
}
else if (get_result)
throw0(DB_ERROR("DB error attempting to fetch tx height from hash"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return (uint64_t)result - 1;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
//FIXME: make sure the random method used here is appropriate
uint64_t BlockchainBDB::get_random_output(const uint64_t& amount) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
uint64_t num_outputs = get_num_outputs(amount);
if (num_outputs == 0)
throw1(OUTPUT_DNE("Attempting to get a random output for an amount, but none exist"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return crypto::rand<uint64_t>() % num_outputs;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::get_num_outputs(const uint64_t& amount) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_cur cur(txn, m_output_amounts);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> k(amount);
Dbt_copy<uint64_t> v;
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
{
return 0;
}
else if (result)
throw0(DB_ERROR("DB error attempting to get number of outputs of an amount"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
db_recno_t num_elems = 0;
cur->count(&num_elems, 0);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return num_elems;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
crypto::public_key BlockchainBDB::get_output_key(const uint64_t& amount, const uint64_t& index) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
uint64_t glob_index = get_output_global_index(amount, index);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint32_t> k(glob_index);
Dbt_copy<crypto::public_key> v;
auto get_result = m_output_keys->get(txn, &k, &v, 0);
if (get_result == DB_NOTFOUND)
throw0(DB_ERROR("Attempting to get output pubkey by global index, but key does not exist"));
else if (get_result)
throw0(DB_ERROR("Error attempting to retrieve an output pubkey from the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return v;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
// As this is not used, its return is now a blank output.
// This will save on space in the db.
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
tx_out BlockchainBDB::get_output(const crypto::hash& h, const uint64_t& index) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
return tx_out();
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
// As this is not used, its return is now a blank output.
// This will save on space in the db.
tx_out BlockchainBDB::get_output(const uint64_t& index) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
return tx_out();
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
void BlockchainBDB::get_output_tx_and_index(const uint64_t& amount,
std::vector<uint64_t> &offsets,
std::vector<tx_out_index> &indices) const
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
bdb_cur cur(txn, m_output_amounts);
uint64_t max = 0;
for(const uint64_t& index : offsets)
{
if(index > max)
max = index;
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// ??? might be a bug, don't always treat as uint64_t
#define DBT_VALUE(dbt) v.get_size() == sizeof(uint64_t) ? \
*((uint64_t *)v.get_data()) : *((uint32_t *)v.get_data()) \
// get returned keypairs count
#define DB_COUNT_RECORDS(dbt, cnt) \
do { \
uint32_t *_p = (uint32_t *) ((uint8_t *)(dbt)->data + \
(dbt)->ulen - sizeof(uint32_t)); \
cnt = 0; \
while(*_p != (uint32_t) -1) { \
_p -= 2; \
++cnt; \
} \
} while(0); \
Dbt_copy<uint64_t> k(amount);
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
Dbt_copy<uint64_t> v;
uint64_t buflen = 0;
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
uint64_t t_dbmul = 0;
uint64_t t_dbscan = 0;
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
TIME_MEASURE_START(db2);
if(max <= 1)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
for (const uint64_t& index : offsets)
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
{
TIME_MEASURE_START(t_seek);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but amount not found"));
else if (result)
throw0(DB_ERROR("DB error attempting to get an output"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
db_recno_t num_elems = 0;
cur->count(&num_elems, 0);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
if (num_elems <= index)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but output not found"));
for (uint64_t i = 0; i < index; ++i)
{
cur->get(&k, &v, DB_NEXT_DUP);
}
uint64_t glob_index = DBT_VALUE(v);
LOG_PRINT_L1("L0->v: " << glob_index);
tx_out_index res = get_output_tx_and_index_from_global(glob_index);
indices.push_back(res);
TIME_MEASURE_FINISH(t_seek);
}
}
else
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// setup a 256KB minimum buffer size
uint32_t pagesize = 256 * 1024;
// Retrieve only a suitable portion of the kvp data, up to somewhere near
// the maximum offset value being retrieved
buflen = (max + 1) * 4 * sizeof(uint64_t);
buflen = ((buflen / pagesize) + ((buflen % pagesize) > 0 ? 1 : 0)) * pagesize;
bool singlebuff = buflen <= BUFFER_LENGTH;
buflen = buflen < BUFFER_LENGTH ? buflen : BUFFER_LENGTH;
Dbt data;
data.set_data(m_buffer);
data.set_ulen(buflen);
data.set_size(buflen);
data.set_flags(DB_DBT_USERMEM);
uint32_t curcount = 0;
uint32_t blockstart = 0;
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
for (const uint64_t& index : offsets)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// fixme! for whatever reason, the first call to DB_MULTIPLE | DB_SET does not
// retrieve the first value.
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
if(index <= 1)
{
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but amount not found"));
else if (result)
throw0(DB_ERROR("DB error attempting to get an output"));
db_recno_t num_elems = 0;
cur->count(&num_elems, 0);
if (num_elems <= index)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but output not found"));
if(index > 0)
cur->get(&k, &v, DB_NEXT_DUP);
}
else
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
while(index >= curcount)
{
TIME_MEASURE_START(t_db1);
try
{
cur->get(&k, &data, DB_MULTIPLE | (curcount == 0 ? DB_SET : DB_NEXT_DUP));
blockstart = curcount;
// skip counting if using single buffer, it actually adds some overhead on some systems.
if(!singlebuff)
{
int count = 0;
DB_COUNT_RECORDS((DBT *) &data, count);
curcount += count;
}
}
catch (const std::exception &e)
{
LOG_PRINT_L0("DB_EXCEPTION: " << e.what());
}
TIME_MEASURE_FINISH(t_db1);
t_dbmul += t_db1;
if(singlebuff)
break;
}
LOG_PRINT_L1("Records returned: " << curcount << " Index: " << index);
TIME_MEASURE_START(t_db2);
DBT *pdata = (DBT *) &data;
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
uint8_t *value;
uint64_t dlen = 0;
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
void *pbase = ((uint8_t *)(pdata->data)) + pdata->ulen - sizeof(uint32_t);
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
uint32_t *p = (uint32_t *) pbase;
if (*p == (uint32_t) -1)
{
value = NULL;
}
else
{
p -= (index - blockstart) * 2; // index * 4 + 2; <- if DB_MULTIPLE_KEY
value = (uint8_t *) pdata->data + *p--;
dlen = *p--;
if (value == (uint8_t *) pdata->data)
value = NULL;
}
if (value != NULL)
{
v = dlen == sizeof(uint64_t) ? *((uint64_t *) value)
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
: *((uint32_t *) value);
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
}
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
TIME_MEASURE_FINISH(t_db2);
t_dbscan += t_db2;
}
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
uint64_t glob_index = DBT_VALUE(v);
LOG_PRINT_L1("L1->v: " << glob_index);
tx_out_index res = get_output_tx_and_index_from_global(glob_index);
indices.push_back(res);
}
}
TIME_MEASURE_FINISH(db2);
LOG_PRINT_L1("blen: " << buflen << " db1: " << t_dbmul << " db2: " << t_dbscan);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
cur.close();
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
tx_out_index BlockchainBDB::get_output_tx_and_index(const uint64_t& amount, const uint64_t& index) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_cur cur(txn, m_output_amounts);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> k(amount);
Dbt_copy<uint64_t> v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but amount not found"));
else if (result)
throw0(DB_ERROR("DB error attempting to get an output"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
db_recno_t num_elems = 0;
cur->count(&num_elems, 0);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
if (num_elems <= index)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but output not found"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
for (uint64_t i = 0; i < index; ++i)
{
cur->get(&k, &v, DB_NEXT_DUP);
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
uint64_t glob_index = v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
cur.close();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return get_output_tx_and_index_from_global(glob_index);
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
std::vector<uint64_t> BlockchainBDB::get_tx_output_indices(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
std::vector<uint64_t> index_vec;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_cur cur(txn, m_tx_outputs);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::hash> k(h);
Dbt_copy<uint64_t> v;
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
throw1(OUTPUT_DNE("Attempting to get an output by tx hash and tx index, but output not found"));
else if (result)
throw0(DB_ERROR("DB error attempting to get an output"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
db_recno_t num_elems = 0;
cur->count(&num_elems, 0);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
for (uint64_t i = 0; i < num_elems; ++i)
{
index_vec.push_back(v);
cur->get(&k, &v, DB_NEXT_DUP);
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
cur.close();
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return index_vec;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
std::vector<uint64_t> BlockchainBDB::get_tx_amount_output_indices(const crypto::hash& h) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
std::vector<uint64_t> index_vec;
std::vector<uint64_t> index_vec2;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
// get the transaction's global output indices first
index_vec = get_tx_output_indices(h);
// these are next used to obtain the amount output indices
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
transaction tx = get_tx(h);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
uint64_t i = 0;
uint64_t global_index;
for (const auto& vout : tx.vout)
{
uint64_t amount = vout.amount;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
global_index = index_vec[i];
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_cur cur(txn, m_output_amounts);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<uint64_t> k(amount);
Dbt_copy<uint64_t> v;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
auto result = cur->get(&k, &v, DB_SET);
if (result == DB_NOTFOUND)
throw1(OUTPUT_DNE("Attempting to get an output index by amount and amount index, but amount not found"));
else if (result)
throw0(DB_ERROR("DB error attempting to get an output"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
db_recno_t num_elems = 0;
cur->count(&num_elems, 0);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
uint64_t amount_output_index = 0;
uint64_t output_index = 0;
bool found_index = false;
for (uint64_t j = 0; j < num_elems; ++j)
{
output_index = v;
if (output_index == global_index)
{
amount_output_index = j;
found_index = true;
break;
}
cur->get(&k, &v, DB_NEXT_DUP);
}
if (found_index)
{
index_vec2.push_back(amount_output_index);
}
else
{
// not found
cur.close();
txn.commit();
throw1(OUTPUT_DNE("specified output not found in db"));
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
cur.close();
++i;
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
return index_vec2;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
Experimental BDB workaround optimizations
2015-05-02 00:16:48 +00:00
tx_out_index BlockchainBDB::get_output_tx_and_index_from_global(const uint64_t& index) const
{
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
Dbt_copy<uint32_t> k(index);
Dbt_copy<crypto::hash > v;
auto get_result = m_output_txs->get(txn, &k, &v, 0);
if (get_result == DB_NOTFOUND)
throw1(OUTPUT_DNE("output with given index not in db"));
else if (get_result)
throw0(DB_ERROR("DB error attempting to fetch output tx hash"));
crypto::hash tx_hash = v;
Dbt_copy<uint64_t> result;
get_result = m_output_indices->get(txn, &k, &result, 0);
if (get_result == DB_NOTFOUND)
throw1(OUTPUT_DNE("output with given index not in db"));
else if (get_result)
throw0(DB_ERROR("DB error attempting to fetch output tx index"));
txn.commit();
return tx_out_index(tx_hash, result);
}
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
bool BlockchainBDB::has_key_image(const crypto::key_image& img) const
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
Dbt_copy<crypto::key_image> val_key(img);
if (m_spent_keys->exists(txn, &val_key, 0) == 0)
{
txn.commit();
return true;
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
txn.commit();
return false;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
// Ostensibly BerkeleyDB has batch transaction support built-in,
// so the following few functions will be NOP.
Optionally allow DB to know expected number of blocks at batch transaction start This will assist in a DB resize check.
2015-07-11 19:28:20 +00:00
void BlockchainBDB::batch_start(uint64_t batch_num_blocks)
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::batch_commit()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::batch_stop()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::batch_abort()
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::set_batch_transactions(bool batch_transactions)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainLMDB::" << __func__);
m_batch_transactions = batch_transactions;
LOG_PRINT_L3("batch transactions " << (m_batch_transactions ? "enabled" : "disabled"));
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
uint64_t BlockchainBDB::add_block( const block& blk
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
, const size_t& block_size
, const difficulty_type& cumulative_difficulty
, const uint64_t& coins_generated
, const std::vector<transaction>& txs
)
{
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
m_write_txn = &txn;
uint64_t num_outputs = m_num_outputs;
try
{
BlockchainDB::add_block(blk, block_size, cumulative_difficulty, coins_generated, txs);
m_write_txn = NULL;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
TIME_MEASURE_START(time1);
txn.commit();
TIME_MEASURE_FINISH(time1);
time_commit1 += time1;
}
catch (const std::exception& e)
{
m_num_outputs = num_outputs;
m_write_txn = NULL;
throw;
}
return ++m_height;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
void BlockchainBDB::pop_block(block& blk, std::vector<transaction>& txs)
{
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
LOG_PRINT_L3("BlockchainBDB::" << __func__);
check_open();
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
bdb_txn_safe txn;
if (m_env->txn_begin(NULL, txn, 0))
throw0(DB_ERROR("Failed to create a transaction for the db"));
m_write_txn = &txn;
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
uint64_t num_outputs = m_num_outputs;
try
{
BlockchainDB::pop_block(blk, txs);
BerkeleyDB BlockchainDB impl copy/paste/modify LMDB implementation code copy/paste/modified into the Berkeley DB implementation. Need to test if it builds, then if it works, and so on, but the code is all there.
2015-03-14 23:28:34 +00:00
Update db_bdb.cpp
2015-05-02 04:12:16 +00:00
m_write_txn = NULL;
txn.commit();
}
catch (...)
{
m_num_outputs = num_outputs;
m_write_txn = NULL;
throw;
}
--m_height;
Initial commit of BDB BlockchainDB implementation Basically verbatim copy of LMDB implementation, but with the guts ripped out and includes changed, etc.
2015-03-09 20:21:44 +00:00
}
} // namespace cryptonote
Reference in New Issue Copy Permalink