forked from lthn/blockchain
28659827c3
lmdb v 24 requires manual resizing/growing during it's normal function Zano core is purely async so it's not easy to prevent all DB txs from starting on lmdb adapter level, because it will lead to random deadlocks in the core due to many high-level cross-thread dependencies. We will rethink this later. Many thanks to @leo-yuriev who helped us to discover these issues!
51 lines
No EOL
1.7 KiB
C++
51 lines
No EOL
1.7 KiB
C++
// Copyright (c) 2014-2019 Zano Project
|
|
// Copyright (c) 2014-2018 The Louisdor Project
|
|
// Distributed under the MIT/X11 software license, see the accompanying
|
|
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
|
|
|
|
#pragma once
|
|
|
|
#ifndef ENV32BIT
|
|
#define CACHE_SIZE uint64_t(uint64_t(1UL * 128UL) * 1024UL * 1024UL * 1024UL)
|
|
#else
|
|
#define CACHE_SIZE (1 * 1024UL * 1024UL * 1024UL)
|
|
#endif
|
|
|
|
|
|
namespace tools
|
|
{
|
|
namespace db
|
|
{
|
|
typedef size_t container_handle;
|
|
const uint64_t invalid_tx_id = 0;
|
|
struct i_db_callback
|
|
{
|
|
virtual bool on_enum_item(uint64_t i, const void* pkey, uint64_t ks, const void* pval, uint64_t vs) = 0;
|
|
};
|
|
|
|
struct stat_info
|
|
{
|
|
uint64_t tx_count;
|
|
uint64_t write_tx_count;
|
|
uint64_t map_size;
|
|
};
|
|
|
|
struct i_db_backend
|
|
{
|
|
virtual bool close()=0;
|
|
virtual bool begin_transaction(bool read_only = false) = 0;
|
|
virtual bool commit_transaction()=0;
|
|
virtual void abort_transaction()=0;
|
|
virtual bool open(const std::string& path, uint64_t cache_sz = CACHE_SIZE) = 0;
|
|
virtual bool open_container(const std::string& name, container_handle& h)=0;
|
|
virtual bool erase(container_handle h, const char* k, size_t s) = 0;
|
|
virtual uint64_t size(container_handle h) = 0;
|
|
virtual bool get(container_handle h, const char* k, size_t s, std::string& res_buff) = 0;
|
|
virtual bool set(container_handle h, const char* k, size_t s, const char* v, size_t vs) = 0;
|
|
virtual bool clear(container_handle h) = 0;
|
|
virtual bool enumerate(container_handle h, i_db_callback* pcb)=0;
|
|
virtual bool get_stat_info(stat_info& si) = 0;
|
|
virtual ~i_db_backend(){};
|
|
};
|
|
}
|
|
} |