AbstractMutex.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/Utilities/AbstractMutex.h>

#include <fesa-core/Utilities/StringUtilities.h>
#include <fesa-core/Exception/FesaException.h>

#include <cmw-log/Logger.h>


namespace
{

CMW::Log::Logger& logger = CMW::Log::LoggerFactory::getLogger("FESA.FWK.fesa-core.Utilities.AbstractMutex");

} // namespace


namespace fesa
{

AbstractMutex::~AbstractMutex()
{
    int32_t err = pthread_mutex_destroy(lock_);
    if (err != 0)
    {
        std::string errorStr("An error occurred while destroying mutex");
        LOG_ERROR_IF(logger, errorStr);
    }
    if (memoryOwner_ == true)
    {
        delete lock_;
    }
}

void AbstractMutex::lock()
{
    int32_t err = pthread_mutex_lock(lock_);
    if (err != 0)
    {
        std::string errorStr("An error occurred while locking mutex");
        LOG_ERROR_IF(logger, errorStr);
    }
}

void AbstractMutex::unlock()
{
    int32_t err = pthread_mutex_unlock(lock_);
    if (err != 0)
    {
        std::string errorStr("An error occurred while unlocking mutex");
        LOG_ERROR_IF(logger, errorStr);
    }
}

int32_t AbstractMutex::getSize()
{
    return sizeof(pthread_mutex_t);
}

void AbstractMutex::init(int32_t processShared)
{
    std::string errorNumber("");

    pthread_mutexattr_t mutexAttr;
    // initialize the mutex attribute
    int32_t err = pthread_mutexattr_init(&mutexAttr);
    if (err != 0)
    {
        errorNumber = StringUtilities::toString(err);
        throw FesaException(__FILE__, __LINE__, FesaErrorInitializingMutexAttribute.c_str(), errorNumber.c_str());
    }

    // set mutex to PTHREAD_PROCESS_PRIVATE
    err = pthread_mutexattr_setpshared(&mutexAttr, processShared);
    if (err != 0)
    {
        errorNumber = StringUtilities::toString(err);
        throw FesaException(__FILE__, __LINE__, FesaErrorSettingPrivateMutexAttribute.c_str(), errorNumber.c_str());
    }

    // initialize the mutex
    err = pthread_mutex_init(lock_, &mutexAttr);
    if (err != 0)
    {
        errorNumber = StringUtilities::toString(err);
        throw FesaException(__FILE__, __LINE__, FesaErrorInitializingMutex.c_str(), errorNumber.c_str());
    }

    // destroy mutex attribute
    err = pthread_mutexattr_destroy(&mutexAttr);
    if (err != 0)
    {
        errorNumber = StringUtilities::toString(err);
        throw FesaException(__FILE__, __LINE__, FesaErrorDestroyingMutexAttribute.c_str(), errorNumber.c_str());
    }
}

} // fesa