with_read_txn.hpp

#ifndef _DITTO_WITH_READ_TXN_
#define _DITTO_WITH_READ_TXN_
 
#include "internal_errors.hpp"
 
#include "dittoffi.hpp"
#include "safer_ffi_utils.hpp"
 
#include <functional>
 
namespace ditto {
template <typename T>
inline T with_read_txn(::CDitto *ditto,
                       std::function<T(CReadTransaction *)> f) {
  CReadTransaction *txn = nullptr;
  assert_lmdb_success(EXTRACT_RESULT(txn, ditto_read_transaction(ditto), .txn));
  T value = f(txn);
  ditto_read_transaction_free(txn);
  return value;
}
 
template <>
inline void with_read_txn(::CDitto *ditto,
                          std::function<void(CReadTransaction *)> f) {
  CReadTransaction *txn = nullptr;
  assert_lmdb_success(EXTRACT_RESULT(txn, ditto_read_transaction(ditto), .txn));
  f(txn);
  ditto_read_transaction_free(txn);
}
} // namespace ditto
#endif