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/master/LICENSE
*/
 
#ifndef HEADER_SQLITEPP_MUTEX_IFACE_INCLUDED
#define HEADER_SQLITEPP_MUTEX_IFACE_INCLUDED
 
#include "handle.hpp"
 
namespace thinsqlitepp
{

    SQLITEPP_EXPORTED
    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([[maybe_unused]] type t) noexcept
        {
        #if !THINSQLITEPP_NO_MUTEX
            return std::unique_ptr<mutex>(from(sqlite3_mutex_alloc(int(t))));
        #else
            return {};
        #endif
        }

        void lock() noexcept
        { 
        #if !THINSQLITEPP_NO_MUTEX
            sqlite3_mutex_enter(c_ptr());
        #endif
        }

        bool try_lock() noexcept
        { 
        #if !THINSQLITEPP_NO_MUTEX
            return sqlite3_mutex_try(c_ptr()) == SQLITE_OK;
        #else
            return true;
        #endif
        }

        void unlock() noexcept
        { 
        #if !THINSQLITEPP_NO_MUTEX
            sqlite3_mutex_leave(c_ptr());
        #endif
        }
    };



    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
        { 
        #if !THINSQLITEPP_NO_MUTEX
            sqlite3_mutex_enter(c_ptr(_mutex));
        #endif
        }

        bool try_lock() noexcept
        { 
        #if !THINSQLITEPP_NO_MUTEX
            return sqlite3_mutex_try(c_ptr(_mutex)) == SQLITE_OK;
        #else
            return true;
        #endif
        }

        void unlock() noexcept
        { 
        #if !THINSQLITEPP_NO_MUTEX
            sqlite3_mutex_leave(c_ptr(_mutex));
        #endif
        }
    private:
        mutex * _mutex;
    };

}
 
#endif