thread.c File Reference

#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <errno.h>
#include <unistd.h>
#include "gwlib/gwlib.h"

Go to the source code of this file.

Functions
Mutex *	mutex_create_real (void)
Mutex *	mutex_init_static_real (Mutex *mutex)
void	mutex_destroy (Mutex *mutex)
void	mutex_lock_real (Mutex *mutex, char *file, int line, const char *func)
int	mutex_unlock_real (Mutex *mutex, char *file, int line, const char *func)
int	mutex_trylock_real (Mutex *mutex, const char *file, int line, const char *func)

Function Documentation

mutex_create_real()

Mutex* mutex_create_real

(

void

)

Definition at line 78 of file thread.c.

References Mutex::dynamic, Mutex::mutex, mutex, and Mutex::owner.

{
    Mutex *mutex;

    mutex = gw_malloc(sizeof(Mutex));
    pthread_mutex_init(&mutex->mutex, NULL);
    mutex->owner = -1;
    mutex->dynamic = 1;
    return mutex;
}

mutex_destroy()

void mutex_destroy

(

Mutex *

mutex

)

Definition at line 97 of file thread.c.

References Mutex::dynamic, info(), Mutex::mutex, mutex, and panic.

Referenced by bearerbox_address_destroy(), client_shutdown(), concat_handling_cleanup(), conn_destroy(), conn_pool_shutdown(), counter_destroy(), dict_destroy(), gw_check_shutdown(), gw_prioqueue_destroy(), gw_timerset_destroy(), gw_timerset_elapsed_destroy(), gwlib_protected_shutdown(), gwlist_destroy(), main(), octstr_shutdown(), port_shutdown(), proxy_shutdown(), radius_acct_shutdown(), server_shutdown(), smscconn_destroy(), smscenter_destruct(), smscwrapper_destroy(), store_dumper(), and timers_shutdown().

{
    int ret;

    if (mutex == NULL)
        return;

#ifdef MUTEX_STATS
    if (mutex->locks > 0 || mutex->collisions > 0) {
        info(0, "Mutex %s:%d: %ld locks, %ld collisions.",
             mutex->filename, mutex->lineno,
             mutex->locks, mutex->collisions);
    }
#endif

    if ((ret = pthread_mutex_destroy(&mutex->mutex)) != 0)
        panic(ret, "Attempt to destroy locked mutex!");

    if (mutex->dynamic == 0)
        return;
    gw_free(mutex);
}

mutex_init_static_real()

Mutex* mutex_init_static_real

(

Mutex *

mutex

)

Definition at line 89 of file thread.c.

References Mutex::dynamic, Mutex::mutex, mutex, and Mutex::owner.

{
    pthread_mutex_init(&mutex->mutex, NULL);
    mutex->owner = -1;
    mutex->dynamic = 0;
    return mutex;
}

mutex_lock_real()

void mutex_lock_real	(	Mutex *	mutex,
		char *	file,
		int	line,
		const char *	func
	)

Definition at line 121 of file thread.c.

References file, gw_assert(), gwthread_self(), Mutex::mutex, mutex, Mutex::owner, and panic.

{
    int ret;

    gw_assert(mutex != NULL);

#ifdef MUTEX_STATS
    ret = pthread_mutex_trylock(&mutex->mutex);
    if (ret != 0) {
        ret = pthread_mutex_lock(&mutex->mutex);
        mutex->collisions++;
    }
    mutex->locks++;
#else
    ret = pthread_mutex_lock(&mutex->mutex);
#endif
    if (ret != 0)
        panic(0, "%s:%ld: %s: Mutex failure! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);
    if (mutex->owner == gwthread_self())
        panic(0, "%s:%ld: %s: Managed to lock the mutex twice! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);
    mutex->owner = gwthread_self();
}

mutex_trylock_real()

int mutex_trylock_real	(	Mutex *	mutex,
		const char *	file,
		int	line,
		const char *	func
	)

Definition at line 165 of file thread.c.

References error(), file, gwthread_self(), Mutex::mutex, mutex, Mutex::owner, and panic.

{
    int ret;

    if (mutex == NULL) {
        error(0, "%s:%ld: %s: Trying to lock a NULL mutex! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);
        return -1;
    }

    ret = pthread_mutex_trylock(&mutex->mutex);
    if (ret == 0) {
        if (mutex->owner == gwthread_self())
            panic(0, "%s:%ld: %s: Managed to lock the mutex twice! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);

        mutex->owner = gwthread_self();
    }
    else if (ret == EINVAL)
        panic(0, "%s:%ld: %s: Mutex failure! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);

    return ret;
}

mutex_unlock_real()

int mutex_unlock_real	(	Mutex *	mutex,
		char *	file,
		int	line,
		const char *	func
	)

Definition at line 146 of file thread.c.

References error(), file, gw_assert(), Mutex::mutex, mutex, Mutex::owner, and panic.

{
     int ret;
    
    if (mutex == NULL) {
        error(0, "%s:%ld: %s: Trying to unlock a NULL mutex! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);
       return -1;
    }
    gw_assert(mutex != NULL);
    mutex->owner = -1;
    ret = pthread_mutex_unlock(&mutex->mutex);
    if (ret != 0)
        panic(0, "%s:%ld: %s: Mutex failure! (Called from %s:%ld:%s.)", \
                 __FILE__, (long) __LINE__, __func__, file, (long) line, func);

    return ret;
}