gw-rwlock.h File Reference

#include "gw-config.h"
#include "list.h"

Go to the source code of this file.

Data Structures
struct	RWLock

Functions
RWLock *	gw_rwlock_create (void)
void	gw_rwlock_init_static (RWLock *lock)
void	gw_rwlock_destroy (RWLock *lock)
int	gw_rwlock_rdlock (RWLock *lock)
int	gw_rwlock_unlock (RWLock *lock)
int	gw_rwlock_wrlock (RWLock *lock)

Function Documentation

gw_rwlock_create()

RWLock* gw_rwlock_create

(

void

)

Definition at line 77 of file gw-rwlock.c.

References RWLock::dynamic, gwlist_create, panic, RWLock::rwlock, and RWLock::writer.

Referenced by load_create_real(), and smsbox_start().

{
    RWLock *ret = gw_malloc(sizeof(*ret));
#ifdef HAVE_PTHREAD_RWLOCK
    int rc = pthread_rwlock_init(&ret->rwlock, NULL);
    if (rc != 0)
        panic(rc, "Initialization of RWLock failed.");
#else
    ret->writer = -1;
    ret->rwlock = gwlist_create();
    if (ret->rwlock == NULL)
        panic(0, "Initialization of RWLock failed.");
#endif
    ret->dynamic = 1;

    return ret;
}

gw_rwlock_destroy()

void gw_rwlock_destroy

(

RWLock *

lock

)

Definition at line 112 of file gw-rwlock.c.

References gwlist_destroy(), lock, and panic.

Referenced by dlr_mem_shutdown(), load_destroy(), log_shutdown(), smsboxc_run(), and smsc2_cleanup().

{
#ifdef HAVE_PTHREAD_RWLOCK
    int ret;
#endif

    if (!lock)
        return;

#ifdef HAVE_PTHREAD_RWLOCK
    ret = pthread_rwlock_destroy(&lock->rwlock);
    if (ret != 0)
        panic(ret, "Attempt to destroy locked rwlock.");
#else
    gwlist_destroy(lock->rwlock, NULL);
#endif

    if (lock->dynamic)
        gw_free(lock);
}

gw_rwlock_init_static()

void gw_rwlock_init_static

(

RWLock *

lock

)

Definition at line 96 of file gw-rwlock.c.

References gwlist_create, lock, and panic.

Referenced by dlr_init_mem(), log_init(), and smsc2_start().

{
#ifdef HAVE_PTHREAD_RWLOCK
    int rc = pthread_rwlock_init(&lock->rwlock, NULL);
    if (rc != 0)
        panic(rc, "Initialization of RWLock failed.");
#else
    lock->writer = -1;
    lock->rwlock = gwlist_create();
    if (lock->rwlock == NULL)
        panic(0, "Initialization of RWLock failed.");
#endif
    lock->dynamic = 0;
}

gw_rwlock_rdlock()

int gw_rwlock_rdlock

(

RWLock *

lock

)

Definition at line 134 of file gw-rwlock.c.

References gw_assert(), gwlist_add_producer(), gwlist_lock(), gwlist_unlock(), lock, panic, and RWDEBUG.

Referenced by bb_smscconn_receive(), boxc_status(), concat_handling_clear_old_parts(), dlr_mem_get(), load_get(), load_len(), route_incoming_to_boxc(), sms_to_smsboxes(), smsc2_resume(), smsc2_rout(), smsc2_shutdown(), smsc2_status(), smsc2_stop_smsc(), and smsc2_suspend().

{
    int ret = 0;
    gw_assert(lock != NULL);

#ifdef HAVE_PTHREAD_RWLOCK
    ret = pthread_rwlock_rdlock(&lock->rwlock);
    if (ret != 0) {
        panic(ret, "Error while pthread_rwlock_rdlock.");
    }
#else
    gwlist_lock(lock->rwlock);
    gwlist_add_producer(lock->rwlock);
    gwlist_unlock(lock->rwlock);
    RWDEBUG("", 0, "------------ gw_rwlock_rdlock(%p) ----------", lock);
#endif

    return ret;
}

gw_rwlock_unlock()

int gw_rwlock_unlock

(

RWLock *

lock

)

Definition at line 155 of file gw-rwlock.c.

References gw_assert(), gwlist_remove_producer(), gwlist_unlock(), gwthread_self(), lock, panic, and RWDEBUG.

Referenced by bb_smscconn_receive(), boxc_status(), concat_handling_clear_old_parts(), dlr_mem_add(), dlr_mem_flush(), dlr_mem_get(), dlr_mem_remove(), dlr_mem_shutdown(), load_add_interval(), load_get(), load_increase_with(), load_len(), log_close_all(), log_open(), log_reopen(), route_incoming_to_boxc(), run_smsbox(), sms_to_smsboxes(), smsbox_restart(), smsc2_add_smsc(), smsc2_cleanup(), smsc2_graceful_restart(), smsc2_reload_lists(), smsc2_remove_smsc(), smsc2_restart_smsc(), smsc2_resume(), smsc2_rout(), smsc2_shutdown(), smsc2_status(), smsc2_stop_smsc(), and smsc2_suspend().

{
    int ret = 0;
    gw_assert(lock != NULL);

#ifdef HAVE_PTHREAD_RWLOCK
    ret = pthread_rwlock_unlock(&lock->rwlock);
    if (ret != 0)
        panic(ret, "Error while gw_rwlock_unlock.");
#else
    RWDEBUG("", 0, "------------ gw_rwlock_unlock(%p) ----------", lock);
    if (lock->writer == gwthread_self()) {
        lock->writer = -1;
        gwlist_unlock(lock->rwlock);
    } else 
        gwlist_remove_producer(lock->rwlock);
#endif

    return ret;
}

gw_rwlock_wrlock()

int gw_rwlock_wrlock

(

RWLock *

lock

)

Definition at line 177 of file gw-rwlock.c.

References gw_assert(), gwlist_consume(), gwlist_lock(), gwlist_producer_count(), gwthread_self(), lock, panic, and RWDEBUG.

Referenced by dlr_mem_add(), dlr_mem_flush(), dlr_mem_remove(), dlr_mem_shutdown(), load_add_interval(), load_increase_with(), log_close_all(), log_open(), log_reopen(), run_smsbox(), smsbox_restart(), smsc2_add_smsc(), smsc2_cleanup(), smsc2_graceful_restart(), smsc2_reload_lists(), smsc2_remove_smsc(), and smsc2_restart_smsc().

{
    int ret = 0;
    gw_assert(lock != NULL);

#ifdef HAVE_PTHREAD_RWLOCK
    ret = pthread_rwlock_wrlock(&lock->rwlock);
    if (ret != 0)
        panic(ret, "Error while pthread_rwlock_wrlock.");
#else
    RWDEBUG("", 0, "------------ gw_rwlock_wrlock(%p) ----------", lock);
    gwlist_lock(lock->rwlock);
    RWDEBUG("", 0, "------------ gw_rwlock_wrlock(%p) producers=%d", lock, gwlist_producer_count(lock->rwlock));
    /* wait for reader */
    gwlist_consume(lock->rwlock);
    lock->writer = gwthread_self();
#endif

    return ret;
}