mutex.hpp

//
// Copyright (c) 2022 Klemens Morgenstern (klemens.morgenstern@gmx.net)
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//
 
#ifndef BOOST_SQLITE_MUTEX_HPP
#define BOOST_SQLITE_MUTEX_HPP
 
#include <boost/sqlite/detail/config.hpp>
#include <memory>
 
BOOST_SQLITE_BEGIN_NAMESPACE
struct mutex
{
  bool try_lock()
  {
    if (!impl_)
      return false;
    return sqlite3_mutex_try(impl_.get()) == SQLITE_OK;
  }
  void lock()   { sqlite3_mutex_enter(impl_.get()); }
  void unlock() { sqlite3_mutex_leave(impl_.get()); }
 
  mutex() : impl_(sqlite3_mutex_alloc(SQLITE_MUTEX_FAST)) {}
  mutex(mutex && ) = delete;
 private:
  struct deleter_ {void operator()(sqlite3_mutex *mtx) {sqlite3_mutex_free(mtx);}};
  std::unique_ptr<sqlite3_mutex, deleter_> impl_;
};
 
struct recursive_mutex
{
  bool try_lock()
  {
    if (!impl_)
      return false;
    return sqlite3_mutex_try(impl_.get()) == SQLITE_OK;
  }
  void lock()   { sqlite3_mutex_enter(impl_.get()); }
  void unlock() { sqlite3_mutex_leave(impl_.get()); }
 
  recursive_mutex() : impl_(sqlite3_mutex_alloc(SQLITE_MUTEX_RECURSIVE)) {}
  recursive_mutex(recursive_mutex && ) = delete;
 private:
  struct deleter_ {void operator()(sqlite3_mutex *mtx) {sqlite3_mutex_free(mtx);}};
  std::unique_ptr<sqlite3_mutex, deleter_> impl_;
};
 
BOOST_SQLITE_END_NAMESPACE
 
#endif //BOOST_SQLITE_MUTEX_HPP