thread_sem.c File Reference

#include "thread.h"

Go to the source code of this file.

Macros
#define	RZ_SEM_NAMED_ONLY   0

Functions
RZ_API RZ_OWN RzThreadSemaphore *	rz_th_sem_new (unsigned int initial)
	Allocates and initialize a RzThreadSemaphore structure. More...
RZ_API void	rz_th_sem_free (RZ_NULLABLE RzThreadSemaphore *sem)
	Frees a RzThreadSemaphore struct. More...
RZ_API void	rz_th_sem_post (RZ_NONNULL RzThreadSemaphore *sem)
	increments (releases) a semaphore More...
RZ_API void	rz_th_sem_wait (RZ_NONNULL RzThreadSemaphore *sem)
	Decrements (acquires) the semaphore (waits indefinetely) More...

Macro Definition Documentation

RZ_SEM_NAMED_ONLY

#define RZ_SEM_NAMED_ONLY   0

Definition at line 11 of file thread_sem.c.

Function Documentation

rz_th_sem_free()

RZ_API void rz_th_sem_free

(

RZ_NULLABLE RzThreadSemaphore *

sem

)

Frees a RzThreadSemaphore struct.

Parameters

sem	The RzThreadSemaphore to free

Definition at line 73 of file thread_sem.c.

                                                               {
    if (!sem) {
        return;
    }
#if HAVE_PTHREAD
    if (sem->sem) {
#if RZ_SEM_NAMED_ONLY
        sem_close(sem->sem);
#else
        sem_destroy(sem->sem);
        free(sem->sem);
#endif
    }
#elif __WINDOWS__
    CloseHandle(sem->sem);
#endif
    free(sem);
}

References free(), and sem_destroy().

Referenced by task_free().

rz_th_sem_new()

RZ_API RZ_OWN RzThreadSemaphore* rz_th_sem_new

(

unsigned int

initial

)

Allocates and initialize a RzThreadSemaphore structure.

Parameters

initial

The initial status of the semaphore

Returns

On success returns a valid RzThreadSemaphore pointer, otherwise NULL

Definition at line 26 of file thread_sem.c.

                                                                     {
    RzThreadSemaphore *sem = RZ_NEW(RzThreadSemaphore);
    if (!sem) {
        return NULL;
    }
#if HAVE_PTHREAD
#if RZ_SEM_NAMED_ONLY
    uuid_t uuid;
    uuid_generate(uuid);
    char name[38];
    name[0] = '/';
    uuid_unparse(uuid, name + 1);
    if (strlen(name) > RZ_SEM_NAME_LEN_MAX - 1) {
        name[RZ_SEM_NAME_LEN_MAX - 1] = '\0';
    }
    sem->sem = sem_open(name, O_CREAT | O_EXCL, S_IRUSR | S_IWUSR, initial);
    if (sem->sem == SEM_FAILED) {
        free(sem);
        return NULL;
    }
#else
    sem->sem = malloc(sizeof(sem_t));
    if (!sem->sem) {
        free(sem);
        return NULL;
    }
    if (sem_init(sem->sem, 0, initial) != 0) {
        free(sem->sem);
        free(sem);
        return NULL;
    }
#endif
#elif __WINDOWS__
    sem->sem = CreateSemaphore(NULL, (LONG)initial, ST32_MAX, NULL);
    if (!sem->sem) {
        free(sem);
        return NULL;
    }
#endif
    return sem;
}

References free(), LONG, malloc(), NULL, O_CREAT, O_EXCL, RZ_NEW, rz_th_sem_t::sem, sem_init(), and ST32_MAX.

Referenced by rz_core_task_enqueue().

rz_th_sem_post()

RZ_API void rz_th_sem_post

(

RZ_NONNULL RzThreadSemaphore *

sem

)

increments (releases) a semaphore

Parameters

sem	The RzThreadSemaphore to increment (release)

Definition at line 97 of file thread_sem.c.

                                                              {
    rz_return_if_fail(sem);
#if HAVE_PTHREAD
    sem_post(sem->sem);
#elif __WINDOWS__
    ReleaseSemaphore(sem->sem, 1, NULL);
#endif
}

References NULL, rz_return_if_fail, and sem_post().

Referenced by task_join(), and task_run_thread().

rz_th_sem_wait()

RZ_API void rz_th_sem_wait

(

RZ_NONNULL RzThreadSemaphore *

sem

)

Decrements (acquires) the semaphore (waits indefinetely)

Parameters

sem	The RzThreadSemaphore to decrement (acquire)

Definition at line 111 of file thread_sem.c.

                                                              {
    rz_return_if_fail(sem);
#if HAVE_PTHREAD
    sem_wait(sem->sem);
#elif __WINDOWS__
    WaitForSingleObject(sem->sem, INFINITE);
#endif
}

References rz_return_if_fail, and sem_wait().

Referenced by rz_core_task_enqueue(), and task_join().