mutex_iface.hpp

/*
 Copyright 2019 Eugene Gershnik
 
 Use of this source code is governed by a BSD-style
 license that can be found in the LICENSE file or at
 https://github.com/gershnik/thinsqlitepp/blob/main/LICENSE
*/
 
#ifndef HEADER_SQLITEPP_MUTEX_IFACE_INCLUDED
#define HEADER_SQLITEPP_MUTEX_IFACE_INCLUDED
 
#include "handle.hpp"
 
namespace thinsqlitepp
{
    class mutex final : public handle<sqlite3_mutex, mutex>
    {
    public:
        enum type { 
            fast = SQLITE_MUTEX_FAST,
            recursive = SQLITE_MUTEX_RECURSIVE
        };
 
        static std::unique_ptr<mutex> alloc(type t) noexcept
            { return std::unique_ptr<mutex>(from(sqlite3_mutex_alloc(int(t)))); }
 
        void lock() noexcept
            { sqlite3_mutex_enter(c_ptr()); }
        bool try_lock() noexcept
            { return sqlite3_mutex_try(c_ptr()) == SQLITE_OK; }
 
        void unlock() noexcept
            { sqlite3_mutex_leave(c_ptr()); }
    };
 
    class lock_adapter
    {
    public:
        lock_adapter(mutex * mutex = nullptr) noexcept: _mutex(mutex)
        {}
        lock_adapter(const std::unique_ptr<mutex> & mutex) noexcept: _mutex(mutex.get())
        {}
        
 
        void lock() noexcept
            { sqlite3_mutex_enter(c_ptr(_mutex)); }
 
        bool try_lock() noexcept
            { return sqlite3_mutex_try(c_ptr(_mutex)) == SQLITE_OK; }
 
        void unlock() noexcept
            { sqlite3_mutex_leave(c_ptr(_mutex)); }
    private:
        mutex * _mutex;
    };
 
}
 
#endif