gw-semaphore.h File Reference

Go to the source code of this file.

Typedefs
typedef struct Semaphore	Semaphore

Functions
Semaphore *	semaphore_create (long n)
void	semaphore_destroy (Semaphore *semaphore)
void	semaphore_up (Semaphore *semaphore)
void	semaphore_down (Semaphore *semaphore)
long	semaphore_getvalue (Semaphore *semaphore)

Typedef Documentation

Semaphore

typedef struct Semaphore Semaphore

Definition at line 68 of file gw-semaphore.h.

Function Documentation

semaphore_create()

Semaphore* semaphore_create

(

long

n

)

Definition at line 81 of file gw-semaphore.c.

References gwlist_add_producer(), gwlist_create, gwlist_produce(), Semaphore::list, and panic.

Referenced by httpd_emu_create(), init_smsbox(), run_smsbox(), smpp_emu(), smsc_emu_create(), and smsc_http_create().

{
    Semaphore *semaphore;
#ifndef HAVE_SEMAPHORE
    static char item;
#endif
    
    semaphore = gw_malloc(sizeof(*semaphore));

#ifdef HAVE_SEMAPHORE
    if (sem_init(&semaphore->sem, 0, (unsigned int) n) != 0)
        panic(errno, "Could not initialize semaphore.");
#else
    semaphore->list = gwlist_create();
    gwlist_add_producer(semaphore->list);
    while (n-- > 0)
    gwlist_produce(semaphore->list, &item);
#endif

    return semaphore;
}

semaphore_destroy()

void semaphore_destroy

(

Semaphore *

semaphore

)

Definition at line 104 of file gw-semaphore.c.

References gwlist_destroy(), Semaphore::list, and panic.

Referenced by conndata_destroy(), httpd_emu_create(), main(), run_smsbox(), smpp_emu(), and smsc_emu_create().

{
    if (semaphore != NULL) {
#ifdef HAVE_SEMAPHORE
        if (sem_destroy(&semaphore->sem) != 0)
            panic(errno, "Destroying semaphore while some threads are waiting.");
#else
    gwlist_destroy(semaphore->list, NULL);
#endif
    gw_free(semaphore);
    }
}

semaphore_down()

void semaphore_down

(

Semaphore *

semaphore

)

Definition at line 132 of file gw-semaphore.c.

References gw_assert(), gwlist_consume(), and Semaphore::list.

Referenced by boxc_sent_push(), httpd_emu_create(), httpsmsc_sender(), obey_request(), smpp_emu_writer(), and smsc_emu_create().

{
    gw_assert(semaphore != NULL);
#ifdef HAVE_SEMAPHORE
    sem_wait(&semaphore->sem);
#else
    gwlist_consume(semaphore->list);
#endif
}

semaphore_getvalue()

long semaphore_getvalue

(

Semaphore *

semaphore

)

Definition at line 143 of file gw-semaphore.c.

References gw_assert(), gwlist_len(), Semaphore::list, and panic.

{
    gw_assert(semaphore != NULL);
#ifdef HAVE_SEMAPHORE
    {
        int val;
        if (sem_getvalue(&semaphore->sem, &val) != 0)
            panic(errno, "Could not get semaphore value.");
        return val;
    }
#else
    return gwlist_len(semaphore->list);
#endif
}

semaphore_up()

void semaphore_up

(

Semaphore *

semaphore

)

Definition at line 118 of file gw-semaphore.c.

References error(), gw_assert(), gwlist_produce(), and Semaphore::list.

Referenced by boxc_sent_pop(), httpd_emu(), httpsmsc_send_cb(), httpsmsc_sender(), obey_request(), run_smsbox(), smpp_emu(), smpp_emu_handle_pdu(), and url_result_thread().

{
#ifndef HAVE_SEMAPHORE
    static char item;
    gw_assert(semaphore != NULL);
    gwlist_produce(semaphore->list, &item);
#else
    gw_assert(semaphore != NULL);
    if (sem_post(&semaphore->sem) != 0)
        error(errno, "Value for semaphore is out of range.");
#endif
}