source: libcf/trunk/src/cf_mutex.c@ 126

/**
 * \file    cf_mutex.c
 * \author  myusgun <myusgun@gmail.com>
 *
 * \brief 뮤텍스 구현
 */
#include "cf_mutex.h"
#include "cf_local.h"
#include "cf_error.h"

#include <stdlib.h>

#if defined(_WIN32) || defined(_WIN64)
# include <windows.h>
# include <process.h>
# define MUTEX_TYPE     HANDLE
#else // #if defined(_WIN32) || defined(_WIN64)
# include <pthread.h>
# define MUTEX_TYPE     pthread_mutex_t
#endif // #if defined(_WIN32) || defined(_WIN64)

#define ASSERT_MUTEX_CTX(__ctx) \
    if (__ctx == NULL)          \
        return CF_ERROR_MUTEX_INVALID_CTX

typedef struct __cf_ctx_ctx__
{
    MUTEX_TYPE  mid;
} CF_MUTEX_CTX;

static int
CF_Mutex_Local_Close (MUTEX_TYPE mid)
{
#if defined(_WIN32) || defined(_WIN64)
    if (mid == NULL)
        return CF_ERROR_MUTEX_INVALID_ARGS;

    CloseHandle (mid);
#else
    pthread_mutex_destroy (&mid);
#endif

    return CF_OK;
}

/**
 * 뮤텍스 컨텍스트를 생성
 *
 * \return 성공 시, CF_OK; 실패 시, 오류 코드
 *
 * \param ctx 뮤텍스 컨텍스트 주소
 */
int
CF_Mutex_CreateCtx (CF_Mutex_Ctx * ctx)
{
    int result = 0;

    CF_MUTEX_CTX * context = NULL;

    context = (CF_MUTEX_CTX *) calloc (sizeof (CF_MUTEX_CTX), 1);
    if (context == NULL)
        return CF_ERROR_MUTEX_CREATE_CTX;

    TRY
    {
#if defined(_WIN32) || defined(_WIN64)
        context->mid = CreateMutexA (NULL, FALSE, NULL);
        if (context->mid == NULL)
        {
            result = CF_ERROR_MUTEX_CREATE;
            TRY_BREAK;
        }
#else
        result = pthread_mutex_init (&context->mid, NULL);
        if (result)
        {
            result = CF_ERROR_MUTEX_CREATE;
            TRY_BREAK;
        }
#endif

        *ctx = context;
    }
    CATCH_IF (result < 0)
    {
        CF_Mutex_DestoryCtx ((CF_Mutex_Ctx) context);
    }

    return result;
}

/**
 * 뮤텍스 컨텍스트 해제
 *
 * \return 성공 시, CF_OK; 실패 시, 오류 코드
 *
 * \param ctx 뮤텍스 컨텍스트
 */
int
CF_Mutex_DestoryCtx (CF_Mutex_Ctx ctx)
{
    CF_MUTEX_CTX * context = ctx;

    ASSERT_MUTEX_CTX (ctx);

    CF_Mutex_Local_Close (context->mid);
    free (context);

    return CF_OK;
}

/**
 * 뮤텍스 잠금
 *
 * \return 성공 시, CF_OK; 실패 시, 오류 코드
 *
 * \param ctx 뮤텍스 컨텍스트
 */
int
CF_Mutex_Lock (CF_Mutex_Ctx ctx)
{
    CF_MUTEX_CTX * context = ctx;

    ASSERT_MUTEX_CTX (ctx);

#if defined(_WIN32) || defined(_WIN64)
    WaitForSingleObject (context->mid, INFINITE);
#else
    pthread_mutex_lock (&context->mid);
#endif

    return CF_OK;
}

/**
 * 뮤텍스 잠금 해제
 *
 * \return 성공 시, CF_OK; 실패 시, 오류 코드
 *
 * \param ctx 뮤텍스 컨텍스트
 */
int
CF_Mutex_Unlock (CF_Mutex_Ctx ctx)
{
    CF_MUTEX_CTX * context = ctx;

    ASSERT_MUTEX_CTX (ctx);

#if defined(_WIN32) || defined(_WIN64)
    ReleaseMutex (context->mid);
#else
    pthread_mutex_unlock (&context->mid);
#endif

    return CF_OK;
}