MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-12 04:51:08 +01:00
Code Issues Releases Wiki Activity

ircd::db::txn: Minor interface cleanup.

Browse source
This commit is contained in:
Jason Volk 2019-05-09 16:28:17 -07:00
parent fd514d2416
commit 96dfcaa122
2 changed files with 14 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

26
include/ircd/db/txn.h
View file

@ -15,35 +15,33 @@ namespace ircd::db
{
struct txn;
bool for_each(const txn &, const std::function<bool (const delta &)> &);
void for_each(const txn &, const std::function<void (const delta &)> &);
std::string debug(const txn &);
using seq_closure_bool = std::function<bool (txn &, const uint64_t &)>;
using delta_closure = std::function<void (const delta &)>;
using delta_closure_bool = std::function<bool (const delta &)>;
using seq_closure = std::function<void (txn &, const uint64_t &)>;
using seq_closure_bool = std::function<bool (txn &, const uint64_t &)>;
bool for_each(const txn &, const delta_closure_bool &);
void for_each(const txn &, const delta_closure &);
bool for_each(database &d, const uint64_t &seq, const seq_closure_bool &);
void for_each(database &d, const uint64_t &seq, const seq_closure &);
void get(database &d, const uint64_t &seq, const seq_closure &);
std::string debug(const txn &);
}
struct ircd::db::txn
{
struct opts;
struct checkpoint;
struct append;
struct handler;
enum state :uint8_t;
using value_closure = std::function<void (const string_view &)>;
database *d {nullptr};
std::unique_ptr<rocksdb::WriteBatch> wb;
enum state state {0};
public:
struct opts;
struct checkpoint;
struct append;
struct handler;
using delta_closure = std::function<void (const delta &)>;
using delta_closure_bool = std::function<bool (const delta &)>;
using value_closure = std::function<void (const string_view &)>;
explicit operator const rocksdb::WriteBatch &() const;
explicit operator const database &() const;
explicit operator rocksdb::WriteBatch &();

4
ircd/db.cc
View file

@ -3784,7 +3784,7 @@ ircd::db::debug(const txn &t)
void
ircd::db::for_each(const txn &t,
const std::function<void (const delta &)> &closure)
const delta_closure &closure)
{
const auto re{[&closure]
(const delta &delta)
@ -3801,7 +3801,7 @@ ircd::db::for_each(const txn &t,
bool
ircd::db::for_each(const txn &t,
const std::function<bool (const delta &)> &closure)
const delta_closure_bool &closure)
{
const database &d(t);
const rocksdb::WriteBatch &wb{t};