diff --git a/mdbx.h++ b/mdbx.h++ index 623b4cc2..473def91 100644 --- a/mdbx.h++ +++ b/mdbx.h++ @@ -3875,12 +3875,31 @@ public: //---------------------------------------------------------------------------- - /// \brief Abandon all the operations of the transaction instead of saving - /// them. + /// \brief Abandon all the operations of the transaction + /// instead of saving ones. void abort(); /// \brief Commit all the operations of a transaction into the database. void commit(); + + using commit_latency = MDBX_commit_latency; + + /// \brief Commit all the operations of a transaction into the database + /// and collect latency information. + void commit(commit_latency *); + + /// \brief Commit all the operations of a transaction into the database + /// and collect latency information. + void commit(commit_latency &latency) { return commit(&latency); } + + /// \brief Commit all the operations of a transaction into the database + /// and return latency information. + /// \returns latency information of commit stages. + commit_latency commit_get_latency() { + commit_latency result; + commit(&result); + return result; + } }; /// \brief Unmanaged cursor. diff --git a/src/mdbx.c++ b/src/mdbx.c++ index 4be94939..78a4ead0 100644 --- a/src/mdbx.c++ +++ b/src/mdbx.c++ @@ -1424,6 +1424,15 @@ void txn_managed::commit() { MDBX_CXX20_UNLIKELY err.throw_exception(); } +void txn_managed::commit(commit_latency *latency) { + const error err = + static_cast(::mdbx_txn_commit_ex(handle_, latency)); + if (MDBX_LIKELY(err.code() != MDBX_THREAD_MISMATCH)) + MDBX_CXX20_LIKELY handle_ = nullptr; + if (MDBX_UNLIKELY(err.code() != MDBX_SUCCESS)) + MDBX_CXX20_UNLIKELY err.throw_exception(); +} + //------------------------------------------------------------------------------ bool txn::drop_map(const char *name, bool throw_if_absent) {